Application: gvSIG desktop

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <artifactId>org.gvsig.desktop.compat.cdc</artifactId>

  <packaging>pom</packaging>

  <name>${project.artifactId}</name>

  <parent>

      <groupId>org.gvsig</groupId>

      <artifactId>org.gvsig.desktop</artifactId>

      <version>2.0.128</version>

  </parent>

  <build>

      <plugins>

      </plugins>

  </build>

  <modules>

      <module>org.gvsig.i18n</module>

      <module>org.gvsig.compat</module>

      <module>org.gvsig.projection</module>

      <module>org.gvsig.fmap.geometry</module>

      <module>org.gvsig.remoteclient</module>

      <module>org.gvsig.fmap.dal</module>

      <module>org.gvsig.fmap.mapcontext</module>

      <module>org.gvsig.metadata.basic</module>

  </modules>

  <description>This project group the gvSIG libraries that haven java 1.4 compatibility.</description>

</project>

/**

 * 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.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.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.taskplanning;

/**

 * <p>

 * ITaskPlanner provides an interface to program your own task planning. It gives

 * you operations for pick a task from the queue according on the criteria that

 * you designed.<br>

 * </p>

 * <p>

 * The simplest implementation of ITaskPlanner would be a FIFO task planner (see

 * FIFOTaskPlanner.java) which takes jobs from a task queue in the same order

 * they were put. But any kind of planner is possible (SJF, LIFO, RoundRobin, etc.). 

 * </p>

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

 *

 */

public interface ITaskPlanner {

	/**

	 * Takes the next task to be executed.

	 * @return IRunnableTask representing the next task to be executed

	 */

	public IRunnableTask nextTask();

	/**

	 * Takes the previous executed task. Notice that it may or may not have

	 * sense for specific implementations. For example, in a FIFO-like planner,

	 * the task is taken from the queue, executed until it is finished and 

	 * removed from the queue. So, there is no previous task.

	 * 

	 * @return IRunnableTask representing the previous executed task, or null

	 * if none.

	 * @deprecated (probably this is unuseful and i'll remove it)

	 */

	public IRunnableTask previousTask();

}

/**

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

import java.util.Vector;

/**

 *  <p>

 *  You should write your own concrete Queue implementation to hold the tasks in

 *  a specific kind of queue.<br>

 *  </p>

 *  <p>

 *  Following the contract, you should also write a task planner that does what 

 *  you desire. Task planners are a concrete class of the ITaskPlanner that would 

 *  plannify which is the next, the previous,.. task to be done. However, if

 *  you don't want to write anything special, just guess a simple FIFO queue<br>

 *  </p>

 *  

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

 *  @see ITaskPlanner

 */

public interface IQueue {

	/**

	 * Adds a new task to the queue. The place where the new task will be put its

	 * left to the concrete implementation of this interface.

	 * @param IRunnableTask task

	 */

	IRunnableTask put(IRunnableTask task);

	/**

	 * Returns the next task by calling the task planner's nextTask() method.

	 * @return IRunnableTask with the next task to be executed.

	 */

	IRunnableTask take();

	/**

	 * Returns true if the Queue has no (more) jobs to do.

	 * @return

	 */

	boolean isEmpty();

	/**

	 * Returns the task planner currently defined by this queue.

	 * @return ITaskPlanner

	 */

	ITaskPlanner getTaskPlanner();

	/**

	 * Sets the TaskPlanner that will decide which of the tasks in the queue will

	 * be executed next. A null value should represent a FIFO planner. 

	 * @param planner

	 */

	void setTaskPlanner(ITaskPlanner planner);

	/**

	 * Causes the execution of this queue to be paused. The task currently in execution

	 * finishes and after it the planner will not issue more tasks until resume() is

	 * invoked.

	 */

	void pause();

	/**

	 * Causes the execution of this queue to be resumed. The execution will continue

	 * with the next task issued by the planner. It has no effect if the queue was not

	 * paused yet. 

	 */

	void resume();

	/**

	 * Returns the set of tasks in a Vector (thread-safe).

	 * @return Vector containing the tasks in this queue.

	 */

	Vector getTasks();

}

/**

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

	 */

	public String getProtocol() {

		return protocol;

	}

	/**

	 * @param protocol The protocol to set.

	 */

	public void setProtocol(String protocol) {

		this.protocol = protocol;

	}

	/**

	 * @return Returns the requestType.

	 */

	public int getRequestType() {

		return requestType;

	}

	/**

	 * @param requestType The requestType to set.

	 */

	public void setRequestType(int requestType) {

		this.requestType = requestType;

	}

	/**

	 * @return Returns the port.

	 */

	public int getPort() {

		return port;

	}

	/**

	 * @param port The port to set.

	 */

	public void setPort(int port) {

		this.port = port;

	}

	public int hashCode() {

		if (hashCode == 0) {

			int result = 17;

			String[] stringFields = new String[] {

					fileName,

					host,

					file,

					protocol

			};

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

				if (stringFields[i] != null)

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

						result = 37*result + (int) stringFields[i].charAt(j);

			}

			result = 37*result + port;

			result = 37*result + requestType;

		}

		return hashCode;

	}

	public boolean equals(Object o) {

		if (this == o)

			return true;

		if (!(o instanceof URLRequest))

			return false;

		URLRequest other = (URLRequest) o;

		String[] stringFields = new String[] {

				// this.fileName, NO!!! Do not check file name

				this.host,

				this.file,

				this.protocol

		};

		String[] othersStringField = new String[] {

				// other.fileName, NO!!! Do not check file name

				other.host,

				other.file,

				other.protocol

		};

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

			if (stringFields[i] == null && othersStringField[i]!=null) return false;

			if (stringFields[i] == null && othersStringField[i]!=null) return false;

			if (stringFields[i] != null && othersStringField[i]!=null) 

				if (!stringFields[i].equals(othersStringField[i])) return false;

		}

		if (this.port != other.port) return false;

		if (this.requestType != other.requestType) return false;

		return true;

	}

}

/**

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

/*

 * Based on portions of code from EarthFlicks

 * http://today.java.net/lpt/a/212

 */

import java.io.BufferedOutputStream;

import java.io.DataOutputStream;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.net.MalformedURLException;

import java.net.URL;

import java.util.Iterator;

import java.util.Vector;

import org.gvsig.remoteclient.taskplanning.IRunnableTask;

/**

 * Clase para bajar ficheros en un thread independiente.

 */

public class URLRetrieveTask  implements IRunnableTask {

	private boolean running, cancelled;

	private URLRequest request;

	private Vector listeners = new Vector();

	private RetrieveEvent event = new RetrieveEvent();

	private InputStream is;

	/**

	 * 

	 */

	public URLRetrieveTask(URLRequest request, RetrieveListener listener) {

		this.request = request;

		addRetrieveListener(listener);

		running = cancelled = false;

	}

	public void execute() {

		event.setType(RetrieveEvent.NOT_STARTED);

		fireEvent();

		cancelled = false;

		running= true;

		long t = System.currentTimeMillis();

		File f = new File(request.getFileName()+System.currentTimeMillis());

		while (f.exists()) {

			t++;

			f = new File(request.getFileName()+t);

		}

		URL url;

		try {

			event.setType(RetrieveEvent.CONNECTING);

			fireEvent();

			url = request.getUrl();

			request.setFileName(f.getAbsolutePath());

			System.out.println("downloading '"+url+"' to: "+f.getAbsolutePath());

			DataOutputStream dos = new DataOutputStream( new BufferedOutputStream(new FileOutputStream(f)));

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

			fireEvent();

			is = url.openStream();

			event.setType(RetrieveEvent.TRANSFERRING);

			fireEvent();

			if (!cancelled) {

				long readed = 0;

				for (int i = is.read(buffer); !cancelled && i>0; i = is.read(buffer)){

					dos.write(buffer, 0, i);

					readed += i;

				}

				dos.close();

			}

			if (cancelled) {

				// Bad incomplete file, delete it.

				System.out.println("download cancelled ("+url+")");

				f.delete();

			} else {

				// register job in the cache

				// TODO aix? deuria d'estar al principi per a poder capturar

				// treballs que s'estan fent per? que encara no s'han acabat

				synchronized (this) {

					RequestManager.getInstance().addDownloadedURLRequest(request, f.getAbsolutePath());

				}

			}