| /* |
| 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; |
| |
