|
Struts example source code file (cometd.js)
The Struts cometd.js source code/* 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 + "'>"; } 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; Other Struts examples (source code examples)Here is a short list of links related to this Struts cometd.js source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.