Application: gvSIG desktop

/**

 * <p> Abstract class that represents handlers to comunicate via WMS protocol.

 * </p>

 */

public abstract class WMSProtocolHandler {

	/**

    /**

     * port number of the comunication channel of the WMS to connect

     */

    /**

     * WMS metadata

     */

    public TreeMap layers;

    public WMSLayer rootLayer;

//    public Vector srs;

    /**

     * It will be mostly the WMS Capabilities, but the implementation

     * will be placed in the handler implementing certain version of the protocol.

     */

    public abstract void parse(File f) ;

    /**

     * returns the alfanumeric information of the layers at the specified point.

     * the diference between the other getfeatureInfo method is that this will

     * be implemented by each specific version because the XML from the server will be

     * parsed and presented by a well known structure.

    	return name;

    	return version;

        return serviceInfo;

    public String getHost ()

    {

    	return host;

    {

    	port = _port;

    }

    /**

	 * <p>Builds a GetCapabilities request that is sent to the WMS

	 * the response will be parse to extract the data needed by the

	 * @param override, if true the previous downloaded data will be overridden

	 */

    public void getCapabilities(WMSStatus status, boolean override, ICancellable cancel)

    	URL request = null;

		try

		{

		}

		try

		{

				Utilities.removeURL(request);

			File f = Utilities.downloadFile(request,"wms_capabilities.xml", cancel);

			if (f == null)

     */

    public String getFeatureInfo(WMSStatus status, int x, int y, int featureCount, ICancellable cancel)

    {

    	URL request = null;

    	StringBuffer output = new StringBuffer();

    	String outputFormat = new String();

    	StringBuffer sb = new StringBuffer();

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

		try

	    	File f = Utilities.downloadFile(request,"wms_feature_info.xml", cancel);

			if (f == null)

				return "";

//	    	outputFormat = request.openConnection().getContentType();

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

//	    	{

//	    		String str = new String(buffer,0,i);

//	    	}

//	    	is.close();

			FileReader fReader = new FileReader(f);

			char[] buffer = new char[1024*256];

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

		    {

		    	String str = new String(buffer,0,i);

		    }

		    if ( (outputFormat == null) || (outputFormat.indexOf("xml") != -1)

		    		||output.toString().toLowerCase().startsWith("<?xml")

		    {

		    	int tag;

		    	KXmlParser kxmlParser = null;

		    	kxmlParser.setInput(new FileReader(f));

		    	if (kxmlParser.getName().compareTo(ServiceException)==0)

				{

		    		sb.append("<INFO>").append(parseException( output.toString().getBytes())).append("</INFO>");

				}

				else if (kxmlParser.getName().compareToIgnoreCase("ERROR")==0)

				{

					return output.toString();

				}

				{

				}

// 				 while(tag != KXmlParser.END_DOCUMENT)

//				 {

//					 switch(tag)

//					 {

//							if (kxmlParser.getName().compareTo(ServiceException)==0)

//							{

//					    		sb.append("<INFO>").append(parseException( output.toString().getBytes())).append("</INFO>");

//							}

//							else if (kxmlParser.getName().compareToIgnoreCase("ERROR")==0)

//								return output.toString();

//							break;

//							sb.append("</" + kxmlParser.getName() + ">\n");

//							break;

//						case KXmlParser.TEXT:

//						break;

//					 }

//    				 tag = kxmlParser.next();

	    		//return sb.toString();

	    	}

	    	else

     * <p>Builds a GetMap request that is sent to the WMS

     * the response (image) will be redirect to the

     * WMS client</p>

    public byte[] _getMap(WMSStatus status) throws ServerErrorException, WMSException

    	URL request = null;

		try

		{

			URLConnection conn = request.openConnection();

			System.out.println(request.toString());

            String type = conn.getContentType();

	    	byte[] imageBytes = null;

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

            InputStream is = conn.getInputStream();

	    	int readed = 0;

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

                // Creates a new buffer to contain the previous readed bytes and the next bunch of bytes

	    		byte[] buffered = new byte[readed+i];

	    			}

				}

	    		imageBytes = (byte[]) buffered.clone();

	    	}

	    		||(Utilities.isTextData(imageBytes)))

               	WMSException wmsEx = null;

            	String exceptionMessage = parseException(imageBytes);

                if (exceptionMessage==null)

                {

            	wmsEx.setWMSMessage(new String(imageBytes));

                throw wmsEx;

            }

		}

		catch(IOException e)

		{

			e.printStackTrace();

            throw new ServerErrorException();

		}

    public File getLegendGraphic(WMSStatus status, String layerName, ICancellable cancel) throws ServerErrorException, WMSException

    {

    	URL request = null;

		try

		{

			System.out.println(request);

	    	if (f== null)

	    		return null;

            if (Utilities.isTextFile(f)) {

	    		byte[] data = new byte[(int)fc.size()];

	    		ByteBuffer bb = ByteBuffer.wrap(data);

	    		fc.read(bb);

	    		WMSException wmsEx = null;

            	String exceptionMessage = parseException(data);

                if (exceptionMessage==null)

                {

                	{

                		String xml = error.substring(pos,error.length());

                		exceptionMessage = parseException(xml.getBytes());

                    if (exceptionMessage == null)

                    	exceptionMessage = new String(data);

                }

             	wmsEx = new WMSException(exceptionMessage);

            	wmsEx.setWMSMessage(new String(data));

            	Utilities.removeURL(request);

                throw wmsEx;

            }

		}

		catch(IOException e)

		{

			e.printStackTrace();

            throw new ServerErrorException();

		}

    public File getMap(WMSStatus status, ICancellable cancel) throws ServerErrorException, WMSException

    	URL request = null;

		try

		{

			//TODO:

			//pass this buildXXXRequest to the WMSProtocolHandlerXXX: The request can depend on the WMS version.

			request = new URL(buildMapRequest(status));

	    	if (f== null)

	    		return null;

            if (Utilities.isTextFile(f)) {

	    		byte[] data = new byte[(int)fc.size()];   // fc.size returns the size of the file which backs the channel

	    		ByteBuffer bb = ByteBuffer.wrap(data);

	    		fc.read(bb);

	    		WMSException wmsEx = null;

            	String exceptionMessage = parseException(data);

                if (exceptionMessage==null)

                {

                		exceptionMessage = parseException(xml.getBytes());

//                        if (exceptionMessage == null)

//                        	exceptionMessage = new String(data);

                    if (exceptionMessage == null)

                    	exceptionMessage = new String(data);

                }

             	wmsEx = new WMSException(exceptionMessage);

            	wmsEx.setWMSMessage(new String(data));

            	// Since it is an error file, It must be deleted from the cache

            	Utilities.removeURL(request);

                throw wmsEx;

            }

		}

		catch(IOException e)

		{

			e.printStackTrace();

            throw new ServerErrorException();

		}

    /* (non-Javadoc)

     * @see org.gvsig.remoteClient.wms.WMSProtocolHandler#parseException(byte[])

     */

        KXmlParser kxmlParser = new KXmlParser();

        try

        {

            kxmlParser.nextTag();

            int tag;

                tag = kxmlParser.nextTag();

                 while(tag != KXmlParser.END_DOCUMENT)

                 {

                                errors.add(errorCode+errorMessage);

                            }

                            break;

                            break;

                     }

                     tag = kxmlParser.nextTag();

                 }

                 //kxmlParser.require(KXmlParser.END_DOCUMENT, null, null);

            }

        }

            parser_ex.printStackTrace();

        }

        }

        String message = errors.size()>0? "" : null;

        for (int i = 0; i < errors.size(); i++) {

     */

    public static String buildCapabilitiesSuitableVersionRequest(String _host, String _version)

    {

        String symbol = getSymbol(_host);

        if((_version != null) && (_version.length()>0 ))

        {

        	req += ("&VERSION=" + _version);

        }

		req += ("&EXCEPTIONS=XML");

    }

    /**

     * Builds the GetCapabilitiesRequest according to the OGC WMS Specifications

     * @param WMSStatus

    {

		StringBuffer req = new StringBuffer();

		String symbol = null;

		String onlineResource;

		if (status == null || status.getOnlineResource() == null)

			onlineResource = getHost();

			onlineResource = status.getOnlineResource();

		symbol = getSymbol(onlineResource);

		req.append(onlineResource).append(symbol).append("REQUEST=GetCapabilities&SERVICE=WMS&");

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

		return req.toString();

    }

    /**

     * Builds the GetFeatureInfoRequest according to the OGC WMS Specifications

     */

		String onlineResource;

		if (status.getOnlineResource() == null)

			onlineResource = getHost();

			onlineResource = status.getOnlineResource();

		symbol = getSymbol(onlineResource);

		req.append(onlineResource).append(symbol).append("REQUEST=GetFeatureInfo&SERVICE=WMS&");

		req.append("&VERSION=").append(getVersion()).append("&INFO_FORMAT=application/vnd.ogc.gml&");

		req.append(getPartialQuery(status)).append("&x="+x + "&y="+y);

		//this parameter sets the max number of features per layer to be returned.

            req.append("&EXCEPTIONS=XML");

        }

		return req.toString().replaceAll(" ", "%20");

    /**

     * Builds the GetMapRequest according to the OGC WMS Specifications

     */

    private String buildGetLegendGraphicRequest(WMSStatus status, String layerName)

    	//TODO: pass by parameter the legend output format?

		StringBuffer req = new StringBuffer();

		String symbol = null;

		String onlineResource = null;

		if (status.getOnlineResource() == null)

			onlineResource = getHost();

			onlineResource = status.getOnlineResource();

		symbol = getSymbol(onlineResource);

		req.append(onlineResource + symbol + "REQUEST=GetLegendGraphic&SERVICE=WMS&VERSION=").append(getVersion());

        req.append("&LAYER=" + layerName).append("&TRANSPARENT=TRUE").append("&FORMAT=image/png");

		return req.toString().replaceAll(" ", "%20");

     * Builds the GetMapRequest according to the OGC WMS Specifications

     */

    private String buildMapRequest(WMSStatus status)

		StringBuffer req = new StringBuffer();

		String symbol = null;

		String onlineResource = null;

		if (status.getOnlineResource() == null)

			onlineResource = getHost();

			onlineResource = status.getOnlineResource();

		symbol = getSymbol(onlineResource);

		req.append(onlineResource + symbol + "REQUEST=GetMap&SERVICE=WMS&VERSION=").append(getVersion()).append("&");

		req.append(getPartialQuery(status));

//        if (status.getExceptionFormat() != null) {

//        }

		return req.toString().replaceAll(" ", "%20");

    }

    /**

     * Just for not repeat code. Gets the correct separator according to the server URL

     * @param h

     */

    protected static String getSymbol(String h) {

        String symbol;

            symbol = "?";

        else if (h.indexOf("?")!=h.length()-1)

            symbol = "&";

     * @return String request

     */

    public String getPartialQuery(WMSStatus status)

        StringBuffer req = new StringBuffer();

        req.append("LAYERS=" + Utilities.Vector2CS(status.getLayerNames()))

           .append("&SRS=" + status.getSrs())

           .append("&STYLES=");

        Vector v = status.getStyles();

        if (v!=null && v.size()>0)

        v = status.getDimensions();

        if (v!=null && v.size()>0)

            req.append("&" + Utilities.Vector2URLParamString(v));

        return req.toString();

    }

        // your code here

    /**

     * Inner class that represents the description of the WMS metadata.

     * The first part of the capabilities will return the service information

     */

    public class ServiceInformation {

        public String email;

        public Vector formats;

        public HashMap operations; // operations that WMS supports

        public ServiceInformation()

            version = new String();

            name = new String();

            scope = new String();

            phone = new String();

            fax = new String();

            email = new String();

        }

        public boolean isQueryable()

        {

        		return true;

        	else

        		return false;

        public void clear() {

        	version = new String();

            name = new String();

            phone = new String();

            fax = new String();

            email = new String();

        }

 }