/*
 * 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.openmeetings.app.data.basic;

import java.lang.reflect.Constructor;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;

import javax.persistence.EntityManager;
import javax.persistence.NoResultException;
import javax.persistence.PersistenceContext;
import javax.persistence.TypedQuery;
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;

import org.openmeetings.app.OpenmeetingsVariables;
import org.openmeetings.app.data.beans.basic.SearchResult;
import org.openmeetings.app.data.user.dao.UsersDaoImpl;
import org.openmeetings.app.persistence.beans.basic.Configuration;
import org.openmeetings.app.remote.red5.ScopeApplicationAdapter;
import org.openmeetings.utils.mappings.CastMapToObject;
import org.red5.logging.Red5LoggerFactory;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

@Transactional
public class Configurationmanagement {

	private static final Logger log = Red5LoggerFactory.getLogger(
			Configurationmanagement.class,
			OpenmeetingsVariables.webAppRootKey);

	public static final String DEFAULT_APP_NAME = "OpenMeetings";

	@PersistenceContext
	private EntityManager em;

	@Autowired
	private UsersDaoImpl usersDao;
	@Autowired
	private AuthLevelmanagement authLevelManagement;
	private String appName = null;

	public Configuration getConfKey(long user_level, String CONF_KEY) {
		try {
			if (authLevelManagement.checkUserLevel(user_level)) {
				TypedQuery<Configuration> query = em
						.createQuery(
								"select c from Configuration as c where c.conf_key = :conf_key and c.deleted = :deleted",
								Configuration.class);
				query.setParameter("conf_key", CONF_KEY);
				query.setParameter("deleted", "false");

				List<Configuration> configs = query.getResultList();

				if (configs != null && configs.size() > 0) {
					return configs.get(0);
				}
			} else {
				log.error("[getAllConf] Permission denied " + user_level);
			}
		} catch (Exception ex2) {
			log.error("[getConfKey]: ", ex2);
		}
		return null;
	}

	/**
	 * Return a object using a custom type and a default value if the key is not present
	 * 
	 * Example: Integer my_key = getConfValue("my_key", Integer.class, "15");
	 * 
	 * @param CONF_KEY
	 * @param typeObject
	 * @param defaultValue
	 * @return
	 */
	public <T> T getConfValue(String CONF_KEY, Class<T> typeObject,
			String defaultValue) {
		try {
			Configuration conf_reminder = getConfKey(3L, CONF_KEY);

			if (conf_reminder == null) {
				log.warn("Could not find key in configuration CONF_KEY: "
						+ CONF_KEY);
			} else {
				// Use the custom value as default value
				defaultValue = conf_reminder.getConf_value();
			}

			// Either this can be directly assigned or try to find a constructor
			// that handles it
			if (typeObject.isAssignableFrom(defaultValue.getClass())) {
				return typeObject.cast(defaultValue);
			}
			Constructor<T> c = typeObject.getConstructor(defaultValue
					.getClass());
			return c.newInstance(defaultValue);

		} catch (Exception err) {
			log.error(
					"cannot be cast to return type, you have misconfigured your configuration CONF_KEY: "
							+ CONF_KEY, err);
			return null;
		}
	}

	public Configuration getConfByConfigurationId(long user_level,
			long configuration_id) {
		try {
			log.debug("getConfByConfigurationId1: user_level " + user_level);
			if (authLevelManagement.checkAdminLevel(user_level)) {
				Configuration configuration = null;
				TypedQuery<Configuration> query = em
						.createQuery("select c from Configuration as c where c.configuration_id = :configuration_id", Configuration.class);
				query.setParameter("configuration_id", configuration_id);
				query.setMaxResults(1);
				try {
					configuration = query.getSingleResult();
				} catch (NoResultException e) {
				}
				log.debug("getConfByConfigurationId4: " + configuration);

				if (configuration != null && configuration.getUser_id() != null) {
					configuration.setUsers(usersDao.getUser(configuration
							.getUser_id()));
				}
				return configuration;
			} else {
				log.error("[getConfByConfigurationId] Permission denied "
						+ user_level);
			}
		} catch (Exception ex2) {
			log.error("[getConfByConfigurationId]: ", ex2);
		}
		return null;
	}

	public SearchResult<Configuration> getAllConf(long user_level, int start, int max,
			String orderby, boolean asc) {
		try {
			if (authLevelManagement.checkAdminLevel(user_level)) {
				SearchResult<Configuration> sresult = new SearchResult<Configuration>();
				sresult.setRecords(this.selectMaxFromConfigurations());
				sresult.setResult(this.getConfigurations(start, max, orderby,
						asc));
				sresult.setObjectName(Configuration.class.getName());
				return sresult;
			} else {
				log.error("[getAllConf] Permission denied " + user_level);
			}
		} catch (Exception ex2) {
			log.error("[getAllConf]: ", ex2);
		}
		return null;
	}

	public List<Configuration> getConfigurations(int start, int max,
			String orderby, boolean asc) {
		try {
			CriteriaBuilder cb = em.getCriteriaBuilder();
			CriteriaQuery<Configuration> cq = cb
					.createQuery(Configuration.class);
			Root<Configuration> c = cq.from(Configuration.class);
			Predicate condition = cb.equal(c.get("deleted"), "false");
			cq.where(condition);
			cq.distinct(asc);
			if (asc) {
				cq.orderBy(cb.asc(c.get(orderby)));
			} else {
				cq.orderBy(cb.desc(c.get(orderby)));
			}
			TypedQuery<Configuration> q = em.createQuery(cq);
			q.setFirstResult(start);
			q.setMaxResults(max);
			List<Configuration> ll = q.getResultList();
			return ll;
		} catch (Exception ex2) {
			log.error("[getConfigurations]", ex2);
		}
		return null;
	}

	/**
	 * 
	 * @return
	 */
	private Long selectMaxFromConfigurations() {
		try {
			log.debug("selectMaxFromConfigurations ");
			// get all users
			TypedQuery<Long> query = em
					.createQuery("select count(c.configuration_id) from Configuration c where c.deleted = 'false'", Long.class);
			List<Long> ll = query.getResultList();
			log.debug("selectMaxFromConfigurations" + ll.get(0));
			return ll.get(0);
		} catch (Exception ex2) {
			log.error("[selectMaxFromConfigurations] ", ex2);
		}
		return null;
	}

	public String addConfByKey(long user_level, String CONF_KEY,
			String CONF_VALUE, Long USER_ID, String comment) {
		String ret = "Add Configuration";
		if (authLevelManagement.checkAdminLevel(user_level)) {
			Configuration configuration = new Configuration();
			configuration.setConf_key(CONF_KEY);
			configuration.setConf_value(CONF_VALUE);
			configuration.setStarttime(new Date());
			configuration.setDeleted("false");
			configuration.setComment(comment);
			if (USER_ID != null)
				configuration.setUser_id(USER_ID);
			try {
				configuration = em.merge(configuration);
				ret = "Erfolgreich";
			} catch (Exception ex2) {
				log.error("[addConfByKey]: ", ex2);
			}
		} else {
			ret = "Error: Permission denied";
		}
		return ret;
	}

	public Long saveOrUpdateConfiguration(long user_level,
			LinkedHashMap<String, ?> values, Long users_id) {
		try {
			if (authLevelManagement.checkAdminLevel(user_level)) {
				Configuration conf = (Configuration) CastMapToObject
						.getInstance().castByGivenObject(values,
								Configuration.class);
				if (conf.getConfiguration_id().equals(null)
						|| conf.getConfiguration_id() == 0) {
					log.info("add new Configuration");
					conf.setConfiguration_id(null);
					conf.setStarttime(new Date());
					conf.setDeleted("false");
					return this.addConfig(conf);
				} else {
					log.info("update Configuration ID: "
							+ conf.getConfiguration_id());
					Configuration conf2 = this.getConfByConfigurationId(3L,
							conf.getConfiguration_id());
					conf2.setComment(conf.getComment());
					conf2.setConf_key(conf.getConf_key());
					conf2.setConf_value(conf.getConf_value());
					conf2.setUser_id(users_id);
					conf2.setDeleted("false");
					conf2.setUpdatetime(new Date());
					return this.updateConfig(conf2);
				}
			} else {
				log.error("[saveOrUpdateConfByConfigurationId] Error: Permission denied");
				return new Long(-100);
			}
		} catch (Exception ex2) {
			log.error("[updateConfByUID]: ", ex2);
		}
		return new Long(-1);
	}

	public Long addConfig(Configuration conf) {
		try {
			conf = em.merge(conf);
			Long configuration_id = conf.getConfiguration_id();
			return configuration_id;
		} catch (Exception ex2) {
			log.error("[updateConfByUID]: ", ex2);
		}
		return new Long(-1);
	}

	public Long updateConfig(Configuration conf) {
		try {
			if (conf.getConfiguration_id() == null) {
				em.persist(conf);
			} else {
				if (!em.contains(conf)) {
					conf = em.merge(conf);
				}
			}
			if ("crypt_ClassName".equals(conf.getConf_key())) {
				ScopeApplicationAdapter.configKeyCryptClassName = conf.getConf_value();
			} else if ("show.whiteboard.draw.status".equals(conf.getConf_key())) {
				ScopeApplicationAdapter.whiteboardDrawStatus = "1".equals(conf.getConf_value());
			}
			return conf.getConfiguration_id();
		} catch (Exception ex2) {
			log.error("[updateConfByUID]: ", ex2);
		}
		return new Long(-1);
	}

	public Long deleteConfByConfiguration(long user_level,
			LinkedHashMap<String, ?> values, Long users_id) {
		try {
			if (authLevelManagement.checkAdminLevel(user_level)) {
				Configuration conf = (Configuration) CastMapToObject
						.getInstance().castByGivenObject(values,
								Configuration.class);
				conf.setUsers(usersDao.getUser(users_id));
				conf.setUpdatetime(new Date());
				conf.setDeleted("true");

				Configuration conf2 = this.getConfByConfigurationId(3L,
						conf.getConfiguration_id());
				conf2.setComment(conf.getComment());
				conf2.setConf_key(conf.getConf_key());
				conf2.setConf_value(conf.getConf_value());
				conf2.setUser_id(users_id);
				conf2.setDeleted("true");
				conf2.setUpdatetime(new Date());

				this.updateConfig(conf2);
				return new Long(1);
			} else {
				log.error("Error: Permission denied");
				return new Long(-100);
			}
		} catch (Exception ex2) {
			log.error("[deleteConfByUID]: ", ex2);
		}
		return new Long(-1);
	}

	public String getAppName() {
		if (appName == null) {
			appName = getConfValue("application.name", String.class, Configurationmanagement.DEFAULT_APP_NAME);
		}
		return appName;
	}
}