Subversion Repositories Applications.papyrus

/*

	Copyright (c) 2004-2006, The Dojo Foundation

	All Rights Reserved.

	Licensed under the Academic Free License version 2.1 or above OR the

	modified BSD license. For more information on Dojo licensing, see:

		http://dojotoolkit.org/community/licensing.shtml

*/

dojo.require("dojo.io.common");

dojo.provide("dojo.io.cometd");

dojo.require("dojo.AdapterRegistry");

dojo.require("dojo.json");

dojo.require("dojo.io.BrowserIO");

dojo.require("dojo.io.IframeIO");

dojo.require("dojo.io.ScriptSrcIO");

dojo.require("dojo.io.cookie");

dojo.require("dojo.event.*");

dojo.require("dojo.lang.common");

dojo.require("dojo.lang.func");

cometd = new function () {

	this.initialized = false;

	this.connected = false;

	this.connectionTypes = new dojo.AdapterRegistry(true);

	this.version = 0.1;

	this.minimumVersion = 0.1;

	this.clientId = null;

	this._isXD = false;

	this.handshakeReturn = null;

	this.currentTransport = null;

	this.url = null;

	this.lastMessage = null;

	this.globalTopicChannels = {};

	this.backlog = [];

	this.tunnelInit = function (childLocation, childDomain) {

	};

	this.tunnelCollapse = function () {

		dojo.debug("tunnel collapsed!");

	};

	this.init = function (props, root, bargs) {

		props = props || {};

		props.version = this.version;

		props.minimumVersion = this.minimumVersion;

		props.channel = "/meta/handshake";

		this.url = root || djConfig["cometdRoot"];

		if (!this.url) {

			dojo.debug("no cometd root specified in djConfig and no root passed");

			return;

		}

		var bindArgs = {url:this.url, method:"POST", mimetype:"text/json", load:dojo.lang.hitch(this, "finishInit"), content:{"message":dojo.json.serialize([props])}};

		var regexp = "^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\\?([^#]*))?(#(.*))?$";

		var r = ("" + window.location).match(new RegExp(regexp));

		if (r[4]) {

			var tmp = r[4].split(":");

			var thisHost = tmp[0];

			var thisPort = tmp[1] || "80";

			r = this.url.match(new RegExp(regexp));

			if (r[4]) {

				tmp = r[4].split(":");

				var urlHost = tmp[0];

				var urlPort = tmp[1] || "80";

				if ((urlHost != thisHost) || (urlPort != thisPort)) {

					dojo.debug(thisHost, urlHost);

					dojo.debug(thisPort, urlPort);

					this._isXD = true;

					bindArgs.transport = "ScriptSrcTransport";

					bindArgs.jsonParamName = "jsonp";

					bindArgs.method = "GET";

				}

			}

		}

		if (bargs) {

			dojo.lang.mixin(bindArgs, bargs);

		}

		return dojo.io.bind(bindArgs);

	};

	this.finishInit = function (type, data, evt, request) {

		data = data[0];

		this.handshakeReturn = data;

		if (data["authSuccessful"] == false) {

			dojo.debug("cometd authentication failed");

			return;

		}

		if (data.version < this.minimumVersion) {

			dojo.debug("cometd protocol version mismatch. We wanted", this.minimumVersion, "but got", data.version);

			return;

		}

		this.currentTransport = this.connectionTypes.match(data.supportedConnectionTypes, data.version, this._isXD);

		this.currentTransport.version = data.version;

		this.clientId = data.clientId;

		this.tunnelInit = dojo.lang.hitch(this.currentTransport, "tunnelInit");

		this.tunnelCollapse = dojo.lang.hitch(this.currentTransport, "tunnelCollapse");

		this.initialized = true;

		this.currentTransport.startup(data);

		while (this.backlog.length != 0) {

			var cur = this.backlog.shift();

			var fn = cur.shift();

			this[fn].apply(this, cur);

		}

	};

	this._getRandStr = function () {

		return Math.random().toString().substring(2, 10);

	};

	this.deliver = function (messages) {

		dojo.lang.forEach(messages, this._deliver, this);

	};

	this._deliver = function (message) {

		if (!message["channel"]) {

			dojo.debug("cometd error: no channel for message!");

			return;

		}

		if (!this.currentTransport) {

			this.backlog.push(["deliver", message]);

			return;

		}

		this.lastMessage = message;

		if ((message.channel.length > 5) && (message.channel.substr(0, 5) == "/meta")) {

			switch (message.channel) {

			  case "/meta/subscribe":

				if (!message.successful) {

					dojo.debug("cometd subscription error for channel", message.channel, ":", message.error);

					return;

				}

				this.subscribed(message.subscription, message);

				break;

			  case "/meta/unsubscribe":

				if (!message.successful) {

					dojo.debug("cometd unsubscription error for channel", message.channel, ":", message.error);

					return;

				}

				this.unsubscribed(message.subscription, message);

				break;

			}

		}

		this.currentTransport.deliver(message);

		if (message.data) {

			var tname = (this.globalTopicChannels[message.channel]) ? message.channel : "/cometd" + message.channel;

			dojo.event.topic.publish(tname, message);

		}

	};

	this.disconnect = function () {

		if (!this.currentTransport) {

			dojo.debug("no current transport to disconnect from");

			return;

		}

		this.currentTransport.disconnect();

	};

	this.publish = function (channel, data, properties) {

		if (!this.currentTransport) {

			this.backlog.push(["publish", channel, data, properties]);

			return;

		}

		var message = {data:data, channel:channel};

		if (properties) {

			dojo.lang.mixin(message, properties);

		}

		return this.currentTransport.sendMessage(message);

	};

	this.subscribe = function (channel, useLocalTopics, objOrFunc, funcName) {

		if (!this.currentTransport) {

			this.backlog.push(["subscribe", channel, useLocalTopics, objOrFunc, funcName]);

			return;

		}

		if (objOrFunc) {

			var tname = (useLocalTopics) ? channel : "/cometd" + channel;

			if (useLocalTopics) {

				this.globalTopicChannels[channel] = true;

			}

			dojo.event.topic.subscribe(tname, objOrFunc, funcName);

		}

		return this.currentTransport.sendMessage({channel:"/meta/subscribe", subscription:channel});

	};

	this.subscribed = function (channel, message) {

		dojo.debug(channel);

		dojo.debugShallow(message);

	};

	this.unsubscribe = function (channel, useLocalTopics, objOrFunc, funcName) {

		if (!this.currentTransport) {

			this.backlog.push(["unsubscribe", channel, useLocalTopics, objOrFunc, funcName]);

			return;

		}

		if (objOrFunc) {

			var tname = (useLocalTopics) ? channel : "/cometd" + channel;

			dojo.event.topic.unsubscribe(tname, objOrFunc, funcName);

		}

		return this.currentTransport.sendMessage({channel:"/meta/unsubscribe", subscription:channel});

	};

	this.unsubscribed = function (channel, message) {

		dojo.debug(channel);

		dojo.debugShallow(message);

	};

};

cometd.iframeTransport = new function () {

	this.connected = false;

	this.connectionId = null;

	this.rcvNode = null;

	this.rcvNodeName = "";

	this.phonyForm = null;

	this.authToken = null;

	this.lastTimestamp = null;

	this.lastId = null;

	this.backlog = [];

	this.check = function (types, version, xdomain) {

		return ((!xdomain) && (!dojo.render.html.safari) && (dojo.lang.inArray(types, "iframe")));

	};

	this.tunnelInit = function () {

		this.postToIframe({message:dojo.json.serialize([{channel:"/meta/connect", clientId:cometd.clientId, connectionType:"iframe"}])});

	};

	this.tunnelCollapse = function () {

		if (this.connected) {

			this.connected = false;

			this.postToIframe({message:dojo.json.serialize([{channel:"/meta/reconnect", clientId:cometd.clientId, connectionId:this.connectionId, timestamp:this.lastTimestamp, id:this.lastId}])});

		}

	};

	this.deliver = function (message) {

		if (message["timestamp"]) {

			this.lastTimestamp = message.timestamp;

		}

		if (message["id"]) {

			this.lastId = message.id;

		}

		if ((message.channel.length > 5) && (message.channel.substr(0, 5) == "/meta")) {

			switch (message.channel) {

			  case "/meta/connect":

				if (!message.successful) {

					dojo.debug("cometd connection error:", message.error);

					return;

				}

				this.connectionId = message.connectionId;

				this.connected = true;

				this.processBacklog();

				break;

			  case "/meta/reconnect":

				if (!message.successful) {

					dojo.debug("cometd reconnection error:", message.error);

					return;

				}

				this.connected = true;

				break;

			  case "/meta/subscribe":

				if (!message.successful) {

					dojo.debug("cometd subscription error for channel", message.channel, ":", message.error);

					return;

				}

				dojo.debug(message.channel);

				break;

			}

		}

	};

	this.widenDomain = function (domainStr) {

		var cd = domainStr || document.domain;

		if (cd.indexOf(".") == -1) {

			return;

		}

		var dps = cd.split(".");

		if (dps.length <= 2) {

			return;

		}

		dps = dps.slice(dps.length - 2);

		document.domain = dps.join(".");

		return document.domain;

	};

	this.postToIframe = function (content, url) {

		if (!this.phonyForm) {

			if (dojo.render.html.ie) {

				this.phonyForm = document.createElement("<form enctype='application/x-www-form-urlencoded' method='POST' style='display: none;'>");

				dojo.body().appendChild(this.phonyForm);

			} else {

				this.phonyForm = document.createElement("form");

				this.phonyForm.style.display = "none";

				dojo.body().appendChild(this.phonyForm);

				this.phonyForm.enctype = "application/x-www-form-urlencoded";

				this.phonyForm.method = "POST";

			}

		}

		this.phonyForm.action = url || cometd.url;

		this.phonyForm.target = this.rcvNodeName;

		this.phonyForm.setAttribute("target", this.rcvNodeName);

		while (this.phonyForm.firstChild) {

			this.phonyForm.removeChild(this.phonyForm.firstChild);

		}

		for (var x in content) {

			var tn;

			if (dojo.render.html.ie) {

				tn = document.createElement("<input type='hidden' name='" + x + "' value='" + content[x] + "'>");

				this.phonyForm.appendChild(tn);

			} else {

				tn = document.createElement("input");

				this.phonyForm.appendChild(tn);

				tn.type = "hidden";

				tn.name = x;

				tn.value = content[x];

			}

		}

		this.phonyForm.submit();

	};

	this.processBacklog = function () {

		while (this.backlog.length > 0) {

			this.sendMessage(this.backlog.shift(), true);

		}

	};

	this.sendMessage = function (message, bypassBacklog) {

		if ((bypassBacklog) || (this.connected)) {

			message.connectionId = this.connectionId;

			message.clientId = cometd.clientId;

			var bindArgs = {url:cometd.url || djConfig["cometdRoot"], method:"POST", mimetype:"text/json", content:{message:dojo.json.serialize([message])}};

			return dojo.io.bind(bindArgs);

		} else {

			this.backlog.push(message);

		}

	};

	this.startup = function (handshakeData) {

		dojo.debug("startup!");

		dojo.debug(dojo.json.serialize(handshakeData));

		if (this.connected) {

			return;

		}

		this.rcvNodeName = "cometdRcv_" + cometd._getRandStr();

		var initUrl = cometd.url + "/?tunnelInit=iframe";

		if (false && dojo.render.html.ie) {

			this.rcvNode = new ActiveXObject("htmlfile");

			this.rcvNode.open();

			this.rcvNode.write("<html>");

			this.rcvNode.write("<script>document.domain = '" + document.domain + "'");

			this.rcvNode.write("</html>");

			this.rcvNode.close();

			var ifrDiv = this.rcvNode.createElement("div");

			this.rcvNode.appendChild(ifrDiv);

			this.rcvNode.parentWindow.dojo = dojo;

			ifrDiv.innerHTML = "<iframe src='" + initUrl + "'></iframe>";

		} else {

			this.rcvNode = dojo.io.createIFrame(this.rcvNodeName, "", initUrl);

		}

	};

};

cometd.mimeReplaceTransport = new function () {

	this.connected = false;

	this.connectionId = null;

	this.xhr = null;

	this.authToken = null;

	this.lastTimestamp = null;

	this.lastId = null;

	this.backlog = [];

	this.check = function (types, version, xdomain) {

		return ((!xdomain) && (dojo.render.html.mozilla) && (dojo.lang.inArray(types, "mime-message-block")));

	};

	this.tunnelInit = function () {

		if (this.connected) {

			return;

		}

		this.openTunnelWith({message:dojo.json.serialize([{channel:"/meta/connect", clientId:cometd.clientId, connectionType:"mime-message-block"}])});

		this.connected = true;

	};

	this.tunnelCollapse = function () {

		if (this.connected) {

			this.connected = false;

			this.openTunnelWith({message:dojo.json.serialize([{channel:"/meta/reconnect", clientId:cometd.clientId, connectionId:this.connectionId, timestamp:this.lastTimestamp, id:this.lastId}])});

		}

	};

	this.deliver = cometd.iframeTransport.deliver;

	this.handleOnLoad = function (resp) {

		cometd.deliver(dojo.json.evalJson(this.xhr.responseText));

	};

	this.openTunnelWith = function (content, url) {

		this.xhr = dojo.hostenv.getXmlhttpObject();

		this.xhr.multipart = true;

		if (dojo.render.html.mozilla) {

			this.xhr.addEventListener("load", dojo.lang.hitch(this, "handleOnLoad"), false);

		} else {

			if (dojo.render.html.safari) {

				dojo.debug("Webkit is broken with multipart responses over XHR = (");

				this.xhr.onreadystatechange = dojo.lang.hitch(this, "handleOnLoad");

			} else {

				this.xhr.onload = dojo.lang.hitch(this, "handleOnLoad");

			}

		}

		this.xhr.open("POST", (url || cometd.url), true);

		this.xhr.setRequestHeader("Content-Type", "application/x-www-form-urlencoded");

		dojo.debug(dojo.json.serialize(content));

		this.xhr.send(dojo.io.argsFromMap(content, "utf8"));

	};

	this.processBacklog = function () {

		while (this.backlog.length > 0) {

			this.sendMessage(this.backlog.shift(), true);

		}

	};

	this.sendMessage = function (message, bypassBacklog) {

		if ((bypassBacklog) || (this.connected)) {

			message.connectionId = this.connectionId;

			message.clientId = cometd.clientId;

			var bindArgs = {url:cometd.url || djConfig["cometdRoot"], method:"POST", mimetype:"text/json", content:{message:dojo.json.serialize([message])}};

			return dojo.io.bind(bindArgs);

		} else {

			this.backlog.push(message);

		}

	};

	this.startup = function (handshakeData) {

		dojo.debugShallow(handshakeData);

		if (this.connected) {

			return;

		}

		this.tunnelInit();

	};

};

cometd.longPollTransport = new function () {

	this.connected = false;

	this.connectionId = null;

	this.authToken = null;

	this.lastTimestamp = null;

	this.lastId = null;

	this.backlog = [];

	this.check = function (types, version, xdomain) {

		return ((!xdomain) && (dojo.lang.inArray(types, "long-polling")));

	};

	this.tunnelInit = function () {

		if (this.connected) {

			return;

		}

		this.openTunnelWith({message:dojo.json.serialize([{channel:"/meta/connect", clientId:cometd.clientId, connectionType:"long-polling"}])});

		this.connected = true;

	};

	this.tunnelCollapse = function () {

		if (!this.connected) {

			this.connected = false;

			dojo.debug("clientId:", cometd.clientId);

			this.openTunnelWith({message:dojo.json.serialize([{channel:"/meta/reconnect", connectionType:"long-polling", clientId:cometd.clientId, connectionId:this.connectionId, timestamp:this.lastTimestamp, id:this.lastId}])});

		}

	};

	this.deliver = cometd.iframeTransport.deliver;

	this.openTunnelWith = function (content, url) {

		dojo.io.bind({url:(url || cometd.url), method:"post", content:content, mimetype:"text/json", load:dojo.lang.hitch(this, function (type, data, evt, args) {

			cometd.deliver(data);

			this.connected = false;

			this.tunnelCollapse();

		}), error:function () {

			dojo.debug("tunnel opening failed");

		}});

		this.connected = true;

	};

	this.processBacklog = function () {

		while (this.backlog.length > 0) {

			this.sendMessage(this.backlog.shift(), true);

		}

	};

	this.sendMessage = function (message, bypassBacklog) {

		if ((bypassBacklog) || (this.connected)) {

			message.connectionId = this.connectionId;

			message.clientId = cometd.clientId;

			var bindArgs = {url:cometd.url || djConfig["cometdRoot"], method:"post", mimetype:"text/json", content:{message:dojo.json.serialize([message])}, load:dojo.lang.hitch(this, function (type, data, evt, args) {

				cometd.deliver(data);

			})};

			return dojo.io.bind(bindArgs);

		} else {

			this.backlog.push(message);

		}

	};

	this.startup = function (handshakeData) {

		if (this.connected) {

			return;

		}

		this.tunnelInit();

	};

};

cometd.callbackPollTransport = new function () {

	this.connected = false;

	this.connectionId = null;

	this.authToken = null;

	this.lastTimestamp = null;

	this.lastId = null;

	this.backlog = [];

	this.check = function (types, version, xdomain) {

		return dojo.lang.inArray(types, "callback-polling");

	};

	this.tunnelInit = function () {

		if (this.connected) {

			return;

		}

		this.openTunnelWith({message:dojo.json.serialize([{channel:"/meta/connect", clientId:cometd.clientId, connectionType:"callback-polling"}])});

		this.connected = true;

	};

	this.tunnelCollapse = function () {

		if (!this.connected) {

			this.connected = false;

			this.openTunnelWith({message:dojo.json.serialize([{channel:"/meta/reconnect", connectionType:"long-polling", clientId:cometd.clientId, connectionId:this.connectionId, timestamp:this.lastTimestamp, id:this.lastId}])});

		}

	};

	this.deliver = cometd.iframeTransport.deliver;

	this.openTunnelWith = function (content, url) {

		var req = dojo.io.bind({url:(url || cometd.url), content:content, mimetype:"text/json", transport:"ScriptSrcTransport", jsonParamName:"jsonp", load:dojo.lang.hitch(this, function (type, data, evt, args) {

			cometd.deliver(data);

			this.connected = false;

			this.tunnelCollapse();

		}), error:function () {

			dojo.debug("tunnel opening failed");

		}});

		this.connected = true;

	};

	this.processBacklog = function () {

		while (this.backlog.length > 0) {

			this.sendMessage(this.backlog.shift(), true);

		}

	};

	this.sendMessage = function (message, bypassBacklog) {

		if ((bypassBacklog) || (this.connected)) {

			message.connectionId = this.connectionId;

			message.clientId = cometd.clientId;

			var bindArgs = {url:cometd.url || djConfig["cometdRoot"], mimetype:"text/json", transport:"ScriptSrcTransport", jsonParamName:"jsonp", content:{message:dojo.json.serialize([message])}, load:dojo.lang.hitch(this, function (type, data, evt, args) {

				cometd.deliver(data);

			})};

			return dojo.io.bind(bindArgs);

		} else {

			this.backlog.push(message);

		}

	};

	this.startup = function (handshakeData) {

		if (this.connected) {

			return;

		}

		this.tunnelInit();

	};

};

cometd.connectionTypes.register("mime-message-block", cometd.mimeReplaceTransport.check, cometd.mimeReplaceTransport);

cometd.connectionTypes.register("long-polling", cometd.longPollTransport.check, cometd.longPollTransport);

cometd.connectionTypes.register("callback-polling", cometd.callbackPollTransport.check, cometd.callbackPollTransport);

cometd.connectionTypes.register("iframe", cometd.iframeTransport.check, cometd.iframeTransport);

dojo.io.cometd = cometd;