--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/mod_tcpproxy/web/xmpp.io.js	Tue Apr 13 04:52:15 2010 +0100
@@ -0,0 +1,84 @@
+var xmlns_ibb = "http://jabber.org/protocol/ibb";
+var xmlns_tcp = "http://prosody.im/protocol/tcpproxy";
+
+function XMPPIO(xmppconn, xmpptcp_host)
+{
+	this.xmppconn = xmppconn;
+	this.xmpphost = xmpptcp_host;
+	this.sid = "FIXME";
+	
+	this.listeners = [];
+	return this;
+}
+
+XMPPIO.prototype = {
+	connect: function (host, port)
+	{
+		var conn = this;
+		console.log("Connecting...");
+
+		function onConnect()
+		{
+			this.xmppconn.addHandler(function (stanza)
+			{
+				var data = stanza.getElementsByTagName("data")[0];
+				if(data)
+					conn.emit("data", Strophe.Base64.decode(Strophe.getText(data)));
+			}, null, "message", null, null, this.xmpphost, {});
+			this.xmppconn.addHandler(function (stanza)
+			{
+				var data = stanza.getElementsByTagName("close")[0];
+				if(close)
+				{
+					conn.write = function () { throw "Connection closed"; };
+					conn.emit("end");
+				}
+			}, xmlns_ibb, "iq", "set", null, this.xmpphost, {});
+			conn.emit("connect");
+		}
+
+		this.xmppconn.sendIQ($iq({to:this.xmpphost,type:"set"})
+			.c("open", {
+				"xmlns": xmlns_ibb,
+				"xmlns:tcp": xmlns_tcp,
+				"tcp:host": host,
+				"tcp:port": port.toString(),
+				"block-size": "4096",
+				"sid": this.sid.toString(),
+				"stanza": "message"
+			}), onConnect,
+			function () { conn.emit("error"); });
+	},
+	emit: function ()
+	{
+		console.log("xmpp.io: Emitting "+arguments[0]);
+		var args = Array.prototype.slice.call(arguments, 1);
+		var listeners = this.listeners[arguments[0]];
+		if(listeners)
+		{
+			for(var i=0;i<listeners.length;i++)
+			{
+				listeners[i][1].apply(listeners[i][0], args);
+			}
+		}
+	},
+	addListener: function (event, method, obj)
+	{
+		if(typeof(obj)=="undefined")
+			obj = this;
+		if(!(event in this.listeners))
+			this.listeners[event] = [];
+		this.listeners[event].push([obj, method]);
+	},
+	write: function (data)
+	{
+		return this.xmppconn.send($msg({to:this.xmpphost})
+			.c("data", {xmlns:xmlns_ibb, sid:this.sid.toString()})
+				.t(Strophe.Base64.encode(data)));
+	},
+	end: function ()
+	{
+		return this.xmppconn.send($iq({to:this.xmpphost})
+			.c("close", {xmlns:xmlns_ibb, sid:this.sid.toString()}));
+	}
+};