Changeset 1417 for trunk/autoquest-plugin-http

Timestamp:

02/28/14 12:23:40 (11 years ago)

Author:

pharms

Message:

• made the plugin a real plugin
• added first extraction of SOAP information
• implemented equals and hash code correctly
• parsed events can now be used to generate task trees

Location:

trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest/plugin/http

Files:

• HTTPLogParser.java (modified) (6 diffs)
• HTTPPlugin.java (added)
• HTTPUtils.java (modified) (1 diff)
• eventcore/HTTPEventType.java (modified) (3 diffs)
• eventcore/HTTPTarget.java (modified) (1 diff)
• eventcore/SOAPEventType.java (added)

trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest/plugin/http/HTTPLogParser.java

@@ -15 +15 @@
 package de.ugoe.cs.autoquest.plugin.http;
 
+import java.io.ByteArrayInputStream;
 import java.io.File;
+import java.io.InputStream;
 import java.util.Collection;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.logging.Level;
 
 import javax.xml.bind.JAXBContext;
@@ -24 +27 @@
 import javax.xml.bind.JAXBException;
 import javax.xml.bind.Unmarshaller;
+import javax.xml.soap.MessageFactory;
+import javax.xml.soap.SOAPMessage;
 import javax.xml.transform.stream.StreamSource;
 
@@ -29 +34 @@
 
 import de.ugoe.cs.autoquest.eventcore.Event;
+import de.ugoe.cs.autoquest.eventcore.IEventType;
+import de.ugoe.cs.autoquest.httpmonitor.exchange.Content;
 import de.ugoe.cs.autoquest.httpmonitor.exchange.HttpExchange;
 import de.ugoe.cs.autoquest.httpmonitor.exchange.Session;
 import de.ugoe.cs.autoquest.plugin.http.eventcore.HTTPEventType;
 import de.ugoe.cs.autoquest.plugin.http.eventcore.HTTPTarget;
+import de.ugoe.cs.autoquest.plugin.http.eventcore.SOAPEventType;
+import de.ugoe.cs.util.console.Console;
 
 /**
  * <p>
  * Parser for HTTP Monitor logs. Uses JAXB for parsing and is therefore quite simple. For each
- * exchange in the log, it creates an appropriate event.
+ * exchange in the log, it creates an appropriate event. It differes between default HTTP events
+ * and SOAP events.
  * </p>
  * 
@@ -50 +60 @@
      */
     private Collection<List<Event>> sequences = new LinkedList<List<Event>>();
+    
+    /**
+     * <p>
+     * the message factory used for parsing SOAP messages
+     * </p>
+     */
+    private MessageFactory soapMessageFactory;
 
     /**
@@ -97 +114 @@
             List<Event> sequence = new LinkedList<Event>();
             for (HttpExchange exchange : session.getHttpExchange()) {
-                sequence.add(new Event(new HTTPEventType(exchange),
+                sequence.add(new Event(createEvent(exchange),
                                        new HTTPTarget(exchange.getReceiver())));
             }
@@ -107 +124 @@
     /**
      * <p>
+     * instantiates the appropriate event type. If it encounters a SOAP exchange, a SOAP event type
+     * is instantiated. Otherwise a normal HTTP event type is created.
+     * </p>
+     *
+     * @param exchange the exchange for which an event type is to be created
+     * 
+     * @return as described
+     */
+    private IEventType createEvent(HttpExchange exchange) {
+        Content requestContent =
+            exchange.getRequest() != null ? exchange.getRequest().getContent() : null;
+        
+        SOAPMessage soapRequest = getSOAPMessage(requestContent);
+        
+        Content responseContent =
+            exchange.getResponse() != null ? exchange.getResponse().getContent() : null;
+            
+        SOAPMessage soapResponse = getSOAPMessage(responseContent);
+        
+        if (soapRequest != null) {
+            return new SOAPEventType(exchange, soapRequest, soapResponse);
+        }
+        else {
+            return new HTTPEventType(exchange);
+        }
+    }
+
+    /**
+     * <p>
+     * convenience method to convert the content of an HTTP request or response into a SOAP message
+     * </p>
+     *
+     * @param content the content to be converted into a SOAP message
+     * 
+     * @return the SOAP message contained in the content or null if either the content is null or
+     *         the content does not contain a SOAP message
+     */
+    private SOAPMessage getSOAPMessage(Content content) {
+        if ((content != null) && (content.getData() != null)) {
+            try {
+                if (soapMessageFactory == null) {
+                    soapMessageFactory = MessageFactory.newInstance();
+                }
+            
+                String encoding = content.getEncoding();
+                if (encoding == null) {
+                    encoding = "UTF-8";
+                }
+                
+                InputStream in = new ByteArrayInputStream(content.getData().getBytes(encoding));
+                return soapMessageFactory.createMessage(null, in);
+            }
+            catch (Exception e) {
+                if (content.getData().toLowerCase().indexOf("envelope") > 0) {
+                    Console.traceln(Level.WARNING, "HTTP message seems to be a SOAP message but " +
+                                    "it could not be parsed as such: " + e);
+                    Console.logException(e);
+                }
+            }
+        }
+        
+        return null;
+    }
+
+    /**
+     * <p>
      * returns the sequences parsed by this parser
      * </p>

trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest/plugin/http/HTTPUtils.java

@@ -62 +62 @@
         return null;
     }
+
+    /**
+     * <p>
+     * compares two addresses and returns true, if they are equal and false else. The addresses
+     * are equal, if either the ip-addresses and the ports match or the host names and the
+     * ports match.
+     * </p>
+     *
+     * @param address1 the first address to compare
+     * @param address2 the second address to compare
+     * 
+     * @return as described
+     */
+    public static boolean equals(Address address1, Address address2) {
+        if (address1 == null) {
+            return address2 == null;
+        }
+        else if (address2 == null) {
+            return false;
+        }
+        
+        if (!equals(address1.getPort(), address2.getPort())) {
+            return false;
+        }
+        
+        if (address1.getIp() != null) {
+            return equals(address1.getIp(), address2.getIp());
+        }
+        else {
+            return equals(address1.getHost(), address2.getHost());
+        }
+    }
     
+    /**
+     * <p>
+     * convenience method to compare to objects. They are considered equal if they both are null,
+     * or if their equals method returns true.
+     * </p>
+     *
+     * @param object1 the first object to compare
+     * @param object2 the second object to compare
+     * 
+     * @return as described
+     */
+    public static <T> boolean equals(T object1, T object2) {
+        if (object1 == null)  {
+            return object2 == null;
+        }
+        else {
+            return object1.equals(object2);
+        }
+    }
+
     /**
      * <p>

trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest/plugin/http/eventcore/HTTPEventType.java

@@ -17 +17 @@
 import de.ugoe.cs.autoquest.eventcore.IEventType;
 import de.ugoe.cs.autoquest.httpmonitor.exchange.HttpExchange;
+import de.ugoe.cs.autoquest.httpmonitor.exchange.HttpRequest;
 import de.ugoe.cs.autoquest.plugin.http.HTTPUtils;
 
@@ -128 +129 @@
     @Override
     public boolean equals(Object obj) {
-        return super.equals(obj);
+        if (this == obj) {
+            return true;
+        }
+        
+        if (obj instanceof HTTPEventType) {
+            HTTPEventType other = (HTTPEventType) obj;
+            
+            HttpRequest request1 = exchange.getRequest();
+            HttpRequest request2 = other.exchange.getRequest();
+            
+            return (HTTPUtils.equals(exchange.getSender(), other.exchange.getSender()) &&
+                    HTTPUtils.equals(exchange.getReceiver(), other.exchange.getReceiver()) &&
+                    HTTPUtils.equals(request1.getMethod(), request2.getMethod()) &&
+                    HTTPUtils.equals(request1.getProtocol(), request2.getProtocol()) &&
+                    HTTPUtils.equals(request1.getUrl(), request2.getUrl()));
+        }
+        else {
+            return false;
+        }
     }
 
@@ -136 +155 @@
     @Override
     public int hashCode() {
-        return super.hashCode();
+        return
+            exchange.getRequest().getMethod().hashCode() +
+            exchange.getRequest().getProtocol().hashCode() +
+            exchange.getRequest().getUrl().hashCode();
     }
 

trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest/plugin/http/eventcore/HTTPTarget.java

@@ -75 +75 @@
 
     /* (non-Javadoc)
+     * @see java.lang.Object#toString()
+     */
+    @Override
+    public String toString() {
+        return stringIdentifier;
+    }
+
+    /* (non-Javadoc)
      * @see java.lang.Object#equals(java.lang.Object)
      */