Application: gvSIG desktop

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

*

* Copyright (C) 2005 IVER T.I. and Generalitat Valenciana.

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* 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 General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

*

* For more information, contact:

*

*  Generalitat Valenciana

*   Conselleria d'Infraestructures i Transport

*   Av. Blasco Ib??ez, 50

*   46010 VALENCIA

*   SPAIN

*

*      +34 963862235

*   gvsig@gva.es

*      www.gvsig.gva.es

*

*    or

*

*   IVER T.I. S.A

*   Salamanca 50

*   46005 Valencia

*   Spain

*

*   +34 963163400

*   dac@iver.es

*/

package com.iver.cit.gvsig.wcs;

import com.iver.andami.PluginServices;

import com.iver.andami.plugins.Extension;

import com.iver.cit.gvsig.AddLayer;

import com.iver.cit.gvsig.fmap.MapControl;

import com.iver.cit.gvsig.fmap.layers.FLyrWCS;

import com.iver.cit.gvsig.gui.toc.WCSPropsTocMenuEntry;

import com.iver.cit.gvsig.gui.toc.WCSZoomPixelCursorTocMenuEntry;

import com.iver.cit.gvsig.gui.wcs.WCSWizard;

import com.iver.cit.gvsig.project.documents.view.toc.gui.FPopupMenu;

import com.iver.utiles.extensionPoints.ExtensionPoints;

import com.iver.utiles.extensionPoints.ExtensionPointsSingleton;

/**

 * @author jaume - jaume.dominguez@iver.es

 *

 */

public class WCSClientExtension extends Extension {

	/**

	 * Initializes the toc menu

	 *

	 */

	public void initialize() {

		// Adds a new tab to the "add layer" wizard for WMS layer creation

    	AddLayer.addWizard(WCSWizard.class);

    	// Adds an entry to the TOC's floating menu to those layers defined in this extensionFPopupMenu.addEntry(new WCSPropsTocMenuEntry());

    	FPopupMenu.addEntry(new WCSPropsTocMenuEntry());

    	// Adds an entry to the TOC's floating menu for the "zoom to pixel" tool

    	FPopupMenu.addEntry(new WCSZoomPixelCursorTocMenuEntry());

    	ExtensionPoints extensionPoints = ExtensionPointsSingleton.getInstance();

    	extensionPoints.add("CatalogLayers","OGC:WCS",FLyrWCS.class);

    	initializeIcons();

	}

	public void execute(String actionCommand) {

		// no commands, no code.

	}

	public boolean isEnabled() {

		// may return whatever

		return true;

	}

	public boolean isVisible() {

		// may return whatever

		return false;

	}

	void initializeIcons(){

		PluginServices.getIconTheme().registerDefault(

	    		"view-previsualize-area",

	    		MapControl.class.getResource("images/ZoomPixelCursor.gif")

	    	);

		PluginServices.getIconTheme().registerDefault(

	    		"ico-WCS-Layer",

	    		MapControl.class.getResource("images/icoLayer.png")

	    	);

	}

}

package com.iver.cit.gvsig.fmap.drivers.wcs;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

public class WCSDriverException extends ReadDriverException{

	public WCSDriverException(String l,Throwable exception) {

		super(l,exception);

		init();

	}

	/**

	 *

	 */

	private void init() {

		messageKey = "error_driver_layer";

		formatString = "Can?t load driver of the layer: %(layer) ";

	}

	 /**

     * Cuts the message text to force its lines to be shorter or equal to

     * lineLength.

     * @param message, the message.

     * @param lineLength, the max line length in number of characters.

     * @return the formated message.

     */

    private static String format(String message, int lineLength){

        if (message.length() <= lineLength) return message;

        String[] lines = message.split("\n");

        String theMessage = "";

        for (int i = 0; i < lines.length; i++) {

            String line = lines[i].trim();

            if (line.length()<lineLength)

                theMessage += line+"\n";

            else {

                String[] chunks = line.split(" ");

                String newLine = "";

                for (int j = 0; j < chunks.length; j++) {

                    int currentLength = newLine.length();

                    chunks[j] = chunks[j].trim();

                    if (chunks[j].length()==0)

                        continue;

                    if ((currentLength + chunks[j].length() + " ".length()) <= lineLength)

                        newLine += chunks[j] + " ";

                    else {

                        newLine += "\n"+chunks[j]+" ";

                        theMessage += newLine;

                        newLine = "";

                    }

                }

            }

        }

        return theMessage;

    }

}

/* gvSIG. Sistema de Informaci�n Geogr�fica de la Generalitat Valenciana

 *

 * Copyright (C) 2004 IVER T.I. and Generalitat Valenciana.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * 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 General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib��ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

package com.iver.cit.gvsig.fmap.drivers.wcs;

import com.iver.andami.PluginServices;

/**

 * Excepci�n provocada por el WCS.

 *

 * @author Vicente Caballero Navarro

 */

public class WCSExceptionOld extends Exception {

	String message;

	public String getMessage() {

		return PluginServices.getText(this, "wcs_server_error")+"\n"+format(message, 200);

	}

	/**

	 *

	 */

	public WCSExceptionOld() {

		super();

	}

	/**

	 * Crea WCSException.

	 *

	 * @param message

	 */

	public WCSExceptionOld(String message) {

        super();

        this.message = message;

	}

	/**

	 * Crea WCSException.

	 *

	 * @param message

	 * @param cause

	 */

	public WCSExceptionOld(String message, Throwable cause) {

		super(format(message, 200), cause);

	}

	/**

	  * Crea WCSException.

	 *

	 * @param cause

	 */

	public WCSExceptionOld(Throwable cause) {

		super(cause);

	}

    /**

     * Cuts the message text to force its lines to be shorter or equal to 

     * lineLength.

     * @param message, the message.

     * @param lineLength, the max line length in number of characters.

     * @return the formated message.

     */

    private static String format(String message, int lineLength){

        if (message.length() <= lineLength) return message;

        String[] lines = message.split("\n");

        String theMessage = "";

        for (int i = 0; i < lines.length; i++) {

            String line = lines[i].trim();

            if (line.length()<lineLength)

                theMessage += line+"\n";

            else {

                String[] chunks = line.split(" ");

                String newLine = "";

                for (int j = 0; j < chunks.length; j++) {

                    int currentLength = newLine.length();

                    chunks[j] = chunks[j].trim();

                    if (chunks[j].length()==0)

                        continue;

                    if ((currentLength + chunks[j].length() + " ".length()) <= lineLength)

                        newLine += chunks[j] + " ";

                    else {

                        newLine += "\n"+chunks[j]+" ";

                        theMessage += newLine;

                        newLine = "";

                    }

                }

            }

        }

        return theMessage;

    }

}

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

*

* Copyright (C) 2005 IVER T.I. and Generalitat Valenciana.

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* 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 General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

*

* For more information, contact:

*

*  Generalitat Valenciana

*   Conselleria d'Infraestructures i Transport

*   Av. Blasco Ib??ez, 50

*   46010 VALENCIA

*   SPAIN

*

*      +34 963862235

*   gvsig@gva.es

*      www.gvsig.gva.es

*

*    or

*

*   IVER T.I. S.A

*   Salamanca 50

*   46005 Valencia

*   Spain

*

*   +34 963163400

*   dac@iver.es

*/

package com.iver.cit.gvsig.fmap.drivers.wcs;

import java.awt.geom.Point2D;

import java.awt.geom.Rectangle2D;

import java.io.File;

import java.io.IOException;

import java.net.ConnectException;

import java.net.URL;

import java.util.ArrayList;

import java.util.Hashtable;

import java.util.Iterator;

import java.util.Set;

import org.gvsig.remoteClient.exceptions.ServerErrorException;

import org.gvsig.remoteClient.exceptions.WCSException;

import org.gvsig.remoteClient.utils.BoundaryBox;

import org.gvsig.remoteClient.wcs.WCSClient;

import org.gvsig.remoteClient.wcs.WCSCoverage;

import org.gvsig.remoteClient.wcs.WCSStatus;

import org.gvsig.remoteClient.wcs.WCSCoverage.AxisDescription;

import org.gvsig.remoteClient.wms.ICancellable;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

import com.hardcode.gdbms.engine.data.driver.DriverException;

import com.iver.cit.gvsig.fmap.layers.FMapWCSParameter;

import com.iver.cit.gvsig.fmap.layers.WCSLayer;

/**

 * Driver between the FMap and WCSClient

 *

 * Controlador entre FMap y WCSClient

 *

 * @author jaume

 *

 */

public class FMapWCSDriver {

	private WCSClient client = null;

	private Hashtable coverages;

	private WCSLayer[] layerList;

	/**

	 * Obtains the host name.

	 *

	 * Devuelve el nombre del host.

	 */

	public String getHost() {

		return client.getHost();

	}

	private FMapWCSDriver() {}

	protected FMapWCSDriver(URL url) throws ConnectException, IOException {

		client = new WCSClient(url.toString());

	}

	/**

	 * Returns the string "WCSDriver", which is the driver's name.

	 *

	 * Devuelve "WCSDriver", el nombre del driver.

	 * @return String

	 */

	public String getName() { return "WCSDriver"; }

	/**

	 * Sets the server that we want to connect to.

	 *

	 * Establece el servidor al que se quiere conectar.

	 *

	 * @param host

	 * @throws IOException

	 */

	public void setHost(String host) throws IOException{

		client = new WCSClient(host);

	}

	/**

	 * Returns a human-readable string containing the server's name.

	 *

	 * Devuelve el nombre legible del servidor devuelto por ?ste.

	 *

	 * @return String

	 */

	public String getLabel() {

		return client.getServiceTitle();

	}

	/**

	 * Returns a string containing the server's WCS version number.

	 *

	 * Devuelve el n?mero de versi?n WCS del servidor

	 *

	 * @return String

	 */

	public String getVersion(){

		return client.getVersion();

	}

	/**

	 * <p>

	 * Returns name and description of the server. It is supposed to be used

	 * as the source of the abstract field in your application's interface.

	 * </p>

	 * <p>

	 * Devuelve nombre y descripci?n (abstract) del servidor.

	 * </p>

	 * @return String

	 */

	public String getDescription(){

		return client.getDescription();

	}

	/**

	 * Returns the layer descriptor for a given coverage name.

	 * @param layerName

	 * @return WCSLayer

	 */

	public WCSLayer getLayer(String layerName) {

		getLayerList();

		return (WCSLayer) coverages.get(layerName);

	}

	/**

	 * Returns an array of WCSLayer's with the descriptors of all coverages

	 * @return WCSLayer[]

	 */

	public WCSLayer[] getLayerList(){

		if (coverages == null || coverages.isEmpty()) {

			// the WCSLayer collection will be built

			coverages = new Hashtable();

			Hashtable wcsCoverages  = client.getCoverageList();

			int sz = wcsCoverages.size();

			// Create an array with the WCSCoverages

			WCSCoverage[] coverageList = new WCSCoverage[sz];

			Iterator it = wcsCoverages.keySet().iterator();

			int i = 0;

			while (it.hasNext()) {

				coverageList[i] = (WCSCoverage) wcsCoverages.get(it.next());

				i++;

			}

			// Create a WCSLayer array from the previous WCSCoverage array

			layerList = new WCSLayer[sz];

			for (int j = 0; j < layerList.length; j++) {

				WCSLayer lyr = new WCSLayer();

				WCSCoverage cov = coverageList[j];

				// name

				lyr.setName(cov.getName());

				// title

				lyr.setTitle(cov.getTitle());

				// description

				lyr.setDescription(cov.getAbstract());

				// srs

				lyr.addAllSrs(cov.getAllSrs());

				// native srs

				lyr.setNativeSRS(cov.getNativeSRS());

				// extents

				Set k = cov.getBBoxes().keySet();

				if (!k.isEmpty()) {

					it = k.iterator();

					while (it.hasNext()) {

						String srs = (String) it.next();

						BoundaryBox bBox = cov.getBbox(srs);

						Rectangle2D r = new Rectangle2D.Double(

												bBox.getXmin(),

												bBox.getYmin(),

												bBox.getXmax()-bBox.getXmin(),

												bBox.getYmax()-bBox.getYmin()

												);

						lyr.addExtent(srs, r);

						}

				}

				// formats

				lyr.setFormats(cov.getFormats());

				// time positions

				lyr.setTimePositions(cov.getTimePositions());

				// max res

				lyr.setMaxRes(new Point2D.Double(cov.getResX(), cov.getResY()));

				// interpolations

				lyr.setInterpolationMethods(cov.getInterpolationMethods());

				// parameters

				k = cov.axisPool.keySet();

				if (!k.isEmpty()) {

					it = k.iterator();

					while (it.hasNext()) {

						AxisDescription ad = (AxisDescription) cov.axisPool.get(it.next());

						FMapWCSParameter p = new FMapWCSParameter();

						p.setName(ad.getName());

						p.setLabel(ad.getLabel());

						p.setType(ad.getInterval()==null? FMapWCSParameter.VALUE_LIST : FMapWCSParameter.INTERVAL);

						if (p.getType()==FMapWCSParameter.VALUE_LIST)

							p.setValueList(ad.getSingleValues());

						else

							p.setInterval(ad.getInterval());

						lyr.addParameter(p);

					}

				}

				layerList[j] = lyr;

				coverages.put(lyr.getName(), lyr);

			}

		}

		return layerList;

	}

	/**

	 * Establishes the connection to the WCS server. Connecting to a WCS is

	 * an abstraction.<br>

	 * <p>

	 * Actually, it sends a GetCapabilities and a general DescribeCoverage

	 * request (not a coverage-specific DescribeCoverage request) to read the

	 * necessary data for building further GetCoverage requests.

	 * </p>

	 * @param override

	 * @throws IOException, DriverException.

	 */

	public boolean connect(boolean override, ICancellable cancel) throws IOException, ReadDriverException {

		coverages = null;

		setHost(client.getHost());

		return client.connect(override, cancel);

	}

	/**

	 * No close operation is needed since WCS service it is a non-session based

	 * protocol. So, this does nothing and you can omit it.<br>

	 */

	public void close() {

//		connected = false;

	}

	/**

	 * Returns the label of an specific coverage given by the coverage name

	 * @param coverage name (string)

	 * @return string

	 */

	public String getLabel(String coverageName) {

		return client.getLabel(coverageName);

	}

	/**

	 * Returns the coverage's MAX extent from the server.

	 * @return Rectangle2D

	 * @throws DriverException

	 * @throws IOException

	 */

	public Rectangle2D getFullExtent(String coverageName, String srs) throws IOException, ReadDriverException {

		return client.getExtent(coverageName, srs);

	}

	/**

	 * Returns the max resolution of a specific coverage given by the coverage's name.

	 * @param coverage name (string)

	 * @return double

	 */

	public Point2D getMaxResolution(String coverageName) {

		if (coverages.containsKey(coverageName)) {

			return ((WCSLayer) coverages.get(coverageName)).getMaxRes();

		}

		return null;

	}

	/**

	 * Returns an ArrayList containing a set of Strings with the coverage's SRSs.

	 * @param coverage name (string)

	 * @return ArrayList

	 */

	public ArrayList getSRSs(String coverageName) {

		if (coverages.containsKey(coverageName)) {

			return ((WCSLayer) coverages.get(coverageName)).getSRSs();

		}

		return null;

	}

	/**

	 * Returns a String containing a description of an specific coverage.

	 * @param coverage name (string)

	 * @return string

	 */

	public String getCoverageDescription(String coverageName) {

		if (coverages.containsKey(coverageName)) {

			return ((WCSLayer) coverages.get(coverageName)).getDescription();

		}

		return null;

	}

	/**

	 * Returns an ArrayList containing strings for the time positions of an

	 * specific coverage given by the coverage's name.

	 * @param coverage name (string)

	 * @return ArrayList

	 */

	public ArrayList getTimes(String coverageName) {

		if (coverages.containsKey(coverageName)) {

			return ((WCSLayer) coverages.get(coverageName)).getTimePositions();

		}

		return null;

	}

	/**

	 * Sends a GetCoverage request to the client.

	 * @param status

	 * @return

	 * @throws WCSException

	 */

	public File getCoverage(WCSStatus status, ICancellable cancel) throws WCSDriverException {

		try {

			return client.getCoverage(status, cancel);

		} catch (ServerErrorException e) {

			throw new WCSDriverException(getName(),e);

		} catch (org.gvsig.remoteClient.exceptions.WCSException e) {

			throw new WCSDriverException(getName(),e);

		}

	}

}

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

 *

 * Copyright (C) 2005 IVER T.I. and Generalitat Valenciana.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * 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 General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

/* CVS MESSAGES:

*

* $Id$

* $Log$

* Revision 1.1  2006-06-26 16:11:05  jaume

* *** empty log message ***

*

*

*/

package com.iver.cit.gvsig.fmap.drivers.wcs;

import java.io.IOException;

import java.net.ConnectException;

import java.net.URL;

import java.util.Hashtable;

public class FMapWCSDriverFactory {

	private static Hashtable drivers = new Hashtable();

	private FMapWCSDriverFactory() { }

	static public final FMapWCSDriver getFMapDriverForURL(URL url) throws ConnectException, IOException {

		FMapWCSDriver drv = (FMapWCSDriver) drivers.get(url);

		if (drv == null) {

			drv = new FMapWCSDriver(url);

			drivers.put(url, drv);

		}

		return drv;

	}

}

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

 *

 * Copyright (C) 2005 IVER T.I. and Generalitat Valenciana.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * 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 General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

package com.iver.cit.gvsig.fmap.layers;

import java.util.ArrayList;

/**

 * Class abstracting WCS's axis descriptions into FMap

 * @author jaume dominguez faus - jaume.dominguez@iver.es

 * @TODO add interval parameters support

 */

public class FMapWCSParameter {

	public static final int VALUE_LIST = 0;

	public static final int INTERVAL = 1;

	private String name;

	private int type;

	private ArrayList valueList;

	private String interval;

	private String label;

	public void setName(String name) {

		this.name = name;

	}

	public void setType(int type) {

		this.type = type;

	}

	public int getType() {

		return type;

	}

	public void setValueList(ArrayList singleValues) {

		this.valueList = singleValues;

	}

	public void setInterval(String interval) {

		this.interval = interval;

	}

	public void setLabel(String label) {

		this.label = label;

	}

	public String toString() {

		return (label!=null) ? label : name;

	}

	public ArrayList getValueList() {

		return valueList;

	}

	public String getName() {

		return name;

	}

}

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

 *

 * Copyright (C) 2004 IVER T.I. and Generalitat Valenciana.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * 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 General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

package com.iver.cit.gvsig.fmap.layers;

import java.awt.Dimension;

import java.awt.Graphics2D;

import java.awt.Point;

import java.awt.Rectangle;

import java.awt.geom.AffineTransform;

import java.awt.geom.NoninvertibleTransformException;

import java.awt.geom.Point2D;

import java.awt.geom.Rectangle2D;

import java.awt.image.BufferedImage;

import java.awt.image.DataBuffer;

import java.io.File;

import java.io.IOException;

import java.lang.reflect.Constructor;

import java.lang.reflect.InvocationTargetException;

import java.net.MalformedURLException;

import java.net.URL;

import java.util.ArrayList;

import java.util.Hashtable;

import java.util.Iterator;

import java.util.Map;

import javax.print.attribute.PrintRequestAttributeSet;

import javax.swing.ImageIcon;

import org.exolab.castor.xml.ValidationException;

import org.gvsig.fmap.raster.layers.FLyrRasterSE;

import org.gvsig.fmap.raster.layers.IRasterLayerActions;

import org.gvsig.fmap.raster.layers.IStatusRaster;

import org.gvsig.fmap.raster.layers.StatusLayerRaster;

import org.gvsig.raster.dataset.CompositeDataset;

import org.gvsig.raster.dataset.IBuffer;

import org.gvsig.raster.dataset.MosaicNotValidException;

import org.gvsig.raster.dataset.MultiRasterDataset;

import org.gvsig.raster.dataset.NotSupportedExtensionException;

import org.gvsig.raster.dataset.io.RasterDriverException;

import org.gvsig.raster.datastruct.ColorTable;

import org.gvsig.raster.datastruct.Extent;

import org.gvsig.raster.datastruct.ViewPortData;

import org.gvsig.raster.grid.GridTransparency;

import org.gvsig.raster.grid.filter.FilterTypeException;

import org.gvsig.raster.grid.filter.RasterFilterList;

import org.gvsig.raster.grid.filter.RasterFilterListManager;

import org.gvsig.raster.grid.filter.enhancement.LinearEnhancementFilter;

import org.gvsig.raster.grid.filter.statistics.TailTrimFilter;

import org.gvsig.remoteClient.wcs.WCSStatus;

import org.gvsig.remoteClient.wms.ICancellable;

import com.hardcode.gdbms.driver.exceptions.ReadDriverException;

import com.hardcode.gdbms.engine.data.driver.DriverException;

import com.iver.cit.gvsig.exceptions.layers.ConnectionErrorLayerException;

import com.iver.cit.gvsig.exceptions.layers.LoadLayerException;

import com.iver.cit.gvsig.exceptions.layers.UnsupportedVersionLayerException;

import com.iver.cit.gvsig.fmap.MapControl;

import com.iver.cit.gvsig.fmap.ViewPort;

import com.iver.cit.gvsig.fmap.crs.CRSFactory;

import com.iver.cit.gvsig.fmap.drivers.DriverIOException;

import com.iver.cit.gvsig.fmap.drivers.wcs.FMapWCSDriver;

import com.iver.cit.gvsig.fmap.drivers.wcs.FMapWCSDriverFactory;

import com.iver.cit.gvsig.fmap.drivers.wcs.WCSDriverException;

import com.iver.cit.gvsig.fmap.layers.layerOperations.XMLItem;

import com.iver.utiles.StringUtilities;

import com.iver.utiles.XMLEntity;

import com.iver.utiles.swing.threads.Cancellable;

/**

 * Class for the WCS layer.

 *

 * Capa para el WCS.

 *

 * Las capas WCS son tileadas para descargarlas del servidor. Esto quiere decir que

 * est?n formadas por multiples ficheros raster. Por esto la fuente de datos raster (IRasterDatasource)

 * de la capa FLyrWCS es un objeto de tipo CompositeDataset. Este objeto est? compuesto por un array

 * bidimensional de MultiRasterDataset. Cada uno de los MultiRasterDataset corresponde con un tile

 * salvado en disco. Estos MultiRasterDataset se crean cada vez que se repinta ya que en WCS a cada

 * zoom varian los ficheros fuente. La secuencia de creaci?n de un CompositeDataset ser?a la siguiente:

 * <UL>

 * <LI>Se hace una petici?n de dibujado por parte del usuario llamando al m?todo draw de FLyrWCS</LI>

 * <LI>Se tilea la petici?n</LI>

 * <LI>Cada tile se dibuja abriendo una FLyrRaster para ese tile</LI>

 * <LI>Si es el primer dibujado se guarda una referencia en la capa WMS a las propiedades de renderizado, orden de bandas,

 * transparencia, filtros aplicados, ...</LI>

 * <LI>Si no es el primer dibujado se asignan las propiedades de renderizado cuya referencia se guarda en la capa WMS</LI>

 * <LI>Se guarda el MultiRasterDataset de cada tile</LI>

 * <LI>Al acabar todos los tiles creamos un CompositeDataset con los MultiRasterDataset de todos los tiles</LI>

 * <LI>Asignamos a la capa la referencia de las propiedades de renderizado que tenemos almacenadas. De esta forma si hay

 * alguna modificaci?n desde el cuadro de propiedades ser? efectiva sobre los tiles que se dibujan.</LI>

 * </UL>

 *

 * @author jaume - jaume.dominguez@iver.es

 */

public class FLyrWCS extends FLyrRasterSE {

	private FMapWCSDriver wcs = null;

	private URL 						host;

	private String						coverageName;

	private Rectangle2D					fullExtent;

	private String						format;

	private String						srs;

	private String						time;

	private String						parameter;

	private Point2D						maxRes;

	private Hashtable 					onlineResources = new Hashtable();

	private WCSStatus					wcsStatus = new WCSStatus();

	private int 						posX = 0, posY = 0;

	private double 						posXWC = 0, posYWC = 0;

	private int 						r = 0, g = 0, b = 0;

	private boolean 					firstLoad = false;

	private VisualStatus				visualStatus = new VisualStatus();

	private boolean 					mustTileDraw = false;

	private int 						maxTileDrawWidth  = 1023;

	private int							maxTileDrawHeight = 1023;

	//private int 						maxTilePrintWidth  = 250;

	//private int							maxTilePrintHeight = 250;

	/**

	 * Lista de filtros aplicada en la renderizaci?n

	 */

	private RasterFilterList            filterList = null;

	private GridTransparency			transparency = null;

	private int[]                       renderBands = null;

	private FLyrRasterSE				layerRaster = null;

	private ArrayList                   filterArguments = null;

	private class MyCancellable implements ICancellable

	{

		private Cancellable original;

		public MyCancellable(Cancellable cancelOriginal)

		{

			this.original = cancelOriginal;

		}

		public boolean isCanceled() {

			return original.isCanceled();

		}

		public Object getID() {

			return this;

		}

	}

	public FLyrWCS(){

		super();

	}

	public FLyrWCS(Map args) throws DriverIOException{

		FMapWCSDriver drv = null;

		String host = (String)args.get("HOST");

		String sCoverage = (String) args.get((String) "COVERAGE");

		try {

			this.setHost(new URL(host));

		} catch (MalformedURLException e) {

			//e.printStackTrace();

			throw new DriverIOException("Malformed host URL, '" + host + "' (" + e.toString() + ").");

		}

		try {

			drv = this.getDriver();

		} catch (Exception e) {

			// e.printStackTrace();

			throw new DriverIOException("Can't get driver to host '" + host + "' (" + e.toString() + ").");

		}

		try{

			if (!drv.connect(false, null)){

				throw new DriverIOException("Can't connect to host '" + host + "'.");

			}

		}catch(Exception e){

			throw new DriverIOException("Can't connect to host '" + host + "'.");

		}

		WCSLayer wcsNode = drv.getLayer(sCoverage);

		if (wcsNode == null){

			throw new DriverIOException("The server '" + host + "' doesn't has the coverage '" + sCoverage + "'.");

		}

		try{

			this.setFullExtent(drv.getFullExtent(sCoverage,

					(String) args.get((String) "CRS")));

			this.setFormat((String) args.get((String) "FORMAT"));

			this.setParameter("BANDS=" + (String) args.get((String) "BANDS"));

			this.setSRS((String) args.get((String) "CRS"));

			this.setName(sCoverage);

			this.setCoverageName(sCoverage);

		}catch (Exception e){

			throw new DriverIOException("The server '" + host + "' is not able to load the coverage '" + sCoverage + "'.");

		}

	}

	/**

	 * Clase que contiene los datos de visualizaci?n de WCS. Tiene datos que representan al

	 * raster en la vista. Este raster puede estar compuesto por tiles por lo que valores

	 * como el ancho total o el m?nimo o m?ximo deben ser calculados a partir de todos los

	 * tiles visualizados.

	 * @author Nacho Brodin (brodin_ign@gva.es)

	 */

	private class VisualStatus {

		/**

		 * Ancho y alto de la imagen o del conjunto de tiles si los tiene. Coincide con

		 * el ancho y alto del viewPort

		 */

		private	int							width = 0, height = 0;

		private double						minX = 0D, minY = 0D, maxX = 0D, maxY = 0D;

		private int 						bandCount = 0;

		private int							dataType = DataBuffer.TYPE_UNDEFINED;

		/**

		 * Ancho y alto total del raster que ser? la suma de todos los tiles.

		 */

		private	int							rasterWidth = 0, rasterHeight = 0;

		private	double						rasterMinX = Double.MAX_VALUE, rasterMinY = Double.MAX_VALUE;

		private	double						rasterMaxX = 0, rasterMaxY = 0;

		/**

		 * Lista de nombre de fichero que componen toda la visualizaci?n.

		 */

		private String[]					fileNames = null;

	}

	/**

	 * @deprecated

	 * @see com.iver.cit.gvsig.fmap.layers.layerOperations.InfoByPoint#getInfo

	 */

	public String queryByPoint(Point p) {

		String data = "<file:"+getName().replaceAll("[^a-zA-Z0-9]","")+">\n";

		ArrayList attr = this.getAttributes();

		data += "  <raster\n";

		data += "    File=\""+getName()+"\"\n";

		for (int i=0; i<attr.size(); i++) {

			Object [] a = (Object []) attr.get(i);

			data += "    "+a[0].toString()+"=";

			if (a[1].toString() instanceof String)

				data += "\""+a[1].toString()+"\"\n";

			else

				data += a[1].toString()+"\n";

		}

		data += "    Point=\""+posX+" , "+posY+"\"\n";

		data += "    Point_WC=\""+posXWC+" , "+posYWC+"\"\n";

		data += "    RGB=\""+r+", "+g+", "+b+"\"\n";

		data += "  />\n";

		data += "</file:"+getName().replaceAll("[^a-zA-Z0-9]","")+">\n";

		System.out.println(data);

		return data;

	}

	/**

	 * @see com.iver.cit.gvsig.fmap.layers.layerOperations.InfoByPoint#getInfo

	 */

	public XMLItem[] getInfo(Point point, double tolerance, Cancellable cancel ) throws ReadDriverException {

		return super.getInfo(point, tolerance, cancel);

	}

	/*

	 *  (non-Javadoc)

	 * @see com.iver.cit.gvsig.fmap.layers.FLayer#getFullExtent()

	 */

	public Rectangle2D getFullExtent() {

		return fullExtent;

	}

	/*

	 *  (non-Javadoc)

	 * @see com.iver.cit.gvsig.fmap.layers.FLayer#draw(java.awt.image.BufferedImage, java.awt.Graphics2D, com.iver.cit.gvsig.fmap.ViewPort, com.iver.cit.gvsig.fmap.operations.Cancellable, double)

	 */

	public void draw(BufferedImage image, Graphics2D g, ViewPort viewPort, Cancellable cancel, double scale) throws ReadDriverException {

		enableStopped();

		// callLegendChanged(null);

		if (isWithinScale(scale)) {

			Point2D p = viewPort.getOffset();

			// p will be (0, 0) when drawing a view or other when painting onto

			// the Layout.

			visualStatus.width = viewPort.getImageWidth();

			visualStatus.height = viewPort.getImageHeight();

			visualStatus.minX = viewPort.getAdjustedExtent().getMinX();

			visualStatus.minY = viewPort.getAdjustedExtent().getMinY();

			visualStatus.maxX = viewPort.getAdjustedExtent().getMaxX();

			visualStatus.maxY = viewPort.getAdjustedExtent().getMaxY();

			visualStatus.rasterWidth = 0;

			visualStatus.rasterHeight = 0;

			visualStatus.rasterMinX = Double.MAX_VALUE;

			visualStatus.rasterMinY = Double.MAX_VALUE;

			visualStatus.rasterMaxX = 0;

			visualStatus.rasterMaxY = 0;

			visualStatus.fileNames = new String[1];

			try {

				if (true) {

					if (viewPort.getImageWidth() <= maxTileDrawWidth && viewPort.getImageHeight() <= maxTileDrawHeight) {

						drawTile(g, viewPort, cancel, 0, scale);

						if (layerRaster == null)

							return;

						dataset = layerRaster.getDataSource();

						getRender().setLastRenderBuffer(layerRaster.getRender().getLastRenderBuffer());

						initializeRasterLayer(null, new IBuffer[][] { { layerRaster.getRender().getLastRenderBuffer() } });

					} else {

						Rectangle r = new Rectangle((int) p.getX(), (int) p.getY(), viewPort.getImageWidth(), viewPort.getImageHeight());

						Tiling tiles = new Tiling(maxTileDrawWidth, maxTileDrawHeight, r);

						tiles.setAffineTransform((AffineTransform) viewPort.getAffineTransform().clone());

						MultiRasterDataset[][] datasets = new MultiRasterDataset[tiles.getNumRows()][tiles.getNumCols()];

						IBuffer[][] buf = new IBuffer[tiles.getNumRows()][tiles.getNumCols()];

						visualStatus.fileNames = new String[tiles.getNumTiles()];

						for (int tileNr = 0; tileNr < tiles.getNumTiles(); tileNr++) {

							// drawing part

							try {

								ViewPort vp = tiles.getTileViewPort(viewPort, tileNr);

								boolean painted = drawTile(g, vp, cancel, tileNr, scale);

								if (layerRaster != null && painted) {

									datasets[(int) (tileNr / tiles.getNumCols())][tileNr % tiles.getNumCols()] = (MultiRasterDataset) layerRaster.getDataSource().newDataset();

									buf[(int) (tileNr / tiles.getNumCols())][tileNr % tiles.getNumCols()] = layerRaster.getRender().getLastRenderBuffer();

								}

							} catch (NoninvertibleTransformException e) {

								e.printStackTrace();

							}

						}

						try {

							if (datasets != null && datasets[0][0] != null) {

								dataset = new CompositeDataset(datasets);

								initializeRasterLayer(datasets, buf);

							}

						} catch (MosaicNotValidException e) {

							throw new ReadDriverException("No hay continuidad en el mosaico.", e);

						} catch (LoadLayerException e) {

							throw new ReadDriverException("Error inicializando la capa.", e);

						}

					}

				} else {

					drawTile(g, viewPort, cancel, 0, scale);

					if (layerRaster == null)

						return;

					dataset = layerRaster.getDataSource();

					getRender().setLastRenderBuffer(layerRaster.getRender().getLastRenderBuffer());

					initializeRasterLayer(null, new IBuffer[][] { { layerRaster.getRender().getLastRenderBuffer() } });

				}

			} catch (ConnectionErrorLayerException e) {

				e.printStackTrace();

			} catch (UnsupportedVersionLayerException e) {

				e.printStackTrace();

			} catch (LoadLayerException e) {

				e.printStackTrace();

			} catch (InterruptedException e) {

			}

		}

		disableStopped();

		// callLegendChanged(null);

		Runtime r = Runtime.getRuntime();

		long mem = r.totalMemory() - r.freeMemory();

		System.err.println("Memoria total: " + (mem / 1024) +"KB");

	}

	/**

	 * Acciones que se realizan despu?s de asignar la fuente de datos a

	 * la capa raster.

	 *

	 * @throws LoadLayerException

	 * @throws InterruptedException

	 */

	private void initializeRasterLayer(MultiRasterDataset[][] datasets, IBuffer[][] buf) throws LoadLayerException, InterruptedException {

		if(this.filterList != null)

			getRender().setFilterList(filterList);

/*

		if(this.transparency != null)

			getRender().setLastTransparency(transparency);

*/

		if(this.renderBands != null)

			getRender().setRenderBands(renderBands);

		if(datasets != null) {

			String[][] names = new String[datasets.length][datasets[0].length];

			for (int i = 0; i < datasets.length; i++) {

				for (int j = 0; j < datasets[i].length; j++) {

					if(datasets[i][j] != null)

						names[i][j] = datasets[i][j].getDataset(0)[0].getFName();

				}

			}

			super.setLoadParams(names);

		}

		super.init();

		if(buf != null) {

			int drawablesBandCount = layerRaster.getDataSource().getBands().getDrawableBandsCount();

			IBuffer buff = null;

			if(dataset instanceof CompositeDataset)

				buff = ((CompositeDataset)dataset).generateBuffer(buf, drawablesBandCount);

			else

				buff = buf[0][0];

			getRender().setLastRenderBuffer(buff);

		}

		if (transparency == null)

			transparency = new GridTransparency(getDataSource().getTransparencyFilesStatus());

		getRender().setLastTransparency(transparency);

	}

	/**

	 * This is the method used to draw a tile in a WCS mosaic layer.

	 * @param tile Tile number to draw

	 * @throws ReadDriverException

	 * @return true when a tile has been painted

	 */

	private boolean drawTile(Graphics2D g, ViewPort vp, Cancellable cancel, int tile, double scale) throws LoadLayerException, ReadDriverException {

		// Compute the query geometry

		// 1. Check if it is within borders

		Rectangle2D extent = getFullExtent();

		if ((vp.getAdjustedExtent().getMinX() > extent.getMaxX()) ||

				(vp.getAdjustedExtent().getMinY() > extent.getMaxY()) ||

				(vp.getAdjustedExtent().getMaxX() < extent.getMinX()) ||

				(vp.getAdjustedExtent().getMaxY() < extent.getMinY()))

			return false;

		// 2. Compute extent to be requested.

		Rectangle2D bBox = new Rectangle2D.Double();

		Rectangle2D.intersect(vp.getAdjustedExtent(), extent, bBox);

		// 3. Compute size in pixels

		double scalex = vp.getAffineTransform().getScaleX();

		double scaley = vp.getAffineTransform().getScaleY();

		int wImg = (int) Math.ceil(Math.abs(bBox.getWidth() * scalex) + 1);

		int hImg = (int) Math.ceil(Math.abs(bBox.getHeight() * scaley) + 1);

		Dimension sz = new Dimension(wImg, hImg);

		if ((wImg <= 0) || (hImg <= 0))

			return false;

		try {

			sz = new Dimension(wImg, hImg);

			wcsStatus.setCoveraName( coverageName );

			wcsStatus.setExtent( bBox );

			wcsStatus.setFormat( format );

			wcsStatus.setHeight( hImg );

			wcsStatus.setWidth( wImg );

			wcsStatus.setSrs(srs);

			wcsStatus.setParameters( parameter );

			wcsStatus.setTime( time );

			wcsStatus.setOnlineResource((String) onlineResources.get("GetCoverage"));

			File f = getDriver().getCoverage(wcsStatus, new MyCancellable(cancel));

			if (f == null)

				return false;

			String nameWordFile = f.getPath() + getExtensionWorldFile();

			com.iver.andami.Utilities.createTemp(nameWordFile, this.getDataWorldFile(bBox, sz));

			IStatusRaster status = super.getStatus();

			if(status!=null && firstLoad){

				try {

					status.applyStatus(this);

				} catch (NotSupportedExtensionException e) {

					throw new ReadDriverException("", e);

				} catch (RasterDriverException e) {

					throw new ReadDriverException("", e);

				} catch (FilterTypeException e) {

					throw new ReadDriverException("", e);

				}

				firstLoad = false;

			}

			ViewPortData vpData = new ViewPortData(

				vp.getProjection(), new Extent(bBox), sz );

			vpData.setMat(vp.getAffineTransform());

			String filePath = f.getAbsolutePath();

			visualStatus.fileNames[tile] = filePath;

			try {

				rasterProcess(filePath, g, vp, scale, cancel);

			} catch (FilterTypeException e) {

			}

//			this.getRender().draw(g, vpData);

//			rasterProcess(g, vpData, f);

//		} catch (ValidationException e) {

//			UnknownResponseFormatExceptionType type =

//				new UnknownResponseFormatExceptionType();

//			type.setLayerName(getName());

//			try {

//				type.setDriverName(getDriver().getName());

//			} catch (Exception e1) {

//				e1.printStackTrace();

//			}

//			type.setFormat(format);

//			type.setHost(host);

//			type.setProtocol("WCS");

//			ReadDriverException exception = new ReadDriverException("unknown_response_format",type);

//			throw exception;

//	azabala		throw new DriverException(PluginServices.getText(this, "unknown_response_format"), e);

//		}

//		catch (UnsupportedVersionLayerException e) {

//			UnsuportedProtocolVersionExceptionType type =

//				new UnsuportedProtocolVersionExceptionType();

//			type.setLayerName(getName());

//			try {

//				type.setDriverName(getDriver().getName());

//			} catch (Exception ex){

//			}

//			type.setUrl(host);

//			throw new ReadDriverException(PluginServices.getText(this, "version_conflict"), e, type);

//	azabala		throw new DriverException(PluginServices.getText(this, "version_conflict"), e);

		} catch (IOException e) {

//			ConnectionErrorExceptionType type = new ConnectionErrorExceptionType();

//			type.setLayerName(getName());

//			try {

//				type.setDriverName(getDriver().getName());

//			} catch (Exception e1) {

//			}

//			type.setHost(host);

			throw new ConnectionErrorLayerException(getName(),e);

		}

//		catch (WCSLayerException e) {

////azabala: la capturamos y la convertimos en DriverException

//			WCSDriverExceptionType type = new WCSDriverExceptionType();

//			type.setLayerName(getName());

//			try {

//				type.setDriverName(getDriver().getName());

//			} catch (Exception e1) {

//			}

//			type.setWcsStatus(wcsStatus);

//			this.setVisible(false);

//			throw new WDriverException("Error WCS", e,  type);

//

////            JOptionPane.showMessageDialog((Component)PluginServices.getMainFrame(), e.getMessage());

//

//        }//

		catch (WCSDriverException e) {

			throw new LoadLayerException(getName(),e);

		} catch (IllegalStateException e) {

			throw new LoadLayerException(getName(),e);

		}

		return true;

	}