package fr.ifremer.quadrige3.synchro.intercept.geometry;
   
   /*-
    * #%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.vividsolutions.jts.geom.Geometry;
  import fr.ifremer.common.synchro.dao.SynchroTableDao;
  import fr.ifremer.common.synchro.intercept.SynchroInterceptorBase;
  import fr.ifremer.common.synchro.intercept.SynchroOperationRepository;
  import fr.ifremer.quadrige3.core.dao.technical.Daos;
  import fr.ifremer.quadrige3.core.dao.technical.Geometries;
  import fr.ifremer.quadrige3.core.exception.QuadrigeTechnicalException;
  import org.hibernate.spatial.dialect.postgis.PGGeometryValueBinder;
  
  import java.lang.reflect.Method;
  import java.sql.Connection;
  import java.util.List;
  
  /**
   * <p>
   * ConvertWkt2PostgisGeometryInterceptor class.
   * </p>
   * 
   */
  public class ConvertWkt2PostgisGeometryInterceptor extends SynchroInterceptorBase {
  
  	private final static PGGeometryValueBinder PG_GEOMETRY_BINDER = new PGGeometryValueBinder();
  
  	private final static Method toNativeMethodPGGeometryValueBinder = getToNativeMethod();
  
  	private static Method getToNativeMethod() {
  		try {
  			Method toNativeMethod = PGGeometryValueBinder.class.getDeclaredMethod("toNative", Geometry.class, Connection.class);
  			toNativeMethod.setAccessible(true);
  			return toNativeMethod;
  		} catch (NoSuchMethodException e) {
  			throw new QuadrigeTechnicalException("Could not initialize ConvertWkt2PostgisGeometryInterceptor class: " + e.getMessage(), e);
  		}
  	}
  
  	private int columnIndex;
  
  	/**
  	 * <p>
  	 * Constructor for ConvertWkt2PostgisGeometryInterceptor.
  	 * </p>
  	 *
  	 * @param columnIndex
  	 *            a int.
  	 */
  	public ConvertWkt2PostgisGeometryInterceptor(int columnIndex) {
  		super();
  		setEnableOnWrite(true);
  		setEnableOnRead(true);
  		this.columnIndex = columnIndex;
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public SynchroInterceptorBase clone() {
  		return new ConvertWkt2PostgisGeometryInterceptor(columnIndex);
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	protected void doOnWrite(Object[] data, List<Object> pk, SynchroTableDao sourceDao, SynchroTableDao targetDao, SynchroOperationRepository buffer,
  			boolean insert) {
  		Object position = data[columnIndex];
  		if ((position instanceof String)) {
  			Geometry geometry = Geometries.getGeometry((String) position);
  			geometry.setSRID(Geometries.DEFAULT_SRID);
  			data[columnIndex] = toNative(geometry, targetDao.getConnection());
  		}
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	protected void doOnRead(Object[] data, SynchroTableDao sourceDao, SynchroTableDao targetDao) {
  		Object position = data[columnIndex];
 
 		if ((position instanceof String)) {
 			Geometry geometry = Geometries.getGeometry((String) position);
 			geometry.setSRID(Geometries.DEFAULT_SRID);
 			data[columnIndex] = toNative(geometry, targetDao.getConnection());
 		}
 	}
 
 	/* -- Internal methods -- */
 
 	/**
 	 * <p>
 	 * toNative.
 	 * </p>
 	 *
 	 * @param geometry
 	 *            a {@link Geometry} object.
 	 * @param connection
 	 *            a {@link Connection} object.
 	 * @return a {@link Object} object.
 	 */
 	protected Object toNative(Geometry geometry, Connection connection) {
 		if (geometry == null) {
 			return null;
 		}
 
 		try {
 			return toNativeMethodPGGeometryValueBinder.invoke(
 					PG_GEOMETRY_BINDER,
 					geometry,
 					// unwrap connection (Mantis #46477)
 					Daos.unwrapConnection(connection));
 		} catch (Exception e) {
 			throw new QuadrigeTechnicalException("Unable to call PGGeometryValueBinder.toNative() using reflection: " + e.getMessage(), e);
 		}
 
 	}
 }