add support for socket io queries.

fixes: koush#47

Author: koush

AndroidAsync/src/com/koushikdutta/async/http/socketio/SocketIOConnection.java

@@ -122,7 +122,12 @@ protected void transform(String result) throws Exception {
                 if (!set.contains("websocket"))
                     throw new Exception("websocket not supported");
 
-                final String sessionUrl = request.getUri().toString() + "websocket/" + session + "/";
+                String query;
+                if (TextUtils.isEmpty(request.getQuery()))
+                    query = "?" + request.getQuery();
+                else
+                    query = "";
+                final String sessionUrl = request.getUri().toString() + "websocket/" + session + "/" + query;
 
                 httpClient.websocket(sessionUrl, null, null)
                 .setCallback(getCompletionCallback());

AndroidAsync/src/com/koushikdutta/async/http/socketio/SocketIORequest.java

@@ -15,8 +15,18 @@ public String getEndpoint() {
         return endpoint;
     }
 
+    String query;
+    public String getQuery() {
+        return query;
+    }
+
     public SocketIORequest(String uri, String endpoint) {
+        this(uri, endpoint, null);
+    }
+
+    public SocketIORequest(String uri, String endpoint, String query) {
         super(Uri.parse(uri).buildUpon().encodedPath("/socket.io/1/").build().toString());
         this.endpoint = endpoint;
+        this.query = query;
     }
 }

AndroidAsyncTest/src/com/koushikdutta/async/test/FutureTests.java

@@ -348,14 +348,7 @@ public void run() {
             assertEquals((int)results.get(i), i);
         }
     }
-    
-    
-    class TriggerFuture extends SimpleFuture<Integer> {
-        public void trigger() {
-            setComplete(2020);
-        }
-    }
-    
+
     public void testReentrancy() throws Exception {
         // verify reentrancy will work
 

AndroidAsyncTest/src/com/koushikdutta/async/test/TriggerFuture.java

@@ -0,0 +1,9 @@
+package com.koushikdutta.async.test;
+
+import com.koushikdutta.async.future.SimpleFuture;
+
+class TriggerFuture extends SimpleFuture<Integer> {
+    public void trigger() {
+        setComplete(2020);
+    }
+}