Application: gvSIG desktop » gvSIG tools: Catalog

/* 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.loaders;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import org.gvsig.app.gui.wizards.WizardListener;

import org.gvsig.app.gui.wizards.WizardListenerSupport;

import org.gvsig.catalog.gui.LoaderWizardPanel;

import org.gvsig.catalog.schemas.Resource;

import org.gvsig.fmap.dal.DataStoreParameters;

import org.gvsig.fmap.dal.coverage.exception.ConnectException;

import org.gvsig.fmap.dal.exception.InitializeException;

import org.gvsig.fmap.dal.exception.ProviderNotRegisteredException;

import org.gvsig.fmap.dal.exception.ValidateDataParametersException;

import org.gvsig.i18n.Messages;

import org.gvsig.raster.wcs.app.wcsclient.gui.panel.WCSParamsPanel;

import org.gvsig.raster.wcs.io.WCSLayerNode;

import org.gvsig.raster.wcs.io.WCSProvider;

import org.gvsig.raster.wcs.io.WCSServerExplorer;

import org.gvsig.raster.wcs.io.WCSServerExplorerParameters;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * This class is used to load a WCS  layer in gvSIG

 * 

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

 */

public class WCSLayerLoader extends GvSigLayerLoader{

        private Logger logger = LoggerFactory.getLogger(WCSLayerLoader.class);

        private WCSServerExplorer explorer;

        private WCSParamsPanel wcsParamsPanel;

        public static final String FIELD_FORMAT = "format";

        public static final String FIELD_NAME = "name";

        public static final String FIELD_SRSSTR = "srsstr";

        public static final String FIELD_URI = "uri";

        public static final String FIELD_ONLINERESOURC = "onlineresources";

        public static final String FIELD_WIDTH = "width";

        public static final String FIELD_HEIGHT = "height";

        public static final String FIELD_PARAM = "parameter";

        public WCSLayerLoader(Resource resource) {

                super(resource);

        }        

        protected boolean hasSpecificLayer() {        

                return true;

        }

        protected String getLayerName() {      

                return getResource().getName();

        } 

        protected DataStoreParameters createDataStoreParameters()

                        throws InitializeException, ProviderNotRegisteredException {

                DataStoreParameters dataStoreParameters = DATA_MANAGER.createStoreParameters("Wcs Store");

                if(getResource() != null){

                        dataStoreParameters.setDynValue(FIELD_NAME, getLayerName());

                        dataStoreParameters.setDynValue(FIELD_ONLINERESOURC, createOnlineResources());

                }

                if(parseQuery(dataStoreParameters, getResource().getLinkage())){

                        return dataStoreParameters;

                }

                return null;

        }

        protected Map createOnlineResources() {

                Map args = new HashMap();

                args.put("GepCoverage", getResource().getLinkage());      

                return args;

        }

        protected String extensionPointName() {

                return "OGC:WCS";

        }

        /**

         * Builds a coverage starting from a full GetCoverage URL.

         * (Using this is not a regular function)

         */

        private boolean parseQuery(DataStoreParameters dataStoreParameters, String link){

                String host = null;

                String queryString = null;

                int index = link.indexOf("?");

                if (index > 0){        

                        host = link.substring(0, index);

                        queryString = link.substring(index+1);

                }else{

                        host = link;

                        queryString = "";

                }

                if(link.indexOf('?') > -1){

                        queryString = link.substring(link.indexOf('?')+1);

                        dataStoreParameters.setDynValue(FIELD_URI, link.substring(0,link.indexOf('?')));

                        String[] params = queryString.split("&");

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

                                if (params[i]!= null){

                                        String[] nameValue = params[i].split("=");

                                        if(nameValue.length == 2){

                                                String param = nameValue[0].toUpperCase();

                                                if (param.equals("CRS")){

                                                        dataStoreParameters.setDynValue(FIELD_SRSSTR, nameValue[1]);

                                                }else if (param.equals("FORMAT")){

                                                        dataStoreParameters.setDynValue(FIELD_FORMAT, nameValue[1]);

                                                }else if (param.equals("WIDTH")){

                                                        dataStoreParameters.setDynValue(FIELD_WIDTH, nameValue[1]);

                                                }else if (param.equals("HEIGHT")){

                                                        dataStoreParameters.setDynValue(FIELD_HEIGHT, nameValue[1]);

                                                }else if (param.equals("BANDS")){

                                                        dataStoreParameters.setDynValue(FIELD_PARAM, nameValue[1]);

                                                }                   

                                        }

                                }

                        }  

                }else{

                        dataStoreParameters.setDynValue(FIELD_URI, link);

                        try {

                                WCSServerExplorerParameters explorerParams;

                                explorerParams = (WCSServerExplorerParameters) DATA_MANAGER.createServerExplorerParameters(WCSProvider.NAME);

                                explorerParams.setHost(host);

                                explorer = (WCSServerExplorer) DATA_MANAGER.createServerExplorer(explorerParams);

                                explorer.connect(null);

                                deleteRepitedValues();

                                if(!getParams(dataStoreParameters, link)){

                                        return false;

                                }

                        } catch (ValidateDataParametersException e) {

                                // TODO Auto-generated catch block

                                e.printStackTrace();

                                return false;

                        } catch (InitializeException e) {

                                // TODO Auto-generated catch block

                                e.printStackTrace();

                                return false;

                        } catch (ProviderNotRegisteredException e) {

                                // TODO Auto-generated catch block

                                e.printStackTrace();

                                return false;

                        } catch (ConnectException e) {

                                // TODO Auto-generated catch block

                                e.printStackTrace();

                        }

                }

                return true;

        }        

        private void deleteRepitedValues() {

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

                        WCSLayerNode layer = explorer.getCoverageList()[i];

                        deleteDuplicatedStringsFromList(layer.getFormats());

                        deleteDuplicatedStringsFromList(layer.getInterpolationMethods());

                        deleteDuplicatedStringsFromList(layer.getSRSs());

                }

        }

        private void deleteDuplicatedStringsFromList(List list){

                HashSet hs = new HashSet();

                hs.addAll(list);

                list.clear();

                list.addAll(hs);

        }

        private boolean getParams(DataStoreParameters dataStoreParameters, String link) {

                try{

                        wcsParamsPanel = new WCSParamsPanel();

                        wcsParamsPanel.setListenerSupport(new WizardListenerSupport());

                        wcsParamsPanel.setWizardData(explorer);

                        LoaderWizardPanel panel = new LoaderWizardPanel(wcsParamsPanel, dataStoreParameters);

                        return panel.showWizardOnDialog();

                }catch(NoClassDefFoundError e1){

                        logger.info("No est? instalada la extensi?n de raster");

                        return false;

                }

        }

        protected String getErrorMessage() {

                return Messages.getText("wcsError") + ".\n" +

                                Messages.getText("link") + ": " + 

                                getResource().getLinkage();                

        }

        protected String getWindowMessage() {

                return Messages.getText("wcsLoad");

        }

}