package fr.ifremer.quadrige2.synchro.service.referential;
   
   /*-
    * #%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.Multimap;
  import fr.ifremer.common.synchro.config.SynchroConfiguration;
  import fr.ifremer.common.synchro.service.SynchroContext;
  import fr.ifremer.quadrige2.synchro.service.SynchroDirection;
  
  import java.io.File;
  import java.util.Set;
  
  /**
   * <p>
   * ReferentialSynchroContext class.
   * </p>
   * 
   */
  public class ReferentialSynchroContext extends SynchroContext {
  
  	private Integer userId;
  
  	private SynchroDirection direction;
  
  	/**
  	 * Need to process deletion ?
  	 */
  	protected boolean enableDelete = true;
  
  	/**
  	 * Need to process insert/update ?
  	 */
  	protected boolean enableInsertOrUpdate = true;
  
  	/**
  	 * List of status to inludes. If null, include all
  	 */
  	protected Set<String> statusCodeIncludes;
  
  	/**
  	 * Change log file, used to record all row operations (PKs for all insert/update/delete operations)
  	 */
  	protected File changeLogFile;
  
  	/**
  	 * List of program codes
  	 */
  	protected Set<String> programCodes;
  
  	/**
  	 * Map of table/PK to includes. Use to limit import on some data (e.g. after a revert on data)
  	 */
  	protected Multimap<String, String> pkIncludes;
  
  	/**
  	 * Table to import, without check table max(update_dt) in method 'prepare()'.
  	 * <p/>
  	 * Useful to import new program/strategy, when user rights changes, even if [update_dt < lastSynchroDate]
  	 */
  	protected Set<String> tableNamesForced;
  
  	/**
  	 * <p>
  	 * Constructor for ReferentialSynchroContext.
  	 * </p>
  	 */
  	public ReferentialSynchroContext() {
  		super();
  	}
  
  	/**
  	 * <p>
  	 * Constructor for ReferentialSynchroContext.
  	 * </p>
  	 * 
  	 * @param direction
  	 *            a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 * @param userId
 	 *            a {@link java.lang.Integer} object.
 	 */
 	public ReferentialSynchroContext(SynchroDirection direction, Integer userId) {
 		super();
 		this.userId = userId;
 		this.direction = direction;
 	}
 
 	/**
 	 * <p>
 	 * Constructor for ReferentialSynchroContext.
 	 * </p>
 	 * 
 	 * @param delegate
 	 *            a {@link fr.ifremer.common.synchro.service.SynchroContext} object.
 	 * @param direction
 	 *            a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 * @param userId
 	 *            a {@link java.lang.Integer} object.
 	 */
 	public ReferentialSynchroContext(SynchroContext delegate, SynchroDirection direction, Integer userId) {
 		super(delegate);
 		this.direction = direction;
 		this.userId = userId;
 	}
 
 	/**
 	 * <p>
 	 * isEnableDelete.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	public boolean isEnableDelete() {
 		return enableDelete;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>enableDelete</code>.
 	 * </p>
 	 * 
 	 * @param enableDelete
 	 *            a boolean.
 	 */
 	public void setEnableDelete(boolean enableDelete) {
 		this.enableDelete = enableDelete;
 	}
 
 	/**
 	 * <p>
 	 * isEnableInsertOrUpdate.
 	 * </p>
 	 * 
 	 * @return a boolean.
 	 */
 	public boolean isEnableInsertOrUpdate() {
 		return enableInsertOrUpdate;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>enableInsertOrUpdate</code>.
 	 * </p>
 	 * 
 	 * @param enableInsertOrUpdate
 	 *            a boolean.
 	 */
 	public void setEnableInsertOrUpdate(boolean enableInsertOrUpdate) {
 		this.enableInsertOrUpdate = enableInsertOrUpdate;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>statusCodeIncludes</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.util.Set} object.
 	 */
 	public Set<String> getStatusCodeIncludes() {
 		return statusCodeIncludes;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>statusCodeIncludes</code>.
 	 * </p>
 	 * 
 	 * @param statusCodeIncludes
 	 *            a {@link java.util.Set} object.
 	 */
 	public void setStatusCodeIncludes(Set<String> statusCodeIncludes) {
 		this.statusCodeIncludes = statusCodeIncludes;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>userId</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.lang.Integer} object.
 	 */
 	public Integer getUserId() {
 		return userId;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>userId</code>.
 	 * </p>
 	 * 
 	 * @param userId
 	 *            a {@link java.lang.Integer} object.
 	 */
 	public void setUserId(Integer userId) {
 		this.userId = userId;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>direction</code>.
 	 * </p>
 	 * 
 	 * @return a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 */
 	public SynchroDirection getDirection() {
 		return direction;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>direction</code>.
 	 * </p>
 	 * 
 	 * @param direction
 	 *            a {@link fr.ifremer.quadrige2.synchro.service.SynchroDirection} object.
 	 */
 	public void setDirection(SynchroDirection direction) {
 		this.direction = direction;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>pkIncludes</code>.
 	 * </p>
 	 * 
 	 * @return a {@link com.google.common.collect.Multimap} object.
 	 */
 	public Multimap<String, String> getPkIncludes() {
 		return pkIncludes;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>pkIncludes</code>.
 	 * </p>
 	 * 
 	 * @param pkIncludes
 	 *            a {@link com.google.common.collect.Multimap} object.
 	 */
 	public void setPkIncludes(Multimap<String, String> pkIncludes) {
 		this.pkIncludes = pkIncludes;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>changeLogFile</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.io.File} object.
 	 */
 	public File getChangeLogFile() {
 		return changeLogFile;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>changeLogFile</code>.
 	 * </p>
 	 * 
 	 * @param changeLogFile
 	 *            a {@link java.io.File} object.
 	 */
 	public void setChangeLogFile(File changeLogFile) {
 		this.changeLogFile = changeLogFile;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>programCodes</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.util.Set} object.
 	 */
 	public Set<String> getProgramCodes() {
 		return programCodes;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>programCodes</code>.
 	 * </p>
 	 * 
 	 * @param programCodes
 	 *            a {@link java.util.Set} object.
 	 */
 	public void setProgramCodes(Set<String> programCodes) {
 		this.programCodes = programCodes;
 	}
 
 	/**
 	 * <p>
 	 * Setter for the field <code>tableNamesForced</code>.
 	 * </p>
 	 * 
 	 * @param tableNamesForced
 	 *            a {@link java.util.Set} object.
 	 */
 	public void setTableNamesForced(Set<String> tableNamesForced) {
 		this.tableNamesForced = tableNamesForced;
 	}
 
 	/**
 	 * <p>
 	 * Getter for the field <code>tableNamesForced</code>.
 	 * </p>
 	 * 
 	 * @return a {@link java.util.Set} object.
 	 */
 	public Set<String> getTableNamesForced() {
 		return tableNamesForced;
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public void copy(SynchroContext otherBean) {
 		super.copy(otherBean);
 
 		SynchroConfiguration config = SynchroConfiguration.getInstance();
 		// Change database configuration class
 		if (otherBean.getTarget() != null) {
 			setTarget(new ReferentialSynchroDatabaseConfiguration(this, otherBean.getTarget()));
 		}
 		if (otherBean.getSource() != null) {
 			setSource(new ReferentialSynchroDatabaseConfiguration(this, otherBean.getSource()));
 		}
 
 		if (otherBean instanceof ReferentialSynchroContext) {
 			this.direction = ((ReferentialSynchroContext) otherBean).direction;
 			this.enableDelete = ((ReferentialSynchroContext) otherBean).enableDelete;
 			this.enableInsertOrUpdate = ((ReferentialSynchroContext) otherBean).enableInsertOrUpdate;
 			this.statusCodeIncludes = ((ReferentialSynchroContext) otherBean).statusCodeIncludes;
 			this.userId = ((ReferentialSynchroContext) otherBean).userId;
 			this.pkIncludes = ((ReferentialSynchroContext) otherBean).pkIncludes;
 			this.changeLogFile = ((ReferentialSynchroContext) otherBean).changeLogFile;
 			this.programCodes = ((ReferentialSynchroContext) otherBean).programCodes;
 			this.tableNamesForced = ((ReferentialSynchroContext) otherBean).tableNamesForced;
 		}
 	}
 
 	/** {@inheritDoc} */
 	@Override
 	public String toString() {
 		return new StringBuilder()
 				.append(super.toString())
 				.append("\n  direction: ").append(direction)
 				.append("\n  enable update/insert: ").append(isEnableInsertOrUpdate())
 				.append("\n  enable delete: ").append(isEnableDelete())
 				.append("\n  programs: ").append(programCodes == null ? "all" : programCodes.toString())
 				.append("\n  change log file: ").append(changeLogFile == null ? "disable" : changeLogFile.getPath())
 				.append("\n  status codes: ").append(statusCodeIncludes == null ? "all" : Joiner.on('\'').join(statusCodeIncludes))
 				.append("\n  user: ").append(getUserId())
 				.append("\n  pkIncludes: ").append(pkIncludes == null ? "all" : pkIncludes.toString())
 				.toString();
 	}
 
 }