/ - Diff - Application: gvSIG desktop - gvSIG

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.exceptions;
     /**
      * <p>
      * Exception thrown when an unexpected response to a request was obtained
      * from a server. It denotes that the server could not process the request
      * by a critical error and it could not answer a service-specific defined
      * exception.
      * </p>
      * <p>
      * Use it to distinguish a server exception that is not part of a service
      * exception definition.
      * </p>
      * @author jaume
+     *
      */
     public class ServerErrorException extends Exception {
     	private static final long serialVersionUID = 1L;
     	public ServerErrorException(){
             super();
+        }
         public ServerErrorException(String message){
             super(message);
+        }
         public ServerErrorException(String message, Throwable e){
             super(message, e);
+        }
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient;
     /**
      * <p></p>
+     *
      */
     public interface ILayer {
     /**
      * <p>Does ...</p>
+     *
+     *
      * @return
      */
         public String getName();
     /**
      * <p>Does ...</p>
+     *
+     *
      * @param _name
      */
         public void setName(String _name);
     /**
      * <p>Does ...</p>
+     *
+     *
      * @param _title
      */
         public void setTitle(String _title);
     /**
      * <p>Does ...</p>
+     *
+     *
      * @return
      */
         public String getTitle();
     /**
      * <p>Does ...</p>
+     *
+     *
      * @return
      */
         public String getAbstract();
     /**
      * <p>Does ...</p>
+     *
+     *
      * @param _abstract
      */
         public void setAbstract(String _abstract);
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient;
     /**
      * <p></p>
+     *
      */
     public interface IRasterClient {
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.ogc;
     import java.util.Hashtable;
     public abstract class OGCClientOperation {
     	public static final int PROTOCOL_UNDEFINED = -1;
     	public static final int PROTOCOL_GET = 0;
     	public static final int PROTOCOL_POST = 1;
     	protected String operationName;
     	protected String onlineResource;
     	public OGCClientOperation(String operationName) {
     		super();
     		this.operationName = operationName;
+    	}
     	public OGCClientOperation(String operationName, String onlineResource) {
     		this.onlineResource = onlineResource;
     		this.operationName = operationName;
+    	}
     	public abstract Hashtable getOperations();
     	/**
     	 * @return Returns the onlineResource.
     	 */
     	public String getOnlineResource() {
     		return onlineResource;
+    	}
     	/**
     	 * @param onlineResource The onlineResource to set.
     	 */
     	public void setOnlineResource(String onlineResource) {
     		this.onlineResource = onlineResource;
+    	}
     	/**
     	 * @return Returns the operationName.
     	 */
     	public String getOperationName() {
     		return operationName;
+    	}
     	/**
     	 * @param operationName The operationName to set.
     	 */
     	public void setOperationName(String operationName) {
     		this.operationName = operationName;
+    	}
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.ogc;
     import java.io.File;
     import java.io.FileInputStream;
     import java.io.IOException;
     import org.kxml2.io.KXmlParser;
     import org.xmlpull.v1.XmlPullParserException;
     import org.gvsig.compat.CompatLocator;
     import org.gvsig.compat.net.Downloader;
     import org.gvsig.remoteclient.utils.CapabilitiesTags;
     public abstract class OGCProtocolHandler {
         protected static final Downloader downloader = CompatLocator.getDownloader();
         /**
          * procotol handler name
          */
         protected String name;
         /**
          * protocol handler version
          */
         protected String version;
         /**
          * host of the WMS to connect
          */
         protected String host;
         /**
          *  port number of the comunication channel of the WMS to connect
          */
         protected String port;
         /**
          * @return Returns the host.
          */
         public String getHost() {
             return host;
+        }
         /**
          * @param host The host to set.
          */
         public void setHost(String host) {
             this.host = host;
+        }
         /**
          * @return Returns the name.
          */
         public String getName() {
             return name;
+        }
         /**
          * @param name The name to set.
          */
         public void setName(String name) {
             this.name = name;
+        }
         /**
          * @return Returns the port.
          */
         public String getPort() {
             return port;
+        }
         /**
          * @param port The port to set.
          */
         public void setPort(String port) {
             this.port = port;
+        }
         /**
          * @return Returns the version.
          */
         public String getVersion() {
             return version;
+        }
         /**
          * @param version The version to set.
          */
         public void setVersion(String version) {
             this.version = version;
+        }
         /**
          * parses the data retrieved by the Capabilities XML document
          */
         public abstract boolean parseCapabilities(File f);
         public abstract OGCServiceInformation getServiceInformation();
         /**
          * Just for not repeat code. Gets the correct separator according
          * to the server URL
          * @param h
          * @return
          */
         protected static String getSymbol(String h) {
             String symbol;
             if (h.indexOf("?")==-1)
                 symbol = "?";
             else if (h.indexOf("?")!=h.length()-1)
                 symbol = "&";
             else
                 symbol = "";
             return symbol;
+        }
         /**
          * Parse an operation into a DcpType tag
          * @param parser
          * The KXMLParser
          * @param operation
          * The WFS operation to parse
          * @throws IOException
          * @throws XmlPullParserException
          */
         protected void parserDcpType(KXmlParser parser, String operation) throws XmlPullParserException, IOException {
             int currentTag;
             boolean end = false;
             currentTag = parser.next();
             while (!end)
+            {
                 switch(currentTag)
+                {
                 case KXmlParser.START_TAG:
                     if(parser.getName().compareTo(CapabilitiesTags.HTTP)==0){
                         parseHTTPTag(parser, operation);
+                    }
                     break;
                 case KXmlParser.END_TAG:
                     if (parser.getName().compareTo(CapabilitiesTags.DCPTYPE) == 0)
                         end = true;
                     break;
                 case KXmlParser.TEXT:
                     break;
+                }
                 if (!end){
                     currentTag = parser.next();
+                }
+            }
+        }
         /**
          * Parse an operation into a HTTP tag
          * @param parser
          * The KXMLParser
          * @param operation
          * The WFS operation to parse
          * @throws IOException
          * @throws XmlPullParserException
          */
         protected void parseHTTPTag(KXmlParser parser, String operation) throws XmlPullParserException, IOException {
             int currentTag;
             boolean end = false;
             currentTag = parser.next();
             int protocol = -1;
             while (!end)
+            {
                 switch(currentTag)
+                {
                 case KXmlParser.START_TAG:
                     String value = null;
                     if(parser.getName().compareTo(CapabilitiesTags.GET)==0){
                         protocol = OGCClientOperation.PROTOCOL_GET;
                         addOperationByAttribute(parser, operation, protocol);
                     }else if(parser.getName().compareTo(CapabilitiesTags.POST)==0){
                         protocol = OGCClientOperation.PROTOCOL_POST;
                         addOperationByAttribute(parser, operation, protocol);
                     }else if(parser.getName().compareTo(CapabilitiesTags.ONLINERESOURCE)==0){
                         addOperationByAttribute(parser, operation, protocol);
+                    }
                     break;
                 case KXmlParser.END_TAG:
                     if (parser.getName().compareTo(CapabilitiesTags.HTTP) == 0)
                         end = true;
                     break;
                 case KXmlParser.TEXT:
                     break;
+                }
                 if (!end){
                     currentTag = parser.next();
+                }
+            }
+        }
         /**
          * Add an operation and the online resource
          * @param parser
          * The parser
          * @param operation
          * The operation to add
          * @param protocol
          * The parser to add
          */
         protected void addOperationByAttribute(KXmlParser parser, String operation, int protocol){
             String value = null;
             if (protocol > -1){
                 for (int i=0 ; i<parser.getAttributeCount() ; i++){
                     if ((parser.getAttributeName(i).toUpperCase().compareTo(CapabilitiesTags.ONLINERESOURCE.toUpperCase()) == 0) ||
                         (parser.getAttributeName(i).equals(CapabilitiesTags.XLINK_HREF))){
                         value = parser.getAttributeValue(i);
+                    }
+                }
                 if (value == null){
                     getServiceInformation().addOperation(operation, protocol);
                 }else{
                     getServiceInformation().addOperation(operation, protocol, value);
+                }
+            }
+        }
         /**
          * Copy the file in a byte array
          * @param file
          * The file to copy
          * @return
          * An array of bytes
          * @throws IOException
          */
         protected byte[] fileToBytes(File file) throws IOException{
             FileInputStream fis = null;
             byte[] bytes = null;
             try{
                 fis = new FileInputStream(file);
                 long length = file.length();
                 bytes = new byte[(int)file.length()];
                 int offset = 0;
                 int numRead = 0;
                 while (offset < bytes.length && (numRead=fis.read(bytes, offset, bytes.length-offset)) >= 0)
+                {
                     offset += numRead;
+                }
             }catch (IOException e) {
                 throw e;
             }finally{
                 if (fis != null){
                     fis.close();
+                }
+            }
             return bytes;
+        }
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.ogc.request;
     import java.io.File;
     import java.io.IOException;
     import java.net.ConnectException;
     import java.net.MalformedURLException;
     import java.net.URL;
     import java.net.UnknownHostException;
     import org.gvsig.compat.CompatLocator;
     import org.gvsig.compat.lang.StringUtils;
     import org.gvsig.compat.net.ICancellable;
     import org.gvsig.remoteclient.RemoteClientStatus;
     import org.gvsig.remoteclient.ogc.OGCClientOperation;
     import org.gvsig.remoteclient.ogc.OGCProtocolHandler;
     import org.gvsig.remoteclient.utils.Utilities;
     public abstract class OGCRequest {
     	protected RemoteClientStatus status = null;
     	protected OGCProtocolHandler protocolHandler = null;
     	protected boolean isDeleted = false;
     	protected static final String XMLTAG_STARTCHARACTER = "<";
     	protected static final String XMLTAG_FINISHCHARACTER = "</";
     	protected static final String XMLTAG_ENDCHARACTER = ">";
     	private static final StringUtils stringUtils = CompatLocator.getStringUtils();
     	public OGCRequest(RemoteClientStatus status, OGCProtocolHandler protocolHandler) {
     		super();
     		this.status = status;
     		this.protocolHandler = protocolHandler;
+    	}
     	/**
     	 * Send a request to the server.
     	 * @return
     	 * The server reply
     	 * @throws IOException
     	 * @throws UnknownHostException
     	 * @throws ConnectException
     	 */
     	public File sendRequest(ICancellable cancel) throws ConnectException, UnknownHostException, IOException{
     		//if the status is null is because is a GetCapabilities operation
     		if (status != null){
     			if (status.getProtocol() != OGCClientOperation.PROTOCOL_UNDEFINED){
     				if (status.getProtocol() == OGCClientOperation.PROTOCOL_GET){
     					String onlineResource = protocolHandler.getHost();
     					String symbol = getSymbol(onlineResource);
     					onlineResource = onlineResource + symbol;
     					return sendHttpGetRequest(onlineResource, cancel);
     				}else{
     					String onlineResource = protocolHandler.getHost();
     					return sendHttpPostRequest(onlineResource);
+    				}
+    			}
+    		}
     		//if exists an online resource for the GET operation
     		String onlineResource = protocolHandler.getServiceInformation().getOnlineResource(getOperationName(), OGCClientOperation.PROTOCOL_GET);
     		if (onlineResource != null){
     			String symbol = getSymbol(onlineResource);
     			onlineResource = onlineResource + symbol;
     			return sendHttpGetRequest(onlineResource, cancel);
+    		}
     		//if exists an online resource for the POST operation
     		onlineResource =  protocolHandler.getServiceInformation().getOnlineResource(getOperationName(), OGCClientOperation.PROTOCOL_POST);
     		if (onlineResource != null){
     			return sendHttpPostRequest(onlineResource);
+    		}
     		//If the online resource doesn't exist, it tries with the server URL and GET
     		onlineResource = protocolHandler.getHost();
     		String symbol = getSymbol(onlineResource);
     		onlineResource = onlineResource + symbol;
     		return sendHttpGetRequest(onlineResource, cancel);
+    	}
     	protected abstract String getHttpGetRequest(String onlineResource);
     	protected abstract String getHttpPostRequest(String onlineResource);
     	protected abstract String getTempFilePrefix();
     	protected abstract String getOperationName();
     	protected abstract String getSchemaLocation();
     	/**
     	 * @return the URL used in the HTTP get operation
     	 * @throws MalformedURLException
     	 */
     	public URL getURL() throws MalformedURLException{
     		String onlineResource = protocolHandler.getServiceInformation().getOnlineResource(getOperationName(), OGCClientOperation.PROTOCOL_GET);
     		if (onlineResource != null){
     			String symbol = getSymbol(onlineResource);
     			onlineResource = onlineResource + symbol;
     			return new URL(getHttpGetRequest(onlineResource));
+    		}
     		//If the online resource doesn't exist, it tries with the server URL and GET
     		onlineResource = protocolHandler.getHost();
     		String symbol = getSymbol(onlineResource);
     		onlineResource = onlineResource + symbol;
     		return new URL(getHttpGetRequest(onlineResource));
+    	}
     	/**
     	 * Send a Http request using the get protocol
     	 * @param onlineResource
     	 * @return
     	 * @throws ConnectException
     	 * @throws UnknownHostException
     	 * @throws IOException
     	 */
     	private File sendHttpGetRequest(String onlineResource, ICancellable cancel) throws ConnectException, UnknownHostException, IOException{
     		URL url = new URL(stringUtils.replaceAll(getHttpGetRequest(onlineResource), " ", "%20"));
     		if (isDeleted()){
     			Utilities.removeURL(url);
+    		}
     		return Utilities.downloadFile(url, getTempFilePrefix(), cancel);
+    	}
     	/**
     	 * Send a Http request using the post protocol
     	 * @param onlineResource
     	 * @return
     	 * @throws ConnectException
     	 * @throws UnknownHostException
     	 * @throws IOException
     	 */
     	private File sendHttpPostRequest(String onlineResource) throws ConnectException, UnknownHostException, IOException{
     		URL url = new URL(onlineResource);
     		String data = getHttpPostRequest(onlineResource);
     		if (isDeleted()){
     			Utilities.removeURL(url+data);
+    		}
     		return Utilities.downloadFile(url, data, getTempFilePrefix(), null);
+    	}
     	/**
     	 * Just for not repeat code. Gets the correct separator according
     	 * to the server URL
     	 * @param h
     	 * @return
     	 */
     	protected static String getSymbol(String h) {
     		String symbol;
     		if (h.indexOf("?")==-1)
     			symbol = "?";
     		else if (h.indexOf("?")!=h.length()-1)
     			symbol = "&";
     		else
     			symbol = "";
     		return symbol;
+    	}
     	public boolean isDeleted() {
     		return isDeleted;
+    	}
     	public void setDeleted(boolean isDeleted) {
     		this.isDeleted = isDeleted;
+    	}
     	protected String createXMLStartTag(String tagName){
     	    return XMLTAG_STARTCHARACTER + tagName + XMLTAG_ENDCHARACTER;
+    	}
        protected String createXMLEndtTag(String tagName){
             return XMLTAG_FINISHCHARACTER + tagName + XMLTAG_ENDCHARACTER;
+        }
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.ogc;
     import java.util.HashMap;
     import java.util.Hashtable;
     import java.util.Iterator;
     public abstract class OGCServiceInformation {
     	public String online_resource = null;
     	protected HashMap operationsGet = new HashMap();
     	protected HashMap operationsPost = new HashMap();
     	/**
     	 * @return Returns the online_resource.
     	 */
     	 public String getOnline_resource() {
     		return online_resource;
+    	}
     	 public abstract OGCClientOperation createOperation(String name);
     	 public abstract OGCClientOperation createOperation(String name, String onlineResource);
     	/**
     	 * Add a new supported operation
     	 * @param operation
     	 * The operation to support
     	 * @param protocol
     	 * The HTTP protocol (Get or Post)
     	 */
     	public void addOperation(String operation, int protocol){
     		if (protocol == OGCClientOperation.PROTOCOL_GET){
     			operationsGet.put(operation, createOperation(operation));
     		}else if (protocol == OGCClientOperation.PROTOCOL_POST){
     			operationsPost.put(operation, createOperation(operation));
+    		}
+    	}
     	/**
     	 * Add a new supported operation
     	 * @param operation
     	 * The operation to support
     	 * @param protocol
     	 * The HTTP protocol (Get or Post)
     	 * @param onlineResource
     	 * The online resource
     	 */
     	public void addOperation(String operation, int protocol, String onlineResource){
     		if (protocol == OGCClientOperation.PROTOCOL_GET){
     			operationsGet.put(operation, createOperation(operation, onlineResource));
     		}else if (protocol == OGCClientOperation.PROTOCOL_POST){
     			operationsPost.put(operation, createOperation(operation, onlineResource));
+    		}
+    	}
     	/**
     	 * Gest the online resource for a concrete operation
     	 * @param operation
     	 * The operation
     	 * @param protocol
     	 * The HTTP protocol (Get or Post)
     	 * @return
     	 * The online resource
     	 */
     	public String getOnlineResource(String operation, int protocol){
     		OGCClientOperation op = null;
     		if (protocol == OGCClientOperation.PROTOCOL_GET){
     			op = (OGCClientOperation)operationsGet.get(operation);
     		}else if (protocol == OGCClientOperation.PROTOCOL_POST){
     			op = (OGCClientOperation)operationsPost.get(operation);
+    		}
     		if ((op == null) ||
     				(op.getOnlineResource() == null) ||
     				(op.getOnlineResource().equals(""))){
     			return null;
+    		}
     		return op.getOnlineResource();
+    	}
     	/**
     	 * Gets the online resource for a concrete operation.
     	 * The default protocol is GET
     	 * @param operation
     	 * The operation
     	 * @return
     	 * The online resource
     	 */
     	public String getOnlineResource(String operation){
     		return getOnlineResource(operation, OGCClientOperation.PROTOCOL_GET);
+    	}
     	/**
     	 * Get a hash map with the supported operations
     	 * @return
     	 */
     	public Hashtable getSupportedOperationsByName(){
     		Hashtable operations = new Hashtable();
     		Iterator getIt = operationsGet.keySet().iterator();
     		while (getIt.hasNext()){
     			String id = (String)getIt.next();
     			OGCClientOperation operation = (OGCClientOperation)operationsGet.get(id);
     			operations.put(operation.getOperationName(),
     					operation.getOnlineResource());
+    		}
     		return operations;
+    	}
     	public boolean isOperationSupported(String operationName){
     	    if (operationsGet.containsKey(operationName)){
     	        return true;
+    	    }
     	    if (operationsPost.containsKey(operationName)){
                 return true;
+            }
     	    return false;
+    	}
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.taskplanning.retrieving;
     import java.io.File;
     import java.net.MalformedURLException;
     import java.util.Hashtable;
     import java.util.TreeMap;
     import org.gvsig.remoteclient.taskplanning.IQueue;
     /**
      * pa administrar les tasques (la hist?ria aquella
      *  de que hi haja una cola per a cada servidor)
      * @author Luis W. Sevilla (sevilla_lui@gva.es)
      */
     public class RequestManager {
     	private boolean debug = true;
     	private static RequestManager instance;
     	private TreeMap serversTable = new TreeMap();
     	private RequestManager() {} // Avoid public instantiation
     	public static RequestManager getInstance() {
     		if (instance == null)
     			instance = new RequestManager();
     		return instance;
+    	}
     	public URLRetrieveTask addURLRequest(URLRequest request, RetrieveListener listener) {
     		try {
     			// TODO canviar per a quetorne el Request antic, que la request guarde el
     			// seu estat aix? com la llista de listeners
     			File f = getPreviousDownloadedURLRequest(request);
     			if (f!=null) {
     				// The file was already requested and it is in the cache or
     				// the download is in process
     				// Overwrite the file name with the file in the cache's one.
     				request.setFileName(f.getAbsolutePath());
     				System.out.println(request.getUrl()+" is cached at '"+f.getAbsolutePath()+"'");
     				// get this server's task queue
     				RetrieveQueue serverQueue = (RetrieveQueue) getQueue(request.getHost());
     				// Look up the previous cached jobs
     				URLRetrieveTask workingTask = serverQueue.getURLPreviousRequest(request);
     				if (workingTask == null) {
     					// Task already done. Notify listener
     					if (debug)
     						System.err.println("done job found: "+request.getUrl());
     					RetrieveEvent event = new RetrieveEvent();
     					event.setType(RetrieveEvent.REQUEST_FINISHED);
     					listener.transferEventReceived(event);
     				} else {
     					// The task is working yet, will register the listener
     					// TODO no va b?... perqu? la cola va buidant-se molt r?pidament
     					// per a fer que vaja tamb? hi hauria que registrar en cache
     					// lo que s'est? baixant al principi de l'execute();
     					if (debug)
     						System.err.println("working job found: "+request.getUrl());
     					workingTask.addRetrieveListener(listener);
+    				}
     			} else {
     				// Pick an unrepeatable fileName
     				String host = request.getHost();
     				String fileName = request.getFileName();
     				File tempDir = new File(tempDirectoryPath);
     				if (!tempDir.exists())
     					tempDir.mkdir();
     				String fileNamePrefix = tempDirectoryPath +
     											File.separator + host +
     											"-" ;
     				if (fileName.startsWith(fileNamePrefix))
     					fileName = fileName.substring(fileNamePrefix.length(), fileName.length());
     				// get this server's task queue
     				RetrieveQueue serverQueue = (RetrieveQueue) getQueue(request.getHost());
     				fileName = fileNamePrefix + fileName;
     				request.setFileName(fileName);
     				// TODO
     				// jo ac? comprovaria quin protocol, m?tode, host, etc... i crearia un
     				// objecte que tractara la desc?rrega segons el m?tode que li toca.
     				// algo en plan Strategy's
     				//
     				// per exemple si fem URLRetrieveTask una abstracta i tenim
     				//
     				// GET de tota la vida
     				// serverQueue.put(new HTTPGetRetrieveTask(request, listener));
     				//
     				// POST
     				// serverQueue.put(new HTTPPostRetrieveTask(request, listener));
     				//
     				// FTP
     				// serverQueue.put(new FTPRetrieveTask(request, listener));
     				//
     				// ????Xarxa local?????
     				// serverQueue.put(new SMBRetrieveTask(request, listener));
     				// Enqueue the request and the listener will be notified when done.
     				URLRetrieveTask task = new URLRetrieveTask(request, listener);
     				return (URLRetrieveTask) serverQueue.put(task);
+    			}
     		} catch (MalformedURLException e) {
     			e.printStackTrace();
+    		}
     		return null;
+    	}
     	private IQueue getQueue(String hostName) {
     		RetrieveQueue queue = null;
     		if (serversTable.containsKey(hostName))
     			queue = (RetrieveQueue) serversTable.get(hostName);
     		else {
     			// crea la cola
     			queue = new RetrieveQueue(hostName);
     			// pone la cola del server en marcha.
+    		}
     		return queue;
+    	}
     	private Hashtable downloadedFiles;
     	private final String tempDirectoryPath = System.getProperty("java.io.tmpdir")+"tmp-andami";
     	/**
          * Remove an URL from the system cache. The file will remain in the file
          * system for further eventual uses.
          * @param request
          */
     	public void removeURLRequest(URLRequest request) {
     		if (downloadedFiles != null && downloadedFiles.containsKey(request))
     			downloadedFiles.remove(request);
+    	}
     	/**
          * Adds an URL to the table of downloaded files for further uses. If the URL
          * already exists in the table its filePath value is updated to the new one and
          * the old file itself is removed from the file system.
+         *
          * @param url
          * @param filePath
          */
         protected void addDownloadedURLRequest(URLRequest request, String filePath){
             if (downloadedFiles==null)
                 downloadedFiles = new Hashtable();
             String fileName = (String) downloadedFiles.put(request, filePath);
             if (fileName!=null){
                 File f = new File(fileName);
                 if (f.exists())
                     f.delete();
+            }
+        }
         /**
          * Returns the content of this URL as a file from the file system.<br>
          * <p>
          * If the URL has been already downloaded in this session and notified
          * to the system using the static <b>Utilities.addDownloadedURL(URL)</b>
          * method, it can be restored faster from the file system avoiding to
          * download it again.
          * </p>
          * @param url
          * @return File containing this URL's content or null if no file was found.
          */
         private File getPreviousDownloadedURLRequest(URLRequest request){
             File f = null;
             if (downloadedFiles!=null && downloadedFiles.containsKey(request)){
                 String filePath = (String) downloadedFiles.get(request);
                 f = new File(filePath);
+            }
             return f;
+        }
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.taskplanning.retrieving;
     /**
      * @author jaume dominguez faus - jaume.dominguez@iver.es
      * Luis W. Sevilla (sevilla_lui@gva.es)
      */
     public class RetrieveEvent {
     	public static final int NOT_STARTED = 0;
     	public static final int CONNECTING = 1;
     	public static final int TRANSFERRING = 2;
     	public static final int REQUEST_FINISHED = 3;
     	public static final int REQUEST_FAILED = 4;
     	public static final int REQUEST_CANCELLED = 5;
     	public static final int POSTPROCESSING = 6;
     	/**
     	 * redundant; use REQUEST_FAILED
     	 * @deprecated ?
     	 */
     	public static final int ERROR = 11;
     	private int eventType;
     	public void setType(int type) {
     		eventType = type;
+    	}
     	public int getType() {
     		return eventType;
+    	}
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.taskplanning.retrieving;
     import java.util.Date;
     import java.util.Vector;
     import org.gvsig.remoteclient.taskplanning.FIFOTaskPlanner;
     import org.gvsig.remoteclient.taskplanning.IQueue;
     import org.gvsig.remoteclient.taskplanning.IRunnableTask;
     import org.gvsig.remoteclient.taskplanning.ITaskPlanner;
     /**
      * @author jaume dominguez faus - jaume.dominguez@iver.es
      * 		   Luis W. Sevilla (sevilla_lui@gva.es)
      */
     public class RetrieveQueue implements IQueue {
     	private String hostName;
     	private Date startTime;
     	private Vector tasks = new Vector();
     	private boolean waiting;
     	private ITaskPlanner taskPlanner;
     	private Worker worker;
     	/**
+    	 *
     	 */
     	public RetrieveQueue(String hName) {
     		hostName = hName;
     		startTime = new Date();
     		worker = new Worker();
     		new Thread(worker).start();
+    	}
     	public IRunnableTask put(IRunnableTask task) {
     		tasks.add(task);
     		if (waiting) {
     			synchronized (this) {
     				notifyAll();
+    			}
+    		}
     		return task;
+    	}
     	public IRunnableTask take() {
     		if (tasks.isEmpty()) {
     			synchronized (this) {
     				waiting = true;
     				try {
     					wait();
     				} catch (InterruptedException ie) {
     					waiting = false;
+    				}
+    			}
+    		}
     		return getTaskPlanner().nextTask() ;
+    	}
     	public boolean isEmpty() {
     		synchronized (this) {
     			return tasks.isEmpty() && !worker.r.isRunning();
+    		}
+    	}
     	public ITaskPlanner getTaskPlanner() {
     		if (taskPlanner == null) {
     			taskPlanner = new FIFOTaskPlanner(this);
+    		}
     		return taskPlanner;
+    	}
     	public void setTaskPlanner(ITaskPlanner planner) {
     		taskPlanner = planner;
+    	}
     	public void pause() {
     		waiting = true;
+    	}
     	public void resume() {
     		waiting = false;
+    	}
     	public Vector getTasks() {
     		return tasks;
+    	}
     	private class Worker implements Runnable {
     		URLRetrieveTask r;
     		int i = 0;
     		public void run() {
     			while (true) {
     				r = (URLRetrieveTask) take();
     				r.execute();
+    			}
+    		}
+    	}
     	protected URLRetrieveTask getURLPreviousRequest(URLRequest request) {
     		// Is the one currently running?
     		/*URLRetrieveTask aux = (URLRetrieveTask) worker.r;
     		if (request.equals(aux.getRequest())) {
     				return aux;
     		}*/
     		// Is one of those in the queue?
     		for (int i = 0; i < tasks.size(); i++) {
     			URLRetrieveTask task = (URLRetrieveTask) tasks.get(i);
     			URLRequest aWorkingRequest = task.getRequest();
     			if (aWorkingRequest.equals(request)) {
     				return task;
+    			}
+    		}
     		return null;
+    	}
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.taskplanning.retrieving;
     /**
      * @author Luis W. Sevilla (sevilla_lui@gva.es)
      */
     public interface RetrieveListener {
     	public void transferEventReceived(RetrieveEvent event);
+    }

     /**
      * gvSIG. Desktop Geographic Information System.
+     *
      * Copyright (C) 2007-2013 gvSIG Association.
+     *
      * 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 3
      * of the License, or (at your option) any later version.
+     *
      * This program is distributed in the hope that it will be useful,
      * but WITHOUT ANY WARRANTY; without even the implied warranty of
      * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
      * GNU General Public License for more details.
+     *
      * You should have received a copy of the GNU 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.
+     *
      * For any additional information, do not hesitate to contact us
      * at info AT gvsig.com, or visit our website www.gvsig.com.
      */
     package org.gvsig.remoteclient.taskplanning.retrieving;
     import java.net.MalformedURLException;
     import java.net.URL;
     /**
      * @author Luis W. Sevilla (sevilla_lui@gva.es)
      */
     public class URLRequest{
     	public static final String HTTP = "http";
     	private volatile int hashCode = 0;
     	public static final int GET = 1;
     	public static final int POST = 2;
     	private int requestType = GET;
     	private String protocol;
     	private String host;
     	private int port = -1;
     	private String file;
     	private String fileName;
     	public URL getUrl() throws MalformedURLException {
     		String u = protocol;
     		u += "://"+host;
     		if (port != -1)
     			u += ":"+port;
     		u += "/"+file;
     		return new URL(u);
+    	}
     	/**
     	 * @return Returns the fileName.
     	 */
     	public String getFileName() {
     		return fileName;
+    	}
     	/**
     	 * @param fileName The fileName to set.
     	 */
     	public void setFileName(String fileName) {
     		this.fileName = fileName;
+    	}
     	/**
     	 * @return Returns the host.
     	 */
     	public String getHost() {
     		return host;
+    	}
     	/**
     	 * @param host The host to set.
     	 */
     	public void setHost(String host) {
     		this.host = host;
+    	}
     	/**
     	 * @return Returns the file.
     	 */
     	public String getFile() {
     		return file;
+    	}
     	/**
     	 * @param page The file to set.
     	 */
     	public void setFile(String page) {
     		this.file = page;
+    	}
     	/**
     	 * @return Returns the protocol.
     	 */

Application: gvSIG desktop

Revision 45301