/trunk/libraries/libRemoteServices/src/org/gvsig/remoteClient/wms/WMSProtocolHandler.java - Diff - Application: gvSIG desktop - gvSIG

Revision 3377 trunk/libraries/libRemoteServices/src/org/gvsig/remoteClient/wms/WMSProtocolHandler.java

     import java.io.DataOutputStream;
     import java.io.File;
     import java.io.FileOutputStream;
     import java.io.IOException;
     import java.io.InputStream;
     import java.io.OutputStream;
     import java.net.ConnectException;
     import java.net.URL;
     import java.net.UnknownHostException;
     import java.util.TreeMap;
     import java.util.Vector;
     import org.gvsig.remoteClient.utils.Utilities;
     import com.devx.io.TempFileManager;
     /**
      * <p> Abstract class that represents handlers to comunicate via WMS protocol.
      * </p>
-...
     			//TODO:
     			//pass this buildXXXRequest to the WMSProtocolHandlerXXX: The request can depend on the WMS version.
     			request = new URL(buildMapRequest(status));
     	    	byte[] buffer = new byte[1024*256];
     	    	byte[] imageBytes = null;
     	    	InputStream is = request.openStream();
     	    	int readed = 0;
     	    	for (int i = is.read(buffer); i>0; i = is.read(buffer)){
     	    		byte[] buffered = new byte[readed+i];
     	    		for (int j = 0; j < buffered.length; j++) {
     	    			if (j<readed){
     	    				buffered[j] = imageBytes[j];
+    	    			}
     	    			else {
     	    				buffered[j] = buffer[j-readed];
+    	    			}
+    				}
     	    		imageBytes = (byte[]) buffered.clone();
     	    		readed += i;
+    	    	}
     			return imageBytes;
+    		}
     		catch(Exception e)
+    		{
     			// TODO something about the exceptionsssss....!!!
+    		}
         	try
+        	{
         		System.out.println(request.toString());
         		File f = new File("map.jpeg");
         	  DataOutputStream dos = new DataOutputStream(new FileOutputStream(f));
     		  OutputStream bos = null;
     	    	byte[] buffer = new byte[1024*256];
     	    	InputStream is = request.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();
     	    return null;
+        	}
         	catch(Exception e)
+        	{
         		//TODO
         		//Implement the correct logic to handle all the exceptions.
         		return null;
+        	}
     		return null;
+        }
     	/**
-...
+    		}
     		catch(Exception e)
+    		{
     			// TODO something about the exceptionsssss....!!!
     			e.printStackTrace();
+    		}
     	   	File f = null;
     	   	f = new File("tochangethis.txt");
     	    if (!f.exists())
+    	    {
     	    	try
+    	    	{
     		    	DataOutputStream dos = new DataOutputStream( new BufferedOutputStream(new FileOutputStream(f)));
     		    	byte[] buffer = new byte[1024*256];
     		    	InputStream is = request.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(Exception e)
     	    	{}
+    	    }
     //	   	File f = null;
     //	   	f = new File("tochangethis.txt");
     //
     //	    if (!f.exists())
     //	    {
     //	    	try
     //	    	{
     //		    	DataOutputStream dos = new DataOutputStream( new BufferedOutputStream(new FileOutputStream(f)));
     //		    	byte[] buffer = new byte[1024*256];
     //		    	InputStream is = request.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(Exception e)
     //	    	{}
     //	    }
     		try
+    		{
     		File f = downloadFile(request,"wms_capabilities.xml");
     	    parse(f);
     	    //return parse(f);
+    		}
     		catch(Exception e)
+    		{
     			//TODO
     			e.printStackTrace();
+    		}
+        }
     /**
      * <p>It will send a GetFeatureInfo request to the WMS
      * Parsing the response and redirecting the info to the WMS client</p>
      */
         public String getFeatureInfo(WMSStatus status, int x, int y)
         public String getFeatureInfo(WMSStatus status, int x, int y, int featureCount)
+        {
         	URL request = null;
     		try
-...
         private String buildCapabilitiesRequest()
+        {
     		String req = new String();
     		req = req + getHost() + "REQUEST=GetCapabilities&SERVICE=WMS&";
     		String host = getHost();
     		if (!host.endsWith("?"))
     			req = req + getHost() + "?REQUEST=GetCapabilities&SERVICE=WMS&";
     		else
     			req = req + getHost() + "REQUEST=GetCapabilities&SERVICE=WMS&";
     		req = req + "VERSION=" + getVersion();
     		req += ("&EXCEPTIONS=XML");
     		return req;
-...
         private String buildGetFeatureInfoRequest(WMSStatus status, int x, int y)
+        {
     		String req = new String();
     		req = req + getHost() + "REQUEST=GetFeatureInfo&SERVICE=WMS&";
     		if (!host.endsWith("?"))
     			req = req + getHost() + "?REQUEST=GetFeatureInfo&SERVICE=WMS&";
     		else
     			req = req + getHost() + "REQUEST=GetFeatureInfo&SERVICE=WMS&";
     		req = req + "QUERY_LAYERS="+Utilities.Vector2CS(status.getLayerNames());
     		req = req + "&VERSION=" + getVersion() + "&";
     		req = req + getPartialQuery(status);
-...
         private String buildMapRequest(WMSStatus status)
+        {
     		String req = new String();
     		req = req + getHost() + "REQUEST=GetMap&SERVICE=WMS&";
     		if (!host.endsWith("?"))
     			req = req + getHost() + "?REQUEST=GetMap&SERVICE=WMS&";
     		else
     			req = req + getHost() + "REQUEST=GetMap&SERVICE=WMS&";
     		req = req + "VERSION=" + getVersion() + "&";
     		req = req + getPartialQuery(status);
            if (status.getExceptionFormat() != null) {
-...
                 email = new String();
                 formats = new Vector();
+            }
+         }
+         }
         /**
          * Downloads an URL into a temporary file that is removed the next time the
          * tempFileManager class is called, which means the next time gvSIG is launched.
+         *
          * @param url
          * @param name
          * @return
          * @throws IOException
          * @throws ServerErrorResponseException
          * @throws ConnectException
          * @throws UnknownHostException
          */
         private File downloadFile(URL url, String name) throws IOException,ConnectException, UnknownHostException{
         	File f = null;
     	    try{
     	    	f = TempFileManager.createTempFile(name, "tmp");
     	    	System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@\ndownloading '"+url.toString()+"' to: "+f.getAbsolutePath());
     	    	f.deleteOnExit();
     	    } catch (IOException io) {
     	    	io.printStackTrace();
+    	    }
     	    DataOutputStream dos = new DataOutputStream( new BufferedOutputStream(new FileOutputStream(f)));
     	    byte[] buffer = new byte[1024*256];
     	    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();
     	    /*if (!isNotAnException(f))
     	    	// SI que es una excepci?n
     	    	throw new ServerErrorResponseException();*/
     	    return f;
+    	}
+     }

Also available in: Unified diff