1 files changed, 186 insertions, 0 deletions
diff --git a/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java b/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java
new file mode 100644
index 00000000..d9995fdd
--- /dev/null
+++ b/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java
@@ -0,0 +1,186 @@
+/*
+* Copyright 2008 Federal Chancellery Austria and
+* Graz University of Technology
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+/*
+ * To change this template, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package at.gv.egiz.bku.binding;
+
+import at.gv.egiz.bku.slcommands.SLCommandFactory;
+import at.gv.egiz.bku.slcommands.SLResult;
+
+import com.sun.net.httpserver.Headers;
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import com.sun.net.httpserver.HttpServer;
+import java.io.BufferedReader;
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.net.InetSocketAddress;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.junit.After;
+import static org.junit.Assert.*;
+
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+/**
+ * 
+ * @author clemens
+ */
+public class DataUrlConnectionTest {
+
+  public static final String REQUEST_RESOURCE = "at/gv/egiz/bku/binding/NOPMultipartDataUrl.txt";
+
+  private static final Log log = LogFactory.getLog(DataUrlConnectionTest.class);
+
+  static HttpServer server;
+  static BindingProcessor bindingProcessor;
+  static BindingProcessorManager manager;
+
+  protected InputStream requestStream;
+
+  @BeforeClass
+  public static void setUpHTTPServer() throws IOException {
+    log.debug("setting up HTTPServer");
+    InetSocketAddress addr = new InetSocketAddress("localhost", 8081);
+    server = HttpServer.create(addr, 0);
+    server.createContext("/", new DataUrlHandler());
+    server.start();
+
+    log.debug("setting up HTTPBindingProcessor");
+    manager = new BindingProcessorManagerImpl(new DummyStalFactory(),
+        new SLCommandInvokerImpl());
+    bindingProcessor = (HTTPBindingProcessor) manager.createBindingProcessor(
+        "http", null);
+    Map<String, String> headers = new HashMap<String, String>();
+    headers.put("Content-Type", InputDecoderFactory.MULTIPART_FORMDATA
+        + ";boundary=---------------------------2330864292941");
+    ((HTTPBindingProcessor) bindingProcessor).setHTTPHeaders(headers);
+  }
+
+  @Before
+  public void setUp() {
+    requestStream = getClass().getClassLoader().getResourceAsStream(
+        REQUEST_RESOURCE);
+  }
+
+  @AfterClass
+  public static void stopServer() {
+    if (server != null) {
+      log.debug("stopping HTTPServer");
+      server.stop(0);
+    }
+  }
+
+  @Test
+  public void testBasicNop() {
+    bindingProcessor.consumeRequestStream(requestStream);
+    // manager.process(bindingProcessor);
+    bindingProcessor.run();
+  }
+
+//  @Test
+  public void openConnectionTest() throws Exception {
+
+    URL dataUrl = new URL("http://localhost:8081/");
+
+    log.debug("creating DataUrlConnection " + dataUrl.toString());
+    DataUrlConnectionImpl c = new DataUrlConnectionImpl();
+    c.init(dataUrl);
+
+    c.setHTTPHeader("httpHeader_1", "001");
+    ByteArrayInputStream bais = new ByteArrayInputStream("Hello, world!"
+        .getBytes());
+    c.setHTTPFormParameter("formParam_1", bais, "text/plain", "UTF-8", null);
+
+    log.debug("open dataUrl connection");
+    c.connect();
+    //TODO mock SLResult and c.transmit(result);
+  }
+
+  static class DataUrlHandler implements HttpHandler {
+
+    public DataUrlHandler() {
+      log.debug("setting up DataUrlHandler");
+    }
+
+    @Override
+    public void handle(HttpExchange exchange) throws IOException {
+      log.debug("handling incoming request");
+      logHTTPHeaders(exchange.getRequestHeaders());
+      logRequest(exchange.getRequestBody());
+
+      log.debug("sending dummy response");
+      exchange.getResponseHeaders().add("Content-type", "text/html");
+      String response = "<b>" + new Date() + "</b> for "
+          + exchange.getRequestURI();
+      exchange.sendResponseHeaders(200, response.length());
+
+      OutputStream os = exchange.getResponseBody();
+      os.write(response.getBytes());
+      os.close();
+    }
+
+    private void logRequest(InputStream in) throws IOException {
+      StringBuilder reqLogMsg = new StringBuilder("HTTP request: \n");
+      int c = 0;
+      while ((c = in.read()) != -1) {
+        reqLogMsg.append((char) c);
+      }
+      log.debug(reqLogMsg.toString());
+      in.close();
+    }
+
+    private void logHTTPHeaders(Headers headers) {
+      StringBuilder headersLogMsg = new StringBuilder("HTTP headers: \n");
+      Set<String> keys = headers.keySet();
+      Iterator<String> keysIt = keys.iterator();
+      while (keysIt.hasNext()) {
+        String key = keysIt.next();
+        List<String> values = headers.get(key);
+        Iterator<String> valuesIt = values.iterator();
+        headersLogMsg.append(' ');
+        headersLogMsg.append(key);
+        headersLogMsg.append(": ");
+        while (valuesIt.hasNext()) {
+          headersLogMsg.append(valuesIt.next());
+          headersLogMsg.append(' ');
+        }
+        headersLogMsg.append('\n');
+      }
+      log.debug(headersLogMsg.toString());
+    }
+  }
+}