package fr.ifremer.quadrige3.synchro.intercept.data;
   
   /*-
    * #%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.eventbus.Subscribe;
  import fr.ifremer.common.synchro.intercept.SynchroInterceptor;
  import fr.ifremer.common.synchro.meta.SynchroDatabaseMetadata;
  import fr.ifremer.common.synchro.meta.SynchroTableMetadata;
  import fr.ifremer.common.synchro.meta.event.LoadTableEvent;
  import fr.ifremer.quadrige3.core.dao.technical.Daos;
  import fr.ifremer.quadrige3.synchro.intercept.geometry.ConvertPostgis2WktGeometryInterceptor;
  import fr.ifremer.quadrige3.synchro.intercept.geometry.ConvertSdo2WktGeometryInterceptor;
  import fr.ifremer.quadrige3.synchro.intercept.geometry.ConvertWkt2PostgisGeometryInterceptor;
  import fr.ifremer.quadrige3.synchro.intercept.geometry.ConvertWkt2SdoGeometryInterceptor;
  import fr.ifremer.quadrige3.synchro.service.SynchroDirection;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.hibernate.tool.hbm2ddl.TableMetadata;
  
  /**
   * <p>
   * GeometryTablesInterceptor class.
   * </p>
   * 
   */
  public class GeometryTablesInterceptor extends AbstractDataInterceptor {
  
  	private static final Log LOG = LogFactory.getLog(GeometryTablesInterceptor.class);
  
  	/** {@inheritDoc} */
  	@Override
  	public boolean doApply(SynchroDatabaseMetadata meta, TableMetadata table) {
  		String tableName = table.getName().toUpperCase();
  		return tableName.endsWith("_AREA")
  				|| tableName.endsWith("_LINE")
  				|| tableName.endsWith("_POINT");
  	}
  
  	/**
  	 * <p>
  	 * handleLoadTable.
  	 * </p>
  	 * 
  	 * @param e
  	 *            a {@link LoadTableEvent} object.
  	 */
  	@Subscribe
  	public void handleLoadTable(LoadTableEvent e) {
  
  		SynchroTableMetadata table = e.table;
  
  		int columnPositionIndex = getPositionColumnIndex(table);
  		if (columnPositionIndex == -1) {
  			return;
  		}
  
  		SynchroDirection direction = getConfig().getDirection();
  		SynchroInterceptor geometryInterceptor = null;
  
  		// Import: Server DB -> Temp DB
  		// Import: Server DB -> Local DB (e.g. from command line, or when running without synchronization server)
  		if (direction == SynchroDirection.IMPORT_NO_TEMP
  				|| direction == SynchroDirection.IMPORT_SERVER2TEMP) {
  
  			if (Daos.isOracleDatabase(getSourceJdbcUrl())) {
  				// Add a interceptor SDO -> WKT
  				geometryInterceptor = new ConvertSdo2WktGeometryInterceptor(columnPositionIndex);
  			} else if (Daos.isPostgresqlDatabase(getSourceJdbcUrl())) {
  				// Add a interceptor Postgis -> WKT
  				geometryInterceptor = new ConvertPostgis2WktGeometryInterceptor(columnPositionIndex);
  			}
  		}
  
  		// Export: Temp DB -> Server DB
  		// Export: Local DB -> Server DB (=Direct export - e.g. from command line, or when running without
  		// synchronization server)
  		else if (direction == SynchroDirection.EXPORT_NO_TEMP
  				|| direction == SynchroDirection.EXPORT_TEMP2SERVER) {
 
 			if (Daos.isOracleDatabase(getTargetJdbcUrl())) {
 				// Add a interceptor WKT -> SDO
 				geometryInterceptor = new ConvertWkt2SdoGeometryInterceptor(columnPositionIndex);
 			} else if (Daos.isPostgresqlDatabase(getTargetJdbcUrl())) {
 				// Add a interceptor WKT -> Postgis
 				geometryInterceptor = new ConvertWkt2PostgisGeometryInterceptor(columnPositionIndex);
 			}
 		}
 
 		if (geometryInterceptor != null) {
 			table.addInterceptor(geometryInterceptor);
 		}
 	}
 
 	/* -- Internal methods -- */
 
 	private int getPositionColumnIndex(SynchroTableMetadata table) {
 		for (String columnName : table.getColumnNames()) {
 			if (columnName.toUpperCase().endsWith("_POSITION")) {
 				return table.getColumnIndex(columnName);
 			}
 		}
 		return -1;
 	}
 
 	private String getSourceJdbcUrl() {
 		return getConfig().getSource() != null ? getConfig().getSource().getJdbcUrl() : getConfig().getJdbcUrl();
 	}
 
 	private String getTargetJdbcUrl() {
 		return getConfig().getTarget() != null ? getConfig().getTarget().getJdbcUrl() : getConfig().getJdbcUrl();
 	}
 }