summaryrefslogtreecommitdiff
path: root/mocca-1.2.11/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'mocca-1.2.11/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java')
-rw-r--r--mocca-1.2.11/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java178
1 files changed, 0 insertions, 178 deletions
diff --git a/mocca-1.2.11/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java b/mocca-1.2.11/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java
deleted file mode 100644
index 6e48e6fa..00000000
--- a/mocca-1.2.11/bkucommon/src/test/java/at/gv/egiz/bku/binding/DataUrlConnectionTest.java
+++ /dev/null
@@ -1,178 +0,0 @@
-/*
-* 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.conf.Configuration;
-import at.gv.egiz.bku.conf.DummyConfiguration;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.net.InetSocketAddress;
-import java.net.URL;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.Iterator;
-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.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-
-import com.sun.net.httpserver.Headers;
-import com.sun.net.httpserver.HttpExchange;
-import com.sun.net.httpserver.HttpHandler;
-import com.sun.net.httpserver.HttpServer;
-
-/**
- *
- * @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(), new DummyConfiguration());
- bindingProcessor = (HTTPBindingProcessor) manager.createBindingProcessor(
- "http://www.iaik.at", 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());
- }
- }
-}