| gvSIG desktop 1

package es.uji.lsi.wcs.client;

/*

 * WCSclient.java

 *

 * Created on 1 de diciembre de 2004, 21:56

 *

 * This file is supposed to implement the interface beetween server and client.

 * It will implement the GetCapabilities, DescribeCoverage and GetCoverage

 * operations.

 */

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.Enumeration;

import java.util.Hashtable;

import es.uji.lsi.wcs.XmlWcsParsing.Capabilities;

import es.uji.lsi.wcs.XmlWcsParsing.CoverageOffering;

import es.uji.lsi.wcs.XmlWcsParsing.DescribeCoverageResponse;

import es.uji.lsi.wcs.XmlWcsParsing.WCSExceptionResponse;

import es.uji.lsi.wcs.XmlWcsParsing.XMLNode;

/**

 *

 * @author  jaume

 */

public class WCSClient {

    public Capabilities capabilities;

    public DescribeCoverageResponse describeCoverageResponse;

    private OperationGetCapabilities operationGetCapabilities;

    private OperationDescribeCoverage operationDescribeCoverage;

    private OperationGetCoverage operationGetCoverage;

    private WCSExceptionResponse wcs_exception;

    // the working address

    private String working_address;

    // When working off-line (for development uses only)

    private boolean working_offline = false;

    private File file = null;

    private String path, datapath, coveragefilename, coveragefileextension;

    /** Creates a new instance of WCSclient */

    public WCSClient(String text) {

        this.working_address = text;

        operationGetCapabilities = new OperationGetCapabilities();

        operationDescribeCoverage = new OperationDescribeCoverage();

        operationGetCoverage = new OperationGetCoverage();

    }

    public WCSClient(){

        working_address = "http://localhost:8080";

        operationGetCapabilities = new OperationGetCapabilities();

        operationDescribeCoverage = new OperationDescribeCoverage();

        operationGetCoverage = new OperationGetCoverage();

    }

    public WCSClient(File file){

        working_offline = true;

        this.file = file;

        operationGetCapabilities = new OperationGetCapabilities();

        operationDescribeCoverage = new OperationDescribeCoverage();

        operationGetCoverage = new OperationGetCoverage();

    }

    public Capabilities getTheCapabilities(){

        return capabilities;

    }

    public void getCapabilities(){

        // Opens the source of the GetCapabilities XML description

            System.out.println("WCSClient>>> GetCapabilities");

        try {

            XMLNode node;

            if (working_offline) node = new XMLNode(file);

            else{

                System.out.println(working_address + operationGetCapabilities.getParamsString());

                URL url = new URL(working_address + operationGetCapabilities.getParamsString());

                node = new XMLNode(url.openStream());

                System.out.println("WCSClient>>> GetCapabilities done...");

            }

            capabilities = new Capabilities(node);

        } catch (MalformedURLException e){

            new Error("Bad URL");

        } catch (IOException e){

            new Error("Unable to retrieve server capabilities");

        } catch (Exception e){

            new Error();

        }

    }

    /**

     * Por documentar, para usar el mismo sistema que gvSIG

     *

     * @param url

     */

    public void getCapabilities(URL url){

            XMLNode node;

            try {

                    node = new XMLNode(url.openStream());

                    capabilities = new Capabilities(node);

            } catch (Exception e){

                    new Error(e.getMessage());

            }

    }

    /**

     * Devuelve la descripci?n de la cobertura ofrecida en el DescribeCoverage

     *

     * @param nomCobertura

     * @return es.uji.lsi.XmlWcsParsing.CoverageOffering

     */

    public CoverageOffering getCoverageDescription(String nomCobertura){

            return describeCoverageResponse.getCoverageOffering(nomCobertura);

        }

    /**

     * Por documentar, para usar el mismo sistema que gvSIG

     *

     * @param url

     */

    public void describeCoverage(URL url){

            XMLNode node;

            try {

                    node = new XMLNode(url.openStream());

            } catch (Exception e){

                    new Error(e.getMessage());

            }

    }

    public void describeCoverage(){

        try {

            XMLNode node;

            if (working_offline) node = new XMLNode(file);

            else{

                System.out.println(working_address+operationDescribeCoverage.getParamsString());

                URL url = new URL(working_address+operationDescribeCoverage.getParamsString());

                node = new XMLNode(url.openStream());

            }

            describeCoverageResponse = new DescribeCoverageResponse(node, capabilities);

        } catch (MalformedURLException e){

            new Error("Bad URL");

        } catch (IOException e){

            new Error("Unable to retrieve server capabilities, connection error.");

        } catch (Exception e){

            new Error();

        }

    }

    public void describeCoverage(String coverage_name){

        try {

            System.out.print("paso por aqu? tambien ya ves");

            operationDescribeCoverage.setParam("coverage", coverage_name);

            System.out.print("paso por aqu? tambien ya ves tu que tio");

            describeCoverage();

        } catch (Exception e){

            new Error("Fallo asignando valor al par?metro <coverage>");

        }

    }

    public boolean getCoverage(){

        System.out.println(operationGetCoverage.getParamsString());

        try {

            String s = this.working_address + operationGetCoverage.getParamsString();

            System.out.println(s);

            URL miurl = new URL(s);

            downloadCoverageFile(miurl, this.datapath);

            return (this.coveragefilename!=null);

        }

        catch (MalformedURLException e){

            new Error("WCS: GetCoverage> URL error.");

        }

        return false;

    }

    public void downloadCoverageFile(URL url, String targetdir){

        try{

            String path = this.getDataPath();

            String filename = this.getCoverageFileName()+this.getCoverageFileExtension();

            String where = path+filename;

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

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

            InputStream is = url.openStream();

            long readed = 0;

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

                dos.write(buffer, 0, i);

                readed += i;

            }

            dos.close();

        } catch (IOException ie){

            new Error("La petici?n de la cobertura no tuvo ?xito.");

        }

    }

    public boolean getCoverage(Hashtable hashtable){

        Enumeration en = hashtable.keys();

        try {

            while (en.hasMoreElements()){

                String key = (String) en.nextElement();

                operationGetCoverage.setParam(key, (String) hashtable.get(key));

            }

            return getCoverage();

        } catch (Exception e){

            new Error("GetCoverage error.");

        }

        return false;

    }

    public String getWorkingAddress(){

        return working_address;

    }

    public String getDataPath(){

        return this.datapath;

    }

    public String getCoverageFileName(){

        return this.coveragefilename;

    }

    public String getCoverageFileExtension(){

        return this.coveragefileextension;

    }

    public String toString(){

        return capabilities.toString();

    }

    public void setBaseDirectory(String path){

        this.path = path;

        this.datapath = this.path+"/data/";

    }

    public void setCoverageFileName(String name){

        this.coveragefilename = name;

    }

    public void setCoverageFileExtension(String extension){

        this.coveragefileextension = "."+extension;

    }

    public boolean isNotAnException(File file){

        this.wcs_exception = new WCSExceptionResponse(file);

        return (this.wcs_exception.getText() == null);

    }

    public String getWCSException(){

        return this.wcs_exception.getText();

    }

    private boolean checkExceptionResponse(File file){

        wcs_exception = new WCSExceptionResponse(file);

        return wcs_exception.getText()!=null;

    }

}