[tor-commits] [flashproxy/rtmfp] Use a URLLoader to query the HTTP facilitator.

[dcf at torproject.org]

commit 5ae83e1cc6ce4bd38958538bbdbecf955a6bfc65
Author: David Fifield <david at bamsoftware.com>
Date:   Mon May 30 21:18:16 2011 -0700

    Use a URLLoader to query the HTTP facilitator.
---
 swfcat.as |   54 +++++++++++++++++++++++++++++-------------------------
 1 files changed, 29 insertions(+), 25 deletions(-)

diff --git a/swfcat.as b/swfcat.as
index 05da498..130b061 100644
--- a/swfcat.as
+++ b/swfcat.as
@@ -6,6 +6,9 @@ package
     import flash.text.TextField;
     import flash.text.TextFormat;
     import flash.net.Socket;
+    import flash.net.URLLoader;
+    import flash.net.URLLoaderDataFormat;
+    import flash.net.URLRequest;
     import flash.events.Event;
     import flash.events.IOErrorEvent;
     import flash.events.ProgressEvent;
@@ -36,9 +39,6 @@ package
         // Seconds.
         private const RATE_LIMIT_HISTORY:Number = 5.0;
 
-        // Socket to facilitator.
-        private var s_f:Socket;
-
         /* TextField for debug output. */
         private var output_text:TextField;
 
@@ -183,45 +183,49 @@ package
         /* The main logic begins here, after start-up issues are taken care of. */
         private function main():void
         {
+            var fac_url:String;
+            var loader:URLLoader;
+
             if (num_proxy_pairs >= MAX_NUM_PROXY_PAIRS) {
                 setTimeout(main, FACILITATOR_POLL_INTERVAL);
                 return;
             }
 
-            s_f = new Socket();
-
-            s_f.addEventListener(Event.CONNECT, fac_connected);
-            s_f.addEventListener(Event.CLOSE, function (e:Event):void {
-                puts("Facilitator: closed connection.");
-                setTimeout(main, FACILITATOR_POLL_INTERVAL);
-            });
-            s_f.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void {
+            loader = new URLLoader();
+            /* Get the x-www-form-urlencoded values. */
+            loader.dataFormat = URLLoaderDataFormat.VARIABLES;
+            loader.addEventListener(Event.COMPLETE, fac_complete);
+            loader.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void {
                 puts("Facilitator: I/O error: " + e.text + ".");
             });
-            s_f.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void {
+            loader.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void {
                 puts("Facilitator: security error: " + e.text + ".");
             });
 
-            puts("Facilitator: connecting to " + fac_addr.host + ":" + fac_addr.port + ".");
-            s_f.connect(fac_addr.host, fac_addr.port);
-        }
-
-        private function fac_connected(e:Event):void
-        {
-            puts("Facilitator: connected.");
-
-            s_f.addEventListener(ProgressEvent.SOCKET_DATA, fac_data);
-
-            s_f.writeUTFBytes("GET / HTTP/1.0\r\n\r\n");
+            fac_url = "http://" + encodeURIComponent(fac_addr.host)
+                + ":" + encodeURIComponent(fac_addr.port) + "/";
+            puts("Facilitator: connecting to " + fac_url + ".");
+            loader.load(new URLRequest(fac_url));
         }
 
-        private function fac_data(e:ProgressEvent):void
+        private function fac_complete(e:Event):void
         {
+            var loader:URLLoader;
             var client_spec:String;
             var client_addr:Object;
             var proxy_pair:Object;
 
-            client_spec = s_f.readMultiByte(e.bytesLoaded, "utf-8");
+            setTimeout(main, FACILITATOR_POLL_INTERVAL);
+
+            loader = e.target as URLLoader;
+            client_spec = loader.data.client;
+            if (client_spec == "") {
+                puts("No clients.");
+                return;
+            } else if (!client_spec) {
+                puts("Error: missing \"client\" in response.");
+                return;
+            }
             puts("Facilitator: got \"" + client_spec + "\".");
 
             client_addr = parse_addr_spec(client_spec);