Application: gvSIG desktop » gvSIG raster

import java.io.IOException;

import java.io.InputStream;

import java.net.MalformedURLException;

import java.net.URL;

import java.net.URLConnection;

import java.util.Hashtable;

import java.util.List;

import org.gvsig.compat.net.ICancellable;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

public class WCSServerExplorer implements RasterDataServerExplorer, DataServerExplorerProvider {

	private WCSConnector                connector                = null;

	private WCSServerExplorerParameters parameters               = null;

	public WCSServerExplorer(

			WCSServerExplorerParameters parameters,

			DataServerExplorerProviderServices services)

			throws InitializeException {

		this.parameters = parameters;

	}

	/**

	 * Gets the provider's name

	 * @return

	public String getDataStoreProviderName() {

		return WCSProvider.NAME;

	}

	public String getDescription() {

		return WCSProvider.DESCRIPTION;

	}

	public boolean add(String provider, NewDataStoreParameters parameters,

			boolean overwrite) throws DataException {

		return false;

	}

	public void remove(DataStoreParameters parameters) throws DataException {

	}

	public void dispose() {

	}

	public String getProviderName() {

		return null;

	}

	/**

	 * Gets the online resources

	 * @return

	 */

	public Hashtable getOnlineResources() {

		return null;

	}

	//**********************************************

	//Connector

	//**********************************************

	public DataStoreParameters getStoredParameters() {

		DataManager manager = DALLocator.getDataManager();

		WCSDataParametersImpl params = null;

		try {

			params = (WCSDataParametersImpl) manager.createStoreParameters(this.getDataStoreProviderName());

		} catch (InitializeException e) {

		} catch (ProviderNotRegisteredException e) {

		}

		return params;

	}

	/**

	 * the basic information to make requests.

	 */

	public void connect(ICancellable cancellable) throws ConnectException {

		URL url = null;

		boolean override = false;

		try {

			url = new URL(parameters.getHost());

		} catch (Exception e) {

        } catch (IOException e) {

			throw new ConnectException(Messages.getText("error_connecting"), e);

		}

	}

	/**

	 * Checks if the network and host are reachable

	 * @param timeout for the host

		} catch (IOException e) {

			return false;

		}

		return true;

	}

	 * @return

	 */

	public String getServerType() {

			return "WCS";

        return "WCS "+ getVersion();

	}

	public String getHost() {

		return parameters.getHost();

	}

	/**

	 * Gets the title

	 * @return

	public WCSLayerNode[] getCoverageList() {

		return connector.getLayerList();

	}

	/**

	 * @return

	 */

	public WCSLayerNode getCoverageByName(String name) {

import java.awt.geom.Rectangle2D;

import java.io.File;

import java.io.IOException;

import java.net.URL;

import java.util.ArrayList;

import java.util.Hashtable;

import org.apache.commons.lang3.StringUtils;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataStore;

import org.gvsig.fmap.dal.DataStoreParameters;

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

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

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

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

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

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

import org.gvsig.fmap.dal.coverage.store.props.HistogramComputer;

import org.gvsig.fmap.dal.coverage.store.props.Transparency;

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

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

import org.gvsig.fmap.dal.spi.DataManagerProviderServices;

import org.gvsig.fmap.dal.spi.DataStoreProviderServices;

import org.gvsig.metadata.MetadataLocator;

import org.gvsig.raster.cache.tile.provider.TileServer;

import org.gvsig.raster.impl.buffer.SpiRasterQuery;

import org.gvsig.raster.impl.datastruct.BandListImpl;

import org.gvsig.raster.impl.datastruct.DatasetBandImpl;

	public static final String          METADATA_DEFINITION_NAME = "WcsStore";

	private Extent                      viewRequest              = null;

	drivers                  = new Hashtable<URL, WCSConnector> ();

	private boolean                     open                     = false;

	private DataStoreTransparency       fileTransparency         = null;

	private File                        lastRequest              = null;

	public static void register() {

		DataManagerProviderServices dataman = (DataManagerProviderServices) DALLocator.getDataManager();

		if (dataman != null && !dataman.getStoreProviders().contains(NAME)) {

	 * Constructor. Abre el dataset.

	 * @param proj Proyecci?n

	 * @param fName Nombre del fichero

	 * @throws NotSupportedExtensionException

	 */

		super(params);

		if(params instanceof String) {

			WCSDataParametersImpl p = new WCSDataParametersImpl();

			super.init(p, null, ToolsLocator.getDynObjectManager()

					.createDynObject(

							MetadataLocator.getMetadataManager().getDefinition(

		}

	}

	public WCSProvider(WCSDataParametersImpl params,

			DataStoreProviderServices storeServices) throws InitializeException {

		super(params, storeServices, ToolsLocator.getDynObjectManager()

		WCSDataParametersImpl p = (WCSDataParametersImpl)parameters;

		URL url = null;

		try {

		} catch (Exception e) {

			throw new RemoteServiceException("Malformed URL",e);

		}

	 * @param proj Proyecci?n

	 * @param param Parametros de carga

	 * @throws NotSupportedExtensionException

	 */

	public void init (DataStoreParameters params,

			DataStoreProviderServices storeServices) throws InitializeException {

		double resolutionX = e.width() / getWidth();

		double resolutionY = e.height() / getHeight();

		ownTransformation = new AffineTransform(

				e.getULX() - (resolutionX / 2),

				e.getULY() - (resolutionY / 2));

		externalTransformation = (AffineTransform) ownTransformation.clone();

		try {

			p.setFormat("image/tiff");

			if(p.getSRSCode() == null){

				ArrayList srs = connector.getSRSs(p.getCoverageName());

				if(!srs.isEmpty() && !StringUtils.isBlank((String)srs.get(0))){

					p.setSRSID((String) srs.get(0));

		return fileTransparency;

	}

	}

	public void setView(Extent e) {

	}

	/**

	 * File layer has in the long side FIXED_SIZE pixels and the bounding box is complete. This file could be

	 * useful to build an histogram or calculate statistics. This represents a sample of data.

	 * @return

	 * Reads a complete block of data and returns an tridimensional array of the right type. This function is useful

	 * to read a file very fast without setting a view. In a WCS service when the size is fixed then it will read the

	 * entire image but when the source hasn't pixel size it will read a sample of data. This set of data will have

	 * @param pos Posici?n donde se empieza  a leer

	 * @param blockHeight Altura m?xima del bloque leido

	 * @return Object que es un array tridimendional del tipo de datos del raster. (Bandas X Filas X Columnas)

	 * @throws FileNotOpenException

	 * @throws RasterDriverException

	 */

			throws InvalidSetViewException, FileNotOpenException, RasterDriverException, ProcessInterruptedException {

		File lastFile = getFileLayer();

		BandList bandList = new BandListImpl();

			bandList.setDrawableBands(new int[]{0, 1, 2});*/

			RasterQuery q = RasterLocator.getManager().createQuery();

					(int)lastRequestProvider.getHeight());

			q.setAllDrawableBands();

			q.setAdjustToExtent(true);

	 * @return

	 * a georeferencing file

	 */

		String worldFile = file;

		int index = file.lastIndexOf(".");

			worldFile = file.substring(0, index) + getExtensionWorldFile();

		} else {

			worldFile = file + getExtensionWorldFile();

	}

	public boolean needEnhanced() {

				(getBandCount() == 1 && getDataType()[0] == Buffer.TYPE_BYTE));

	}

	 * @throws RasterDriverException

	 * @throws ProcessInterruptedException

	 */

			double ulx, double uly, double lrx, double lry) throws RasterDriverException, ProcessInterruptedException {

		try {

			//El nombre de fichero que ha puesto en el bandList es el del servidor y no el del fichero en disco

		WCSStatus wcsStatus = loadWCSStatus(ex.toRectangle2D());

		lastRequest = downloadFile(

				query.getAdjustedBufHeight());

		if (lastRequest == null) {

	 * @param buf

	 * @param bandList

	 * @return

	 */

	private void loadInitialInfo() throws RasterDriverException {

		WCSDataParametersImpl p = (WCSDataParametersImpl)parameters;

	/*private Buffer changeBufferDataType(int newDataType, Buffer buf, BandList bandList) {

		Buffer newBuffer = null;

		if(buf.getDataType() != newDataType) {

			buf.free();

			return buf;

		bandList.clear();

		return newBuffer;

	}*/

			BandList bandList, Buffer rasterBuf, TaskStatus status) throws ProcessInterruptedException, RasterDriverException {

		Point2D p1 = rasterToWorld(new Point2D.Double(x, y));

		Point2D p2 = rasterToWorld(new Point2D.Double(x + w, y + h));

		}

		if (format.indexOf("png") >= 0){

			return "png";

		if (format.indexOf("xml") >= 0){

			return "xml";

		if (format.indexOf("gif") >= 0){

			return "gif";

		}

		}

		if (format.indexOf("jpg") >= 0

				|| format.indexOf("jpeg") >= 0){

		}

		return "xml";

	}

		return true;

	}

		return null;

	}

		return histogram;

	}

}

import java.awt.geom.Point2D;

import java.awt.geom.Rectangle2D;

import java.util.Hashtable;

import java.util.Map;

	 * @return

	 */

	public Object getTime();

	/**

	 * Sets the time information for the request

	 * @param time

	 * @return Formato.

	 */

	public Object getFormat();

	/**

	 * Sets the format

	 * @param format Formato.

	public Object getURI();

	public String getCoverageName();

	public Point2D getMaxResolution();

	public String getParameter();

	/**

	 * Gets the bounding box

	 * @return

	 */

	public Rectangle2D getExtent();

	public int getWidth();

	public int getHeight();

	public boolean isOverridingHost();

	/**

	 * Gets the online resource map

	 * @param onlineResources

	 */

	public Map<String,String> getOnlineResource();

	public String getDepth();

	public void setCancellable(ICancellable cancel);

	public void setOverrideHost(boolean over);

	/**

	 * When a provider is initialized this will need to know what is the extent before the request.

	 * @param bBox

	 */

	public void setExtent(Rectangle2D bBox);

	public void setSRS(String srs);

	 * @param onlineResources

	 */

	public void setOnlineResources(Hashtable<String, String> onlineResources);

	public void setDepth(String depth);

}

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

* @author Nacho Brodin (nachobrodin@gmail.com)

*/

public class WCSTileServer implements TileServer {

	private Downloader                 downloader           = null;

	private RasterDataStore            store                = null;

	private String                     suffix               = ".tif";

	public WCSTileServer(RasterDataStore store) {

		this.store = store;

		this.suffix = ((RasterProvider)store.getProvider()).getFileSuffix();

	}

	public Downloader getDownloader() {

		if(downloader == null ||

		   ((TileDownloaderForWCS)downloader).getTileSize()[0] != TileCacheLibrary.ALTERNATIVE_TILESIZE ||

		   ((TileDownloaderForWCS)downloader).getTileSize()[1] != TileCacheLibrary.ALTERNATIVE_TILESIZE) {

			try {

				downloader = new TileDownloaderForWCS(

						((WCSProvider)store.getProvider()).getConnector());

			} catch (RemoteServiceException e) {

				return null;

	public CacheStruct getStruct() {

		if(struct == null) {

			TileCacheManager  manager = TileCacheLocator.getManager();

			int coordinates = CacheStruct.FLAT;

			if(store.getProjection() != null)

				coordinates = (store.getProjection() != null && store.getProjection().isProjected()) ? CacheStruct.FLAT : CacheStruct.GEOGRAFIC;

			else {

				Extent e = store.getExtent();

					e.getULY() >= -90 && e.getULY() <= 90 && e.getLRY() >= -90 && e.getLRY() <= 90) {

					coordinates = CacheStruct.GEOGRAFIC;

				}

			}

			String epsg = null;

			IProjection proj = store.getProjection();

			if(proj != null)

				epsg = proj.getAbrev();

					TileCacheLibrary.ALTERNATIVE_TILESIZE,

					((WCSProvider)store.getProvider()).getParameters().getCoverageName(),

					TileCacheLibrary.DEFAULT_STRUCTURE,

					RasterLibrary.pathTileCache,

		}

		return struct;

	}

	public void setStruct(CacheStruct struct) {

		if(struct != null) {

			this.struct = struct;

			if(struct.getTileSizeByLevel(0) != null) {

				try {

							struct.getTileSizeByLevel(0)[1],

							((WCSProvider)store.getProvider()).getConnector());

				} catch (RemoteServiceException ex) {

			}

		}

	}

	public String getFileSuffix() {

		return suffix;

	}

	public void setFileSuffix(String extension) {

		this.suffix = extension;

	}

import java.awt.geom.Rectangle2D;

import java.awt.image.BufferedImage;

import java.io.IOException;

import java.util.HashMap;

import java.util.List;

import javax.print.attribute.PrintRequestAttributeSet;

import org.cresques.cts.IProjection;

import org.gvsig.compat.net.ICancellable;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.tools.task.Cancellable;

import org.gvsig.tools.task.SimpleTaskStatus;

import org.gvsig.tools.task.TaskStatusManager;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

        this();

        //Create the explorer and connect

        DataManager dataManager = DALLocator.getDataManager();

        dataManager.createServerExplorerParameters(WCSProvider.NAME);

        explorerParams.setHost((String)dataStoreParameters.getDynValue("uri"));

            (WCSServerExplorer) dataManager.openServerExplorer(WCSProvider.NAME, explorerParams);

        wmsServerExplorer.connect(null);

        wmsServerExplorer.getCoverageList();

        //Set the parameters

        setParameters((WCSDataParameters)dataStoreParameters);

        setExplorer(wmsServerExplorer);

        } catch (ProviderNotRegisteredException e) {

            return null;

        }

        params.setSRS(srs);

        try {

            firstLoad = true;

        }

        enableStopped();

        if(recalcLevel) {

			double pixelSize = viewPort.getEnvelope().getLength(0) / (double)viewPort.getImageWidth();

			zoomLevel = dataStore.getNearestLevel(pixelSize);

            //Rectangle2D.intersect(vpExtent, bBox, extent);

            Extent ex = rManager.getDataStructFactory().createExtent(

                vp.getAdjustedEnvelope().getMinimum(1));

            ViewPortData vpData = rManager.getDataStructFactory().createViewPortData(vp.getProjection(), ex, sz );

            vpData.setMat(vp.getAffineTransform());

            vpData.setDPI((int)vp.getDPI());

            try {

                getParameters().setExtent(bBox);

                getParameters().setWidth(wImg);

            } catch (QueryException e) {

            	throw new RemoteServiceException("Problems drawing this layer: " + e.getMessage(), e);

			} finally {

            }

        } catch (RemoteServiceException e) {

            .getLength(0), env.getLength(1));

    }

    /**

     * Gets the explorer

     * @return

		}

    	return null;

    }

    /**

     * Calcula el contenido del fichero de georreferenciaci?n de una imagen.

     * @param bBox Tama?o y posici?n de la imagen (en coordenadas de usuario)

    public boolean isTiled() {

        return mustTileDraw;

    }

	public boolean isRemote() {

		return true;

	}

        }

        return new DynObjectSetWCSInfo(fInfo, DynObjectSetWCSInfo.TYPE_TEXT);

    }

	@Override

	public String getFileFormat() {

		return "WCS";

        }*/

        return getWCSParameters(getDataStore().getParameters());

    }

    /**

     * Gets <code>WCSDataParameters</code>

     * @param parameters

    	if(parameters instanceof WCSDataParameters) {

			params = (WCSDataParameters) parameters;

		}

		if(parameters instanceof TileDataParameters) {

			DataParameters p = ((TileDataParameters) parameters).getDataParameters();

			if(p instanceof WCSDataParameters) {

    	if(getDataStore() != null)

    		getDataStore().setExplorer(explorer);

    }

    /**

	 * Assigns the flag to delete this layer from the cache

	 * @param selected

        if(params instanceof TileDataParameters) {

			((TileDataParameters)params).deleteCache(deleteCache);

		}

        DataManagerProviderServices dataman = (DataManagerProviderServices) DALLocator.getDataManager();

        try {

            DataStore dStore = dataman.openStore(params.getDataStoreName(), params);

			if(params instanceof WCSDataParameters) {

				this.setName((String)((WCSDataParameters)params).getURI());

			}

			if(params instanceof TileDataParameters) {

				DataParameters p = ((TileDataParameters) params).getDataParameters();

				if(p instanceof WCSDataParameters) {

            throw new InitializeException(e);

        }

    }

	/*@Override

	public void loadFromState(PersistentState state)

	throws PersistenceException {

		String host = state.getString("host");

		getParameters();

		((WCSServerExplorerParameters)explorer.getParameters()).setHost(host);

		if(!explorer.isHostReachable()) {

			loadDataStore = false;

			super.loadFromState(state);

			return;

		}

		try {

			explorer.connect(new CancelTaskImpl());

			explorer.getCoverageList();

			super.loadFromState(state);

			return;

		}

		loadDataStore = true;

		super.loadFromState(state);

		state.set("host", getParameters().getURI());

		state.set("name", getName());

	}*/

	/*public static void registerPersistent() {

		PersistenceManager manager = ToolsLocator.getPersistenceManager();

		DynStruct definition = manager.getDefinition(PERSISTENT_NAME);

					FLyrWCS.class,

					PERSISTENT_NAME,

					PERSISTENT_DESCRIPTION,

					null

			);

			definition.extend(PersistenceManager.PERSISTENCE_NAMESPACE, "FLyrDefault");

		}

		definition.addDynFieldString("host").setMandatory(false);

		definition.addDynFieldString("name").setMandatory(false);

	}*/

	public static void registerPersistent() {

		PersistenceManager manager = ToolsLocator.getPersistenceManager();

		DynStruct definition = manager.getDefinition("FLyrWCS_Persistent");

					FLyrWCS.class,

					"FLyrWCS_Persistent",

					"FLyrWCS Persistent Definition",

					null

			);

			definition.extend(PersistenceManager.PERSISTENCE_NAMESPACE, DefaultFLyrRaster.PERSISTENT_NAME);

		}

*

* 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

* MA  02110-1301, USA.

*/

package org.gvsig.raster.wcs.app.wcsclient.gui.panel;

import java.awt.event.FocusEvent;

import java.awt.event.FocusListener;

import java.awt.geom.Rectangle2D;

import java.lang.reflect.InvocationTargetException;

import java.util.ArrayList;

import java.util.prefs.Preferences;

	private WizardListenerSupport  listenerSupport;

	private JTabbedPane            jTabbedPane        = null;

	private boolean                lastCached         = false;

	public WCSParamsPanel() {

		super();

		initialize();

		listenerSupport.callStateChanged(b);

		callStateChanged(b);

	}

	/**

	 * WCSWizard doesn't have a JCheckBox for selecting with or without cache.

	 * @return

	 * @throws LoadLayerException

	 */

	public FLayer getLayer() throws InitializeException {

		return getLayer(lastCached);

	}

	@SuppressWarnings("unchecked")

		lastCached = cached;

		FLyrWCS layer = new FLyrWCS();

		WCSDataParameters par = (WCSDataParameters)explorer.getStoredParameters();

		DataStoreParameters parameters = par;

		if(cached) {

			DataManager manager = DALLocator.getDataManager();

			TileDataParameters tileParams = null;

			tileParams.setDataParameters(par);

			parameters = tileParams;

		}

		par.setSRS(getSRS());

		par.setFormat(getFormat());

		par.setCoverageName(getLayerPanel().getSelectedCoverageName());

		WCSLayerNode lNode = explorer.getCoverageByName(cName);

		par.setMaxResolution(lNode.getMaxRes());

		par.setOnlineResources(explorer.getOnlineResources());

		try {

			layer.setParameters(parameters);

			layer.setExplorer(explorer);

		}

		return layer;

	}

	/**

	 * of this exception is returned by the server

	 * @param e

	 * @return

				t = ex.getCause();

			} else if(ex instanceof InvocationTargetException) {

				t = ((InvocationTargetException)ex).getTargetException();

			if(t == null)

				return null;

			else

			fireWizardComplete(isCorrectlyConfigured());

		}

	}

	/**

	 * Cleans up the wizard's components but the server's layers list.

	 *

				pString);

	}

	public void setListenerSupport(WizardListenerSupport support) {

		listenerSupport = support;

	}

		}

		return jTabbedPane;

	}

	/**

	 * This method initializes InfoPanel

	 *

		}

		return infoPanel;

	}

	/**

	 * This method initializes TimePanel

	 *

		}

		return timesPanel;

	}

	/**

	 * This method initializes FormatPanel

	 *

		}

		return formatsPanel;

	}

	/**

	 * This method initializes ParameterPanel

	 * @return javax.swing.JPanel

		}

		return parameterPanel;

	}

	/**

	 * This method initializes LayerPanel

	 * @return javax.swing.JPanel

	public void close() {

		// Nothing to do

	}

	public WCSServerExplorer getExplorer() {

		return explorer;

	}

	/**

	 * Returns the extent of the currently selected coverage for the currently

	 * selected SRS.

		}

		return null;

	}

	/**

	 * Returns the name of the selected coverage.

	 *

	public String getLayerName() {

		return getLayerPanel().getTxtName().getText();

	}

	/**

	 * Returns the selected CRS.

	 *

		if (getTimePanel().timeRequired() && getTimePanel().getTime()==null) {

			return false;

		}

		/*if (getParameterPanel().getCmbParam().getSelectedItem()!=null){

			if (parameterType == SINGLE_VALUE && getParameterPanel().getParameterString()==null) {

				return false;

			if (parameterType == INTERVAL) {

			}

		}*/

		if (getSRS() == null) {

			return false;

		}

		if (getFormat() == null) {

			return false;

		}

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

    <description>WCS client</description>

    <inceptionYear>2011</inceptionYear>

    <parent>

        <groupId>org.gvsig</groupId>

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

    </parent>

        <properties>

            <!-- El plugin versions:use-latest-versions falla con scope import -->

            <!-- asi que toca usar el versions:update-properties que si que funciona -->

        </properties>

    <repositories>

        <repository>

            <id>gvsig-public-http-repository</id>

            </snapshots>

        </repository>

    </repositories>

    <scm>

        <connection>scm:svn:https://devel.gvsig.org/svn/gvsig-raster/org.gvsig.raster.wcs/trunk/org.gvsig.raster.wcs</connection>

        <developerConnection>scm:svn:https://devel.gvsig.org/svn/gvsig-raster/org.gvsig.raster.wcs/trunk/org.gvsig.raster.wcs</developerConnection>

        <url>https://devel.gvsig.org/redmine/projects/gvsig-raster/repository/show/org.gvsig.raster.wcs/trunk/org.gvsig.raster.wcs</url>

    </scm>

    <build>

        <plugins>

            <plugin>

            </plugin>

        </plugins>

    </build>

    <dependencyManagement>

        <dependencies>

                        <dependency>

        </dependencies>

    </dependencyManagement>

    <modules>

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

        <module>org.gvsig.raster.wcs.io</module>

        <module>org.gvsig.raster.wcs.app.wcsclient</module>

    </modules>

</project>