package fr.ifremer.quadrige3.synchro.intercept;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Synchro Core
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2017 Ifremer
   * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU Affero General Public License as published by
   * the Free Software Foundation, either version 3 of the License, or
   * (at your option) any later version.
   * 
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   * 
   * You should have received a copy of the GNU Affero General Public License
   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
   * #L%
   */
  
  import com.google.common.collect.ImmutableSet;
  import fr.ifremer.common.synchro.intercept.SynchroInterceptorBase;
  import fr.ifremer.common.synchro.meta.SynchroDatabaseMetadata;
  import fr.ifremer.common.synchro.service.SynchroDatabaseConfiguration;
  import fr.ifremer.quadrige3.core.dao.technical.Assert;
  import fr.ifremer.quadrige3.synchro.service.AbstractSynchroDatabaseConfiguration;
  import fr.ifremer.quadrige3.synchro.service.SynchroDirection;
  import org.hibernate.tool.hbm2ddl.TableMetadata;
  
  import java.util.Arrays;
  import java.util.Set;
  import java.util.stream.Collectors;
  
  /**
   * <p>
   * Abstract AbstractSynchroInterceptor class.
   * </p>
   * 
   */
  public abstract class AbstractSynchroInterceptor<T extends AbstractSynchroDatabaseConfiguration> extends SynchroInterceptorBase {
  
  	private SynchroDatabaseMetadata meta;
  	private Integer userId;
  	private Set<SynchroDirection> allowDirections;
  	private Set<String> allowTables;
  
  	/**
  	 * <p>
  	 * Constructor for AbstractSynchroInterceptor.
  	 * </p>
  	 */
  	public AbstractSynchroInterceptor() {
  		// All direction are allowed
  		this.allowDirections = null;
  		// All table are allowed
  		this.allowTables = null;
  	}
  
  	/**
  	 * <p>
  	 * Constructor for AbstractSynchroInterceptor.
  	 * </p>
  	 * 
  	 * @param directions
  	 *            a {@link fr.ifremer.quadrige3.synchro.service.SynchroDirection} object.
  	 */
  	public AbstractSynchroInterceptor(SynchroDirection... directions) {
  		Assert.notEmpty(directions);
  
  		// Fill allowed directions
  		this.allowDirections = ImmutableSet.copyOf(directions);
  		// All table are allowed
  		this.allowTables = null;
  	}
  
  	/**
  	 * <p>
  	 * Constructor for AbstractSynchroInterceptor.
  	 * </p>
  	 * 
  	 * @param tableIncludes
  	 *            a {@link java.util.Set} object.
  	 * @param directions
  	 *            a {@link fr.ifremer.quadrige3.synchro.service.SynchroDirection} object.
  	 */
  	public AbstractSynchroInterceptor(Set<String> tableIncludes, SynchroDirection... directions) {
  		Assert.notEmpty(tableIncludes);
  		Assert.notEmpty(directions);
  
  		this.allowTables = ImmutableSet.copyOf(tableIncludes.stream().map(String::toUpperCase).collect(Collectors.toSet()));
  
  		// Fill allowed directions
  		this.allowDirections = ImmutableSet.copyOf(directions);
  	}
 
 	/**
 	 * <p>
 	 * Constructor for AbstractSynchroInterceptor.
 	 * </p>
 	 * 
 	 * @param tableIncludes
 	 *            a {@link java.util.Set} object.
 	 */
 	public AbstractSynchroInterceptor(Set<String> tableIncludes) {
 		Assert.notEmpty(tableIncludes);
 
 		this.allowTables = ImmutableSet.copyOf(tableIncludes.stream().map(String::toUpperCase).collect(Collectors.toSet()));
 
 		// All direction are allowed
 		this.allowDirections = null;
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public SynchroInterceptorBase clone() {
 		AbstractSynchroInterceptor result = (AbstractSynchroInterceptor) super.clone();
 		result.meta = this.meta;
 		result.userId = this.userId;
 		result.allowDirections = allowDirections;
 		result.allowTables = allowTables;
 		return result;
 	}
 
 	/** {@inheritDoc} */
 	@SuppressWarnings("unchecked")
 	@Override
 	public final boolean apply(SynchroDatabaseConfiguration config) {
 		boolean result = getConfigClass().isInstance(config)
 				/* super is need to store the config into a field */
 				&& super.apply(config);
 
 		if (result) {
 			// Init the interceptor
 			init((T) config);
 		}
 		return result;
 	}
 
 	/**
 	 * <p>
 	 * getConfigClass.
 	 * </p>
 	 * 
 	 * @return a {@link java.lang.Class} object.
 	 */
 	protected abstract Class<T> getConfigClass();
 
 	/** {@inheritDoc} */
 	@Override
 	public final boolean apply(SynchroDatabaseMetadata meta, TableMetadata table) {
 		Assert.notNull(meta);
 		if (this.meta != null) {
 			Assert.state(this.meta == meta, "this metadata should be the same as previous");
 		}
 
 		// Store meta and configuration
 		else {
 			this.meta = meta;
 
 			// Retrieve the user id
 			userId = getConfig().getUserId();
 		}
 
 		return (allowDirections == null || allowDirections.contains(getConfig().getDirection()))
 				&& (allowTables == null || allowTables.contains(table.getName().toUpperCase()))
 				&& doApply(meta, table);
 	}
 
 	/**
 	 * <p>
 	 * doApply.
 	 * </p>
 	 * 
 	 * @param meta
 	 *            a {@link fr.ifremer.common.synchro.meta.SynchroDatabaseMetadata} object.
 	 * @param table
 	 *            a {@link org.hibernate.tool.hbm2ddl.TableMetadata} object.
 	 * @return a boolean.
 	 */
 	public abstract boolean doApply(SynchroDatabaseMetadata meta, TableMetadata table);
 
 	/**
 	 * <p>
 	 * checkAndGetUserId.
 	 * </p>
 	 * 
 	 * @return a int.
 	 */
 	public int checkAndGetUserId() {
 		Assert.notNull(
 						userId,
 						String.format(
 								"Could not retrieve user id (in database configuration). %s need a not null userId.",
 								getClass().getSimpleName()
 								));
 		return userId;
 	}
 
 	/* -- delegate methods -- */
 
 	/**
 	 * <p>
 	 * getConfig.
 	 * </p>
 	 * 
 	 * @return a T object.
 	 */
 	@SuppressWarnings("unchecked")
 	public T getConfig() {
 		return (T) getDefaultDatabaseConfiguration();
 	}
 
 	/* -- internal methods -- */
 
 	/**
 	 * <p>
 	 * init.
 	 * </p>
 	 * 
 	 * @param config
 	 *            a T object.
 	 */
 	protected void init(T config) {
 		// could be override
 	}
 
 	/**
 	 * <p>
 	 * isInDirections.
 	 * </p>
 	 * 
 	 * @param allowDirections
 	 *            a {@link fr.ifremer.quadrige3.synchro.service.SynchroDirection} object.
 	 * @return a boolean.
 	 */
 	protected boolean isInDirections(SynchroDirection... allowDirections) {
 		return Arrays.asList(allowDirections).contains(getConfig().getDirection());
 	}
 }