Application: gvSIG desktop

remote-clients.jar

dist

bin

bin-test

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

 *

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

 *

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

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

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

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

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

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

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

/*

 * $Id$ 

 * $Log$

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

 * some warnings removed

 *

 * Revision 1.7  2006/03/15 08:54:31  jaume

 * *** empty log message ***

 *

 * Revision 1.6  2006/03/06 07:16:08  jaume

 * *** empty log message ***

 *

 * Revision 1.5  2006/03/02 07:17:08  jaume

 * *** empty log message ***

 *

 * Revision 1.3  2006/03/01 18:07:11  jaume

 * *** empty log message ***

 *

 * Revision 1.2  2006/03/01 17:56:28  jaume

 * *** empty log message ***

 *

 * Revision 1.1  2006/02/28 15:26:59  jaume

 * *** empty log message ***

 * 

 */

package org.gvsig.remoteclient.wcs.wcs_1_0_0;

import java.io.File;

import junit.framework.TestCase;

/**

 * 

 * @author jaume

 *

 */

public class WCSProtocolHandler_1_0_0Test extends TestCase {

	WCSProtocolHandler1_0_0 handler1, handler2, handler3, handler4;

	public void setUp() {

		System.out.println("Setting up test..");

		handler1 = new WCSProtocolHandler1_0_0();

		handler2 = new WCSProtocolHandler1_0_0();

		handler3 = new WCSProtocolHandler1_0_0();

		handler4 = new WCSProtocolHandler1_0_0();

	}

	public void testParsing() {

		long t1 = System.currentTimeMillis();

		assertTrue(handler1.parseCapabilities(new File("testdata/wcs/WCS-hypnosGetCapabilities.xml")));

		assertTrue(handler1.parseDescribeCoverage(new File("testdata/wcs/WCS-hypnosDescribeCoverage.xml")));

		assertTrue(handler2.parseCapabilities(new File("testdata/wcs/WCS-simonCITCostasGetCapabilities.xml")));

		assertTrue(handler2.parseDescribeCoverage(new File("testdata/wcs/WCS-simonCITCostasDescribeCoverage.xml")));

		assertTrue(handler3.parseCapabilities(new File("testdata/wcs/WCS-simonCITSpotGetCapabilities.xml")));

		assertTrue(handler3.parseDescribeCoverage(new File("testdata/wcs/WCS-simonCITSpotDescribeCoverage.xml")));

		assertTrue(handler4.parseCapabilities(new File("testdata/wcs/WCS-ionicGetCapabilities.xml")));

		assertTrue(handler4.parseDescribeCoverage(new File("testdata/wcs/WCS-ionicDescribeCoverage.xml")));

		long t2 = System.currentTimeMillis();

		System.out.println("Test parsing done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

}

package org.gvsig.remoteclient.wfs.wfs_1_0_0;

import java.io.File;

import junit.framework.TestCase;

/* 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  2006-10-10 12:52:28  jorpiell

 * Soporte para features complejas.

 *

 * Revision 1.1  2006/08/10 12:00:49  jorpiell

 * Primer commit del driver de Gml

 *

 * Revision 1.3  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.2  2006/04/20 16:39:16  jorpiell

 * A?adida la operacion de describeFeatureType y el parser correspondiente.

 *

 * 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 WFSProtocolHandlerTest1_0_0 extends TestCase {

	WFSProtocolHandler1_0_0 handler;

	public void setUp() {

		System.out.println("Setting up test..");

		handler = new WFSProtocolHandler1_0_0();		

	}	

	public void testParsingDescribeFeatureType() {

		long t1 = System.currentTimeMillis();

		assertTrue(handler.parseCapabilities(new File("testdata/wfs/WFS-dmsolutionsGetCapabilities.xml")));

		handler.setCurrentFeature("popplace");		

		long t2 = System.currentTimeMillis();

		System.out.println("Test parsing vivid done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

	public void testParsingDescribeFeatureType2() {

		long t1 = System.currentTimeMillis();

		assertTrue(handler.parseCapabilities(new File("testdata/wfs/WFS-sercartlinGetCapabilities.xml")));

		handler.setCurrentFeature("topp:tasmania_roads");		

		long t2 = System.currentTimeMillis();

		System.out.println("Test parsing sercartlin done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

	public void testParsingDescribeFeatureType3() {

		long t1 = System.currentTimeMillis();

		assertTrue(handler.parseCapabilities(new File("testdata/wfs/WFS-IDEEGetCapabilities.xml")));

		handler.setCurrentFeature("BDLL200_Provincia");	

		long t2 = System.currentTimeMillis();

		System.out.println("Test parsing TNT done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

}

package org.gvsig.remoteclient.wfs.wfs_1_1_0;

import java.io.File;

import junit.framework.TestCase;

/* 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 WFSProtocolHandlerTest1_1_0 extends TestCase {

	WFSProtocolHandler1_1_0 handler;

	public void setUp() {

		System.out.println("Setting up test..");

		handler = new WFSProtocolHandler1_1_0();		

	}

	public void testParsingDescribeFeatureType1() {

//		long t1 = System.currentTimeMillis();

//		assertTrue(handler.parseCapabilities(new File("test/WFS-1_1_0SercartlinGetCapabilities.xml")));

//		handler.setCurrentFeature("popplace");

//		

//		assertTrue(handler.parseDescribeFeatureType(new File("test/WFS-dmsolutionsDescribeFeatureType.xml"),null));

//		long t2 = System.currentTimeMillis();

//		System.out.println("Test parsing vivid done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

	public void testParsingDescribeFeatureType2() {

		long t1 = System.currentTimeMillis();

		assertTrue(handler.parseCapabilities(new File("testdata/wfs/WFS-1_1_0IDEEGetCapabilities.xml")));

		handler.setCurrentFeature("ideewfs:VerticeRedOrdenInferior");	

		long t2 = System.currentTimeMillis();

		Object obj = handler.getFeatures().get("ideewfs:VerticeRedOrdenInferior");

		System.out.println("Test parsing vivid done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

	public void testParsingDescribeFeatureTypeTNT() {

		long t1 = System.currentTimeMillis();

		assertTrue(handler.parseCapabilities(new File("testdata/wfs/WFS-1_1_0TNTGetCapabilities.xml")));

		handler.setCurrentFeature("BDLL200_Provincia");		

		long t2 = System.currentTimeMillis();

		System.out.println("Test parsing IDEE done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

}

package org.gvsig.remoteclient.Tests;

import java.awt.geom.Rectangle2D;

import junit.framework.TestCase;

import org.gvsig.remoteclient.wms.WMSClient;

import org.gvsig.remoteclient.wms.WMSStatus;

public class Test extends TestCase

{

	public static void main(String[] args)

	{

		try

		{

			WMSClient wmsclient = new WMSClient("http://orto.cth.gva.es:80/wmsconnector/com.esri.wms.Esrimap/wms_urbanismo_tematicos?");

			//http://orto.cth.gva.es/wmsconnector/com.esri.wms.Esrimap/wms_urbanismo_tematicos?REQUEST=GetMap&SERVICE=WMS&VERSION=1.1.1&LAYERS=3&STYLES=&SRS=EPSG:4326&BBOX=-1.5597948439,37.8178641941,0.5286772976,40.8151000365&WIDTH=500&HEIGHT=500&FORMAT=image/jpeg&EXCEPTIONS=XML

			wmsclient.connect(null);

			//System.out.println();

			//System.out.println(Utilities.Vector2CS(layerNames));

			WMSStatus status = new WMSStatus();

			status.addLayerName("3");

//			status.addLayerName("europa_rivieren");

//			status.addStyleName("default");

//			status.addStyleName("default");

			status.setSrs("EPSG:4326");

			Rectangle2D extent = new Rectangle2D.Double(-1.5597948439,37.8178641941,-1.5597948439-0.5286772976,37.8178641941-40.8151000365);

			status.setExtent(extent);

			status.setFormat("image/jpeg");

			status.setHeight(500);

			status.setWidth(500);

			//wmsclient.getMap(status);

			//wmsclient.getFeatureInfo(status,300,300);

			System.out.println();

		}

		catch(Exception e)

		{

			System.out.println(e.getMessage());

		}

	}

}

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

 *

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

 *

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

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

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

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

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

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

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

package org.gvsig.remoteclient.wms.wms_1_1_1;

import java.io.File;

import junit.framework.TestCase;

/**

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

 */

public class WMSProtocolHandler_1_1_1Test extends TestCase {

	WMSProtocolHandler1_1_1 handler1, handler2, handler3, handler4;

	public void setUp() {

		System.out.println("Setting up test..");

		handler1 = new WMSProtocolHandler1_1_1();

	}

	public void testParsing() {

		long t1 = System.currentTimeMillis();

		handler1.parseCapabilities(new File("testdata/wms/wms.xml"));

		long t2 = System.currentTimeMillis();

		System.out.println("Test parsing done with apparently no errors in "+ (t2-(float)t1)/1000+" seconds");

	}

}

package org.gvsig.remoteclient.wms;

import java.awt.geom.Rectangle2D;

import java.util.Vector;

import junit.framework.TestCase;

/**

 * 

 * @author jaume

 *

 */

public class WMSStatusTest extends TestCase {

	WMSStatus st1, st2, st3, st4;

    protected void setUp() {

    	st1 = new WMSStatus();

    	// Layer names

    	Vector v1 = new Vector();

    	v1.add("a");

    	v1.add("b");

    	v1.add("c");

    	st1.setLayerNames(v1);

    	v1.clear();

    	// Styles

    	v1.add("s1");

    	v1.add("s2");

    	v1.add("s3");

    	st1.setStyles(v1);

    	// Transparency

    	st1.setTransparency(false);

    	v1.clear();

    	v1.add("TIME=february");

    	v1.add("WAVELENGTH=200nm");

    	st1.setDimensions(v1);

    	// Extent

    	Rectangle2D rect1 = new Rectangle2D.Double(1.0, 1.00000001, 5.000000, 6.8);

    	st1.setExtent(rect1);

    	// Exception format

    	st1.setExceptionFormat("bla");

    	// SRS

    	st1.setSrs("bla bla");

    	// Format

    	st1.setFormat("image/mpeg");

    	// Width

    	st1.setWidth(800);

    	// Height

    	st1.setHeight(600);

    	// Online resource

    	st1.setOnlineResource("alkjf");

    	st2 = new WMSStatus();

    	// Layer names

        Vector v2 = new Vector();

    	v2.add("a");

    	v2.add("b");

    	v2.add("c");

    	st2.setLayerNames(v2);

    	v2.clear();

    	// Styles

    	v2.add("s1");

    	v2.add("s2");

    	v2.add("s3");

    	st2.setStyles(v2);

    	// Transparency

    	st2.setTransparency(false);

    	v2.clear();

    	// Dimensions

    	v2.add("TIME=february");

    	v2.add("WAVELENGTH=200nm");

    	st2.setDimensions(v2);

    	// Extent

    	Rectangle2D rect2 = new Rectangle2D.Double(1.0, 1.00000001, 5.000000, 6.8);

    	st2.setExtent(rect2);

    	// Exception format

    	st2.setExceptionFormat("bla");

    	// SRS

    	st2.setSrs("bla bla");

    	// Format

    	st2.setFormat("image/mpeg");

    	// Width

    	st2.setWidth(800);

    	// Height

    	st2.setHeight(600);

    	// Online resource

    	st2.setOnlineResource("alkjf");

    	st3 = new WMSStatus();

    	// Layer names

        Vector v3 = new Vector();

    	v3.add("a");

    	v3.add("b");

    	v3.add("c");

    	st3.setLayerNames(v3);

    	v3.clear();

    	// Styles

    	v3.add("s1");

    	v3.add("s2");

    	v3.add("s3");

    	st3.setStyles(v3);

    	// Transparency

    	st3.setTransparency(false);

    	v3.clear();

    	// Dimensions

    	v3.add("TIME=february");

    	v3.add("WAVELENGTH=200nm");

    	st3.setDimensions(v3);

    	// Extent

    	Rectangle2D rect3 = new Rectangle2D.Double(2.0, 1.00000001, 5.000000, 6.8);

    	st3.setExtent(rect3);

    	// Exception format

    	st3.setExceptionFormat("bla");

    	// SRS

    	st3.setSrs("bla bla");

    	// Format

    	st3.setFormat("image/mpeg");

    	// Width

    	st3.setWidth(800);

    	// Height

    	st3.setHeight(600);

    	// Online resource

    	st3.setOnlineResource("alkjf");

    	st4 = new WMSStatus(); 

        // Layer names

        Vector v4 = new Vector();

    	v4.add("a");

    	v4.add("b");

    	v4.add("c");

    	st4.setLayerNames(v4);

    	v4.clear();

    	// Styles

    	v4.add("s1");

    	v4.add("s2");

    	v4.add("s3");

    	st4.setStyles(v4);

    	// Transparency

    	st4.setTransparency(false);

    	v4.clear();

    	// Dimensions

    	v4.add("TIME=february");

    	v4.add("WAVELENGTH=200nm");

    	st4.setDimensions(v4);

    	// Extent

    	Rectangle2D rect4 = new Rectangle2D.Double(2.0, 1.00000001, 5.000000, 6.8);

    	st4.setExtent(rect3);

    	// Exception format

    	st4.setExceptionFormat("bla");

    	// SRS

    	st4.setSrs("bla bla");

    	// Format

    	st4.setFormat("image/mpeg");

    	// Width

    	st4.setWidth(800);

    	// Height

    	st4.setHeight(600);

    	// Online resource

    	st4.setOnlineResource("alkjfa");

    }

    public void testEquality() {

    	assertTrue(st1.equals(st2));

    	assertFalse(st1.equals(st3)); // (distinct extent)

    	assertFalse(st3.equals(st4)); // (distinct online resources)

    }

}

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

 *

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

 *

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

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

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

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

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

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

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

/* CVS MESSAGES:

 *

 * $Id$

 * $Log$

 * Revision 1.3  2006-05-16 17:10:27  jaume

 * *** empty log message ***

 *

 * Revision 1.2  2006/05/15 09:39:52  jaume

 * *** empty log message ***

 *

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

 * some warnings removed

 *

 * Revision 1.1  2006/05/12 07:15:45  jaume

 * *** empty log message ***

 *

 *

 */

package org.gvsig.remoteclient.taskplanning.retrieving;

import java.io.File;

import junit.framework.TestCase;

import org.gvsig.remoteclient.taskplanning.IQueue;

import org.gvsig.remoteclient.taskplanning.IRunnableTask;

/**

 * 

 * @author jaume

 *

 */

public class URLRetrieveTest extends TestCase {

	private final static String tempDirectoryPath = System.getProperty("java.io.tmpdir")+"tmp-andami";

	IQueue queue;

	IRunnableTask task1, task2, task3, task4;

	boolean finished1, finished2, finished3, finished4;

	RetrieveListener listener1 = new RetrieveListener() {

		public void transferEventReceived(RetrieveEvent event) {

			int e = event.getType();

			printMessage("listener1", event.getType());

			if (e==RetrieveEvent.REQUEST_FINISHED || e == RetrieveEvent.REQUEST_FAILED || e == RetrieveEvent.REQUEST_CANCELLED )

				finished1 = true;

		}

	};

	String protocol = URLRequest.HTTP;

	String host1 = "192.168.0.223";

	String page1 = "cgi-bin/mapserv_46.exe?map=c:\\ms4w\\Apache\\cgi-bin\\demo.map&&REQUEST=GetMap&SERVICE=WMS&VERSION=1.1.1&LAYERS=comunidades&SRS=EPSG:23030&BBOX=507522.0,4154976.282477341,942309.0,4552983.717522658&WIDTH=332&HEIGHT=305&FORMAT=image/png&STYLES=&TRANSPARENT=TRUE";

	URLRequest request1;

	String host2 = "localhost";

	String page2 = "aegCapabilities1.3.xml";

	URLRequest request2;

	RetrieveListener listener2 = new RetrieveListener() {

		public void transferEventReceived(RetrieveEvent event) {

			int e = event.getType();

			printMessage("listener2", event.getType());

			if (e==RetrieveEvent.REQUEST_FINISHED || e == RetrieveEvent.REQUEST_FAILED || e==RetrieveEvent.REQUEST_CANCELLED )

				finished2 = true;

		}

	};

	String host3 = "localhost";

	String page3 = "avalencia.ecw";

	URLRequest request3;

	RetrieveListener listener3 = new RetrieveListener() {

		public void transferEventReceived(RetrieveEvent event) {

			int e = event.getType();

			printMessage("listener3", event.getType());

			if (e==RetrieveEvent.REQUEST_FINISHED || e == RetrieveEvent.REQUEST_FAILED  || e == RetrieveEvent.REQUEST_CANCELLED )

				finished3 = true;

		}

	};

	String host4 = "192.168.0.223";

	String page4 = "prueba.rar";

	URLRequest request4;

	RetrieveListener listener4 = new RetrieveListener() {

		public void transferEventReceived(RetrieveEvent event) {

			int e = event.getType();

			printMessage("listener4", event.getType());

			if (e==RetrieveEvent.REQUEST_FINISHED || e == RetrieveEvent.REQUEST_FAILED  || e == RetrieveEvent.REQUEST_CANCELLED )

				finished4 = true;

		}

	};

	{

		cleanFiles();

	}

	private static void cleanFiles(){

		try{

			File tempDirectory = new File(tempDirectoryPath);

			File[] files = tempDirectory.listFiles();

			if (files!=null) {

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

					// s?lo por si en un futuro se necesitan crear directorios temporales

					files[i].delete();

				}

			}

			tempDirectory.delete();

		} catch (Exception e) {	}

	}

	public void setUp() {

		File tmpDir = new File(tempDirectoryPath);

		if (!tmpDir.exists())

			tmpDir.mkdir();

		finished1 = finished2 = finished3 = finished4 = false;

		System.out.println("\n\n\nSetting up test..");

		queue = new RetrieveQueue("http://192.168.0.223/cgi-bin/mapserv_46.exe?map=c:\\ms4w\\Apache\\cgi-bin\\demo.map");

		request1 = new URLRequest();

		// http://192.168.0.223/cgi-bin/mapserv_46.exe?map=c:\\ms4w\\Apache\\cgi-bin\\demo.map&&REQUEST=GetMap&SERVICE=WMS&VERSION=1.1.1&LAYERS=comunidades&SRS=EPSG:23030&BBOX=507522.0,4154976.282477341,942309.0,4552983.717522658&WIDTH=332&HEIGHT=305&FORMAT=image/png&STYLES=&TRANSPARENT=TRUE

		request1.setProtocol(protocol);

		request1.setHost(host1);

		request1.setFile(page1);

		request1.setFileName(tempDirectoryPath+File.separator+"task1");

		request1.setRequestType(URLRequest.GET);

		task1 = new URLRetrieveTask(request1, listener1); 

		request2 = new URLRequest();

		// http://localhost/aegCapabilities1.3.xml

		request2.setProtocol(protocol);

		request2.setHost(host2);

		request2.setFile(page2);

		request2.setFileName(tempDirectoryPath+File.separator+"task2");

		request2.setRequestType(URLRequest.GET);

		task2 = new URLRetrieveTask(request2, listener2);

		request3 = new URLRequest();

		// http://localhost/avalencia.ecw

		request3.setProtocol(protocol);

		request3.setHost(host3);

		request3.setFile(page3);

		request3.setFileName(tempDirectoryPath+File.separator+"task3");

		request3.setRequestType(URLRequest.GET);

		task3 = new URLRetrieveTask(request3, listener3);

		request4 = new URLRequest();

		// http://192.168.0.223/prueba.rar

		request4.setProtocol(protocol);

		request4.setHost(host4);

		request4.setFile(page4);

		request4.setFileName(tempDirectoryPath+File.separator+"task4");

		request4.setRequestType(URLRequest.GET);

		task4 = new URLRetrieveTask(request4, listener4);

	}

	public void testRetrieve() {

		queue.put(task1);

		queue.put(task2);

		while(!queue.isEmpty()) {		

		}

	}

	public void testCancelling() {

		long time = System.currentTimeMillis();

		queue.put(task1);

		queue.put(task2);

		boolean more = true;

		while (!queue.isEmpty()) {

			if (more && System.currentTimeMillis()-time > 1000) { // wait 1 seconds and cancel

				task2.cancel();

				more = false;

			}

		}

	}

	public void testRequestManager() {

		System.out.println("tests parallel downloading from different servers");

		request3.setFileName("task3");

		// http://localhost/avalencia.ecw

		request4.setFileName("task4");

		// http://192.168.0.223/prueba.rar

		RequestManager manager = RequestManager.getInstance();

		manager.addURLRequest(request3, listener3);

		manager.addURLRequest(request4, listener4);

		manager.addURLRequest(request4, listener1);

		while (!(finished1 && finished3 && finished4)) { 

		}

	}

	public void testCocurrentTransfers() {

		finished1 = finished2 = finished3 = finished4 = false;

		System.out.println("tests to merge two or more equivalent transfers into one");

		RequestManager manager = RequestManager.getInstance();

		//manager.removeURLRequest(request3);

		request3.setFileName("task3");

		manager.addURLRequest(request3, listener1);

		manager.addURLRequest(request3, listener2);

		manager.addURLRequest(request3, listener3);

		manager.addURLRequest(request3, listener4);

		while (!(finished1 && finished2 && finished3 && finished4)) { 

		}

	}

	public void printMessage(String who, int code) {

		switch (code) {

		case RetrieveEvent.CONNECTING:

			System.out.println(who+": connecting");

			break;

		case RetrieveEvent.TRANSFERRING:

			System.out.println(who+": transferring");

			break;

		case RetrieveEvent.REQUEST_CANCELLED:

			System.out.println(who+": cancelled");

			break;

		case RetrieveEvent.REQUEST_FINISHED:

			System.out.println(who+": finished");

			break;

		case RetrieveEvent.REQUEST_FAILED:

			System.err.println(who+": failed");

			break;

		case RetrieveEvent.NOT_STARTED:

			System.out.println(who+": not started");

			break;

		case RetrieveEvent.POSTPROCESSING:

			System.out.println(who+": postprocessing");

			break;

		}

	}

}

package org.gvsig.remoteclient;

import junit.framework.Test;

import junit.framework.TestSuite;

import org.gvsig.remoteclient.wcs.wcs_1_0_0.WCSProtocolHandler_1_0_0Test;

import org.gvsig.remoteclient.wfs.wfs_1_0_0.WFSProtocolHandlerTest1_0_0;

import org.gvsig.remoteclient.wfs.wfs_1_1_0.WFSProtocolHandlerTest1_1_0;

import org.gvsig.remoteclient.wms.WMSStatusTest;

import org.gvsig.remoteclient.wms.wms_1_1_1.WMSProtocolHandler_1_1_1Test;

public class AllTests {

	public static Test suite() {

		TestSuite suite = new TestSuite("Test for org.gvsig.remoteClient");

		//$JUnit-BEGIN$

		suite.addTestSuite(Test.class);

		//commented until there is a way to simulate the needed servers.

		//suite.addTestSuite(URLRetrieveTest.class);

		suite.addTestSuite(WCSProtocolHandler_1_0_0Test.class);

		suite.addTestSuite(WFSProtocolHandlerTest1_0_0.class);

		suite.addTestSuite(WFSProtocolHandlerTest1_1_0.class);

		suite.addTestSuite(WMSProtocolHandler_1_1_1Test.class);

		suite.addTestSuite(WMSStatusTest.class);

		//$JUnit-END$

		return suite;

	}

}

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;

import java.io.IOException;

import org.kxml2.io.KXmlParser;

import org.xmlpull.v1.XmlPullParserException;

/* 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  2006-05-16 14:12:56  jorpiell

 * A?adido el parseador de Esquemas

 *

 *

 */

/**

 * 

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

 */

public class WFSSchemaParser extends KXmlParser {

	private String schema = "";

	public WFSSchemaParser(){

		super();

	}

	public WFSSchemaParser(String schema){

		this.schema = schema;

	}

	/**

	 * It gets the schema from a tag. The schema is separated

	 * of the tag name by ":".

	 * @param tag

	 */

	public void setSchemaFromMainTag(String tag){

		int pos = tag.indexOf(":");

		if (pos > 0){

			this.schema = tag.substring(0,pos);

		}else{

			this.schema = "";

		}

	}	

	/**

	 * @return Returns the schema.

	 */

	public String getSchema() {

		return schema;

	}

	/**

	 * @param schema The schema to set.

	 */

	public void setSchema(String schema) {

		this.schema = schema;

	}	

	/**

	 * Returns a SCHEMA:TAG

	 * @param tag

	 * @return SCHEMA:TAG

	 */

	private String getTag(String tag){

		if (tag == null){

			return null;

		}

		if ((schema == null) || (schema.equals(""))){

			return tag;

		}

		return schema + ":" + tag;

	}

	/*

	 *  (non-Javadoc)

	 * @see org.xmlpull.v1.XmlPullParser#require(int, java.lang.String, java.lang.String)

	 */

	public void require(int type, String namespace, String name)

		throws XmlPullParserException, IOException{

		super.require(type,namespace,getTag(name));

	}

	/*

	 *  (non-Javadoc)

	 * @see org.xmlpull.v1.XmlPullParser#getName()

	 */

	public String getName(){

		try{

		String name = super.getName();

		if ((schema != null) || (!(schema.equals("")))){

			return name.substring(name.indexOf(":") + 1,name.length());

		}

		return name;

		}catch (NullPointerException e){

			return "";

		}

	}

}

package org.gvsig.remoteclient.wfs.wfs_1_0_0.request;

import org.gvsig.compat.CompatLocator;

import org.gvsig.compat.lang.StringUtils;

import org.gvsig.remoteclient.wfs.WFSProtocolHandler;

import org.gvsig.remoteclient.wfs.WFSStatus;

import org.gvsig.remoteclient.wfs.request.WFSDescribeFeatureTypeRequest;

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

 *

 */

/**

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

 */

public class WFSDescribeFeatureTypeRequest1_0_0 extends WFSDescribeFeatureTypeRequest {

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

	public WFSDescribeFeatureTypeRequest1_0_0(WFSStatus status,

			WFSProtocolHandler protocolHandler) {

		super(status, protocolHandler);		

	}

	/*

	 * (non-Javadoc)

	 * @see org.gvsig.remoteClient.wfs.requests.WFSRequest#getHttpGetRequest(java.lang.String)

	 */

	protected String getHttpGetRequest(String onlineResource) {

		StringBuffer req = new StringBuffer();

		req.append(onlineResource);

		req.append("REQUEST=DescribeFeatureType&SERVICE=WFS&");

		//Typename

		String typeName = status.getFeatureFullName();

		if ((status.getNamespaceLocation() != null) && 

				(status.getNamespacePrefix() != null)){

			req.append("NAMESPACE=");

			req.append("xmlns(" + status.getNamespacePrefix() + "=");

			req.append(status.getNamespaceLocation() + ")");

			req.append("&");				

		}

		req.append("TYPENAME=").append(typeName).append("&");

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

		String request = stringUtils.replaceAll(req.toString(), "UEeRtKxB+ROJTlqYiWB3XQ==", "UEeRtKxB%2bROJTlqYiWB3XQ%3d%3d");

		return request;

	}

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

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

 * of the Valencian Government (CIT)

 *

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

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

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

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

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

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 */

package org.gvsig.remoteclient.wfs.wfs_1_0_0.request;

import java.util.Iterator;

import org.gvsig.remoteclient.utils.CapabilitiesTags;

import org.gvsig.remoteclient.wfs.WFSProtocolHandler;

import org.gvsig.remoteclient.wfs.WFSStatus;

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

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

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

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

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

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

import org.gvsig.remoteclient.wfs.request.WFSTransactionRequest;

/**

 * @author gvSIG Team

 * @version $Id$

 *

 */

public class WFSTransactionRequest1_0_0 extends WFSTransactionRequest{

    /**

     * @param status

     * @param protocolHandler

     */

    public WFSTransactionRequest1_0_0(WFSStatus status,

        WFSProtocolHandler protocolHandler) {

        super(status, protocolHandler);      

    }

    protected String getHttpGetRequest(String onlineResource) {

        // TODO Auto-generated method stub

        return null;

    }

    protected String getHttpPostRequest(String onlineResource) {

        StringBuffer request = new StringBuffer();

        addHttpPostHeaderRequest(request);

        //Add the operations

        WFSTTransaction transaction = status.getTransaction();

        //Insert operations

        for (int i=0 ; i<transaction.getInsertOperationSize() ; i++){

            addInsertOperation(transaction.getInseOperationAt(i), request);            

        }

        //Update operations

        for (int i=0 ; i<transaction.getUpdateOperationSize() ; i++){

            addUpdateOperation(transaction.getUpdateOperationAt(i), request);            

        }

        //Delete operations. All of them in just one operation

        if (transaction.getDeleteOperationSize() > 0){            

            IWFSTOperation firstOperation = transaction.getDeleteOperationAt(0);

            addOperationHeader(firstOperation, request);

            FilterEncoding filterEncoding = new FilterEncoding(status);

            filterEncoding.setQualified(true);

            for (int i=0 ; i<transaction.getDeleteOperationSize() ; i++){               

                filterEncoding.addFeatureById(transaction.getDeleteOperationAt(i).getId());       

            }

            request.append(filterEncoding.toString(protocolHandler.getVersion()));

            addOperationEnd(firstOperation, request);

        }

        addHttpPostEndRequest(request);

        return request.toString();

    }

    private void addOperationHeader(IWFSTOperation operation, StringBuffer request){

        request.append("<" + CapabilitiesTags.WFS_NAMESPACE_PREFIX + ":");

        request.append(operation.getOperationName());

        if (operation.hasTypeName()){

            request.append(" typeName=\"" + status.getFeatureFullName() + "\"");

        }

        request.append(">");      

    }