Changeset 1390 for trunk/autoquest-httpmonitor-test/src/test/java

Timestamp:

02/20/14 16:15:23 (11 years ago)

Author:

pharms

Message:

• added test cases for SOAP message exchange

Location:

trunk/autoquest-httpmonitor-test/src/test/java/de/ugoe/cs/autoquest/httpmonitor

Files:

• AbstractTC.java (modified) (7 diffs)
• HttpMonitorTest.java (modified) (6 diffs)
• HttpMonitoringProxyTest.java (modified) (11 diffs)

trunk/autoquest-httpmonitor-test/src/test/java/de/ugoe/cs/autoquest/httpmonitor/AbstractTC.java

@@ -22 +22 @@
 import java.util.logging.Level;
 
+import org.apache.catalina.Context;
+import org.apache.catalina.startup.Tomcat;
 import org.apache.http.HttpEntity;
 import org.apache.http.HttpResponse;
@@ -30 +32 @@
 import org.apache.http.entity.StringEntity;
 import org.apache.http.impl.client.DefaultHttpClient;
-import org.eclipse.jetty.server.Server;
-import org.eclipse.jetty.servlet.ServletContextHandler;
-import org.eclipse.jetty.servlet.ServletHolder;
 import org.junit.After;
 import org.junit.Before;
@@ -56 +55 @@
      * 
      */
-    protected static final int PORT = 19098;
-    
-    /**
-     * the jetty web server used for receiving messages
-     */
-    private Server dummyServer;
+    protected static final int DUMMY_SERVER_PORT = 19098;
+    
+    /**
+     * 
+     */
+    protected static final int PROXY_PORT = 19099;
+    
+    /**
+     * 
+     */
+    protected static final int MONITOR_PORT = 19100;
     
     /**
@@ -67 +71 @@
      */
     private DummyServlet dummyServlet;
+    
+    /** */
+    private static Tomcat tomcat = new Tomcat();
 
     /**
@@ -74 +81 @@
     public void setUp() throws Exception {
         // setup a simple HTTP server
-        dummyServer = new Server(PORT + 1);
+        dummyServlet = new DummyServlet();
+        
+        /*dummyServer = new Server(DUMMY_SERVER_PORT);
         
         ServletContextHandler root =
-            new ServletContextHandler(dummyServer, "/", ServletContextHandler.SESSIONS);
-
-        dummyServlet = new DummyServlet();
+            new ServletContextHandler(dummyServer, "/dummyServer", ServletContextHandler.SESSIONS);
+
+        
         root.addServlet(new ServletHolder(dummyServlet), "/*");
-        
-        dummyServer.start();
+       
+        dummyServer.start();*/
+        
+        File tomcatDir = new File("target/test/tomcat");
+        File webappRootDir = new File(tomcatDir, "webapp");
+        
+        tomcat = new Tomcat();
+        tomcat.setPort(DUMMY_SERVER_PORT);
+        tomcat.setBaseDir(tomcatDir.getAbsolutePath());
+
+        File warFile = new File(webappRootDir, "dummyService.war");
+        tomcat.addWebapp("/dummyWebapp", warFile.getAbsolutePath());
+        System.out.println("configuring Dummy Service from " + warFile.getAbsolutePath());
+        
+        File servletRootDir = new File(tomcatDir, "servlet");
+        servletRootDir.mkdirs();
+        Context ctx = tomcat.addContext("/", servletRootDir.getAbsolutePath());
+        Tomcat.addServlet(ctx, "dummyServlet", dummyServlet);
+        ctx.addServletMapping("/dummyServlet", "dummyServlet");
+        
+        tomcat.start();
         
         setUpHook();
@@ -103 +131 @@
         tearDownHook();
 
-        if (dummyServer != null) {
+        if (tomcat != null) {
             try {
-                dummyServer.stop();
+                tomcat.stop();
+                tomcat.getServer().await();
+                tomcat.destroy();
             }
             finally {
-                dummyServer = null;
+                tomcat = null;
             }
         }
@@ -133 +163 @@
         
         if ("POST".equals(type)) {
-            httpRequest = new HttpPost("http://localhost:" + PORT + "/");
+            httpRequest = new HttpPost("http://localhost:" + PROXY_PORT + "/dummyServlet");
             HttpEntity entity = new StringEntity(message, ContentType.TEXT_PLAIN);
             ((HttpPost) httpRequest).setEntity(entity);
         }
         else if ("GET".equals(type)) {
-            httpRequest = new HttpGet("http://localhost:" + PORT + "/");
+            httpRequest = new HttpGet("http://localhost:" + PROXY_PORT + "/dummyServlet");
         }
         
         try {
             HttpResponse response = httpclient.execute(httpRequest);
+            System.err.println(response.getStatusLine());
             String responseStr = readStreamContentToString(response.getEntity().getContent());
-            System.err.println("received response: " + message);
+            System.err.println("received response: " + responseStr);
             return responseStr;
         }

trunk/autoquest-httpmonitor-test/src/test/java/de/ugoe/cs/autoquest/httpmonitor/HttpMonitorTest.java

@@ -94 +94 @@
     @Test
     public void test_SimulatedSession_MonitorOnly() throws Exception {
-        monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, PORT +"" });
+        monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, MONITOR_PORT + "" });
 
         monitor.init();
@@ -155 +155 @@
     @Test
     public void test_SimpleText_ProxyAndMonitor() throws Exception {
-        monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, (PORT + 2) + "" });
+        monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, MONITOR_PORT + "" });
 
         monitor.init();
@@ -161 +161 @@
 
         proxy = new HttpMonitoringProxy
-            (new String[] { LOG_FILE_DIR, PORT +"",
-                            "localhost:" + (PORT + 1), "localhost:" + (PORT + 2) });
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "",
+                            "localhost:" + DUMMY_SERVER_PORT, "localhost:" + MONITOR_PORT });
 
         proxy.init();
@@ -216 +216 @@
     @Test
     public void test_XMLMessage_ProxyAndMonitor() throws Exception {
-        monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, (PORT + 2) + "" });
+        monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, MONITOR_PORT + "" });
 
         monitor.init();
@@ -222 +222 @@
 
         proxy = new HttpMonitoringProxy
-            (new String[] { LOG_FILE_DIR, PORT +"",
-                            "localhost:" + (PORT + 1), "localhost:" + (PORT + 2) });
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "",
+                            "localhost:" + DUMMY_SERVER_PORT, "localhost:" + MONITOR_PORT });
 
         proxy.init();
@@ -315 +315 @@
         
         for (HttpExchange exchange : exchanges) {
-            HttpPost httpRequest = new HttpPost("http://localhost:" + PORT + "/");
+            HttpPost httpRequest = new HttpPost("http://localhost:" + MONITOR_PORT + "/");
             
             JAXBContext jaxbContext =

trunk/autoquest-httpmonitor-test/src/test/java/de/ugoe/cs/autoquest/httpmonitor/HttpMonitoringProxyTest.java

@@ -20 +20 @@
 import java.io.IOException;
 import java.io.StringReader;
+import java.net.URL;
 import java.util.Collection;
 import java.util.Iterator;
@@ -32 +33 @@
 import javax.xml.bind.JAXBElement;
 import javax.xml.bind.Unmarshaller;
+import javax.xml.namespace.QName;
 
 import org.eclipse.jetty.server.Server;
@@ -37 +39 @@
 import org.eclipse.jetty.servlet.ServletHolder;
 import org.junit.Test;
+
+import dummyservice.ObjectFactory;
+import dummyservice.VerifyUserInMsgType;
+import dummyservice.VerifyUserOutMsgType;
 
 import de.ugoe.cs.autoquest.eventcore.Event;
@@ -45 +51 @@
 import de.ugoe.cs.autoquest.plugin.http.eventcore.HTTPEventType;
 import de.ugoe.cs.autoquest.plugin.http.eventcore.HTTPTarget;
+import dummyservice.DummyService;
+import dummyservice.DummyServicePortType;
 
 /**
@@ -73 +81 @@
         messages = new LinkedList<String>();
         
-        dummyMonitor = new Server(PORT + 2);
+        dummyMonitor = new Server(MONITOR_PORT);
         ServletContextHandler root =
             new ServletContextHandler(dummyMonitor, "/", ServletContextHandler.SESSIONS);
@@ -113 +121 @@
     public void test_SimpleText_Local() throws Exception {
         proxy = new HttpMonitoringProxy
-            (new String[] { LOG_FILE_DIR, PORT +"", "localhost:" + (PORT + 1), "local" });
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "", "localhost:" + DUMMY_SERVER_PORT,
+                            "local" });
 
         proxy.init();
@@ -155 +164 @@
     public void test_SimpleText_Remote() throws Exception {
         proxy = new HttpMonitoringProxy
-            (new String[] { LOG_FILE_DIR, PORT +"",
-                            "localhost:" + (PORT + 1), "localhost:" + (PORT + 2) });
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "",
+                            "localhost:" + DUMMY_SERVER_PORT, "localhost:" + MONITOR_PORT });
 
         proxy.init();
@@ -190 +199 @@
     public void test_XMLMessage_Local() throws Exception {
         proxy = new HttpMonitoringProxy
-            (new String[] { LOG_FILE_DIR, PORT +"", "localhost:" + (PORT + 1), "local" });
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "", "localhost:" + DUMMY_SERVER_PORT,
+                            "local" });
 
         proxy.init();
@@ -265 +275 @@
     public void test_XMLMessage_Remote() throws Exception {
         proxy = new HttpMonitoringProxy
-            (new String[] { LOG_FILE_DIR, PORT +"",
-                            "localhost:" + (PORT + 1), "localhost:" + (PORT + 2) });
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "",
+                            "localhost:" + DUMMY_SERVER_PORT, "localhost:" + MONITOR_PORT });
 
         proxy.init();
@@ -330 +340 @@
     }
     
+    @Test
+    public void test_SOAP_Local() throws Exception {
+        proxy = new HttpMonitoringProxy
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "", "localhost:" + DUMMY_SERVER_PORT,
+                            "local" });
+
+        proxy.init();
+        proxy.start();
+
+        DummyService service = new DummyService
+            (new URL("http://localhost:" + PROXY_PORT + "/dummyWebapp/DummyServiceSOAPPort?wsdl"),
+             new QName("DummyService", "DummyService"));
+
+        DummyServicePortType dummyService = service.getDummyServiceSOAPPort();
+        
+        ObjectFactory factory = new ObjectFactory();
+        VerifyUserInMsgType request = factory.createVerifyUserInMsgType();
+        VerifyUserOutMsgType response = dummyService.verifyUser(request);
+
+        assertNotNull(response);
+        
+        proxy.stop();
+        proxy = null;
+
+        File logFile = new File(LOG_FILE_DIR + File.separator + "httpmonitor_000.log");
+        
+        assertTrue(logFile.exists());
+        
+        HTTPLogParser parser = new HTTPLogParser();
+
+        parser.parseFile(logFile);
+
+        // check the sequences
+        Collection<List<Event>> sequences = parser.getSequences();
+
+        assertNotNull(sequences);
+
+        Iterator<List<Event>> iterator = sequences.iterator();
+        assertTrue(iterator.hasNext());
+
+        List<Event> sequence = iterator.next();
+        assertFalse(iterator.hasNext());
+
+        assertNotNull(sequence);
+        assertEquals(2, sequence.size());
+
+        assertEvent(sequence.get(0), "GET", null, null); // get WSDL
+        assertEvent(sequence.get(1), "POST", null, null); // send request
+    }
+    
+    @SuppressWarnings("unchecked")
+    @Test
+    public void test_SOAP_Remote() throws Exception {
+        proxy = new HttpMonitoringProxy
+            (new String[] { LOG_FILE_DIR, PROXY_PORT + "", "localhost:" + DUMMY_SERVER_PORT,
+                            "localhost:" + MONITOR_PORT  });
+
+        proxy.init();
+        proxy.start();
+
+        DummyService service = new DummyService
+            (new URL("http://localhost:" + PROXY_PORT + "/dummyWebapp/DummyServiceSOAPPort?wsdl"),
+             new QName("DummyService", "DummyService"));
+
+        DummyServicePortType dummyService = service.getDummyServiceSOAPPort();
+        
+        ObjectFactory factory = new ObjectFactory();
+        VerifyUserInMsgType request = factory.createVerifyUserInMsgType();
+        VerifyUserOutMsgType response = dummyService.verifyUser(request);
+
+        assertNotNull(response);
+        
+        proxy.stop();
+        proxy = null;
+
+        // give the proxy some time to send the copy of the message
+        while(messages.size() < 1) {
+            Thread.sleep(1000);
+        }
+        
+        assertEquals(2, messages.size());
+        
+        JAXBContext jaxbContext = JAXBContext.newInstance(HttpExchange.class.getPackage().getName());
+        Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
+        
+        JAXBElement<HttpExchange> jaxObject =
+            (JAXBElement<HttpExchange>) unmarshaller.unmarshal(new StringReader(messages.get(0)));
+        
+        HttpExchange exchange = jaxObject.getValue();
+        
+        assertEquals(Method.GET, exchange.getRequest().getMethod());
+
+        assertNull(exchange.getRequest().getContent());
+        assertNotNull(exchange.getResponse().getContent().getData());
+
+        jaxObject =
+            (JAXBElement<HttpExchange>) unmarshaller.unmarshal(new StringReader(messages.get(1)));
+            
+        exchange = jaxObject.getValue();
+            
+        assertEquals(Method.POST, exchange.getRequest().getMethod());
+
+        assertNotNull(exchange.getRequest().getContent().getData());
+        assertNotNull(exchange.getResponse().getContent().getData());
+    }
+    
     /**
      *
@@ -344 +460 @@
         
         assertEquals(Method.fromValue(method), exchange.getRequest().getMethod());
-        assertEquals(message, exchange.getRequest().getContent().getData());
-        assertEquals(response, exchange.getResponse().getContent().getData());
+        
+        if (message != null) {
+            assertEquals(message, exchange.getRequest().getContent().getData());
+        }
+        else if (exchange.getRequest().getContent() != null) {
+            System.err.println(exchange.getRequest().getContent().getData());
+        }
+        
+        if (response != null) {
+            assertEquals(response, exchange.getResponse().getContent().getData());
+        }
+        else if (exchange.getResponse().getContent() != null) {
+            System.err.println(exchange.getResponse().getContent().getData());
+        }
     }