/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License") +  you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.openmeetings.axis.services;

import org.apache.axis2.AxisFault;
import org.apache.openmeetings.OpenmeetingsVariables;
import org.apache.openmeetings.data.basic.AuthLevelUtil;
import org.apache.openmeetings.data.basic.SessiondataDao;
import org.apache.openmeetings.data.basic.dao.ServerDao;
import org.apache.openmeetings.data.user.UserManager;
import org.apache.openmeetings.persistence.beans.basic.Server;
import org.red5.logging.Red5LoggerFactory;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;

/**
 * This class provides method implementations necessary for OM to manage servers
 * participating in cluster.
 * 
 * @author solomax, sebawagner
 * @webservice ServerService
 * 
 */
public class ServerWebService {
	private static final Logger log = Red5LoggerFactory.getLogger(
			ServerWebService.class, OpenmeetingsVariables.webAppRootKey);

	@Autowired
	private SessiondataDao sessiondataDao;
	@Autowired
	private UserManager userManager;
	@Autowired
	private AuthLevelUtil authLevelUtil;
	@Autowired
	private ServerDao serversDao;

	/**
	 * Method to retrieve the list of the servers participating in cluster
	 * 
	 * @param SID
	 *            - session id to identify the user making request
	 * @param start
	 *            - server index to start with
	 * @param max
	 *            - Maximum server count
	 * @return The list of servers participating in cluster
	 */
	public Server[] getServers(String SID, int start, int max) throws AxisFault {
		log.debug("getServers enter");
		Long users_id = sessiondataDao.checkSession(SID);
		Long user_level = userManager.getUserLevelByID(users_id);

		if (authLevelUtil.checkWebServiceLevel(user_level)) {
			return serversDao.get(start, max).toArray(new Server[0]);
		} else {
			log.warn("Insuffisient permissions");
			return null;
		}
	}

	/**
	 * Method to retrieve the total count of the servers participating in
	 * cluster
	 * 
	 * @param SID
	 *            - session id to identify the user making request
	 * @return total count of the servers participating in cluster
	 */
	public int getServerCount(String SID) throws AxisFault {
		log.debug("getServerCount enter");
		Long users_id = sessiondataDao.checkSession(SID);
		Long user_level = userManager.getUserLevelByID(users_id);

		if (authLevelUtil.checkWebServiceLevel(user_level)) {
			return (int) serversDao.count();
		} else {
			log.warn("Insuffisient permissions");
			return -1;
		}
	}

	/**
	 * Method to add/update server
	 * 
	 * @param SID
	 *            - session id to identify the user making request
	 * @param id
	 *            - the id of the server to save
	 * @param name
	 *            - the name of the server to save
	 * @param address
	 *            - the address(DNS name or IP) of the server to save
	 * @param port
	 *            - the http port of the slave
	 * @param user
	 *            - REST user to access the slave
	 * @param pass
	 *            - REST pass to access the slave
	 * @param webapp
	 *            - webapp name of the OpenMeetings instance
	 * @param protocol
	 *            - protocol to access the OpenMeetings instance
	 * @param active
	 *            - if the server currently participates in the cluster or not
	 * @param comment
	 *            - comment for the server
	 * @return the id of saved server
	 */
	public long saveServer(String SID, long id, String name, String address,
			int port, String user, String pass, String webapp, String protocol,
			Boolean active, String comment) throws AxisFault {
		log.debug("saveServerCount enter");
		Long users_id = sessiondataDao.checkSession(SID);
		Long user_level = userManager.getUserLevelByID(users_id);

		if (authLevelUtil.checkWebServiceLevel(user_level)) {
			Server s = serversDao.get(id);
			if (s == null) {
				s = new Server();
			}
			s.setName(name);
			s.setAddress(address);
			s.setPort(port);
			s.setUser(user);
			s.setPass(pass);
			s.setWebapp(webapp);
			s.setProtocol(protocol);
			s.setActive(active);
			s.setComment(comment);
			return serversDao.update(s, users_id).getId();
		} else {
			log.warn("Insuffisient permissions");
			return -1;
		}
	}

	/**
	 * Method to delete server
	 * 
	 * @param SID
	 *            - session id to identify the user making request
	 * @param id
	 *            - the id of the server to delete
	 * @return true if the server was deleted, false otherwise
	 */
	public boolean deleteServer(String SID, long id) throws AxisFault {
		log.debug("saveServerCount enter");
		Long users_id = sessiondataDao.checkSession(SID);
		Long user_level = userManager.getUserLevelByID(users_id);

		if (authLevelUtil.checkWebServiceLevel(user_level)) {
			Server s = serversDao.get(id);
			if (s != null) {
				serversDao.delete(s, users_id);
				return true;
			}
		} else {
			log.warn("Insuffisient permissions");
		}
		return false;
	}

}