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.Geometries;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.hibernate.spatial.GeometryJavaTypeDescriptor;
  import org.hibernate.spatial.dialect.postgis.PGGeometryTypeDescriptor;
  import org.hibernate.spatial.dialect.postgis.PGGeometryValueExtractor;
  
  import java.util.List;
  
  /**
   * <p>
   * ConvertPostgis2WktGeometryInterceptor class.
   * </p>
   * 
   */
  public class ConvertPostgis2WktGeometryInterceptor extends SynchroInterceptorBase {
  
  	private final static PGGeometryValueExtractor<Geometry> PG_GEOMETRY_EXTRACTOR = new PGGeometryValueExtractor<>(GeometryJavaTypeDescriptor.INSTANCE, PGGeometryTypeDescriptor.INSTANCE);
  
  	private static final Log LOG = LogFactory.getLog(ConvertPostgis2WktGeometryInterceptor.class);
  
  	private int columnIndex;
  
  	/**
  	 * <p>
  	 * Constructor for ConvertPostgis2WktGeometryInterceptor.
  	 * </p>
  	 *
  	 * @param columnIndex
  	 *            a int.
  	 */
  	public ConvertPostgis2WktGeometryInterceptor(int columnIndex) {
  		super();
  		setEnableOnWrite(true);
  		setEnableOnRead(true);
  		this.columnIndex = columnIndex;
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	public SynchroInterceptorBase clone() {
  		return new ConvertPostgis2WktGeometryInterceptor(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 != null && !(position instanceof String)) {
  			Geometry geometry = null;
  			try {
  				geometry = PG_GEOMETRY_EXTRACTOR.toJTS(position);
  			} catch (IllegalArgumentException iae) {
  				LOG.warn("the position is unreadable : " + iae.getLocalizedMessage());
  			}
  			if (geometry != null) {
  				String wtkGeometry = Geometries.getWKTString(geometry);
  				data[columnIndex] = wtkGeometry.replaceAll(", ", ",");
  			} else {
  				data[columnIndex] = null;
  			}
  		}
  	}
  
  	/** {@inheritDoc} */
  	@Override
  	protected void doOnRead(Object[] data, SynchroTableDao sourceDao, SynchroTableDao targetDao) {
  		Object position = data[columnIndex];
  
 		if (position != null && !(position instanceof String)) {
 			Geometry geometry = PG_GEOMETRY_EXTRACTOR.toJTS(position);
 			String wtkGeometry = Geometries.getWKTString(geometry);
 			data[columnIndex] = wtkGeometry.replaceAll(", ", ",");
 		}
 	}
 
 	/* -- Internal methods -- */
 
 }