Removing HTTP and UDP servers

3 files changed, 0 insertions, 274 deletions

diff --git a/src/main/java/com/c2kernel/process/ItemHTTPBridge.java b/src/main/java/com/c2kernel/process/ItemHTTPBridge.java
deleted file mode 100644
index 8db52f9..0000000
--- a/src/main/java/com/c2kernel/process/ItemHTTPBridge.java
+++ /dev/null
@@ -1,60 +0,0 @@
-package com.c2kernel.process;

-

-import java.util.StringTokenizer;

-

-import com.c2kernel.common.ObjectNotFoundException;

-import com.c2kernel.entity.C2KLocalObject;

-import com.c2kernel.lookup.DomainPath;

-import com.c2kernel.lookup.InvalidItemPathException;

-import com.c2kernel.lookup.ItemPath;

-import com.c2kernel.utils.server.HTTPRequestHandler;

-

-/* QueryData over HTTP Socket Handler

- * Processes an HTTP request consisting of /<path to item>/<path to kernel object>

- * and returns that kernel object as XML

- * Currently supports GET requests.

- * REVISIT: POST calls Item.request()

- */

-

-public class ItemHTTPBridge extends HTTPRequestHandler {

-

-    public ItemHTTPBridge() { }

-

-    @Override

-	public String getName() {

-        return "Item HTTP Server";

-    }

-

-    @Override

-	public String processRequest() {

-    	System.out.println("ItemHTTPBridge::ProcessRequest()");

-        StringTokenizer tok = new StringTokenizer(resource, "?");

-        String path = tok.nextToken();

-        String query = tok.nextToken();

-        ItemPath itemPath;

-        try {

-        	itemPath = new ItemPath(path);

-        } catch (InvalidItemPathException ex) {

-        	DomainPath domPath = new DomainPath(path);

-        	if (!domPath.exists())

-        		return error("404 Not Found", "The path "+path+" you requested was not found.");

-        	try {

-				itemPath = domPath.getItemPath();

-			} catch (ObjectNotFoundException e) {

-				return error("404 Not Found", "The path "+path+" you requested was not found.");

-			}

-        }

-

-        if (method.equals("GET")) {

-            try {

-                C2KLocalObject response = Gateway.getStorage().get(itemPath, query, null);

-                return Gateway.getMarshaller().marshall(response);

-            }

-            catch (Exception e) {

-                return error("400 Bad Request", "Usage: GET &lt;path to item&gt;?&lt;path to kernel object&gt;<br>"+e.getClass().getName());

-            }

-        }

-        return(super.processRequest());

-    }

-

-}

diff --git a/src/main/java/com/c2kernel/utils/server/HTTPRequestHandler.java b/src/main/java/com/c2kernel/utils/server/HTTPRequestHandler.java
deleted file mode 100644
index 886ae9f..0000000
--- a/src/main/java/com/c2kernel/utils/server/HTTPRequestHandler.java
+++ /dev/null
@@ -1,160 +0,0 @@
-package com.c2kernel.utils.server;

-

-import java.io.BufferedReader;

-import java.io.IOException;

-import java.io.InputStreamReader;

-import java.io.OutputStream;

-import java.net.Socket;

-import java.util.Date;

-import java.util.HashMap;

-import java.util.NoSuchElementException;

-import java.util.StringTokenizer;

-

-import com.c2kernel.utils.Logger;

-

-public class HTTPRequestHandler implements SocketHandler {

-

-    protected HashMap<String, String> headers = new HashMap<String, String>();

-    protected String method;

-    protected String resource;

-    protected String version;

-    protected String returnMIME;

-    protected String statusCode;

-    protected String postData;

-    protected final static String CRLF = "\r\n";

-    protected BufferedReader request;

-    protected Socket currentSocket = null;

-

-    public HTTPRequestHandler() { }

-

-    @Override

-	public String getName() {

-        return "HTTP Server";

-    }

-

-    @Override

-	public boolean isBusy() {

-        return (currentSocket!=null);

-    }

-

-    @Override

-	public void setSocket(Socket newSocket) {

-        currentSocket = newSocket;

-    }

-

-    @Override

-	public void shutdown() {

-        try {

-            if (currentSocket != null) currentSocket.close();

-        } catch (IOException e) {

-            Logger.error("Error shutting down HTTP connection");

-        }

-        currentSocket = null;

-    }

-

-    @Override

-	public void run() {

-        Thread.currentThread().setName("HTTP Request Handler");

-        try {

-            request = new BufferedReader(new InputStreamReader(currentSocket.getInputStream()));

-            // parse the request

-            boolean firstLine = true;

-            String headerLine;

-            do {

-                headerLine = request.readLine();

-                if (headerLine == null)

-                    throw new IOException("Disconnected");

-                if (firstLine) { // request line

-                    StringTokenizer params = new StringTokenizer(headerLine);

-                    try {

-                        method = params.nextToken();

-                        resource = params.nextToken();

-                        version = params.nextToken();

-                    } catch (NoSuchElementException ex1) { } // incomplete request line - doesn't matter

-                    firstLine = false;

-                }

-                else { // headers

-                    int split = headerLine.indexOf(": ");

-                    if (split >= 0)

-                        headers.put(

-                            headerLine.substring(0, split),

-                            headerLine.substring(split+2)

-                            );

-                }

-            } while (!headerLine.equals(CRLF) && !headerLine.equals(""));

-

-            String response = null;

-

-            try {

-

-                if (headers.containsKey("Content-length")) { // read POST data

-                    StringBuffer postBuffer = new StringBuffer();

-                    int received = 0; int length = Integer.parseInt(headers.get("Content-length"));

-                    try {

-                        while (received < length) {

-                            String postLine = request.readLine();

-                            postBuffer.append(postLine);

-                            received+=postLine.length();

-                        }

-                    } catch (IOException ex) {

-                        Logger.error("Error reading post data. "+received+" bytes of "+length+" received. ("+(received*100.0/length)+"%");

-                        Logger.error(ex);

-                        throw ex;

-                    }

-                }

-                // Got the params, generate response

-

-                returnMIME = "text/xml";

-                statusCode = "200 OK";

-

-                response = processRequest();

-            } catch (Exception ex3) {

-                response = error("500 Server Error", ex3.getClass().getName()+"<br>"+ex3.getMessage());

-            }

-            System.out.println(new Date().toString()+" "+currentSocket.getInetAddress()+" "+method+" "+resource+" "+statusCode);

-

-            OutputStream output = currentSocket.getOutputStream();

-

-            statusCode = "HTTP/1.0 "+statusCode+CRLF;

-            output.write(statusCode.getBytes());

-

-            returnMIME = "Content-type: "+returnMIME+CRLF;

-            output.write(returnMIME.getBytes());

-

-            String contentLength = "Content-Length: "+response.length()+CRLF;

-            output.write(contentLength.getBytes());

-

-            // Possible: last mod?

-            // end of headers

-            output.write(CRLF.getBytes());

-

-            // write the content

-            output.write(response.getBytes());

-            request.close();

-            output.close();

-            currentSocket.close();

-        } catch (IOException ex2) {

-            Logger.error(ex2);

-        } // aborted connection probably

-        currentSocket = null;

-    }

-

-    /* This is a dummy method that doesn't support anything.

-     * Override it.

-     */

-

-    public String processRequest() {

-        return error("501 Not Implemented", "The method "+method+" you have requested is not supported by this server.");

-    }

-

-    public String error(String code, String desc) {

-        statusCode = code;

-        returnMIME = "text/html";

-        return ("<HTML>" +

-            "<HEAD><TITLE>"+code+"</TITLE></HEAD>" +

-            "<BODY><h1>"+code+"</h1>" +

-            "<p>"+desc+

-            "<hr><p><small>Cristal Item HTTP server</small></BODY></HTML>");

-    }

-}

-

diff --git a/src/main/java/com/c2kernel/utils/server/UDPListener.java b/src/main/java/com/c2kernel/utils/server/UDPListener.java
deleted file mode 100644
index 3b1fc9d..0000000
--- a/src/main/java/com/c2kernel/utils/server/UDPListener.java
+++ /dev/null
@@ -1,54 +0,0 @@
-package com.c2kernel.utils.server;

-

-import java.io.IOException;

-import java.io.InterruptedIOException;

-import java.net.DatagramPacket;

-import java.net.DatagramSocket;

-

-import com.c2kernel.common.InvalidDataException;

-import com.c2kernel.utils.Logger;

-

-/**************************************************************************

- *

- * $Revision: 1.2 $

- * $Date: 2004/02/06 14:50:43 $

- *

- * Copyright (C) 2003 CERN - European Organization for Nuclear Research

- * All rights reserved.

- **************************************************************************/

-

-public abstract class UDPListener extends Thread {

-

-   private boolean active = true;

-   protected DatagramSocket socket;

-

-    public UDPListener() {

-        super();

-    }

-

-    @Override

-	public void run() {

-        Thread.currentThread().setName("UDP Server");

-        byte[] buffer = new byte[255];

-        DatagramPacket newPacket = new DatagramPacket(buffer, buffer.length);

-        while (active) {

-            try {

-                socket.receive(newPacket);

-                processPacket(newPacket);

-            } catch (InterruptedIOException e) { // ignore timeout

-            } catch (IOException e) {

-                Logger.error("Error receiving proxy packet:");

-                Logger.error(e);

-            } catch (InvalidDataException e) {

-                Logger.error(e);

-            }

-        }

-        socket.close();

-    }

-

-    protected abstract void processPacket(DatagramPacket packet) throws InvalidDataException;

-

-    public void shutdown() {

-        active = false;

-    }

-}