// Stilts stomp-client.js 0.1.38
// Some parts (c) 2010 Jeff Mesnil -- http://jmesnil.net/
// 0.1.38
var Stomp = {
Headers: {
HOST : 'host',
CONTENT_LENGTH : 'content-length',
CONTENT_TYPE : 'content-type',
ACCEPT_VERSION : 'accept-version',
VERSION : 'version'
},
Transport: {
},
Transports: [],
unmarshal: function(data) {
var divider = data.search(/\n\n/);
var headerLines = data.substring(0, divider).split('\n');
var command = headerLines.shift(), headers = {}, body = '';
// Parse headers
var line = idx = null;
for ( var i = 0; i < headerLines.length; i++) {
line = '' + headerLines[i];
idx = line.indexOf(':');
headers[line.substring(0, idx).trim()] = line.substring(idx + 1).trim();
}
try {
if (headers[Stomp.Headers.CONTENT_LENGTH]) {
var len = parseInt( headers[Stomp.Headers.CONTENT_LENGTH] );
var start = divider + 2;
body = (''+ data).substring(start, start+len);
} else {
// Parse body, stopping at the first \0 found.
var chr = null;
for ( var i = divider + 2; i < data.length; i++) {
chr = data.charAt(i);
if (chr === '\0') {
break;
}
body += chr;
}
}
return Stomp.frame(command, headers, body);
} catch (err) {
return Stomp.frame('ERROR', headers, "Error parsing frame: " + err.description);
}
},
marshal: function(command, headers, body) {
var frame = Stomp.frame(command, headers, body);
return frame.toString() + '\0';
},
frame: function(command, headers, body) {
return {
command : command,
headers : headers,
body : body,
toString : function() {
var out = command + '\n';
if (headers) {
for (header in headers) {
if (headers.hasOwnProperty(header)) {
out = out + header + ':' + headers[header] + '\n';
}
}
}
if (body) {
out = out + 'content-length:' + body.length + '\n';
}
out = out + '\n';
if (body) {
out = out + body;
}
return out;
}
}
},
};
Stomp.Client = function(host, port, secure) {
this._host = host || Stomp.DEFAULT_HOST;
this._port = port || Stomp.DEFAULT_PORT || 8675;
this._secure = secure || Stomp.DEFAULT_SECURE_FLAG || false;
}
Stomp.Client.prototype = {
Versions: {
VERSION_1_0 : "1.0",
VERSION_1_1 : "1.1",
},
supportedVersions : function() {
return "1.0,1.1";
},
connect: function(callback) {
if ( arguments.length == 1 ) {
this._connectCallback = arguments[0];
}
if ( arguments.length == 2 ) {
this._connectCallback = arguments[0];
this._errorCallback = arguments[1];
}
if ( arguments.length == 3 ) {
this._login = arguments[0];
this._passcode = arguments[1];
this._connectCallback = arguments[2];
}
if ( arguments.length == 4 ) {
this._login = arguments[0];
this._passcode = arguments[1];
this._connectCallback = arguments[2];
this._errorCallback = arguments[3];
}
this._connectTransport(callback);
},
_connectTransport: function(callback) {
var transports = [];
for ( i = 0 ; i < Stomp.Transports.length ; ++i ) {
var t = new Stomp.Transports[i]( this._host, this._port, this._secure );
t.client = this;
transports.push( t );
}
this._buildConnector( transports, 0, callback )();
},
_buildConnector: function(transports, i, callback) {
var client = this;
if ( i+1 < transports.length ) {
return function() {
var fallback = client._buildConnector( transports, i+1, callback );
try {
transports[i].connect( function() {
client._transport = transports[i];
callback();
}, fallback );
} catch (err) {
fallback();
}
};
} else if ( i < transports.length ) {
return function() {
var fallback = client.connectionFailed.bind( this );
try {
transports[i].connect( function() {
client._transport = transports[i];
callback();
}, client.connectionFailed.bind( this ) );
} catch(err) {
fallback();
}
};
} else {
return function() {
client.connectionFailed(this);
};
}
},
connectionFailed: function() {
console.log( "unable to connect" );
},
disconnect: function(disconnectCallback) {
this._transmit("DISCONNECT");
this._transport.close();
if (disconnectCallback) {
disconnectCallback();
}
},
waitForDisconnect: function() {
this._transport.waitForClosedState();
},
send: function(destination, headers, body) {
var headers = headers || {};
headers.destination = destination;
this._transmit("SEND", headers, body);
},
subscribe: function(destination, callback, headers) {
var headers = headers || {};
var subscription_id = "sub-" + this._counter++;
headers.destination = destination;
headers.id = subscription_id;
this._subscriptions['' + subscription_id] = callback;
this._transmit("SUBSCRIBE", headers);
return subscription_id;
},
unsubscribe: function(id, headers) {
var headers = headers || {};
headers.id = id;
delete this._subscriptions[id];
this._transmit("UNSUBSCRIBE", headers);
},
begin: function(transaction, headers) {
var headers = headers || {};
headers.transaction = transaction;
this._transmit("BEGIN", headers);
},
commit: function(transaction, headers) {
var headers = headers || {};
headers.transaction = transaction;
this._transmit("COMMIT", headers);
},
abort: function(transaction, headers) {
var headers = headers || {};
headers.transaction = transaction;
this._transmit("ABORT", headers);
},
ack: function(message_id, headers) {
var headers = headers || {};
headers["message-id"] = message_id;
this._transmit("ACK", headers);
},
nack: function(message_id, headers) {
// TODO: Add nack functionality.
},
// ----------------------------------------
processMessage: function(message) {
if (message.command == "MESSAGE") {
var subId = message.headers['subscription'];
var callback = this._subscriptions[ subId ];
callback(message);
} else if (message.command == "RECEIPT" && this.onreceipt) {
this.onreceipt(message);
} else if (message.command == "ERROR" && this.onerror) {
this.onerror(message);
}
},
// ----------------------------------------
_login: undefined,
_passcode: undefined,
_connectCallback: undefined,
_errorCallback: undefined,
_webSocketEnabled: true,
_longPollEnabled: true,
_transport: undefined,
_subscriptions: {},
_counter: 0,
_transmit: function(command, headers, body) {
this._transport.transmit(command, headers, body);
},
}
Stomp.Transport.WebSocket = function(host, port, secure) {
this._host = host;
this._port = port;
this._secure = secure;
}
Stomp.Transport.WebSocket.prototype = {
_ws: undefined,
_state: 'unconnected',
transmit: function(command, headers, body) {
var out = Stomp.marshal(command, headers, body);
this._ws.send(out);
},
connect: function(callback, errorCallback) {
var wsClass = null;
if ( typeof WebSocket != 'undefined' ) {
wsClass = WebSocket;
} else if ( typeof MozWebSocket != 'undefined' ) {
wsClass = MozWebSocket;
} else {
return;
}
this._connectCallback = callback;
this._ws = new wsClass( this._url() );
this._ws.onopen = this._issueConnect.bind(this);
this._ws.onmessage = this._handleMessage.bind(this);
this._ws.onerror = errorCallback;
},
close: function() {
this._ws.close();
},
send: function(data) {
this._ws.send(data);
},
_issueConnect: function() {
var headers = {};
this._ws.onerror = this.client.onerror;
if ( this._login ) {
headers['login'] = this._login;
}
if ( this._passcode ) {
headers['passcode'] = this._passcode;
}
console.debug( this.client );
headers[Stomp.Headers.ACCEPT_VERSION] = this.client.supportedVersions();
this.transmit( "CONNECT", headers)
},
_handleMessage: function(evt) {
var frame = Stomp.unmarshal(evt.data);
if (frame.command == "CONNECTED") {
this._version = frame.headers[Stomp.Headers.VERSION];
if (this._connectCallback) {
this._connectCallback(frame);
}
} else {
this.client.processMessage( frame );
}
},
_url: function() {
if ( this._secure ) {
return "wss://" + this._host + ":" + this._port + "/";
}
return "ws://" + this._host + ":" + this._port + "/";
},
}
Stomp.Transports.push( Stomp.Transport.WebSocket );
// ---------------------------------------------------------------
// Third-party Libraries
// ---------------------------------------------------------------
/* SWFObject v2.2
is released under the MIT License
*/
var swfobject=function(){var D="undefined",r="object",S="Shockwave Flash",W="ShockwaveFlash.ShockwaveFlash",q="application/x-shockwave-flash",R="SWFObjectExprInst",x="onreadystatechange",O=window,j=document,t=navigator,T=false,U=[h],o=[],N=[],I=[],l,Q,E,B,J=false,a=false,n,G,m=true,M=function(){var aa=typeof j.getElementById!=D&&typeof j.getElementsByTagName!=D&&typeof j.createElement!=D,ah=t.userAgent.toLowerCase(),Y=t.platform.toLowerCase(),ae=Y?/win/.test(Y):/win/.test(ah),ac=Y?/mac/.test(Y):/mac/.test(ah),af=/webkit/.test(ah)?parseFloat(ah.replace(/^.*webkit\/(\d+(\.\d+)?).*$/,"$1")):false,X=!+"\v1",ag=[0,0,0],ab=null;if(typeof t.plugins!=D&&typeof t.plugins[S]==r){ab=t.plugins[S].description;if(ab&&!(typeof t.mimeTypes!=D&&t.mimeTypes[q]&&!t.mimeTypes[q].enabledPlugin)){T=true;X=false;ab=ab.replace(/^.*\s+(\S+\s+\S+$)/,"$1");ag[0]=parseInt(ab.replace(/^(.*)\..*$/,"$1"),10);ag[1]=parseInt(ab.replace(/^.*\.(.*)\s.*$/,"$1"),10);ag[2]=/[a-zA-Z]/.test(ab)?parseInt(ab.replace(/^.*[a-zA-Z]+(.*)$/,"$1"),10):0}}else{if(typeof O.ActiveXObject!=D){try{var ad=new ActiveXObject(W);if(ad){ab=ad.GetVariable("$version");if(ab){X=true;ab=ab.split(" ")[1].split(",");ag=[parseInt(ab[0],10),parseInt(ab[1],10),parseInt(ab[2],10)]}}}catch(Z){}}}return{w3:aa,pv:ag,wk:af,ie:X,win:ae,mac:ac}}(),k=function(){if(!M.w3){return}if((typeof j.readyState!=D&&j.readyState=="complete")||(typeof j.readyState==D&&(j.getElementsByTagName("body")[0]||j.body))){f()}if(!J){if(typeof j.addEventListener!=D){j.addEventListener("DOMContentLoaded",f,false)}if(M.ie&&M.win){j.attachEvent(x,function(){if(j.readyState=="complete"){j.detachEvent(x,arguments.callee);f()}});if(O==top){(function(){if(J){return}try{j.documentElement.doScroll("left")}catch(X){setTimeout(arguments.callee,0);return}f()})()}}if(M.wk){(function(){if(J){return}if(!/loaded|complete/.test(j.readyState)){setTimeout(arguments.callee,0);return}f()})()}s(f)}}();function f(){if(J){return}try{var Z=j.getElementsByTagName("body")[0].appendChild(C("span"));Z.parentNode.removeChild(Z)}catch(aa){return}J=true;var X=U.length;for(var Y=0;Y0){for(var af=0;af0){var ae=c(Y);if(ae){if(F(o[af].swfVersion)&&!(M.wk&&M.wk<312)){w(Y,true);if(ab){aa.success=true;aa.ref=z(Y);ab(aa)}}else{if(o[af].expressInstall&&A()){var ai={};ai.data=o[af].expressInstall;ai.width=ae.getAttribute("width")||"0";ai.height=ae.getAttribute("height")||"0";if(ae.getAttribute("class")){ai.styleclass=ae.getAttribute("class")}if(ae.getAttribute("align")){ai.align=ae.getAttribute("align")}var ah={};var X=ae.getElementsByTagName("param");var ac=X.length;for(var ad=0;ad'}}aa.outerHTML='";N[N.length]=ai.id;X=c(ai.id)}else{var Z=C(r);Z.setAttribute("type",q);for(var ac in ai){if(ai[ac]!=Object.prototype[ac]){if(ac.toLowerCase()=="styleclass"){Z.setAttribute("class",ai[ac])}else{if(ac.toLowerCase()!="classid"){Z.setAttribute(ac,ai[ac])}}}}for(var ab in ag){if(ag[ab]!=Object.prototype[ab]&&ab.toLowerCase()!="movie"){e(Z,ab,ag[ab])}}aa.parentNode.replaceChild(Z,aa);X=Z}}return X}function e(Z,X,Y){var aa=C("param");aa.setAttribute("name",X);aa.setAttribute("value",Y);Z.appendChild(aa)}function y(Y){var X=c(Y);if(X&&X.nodeName=="OBJECT"){if(M.ie&&M.win){X.style.display="none";(function(){if(X.readyState==4){b(Y)}else{setTimeout(arguments.callee,10)}})()}else{X.parentNode.removeChild(X)}}}function b(Z){var Y=c(Z);if(Y){for(var X in Y){if(typeof Y[X]=="function"){Y[X]=null}}Y.parentNode.removeChild(Y)}}function c(Z){var X=null;try{X=j.getElementById(Z)}catch(Y){}return X}function C(X){return j.createElement(X)}function i(Z,X,Y){Z.attachEvent(X,Y);I[I.length]=[Z,X,Y]}function F(Z){var Y=M.pv,X=Z.split(".");X[0]=parseInt(X[0],10);X[1]=parseInt(X[1],10)||0;X[2]=parseInt(X[2],10)||0;return(Y[0]>X[0]||(Y[0]==X[0]&&Y[1]>X[1])||(Y[0]==X[0]&&Y[1]==X[1]&&Y[2]>=X[2]))?true:false}function v(ac,Y,ad,ab){if(M.ie&&M.mac){return}var aa=j.getElementsByTagName("head")[0];if(!aa){return}var X=(ad&&typeof ad=="string")?ad:"screen";if(ab){n=null;G=null}if(!n||G!=X){var Z=C("style");Z.setAttribute("type","text/css");Z.setAttribute("media",X);n=aa.appendChild(Z);if(M.ie&&M.win&&typeof j.styleSheets!=D&&j.styleSheets.length>0){n=j.styleSheets[j.styleSheets.length-1]}G=X}if(M.ie&&M.win){if(n&&typeof n.addRule==r){n.addRule(ac,Y)}}else{if(n&&typeof j.createTextNode!=D){n.appendChild(j.createTextNode(ac+" {"+Y+"}"))}}}function w(Z,X){if(!m){return}var Y=X?"visible":"hidden";if(J&&c(Z)){c(Z).style.visibility=Y}else{v("#"+Z,"visibility:"+Y)}}function L(Y){var Z=/[\\\"<>\.;]/;var X=Z.exec(Y)!=null;return X&&typeof encodeURIComponent!=D?encodeURIComponent(Y):Y}var d=function(){if(M.ie&&M.win){window.attachEvent("onunload",function(){var ac=I.length;for(var ab=0;ab
// License: New BSD License
// Reference: http://dev.w3.org/html5/websockets/
// Reference: http://tools.ietf.org/html/rfc6455
WEB_SOCKET_SUPPRESS_CROSS_DOMAIN_SWF_ERROR = true;
(function() {
if (window.WEB_SOCKET_FORCE_FLASH) {
// Keeps going.
} else if (window.WebSocket) {
return;
} else if (window.MozWebSocket) {
// Firefox.
window.WebSocket = MozWebSocket;
return;
}
var logger;
if (window.WEB_SOCKET_LOGGER) {
logger = WEB_SOCKET_LOGGER;
} else if (window.console && window.console.log && window.console.error) {
// In some environment, console is defined but console.log or console.error is missing.
logger = window.console;
} else {
logger = {log: function(){ }, error: function(){ }};
}
// swfobject.hasFlashPlayerVersion("10.0.0") doesn't work with Gnash.
if (swfobject.getFlashPlayerVersion().major < 10) {
logger.error("Flash Player >= 10.0.0 is required.");
return;
}
if (location.protocol == "file:") {
logger.error(
"WARNING: web-socket-js doesn't work in file:///... URL " +
"unless you set Flash Security Settings properly. " +
"Open the page via Web server i.e. http://...");
}
/**
* Our own implementation of WebSocket class using Flash.
* @param {string} url
* @param {array or string} protocols
* @param {string} proxyHost
* @param {int} proxyPort
* @param {string} headers
*/
window.WebSocket = function(url, protocols, proxyHost, proxyPort, headers) {
var self = this;
self.__id = WebSocket.__nextId++;
WebSocket.__instances[self.__id] = self;
self.readyState = WebSocket.CONNECTING;
self.bufferedAmount = 0;
self.__events = {};
if (!protocols) {
protocols = [];
} else if (typeof protocols == "string") {
protocols = [protocols];
}
// Uses setTimeout() to make sure __createFlash() runs after the caller sets ws.onopen etc.
// Otherwise, when onopen fires immediately, onopen is called before it is set.
self.__createTask = setTimeout(function() {
WebSocket.__addTask(function() {
self.__createTask = null;
WebSocket.__flash.create(
self.__id, url, protocols, proxyHost || null, proxyPort || 0, headers || null);
});
}, 0);
};
/**
* Send data to the web socket.
* @param {string} data The data to send to the socket.
* @return {boolean} True for success, false for failure.
*/
WebSocket.prototype.send = function(data) {
if (this.readyState == WebSocket.CONNECTING) {
throw "INVALID_STATE_ERR: Web Socket connection has not been established";
}
// We use encodeURIComponent() here, because FABridge doesn't work if
// the argument includes some characters. We don't use escape() here
// because of this:
// https://developer.mozilla.org/en/Core_JavaScript_1.5_Guide/Functions#escape_and_unescape_Functions
// But it looks decodeURIComponent(encodeURIComponent(s)) doesn't
// preserve all Unicode characters either e.g. "\uffff" in Firefox.
// Note by wtritch: Hopefully this will not be necessary using ExternalInterface. Will require
// additional testing.
var result = WebSocket.__flash.send(this.__id, encodeURIComponent(data));
if (result < 0) { // success
return true;
} else {
this.bufferedAmount += result;
return false;
}
};
/**
* Close this web socket gracefully.
*/
WebSocket.prototype.close = function() {
if (this.__createTask) {
clearTimeout(this.__createTask);
this.__createTask = null;
this.readyState = WebSocket.CLOSED;
return;
}
if (this.readyState == WebSocket.CLOSED || this.readyState == WebSocket.CLOSING) {
return;
}
this.readyState = WebSocket.CLOSING;
WebSocket.__flash.close(this.__id);
};
/**
* Implementation of {@link DOM 2 EventTarget Interface}
*
* @param {string} type
* @param {function} listener
* @param {boolean} useCapture
* @return void
*/
WebSocket.prototype.addEventListener = function(type, listener, useCapture) {
if (!(type in this.__events)) {
this.__events[type] = [];
}
this.__events[type].push(listener);
};
/**
* Implementation of {@link DOM 2 EventTarget Interface}
*
* @param {string} type
* @param {function} listener
* @param {boolean} useCapture
* @return void
*/
WebSocket.prototype.removeEventListener = function(type, listener, useCapture) {
if (!(type in this.__events)) return;
var events = this.__events[type];
for (var i = events.length - 1; i >= 0; --i) {
if (events[i] === listener) {
events.splice(i, 1);
break;
}
}
};
/**
* Implementation of {@link DOM 2 EventTarget Interface}
*
* @param {Event} event
* @return void
*/
WebSocket.prototype.dispatchEvent = function(event) {
var events = this.__events[event.type] || [];
for (var i = 0; i < events.length; ++i) {
events[i](event);
}
var handler = this["on" + event.type];
if (handler) handler.apply(this, [event]);
};
/**
* Handles an event from Flash.
* @param {Object} flashEvent
*/
WebSocket.prototype.__handleEvent = function(flashEvent) {
if ("readyState" in flashEvent) {
this.readyState = flashEvent.readyState;
}
if ("protocol" in flashEvent) {
this.protocol = flashEvent.protocol;
}
var jsEvent;
if (flashEvent.type == "open" || flashEvent.type == "error") {
jsEvent = this.__createSimpleEvent(flashEvent.type);
} else if (flashEvent.type == "close") {
jsEvent = this.__createSimpleEvent("close");
jsEvent.wasClean = flashEvent.wasClean ? true : false;
jsEvent.code = flashEvent.code;
jsEvent.reason = flashEvent.reason;
} else if (flashEvent.type == "message") {
var data = decodeURIComponent(flashEvent.message);
jsEvent = this.__createMessageEvent("message", data);
} else {
throw "unknown event type: " + flashEvent.type;
}
this.dispatchEvent(jsEvent);
};
WebSocket.prototype.__createSimpleEvent = function(type) {
if (document.createEvent && window.Event) {
var event = document.createEvent("Event");
event.initEvent(type, false, false);
return event;
} else {
return {type: type, bubbles: false, cancelable: false};
}
};
WebSocket.prototype.__createMessageEvent = function(type, data) {
if (document.createEvent && window.MessageEvent && !window.opera) {
var event = document.createEvent("MessageEvent");
event.initMessageEvent("message", false, false, data, null, null, window, null);
return event;
} else {
// IE and Opera, the latter one truncates the data parameter after any 0x00 bytes.
return {type: type, data: data, bubbles: false, cancelable: false};
}
};
/**
* Define the WebSocket readyState enumeration.
*/
WebSocket.CONNECTING = 0;
WebSocket.OPEN = 1;
WebSocket.CLOSING = 2;
WebSocket.CLOSED = 3;
// Field to check implementation of WebSocket.
WebSocket.__isFlashImplementation = true;
WebSocket.__initialized = false;
WebSocket.__flash = null;
WebSocket.__instances = {};
WebSocket.__tasks = [];
WebSocket.__nextId = 0;
/**
* Load a new flash security policy file.
* @param {string} url
*/
WebSocket.loadFlashPolicyFile = function(url){
WebSocket.__addTask(function() {
WebSocket.__flash.loadManualPolicyFile(url);
});
};
/**
* Loads WebSocketMain.swf and creates WebSocketMain object in Flash.
*/
WebSocket.__initialize = function() {
if (WebSocket.__initialized) return;
WebSocket.__initialized = true;
if (WebSocket.__swfLocation) {
// For backword compatibility.
window.WEB_SOCKET_SWF_LOCATION = WebSocket.__swfLocation;
}
if (!window.WEB_SOCKET_SWF_LOCATION) {
logger.error("[WebSocket] set WEB_SOCKET_SWF_LOCATION to location of WebSocketMain.swf");
return;
}
if (!window.WEB_SOCKET_SUPPRESS_CROSS_DOMAIN_SWF_ERROR &&
!WEB_SOCKET_SWF_LOCATION.match(/(^|\/)WebSocketMainInsecure\.swf(\?.*)?$/) &&
WEB_SOCKET_SWF_LOCATION.match(/^\w+:\/\/([^\/]+)/)) {
var swfHost = RegExp.$1;
if (location.host != swfHost) {
logger.error(
"[WebSocket] You must host HTML and WebSocketMain.swf in the same host " +
"('" + location.host + "' != '" + swfHost + "'). " +
"See also 'How to host HTML file and SWF file in different domains' section " +
"in README.md. If you use WebSocketMainInsecure.swf, you can suppress this message " +
"by WEB_SOCKET_SUPPRESS_CROSS_DOMAIN_SWF_ERROR = true;");
}
}
var container = document.createElement("div");
container.id = "webSocketContainer";
// Hides Flash box. We cannot use display: none or visibility: hidden because it prevents
// Flash from loading at least in IE. So we move it out of the screen at (-100, -100).
// But this even doesn't work with Flash Lite (e.g. in Droid Incredible). So with Flash
// Lite, we put it at (0, 0). This shows 1x1 box visible at left-top corner but this is
// the best we can do as far as we know now.
container.style.position = "absolute";
if (WebSocket.__isFlashLite()) {
container.style.left = "0px";
container.style.top = "0px";
} else {
container.style.left = "-100px";
container.style.top = "-100px";
}
var holder = document.createElement("div");
holder.id = "webSocketFlash";
container.appendChild(holder);
document.body.appendChild(container);
// See this article for hasPriority:
// http://help.adobe.com/en_US/as3/mobile/WS4bebcd66a74275c36cfb8137124318eebc6-7ffd.html
swfobject.embedSWF(
WEB_SOCKET_SWF_LOCATION,
"webSocketFlash",
"1" /* width */,
"1" /* height */,
"10.0.0" /* SWF version */,
null,
null,
{hasPriority: true, swliveconnect : true, allowScriptAccess: "always"},
null,
function(e) {
if (!e.success) {
logger.error("[WebSocket] swfobject.embedSWF failed");
}
}
);
};
/**
* Called by Flash to notify JS that it's fully loaded and ready
* for communication.
*/
WebSocket.__onFlashInitialized = function() {
// We need to set a timeout here to avoid round-trip calls
// to flash during the initialization process.
setTimeout(function() {
WebSocket.__flash = document.getElementById("webSocketFlash");
WebSocket.__flash.setCallerUrl(location.href);
WebSocket.__flash.setDebug(!!window.WEB_SOCKET_DEBUG);
for (var i = 0; i < WebSocket.__tasks.length; ++i) {
WebSocket.__tasks[i]();
}
WebSocket.__tasks = [];
}, 0);
};
/**
* Called by Flash to notify WebSockets events are fired.
*/
WebSocket.__onFlashEvent = function() {
setTimeout(function() {
try {
// Gets events using receiveEvents() instead of getting it from event object
// of Flash event. This is to make sure to keep message order.
// It seems sometimes Flash events don't arrive in the same order as they are sent.
var events = WebSocket.__flash.receiveEvents();
for (var i = 0; i < events.length; ++i) {
WebSocket.__instances[events[i].webSocketId].__handleEvent(events[i]);
}
} catch (e) {
logger.error(e);
}
}, 0);
return true;
};
// Called by Flash.
WebSocket.__log = function(message) {
logger.log(decodeURIComponent(message));
};
// Called by Flash.
WebSocket.__error = function(message) {
logger.error(decodeURIComponent(message));
};
WebSocket.__addTask = function(task) {
if (WebSocket.__flash) {
task();
} else {
WebSocket.__tasks.push(task);
}
};
/**
* Test if the browser is running flash lite.
* @return {boolean} True if flash lite is running, false otherwise.
*/
WebSocket.__isFlashLite = function() {
if (!window.navigator || !window.navigator.mimeTypes) {
return false;
}
var mimeType = window.navigator.mimeTypes["application/x-shockwave-flash"];
if (!mimeType || !mimeType.enabledPlugin || !mimeType.enabledPlugin.filename) {
return false;
}
return mimeType.enabledPlugin.filename.match(/flashlite/i) ? true : false;
};
if (!window.WEB_SOCKET_DISABLE_AUTO_INITIALIZATION) {
// NOTE:
// This fires immediately if web_socket.js is dynamically loaded after
// the document is loaded.
swfobject.addDomLoadEvent(function() {
WebSocket.__initialize();
});
}
})();
// ----------------------------------------
// HTTP Transport
// ----------------------------------------
Stomp.Transport.HTTP = function(host, port, secure) {
this._host = host;
this._port = port;
this._secure = secure;
}
Stomp.Transport.HTTP.prototype = {
_receiverRequest: undefined,
_disconnectReceiver: false,
connect: function(callback, errorCallback) {
var headers = {};
if ( this._login ) {
headers.login = this._login;
}
if ( this._passcode ) {
headers.passcode = this._passcode;
}
headers[Stomp.Headers.ACCEPT_VERSION] = this.client.supportedVersions();
var transport = this;
var request = new XMLHttpRequest();
request.open( "POST", this._url(), true );
request.withCredentials = true;
var timeoutHandle = setTimeout( function() {
if ( request.readyState != 0 && request.readyState != 4 ) {
request.abort();
errorCallack();
}
}, 5000 );
request.onerror = errorCallback;
request.onload = function() {
clearTimeout( timeoutHandle );
transport.connectMessageReceiver();
callback();
}
request.setRequestHeader("Content-type","text/stomp");
var data = Stomp.marshal("CONNECT", headers);
request.send(data);
},
connectMessageReceiver: function() {
var transport = this;
try {
this._eventSource = new EventSource( this._url(), { withCredentials: true } );
this._eventSource.withCredentials = true;
this._eventSource.onerror = function() {
transport._eventSource.close();
transport._eventSource = undefined;
transport.connectLongPoll();
};
this._eventSource.onopen = function() {
transport._eventSource.onerror = undefined;
};
this._eventSource.onmessage = function(e) {
var message = Stomp.unmarshal( e.data );
transport.client.processMessage( message );
};
} catch (err) {
console.debug( err );
this._eventSource.close();
this._eventSource = undefined;
this.connectLongPoll();
}
},
connectLongPoll: function() {
var transport = this;
var request = new XMLHttpRequest();
request.open( "GET", this._url(), true );
request.onload = function() {
var message = Stomp.unmarshal( request.response );
transport.client.processMessage( message );
}
request.onloadend = function() {
if ( transport._disconnectReceiver ) {
return;
}
transport.connectLongPoll();
}
setTimeout( function() {
if ( request.readyState != 0 && request.readyState != 4 ) {
request.abort();
}
}, 10000 );
request.setRequestHeader("Accept","text/stomp-poll");
request.withCredentials = true;
request.send();
this._receiverRequest = request;
},
disconnectMessageReceiver: function() {
this._disconnectReceiver = true;
if ( this._eventSource ) {
this._eventSource.close();
this._eventSource = undefined;
}
if ( this._receiverRequest ) {
this._receiverRequest.abort();
this._receiverRequest = undefined;
}
},
close: function() {
this.disconnectMessageReceiver();
},
transmit: function(command, headers, body, callbacks, timeoutMs) {
var data = Stomp.marshal(command, headers, body);
this.send(data, callbacks, timeoutMs);
},
send: function(data, callbacks) {
callbacks = callbacks || {};
var request = new XMLHttpRequest();
request.open( "POST", this._url(), true );
request.withCredentials = true;
console.debug( request );
if ( callbacks['load'] ) {
request.onload = function() {
callbacks['load'](request);
}
}
if ( callbacks['error'] ) {
requrest.onerror = function() {
callbacks['error'](request);
}
}
request.setRequestHeader("Content-type","text/stomp");
request.send(data);
},
_url: function() {
if ( this._secure ) {
return "https://" + this._host + ":" + this._port + "/";
}
return "http://" + this._host + ":" + this._port + "/";
},
};
Stomp.Transports.push( Stomp.Transport.HTTP );