package fr.ifremer.quadrige2.synchro.intercept.data;
   
   /*-
    * #%L
    * Quadrige2 Core :: Quadrige2 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.base.Joiner;
  import com.google.common.collect.ImmutableList;
  import com.google.common.collect.Sets;
  import com.google.common.eventbus.Subscribe;
  import fr.ifremer.common.synchro.intercept.SynchroInterceptorBase;
  import fr.ifremer.common.synchro.meta.SynchroTableMetadata;
  import fr.ifremer.common.synchro.meta.event.CreateQueryEvent;
  import fr.ifremer.common.synchro.meta.event.LoadTableEvent;
  import fr.ifremer.common.synchro.query.SynchroQueryBuilder;
  import fr.ifremer.common.synchro.query.SynchroQueryOperator;
  import fr.ifremer.quadrige2.core.dao.ObjectTypes;
  import fr.ifremer.quadrige2.synchro.meta.DatabaseColumns;
  import fr.ifremer.quadrige2.synchro.meta.data.DataSynchroTables;
  import fr.ifremer.quadrige2.synchro.service.SynchroDirection;
  import org.apache.commons.collections4.CollectionUtils;
  
  import java.util.List;
  import java.util.Set;
  
  /**
   * Import DELETED_ITEM_HISTORY rows, limited to data tables
   * 
   * @author Benoit Lavenier <benoit.lavenier@e-is.pro>
   * @since 1.0
   */
  public class DeletedItemHistoryInterceptor extends AbstractDataInterceptor {
  
  	/** Constant <code>NATURAL_ID_COLUMNS</code> */
  	public static final List<String> NATURAL_ID_COLUMNS = ImmutableList.of(
  			DatabaseColumns.OBJECT_TYPE_CD.name(),
  			DatabaseColumns.OBJECT_ID.name(),
  			DatabaseColumns.OBJECT_CD.name());
  
  	private String whereClauseOnTableIncludes = null;
  
  	private String whereClauseForExportLocal2Temp = null;
  
  	/**
  	 * <p>
  	 * Constructor for DeletedItemHistoryInterceptor.
  	 * </p>
  	 */
  	public DeletedItemHistoryInterceptor() {
  
  		super(DataSynchroTables.DELETED_ITEM_HISTORY.name(),
  				// Exclude Temp -> Local (process in a special code)
  				SynchroDirection.IMPORT_SERVER2TEMP,
  				SynchroDirection.EXPORT_LOCAL2TEMP,
  				SynchroDirection.EXPORT_TEMP2SERVER);
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public SynchroInterceptorBase clone() {
  		DeletedItemHistoryInterceptor newBean = (DeletedItemHistoryInterceptor) super.clone();
  		newBean.whereClauseOnTableIncludes = this.whereClauseOnTableIncludes;
  		return newBean;
  	}
  
  	/**
  	 * <p>
  	 * handleCreateQuery.
  	 * </p>
  	 * 
  	 * @param e
  	 *            a {@link fr.ifremer.common.synchro.meta.event.CreateQueryEvent} object.
  	 */
  	@Subscribe
  	public void handleCreateQuery(CreateQueryEvent e) {
  		switch (e.queryName) {
  		case count:
  		case countFromUpdateDate:
  		case select:
  		case selectFromUpdateDate:
 		case selectMaxUpdateDate:
 			e.sql = addRestrictions(e.sql);
 			break;
 
 		default:
 			break;
 		}
 	}
 
 	/**
 	 * <p>
 	 * handleTableLoad.
 	 * </p>
 	 * 
 	 * @param e
 	 *            a {@link fr.ifremer.common.synchro.meta.event.LoadTableEvent} object.
 	 */
 	@Subscribe
 	public void handleTableLoad(LoadTableEvent e) {
 		SynchroTableMetadata table = e.table;
 		SynchroDirection direction = getConfig().getDirection();
 
 		// Do not import this table to local
 		boolean isRoot = isInDirections(SynchroDirection.IMPORT_SERVER2TEMP,
 				SynchroDirection.EXPORT_LOCAL2TEMP,
 				SynchroDirection.EXPORT_TEMP2SERVER);
 
 		e.table.setRoot(isRoot);
 
 		// Export: Temp DB -> Server DB
 		if (direction == SynchroDirection.EXPORT_TEMP2SERVER) {
 			// Define natural id, to avoid 2 rows inserted (because trigger will insert row also)
 			table.addUniqueConstraint("NATURAL_ID_UNIQUE_C", NATURAL_ID_COLUMNS, SynchroTableMetadata.DuplicateKeyStrategy.WARN);
 		}
 	}
 
 	/* -- Internal methods -- */
 
 	private String addRestrictions(String sql) {
 
 		SynchroQueryBuilder query = SynchroQueryBuilder.newBuilder(sql);
 
 		// Add limit on included tables
 		if (whereClauseOnTableIncludes == null) {
 			whereClauseOnTableIncludes = createWhereClauseOnTableIncludes();
 		}
 		query.addWhere(SynchroQueryOperator.AND, whereClauseOnTableIncludes);
 
 		// Export: only delete done by connected user, and not exported deletion
 		if (getConfig().getDirection() == SynchroDirection.EXPORT_LOCAL2TEMP) {
 			if (whereClauseForExportLocal2Temp == null) {
 				whereClauseForExportLocal2Temp = createWhereClauseForExportLocal2Temp();
 			}
 
 			query.addWhere(SynchroQueryOperator.AND, whereClauseForExportLocal2Temp);
 		}
 
 		return query.build();
 	}
 
 	private String createWhereClauseOnTableIncludes() {
 		Set<String> tableToIncludes = DataSynchroTables.getImportTablesIncludes();
 
 		// If no tables configured : should return no lines
 		if (CollectionUtils.isEmpty(tableToIncludes)) {
 			return "1=2";
 		}
 
 		Set<String> allObjectTypeCds = Sets.newHashSet();
 		for (String tableName : tableToIncludes) {
 			Set<String> objectTypeCds = ObjectTypes.getObjectTypeFromTableName(tableName);
 			if (CollectionUtils.isNotEmpty(objectTypeCds)) {
 				allObjectTypeCds.addAll(objectTypeCds);
 			}
 			else {
 				// By default, add the table name itself (i.e. PERSON_SESSION_VESSEL)
 				allObjectTypeCds.add(tableName);
 			}
 		}
 
 		// Remove itself
 		allObjectTypeCds.remove(DataSynchroTables.DELETED_ITEM_HISTORY.name());
 
 		return new StringBuilder()
 				.append(DatabaseColumns.OBJECT_TYPE_CD)
 				.append(" IN ('")
 				.append(Joiner.on("','").join(allObjectTypeCds))
 				.append("')")
 				.toString();
 	}
 
 	private String createWhereClauseForExportLocal2Temp() {
 
 		// mantis #22850 : do not limit to the recorder of the deletion
 		// Integer recorderPersonId = checkAndGetPersonId();
 		// return String.format("%s = %s AND %s is null",COLUMN_RECORDER_PERSON,recorderPersonId,COLUMN_REMOTE_ID);
 
 		return DatabaseColumns.REMOTE_ID.name() + " is null";
 	}
 }