Application: gvSIG desktop

package org.gvsig.remoteclient;

import org.gvsig.remoteclient.ogc.OGCClientOperation;

/**

 * This class represents the client status at a certain moment

 * it describes the "graphic" situation or the requirements of the data

 * to be retrieved.

 * 

 */

public abstract class RemoteClientStatus {

	// width and heigh of the map

    private int width;

    private int height;

    //format of the image to be retrieved

    private String format;

    private String infoFormat;

    // spatial reference system of the image to be retrieved

    private String srs;

    // exception format, to be retrieved in case of error

    private String exceptionFormat;

    //To set if the client has to use GET or POST

	private int protocol = OGCClientOperation.PROTOCOL_UNDEFINED;

	public int getWidth() {        

        return width;

    }

    public void setWidth(int _width) {        

    	width = _width;

    } 

    public int getHeight() {                

        return height;

    } 

    public void setHeight(int _height) {        

        height = _height;

    } 

    public String getFormat() {        

        return format;

    }

    public void setFormat(String _format) {        

        format = _format;

    } 

    public String getInfoFormat() {        

        return infoFormat;

    } 

    public void setInfoFormat(String _format) {        

        infoFormat = _format;

    } 

    public String getSrs() {        

        return srs;

    } 

    public void setSrs(String _srs) {        

        srs = _srs;

    } 

    public void setExceptionFormat(String _format) {        

        exceptionFormat = _format;

    } 

    public String getExceptionFormat() {        

        return exceptionFormat;

    }

    /**

	 * @return the protocol

	 */

	public int getProtocol() {

		return protocol;

	}

	/**

	 * @param protocol the protocol to set

	 */

	public void setProtocol(int protocol) {

		this.protocol = protocol;

	}

 }

package org.gvsig.remoteclient;

/**

 * <p></p>

 * 

 */

public abstract class RasterClient extends org.gvsig.remoteclient.RemoteClient implements org.gvsig.remoteclient.IRasterClient {

 }

package org.gvsig.remoteclient.wfs.exceptions;

import java.util.HashMap;

import java.util.Map;

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

 */

/* CVS MESSAGES:

 *

 * $Id$

 * $Log$

 *

 */

/**

 * This exception is thrown when there is a problem 

 * with the GetFeature operation

 * @author Jorge Piera LLodr? (jorge.piera@iver.es)

 */

public class WFSGetFeatureException extends WFSException{

	private static final long serialVersionUID = 1L;

	public WFSGetFeatureException(Throwable e){

		initCause(e);

		initialize();

	}

	/*

	 * (non-Javadoc)

	 * @see com.iver.gvsig.crstoslr.exceptions.LRSToCRSBaseException#initialize()

	 */ 

	protected void initialize() {

		messageKey = "wfs_getFeature_excpetion";

		formatString = "Exception with the GetFeature operation";

		code = serialVersionUID;

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.exceptions.BaseException#values()

	 */

	protected Map values() {

		return new HashMap();

	}

}

package org.gvsig.remoteclient.wfs.exceptions;

import java.util.Hashtable;

import java.util.Map;

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

 */

/* CVS MESSAGES:

 *

 * $Id$

 * $Log$

 * Revision 1.1  2007-02-09 14:11:01  jorpiell

 * Primer piloto del soporte para WFS 1.1 y para WFS-T

 *

 *

 */

/**

 * @author Jorge Piera Llodr? (piera_jor@gva.es)

 */

public class InvalidFormatException extends WFSException {

	private static final long serialVersionUID = 8833249742771533911L;

	private String msg = null;		

	public InvalidFormatException(String msg) {

		this.msg = msg;

		init();			

	}	

	protected Map values() {		

		Hashtable params;

		params = new Hashtable();		

		return params;

	}

	public void init() {

		messageKey = "wfs_invalidFormat";

		formatString = msg;

		code = serialVersionUID;

	}

}

package org.gvsig.remoteclient.wfs.exceptions;

import java.util.Hashtable;

import java.util.Map;

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

 */

/* CVS MESSAGES:

 *

 * $Id$

 * $Log$

 * Revision 1.1  2007-02-09 14:11:01  jorpiell

 * Primer piloto del soporte para WFS 1.1 y para WFS-T

 *

 *

 */

/**

 * @author Jorge Piera Llodr? (piera_jor@gva.es)

 */

public class WFSException extends Exception {

    private static final long serialVersionUID = 1476084093500156070L;

    private String wfsCode = null;

    protected String formatString;

    protected String messageKey;

    protected long code;

    public WFSException() {		

        init();			

    }	

    public WFSException(Throwable cause) {		

        init();	

        initCause(cause);

    }	

    public WFSException(String wfsCode,String message) {		

        init();	

        formatString = message;

        this.wfsCode = wfsCode;

    }	

    public WFSException(String message) {        

        init(); 

        formatString = message;       

    }   

    protected Map values() {		

        Hashtable params;

        params = new Hashtable();		

        return params;

    }

    public void init() {

        messageKey = "wfs_exception";

        formatString = "WFS Exception";

        code = serialVersionUID;

    }

    /**

     * @return Returns the wfsCode.

     */

    public String getWfsCode() {

        return wfsCode;

    }	

}

package org.gvsig.remoteclient.wfs.exceptions;

import java.io.IOException;

import org.kxml2.io.KXmlParser;

import org.xmlpull.v1.XmlPullParserException;

import org.gvsig.remoteclient.utils.CapabilitiesTags;

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

 */

/* CVS MESSAGES:

 *

 * $Id$

 * $Log$

 * Revision 1.1  2007-02-09 14:11:01  jorpiell

 * Primer piloto del soporte para WFS 1.1 y para WFS-T

 *

 *

 */

/**

 * This class parses an exception and returns it

 * @author Jorge Piera Llodr? (piera_jor@gva.es)

 */

public class ExceptionsFactory {

	public static WFSException parseServiceExceptionReport(KXmlParser parser) throws XmlPullParserException, IOException {

		int currentTag;

		boolean end = false;		

		currentTag = parser.next();

		while (!end) 

		{

			switch(currentTag)

			{

			case KXmlParser.START_TAG:

				if (parser.getName().compareToIgnoreCase(CapabilitiesTags.SERVICE_EXCEPTION)==0)

				{

					for (int i=0 ; i<parser.getAttributeCount() ; i++){

						String attName = parser.getAttributeName(i);

						String code = null;

						if (attName.compareTo(CapabilitiesTags.CODE)==0){

							code = parser.getAttributeValue(i);

						}

						if (code != null){

							if (code.compareTo(CapabilitiesTags.INVALID_FORMAT)==0){

								parser.next();

								return new InvalidFormatException(parser.getText());

							}

							//Code unspecified

							parser.next();

							return new WFSException(code,parser.getText());

						}

					}

				}  		                       

				break;

			case KXmlParser.END_TAG:

				if (parser.getName().compareTo(CapabilitiesTags.SERVICE_EXCEPTION_REPORT) == 0)

					end = true;

				break;

			case KXmlParser.TEXT:                   

				break;

			}

			if (!end){

				currentTag = parser.next();

			}

		}   

		return new WFSException();

	}

	public static WFSException parseExceptionReport(KXmlParser parser) throws XmlPullParserException, IOException {

        int currentTag;

        boolean end = false;        

        currentTag = parser.next();

        String code = null;

        while (!end) 

        {

            switch(currentTag)

            {

            case KXmlParser.START_TAG:                

                if (CapabilitiesTags.EXCEPTION.equals(parser.getName()))

                {

                    for (int i=0 ; i<parser.getAttributeCount() ; i++){

                        String attName = parser.getAttributeName(i);                       

                        if (CapabilitiesTags.EXCEPTION_CODE.equals(attName)){

                            code = parser.getAttributeValue(i);

                        }                                    

                    }

                } else if (CapabilitiesTags.EXCEPTION_TEXT.equals(parser.getName())){

                    parser.next();

                    return new WFSException(code, parser.getText());

                }                                  

                break;

            case KXmlParser.END_TAG:

                if (CapabilitiesTags.EXCEPTION_REPORT.equals(parser.getName()))

                    end = true;

                break;

            case KXmlParser.TEXT:                   

                break;

            }

            if (!end){

                currentTag = parser.next();

            }

        }   

        return new WFSException();

    }

}

package org.gvsig.remoteclient.wfs;

import java.awt.geom.Rectangle2D;

import java.util.ArrayList;

import org.gvsig.compat.CompatLocator;

import org.gvsig.compat.lang.StringUtils;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.Geometry.SUBTYPES;

import org.gvsig.fmap.geom.GeometryLocator;

import org.gvsig.fmap.geom.GeometryManager;

import org.gvsig.fmap.geom.exception.CreateGeometryException;

import org.gvsig.fmap.geom.primitive.Envelope;

import org.gvsig.fmap.geom.primitive.GeneralPathX;

import org.gvsig.remoteclient.RemoteClientStatus;

import org.gvsig.remoteclient.wfs.edition.WFSTTransaction;

import org.gvsig.remoteclient.wfs.filters.AbstractFilter;

import org.gvsig.remoteclient.wfs.filters.filterencoding.FilterEncoding;

import org.gvsig.remoteclient.wfs.filters.operations.WFSEnvelopeFilterOperation;

import org.gvsig.remoteclient.wfs.filters.operations.WFSGeometryFilterOperation;

import org.gvsig.remoteclient.wfs.filters.operations.WFSSpatialFilterOperation;

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

 */

/* CVS MESSAGES:

 *

 * $Id$

 * $Log$

 * Revision 1.7  2007-09-20 09:30:12  jaume

 * removed unnecessary imports

 *

 * Revision 1.6  2007/02/09 14:11:01  jorpiell

 * Primer piloto del soporte para WFS 1.1 y para WFS-T

 *

 * Revision 1.5  2006/12/11 11:02:24  ppiqueras

 * Corregido bug -> que se mantenga la frase de filtrado

 *

 * Revision 1.4  2006/10/10 12:52:28  jorpiell

 * Soporte para features complejas.

 *

 * Revision 1.3  2006/06/14 07:54:18  jorpiell

 * Se parsea el online resource que antes se ignoraba

 *

 * Revision 1.2  2006/05/23 13:23:13  jorpiell

 * Se ha cambiado el final del bucle de parseado y se tiene en cuenta el online resource

 *

 * Revision 1.1  2006/04/19 12:51:35  jorpiell

 * A?adidas algunas de las clases del servicio WFS

 *

 *

 */

/**

 * The status of the current WFS connection

 * 

 * @author Jorge Piera Llodr? (piera_jor@gva.es)

 * @see <a href="http://www.opengeospatial.org/standards/wfs">OpenGIS Web Feature Service (WFS) Implementation Specification</a>

 */

public class WFSStatus extends RemoteClientStatus{

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

    /**

	 *  The optional resultType attribute is used to control how 

	 *  a web feature service responds to a GetFeature request.

	 *  The possible values for the attribute are defined in 

	 *  some constants in this class.

	 */

	private int resultType = RESULTYPE_RESULTS;

	/**

	 * The default value results indicates that a web feature 

	 * service should generate a complete response that 

	 * contains all the features that satisfy the request.

	 */

	public static final int RESULTYPE_RESULTS = 0;

	/**

	 * The value hits indicates that a web feature service should process the

	 * GetFeature request and rather than return the entire result set, 

	 * it should simply indicate the number of feature instance of 

	 * the requested feature type(s) that satisfy the request.

	 */

	public static final int RESULTYPE_HITS = 1;

	static final String LOCKACTION_ALL = "ALL"; 

	static final String LOCKACTION_SOME = "SOME"; 

	//WFS attributes

	private String featureName = null;

	private String namespacePrefix = null;

	private String namespaceLocation = null;

	private String[] fields = null;

	private String onlineResource = null;

	private Integer timeout = new Integer(10000);

	private Integer maxFeatures = new Integer(100);	

	private String filterByAttribute = null;

	private WFSSpatialFilterOperation filterByArea = null;

	//Geometry manager

	private static GeometryManager geometryManager = GeometryLocator.getGeometryManager();

	//WFS-T LockFeature attributes

	private String userName = null;

	private String password = null;

	private ArrayList featuresToLock = new ArrayList();

	private ArrayList featuresToLockPropertieName = new ArrayList();

	private ArrayList featuresToLockPropertieValue = new ArrayList();

	private ArrayList featuresLocked = new ArrayList();

	private int expiry = -1;

	private String lockAction = null;

	private Rectangle2D lockedArea = null;

	private String lockedAreaProperty = null;

	//WFS-T Transaction

	private WFSTTransaction transaction = null;

	public WFSStatus(String featureName){

		this(featureName, null);

	}

	public WFSStatus(String featureName, String namespace){

		this.featureName = featureName;

		this.namespaceLocation = namespace;

		setFeatureName(featureName);

		lockAction = LOCKACTION_ALL;

		featuresLocked = new ArrayList();

		featuresLocked = new ArrayList();

		featuresToLockPropertieName = new ArrayList();

		featuresToLockPropertieValue = new ArrayList();		

	}

	/**

	 * @return Returns the buffer.

	 */

	public Integer getMaxFeatures() {

		return maxFeatures;

	}

	/**

	 * @param buffer The buffer to set.

	 */

	public void setMaxFeatures(Integer buffer) {

		if (buffer != null){

			this.maxFeatures = buffer;

		}

	}

	/**

	 * @return Returns the featureName.

	 */

	public String getFeatureName() {

		return featureName;

	}

	public String getFeatureFullName(){

	    if (namespacePrefix == null){

	        return featureName;

	    }else{

	        return namespacePrefix + ":" + featureName;

	    }

	}

	/**

	 * @param featureName The featureName to set.

	 */

	public void setFeatureName(String featureName) {

	    if (featureName != null){

            int index = featureName.indexOf(":");

            if (index>0){

                this.featureName = featureName.substring(index+1, featureName.length());

                namespacePrefix = featureName.substring(0, index);

            }else{

                this.featureName = featureName;

            }

        }	   

	}

	/**

	 * @return Returns the fields.

	 */

	public String[] getFields() {

		if (fields == null){

			fields = new String[0];

		}

		return fields;

	}

	/**

	 * @param fields The fields to set.

	 */

	public void setFields(String[] fields) {

		this.fields = fields;

	}

	public void setFields(String fields) {

		if (fields == null){

			return;

		}

		this.fields = stringUtils.split(fields, ",");		

	}

	/**

	 * @return Returns the password.

	 */

	public String getPassword() {

		return password;

	}

	/**

	 * @param password The password to set.

	 */

	public void setPassword(String password) {

		this.password = password;

	}

	/**

	 * @return Returns the timeout.

	 */

	public Integer getTimeout() {

		return timeout;

	}

	/**

	 * @param timeout The timeout to set.

	 */

	public void setTimeout(Integer timeout) {

		if (timeout != null){

			this.timeout = timeout;

		}

	}

	/**

	 * @return Returns the userName.

	 */

	public String getUserName() {

		return userName;

	}

	/**

	 * @param userName The userName to set.

	 */

	public void setUserName(String userName) {

		this.userName = userName;

	}

	public String getOnlineResource() {

		return onlineResource;

	}

	public void setOnlineResource(String url) {

		onlineResource = url;

	}

	/**

	 * @return Returns the filterQuery.

	 */

	public String getFilterByAttribute() {

		return filterByAttribute;

	}

	/**

	 * @param filterQuery The filterQuery to set.

	 */

	public void setFilterByAttribute(String filterQuery) {

		this.filterByAttribute = filterQuery;

	}	

	/**

	 * @param filterByArea 

	 * the filterByArea to set

	 * @param operation

	 * The geometric operation to apply. It has to be a value from 

	 * {@link AbstractFilter}

	 */

	public void setFilterByArea(Geometry geometry, String attributeName, String srs, Integer operation) {

		if (geometry == null){

			return;

		}

		if (attributeName == null){

			attributeName = "the_geom";

		}

		if (operation == null){

			operation = new Integer(AbstractFilter.GEOMETRIC_OPERATOR_INTERSECT);

		}

		//TODO add a manager to register this

		this.filterByArea = new WFSGeometryFilterOperation(geometry,

				operation.intValue(),

				attributeName, 

				getNamespacePrefix(),

				getNamespaceLocation(),

				srs);				

	}	

	public void removeFilterByArea(){

	    this.filterByArea = null;

	}

	public void removeFilterByAttribute(){

	    this.filterByAttribute = null;

	}

	public void removeAllFilters(){

	    removeFilterByArea();

	    removeFilterByAttribute();

	}

	/**

	 * @param filterByArea 

	 * the filterByArea to set

	 * @param operation

	 * The geometric operation to apply. It has to be a value from 

	 * {@link AbstractFilter}

	 */

	public void setFilterByArea(Envelope envelope, String attributeName, String srs, Integer operation) {

		if (envelope == null){

			return;

		}

		if (attributeName == null){

			attributeName = "the_geom";

		}

		if (operation == null){

			operation = new Integer(AbstractFilter.GEOMETRIC_OPERATOR_INTERSECT);

		}

		this.filterByArea = new WFSEnvelopeFilterOperation(envelope,

				operation.intValue(),

				attributeName, 

				getNamespacePrefix(),

				getNamespaceLocation(),

				srs);				

	}	

	/**

	 * @return the filterByArea

	 */

	public WFSSpatialFilterOperation getFilterByArea() {

		return filterByArea;

	}

	/**

	 * @return the filterQueryLocked

	 */

	public String getFilterQueryLocked() {

		FilterEncoding filter = new FilterEncoding(this);

		filter.setQualified(true);

		filter.setNamepacePrefix(null);

		filter.setHasBlankSpaces(false);

		return getFilterQueryLocked(filter);	

	}

	/**

	 * @return the filterQueryLocked

	 */

	public String getFilterQueryLockedPost() {

		FilterEncoding filter = new FilterEncoding(this);

		filter.setQualified(true);

		return getFilterQueryLocked(filter);

	}

	/**

	 * Create a filter encoding request

	 * @param filter

	 * @return

	 */

	private String getFilterQueryLocked(FilterEncoding filter){

		if ((featuresToLock.size() == 0) && 

				(getLockedArea() == null) &&

				(featuresToLockPropertieName.size() == 0)){

			return null;

		}

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

			filter.addFeatureById(featuresToLock.get(i));

		}

		if (featuresToLockPropertieName.size() > 0){

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

				filter.addAndClause((String)featuresToLockPropertieName.get(i),

						(String)featuresToLockPropertieValue.get(i));						

			}				

		}

		if (lockedArea != null){

			GeneralPathX generalPath = new GeneralPathX();

			generalPath.moveTo(lockedArea.getMinX(), lockedArea.getMinY());

			generalPath.lineTo(lockedArea.getMaxX(), lockedArea.getMinY());

			generalPath.lineTo(lockedArea.getMaxX(), lockedArea.getMaxY());

			generalPath.lineTo(lockedArea.getMinX(), lockedArea.getMaxY());

			generalPath.lineTo(lockedArea.getMinX(), lockedArea.getMinY());

			try {

				filter.clearSpatialFilters();

				filter.addSpatialFilter(geometryManager.createSurface(generalPath, SUBTYPES.GEOM2D),

						lockedAreaProperty, 

						getNamespacePrefix(),

						getNamespaceLocation(),

						getSrs(), 

						AbstractFilter.BBOX_ENCLOSES);

			} catch (CreateGeometryException e) {

				return null;

			}

		}

		return filter.toString();	

	}

	/**

	 * @return the expiry

	 */

	public int getExpiry() {

		return expiry;

	}

	/**

	 * @param expiry the expiry to set

	 */

	public void setExpiry(int expiry) {

		this.expiry = expiry;

	}

	/**

	 * @return the lockAction

	 */

	public String getLockAction() {

		return lockAction;

	}

	/**

	 * Set the lock action to all

	 */

	public void setLockActionToAll() {

		lockAction = LOCKACTION_ALL;

	}

	/**

	 * Set teh lock action to some

	 */

	public void setLockActionToSome() {

		lockAction = LOCKACTION_SOME;

	}

	public WFSTTransaction createNewTransaction(){

	    transaction = new WFSTTransaction(this);

	    return transaction;

	}

	public WFSTTransaction getTransaction(){

	    return transaction;

	}

	/**

	 * @return the neumber of features blocked

	 */

	public int getFeaturesToLockSize() {

		return featuresToLock.size();

	}

	/**

	 * Gets an identifier of a feature that is blocked

	 * @param i

	 * The id position

	 * @return

	 * The Id

	 */

	public String getFeatureToLockAt(int i){

		if (i>featuresToLock.size()){

			return null;

		}

		return (String)featuresToLock.get(i);

	}

	/**

	 * Remove all the features to lock

	 */

	public void removeFeaturesToLock() {

		featuresToLock.clear();

		featuresLocked.clear();

		featuresToLockPropertieName.clear();

		featuresToLockPropertieValue.clear();

	}

	/**

	 * Adds a new feature locked

	 * @param idFeature

	 * the feature id

	 */

	public void addFeatureToLock(String idFeature) {

		featuresToLock.add(idFeature);

	}

	/**

	 * Adds a new feature locked

	 * @param idFeature

	 * the feature id

	 */

	public void addFeatureToLock(String propertyName, String propertyValue){

		featuresToLockPropertieName.add(propertyName);

		featuresToLockPropertieValue.add(propertyValue);

	}

	/**

	 * @return the idsLocked size

	 */

	public int getFeaturesLocked() {

		return featuresLocked.size();

	}

	/**

	 * Gets an identifier tha is blocked

	 * @param i

	 * The id position

	 * @return

	 * The Id

	 */

	public String getFeatureLockedAt(int i){

		if (i>featuresLocked.size()){

			return null;

		}

		return (String)featuresLocked.get(i);

	}

	/**

	 * Adds a new Id

	 * @param idLocked

	 * the idLocked to add

	 */

	public void addFeatureLocked(String lockId) {

		featuresLocked.add(lockId);

	}

	/**

	 * @return the lockedArea

	 */

	public Rectangle2D getLockedArea() {

		return lockedArea;

	}

	/**

	 * @param lockedArea the lockedArea to set

	 */

	public void setLockedArea(Rectangle2D lockedArea, String lockedAreaProperty) {

		this.lockedArea = lockedArea;

		this.lockedAreaProperty = lockedAreaProperty;

	}

	/**

	 * @return the namespace prefix

	 */

	public String getNamespacePrefix(){

		return namespacePrefix;

	}

	/**

	 * @return the namespace URL

	 */

	public String getNamespaceLocation(){

		return namespaceLocation;

	}

	/**

	 * @param namespaceprefix the namespaceprefix to set

	 */

	public void setNamespacePrefix(String namespacePrefix) {

		this.namespacePrefix = namespacePrefix;

	}

	/**

	 * @param namespace the namespace to set

	 */

	public void setNamespaceLocation(String namespaceLocation) {

		this.namespaceLocation = namespaceLocation;		

	}

	/**

	 * @return the resultType

	 */

	public int getResultType() {

		return resultType;

	}

	/**

	 * @param resultType the resultType to set

	 */

	public void setResultType(int resultType) {

		this.resultType = resultType;

	}

}

package org.gvsig.remoteclient.wfs;

import java.io.File;

import java.io.FileReader;

import java.io.IOException;

import java.io.Reader;

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.compat.CompatLocator;

import org.gvsig.compat.lang.StringUtils;

import org.gvsig.remoteclient.utils.CapabilitiesTags;

import org.gvsig.remoteclient.utils.EncodingXMLParser;

import org.gvsig.remoteclient.utils.Utilities;

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

 */

/* CVS MESSAGES:

 *

 * $Id$

 * $Log$

 * Revision 1.2  2007-02-09 14:11:01  jorpiell

 * Primer piloto del soporte para WFS 1.1 y para WFS-T

 *

 * Revision 1.1  2006/04/19 12:51:35  jorpiell

 * A?adidas algunas de las clases del servicio WFS

 *

 *

 */

/**

 * @author Jorge Piera Llodr? (piera_jor@gva.es)

 */

public class WFSProtocolHandlerFactory {

	public WFSProtocolHandler wFSProtocolHandler;

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

	private static ArrayList supportedVersions = new ArrayList();

	static {

		supportedVersions.add("1.0.0");

		supportedVersions.add("1.1.0");

	}

	/**

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

	 * coleccion de WFSClient'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 WFSProtocolHandler negotiate(String host) throws ConnectException, IOException {

		if (supportedVersions.size() == 0){

			return null;

		}

		try	{        	

			String highestVersionSupportedByServer  = getSuitableWFSVersion(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 WFS supports and we are able to read.

				Iterator iVersion = supportedVersions.iterator();

				String wfsVersion;

				String gvSIGVersion;

				while (iVersion.hasNext()) { 

					gvSIGVersion = (String)iVersion.next();

					wfsVersion = getSuitableWFSVersion(host,gvSIGVersion);

					//TODO:

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

					// send GetCapabilities and read the version to compare.

					int res = wfsVersion.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: " + wfsVersion);

					} else { //Si es menor que nuestra version

						//Obtenemos la primera version menor o igual que tengamos

						String lowerVersion = WFSProtocolHandlerFactory.getDriverVersion(wfsVersion, iVersion);

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

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

						} else {

							if (lowerVersion.equals(wfsVersion)) { 

								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 WFS server to get the version

	 * if the version parameter is null, the WFS 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 getSuitableWFSVersion(String host, String _version) throws ConnectException, IOException {    	 

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

		String version = new String(); 

		Reader reader = null;

		try {   	

			File file = Utilities.downloadFile(new URL(request), "wfs-suitable-version", null);

			reader = new FileReader(file);

			EncodingXMLParser kxmlParser = new EncodingXMLParser();

			kxmlParser.setInput(reader);		

			kxmlParser.nextTag();

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

				String tag = kxmlParser.getName();

				if (stringUtils.split(tag, ":").length == 2){

					tag = stringUtils.split(tag, ":")[1];

				}

				if ((tag.compareTo(CapabilitiesTags.WFS_CAPABILITIES_ROOT1_0_0)==0)) {

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

				}

			}

			// do not forget to close the Stream.    		

			reader.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(); 

				}

			}

		} 

	}

	/**

	 * It creates an instance of a WFSDriver class.

	 *

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

	 * @return WFSDriver.

	 */

	public static WFSProtocolHandler createVersionDriver(String version) {    	   

		try {

			Class driver;

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

			driver = Class.forName("org.gvsig.remoteclient.wfs.wfs_"+version+".WFSProtocolHandler" + version);

			return (WFSProtocolHandler)driver.newInstance();

		} catch (Exception e) {

			e.printStackTrace();

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

			return null;

		}

	}    

}