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

Timestamp:

07/08/15 09:03:46 (9 years ago)

Author:

pharms

Message:

• added ordering id for requests and responses

File:

• trunk/autoquest-httpmonitor-test/src/test/java/de/ugoe/cs/autoquest/httpmonitor/HttpMonitorTest.java (modified) (5 diffs)

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

@@ -32 +32 @@
 
 import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.methods.HttpGet;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.entity.ContentType;
@@ -102 +104 @@
      */
     @Test
+    public void test_RetrievalOfId_MonitorOnly() throws Exception {
+        monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, MONITOR_PORT + "" });
+
+        monitor.init();
+        monitor.start();
+        
+        long id = getId();
+        assertTrue(id > 0);
+        
+        for (int i = 0; i < 300; i++) {
+            long prevId = id;
+            id = getId();
+            assertTrue(id > prevId);
+        }
+        
+        monitor.stop();
+        monitor = null;
+    }
+    
+    /**
+     *
+     */
+    @Test
     public void test_SimulatedSession_MonitorOnly() throws Exception {
         monitor = new HttpMonitor(new String[] { LOG_FILE_DIR, MONITOR_PORT + "" });
@@ -138 +163 @@
         System.out.println("{");
         System.out.println("  {");
+        long prevId = 0;
+        
         for (int j = 0; j < sequence.size(); j++) {
             System.out.print("    ");
@@ -150 +177 @@
             assertTrue(sequence.get(j).getTarget() instanceof HTTPTarget);
 
+            HTTPEventType eventType = (HTTPEventType) sequence.get(j).getType();
+            
             HTTPTestUtils.assertExchangeEquals
-                (simulatedSession.getHttpExchange().get(j),
-                 ((HTTPEventType) sequence.get(j).getType()).getExchange());
+                (simulatedSession.getHttpExchange().get(j), eventType.getExchange());
 
             assertEquals(HTTPUtils.toString(simulatedSession.getHttpExchange().get(j).getReceiver()),
                          ((HTTPTarget) sequence.get(j).getTarget()).getStringIdentifier());
+            
+            assertNotNull(eventType.getExchange().getRequest().getOrderingId());
+            assertTrue(prevId < eventType.getExchange().getRequest().getOrderingId());
+            prevId = eventType.getExchange().getRequest().getOrderingId();
+            
+            assertNotNull(eventType.getExchange().getResponse().getOrderingId());
+            assertTrue(prevId < eventType.getExchange().getResponse().getOrderingId());
+            prevId = eventType.getExchange().getResponse().getOrderingId();
         }
         System.out.println("  }");
@@ -510 +546 @@
     }
 
+    /**
+     *
+     */
+    private long getId() throws Exception {
+        DefaultHttpClient httpclient = new DefaultHttpClient();
+        
+        HttpGet httpRequest = new HttpGet("http://localhost:" + MONITOR_PORT + "/");
+            
+        try {
+            HttpResponse response = httpclient.execute(httpRequest);
+            return Long.parseLong(response.getFirstHeader("X-AutoQUEST-OrderingId").getValue());
+        }
+        finally {
+            httpRequest.releaseConnection();
+        }
+    }
+
 }