| gvSIG desktop 1

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

 */

package org.gvsig.catalog.protocols;

import java.io.File;

import java.net.URL;

import java.util.Collection;

import org.apache.commons.httpclient.NameValuePair;

import org.gvsig.catalog.metadataxml.XMLTree;

import org.gvsig.remoteclient.utils.Utilities;

/**

 * 

 * 

 * 

 * @author Jorge Piera Llodra (piera_jor@gva.es)

 */

public class HTTPGetProtocol implements IProtocols {

	/**

	 * 

	 * 

	 * 

	 * @return 

	 * @param url 

	 * @param object 

	 * @param firstRecord 

	 */

	public Collection doQuery(URL url, Object object, int firstRecord) {        

		NameValuePair[] parameters = (NameValuePair[]) object;

		File file = null;

		String sUrl = "http://" + url.getHost() + ":" +

		url.getPort() + url.getPath();

		sUrl = sUrl + createURLParams(parameters);

		try {	

			file = Utilities.downloadFile(new URL(sUrl),

					"catalog-", null);

		} catch (Exception e) {

			return null;

		}

		Collection col = new java.util.ArrayList();

		col.add(XMLTree.xmlToTree(file));

		return col;

	} 

	/**

	 * Create and string for a list of params

	 * @param params

	 * @return

	 */

	private String createURLParams(NameValuePair[] params){

		StringBuffer buffer = new StringBuffer();

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

			if (i==0){

				buffer.append("?");

			}else{

				buffer.append("&");

			}

			buffer.append(params[i].getName());

			buffer.append("=");

			buffer.append(params[i].getValue());

		}

		return buffer.toString();

	}

}

package org.gvsig.catalog.protocols;

import java.net.URI;

import java.util.Hashtable;

import org.jzkit.search.provider.iface.SearchException;

import org.jzkit.search.provider.iface.Searchable;

import org.jzkit.search.provider.z3950.Z3950ServiceFactory;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.FileSystemXmlApplicationContext;

/* 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: Z3950ConnectionFactory.java 568 2007-07-27 07:23:27 +0000 (Fri, 27 Jul 2007) jpiera $

 * $Log$

 * Revision 1.1.2.2.4.2  2007/07/13 12:00:35  jorpiell

 * Add the posibility to add a new panel

 *

 * Revision 1.1.2.2.4.1  2007/07/10 11:18:04  jorpiell

 * Added the registers

 *

 * Revision 1.1.2.2  2006/11/15 00:08:08  jjdelcerro

 * *** empty log message ***

 *

 * Revision 1.2  2006/10/02 08:29:07  jorpiell

 * Modificados los cambios del Branch 10 al head

 *

 * Revision 1.1.2.1  2006/09/20 12:01:07  jorpiell

 * Se ha cambiado la versi?n de la jzkit, se ha incorporado la funcionalidad de cargar arcims

 *

 * Revision 1.1  2006/09/20 11:20:17  jorpiell

 * Se ha cambiado la versi?n de la librer?a jzkit de la 1 a la 2.0

 *

 *

 */

/**

 * This factory creates Z39.50 connections

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

 */

public class Z3950ConnectionFactory {

	private static ApplicationContext app_context = null;

	private static boolean appContextInitialized = false;

	private static Z3950ServiceFactory factory = null;

	private static Hashtable connections = new Hashtable();

	public static Z3950Connection getConnection(URI uri){

		Z3950Connection connection = (Z3950Connection)connections.get(uri);

		if (connection == null){

			connection = new Z3950Connection(uri);

			connections.put(uri,connection);

		}

		return connection;

	}

	public static Searchable getSearchable(URI uri) throws SearchException{

		if (!(appContextInitialized)){

			initAppContext(uri);

			factory = new Z3950ServiceFactory();		

			factory.setApplicationContext(app_context);

			factory.setDefaultRecordSyntax("usmarc");

			factory.setDefaultElementSetName("F");

			factory.getRecordArchetypes().put("Default","usmarc::F");

			factory.getRecordArchetypes().put("FullDisplay","usmarc::F");

			factory.getRecordArchetypes().put("BriefDisplay","usmarc::B");

			factory.getRecordArchetypes().put("Holdings","usmarc::F");

		}

		factory.setHost(uri.getHost());

		factory.setPort(uri.getPort());

		Searchable s = factory.newSearchable();

		s.setApplicationContext(app_context);	

		return s;

	}

	/**

	 * Initialize the application context

	 * @param url 

	 */

	private static void initAppContext(URI uri){

		System.setProperty("javax.xml.parsers.DocumentBuilderFactory","org.apache.xerces.jaxp.DocumentBuilderFactoryImpl");

		try{

			app_context = new FileSystemXmlApplicationContext(new String[]{"config/ApplicationContextAlone.xml"},false);

			((FileSystemXmlApplicationContext)app_context).setClassLoader(Z3950ConnectionFactory.class.getClassLoader());

			((FileSystemXmlApplicationContext)app_context).refresh();

		}catch(Exception e){

			e.printStackTrace();

			app_context = new FileSystemXmlApplicationContext(new String[]{"gvSIG/extensiones/es.gva.cit.gvsig.catalogClient/config/ApplicationContext.xml"},false);

			((FileSystemXmlApplicationContext)app_context).setClassLoader(Z3950ConnectionFactory.class.getClassLoader());

			((FileSystemXmlApplicationContext)app_context).refresh();

		}			

		if (app_context == null){

			throw new RuntimeException("Unable to locate TestApplicationContext.xml definition file");

		}

		appContextInitialized = true;

	}

}

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

*/

package org.gvsig.catalog.protocols;

import java.awt.image.BufferedImage;

import java.io.File;

import java.io.IOException;

import java.net.MalformedURLException;

import java.net.URL;

import javax.imageio.ImageIO;

/**

 * This class is used lo load an image from a URL. It saves the image

 * in a file

 * 

 * 

 * @author Jorge Piera Llodra (piera_jor@gva.es)

 */

public class GetImageFromWeb {

/**

 * It saves an image in a file

 * 

 * 

 * @return 

 * @param sUrl URL that contains the image

 * @param sfile File to save the image

 */

    public boolean getImageUrl(String sUrl, String sfile) {        

        URL url;

        try {

            url = new URL(sUrl);

            BufferedImage img = ImageIO.read(url);

            if (img == null)

                return false;            

            File outFile = new File(sfile);

            //We must to change this value: getCapabalilities request

            //has the supported formats

            return ImageIO.write(img, "jpeg", outFile);

        } catch (MalformedURLException e) {

            // TODO Auto-generated catch block

            System.out.println("La URL de la imagen no es correcta");

        } catch (IOException e1) {

            // TODO Auto-generated catch block

            System.out.println("No he podido leer la imagen desde la URL");

        }

        return false;

    } 

 }

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

*/

package org.gvsig.catalog.protocols;

import java.io.BufferedReader;

import java.io.ByteArrayInputStream;

import java.io.File;

import java.io.FileWriter;

import java.io.InputStream;

import java.net.URL;

import java.util.Collection;

import javax.xml.parsers.DocumentBuilder;

import org.apache.soap.Constants;

import org.apache.soap.Envelope;

import org.apache.soap.SOAPException;

import org.apache.soap.messaging.Message;

import org.apache.soap.transport.SOAPTransport;

import org.apache.soap.util.xml.XMLParserUtils;

import org.gvsig.catalog.metadataxml.XMLTree;

import org.w3c.dom.Document;

import org.xml.sax.InputSource;

/**

 * 

 * 

 * 

 * @author Jorge Piera Llodra (piera_jor@gva.es)

 */

public class SOAPProtocol implements IProtocols {

/**

 * 

 * 

 * 

 * @return 

 * @param url 

 * @param object 

 * @param firstRecord 

 */

    public Collection doQuery(URL url, Object object, int firstRecord) {        

        String message = (String) object;

        File fileAnswer = null;

        //get the envelope to send

        try {

            InputStream buffer = new ByteArrayInputStream(message.getBytes());

            DocumentBuilder xdb = XMLParserUtils.getXMLDocBuilder();

            Document doc = xdb.parse(new InputSource(buffer));

            if (doc == null) {

                throw new SOAPException(Constants.FAULT_CODE_CLIENT,

                    "parsing error");

            }

            Envelope msgEnv = Envelope.unmarshall(doc.getDocumentElement());

            // send the message

            Message msg = new Message();

            msg.send(url, "urn:this-is-the-action-uri", msgEnv);

            // receive whatever from the transport and dump it to the screen

            SOAPTransport st = msg.getSOAPTransport();

            BufferedReader br = st.receive();

            String line;

            //File to save the answer

            fileAnswer = new File("auxiliar");

            FileWriter fwAnswer = new FileWriter(fileAnswer);

            fwAnswer.write("<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>");

            //Process the answer	    		    

            while ((line = br.readLine()) != null) {

                System.out.println(line);

                fwAnswer.write(line);

                fwAnswer.flush();

            }

            fwAnswer.close();

        } catch (Exception e) {

            return null;

        }

        Collection col = new java.util.ArrayList();

        col.add(XMLTree.xmlToTree(fileAnswer));

        return col;

    } 

/**

 * 

 * 

 * 

 * @return 

 * @param url 

 */

    public static boolean isProtocolSupported(URL url) {        

        return true;

    } 

/**

 * This function returns a SOAP message

 * 

 * 

 * @return 

 * @param message the XML message

 * @param schemas 

 */

    public static String setSOAPMessage(String message, String[] schemas) {        

        String soap =  "<SOAP:Envelope xmlns:SOAP=\"http://schemas.xmlsoap.org/soap/envelope/\" " +

        	"xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"" ;

        if (schemas != null){

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

                soap = soap + " " + schemas[i];

            }

        }

        soap = soap + ">";

        soap = soap + "<SOAP:Body>" + message + "</SOAP:Body>" + "</SOAP:Envelope>";

        return soap;

    } 

 }

bib-1.1=AccessPoint

bib-1.2=Relation

bib-1.3=Position

bib-1.4=Structure

bib-1.5=Truncation

bib-1.6=Completeness

gils.1=AccessPoint

gils.10=SpatialQualifier

# Default OID Configuration file

#

# $Id: a2j.properties 561 2007-07-27 06:49:30 +0000 (Fri, 27 Jul 2007) jpiera $

#

# Attribute Set OID's

# Bib-1 Attribute Set

oid.bib-1={1,2,840,10003,3,1}

# Explain Attribute Set

oid.exp-1={1,2,840,10003,3,2}

oid.ext-1={1,2,840,10003,3,3}

oid.ccl={1,2,840,10003,3,4}

oid.gils_attrset={1,2,840,10003,3,5}

oid.stas={1,2,840,10003,3,6}

oid.collect1={1,2,840,10003,3,7}

oid.cimi={1,2,840,10003,3,8}

oid.geo={1,2,840,10003,3,9}

oid.zbig={1,2,840,10003,3,10}

oid.util={1,2,840,10003,3,11}

oid.xd1={1,2,840,10003,3,12}

name.xd1=Cross Domain Attribute Set

oid.zthes={1,2,840,10003,3,13}

name.zthes=Thesaurus Attribute Set

oid.holdings={1,2,840,10003,3,16}

name.holdings=Holdings Attribute Set

# Record Syntax OID's

oid.unimarc={1,2,840,10003,5,1}

name.unimarc=UNIMarc Record

oid.usmarc={1,2,840,10003,5,10}

name.usmarc=US Marc Record

oid.marc21={1,2,840,10003,5,10}

name.marc21=Marc21 Record

oid.ukmarc={1,2,840,10003,5,11}

name.ukmark=UK Marc Record

oid.normarc={1,2,840,10003,5,12}

name.normarc=NorMarc Record

oid.librismarc={1,2,840,10003,5,13}

name.librismarc=LibrisMarc Record

oid.danmarc={1,2,840,10003,5,14}

oid.finmarc={1,2,840,10003,5,15}

oid.canmarc={1,2,840,10003,5,17}

oid.ausmarc={1,2,840,10003,5,20}

oid.ibermarc={1,2,840,10003,5,21}

name.ibermarc=IberMarc Record

oid.catmarc={1,2,840,10003,5,22}

name.catmarc=CatMarc Record

oid.explain={1,2,840,10003,5,100}

name.explain=Explain Record

codec.explain=org.jzkit.z3950.gen.v3.RecordSyntax_explain.Explain_Record_codec

oid.sutrs={1,2,840,10003,5,101}

name.sutrs=Simple Unstructured Text Record

codec.sutrs=org.jzkit.z3950.gen.v3.RecordSyntax_SUTRS.SutrsRecord_codec

oid.opac={1,2,840,10003,5,102}

name.opac=Opac Record

codec.opac=org.jzkit.z3950.gen.v3.RecordSyntax_opac.OPACRecord_codec

oid.summary={1,2,840,10003,5,103}

name.summary=Summary Record

codec.summary=org.jzkit.z3950.gen.v3.RecordSyntax_summary.BriefBib_codec

oid.grs-1={1,2,840,10003,5,105}

name.grs-1=Generic Record

codec.grs-1=org.jzkit.z3950.gen.v3.RecordSyntax_generic.GenericRecord_codec

oid.pdf={1,2,840,10003,5,109,1}

name.pdf=PDF Document

oid.postscript={1,2,840,10003,5,109,2}

name.postscript=Postscript Document

oid.html={1,2,840,10003,5,109,3}

name.html=HTML data

oid.sgml={1,2,840,10003,5,109,9}

name.sgml=SGML data

oid.xml={1,2,840,10003,5,109,10}

name.xml=XML data

# Diagnostic Set OID's

oid.diag-bib-1={1,2,840,10003,4,1}

name.diag-bib-1=Bib1 Diagnostic Set

oid.diag-1={1,2,840,10003,4,2}

name.diag-1=Diag1 Diagnostic Set

codec.diag-1=org.jzkit.z3950.gen.v3.DiagnosticFormatDiag1.DiagnosticFormat_codec

# Schema OID's

oid.wais_schema={1,2,840,10003,13,1}

name.wais_schema=WAIS Record Schema

oid.gils_schema={1,2,840,10003,13,2}

name.gils_schema=GILS Record Schema

oid.collections_schema={1,2,840,10003,13,3}

name.collections_schema=GILS Record Schema

oid.geo_schema={1,2,840,10003,13,4}

name.geo_schema=GEO Record Schema

oid.cimi_schema={1,2,840,10003,13,5}

name.cimi_schema=CIMI Record Schema

oid.update_schema={1,2,840,10003,13,6}

name.update_schema=CIMI Record Schema

oid.holdings_schema={1,2,840,10003,13,7}

name.holdings_schema=Holdings Record Schema

oid.zthes_schema={1,2,840,10003,13,8}

name.zthes_schema=Zthes Record Schema

oid.z_charset_neg_3={1,2,840,10003,15,3}

name.z_charset_neg_3=Z39.50-Character-Set-Negotiation-3

codec.z_charset_neg_3=org.jzkit.z3950.gen.v3.NegotiationRecordDefinition_charSetandLanguageNegotiation_3.CharSetandLanguageNegotiation_codec

oid.charset_ucs2={1,0,10646,1,0,2}

name.charset_ucs2=UCS-2

oid.charset_ucs4={1,0,10646,1,0,4}

name.charset_ucs4=UCS-4

oid.charset_utf16={1,0,10646,1,0,5}

name.charset_utf16=UTF-16

oid.charset_utf8={1,0,10646,1,0,8}

name.charset_utf8=UTF-8

oid.es_persistent_result_set={1,2,840,10003,9,1}

name.es_persistent_result_set=Persistent Result Set Extended Service

oid.es_persistent_query={1,2,840,10003,9,2}

name.es_persistent_query=Persistent Query Extended Service

oid.es_periodic_query_schedule={1,2,840,10003,9,3}

name.es_periodic_query_schedule=Periodic Query Schedule Extended Service

oid.es_item_order={1,2,840,10003,9,4}

name.es_item_order=Item Order Extended Service

oid.es_database_update={1,2,840,10003,9,5}

name.es_database_update=Database Update

codec.es_database_update=org.jzkit.z3950.gen.v3.ESFormat_Update0.Update_codec

oid.es_database_update_r1={1,2,840,10003,9,5,1,1}

name.es_database_update_r1=Database Update Revision 1

codec.es_database_update_r1=org.jzkit.z3950.gen.v3.ESFormat_Update.Update_codec

oid.es_export_specification={1,2,840,10003,9,6}

name.es_export_specification=Export Specification

oid.es_export_invocation={1,2,840,10003,9,6}

name.es_export_invocation=Export Invocation

# ISO ILL Externals

oid.ILL_OCLC_PRISM_Error={1,0,10161,13,1}

name.ILL_OCLC_PRISM_Error=OCLC Prism Error Extension

oid.ILL_OCLC_Request={1,0,10161,13,2}

name.ILL_OCLC_Request=OCLC Request Extension

oid.ILL_APDU_Delivery_Info={1,0,10161,13,3}

name.ILL_APDU_Delivery_Info=ILL APDU Delivery Info

# codec.ILL_APDU_Delivery_Info=org.jzkit.OpenRequest.isoill.gen.ILL_APDU_Delivery_Info.APDU_Delivery_Info_codec

oid.ILL_Supplemental_Client_Info={1,0,10161,13,4}

name.ILL_Supplemental_Client_Info=ILL Supplemental Client Info

oid.ILL_Forwarded_Additional_Info={1,0,10161,13,5}

name.ILL_Forwarded_Additional_Info=ILL Forwarded Additional Info

oid.IPIG_Additional_User_Error_Info={1,0,10161,13,6}

name.IPIG_Additional_User_Error_Info=IPIG Additional User Error Information

oid.ILL_Suppliers_Reference={1,0,10161,13,7}

name.ILL_Suppliers_Reference=ILL Suppliers Reference

oid.ILL_Internal_Reference_Number={1,0,10161,13,8}

name.ILL_Internal_Reference_Number=ILL Internal Reference Number

oid.IPIG_ILL_Request_Extension={1,0,10161,13,9}

name.IPIG_ILL_Request_Extension=IPIG ILL Request Extension

DefaultTargetAttrset=bib-1

dc.title=bib-1:1:4

dc.creator=bib-1:1:4

k-int.anywhere=bib-1:1:1016

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

*/

package org.gvsig.catalog.protocols;

import java.io.ByteArrayInputStream;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStreamWriter;

import java.net.HttpURLConnection;

import java.net.URL;

import java.util.Collection;

import org.gvsig.catalog.metadataxml.XMLTree;

import org.gvsig.catalog.utils.Strings;

/**

 * This class implement the HTTP Post protocol.

 * 

 * 

 * @author Jorge Piera Llodra (piera_jor@gva.es)

 */

public class HTTPPostProtocol implements IProtocols {

/**

 * @return 

 * @param url 

 * @param message 

 * @param firstRecord 

 */

    public Collection doQuery(URL url, Object message, int firstRecord) {        

        String body = (String) message;

        ByteArrayInputStream output = null;

        try {

            HttpURLConnection c = (HttpURLConnection) url.openConnection();

         c.setRequestProperty("SOAPAction","post");

         c.setRequestMethod("POST");

         c.setDoOutput(true);

         c.setRequestProperty("Content-Type", "text/xml; charset=UTF-8");

        // Write the request.

        OutputStreamWriter w =

            new OutputStreamWriter(c.getOutputStream(), "UTF-8");

        w.write(body);

        w.flush();

        InputStream is = c.getInputStream();

        byte[] buf = new byte[1024];

        int len;

        String str = "";

        while ((len = is.read(buf)) > 0) {

            str = str + new String(buf, 0, len);

        }

        str = Strings.replace(str,

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

		  "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>");

        System.out.println(str);

        output = new ByteArrayInputStream(str.getBytes());

        }  catch (IOException e) {

            // TODO Auto-generated catch block

            //e.printStackTrace();

            return null;

        } 

        Collection col = new java.util.ArrayList();

        col.add(XMLTree.xmlToTree(output));

        return col;            

    }    

    public void doQuery(URL url, Object message, int firstRecord, String fileName) {        

    	String body = (String) message;

    	FileOutputStream output = null;

    	try {

    		HttpURLConnection c = (HttpURLConnection) url.openConnection();

    		c.setRequestProperty("SOAPAction","post");

    		c.setRequestMethod("POST");

    		c.setDoOutput(true);

    		c.setRequestProperty("Content-Type", "text/xml; charset=UTF-8");

    		// Write the request.

    		OutputStreamWriter w =

    			new OutputStreamWriter(c.getOutputStream(), "UTF-8");

    		w.write(body);

    		w.flush();

    		InputStream is = c.getInputStream();

    		byte[] buf = new byte[1024];

    		int len;

    		String str = "";

    		while ((len = is.read(buf)) > 0) {

    			str = str + new String(buf, 0, len);

    		}

    		System.out.println(str);

    		output = new FileOutputStream(new File(fileName));

    		output.write(str.getBytes());

    		output.flush();

    		output.close();

    	}  catch (IOException e) {

    		e.printStackTrace();           

    	}           

    }    

 }

package org.gvsig.catalog.protocols;

/* 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: Z3950Connection.java 561 2007-07-27 06:49:30 +0000 (Fri, 27 Jul 2007) jpiera $

 * $Log$

 * Revision 1.1.2.6.4.3  2007/07/23 07:14:25  jorpiell

 * Catalog refactoring

 *

 * Revision 1.1.2.6.4.2  2007/07/13 12:00:35  jorpiell

 * Add the posibility to add a new panel

 *

 * Revision 1.1.2.6.4.1  2007/07/10 11:18:04  jorpiell

 * Added the registers

 *

 * Revision 1.1.2.6  2006/11/15 00:08:08  jjdelcerro

 * *** empty log message ***

 *

 * Revision 1.4  2006/11/13 07:52:58  jorpiell

 * Se han incluido los cambios que se hicieron para Chile: cambio de la librer?a jzKit, carga de ArcIms y WCS

 *

 * Revision 1.3  2006/10/02 08:29:07  jorpiell

 * Modificados los cambios del Branch 10 al head

 *

 * Revision 1.1.2.3  2006/10/02 07:13:43  jorpiell

 * Comprobada una NullPointerException que generaba una excepci?n

 *

 * Revision 1.1.2.2  2006/09/25 06:48:38  jorpiell

 * A?adida la funcionalidad de mostrar el documento de texto cuando no es un XML

 *

 * Revision 1.1.2.1  2006/09/20 12:01:07  jorpiell

 * Se ha cambiado la versi?n de la jzkit, se ha incorporado la funcionalidad de cargar arcims

 *

 * Revision 1.1  2006/09/20 11:20:17  jorpiell

 * Se ha cambiado la versi?n de la librer?a jzkit de la 1 a la 2.0

 *

 *

 */

import java.net.URI;

import java.util.StringTokenizer;

import java.util.Vector;

import org.gvsig.catalog.drivers.GetRecordsReply;

import org.gvsig.catalog.metadataxml.XMLNode;

import org.gvsig.catalog.metadataxml.XMLTree;

import org.jzkit.a2j.codec.util.OIDRegister;

import org.jzkit.search.provider.iface.IRQuery;

import org.jzkit.search.provider.iface.SearchException;

import org.jzkit.search.provider.iface.Searchable;

import org.jzkit.search.util.RecordModel.ExplicitRecordFormatSpecification;

import org.jzkit.search.util.RecordModel.InformationFragment;

import org.jzkit.search.util.RecordModel.RecordFormatSpecification;

import org.jzkit.search.util.RecordModel.SUTRS;

import org.jzkit.search.util.RecordModel.XMLRecord;

import org.jzkit.search.util.ResultSet.IRResultSet;

import org.jzkit.search.util.ResultSet.IRResultSetException;

import org.jzkit.search.util.ResultSet.IRResultSetStatus;

import org.jzkit.z3950.client.SynchronousOriginBean;

import org.jzkit.z3950.gen.v3.Z39_50_APDU_1995.InitializeResponse_type;

public class Z3950Connection extends SynchronousOriginBean

{

  public static final char ISO2709_RS = 035;

  public static final char ISO2709_FS = 036;

  public static final char ISO2709_IDFS = 037;

  private static final String PREFIX_QUERY_TYPE = "PREFIX";

  private static final String CCL_QUERY_TYPE = "CCL";

  private int auth_type = 0; // 0=none, 1=anonymous, 2=open, 3=idpass

  private String principal = null;

  private String group = null;

  private String credentials = null; 

  private InitializeResponse_type resp = null;

  private URI uri = null;

  private String host = null;

  private int port = 0;

  private String database = null;

  public Z3950Connection(URI uri){

	  super(new OIDRegister("/a2j.properties"));

	  this.uri = uri;

	  this.host = uri.getHost();

	  this.port = uri.getPort();

	  StringTokenizer sti = new StringTokenizer(uri.getPath(), "/");

      if (sti.countTokens() == 0) {

          this.database = "geo";

      } else {

          this.database = sti.nextToken();

      }

  }

  /**

   * 

   * @param url

   * @return

   */

  public String connect(){

	   	if (resp == null){

	    	resp = connect(host,port,auth_type,principal,group,credentials);

	    }

	    StringBuffer string = new StringBuffer();	    

	    if (resp == null){

	    	return null;

	    }

	    if (resp.result.booleanValue() == true) {

	    	if (resp.referenceId != null) {

	    		string.append("Reference ID : " + new String(resp.referenceId) +

	    		"\n");

	    	}

	    	string.append("Implementation ID : " +

	    			resp.implementationId + "\n");

	    	string.append("Implementation Name : " +

	    			resp.implementationName + "\n");

	    	string.append("Implementation Version : " +

	    			resp.implementationVersion + "\n");

	    } else {

	    	System.out.println(" Failed to establish association");

	    	return null;

	    }

	    return string.toString();

  }

  public GetRecordsReply search(GetRecordsReply recordsReply, String sQuery,int firstRecord){

	  try{

		  IRQuery query = new IRQuery();

		  query.collections = new Vector();

		  query.collections.add(database);

		  query.query = new org.jzkit.search.util.QueryModel.PrefixString.PrefixString(sQuery);

		  Searchable s = Z3950ConnectionFactory.getSearchable(uri);

		  IRResultSet result = s.evaluate(query);

		  result.waitForStatus(IRResultSetStatus.COMPLETE|IRResultSetStatus.FAILURE,0);

		  int numOfResults = result.getFragmentCount();

		  recordsReply.setNumRecords(numOfResults);

		  RecordFormatSpecification rfs = new ExplicitRecordFormatSpecification(null,null,"f");

		  InformationFragment[] fragment = result.getFragment(firstRecord,10,rfs);

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

			  try {

				  String answer = "";				  

				  if (fragment[i] instanceof XMLRecord){				  	 

					  XMLRecord xml = (XMLRecord)fragment[i];	

					  answer = xml.toString();

				  }else {

					  SUTRS sutr = (SUTRS)fragment[i];

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

					  "<" + XMLNode.ISNOTXML + ">" + 

					  sutr.toString() + 

					  "</" + XMLNode.ISNOTXML + ">";

				  }  				  

				  recordsReply.addRecord(uri, XMLTree.xmlToTree(answer));

			  } catch (Exception e1) {

				  // TODO Auto-generated catch block

				  e1.printStackTrace();

			  }

		  }	

	  }catch(SearchException e){

		  e.printStackTrace();

	  } catch (IRResultSetException e) {

		  // TODO Auto-generated catch block

		  e.printStackTrace();

	  } catch (Exception e) {

		  // TODO Auto-generated catch block

		  e.printStackTrace();

	  }	  

      return recordsReply;

  } 

}

package org.gvsig.catalog.protocols;

import java.net.URI;

import java.util.StringTokenizer;

import org.gvsig.catalog.drivers.GetRecordsReply;

import org.jzkit.search.provider.iface.SearchException;

import org.jzkit.search.util.ResultSet.IRResultSetException;

/* 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: Z3950Protocol.java 561 2007-07-27 06:49:30 +0000 (Fri, 27 Jul 2007) jpiera $

 * $Log$

 * Revision 1.21.2.2.4.3  2007/07/23 07:14:25  jorpiell

 * Catalog refactoring

 *

 * Revision 1.21.2.2.4.2  2007/07/13 12:00:35  jorpiell

 * Add the posibility to add a new panel

 *

 * Revision 1.21.2.2.4.1  2007/07/10 11:18:04  jorpiell

 * Added the registers

 *

 * Revision 1.21.2.2  2006/11/15 00:08:08  jjdelcerro

 * *** empty log message ***

 *

 * Revision 1.23  2006/10/02 08:29:07  jorpiell

 * Modificados los cambios del Branch 10 al head

 *

 * Revision 1.21.2.1  2006/09/20 12:01:18  jorpiell

 * Se ha cambiado la versi?n de la jzkit, se ha incorporado la funcionalidad de cargar arcims

 *

 * Revision 1.22  2006/09/20 11:20:17  jorpiell

 * Se ha cambiado la versi?n de la librer?a jzkit de la 1 a la 2.0

 *

 *

 */

/**

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

 */

public class Z3950Protocol {

	/**

	   * Makes a query

	   * @param url

	   * @param object

	   * @param firstRecord

	   * @return

	 * @throws IRResultSetException 

	 * @throws SearchException 

	   */

	  public GetRecordsReply doQuery(GetRecordsReply recordsReply, URI uri, Object object, int firstRecord){    

		  Z3950Connection connection = Z3950ConnectionFactory.getConnection(uri);

		  return connection.search(recordsReply,(String)object,firstRecord);

	 }  

	  /**

	   * 

	   * @param url

	   * @return

	   */

	  public String openConnection(URI uri) {      

		  Z3950Connection connection = Z3950ConnectionFactory.getConnection(uri);

		  return connection.connect();

	  }

	  /**

	   * 

	   * @param url

	   * @return

	   */

	  public boolean isProtocolSupported(URI uri) {    

	     Z3950Connection connection = Z3950ConnectionFactory.getConnection(uri);

	     if (connection.connect() == null){

	    	 return false;

	     }

	     return true;

	  }

	  /**

	   * Return the database

	   * @param url

	   * @return

	   */

	  public static String getDatabase(URI uri) {

		  StringTokenizer sti = new StringTokenizer(uri.getPath(), "/");

		  if (sti.countTokens() == 0) {

			  return "geo";

		  } else {

			  return sti.nextToken();

		  }

	  }

}

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

*/

package org.gvsig.catalog.protocols;

import java.net.URL;

import java.util.Collection;

/**

 * 

 * 

 * 

 * @author Jorge Piera Llodra (piera_jor@gva.es)

 */

public interface IProtocols {

/**

 * 

 * 

 * 

 * @return 

 * @param url 

 * @param message 

 * @param firstRecord 

 */

    public Collection doQuery(URL url, Object message, int firstRecord);

}

/* gvSIG. Geographic Information System of the Valencian Government

*

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

* of the Valencian Government (CIT)

* 

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

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

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

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

* 

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

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

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

* 

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

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

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

* MA  02110-1301, USA.

* 

*/

/*

* AUTHORS (In addition to CIT):

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

*/

package org.gvsig.catalog;

import java.lang.reflect.InvocationTargetException;

import java.net.URI;

import org.gvsig.catalog.drivers.ICatalogServiceDriver;

import org.gvsig.catalog.loaders.LayerLoader;

import org.gvsig.catalog.metadataxml.XMLNode;

import org.gvsig.catalog.schemas.Record;

import org.gvsig.catalog.schemas.Resource;

/**

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

 */

public interface CatalogManager {

	/**

	 * It is used to retrieve a driver that supports a concrete 

	 * protocol

	 * @param protocol

	 * Catalog protocol

	 * @return

	 * The concrete catalog service driver

	 */

	public ICatalogServiceDriver getDriver(String protocol);

	/**

	 * @return a list with all the catalog drivers

	 */

	public ICatalogServiceDriver[] getDrivers();

	/**

	 * This method is used to register a new catalog driver 

	 * that manage a concrete protocol

	 * @param driver

	 * Catalog driver to register

	 */

	public void register(String name, Class driver);

	/**

	 * Adds a new record

	 * @param record

	 * New record to add

	 */

	public void addRecord(Record record);	

	/**

	 * Try to identify the XML format and return a record

	 * @param uri

	 * Server URI (used to retrieve the images)

	 * @param node

	 * XML node

	 * @return

	 */

	public Record createRecord(URI uri, XMLNode node);

	public void addLayerLoader(String key, Class loader);

	public LayerLoader getLayerLoader(Resource resource) throws IllegalArgumentException, SecurityException, InstantiationException, IllegalAccessException, InvocationTargetException, NoSuchMethodException;

}