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 org.gvsig.remoteclient.wcs;

import java.awt.geom.Rectangle2D;

import java.io.File;

import java.io.IOException;

import java.net.ConnectException;

import java.util.ArrayList;

import java.util.Hashtable;

import java.util.Iterator;

import org.gvsig.compat.net.ICancellable;

import org.gvsig.remoteclient.exceptions.ServerErrorException;

import org.gvsig.remoteclient.exceptions.WCSException;

import org.gvsig.remoteclient.utils.BoundaryBox;

/**

 * WCSClient managing the low-level comunication to the server. It is used

 * as a bridge between a standard WCS server and other high-level clients.

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

 *

 */

public class WCSClient extends org.gvsig.remoteclient.RasterClient{

    private WCSProtocolHandler handler;

    private Hashtable layerPool;

    /**

     * Constructor.

     * the parameter host, indicates the WCS host to connect.

     * @throws IOException

     *

     */

    public WCSClient(String host) throws ConnectException, IOException {

        setHost(host);

        try {

        	handler = WCSProtocolHandlerFactory.negotiate(host);

        	handler.setHost(host);

        } catch(ConnectException conE) {

        	throw conE;

        } catch(IOException ioE) {

        	throw ioE;

        } catch(Exception e) {

        	e.printStackTrace();

        }

    }

    /**

     * <p>Checks the connection to de remote WMS and requests its capabilities.</p>

     * @param override

     *

     */

    public boolean connect(boolean override, ICancellable cancel)

    {

        try {

            if (handler == null) {

                if (getHost().trim().length() > 0) {

                	handler = WCSProtocolHandlerFactory.negotiate(getHost());

                    handler.setHost(getHost());

                } else {

                    // must to specify host first!!!!

                    return false;

                }

            }

            getCapabilities(null, override, cancel);

            describeCoverage(null, override, cancel); //TODO falta posar el onlineresource del describe coverage

            return true;

        } catch (Exception e) {

            e.printStackTrace();

            return false;

        }

    }

    /**

     * Sends a GetCapabilities request using the properties contained by

     * the status. If status is null, then it uses the default configuration.

     * @param override

     * @param WCSStatus, containing the status properties

     */

    private void getCapabilities(WCSStatus status, boolean override, ICancellable cancel) {

        handler.getCapabilities(status, override, cancel);

    }

    /**

     * Sends a DescribeCoverage request using the properties contained by

     * the status.

     * @param override, if true the cache is ignored

     * @param WCSStatus, containing the status properties

     */

    private void describeCoverage(WCSStatus status, boolean override, ICancellable cancel) {

        handler.describeCoverage(status, override, cancel);

        // check it was response or if we need to perform a specific DescribeCoverage for each coverage

        Hashtable layers = handler.getLayers();

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

        while (it.hasNext()) {

        	Object obj = layers.get(it.next());

        	if (obj instanceof CoverageOfferingBrief) {

        		if (status == null)

        			status = new WCSStatus();

        		status.setCoveraName( ((CoverageOfferingBrief) obj).getName());

        		handler.describeCoverage(status, override, cancel);

        	}

        }

        layerPool = handler.getLayers();

    }

    /* (non-Javadoc)

     * @see org.gvsig.remoteClient.RemoteClient#close()

     */

    public void close() {

    }

    /**

     * Returns the title of the service. The title is a human-readable string format

     * used to label the service connection.

     * @return String

     */

	public String getServiceTitle() {

		return handler.serviceInfo.title;

	}

	/**

	 * Returns the service version (1.0.0, 1.1.0, ...).

	 * @return String

	 */

	public String getVersion() {

		return handler.getVersion();

	}

	/**

	 * Returns a brief description of the service, it is a human-readable string.

	 * @return String

	 */

	public String getDescription() {

		return handler.serviceInfo.abstr;

	}

	/**

	 *

	 * @return

	 */

	public ArrayList getFormats() {

		return handler.getFormats();

	}

	/**

	 * Returns a hash table containing the WCSCoverage's produced at parse time using

	 * the coverage names as the Hashtable's keys

	 * @return Hashtable.

	 */

	public Hashtable getCoverageList() {

		return layerPool;

	}

	/**

	 * Given a coverage name, it returns the coverage's title.

	 * @param coverageName

	 * @return String

	 */

	public String getLabel(String coverageName) {

		return ((WCSCoverage) layerPool.get(coverageName)).getTitle();

	}

	/**

	 * Given a coverage name and the CRS name, it returns the extent defined by the

	 * server in the DescribeCoverage document.

	 *

	 * @param coverageName

	 * @param crs

	 * @return Rectangle2D

	 */

	public Rectangle2D getExtent(String coverageName, String crs) {

		BoundaryBox bbox = (BoundaryBox) ((WCSCoverage) layerPool.get(coverageName)).getBbox(crs);;

        if (bbox == null) return null;

        double xmin = bbox.getXmin();

        double xmax = bbox.getXmax();

        double ymin = bbox.getYmin();

        double ymax = bbox.getYmax();

		return new Rectangle2D.Double(xmin, ymin, xmax-xmin, ymax-ymin);

	}

	/**

	 * Sends the GetCoverage request according to the settings passed in the status

	 * argument.

	 * @param status

	 * @return File

	 * @throws ServerErrorException

	 * @throws WCSException

	 */

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

		return handler.getCoverage(status, cancel);

	}

}

/* 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 org.gvsig.remoteclient.wcs;

import java.io.ByteArrayInputStream;

import java.io.File;

import java.io.IOException;

import java.net.MalformedURLException;

import java.net.URL;

import java.util.ArrayList;

import java.util.Hashtable;

import java.util.StringTokenizer;

import org.kxml2.io.KXmlParser;

import org.xmlpull.v1.XmlPullParserException;

import org.gvsig.compat.CompatLocator;

import org.gvsig.compat.lang.StringUtils;

import org.gvsig.compat.net.ICancellable;

import org.gvsig.remoteclient.exceptions.ServerErrorException;

import org.gvsig.remoteclient.exceptions.WCSException;

import org.gvsig.remoteclient.ogc.OGCProtocolHandler;

import org.gvsig.remoteclient.ogc.OGCServiceInformation;

import org.gvsig.remoteclient.utils.ExceptionTags;

import org.gvsig.remoteclient.utils.Utilities;

import org.gvsig.remoteclient.wcs.request.WCSDescribeCoverageRequest;

import org.gvsig.remoteclient.wcs.request.WCSGetCoverageRequest;

/**

 *

 * @author jaume

 *

 */

public abstract class WCSProtocolHandler extends OGCProtocolHandler {

	/**

	 * Encoding used to parse different xml documents.

	 */

	protected String encoding = "UTF-8";

	protected Hashtable layerPool = new Hashtable();

	/**

     * WCS metadata

     */

    protected WCSServiceInformation serviceInfo = new WCSServiceInformation();

    private static final StringUtils stringUtils = CompatLocator.getStringUtils();

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.remoteClient.OGCProtocolHandler#setHost(java.lang.String)

	 */

	public void setHost(String host) {

		try {

			// Validates the URL if doesn't produces an exception

			new URL(host);

			int index = host.indexOf("?");

			if (index == -1)

				super.setHost(host);

			else

				super.setHost(host.substring(0, index));

		}

		catch (MalformedURLException m) {

			// Bad URL -> hold it

			super.setHost(host);

		}

	}

	/**

     * <p>

     * Builds a GetCapabilities request that is sent to the WCS

     * the response will be parse to extract the data needed by the

     * WCS client.

     * </p>

     * @param override, if true the cache is ignored

     */

    public void getCapabilities(WCSStatus status, boolean override, ICancellable cancel) {

           URL request = null;

            try {

                request = new URL(buildCapabilitiesRequest(status));

            }

            catch(Exception e) {

                e.printStackTrace();

            }

            try {

            	if (override)

            	    downloader.removeURL(request);

            	File f =  downloader.downloadFile(request,"wcs_capabilities.xml", cancel);

            	if (f!=null)

            		parseCapabilities(f);

            } catch(Exception e) {

            	e.printStackTrace();

            }

    }

    /**

     * Builds a complete URL-string that can be used to send a GetCapabilities request.

     * @return String

     */

    private String buildCapabilitiesRequest(WCSStatus status) {

    	StringBuffer req = new StringBuffer();

		String symbol = null;

		String onlineResource;

		if (status == null || status.getOnlineResource() == null)

			onlineResource = getHost();

		else

			onlineResource = status.getOnlineResource();

		symbol = getSymbol(onlineResource);

		req.append(onlineResource).append(symbol).append("REQUEST=GetCapabilities&SERVICE=WCS&");

		req.append("VERSION=").append(getVersion()).append("&EXCEPTIONS=XML");

		return req.toString();

    }

    /**

     * parses the data retrieved by the DescribeCoverage XML document

     */

    public abstract boolean parseDescribeCoverage(File f);

    /**

     * Send a DescribeCoverage request using the settings passed in the status argument.

     * If status is null, then default settings are used.

     * @param override

     * @return String

     */

    public void describeCoverage(WCSStatus status, boolean override, ICancellable cancel) {

       try {

    	   WCSDescribeCoverageRequest request = createDescribeCoverageRequest(status);

           File f = request.sendRequest();

        	if (f!=null)

        		parseDescribeCoverage(f);

        } catch(Exception e) {

        	e.printStackTrace();

        }

    }

    /**

     * Send a GetCoverage request using the settings passed in the status.

     * @return String

     */

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

    	try

		{

			//TODO:

			//pass this buildXXXRequest to the WCSProtocolHandlerXXX: The request can depend on the WCS version.

			WCSGetCoverageRequest request = createGetCoverageRequest(status);

            File f = request.sendRequest();

            if (f!=null && Utilities.isTextFile(f)) {

                byte[] data = fileToBytes(f);

	    		WCSException wcsEx = null;

            	String exceptionMessage = parseException(data);

                if (exceptionMessage==null)

                {

                 	String error = new String(data);

                	int pos = error.indexOf("<?xml");

                	if (pos!= -1)

                	{

                		String xml = error.substring(pos,error.length());

                		exceptionMessage = parseException(xml.getBytes());

                	}

                    if (exceptionMessage == null)

                    	exceptionMessage = new String(data);

                }

             	wcsEx = new WCSException(exceptionMessage);

            	wcsEx.setWCSMessage(new String(data));

            	// Since it is an error file, It must be deleted from the cache

            	downloader.removeURL(request);

                throw wcsEx;

            }

			return f;

		}

		catch(IOException e)

		{

			e.printStackTrace();

            throw new ServerErrorException();

		}

    }

    /**

     * Parses the WCS Exception document.

     * @param bytes, byte[]

     * @return

     */

    private String parseException(byte[] data) {

    	// TODO: a?? est? fusilat del WMS, comprovar que funciona.

    	ArrayList errors = new ArrayList();

        KXmlParser kxmlParser = new KXmlParser();

        try

        {

            kxmlParser.setInput(new ByteArrayInputStream(data), encoding);

            kxmlParser.nextTag();

            int tag;

            if ( kxmlParser.getEventType() != KXmlParser.END_DOCUMENT )

            {

                kxmlParser.require(KXmlParser.START_TAG, null, ExceptionTags.EXCEPTION_ROOT);

                tag = kxmlParser.nextTag();

                 while(tag != KXmlParser.END_DOCUMENT)

                 {

                     switch(tag)

                     {

                        case KXmlParser.START_TAG:

                            if (kxmlParser.getName().compareTo(ExceptionTags.SERVICE_EXCEPTION)==0){

                                String errorCode = kxmlParser.getAttributeValue("", ExceptionTags.CODE);

                                errorCode = (errorCode != null) ? "["+errorCode+"] " : "";

                                String errorMessage = kxmlParser.nextText();

                                errors.add(errorCode+errorMessage);

                            }

                            break;

                        case KXmlParser.END_TAG:

                            break;

                     }

                     tag = kxmlParser.nextTag();

                 }

                 //kxmlParser.require(KXmlParser.END_DOCUMENT, null, null);

            }

        }

        catch(XmlPullParserException parser_ex){

            parser_ex.printStackTrace();

        }

        catch (IOException ioe) {

            ioe.printStackTrace();

        }

        String message = errors.size()>0? "" : null;

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

            message += (String) errors.get(i)+"\n";

        }

        return message;

	}	

    /**

     * Builds the GetCapabilitiesRequest according to the OGC WCS Specifications

     * without a VERSION, to get the highest version than a WCS supports.

     */

    public static String buildCapabilitiesSuitableVersionRequest(String _host, String _version) {

		int index = _host.indexOf('?');

		if (index > -1) {

			String host = _host.substring(0, index + 1);

			String query = _host.substring(index + 1, _host.length());

			StringTokenizer tokens = new StringTokenizer(query, "&");

			String newQuery = "", token;

			// If there is a field or a value with spaces, (and then it's on different tokens) -> unify them

			while (tokens.hasMoreTokens()) {

				token = tokens.nextToken().trim();

				if (token.toUpperCase().compareTo("REQUEST=GETCAPABILITIES") == 0)

					continue;

				if (token.toUpperCase().compareTo("SERVICE=WCS") == 0)

					continue;

				if ((_version != null) && (_version.length() > 0)) {

    				if (token.toUpperCase().compareTo("VERSION=" + _version) == 0)

    					continue;

				}

				if (token.toUpperCase().compareTo("EXCEPTIONS=XML") == 0)

					continue;

				newQuery += token + "&";

			}

        	_host = host + newQuery;

		}

		else {

			_host += "?";

		}

    	if ((_version != null) && (_version.compareTo("") != 0))

    		_host += "REQUEST=GetCapabilities&SERVICE=WCS&VERSION=" + _version + "&EXCEPTIONS=XML";

    	else

    		_host += "REQUEST=GetCapabilities&SERVICE=WCS&EXCEPTIONS=XML";

    	return stringUtils.replaceAll(_host, " ", "%20");

    }

	public ArrayList getFormats() {

		return new ArrayList(serviceInfo.formats);

	}       

	public Hashtable getLayers() {

		return layerPool;

	}

	public abstract WCSDescribeCoverageRequest createDescribeCoverageRequest(WCSStatus status);

	public abstract WCSGetCoverageRequest createGetCoverageRequest(WCSStatus status);

	/* (non-Javadoc)

	 * @see org.gvsig.remoteclient.ogc.OGCProtocolHandler#getServiceInformation()

	 */	

	public OGCServiceInformation getServiceInformation() {

		return serviceInfo;

	}	

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

* 

* 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., 51 Franklin Street, Fifth Floor, Boston, 

* MA  02110-1301, USA.

* 

*/

/*

* AUTHORS (In addition to CIT):

* 2009 Iver T.I.  {{Task}}

*/

package org.gvsig.remoteclient.wcs;

import java.util.Hashtable;

import org.gvsig.remoteclient.ogc.OGCClientOperation;

import org.gvsig.remoteclient.utils.CapabilitiesTags;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>

 */

public class WCSOperation extends OGCClientOperation{ 

	protected static Hashtable operations = new Hashtable();

	static{

		operations.put(CapabilitiesTags.GETCAPABILITIES, new WCSOperation(CapabilitiesTags.GETCAPABILITIES));

		operations.put(CapabilitiesTags.DESCRIBECOVERAGE, new WCSOperation(CapabilitiesTags.DESCRIBECOVERAGE));

		operations.put(CapabilitiesTags.GETCOVERAGE, new WCSOperation(CapabilitiesTags.GETCOVERAGE));

	}

	public WCSOperation(String operationName) {

		super(operationName);		

	}

	public WCSOperation(String operationName, String onlineResource) {

		super(operationName, onlineResource);		

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.remoteClient.OGCClientOperation#getOperations()

	 */

	public Hashtable getOperations() {

		return operations;

	}

}

/* 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

 */

/*

 * $Id$ 

 * $Log$

 * Revision 1.9  2006-12-05 16:27:15  fdiaz

 * *** empty log message ***

 *

 * Revision 1.8  2006/05/12 07:45:49  jaume

 * some warnings removed

 *

 * Revision 1.7  2006/04/25 06:47:50  jaume

 * clean up unnecessary imports

 *

 * Revision 1.6  2006/04/19 11:04:51  jaume

 * *** empty log message ***

 *

 * Revision 1.5  2006/03/27 15:20:15  jaume

 * *** empty log message ***

 *

 * Revision 1.3  2006/03/21 11:30:26  jaume

 * some wcs client operation stuff

 *

 * Revision 1.2  2006/03/15 08:54:42  jaume

 * *** empty log message ***

 *

 * Revision 1.1.2.1  2006/03/08 09:08:31  jaume

 * *** empty log message ***

 *

 * Revision 1.1  2006/03/06 15:18:32  jaume

 * *** empty log message ***

 * 

 */

package org.gvsig.remoteclient.wcs;

import java.awt.geom.Rectangle2D;

import org.gvsig.remoteclient.RemoteClientStatus;

/**

 * Describes the status of a WCSclient, so it adds to the Remote client status

 * a list of layers, a list of layer styles, the extent of the map.

 * Provides the functionality to modify these lists.

 * 

 * @author jaume dom?nguez faus - jaume.dominguez@iver.es

 */

public class WCSStatus extends RemoteClientStatus {

	//private String		resolution		= null; TODO do I need it?

	private Rectangle2D	bBox			= null;

	private String		coverageName	= null;

	private String		onlineResource	= null;

	private String		depth			= null;

	private String		times			= null;

	private String		parameters		= null;

	private String		message			= null;

	/**

	 * Sets the Bounding Box that is going to be requested to the server.

	 * @param bBox, Rectangle2D containing the edges of the bounding box

	 */

	public void setExtent(Rectangle2D bBox) {

		this.bBox = bBox;

	}

	/**

	 * Sets the name of the coverage requested to the server.

	 * @param coverageName, String containing the name of the requesting coverage

	 */

	public void setCoveraName(String coverageName) {

		this.coverageName = coverageName;

	}

	/**

	 * Sets the parameter string. The parameter string is the part of the request 

	 * containing the value for the axis as described in the DescribeCoverage

	 * document.

	 * @param parameters

	 */

	public void setParameters(String parameters) {

		this.parameters = parameters;

	}

	/**

	 * Will set the address of the host that serves the following request

	 * @param onlineResources

	 */

	public void setOnlineResource(String onlineResources) {

		this.onlineResource = onlineResources;

	}

	/**

	 * Sets the depth. The depth is the third dimension for the size. 

	 * @param depth, String

	 */

	public void setDepth(String depth) {

		this.depth = depth;

	}

	/**

	 * Returns the address host that will serve the request 

	 * @return String

	 */

	public String getOnlineResource() {

		return onlineResource;

	}

	/**

	 * Return the name of the coverage requested to the server.

	 * @return String containing the name of the requesting coverage

	 */

	public String getCoverageName() {

		return this.coverageName;

	}

	/**

	 * Returns the Bounding Box that is going to be requested to the server.

	 * @return Rectangle2D containing the edges of the bounding box

	 */

	public Rectangle2D getExtent() {

		return this.bBox;

	}

	/**

	 * Returns the depth of the next request.

	 * @return String

	 */

	public String getDepth() {

		return depth;

	}

	/**

	 * Returns the value for the time parameter that will be used in the next request

	 * @return String

	 */

	public String getTime() {

		return times;

	}

	/**

	 * Returns the parameter string.

	 * The parameter string is the part of the request containing the value for the

	 * axis as described in the DescribeCoverage.

	 * @return String

	 */

	public String getParameters() {

		return parameters;

	}

	/**

	 * Sets the value(s) for the time that will be used in the next request. 

	 * @param times

	 */

	public void setTime(String times) {

		this.times = times;

	}

	/**

	 * Returns the message string

	 * @return String

	 */

	public String getMessage() {

		return message;

	}

	/**

	 * Sets the message string 

	 * @param message

	 */

	public void setMessage(String message) {

		this.message = message;

	}

}

/* 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-09-04 16:12:17  jaume

* *** empty log message ***

*

*

*/

package org.gvsig.remoteclient.wcs;

import java.io.IOException;

import org.kxml2.io.KXmlParser;

import org.xmlpull.v1.XmlPullParserException;

import org.gvsig.compat.CompatLocator;

import org.gvsig.compat.lang.StringUtils;

import org.gvsig.remoteclient.utils.BoundaryBox;

import org.gvsig.remoteclient.utils.CapabilitiesTags;

import org.gvsig.remoteclient.utils.DescribeCoverageTags;

public class CoverageOfferingBrief {

	private String name;

	private String label;

	private BoundaryBox		lonLatBbox;

    private static final StringUtils stringUtils = CompatLocator.getStringUtils();

	public String getLabel() {

		return label;

	}

	public void setLabel(String label) {

		this.label = label;

	}

	public BoundaryBox getLonLatBbox() {

		return lonLatBbox;

	}

	public void setLonLatBbox(BoundaryBox lonLatBbox) {

		this.lonLatBbox = lonLatBbox;

	}

	public String getName() {

		return name;

	}

	public void setName(String name) {

		this.name = name;

	}

	public void parse(KXmlParser parser) throws XmlPullParserException, IOException {

		int currentTag;

		boolean end = false;

		parser.require(KXmlParser.START_TAG, null, "wcs:"+CapabilitiesTags.WCS_COVERAGEOFFERINGBRIEF);

		currentTag = parser.next();

		while (!end)

		{

			switch(currentTag)

			{

			case KXmlParser.START_TAG:

				if (parser.getName().toLowerCase().compareTo(CapabilitiesTags.NAME.toLowerCase())==0) {

					this.name = parser.nextText();

				} else if (parser.getName().compareTo(CapabilitiesTags.WCS_LABEL)==0) {

					this.label = parser.nextText();

				} else if (parser.getName().compareTo(DescribeCoverageTags.LONLAT_ENVELOPE)==0) {

					parser.nextTag();

					this.lonLatBbox = new BoundaryBox();

					this.lonLatBbox.setSrs(DescribeCoverageTags.WGS84);

					parser.require(KXmlParser.START_TAG, null, DescribeCoverageTags.GML_POS);

					String[][] coord = new String[2][2];

					coord[0] = stringUtils.split(parser.nextText(), WCSCoverage.SEPARATOR);

					parser.nextTag();

					parser.require(KXmlParser.START_TAG, null, DescribeCoverageTags.GML_POS);

					coord[1] = stringUtils.split(parser.nextText(), WCSCoverage.SEPARATOR);

					this.lonLatBbox.setXmin(Double.parseDouble(coord[0][0]));

					this.lonLatBbox.setYmin(Double.parseDouble(coord[0][1]));

					this.lonLatBbox.setXmax(Double.parseDouble(coord[1][0]));

					this.lonLatBbox.setYmax(Double.parseDouble(coord[1][1]));

				}

			case KXmlParser.END_TAG:

				if (parser.getName().compareTo("wcs:"+CapabilitiesTags.WCS_COVERAGEOFFERINGBRIEF) == 0)

					end = true;

				break;

			case KXmlParser.TEXT:

				break;

			}

			currentTag = parser.next();

		}

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

*

* Copyright (C) 2007-2008 Infrastructures and Transports Department

* of the Valencian Government (CIT)

* 

* 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., 51 Franklin Street, Fifth Floor, Boston, 

* MA  02110-1301, USA.

* 

*/

/*

* AUTHORS (In addition to CIT):

* 2009 {Iver T.I.}   {Task}

*/

package org.gvsig.remoteclient.wcs;

import java.util.HashMap;

import java.util.Vector;

import org.gvsig.remoteclient.ogc.OGCClientOperation;

import org.gvsig.remoteclient.ogc.OGCServiceInformation;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>

 */

public class WCSServiceInformation extends OGCServiceInformation {

	 public String online_resource = null;

     public String version;

     public String name;

     public String scope;

     public String title;

     public String abstr;

     public String keywords;

     public String fees;

     public String operationsInfo;

     public String personname;

     public String organization;

     public String function;

     public String addresstype;

     public String address;

     public String place;

     public String province;

     public String postcode;

     public String country;

     public String phone;

     public String fax;

     public String email;

     public Vector formats;

     public HashMap operations; // operations that WCS supports

     public WCSServiceInformation()

     {

         version = new String();

         name = new String();

         scope = new String();

         title = new String();

         abstr = new String();

         keywords = new String();

         fees = new String();

         operationsInfo = new String();

         personname = new String();

         organization = new String();

         function = new String();

         addresstype = new String();

         address = new String();

         place = new String();

         province = new String();

         postcode = new String();

         country = new String();

         phone = new String();

         fax = new String();

         email = new String();

         operations = new HashMap();

     }

	public OGCClientOperation createOperation(String name) {

		return new WCSOperation(name); 

	}

	public OGCClientOperation createOperation(String name, String onlineResource) {

		return new WCSOperation(name, onlineResource);

	}

}

/* 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

 */

/*

 * $Id$

 * $Log$

 * Revision 1.4  2006-07-18 11:41:05  jaume

 * no hay nada nuevo pero el team synchronize est? pesado

 *

 * Revision 1.3  2006/04/25 06:47:50  jaume

 * clean up unnecessary imports

 *

 * Revision 1.2  2006/03/15 08:54:42  jaume

 * *** empty log message ***

 *

 * Revision 1.1.2.1  2006/03/08 09:08:31  jaume

 * *** empty log message ***

 *

 * Revision 1.1  2006/03/06 15:18:32  jaume

 * *** empty log message ***

 *

 */

package org.gvsig.remoteclient.wcs;

import java.io.DataInputStream;

import java.io.IOException;

import java.io.StringReader;

import java.net.ConnectException;

import java.net.URL;

import java.util.ArrayList;

import java.util.Iterator;

import org.kxml2.io.KXmlParser;

import org.xmlpull.v1.XmlPullParserException;

import org.gvsig.remoteclient.utils.CapabilitiesTags;

/**

 *

 * @author jaume dominguez faus

 *

 */

public class WCSProtocolHandlerFactory {

	public org.gvsig.remoteclient.wcs.WCSProtocolHandler wCSProtocolHandler;

	private static ArrayList supportedVersions = new ArrayList();

	static {

		supportedVersions.add("1.0.0");

	}

	/**

	 * M?todo que dada una respuesta de getCapabilities y un iterador sobre una

	 * coleccion de WCSClient's ordenada descendentemente devuelve el cliente

	 * cuya version es igual o inmediatamente inferior

	 *

	 * @param caps Capabilities con la respuesta del servidor

	 * @param clients Iterador de conjunto ordenado descendientemente

	 *

	 * @return cliente cuya version es igual o inmediatamente inferior

	 * @throws IllegalAccessException

	 * @throws InstantiationException

	 *

	 */

	private static String getDriverVersion(String version, Iterator clients) throws InstantiationException, IllegalAccessException {

		while (clients.hasNext()) {

			String clientVersion = (String)clients.next();

			int ret = version.compareTo(clientVersion);

			if (ret >= 0) {

				return clientVersion;

			}

		}

		return null;

	}

	/**

	 * Establece la versi?n con la que se comunicar? con el servidor y devuelve

	 * el objeto Capabilities obtenido con dicha versi?n

	 *

	 * @param host maquina con la que se negocia

	 *

	 * @return instancia de un cliente capaz de negociar con el host que se

	 *         pasa como par?metro

	 */

	public static WCSProtocolHandler negotiate(String host) throws ConnectException, IOException {

		if (supportedVersions.size() == 0)

		{

			return null;

		}

		try

		{

			String highestVersionSupportedByServer  = getSuitableWCSVersion(host,"");

			if (supportedVersions.contains(highestVersionSupportedByServer))

			{

				// we support the highest version supported by the server

				// this is the best case

				return createVersionDriver(highestVersionSupportedByServer);

			}

			else

			{

				// in case we dont support the highest version from the server

				// we start the negotiation process in which we have to get the higest version

				// the WCS supports and we are able to read.

				Iterator iVersion = supportedVersions.iterator();

				String wcsVersion;

				String gvSIGVersion;

				while (iVersion.hasNext()) {

					gvSIGVersion = (String)iVersion.next();

					wcsVersion = getSuitableWCSVersion(host,gvSIGVersion);

					//TODO:

					//compare with the version returned by the WMS!!!!!

					// send GetCapabilities and read the version to compare.

					int res = wcsVersion.compareTo(gvSIGVersion);

					if (res == 0) { //Si es la misma que nuestra version

						return createVersionDriver(gvSIGVersion);

					} else if (res > 0) { //Si es mayor que nuestra version

						throw new Exception("Server Version too high: " + wcsVersion);

					} else { //Si es menor que nuestra version

						//Obtenemos la primera version menor o igual que tengamos

						String lowerVersion = WCSProtocolHandlerFactory.getDriverVersion(wcsVersion, iVersion);

						if (lowerVersion == null) { //Si no hay ninguna

							throw new Exception("Lowest server version is " + wcsVersion);

						} else {

							if (lowerVersion.equals(wcsVersion)) {

								return createVersionDriver(lowerVersion);

							} else { //Si hay una version menor que la que retorno el servidor

								//iV = lower;

							}

						}

					}

				}

			}//case we had to start the negotiation process.

			return null; // if it did not find any suitable version.

		}

		catch(ConnectException conEx)

		{

			throw conEx;

		}

		catch(IOException ioEx)

		{

			throw ioEx;

		}

		catch(Exception e)

		{

//			e.printStackTrace();

			return null;

		}

	}

	/**

	 * Sends a GetCapabilities to the WCS server to get the version

	 * if the version parameter is null, the WCS will return the highest version supported

	 * if not it will return the lower highest version than the one requested.

	 * @param host

	 * @param version

	 * @return suitable version supported by the server

	 */

	private static String getSuitableWCSVersion(String host, String _version) throws ConnectException, IOException {

		String request = WCSProtocolHandler.buildCapabilitiesSuitableVersionRequest(host, _version);

		String version = new String();

		StringReader reader = null;

		//InputStreamReader reader;

		//InputStream is = null;

		DataInputStream dis = null;

		try {

			URL url = new URL(request);

			byte[] buffer = new byte[1024];//new byte[1024*256];

//			is = url.openStream();

//			reader = new InputStreamReader(is);

			//int numberOfBytes = is.read(buffer);

			//String readed = new String(buffer);

			dis = new DataInputStream(url.openStream());

			dis.readFully(buffer);

			reader = new StringReader(new String(buffer));

			KXmlParser kxmlParser = null;

			kxmlParser = new KXmlParser();

			kxmlParser.setInput(reader);

			kxmlParser.nextTag();

			if ( kxmlParser.getEventType() != KXmlParser.END_DOCUMENT ) {

				if ((kxmlParser.getName().compareTo(CapabilitiesTags.WCS_CAPABILITIES_ROOT1_0_0)==0)) {

					version = kxmlParser.getAttributeValue("", CapabilitiesTags.VERSION);

				}

			}

			// do not forget to close the Stream.

			reader.close();

			dis.close();

			return version;

		} catch(ConnectException conEx) {

			throw new ConnectException(conEx.getMessage());

		} catch(IOException ioEx) {

			throw new IOException(ioEx.getMessage());

		} catch(XmlPullParserException xmlEx) {

			xmlEx.printStackTrace();

			return "";

		} finally {

			if (reader != null) {

				try {

					reader.close();

				} catch(Exception ex) {

					ex.printStackTrace();

				}

			} if (dis != null) {

				try {

					dis.close();

				} catch(Exception ex){

					ex.printStackTrace();

				}

			}

		}

	}

	/**

	 * It creates an instance of a WCSDriver class.

	 *

	 * @param String, with the version of the driver to be created

	 * @return WCSDriver.

	 */

	private static WCSProtocolHandler createVersionDriver(String version) {

		try {

			Class driver;

			version = version.replace('.', '_');

			driver = Class.forName("org.gvsig.remoteclient.wcs.wcs_"+version+".WCSProtocolHandler" + version);

			return (WCSProtocolHandler)driver.newInstance();

		} catch (Exception e) {

			e.printStackTrace();

			//throw new Exception("WCSDriverFactory. Unknown driver version " + e);

			return null;

		}

	}

}

/* 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