view mod_tcpproxy/web/xmpp.io.js @ 2670:6e01878103c0

mod_smacks: Ignore user when writing or reading session_cache on prosody 0.9 At least under some circumstances it seems that session.username is nil when a user tries to resume his session in prosody 0.9. The username is not relevant when no limiting is done (limiting the number of entries in the session cache is only possible in prosody 0.10), so this commit removes the usage of the username when accessing the prosody 0.9 session cache.
author tmolitor <thilo@eightysoft.de>
date Thu, 06 Apr 2017 02:12:14 +0200
parents 7dbde05b48a9
children
line wrap: on
line source

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()}));
	}
};