New file |
0,0 → 1,528 |
/* |
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; |
|