- tor-commits - lists.torproject.org

[flashproxy/master] removed two spaces from close body
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit fd7c1d376ec99450745545dc9b54a5213128f6ac Author: ellitron <jdellit(a)stanford.edu> Date: Tue May 24 19:54:32 2011 -0700 removed two spaces from close body --- com/rtmfpcat/rtmfp/RTMFPSocket.as | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/com/rtmfpcat/rtmfp/RTMFPSocket.as b/com/rtmfpcat/rtmfp/RTMFPSocket.as index 2d634f0..450e520 100644 --- a/com/rtmfpcat/rtmfp/RTMFPSocket.as +++ b/com/rtmfpcat/rtmfp/RTMFPSocket.as @@ -69,7 +69,7 @@ package rtmfp public function close():void { - connection.close(); + connection.close(); } public function get id():String

1 0

[flashproxy/master] Messed up the last commit.
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit b875382c6e5d2c4a0feaeb3a9e91632fdab9b741 Author: David Fifield <david(a)bamsoftware.com> Date: Wed May 25 00:43:28 2011 -0700 Messed up the last commit. --- rtmfpcat.as | 5 ++++- 1 files changed, 4 insertions(+), 1 deletions(-) diff --git a/rtmfpcat.as b/rtmfpcat.as index 49fcdeb..d01bb37 100644 --- a/rtmfpcat.as +++ b/rtmfpcat.as @@ -109,7 +109,10 @@ package return; } } else { - tor_addr = DEFAULT_TOR_CLIENT_ADDR; + if (proxy_mode) + tor_addr = DEFAULT_TOR_PROXY_ADDR; + else + tor_addr = DEFAULT_TOR_CLIENT_ADDR; } main();

1 0

[flashproxy/master] Completed return_of_the_rtmfpcat client side code, works
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit 59ccbab495b24f513c45976b81a318948510d207 Author: ellitron <jdellit(a)stanford.edu> Date: Wed May 25 18:05:13 2011 -0700 Completed return_of_the_rtmfpcat client side code, works --- return_of_the_rtmfpcat.as | 157 +++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 157 insertions(+), 0 deletions(-) diff --git a/return_of_the_rtmfpcat.as b/return_of_the_rtmfpcat.as index e8b786d..9ecc61f 100644 --- a/return_of_the_rtmfpcat.as +++ b/return_of_the_rtmfpcat.as @@ -76,6 +76,9 @@ package /* Cirrus connection timeout ID. */ private var circon_timeo_id:int; + /* Array of connection pairs */ + private var con_pairs:Array; + /* Put a string to the screen. */ public function puts(s:String):void { @@ -175,6 +178,19 @@ package puts("circon_netstatus_event: NetConnection.Connect.Success"); puts("Got id " + circon.nearID + "."); clearInterval(circon_timeo_id); + + if(proxy_mode) { + + } else { + /* Listen for incoming RTMFP connections. */ + var s_r:RTMFPSocket = new RTMFPSocket(circon); + s_r.addEventListener(Event.CONNECT, rtmfp_connect_event); + s_r.listen(); + + /* Register ID with facilitator. */ + register_id(circon.nearID, fac_addr); + } + break; case "NetStream.Connect.Success" : puts("circon_netstatus_event: NetStream.Connect.Success"); @@ -191,6 +207,32 @@ package } } + private function rtmfp_connect_event(e:Event):void + { + puts("VICTORY!"); + } + + private function register_id(id:String, fac_addr:Object):void + { + var s_f:Socket = new Socket(); + s_f.addEventListener(Event.CONNECT, function (e:Event):void { + puts("Facilitator: connected to " + fac_addr.host + ":" + fac_addr.port + "."); + puts("Registering id " + id); + s_f.writeUTFBytes("POST / HTTP/1.0\r\n\r\nclient=" + id + "\r\n"); + }); + s_f.addEventListener(Event.CLOSE, function (e:Event):void { + puts("Facilitator: connection closed."); + }); + 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 + "."); + }); + + s_f.connect(fac_addr.host, fac_addr.port); + } + private function circon_timeout():void { puts("Cirrus server connection timed out!"); @@ -215,3 +257,118 @@ package } } +import flash.display.Sprite; +import flash.events.Event; +import flash.events.EventDispatcher; +import flash.events.IOErrorEvent; +import flash.events.ProgressEvent; +import flash.events.SecurityErrorEvent; +import flash.net.Socket; +import flash.utils.ByteArray; +import flash.utils.clearTimeout; +import flash.utils.getTimer; +import flash.utils.setTimeout; +import flash.net.NetConnection; +import flash.net.NetStream; + +class RTMFPSocket extends EventDispatcher +{ + /* The name of the "media" to pass between peers. */ + private static const DATA:String = "data"; + + /* Connection to the Cirrus rendezvous service. + * RTMFPSocket is established using this service. */ + private var circon:NetConnection; + + /* Unidirectional streams composing socket. */ + private var send_stream:NetStream; + private var recv_stream:NetStream; + + public function RTMFPSocket(circon:NetConnection) + { + this.circon = circon; + } + + public function listen():void + { + send_stream = new NetStream(circon, NetStream.DIRECT_CONNECTIONS); + var client:Object = new Object(); + client.onPeerConnect = send_stream_peer_connect; + send_stream.client = client; + send_stream.publish(DATA); + } + + private function send_stream_peer_connect(peer:NetStream):Boolean + { + recv_stream = new NetStream(circon, peer.farID); + var client:RTMFPSocketClient = new RTMFPSocketClient(); + client.addEventListener(ProgressEvent.SOCKET_DATA, function (event:ProgressEvent):void { + dispatchEvent(event); + }, false, 0, true); + client.addEventListener(RTMFPSocketClient.PEER_CONNECT_ACKNOWLEDGED, function (event:Event):void { + dispatchEvent(new Event(Event.CONNECT)); + }, false, 0, true); + recv_stream.client = client; + recv_stream.play(DATA); + + return true; + } + + +} + +dynamic class RTMFPSocketClient extends EventDispatcher +{ + public static const PEER_CONNECT_ACKNOWLEDGED:String = "peerConnectAcknowledged"; + + private var _bytes:ByteArray; + private var _peerID:String; + private var _peerConnectAcknowledged:Boolean; + + public function RTMFPSocketClient() + { + super(); + _bytes = new ByteArray(); + _peerID = null; + _peerConnectAcknowledged = false; + } + + public function get bytes():ByteArray + { + return _bytes; + } + + public function dataAvailable(bytes:ByteArray):void + { + this._bytes.clear(); + bytes.readBytes(this._bytes); + dispatchEvent(new ProgressEvent(ProgressEvent.SOCKET_DATA, false, false, this._bytes.bytesAvailable, this._bytes.length)); + } + + public function get peerConnectAcknowledged():Boolean + { + return _peerConnectAcknowledged; + } + + public function setPeerConnectAcknowledged():void + { + _peerConnectAcknowledged = true; + dispatchEvent(new Event(PEER_CONNECT_ACKNOWLEDGED)); + } + + public function get peerID():String + { + return _peerID; + } + + public function set peerID(id:String):void + { + _peerID = id; + } + +} + +class ConnectionPair extends EventDispatcher +{ + +}

1 0

[flashproxy/master] Merge remote branch 'origin/rtmfp' into rtmfp
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit 486fba47f3bf851eb8549c03ff506fece4dc4818 Merge: e178468 0423ede Author: ellitron <jdellit(a)stanford.edu> Date: Thu May 26 13:56:26 2011 -0700 Merge remote branch 'origin/rtmfp' into rtmfp facilitator.py | 106 ++++++++++++++++++++++++++++++++++++++++---------------- 1 files changed, 76 insertions(+), 30 deletions(-)

1 0

[flashproxy/master] adding small rework of rtmfpcat
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit 1aeec175fe5058ca9ca5adb114eb6819e831c407 Author: ellitron <jdellit(a)stanford.edu> Date: Wed May 25 15:08:18 2011 -0700 adding small rework of rtmfpcat --- Makefile | 2 +- return_of_the_rtmfpcat.as | 217 +++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 218 insertions(+), 1 deletions(-) diff --git a/Makefile b/Makefile index 3595385..bc1f8bf 100644 --- a/Makefile +++ b/Makefile @@ -1,6 +1,6 @@ MXMLC ?= mxmlc -TARGETS = rtmfpcat.swf +TARGETS = rtmfpcat.swf return_of_the_rtmfpcat.swf all: $(TARGETS) diff --git a/return_of_the_rtmfpcat.as b/return_of_the_rtmfpcat.as new file mode 100644 index 0000000..e8b786d --- /dev/null +++ b/return_of_the_rtmfpcat.as @@ -0,0 +1,217 @@ +/* Meow! */ +package +{ + import flash.display.Sprite; + import flash.display.StageAlign; + import flash.display.StageScaleMode; + import flash.text.TextField; + import flash.text.TextFormat; + 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.utils.ByteArray; + import flash.utils.setTimeout; + import flash.utils.clearInterval; + import flash.utils.setInterval; + import flash.utils.setTimeout; + import flash.net.NetConnection; + + import rtmfp.RTMFPSocket; + import rtmfp.events.RTMFPSocketEvent; + + public class return_of_the_rtmfpcat extends Sprite + { + /* David's relay (nickname 3VXRyxz67OeRoqHn) that also serves a + crossdomain policy. */ + private const DEFAULT_TOR_PROXY_ADDR:Object = { + host: "173.255.221.44", + port: 9001 + }; + + /* Tor application running on the client. */ + private const DEFAULT_TOR_CLIENT_ADDR:Object = { + host: "127.0.0.1", + port: 3333 + }; + + /* Nate's facilitator -- also serving a crossdomain policy */ + private const DEFAULT_FACILITATOR_ADDR:Object = { + host: "128.12.179.80", + port: 9002 + }; + + /* Cirrus server information. */ + private const DEFAULT_CIRRUS_ADDRESS:String = "rtmfp://p2p.rtmfp.net"; + private const DEFAULT_CIRRUS_KEY:String = RTMFP::CIRRUS_KEY; + + private static const DEFAULT_CIRCON_TIMEOUT:uint = 4000; + + /* TextField for debug output. */ + private var output_text:TextField; + + /* Are we the proxy or the client? */ + private var proxy_mode:Boolean; + + /* Facilitator address */ + private var fac_addr:Object; + + /* Tor address. If we're a proxy, then this address is a relay. + * If we're running on the client, then this address is the Tor + * client application. */ + private var tor_addr:Object; + + /* Cirrus address */ + private var cir_addr:String; + + /* Cirrus key */ + private var cir_key:String; + + /* Connection to the Cirrus rendezvous service */ + private var circon:NetConnection; + + /* Cirrus connection timeout ID. */ + private var circon_timeo_id:int; + + /* Put a string to the screen. */ + public function puts(s:String):void + { + output_text.appendText(s + "\n"); + output_text.scrollV = output_text.maxScrollV; + } + + public function return_of_the_rtmfpcat() + { + // Absolute positioning. + stage.scaleMode = StageScaleMode.NO_SCALE; + stage.align = StageAlign.TOP_LEFT; + + output_text = new TextField(); + output_text.width = stage.stageWidth; + output_text.height = stage.stageHeight; + output_text.background = true; + output_text.backgroundColor = 0x001f0f; + output_text.textColor = 0x44cc44; + + puts("Meow!"); + 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."); + + proxy_mode = (this.loaderInfo.parameters["proxy"] != null); + addChild(output_text); + + fac_spec = this.loaderInfo.parameters["facilitator"]; + if (fac_spec) { + 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; + } + } else { + fac_addr = DEFAULT_FACILITATOR_ADDR; + } + + tor_spec = this.loaderInfo.parameters["tor"]; + if (tor_spec) { + puts("Tor spec: \"" + tor_spec + "\""); + tor_addr = parse_addr_spec(tor_spec); + if (!tor_addr) { + puts("Error: Tor spec must be in the form \"host:port\"."); + return; + } + } else { + if (proxy_mode) + tor_addr = DEFAULT_TOR_PROXY_ADDR; + else + tor_addr = DEFAULT_TOR_CLIENT_ADDR; + } + + if(this.loaderInfo.parameters["cirrus_server"]) + cir_addr = this.loaderInfo.parameters["cirrus_server"]; + else + cir_addr = DEFAULT_CIRRUS_ADDRESS; + + if(this.loaderInfo.parameters["cirrus_key"]) + cir_key = this.loaderInfo.parameters["cirrus_key"]; + else + cir_key = DEFAULT_CIRRUS_KEY; + + main(); + } + + /* The main logic begins here, after start-up issues are taken care of. */ + private function main():void + { + puts("Making connection to cirrus server."); + circon = new NetConnection(); + circon.addEventListener(NetStatusEvent.NET_STATUS, circon_netstatus_event); + circon.addEventListener(IOErrorEvent.IO_ERROR, function (e:Event):void { + puts("Cirrus connection had an IOErrorEvent.IO_ERROR event"); + }); + circon.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:Event):void { + puts("Cirrus connection had a SecurityErrorEvent.SECURITY_ERROR"); + }); + circon.connect(cir_addr + "/" + cir_key); + circon_timeo_id = setInterval(circon_timeout, DEFAULT_CIRCON_TIMEOUT); + } + + private function circon_netstatus_event(event:NetStatusEvent):void + { + switch (event.info.code) { + case "NetConnection.Connect.Success" : + puts("circon_netstatus_event: NetConnection.Connect.Success"); + puts("Got id " + circon.nearID + "."); + clearInterval(circon_timeo_id); + break; + case "NetStream.Connect.Success" : + puts("circon_netstatus_event: NetStream.Connect.Success"); + break; + case "NetStream.Publish.BadName" : + puts("circon_netstatus_event: NetStream.Publish.BadName"); + break; + case "NetStream.Connect.Closed" : + puts("circon_netstatus_event: NetStream.Connect.Closed"); + // we've disconnected from the peer + // can reset to accept another + // clear the publish stream and re-publish another + break; + } + } + + private function circon_timeout():void + { + puts("Cirrus server connection timed out!"); + } + + /* 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; + } + } +} +

1 0

[flashproxy/master] Use parse_addr_spec to parse regs.
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit 07fb8b258a2f87358af0328469dc2d12e0bcfa70 Author: David Fifield <david(a)bamsoftware.com> Date: Wed May 25 18:03:06 2011 -0700 Use parse_addr_spec to parse regs. --- facilitator.py | 56 ++++++++++++++++++++++++++++++++++++-------------------- 1 files changed, 36 insertions(+), 20 deletions(-) diff --git a/facilitator.py b/facilitator.py index fde81b7..0333aee 100755 --- a/facilitator.py +++ b/facilitator.py @@ -47,6 +47,41 @@ def log(msg): finally: log_lock.release() +def parse_addr_spec(spec, defhost = None, defport = None): + host = None + port = None + m = None + # IPv6 syntax. + if not m: + m = re.match(ur'^\[(.+)\]:(\d+)$', spec) + if m: + host, port = m.groups() + af = socket.AF_INET6 + if not m: + m = re.match(ur'^\[(.+)\]:?$', spec) + if m: + host, = m.groups() + af = socket.AF_INET6 + # IPv4 syntax. + if not m: + m = re.match(ur'^(.+):(\d+)$', spec) + if m: + host, port = m.groups() + af = socket.AF_INET + if not m: + m = re.match(ur'^:?(\d+)$', spec) + if m: + port, = m.groups() + af = 0 + if not m: + host = spec + af = 0 + host = host or defhost + port = port or defport + if not (host and port): + raise ValueError("Bad address specification \"%s\"" % spec) + return af, host, int(port) + def format_addr(addr): host, port = addr if not host: @@ -77,26 +112,7 @@ class Reg(object): @staticmethod def parse(spec, defhost = None, defport = None): - host = None - port = None - m = re.match(r'^\[(.+)\]:(\d*)$', spec) - if m: - host, port = m.groups() - af = socket.AF_INET6 - else: - m = re.match(r'^(.*):(\d*)$', spec) - if m: - host, port = m.groups() - if host: - af = socket.AF_INET - else: - # Has to be guessed from format of defhost. - af = 0 - host = host or defhost - port = port or defport - if not (host and port): - raise ValueError("Bad address specification \"%s\"" % spec) - + af, host, port = parse_addr_spec(spec, defhost, defport) try: addrs = socket.getaddrinfo(host, port, af, socket.SOCK_STREAM, socket.IPPROTO_TCP, socket.AI_NUMERICHOST) except socket.gaierror, e:

1 0

[flashproxy/master] Changes I needed to make return_of_the_rtmfpcat.as compile.
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit bbfb3e242a38e789e68a160abf4dede04ffbe3ca Author: David Fifield <david(a)bamsoftware.com> Date: Thu May 26 22:28:00 2011 -0700 Changes I needed to make return_of_the_rtmfpcat.as compile. --- return_of_the_rtmfpcat.as | 14 ++++++-------- 1 files changed, 6 insertions(+), 8 deletions(-) diff --git a/return_of_the_rtmfpcat.as b/return_of_the_rtmfpcat.as index ed582b8..a4ec182 100644 --- a/return_of_the_rtmfpcat.as +++ b/return_of_the_rtmfpcat.as @@ -14,15 +14,13 @@ package import flash.events.ProgressEvent; import flash.events.SecurityErrorEvent; import flash.utils.ByteArray; + import flash.utils.clearTimeout; import flash.utils.setTimeout; import flash.utils.clearInterval; import flash.utils.setInterval; import flash.utils.setTimeout; import flash.net.NetConnection; - import rtmfp.RTMFPSocket; - import rtmfp.events.RTMFPSocketEvent; - public class return_of_the_rtmfpcat extends Sprite { /* David's relay (nickname 3VXRyxz67OeRoqHn) that also serves a @@ -423,11 +421,11 @@ class RTMFPSocket extends EventDispatcher send_stream.publish(DATA); recv_stream = new NetStream(circon, clientID); - var client:RTMFPSocketClient = new RTMFPSocketClient(); - client.addEventListener(ProgressEvent.SOCKET_DATA, function (event:ProgressEvent):void { + var client_rtmfp:RTMFPSocketClient = new RTMFPSocketClient(); + client_rtmfp.addEventListener(ProgressEvent.SOCKET_DATA, function (event:ProgressEvent):void { dispatchEvent(event); }, false, 0, true); - recv_stream.client = client; + recv_stream.client = client_rtmfp; recv_stream.play(DATA); } @@ -469,9 +467,9 @@ class RTMFPSocket extends EventDispatcher } - public function readBytes(bytes:ByteArray):void + public function readBytes(bytes:ByteArray, offset:uint = 0, length:uint = 0):void { - recv_stream.client.bytes.readBytes(bytes); + recv_stream.client.bytes.readBytes(bytes, offset, length); } public function writeBytes(bytes:ByteArray):void

1 0

[flashproxy/master] completed proxy side of the code, untested
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit 57c267849ce64c15a597211c07072414baf2e267 Author: ellitron <jdellit(a)stanford.edu> Date: Thu May 26 18:39:32 2011 -0700 completed proxy side of the code, untested --- return_of_the_rtmfpcat.as | 112 +++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 104 insertions(+), 8 deletions(-) diff --git a/return_of_the_rtmfpcat.as b/return_of_the_rtmfpcat.as index 3958c69..ed582b8 100644 --- a/return_of_the_rtmfpcat.as +++ b/return_of_the_rtmfpcat.as @@ -59,6 +59,9 @@ package /* Maximum connections. */ private const MAXIMUM_RCP_PAIRS:uint = 1; + /* Milliseconds. */ + private const FACILITATOR_POLL_INTERVAL:int = 10000; + /* TextField for debug output. */ private var output_text:TextField; @@ -88,6 +91,9 @@ package /* Number of connected RTMFPConnectionPairs. */ private var rcp_pairs:uint; + /* Keep track of facilitator polling timer. */ + private var fac_poll_timeo_id:uint; + /* Put a string to the screen. */ public function puts(s:String):void { @@ -192,7 +198,7 @@ package clearInterval(circon_timeo_id); if(proxy_mode) { - + poll_for_id(); } else { puts("Setting up listening RTMFPConnectionPair"); var rcp:RTMFPConnectionPair = new RTMFPConnectionPair(circon, tor_addr, output_text); @@ -209,6 +215,43 @@ package } } + private function poll_for_id():void + { + var s_f:Socket = new Socket(); + s_f.addEventListener(Event.CONNECT, function (e:Event):void { + puts("Facilitator: connected to " + fac_addr.host + ":" + fac_addr.port + "."); + s_f.writeUTFBytes("GET / HTTP/1.0\r\n\r\n"); + }); + s_f.addEventListener(Event.CLOSE, function (e:Event):void { + puts("Facilitator: connection closed."); + }); + s_f.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { + puts("Facilitator: I/O error: " + e.text + "."); + }); + s_f.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var clientID:String = s_f.readMultiByte(e.bytesLoaded, "utf-8"); + puts("Facilitator: got \"" + clientID + "\""); + if (clientID != "Registration list empty") { + puts("Connecting to " + clientID + "."); + var rcp:RTMFPConnectionPair = new RTMFPConnectionPair(circon, tor_addr, output_text); + rcp.addEventListener(Event.CONNECT, rcp_connect_event); + rcp.addEventListener(Event.CLOSE, rcp_close_event); + rcp.connect(clientID); + } else { + /* Need to clear any outstanding timers to ensure + * that only one timer ever runs. */ + clearTimeout(fac_poll_timeo_id); + fac_poll_timeo_id = setTimeout(poll_for_id, FACILITATOR_POLL_INTERVAL); + } + }); + s_f.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void { + puts("Facilitator: security error: " + e.text + "."); + }); + + s_f.connect(fac_addr.host, fac_addr.port); + + } + private function rcp_connect_event(e:Event):void { puts("RTMFPConnectionPair connected"); @@ -216,7 +259,9 @@ package rcp_pairs++; if(proxy_mode) { - + if(rcp_pairs < MAXIMUM_RCP_PAIRS) { + poll_for_id(); + } } else { /* Setup listening RTMFPConnectionPair. */ if(rcp_pairs < MAXIMUM_RCP_PAIRS) { @@ -237,6 +282,19 @@ package /* FIXME: Do I need to unregister the event listeners so * that the system can garbage collect the rcp object? */ + if(proxy_mode) { + if(rcp_pairs < MAXIMUM_RCP_PAIRS) { + poll_for_id(); + } + } else { + if(rcp_pairs < MAXIMUM_RCP_PAIRS) { + puts("Setting up listening RTMFPConnectionPair"); + var rcp:RTMFPConnectionPair = new RTMFPConnectionPair(circon, tor_addr, output_text); + rcp.addEventListener(Event.CONNECT, rcp_connect_event); + rcp.addEventListener(Event.CLOSE, rcp_close_event); + rcp.listen(); + } + } } private function register_id(id:String, fac_addr:Object):void @@ -349,6 +407,30 @@ class RTMFPSocket extends EventDispatcher send_stream.publish(DATA); } + public function connect(clientID:String):void + { + puts("RTMFPSocket: connecting to peer..."); + + send_stream = new NetStream(circon, NetStream.DIRECT_CONNECTIONS); + var client:Object = new Object(); + client.onPeerConnect = function (peer:NetStream):Boolean { + puts("RTMFPSocket: connected to peer"); + connected = true; + dispatchEvent(new Event(Event.CONNECT)); + return true; + }; + send_stream.client = client; + send_stream.publish(DATA); + + recv_stream = new NetStream(circon, clientID); + var client:RTMFPSocketClient = new RTMFPSocketClient(); + client.addEventListener(ProgressEvent.SOCKET_DATA, function (event:ProgressEvent):void { + dispatchEvent(event); + }, false, 0, true); + recv_stream.client = client; + recv_stream.play(DATA); + } + private function send_stream_peer_connect(peer:NetStream):Boolean { puts("RTMFPSocket: peer connecting..."); @@ -483,6 +565,14 @@ class RTMFPConnectionPair extends EventDispatcher this.output_text = output_text; } + public function connect(clientID:String):void + { + s_r = new RTMFPSocket(circon, output_text); + s_r.addEventListener(Event.CONNECT, rtmfp_connect_event); + s_r.addEventListener(Event.CLOSE, rtmfp_close_event); + s_r.connect(clientID); + } + public function listen():void { s_r = new RTMFPSocket(circon, output_text); @@ -500,6 +590,18 @@ class RTMFPConnectionPair extends EventDispatcher s_t = new Socket(); s_t.addEventListener(Event.CONNECT, function (e:Event):void { puts("RTMFPConnectionPair: Tor: connected to " + tor_addr.host + ":" + tor_addr.port + "."); + s_r.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var bytes:ByteArray = new ByteArray(); + s_r.readBytes(bytes, 0, e.bytesLoaded); + puts("RTMFPConnectionPair: RTMFP: read " + bytes.length + " bytes."); + s_t.writeBytes(bytes); + }); + s_t.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var bytes:ByteArray = new ByteArray(); + s_t.readBytes(bytes, 0, e.bytesLoaded); + puts("RTMFPConnectionPair: Tor: read " + bytes.length + " bytes."); + s_r.writeBytes(bytes); + }); dispatchEvent(new Event(Event.CONNECT)); }); s_t.addEventListener(Event.CLOSE, function (e:Event):void { @@ -513,12 +615,6 @@ class RTMFPConnectionPair extends EventDispatcher s_t.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { puts("RTMFPConnectionPair: Tor: I/O error: " + e.text + "."); }); - s_t.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { - var bytes:ByteArray = new ByteArray(); - s_t.readBytes(bytes, 0, e.bytesLoaded); - puts("RTMFPConnectionPair: Tor: read " + bytes.length + " bytes."); - s_r.writeBytes(bytes); - }); s_t.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void { puts("RTMFPConnectionPair: Tor: security error: " + e.text + "."); });

1 0

[flashproxy/master] Added lots of code to make connection pairs and connect to the connector and so on...
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit e1784683cccccf352ffd7d6d273085b3890079e8 Author: ellitron <jdellit(a)stanford.edu> Date: Thu May 26 13:55:55 2011 -0700 Added lots of code to make connection pairs and connect to the connector and so on... --- return_of_the_rtmfpcat.as | 163 ++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 153 insertions(+), 10 deletions(-) diff --git a/return_of_the_rtmfpcat.as b/return_of_the_rtmfpcat.as index 9ecc61f..8436f1a 100644 --- a/return_of_the_rtmfpcat.as +++ b/return_of_the_rtmfpcat.as @@ -50,6 +50,9 @@ package private static const DEFAULT_CIRCON_TIMEOUT:uint = 4000; + /* Maximum connections. */ + private const MAXIMUM_RCP_PAIRS:uint = 1; + /* TextField for debug output. */ private var output_text:TextField; @@ -76,8 +79,8 @@ package /* Cirrus connection timeout ID. */ private var circon_timeo_id:int; - /* Array of connection pairs */ - private var con_pairs:Array; + /* Number of connected RTMFPConnectionPairs. */ + private var rcp_pairs:uint; /* Put a string to the screen. */ public function puts(s:String):void @@ -99,6 +102,9 @@ package output_text.backgroundColor = 0x001f0f; output_text.textColor = 0x44cc44; + /* Initialize connection pair count. */ + rcp_pairs = 0; + puts("Meow!"); puts("Starting."); // Wait until the query string parameters are loaded. @@ -182,11 +188,13 @@ package if(proxy_mode) { } else { - /* Listen for incoming RTMFP connections. */ - var s_r:RTMFPSocket = new RTMFPSocket(circon); - s_r.addEventListener(Event.CONNECT, rtmfp_connect_event); - s_r.listen(); + puts("Setting up listening RTMFPConnectionPair"); + var rcp:RTMFPConnectionPair = new RTMFPConnectionPair(circon, tor_addr, output_text); + rcp.addEventListener(Event.CONNECT, rcp_connect_event); + rcp.addEventListener(Event.CLOSE, rcp_close_event); + rcp.listen(); + puts("Registering with facilitator"); /* Register ID with facilitator. */ register_id(circon.nearID, fac_addr); } @@ -207,9 +215,34 @@ package } } - private function rtmfp_connect_event(e:Event):void + private function rcp_connect_event(e:Event):void + { + puts("RTMFPConnectionPair connected"); + + rcp_pairs++; + + if(proxy_mode) { + + } else { + /* Setup listening RTMFPConnectionPair. */ + if(rcp_pairs < MAXIMUM_RCP_PAIRS) { + puts("Setting up listening RTMFPConnectionPair"); + var rcp:RTMFPConnectionPair = new RTMFPConnectionPair(circon, tor_addr, output_text); + rcp.addEventListener(Event.CONNECT, rcp_connect_event); + rcp.addEventListener(Event.CLOSE, rcp_close_event); + rcp.listen(); + } + } + } + + private function rcp_close_event(e:Event):void { - puts("VICTORY!"); + puts("RTMFPConnectionPair closed"); + + rcp_pairs--; + + /* FIXME: Do I need to unregister the event listeners so + * that the system can garbage collect the rcp object? */ } private function register_id(id:String, fac_addr:Object):void @@ -270,6 +303,7 @@ import flash.utils.getTimer; import flash.utils.setTimeout; import flash.net.NetConnection; import flash.net.NetStream; +import flash.text.TextField; class RTMFPSocket extends EventDispatcher { @@ -284,9 +318,23 @@ class RTMFPSocket extends EventDispatcher private var send_stream:NetStream; private var recv_stream:NetStream; - public function RTMFPSocket(circon:NetConnection) + /* Keeps the state of our connectedness. */ + public var connected:Boolean; + + private var output_text:TextField; + + /* Put a string to the screen. */ + public function puts(s:String):void + { + output_text.appendText(s + "\n"); + output_text.scrollV = output_text.maxScrollV; + } + + public function RTMFPSocket(circon:NetConnection, output_text:TextField) { this.circon = circon; + this.output_text = output_text; + connected = false; } public function listen():void @@ -300,12 +348,15 @@ class RTMFPSocket extends EventDispatcher private function send_stream_peer_connect(peer:NetStream):Boolean { + puts("RTMFPSocket: peer connecting..."); recv_stream = new NetStream(circon, peer.farID); var client:RTMFPSocketClient = new RTMFPSocketClient(); client.addEventListener(ProgressEvent.SOCKET_DATA, function (event:ProgressEvent):void { dispatchEvent(event); }, false, 0, true); client.addEventListener(RTMFPSocketClient.PEER_CONNECT_ACKNOWLEDGED, function (event:Event):void { + puts("RTMFPSocket: peer connected"); + connected = true; dispatchEvent(new Event(Event.CONNECT)); }, false, 0, true); recv_stream.client = client; @@ -314,7 +365,23 @@ class RTMFPSocket extends EventDispatcher return true; } + public function readBytes(bytes:ByteArray):void + { + recv_stream.client.bytes.readBytes(bytes); + } + + public function writeBytes(bytes:ByteArray):void + { + send_stream.send("dataAvailable", bytes); + } + public function close():void + { + puts("RTMFPSocket: closing..."); + send_stream.close(); + recv_stream.close(); + connected = false; + } } dynamic class RTMFPSocketClient extends EventDispatcher @@ -368,7 +435,83 @@ dynamic class RTMFPSocketClient extends EventDispatcher } -class ConnectionPair extends EventDispatcher +class RTMFPConnectionPair extends EventDispatcher { + private var circon:NetConnection; + + private var tor_addr:Object; + + private var s_r:RTMFPSocket; + + private var s_t:Socket; + + private var output_text:TextField; + + /* Put a string to the screen. */ + public function puts(s:String):void + { + output_text.appendText(s + "\n"); + output_text.scrollV = output_text.maxScrollV; + } + + public function RTMFPConnectionPair(circon:NetConnection, tor_addr:Object, output_text:TextField) + { + this.circon = circon; + this.tor_addr = tor_addr; + this.output_text = output_text; + } + + public function listen():void + { + s_r = new RTMFPSocket(circon, output_text); + s_r.addEventListener(Event.CONNECT, rtmfp_connect_event); + s_r.addEventListener(Event.CLOSE, rtmfp_close_event); + s_r.listen(); + } + + private function rtmfp_connect_event(e:Event):void + { + puts("RTMFPConnectionPair: RTMFPSocket connected!"); + puts("RTMFPConnectionPair: setting up tor connection..."); + + /* Setup tor connection linked to RTMFPSocket. */ + s_t = new Socket(); + s_t.addEventListener(Event.CONNECT, function (e:Event):void { + puts("RTMFPConnectionPair: Tor: connected to " + tor_addr.host + ":" + tor_addr.port + "."); + dispatchEvent(new Event(Event.CONNECT)); + }); + s_t.addEventListener(Event.CLOSE, function (e:Event):void { + puts("RTMFPConnectionPair: Tor: closed connection."); + /* Close other side of connection pair if it is open and + * dispatch close event. */ + if(s_r.connected) + s_r.close(); + dispatchEvent(new Event(Event.CLOSE)); + }); + s_t.addEventListener(IOErrorEvent.IO_ERROR, function (e:IOErrorEvent):void { + puts("RTMFPConnectionPair: Tor: I/O error: " + e.text + "."); + }); + s_t.addEventListener(ProgressEvent.SOCKET_DATA, function (e:ProgressEvent):void { + var bytes:ByteArray = new ByteArray(); + s_t.readBytes(bytes, 0, e.bytesLoaded); + puts("RTMFPConnectionPair: Tor: read " + bytes.length + " bytes."); + s_r.writeBytes(bytes); + }); + s_t.addEventListener(SecurityErrorEvent.SECURITY_ERROR, function (e:SecurityErrorEvent):void { + puts("RTMFPConnectionPair: Tor: security error: " + e.text + "."); + }); + + s_t.connect(tor_addr.host, tor_addr.port); + } + + private function rtmfp_close_event(e:Event):void + { + puts("RTMFPConnectionPair: RTMFPSocket closed connection"); + /* Close other side of connection pair if it is open and dispatch + * close event. */ + if(s_t.connected) + s_t.close(); + dispatchEvent(new Event(Event.CLOSE)); + } }

1 0

[flashproxy/master] Merge branch 'master' into rtmfp
by dcf＠torproject.org 12 Jun '11

12 Jun '11

commit 9b43d64be7a6b6d11f33a632030dfc020dc8f0ac Merge: 57c2678 8cac767 Author: David Fifield <david(a)bamsoftware.com> Date: Thu May 26 22:11:17 2011 -0700 Merge branch 'master' into rtmfp Conflicts: README swfcat.as README | 4 +- connector.py | 89 +++++++++++++++++++++------------------ swfcat.as | 53 +++++++++++++++--------- tor-ignore-bridge-failure.diff | 19 ++++++++ 4 files changed, 102 insertions(+), 63 deletions(-) diff --cc README index 17fadf5,067f92e..afae925 --- a/README +++ b/README @@@ -39,16 -29,14 +39,16 @@@ Download the (free software) Flex SDK Put its bin directory in your PATH. The important executable is mxmlc. To build, run $ make -Copy the resulting swfcat.swf file to a web server. +Copy the resulting rtmfpcat.swf file to a web server. On the computer that will be the facilitator, run - sudo ./crossdomaind.py - ./facilitator.py + sudo ./crossdomaind.py + ./facilitator.py crossdomaind.py needs to be run on any server that will accept connections from a Flash proxy. It serves a chunk of data on port 843. -The facilitator runs on port 9002 by default. +The facilitator runs on port 9002 by default. Note that this is a different +facilitator script than the swfcat one, since this facilitator needs to +deal with Cirrus client IDs instead of ip:port tuples. The client needs to be running a version of Tor that supports the Socks4Proxy configuration. This means version 0.2.2.1-alpha or

1 0