commit 3f5a036ef65d488d575c3ec8e3a8a3f7b7e69f6e Author: Nate Hardison <nate@rescomp-09-154551.stanford.edu> Date: Wed May 4 16:28:34 2011 -0700 New RTMFP relay started in Proxy.as, building relay system for Tor client and patsy proxy --- Connector.as | 52 +++++++++++ Makefile | 2 +- Proxy.as | 261 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ RTMFPRelay.as | 272 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 4 files changed, 586 insertions(+), 1 deletions(-) diff --git a/Connector.as b/Connector.as new file mode 100644 index 0000000..f362dd3 --- /dev/null +++ b/Connector.as @@ -0,0 +1,52 @@ +package +{ + import flash.display.Sprite; + import flash.text.TextField; + import flash.net.Socket; + import flash.events.Event; + import flash.events.EventDispatcher; + import flash.events.IOErrorEvent; + import flash.events.NetStatusEvent; + import flash.events.ProgressEvent; + import flash.events.SecurityErrorEvent; + import flash.net.NetConnection; + import flash.net.NetStream; + import flash.utils.ByteArray; + import flash.utils.clearInterval; + import flash.utils.setInterval; + import flash.utils.setTimeout; + + public class Connector extends RTMFPRelay { + + private var output_text:TextField; + + private var fac_addr:Object; + private var tor_addr:Object; + + public function Connector() { + output_text = new TextField(); + output_text.width = 400; + output_text.height = 300; + output_text.background = true; + output_text.backgroundColor = 0x001f0f; + output_text.textColor = 0x44CC44; + addChild(output_text); + + puts("Starting."); + // Wait until the query string parameters are loaded. + this.loaderInfo.addEventListener(Event.COMPLETE, loaderinfo_complete); + } + + + private function loaderinfo_complete(e:Event):void + { + var fac_spec:String; + var tor_spec:String; + + puts("Parameters loaded."); + + + } + +} + \ No newline at end of file diff --git a/Makefile b/Makefile index 27ba9d8..6f03eb6 100644 --- a/Makefile +++ b/Makefile @@ -5,7 +5,7 @@ TARGETS = swfcat.swf all: $(TARGETS) %.swf: %.as - $(MXMLC) -output $@ $^ + $(MXMLC) -output $@ -define=RTMFP::CIRRUS_KEY,\"$(CIRRUS_KEY)\" $^ clean: rm -f $(TARGETS) diff --git a/Proxy.as b/Proxy.as new file mode 100644 index 0000000..01b2fe3 --- /dev/null +++ b/Proxy.as @@ -0,0 +1,261 @@ +package +{ + import flash.display.Sprite; + import flash.text.TextField; + import flash.net.Socket; + import flash.events.Event; + import flash.events.EventDispatcher; + import flash.events.IOErrorEvent; + import flash.events.NetStatusEvent; + import flash.events.ProgressEvent; + import flash.events.SecurityErrorEvent; + import flash.net.NetConnection; + import flash.net.NetStream; + import flash.utils.ByteArray; + import flash.utils.clearInterval; + import flash.utils.setInterval; + import flash.utils.setTimeout; + + public class Proxy extends Sprite + { + /* David's relay (nickname 3VXRyxz67OeRoqHn) that also serves a + crossdomain policy. */ + private const DEFAULT_TOR_ADDR:Object = { + host: "173.255.221.44", + port: 9001 + }; + + /* Address of the Cirrus rendezvous service with Nate's + developer key appended */ + private static const CIRRUS_ADDRESS:String = "rtmfp://p2p.rtmfp.net/" + RTMFP::CIRRUS_KEY + "/"; + + // The name of our data stream + public static const DATA:String = "data"; + + private var output_text:TextField; + + // Socket to Tor relay. + private var s_t:Socket; + // Socket to facilitator. + private var s_f:Socket; + + /* Connection to the Cirrus rendezvous service that will hook + us up with the Tor client */ + public var cirrus:NetConnection; + + // The Tor client's peerID (used when establishing the client_stream) + private var client_id:String; + + // The data streams to be established with the Tor client + public var send_stream:NetStream; + public var recv_stream:NetStream; + + private var fac_addr:Object; + private var tor_addr:Object; + + private function puts(s:String):void + { + output_text.appendText(s + "\n"); + output_text.scrollV = output_text.maxScrollV; + } + + public function Proxy() + { + output_text = new TextField(); + output_text.width = 400; + output_text.height = 300; + output_text.background = true; + output_text.backgroundColor = 0x001f0f; + output_text.textColor = 0x44CC44; + addChild(output_text); + + puts("Starting."); + // Wait until the query string parameters are loaded. + this.loaderInfo.addEventListener(Event.COMPLETE, loaderinfo_complete); + } + + private function loaderinfo_complete(e:Event):void + { + var fac_spec:String; + var tor_spec:String; + + puts("Parameters loaded."); + fac_spec = this.loaderInfo.parameters["facilitator"]; + if (!fac_spec) { + puts("Error: no \"facilitator\" specification provided."); + return; + } + puts("Facilitator spec: \"" + fac_spec + "\""); + fac_addr = parse_addr_spec(fac_spec); + if (!fac_addr) { + puts("Error: Facilitator spec must be in the form \"host:port\"."); + return; + } + + tor_addr = DEFAULT_TOR_ADDR; + + go(); + } + + /* We connect first to the Tor relay; once that happens we connect to + the facilitator to get a client address; once we have the address + of a waiting client then we connect to the client and BAM! we're in business. */ + private function go():void + { + s_t = new Socket(); + + s_t.addEventListener(Event.CONNECT, tor_connected); + s_t.addEventListener(Event.CLOSE, function (e:Event):void { + puts("Tor: closed."); + }); + s_t.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { + puts("Tor: I/O error: " + e.text + "."); + }); + s_t.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void { + puts("Tor: security error: " + e.text + "."); + + }); + + puts("Tor: connecting to " + tor_addr.host + ":" + tor_addr.port + "."); + s_t.connect(tor_addr.host, tor_addr.port); + } + + private function tor_connected(e:Event):void + { + /* Got a connection to tor, now let's get served a client from the facilitator */ + s_f = new Socket(); + + puts("Tor: connected."); + s_f.addEventListener(Event.CONNECT, fac_connected); + s_f.addEventListener(Event.CLOSE, function (e:Event):void { + puts("Facilitator: closed connection."); + }); + s_f.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { + puts("Facilitator: I/O error: " + e.text + "."); + if (s_t.connected) + s_t.close(); + }); + s_f.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void { + puts("Facilitator: security error: " + e.text + "."); + if (s_t.connected) + s_t.close(); + }); + + 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, function (e:ProgressEvent):void { + var client_spec:String; + var client_addr:Object; + + client_spec = s_f.readMultiByte(e.bytesLoaded, "utf-8"); + puts("Facilitator: got \"" + client_spec + "\""); + + /*client_addr = parse_addr_spec(client_spec); + if (!client_addr) { + puts("Error: Client spec must be in the form \"host:port\"."); + return; + } + if (client_addr.host == "0.0.0.0" && client_addr.port == 0) { + puts("Error: Facilitator has no clients."); + return; + }*/ + + /* Now we have a client, so start up a connection to the Cirrus rendezvous point */ + cirrus = new NetConnection(); + cirrus.addEventListener(NetStatusEvent.NET_STATUS, net_status_event_handler); + cirrus.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { + if (s_t.connected) s_t.close(); + if (s_f.connected) s_f.close(); + }); + + cirrus.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityError):void { + if (s_t.connected) s_t.close(); + if (s_f.connected) s_f.close(); + }); + + cirrus.connect(CIRRUS_ADDRESS); + }); + + s_f.writeUTFBytes("GET / HTTP/1.0\r\n\r\n"); + } + + private function net_status_event_handler(e:NetStatusEvent):void + { + switch (e.info.code) { + case "NetConnection.Connect.Success" : + // Cirrus is now connected + cirrus_connected(e); + } + + } + + private function cirrus_connected(e:Event):void + { + if (client_id == null) { + puts("Error: Client ID doesn't exist."); + return; + } else if (client_id == cirrus.nearID) { + puts("Error: Client ID is our ID."); + return; + } + + send_stream = new NetStream(cirrus, NetStream.DIRECT_CONNECTIONS); + send_stream.addEventListener(NetStatusEvent.NET_STATUS, net_status_event_handler); + send_stream.publish(DATA); + + recv_stream = new NetStream(cirrus, client_id); + recv_stream.addEventListener(NetStatusEvent.NET_STATUS, net_status_event_handler); + recv_stream.play(DATA); + } + + /*private function client_connected(e:Event):void + { + puts("Client: connected."); + + s_t.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var bytes:ByteArray = new ByteArray(); + s_t.readBytes(bytes, 0, e.bytesLoaded); + puts("Tor: read " + bytes.length + "."); + s_c.writeBytes(bytes); + }); + s_c.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var bytes:ByteArray = new ByteArray(); + s_c.readBytes(bytes, 0, e.bytesLoaded); + puts("Client: read " + bytes.length + "."); + s_t.writeBytes(bytes); + }); + }*/ + + private function close_connections():void + { + if (s_t.connected) s_t.close(); + if (s_f.connected) s_f.close(); + if (cirrus.connected) cirrus.close(); + if (send_stream != null) send_stream.close(); + if (recv_stream != null) recv_stream.close(); + } + + /* Parse an address in the form "host:port". Returns an Object with + keys "host" (String) and "port" (int). Returns null on error. */ + private static function parse_addr_spec(spec:String):Object + { + var parts:Array; + var addr:Object; + + parts = spec.split(":", 2); + if (parts.length != 2 || !parseInt(parts[1])) + return null; + addr = {} + addr.host = parts[0]; + addr.port = parseInt(parts[1]); + + return addr; + } + } +} diff --git a/RTMFPRelay.as b/RTMFPRelay.as new file mode 100644 index 0000000..27b3208 --- /dev/null +++ b/RTMFPRelay.as @@ -0,0 +1,272 @@ +package +{ + import flash.display.Sprite; + import flash.text.TextField; + import flash.net.Socket; + import flash.events.Event; + import flash.events.EventDispatcher; + import flash.events.IOErrorEvent; + import flash.events.NetStatusEvent; + import flash.events.ProgressEvent; + import flash.events.SecurityErrorEvent; + import flash.net.NetConnection; + import flash.net.NetStream; + import flash.utils.ByteArray; + import flash.utils.clearInterval; + import flash.utils.setInterval; + import flash.utils.setTimeout; + + import Utils; + + public class RTMFPRelay extends Sprite + { + private static const CIRRUS_ADDRESS:String = "rtmfp://p2p.rtmfp.net"; + private static const CIRRUS_DEV_KEY:String = RTMFP::CIRRUS_KEY; + + /* The name of the "media" to pass between peers */ + public static const DATA:String = "data"; + + protected var output_text:TextField; + + // Socket to Tor relay. + private var s_t:Socket; + // Socket to facilitator. + private var s_f:Socket; + + /* Connection to the Cirrus rendezvous service */ + private var cirrus_conn:NetConnection; + + /* ID of the peer to connect to */ + private var peer_id:String; + + /* Data streams to be established with peer */ + private var send_stream:NetStream; + private var recv_stream:NetStream; + + private var fac_addr:Object; + private var tor_addr:Object; + + private function puts(s:String):void + { + output_text.appendText(s + "\n"); + output_text.scrollV = output_text.maxScrollV; + } + + public function RTMFPRelay() + { + output_text = new TextField(); + output_text.width = 400; + output_text.height = 300; + output_text.background = true; + output_text.backgroundColor = 0x001f0f; + output_text.textColor = 0x44CC44; + addChild(output_text); + + puts("Starting."); + + cirrus_conn = new NetConnection(); + cirrus_conn.addEventListener(NetStatusEvent.NET_STATUS, function (e:NetStatusEvent):void { + puts("Cirrus: connected."); + }); + cirrus_conn.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { + puts("Cirrus: I/O error: " + e.text + "."); + }); + + cirrus_conn.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityError):void { + puts("Cirrus: security error: " + e.text + "."); + }); + + cirrus_conn.connect(CIRRUS_ADDRESS + "/" + CIRRUS_DEV_KEY); + + + // Wait until the query string parameters are loaded. + this.loaderInfo.addEventListener(Event.COMPLETE, loaderinfo_complete); + } + + public function data_is(data:ByteArray):void + { + + + } + + public function facilitator_is(host:String, port:String):void + { + if (s_f != null && s_f.connected) { + + return; + } + + s_f = new Socket(); + + s_f.addEventListener(Event.CONNECT, function (e:Event):void { + puts("Facilitator: connected."); + }); + s_f.addEventListener(Event.CLOSE, function (e:Event):void { + puts("Facilitator: closed connection."); + }); + s_f.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 { + puts("Facilitator: security error: " + e.text + "."); + }); + + puts("Facilitator: connecting to " + host + ":" + port + "."); + s_f.connect(host, port); + } + + public function peer(peer_id:String):String + { + return this.peer_id; + } + + public function peer_is(peer_id:String):void + { + if (peer_id == null) { + puts("Error: Client ID doesn't exist."); + return; + } else if (peer_id == cirrus_conn.nearID) { + puts("Error: Client ID is our ID."); + return; + } else if (this.peer_id == peer_id) { + + } else if (this.recv_stream != null) { + puts("Error: already set up with a peer!"); + return; + } + + this.peer_id = peer_id; + + send_stream = new NetStream(cirrus_conn, NetStream.DIRECT_CONNECTIONS); + send_stream.addEventListener(NetStatusEvent.NET_STATUS, net_status_event_handler); + send_stream.publish(DATA); + + recv_stream = new NetStream(cirrus_conn, peer_id); + recv_stream.addEventListener(NetStatusEvent.NET_STATUS, net_status_event_handler); + recv_stream.play(DATA); + } + + public function tor_relay_is(host:String, port:String):void + { + if (s_t != null && s_t.connected) { + puts("Error: already connected to Tor relay!"); + return; + } + + s_t = new Socket(); + + s_t.addEventListener(Event.CONNECT, function (e:Event):void { + puts("Tor: connected."); + }); + s_t.addEventListener(Event.CLOSE, function (e:Event):void { + puts("Tor: closed."); + }); + s_t.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { + puts("Tor: I/O error: " + e.text + "."); + }); + s_t.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void { + puts("Tor: security error: " + e.text + "."); + }); + + puts("Tor: connecting to " + host + ":" + port + "."); + s_t.connect(host, port); + } + + private function loaderinfo_complete(e:Event):void + { + var fac_spec:String; + var tor_spec:String; + + puts("Parameters loaded."); + fac_spec = this.loaderInfo.parameters["facilitator"]; + if (!fac_spec) { + puts("Error: no \"facilitator\" specification provided."); + return; + } + puts("Facilitator spec: \"" + fac_spec + "\""); + fac_addr = parse_addr_spec(fac_spec); + if (!fac_addr) { + puts("Error: Facilitator spec must be in the form \"host:port\"."); + return; + } + + tor_addr = DEFAULT_TOR_ADDR; + + go(); + } + + private function fac_connected(e:Event):void + { + + + s_f.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var client_spec:String; + var client_addr:Object; + + client_spec = s_f.readMultiByte(e.bytesLoaded, "utf-8"); + puts("Facilitator: got \"" + client_spec + "\""); + + /*client_addr = parse_addr_spec(client_spec); + if (!client_addr) { + puts("Error: Client spec must be in the form \"host:port\"."); + return; + } + if (client_addr.host == "0.0.0.0" && client_addr.port == 0) { + puts("Error: Facilitator has no clients."); + return; + }*/ + + /* Now we have a client, so start up a connection to the Cirrus rendezvous point */ + + }); + + s_f.writeUTFBytes("GET / HTTP/1.0\r\n\r\n"); + } + + private function net_status_event_handler(e:NetStatusEvent):void + { + switch (e.info.code) { + case "NetConnection.Connect.Success" : + // Cirrus is now connected + cirrus_connected(e); + } + + } + + private function cirrus_connected(e:Event):void + { + + + + } + + /*private function client_connected(e:Event):void + { + puts("Client: connected."); + + s_t.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var bytes:ByteArray = new ByteArray(); + s_t.readBytes(bytes, 0, e.bytesLoaded); + puts("Tor: read " + bytes.length + "."); + s_c.writeBytes(bytes); + }); + s_c.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var bytes:ByteArray = new ByteArray(); + s_c.readBytes(bytes, 0, e.bytesLoaded); + puts("Client: read " + bytes.length + "."); + s_t.writeBytes(bytes); + }); + }*/ + + private function close_connections():void + { + if (s_t.connected) s_t.close(); + if (s_f.connected) s_f.close(); + if (cirrus.connected) cirrus.close(); + if (send_stream != null) send_stream.close(); + if (recv_stream != null) recv_stream.close(); + } + + + } +}