socketio-client 0.9.16 fork
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/*! Socket.IO.js build:0.9.16, development. Copyright(c) 2011 LearnBoost <dev@learnboost.com> MIT Licensed */ | |
/* Modifications by Vlad Niculae <vlad@vene.ro> | |
Available at https://gist.github.com/vene/c0657d854ae74a4511d2 | |
Forked from https://raw.githubusercontent.com/Automattic/socket.io-client/ \ | |
0.9.16/dist/socket.io.js | |
Changes: | |
* added 'wsport' configuration option | |
Supports configuring a different port for websocket vs normal traffic. | |
This is important for hosting on OpenShift with fallbacks, as well as | |
for allowing handshakes over firewalls. | |
* connectTimeoutTimer now publishes connect_failed even if | |
"try multiple transports" is false. | |
*/ | |
var io = ('undefined' === typeof module ? {} : module.exports); | |
(function() { | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, global) { | |
/** | |
* IO namespace. | |
* | |
* @namespace | |
*/ | |
var io = exports; | |
/** | |
* Socket.IO version | |
* | |
* @api public | |
*/ | |
io.version = '0.9.16'; | |
/** | |
* Protocol implemented. | |
* | |
* @api public | |
*/ | |
io.protocol = 1; | |
/** | |
* Available transports, these will be populated with the available transports | |
* | |
* @api public | |
*/ | |
io.transports = []; | |
/** | |
* Keep track of jsonp callbacks. | |
* | |
* @api private | |
*/ | |
io.j = []; | |
/** | |
* Keep track of our io.Sockets | |
* | |
* @api private | |
*/ | |
io.sockets = {}; | |
/** | |
* Manages connections to hosts. | |
* | |
* @param {String} uri | |
* @Param {Boolean} force creation of new socket (defaults to false) | |
* @api public | |
*/ | |
io.connect = function (host, details) { | |
var uri = io.util.parseUri(host) | |
, uuri | |
, socket; | |
if (global && global.location) { | |
uri.protocol = uri.protocol || global.location.protocol.slice(0, -1); | |
uri.host = uri.host || (global.document | |
? global.document.domain : global.location.hostname); | |
uri.port = uri.port || global.location.port; | |
} | |
uuri = io.util.uniqueUri(uri); | |
var options = { | |
host: uri.host | |
, secure: 'https' == uri.protocol | |
, port: uri.port || ('https' == uri.protocol ? 443 : 80) | |
, query: uri.query || '' | |
}; | |
io.util.merge(options, details); | |
if (options['force new connection'] || !io.sockets[uuri]) { | |
socket = new io.Socket(options); | |
} | |
if (!options['force new connection'] && socket) { | |
io.sockets[uuri] = socket; | |
} | |
socket = socket || io.sockets[uuri]; | |
// if path is different from '' or / | |
return socket.of(uri.path.length > 1 ? uri.path : ''); | |
}; | |
})('object' === typeof module ? module.exports : (this.io = {}), this); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, global) { | |
/** | |
* Utilities namespace. | |
* | |
* @namespace | |
*/ | |
var util = exports.util = {}; | |
/** | |
* Parses an URI | |
* | |
* @author Steven Levithan <stevenlevithan.com> (MIT license) | |
* @api public | |
*/ | |
var re = /^(?:(?![^:@]+:[^:@\/]*@)([^:\/?#.]+):)?(?:\/\/)?((?:(([^:@]*)(?::([^:@]*))?)?@)?([^:\/?#]*)(?::(\d*))?)(((\/(?:[^?#](?![^?#\/]*\.[^?#\/.]+(?:[?#]|$)))*\/?)?([^?#\/]*))(?:\?([^#]*))?(?:#(.*))?)/; | |
var parts = ['source', 'protocol', 'authority', 'userInfo', 'user', 'password', | |
'host', 'port', 'relative', 'path', 'directory', 'file', 'query', | |
'anchor']; | |
util.parseUri = function (str) { | |
var m = re.exec(str || '') | |
, uri = {} | |
, i = 14; | |
while (i--) { | |
uri[parts[i]] = m[i] || ''; | |
} | |
return uri; | |
}; | |
/** | |
* Produces a unique url that identifies a Socket.IO connection. | |
* | |
* @param {Object} uri | |
* @api public | |
*/ | |
util.uniqueUri = function (uri) { | |
var protocol = uri.protocol | |
, host = uri.host | |
, port = uri.port; | |
if ('document' in global) { | |
host = host || document.domain; | |
port = port || (protocol == 'https' | |
&& document.location.protocol !== 'https:' ? 443 : document.location.port); | |
} else { | |
host = host || 'localhost'; | |
if (!port && protocol == 'https') { | |
port = 443; | |
} | |
} | |
return (protocol || 'http') + '://' + host + ':' + (port || 80); | |
}; | |
/** | |
* Mergest 2 query strings in to once unique query string | |
* | |
* @param {String} base | |
* @param {String} addition | |
* @api public | |
*/ | |
util.query = function (base, addition) { | |
var query = util.chunkQuery(base || '') | |
, components = []; | |
util.merge(query, util.chunkQuery(addition || '')); | |
for (var part in query) { | |
if (query.hasOwnProperty(part)) { | |
components.push(part + '=' + query[part]); | |
} | |
} | |
return components.length ? '?' + components.join('&') : ''; | |
}; | |
/** | |
* Transforms a querystring in to an object | |
* | |
* @param {String} qs | |
* @api public | |
*/ | |
util.chunkQuery = function (qs) { | |
var query = {} | |
, params = qs.split('&') | |
, i = 0 | |
, l = params.length | |
, kv; | |
for (; i < l; ++i) { | |
kv = params[i].split('='); | |
if (kv[0]) { | |
query[kv[0]] = kv[1]; | |
} | |
} | |
return query; | |
}; | |
/** | |
* Executes the given function when the page is loaded. | |
* | |
* io.util.load(function () { console.log('page loaded'); }); | |
* | |
* @param {Function} fn | |
* @api public | |
*/ | |
var pageLoaded = false; | |
util.load = function (fn) { | |
if ('document' in global && document.readyState === 'complete' || pageLoaded) { | |
return fn(); | |
} | |
util.on(global, 'load', fn, false); | |
}; | |
/** | |
* Adds an event. | |
* | |
* @api private | |
*/ | |
util.on = function (element, event, fn, capture) { | |
if (element.attachEvent) { | |
element.attachEvent('on' + event, fn); | |
} else if (element.addEventListener) { | |
element.addEventListener(event, fn, capture); | |
} | |
}; | |
/** | |
* Generates the correct `XMLHttpRequest` for regular and cross domain requests. | |
* | |
* @param {Boolean} [xdomain] Create a request that can be used cross domain. | |
* @returns {XMLHttpRequest|false} If we can create a XMLHttpRequest. | |
* @api private | |
*/ | |
util.request = function (xdomain) { | |
if (xdomain && 'undefined' != typeof XDomainRequest && !util.ua.hasCORS) { | |
return new XDomainRequest(); | |
} | |
if ('undefined' != typeof XMLHttpRequest && (!xdomain || util.ua.hasCORS)) { | |
return new XMLHttpRequest(); | |
} | |
if (!xdomain) { | |
try { | |
return new window[(['Active'].concat('Object').join('X'))]('Microsoft.XMLHTTP'); | |
} catch(e) { } | |
} | |
return null; | |
}; | |
/** | |
* XHR based transport constructor. | |
* | |
* @constructor | |
* @api public | |
*/ | |
/** | |
* Change the internal pageLoaded value. | |
*/ | |
if ('undefined' != typeof window) { | |
util.load(function () { | |
pageLoaded = true; | |
}); | |
} | |
/** | |
* Defers a function to ensure a spinner is not displayed by the browser | |
* | |
* @param {Function} fn | |
* @api public | |
*/ | |
util.defer = function (fn) { | |
if (!util.ua.webkit || 'undefined' != typeof importScripts) { | |
return fn(); | |
} | |
util.load(function () { | |
setTimeout(fn, 100); | |
}); | |
}; | |
/** | |
* Merges two objects. | |
* | |
* @api public | |
*/ | |
util.merge = function merge (target, additional, deep, lastseen) { | |
var seen = lastseen || [] | |
, depth = typeof deep == 'undefined' ? 2 : deep | |
, prop; | |
for (prop in additional) { | |
if (additional.hasOwnProperty(prop) && util.indexOf(seen, prop) < 0) { | |
if (typeof target[prop] !== 'object' || !depth) { | |
target[prop] = additional[prop]; | |
seen.push(additional[prop]); | |
} else { | |
util.merge(target[prop], additional[prop], depth - 1, seen); | |
} | |
} | |
} | |
return target; | |
}; | |
/** | |
* Merges prototypes from objects | |
* | |
* @api public | |
*/ | |
util.mixin = function (ctor, ctor2) { | |
util.merge(ctor.prototype, ctor2.prototype); | |
}; | |
/** | |
* Shortcut for prototypical and static inheritance. | |
* | |
* @api private | |
*/ | |
util.inherit = function (ctor, ctor2) { | |
function f() {}; | |
f.prototype = ctor2.prototype; | |
ctor.prototype = new f; | |
}; | |
/** | |
* Checks if the given object is an Array. | |
* | |
* io.util.isArray([]); // true | |
* io.util.isArray({}); // false | |
* | |
* @param Object obj | |
* @api public | |
*/ | |
util.isArray = Array.isArray || function (obj) { | |
return Object.prototype.toString.call(obj) === '[object Array]'; | |
}; | |
/** | |
* Intersects values of two arrays into a third | |
* | |
* @api public | |
*/ | |
util.intersect = function (arr, arr2) { | |
var ret = [] | |
, longest = arr.length > arr2.length ? arr : arr2 | |
, shortest = arr.length > arr2.length ? arr2 : arr; | |
for (var i = 0, l = shortest.length; i < l; i++) { | |
if (~util.indexOf(longest, shortest[i])) | |
ret.push(shortest[i]); | |
} | |
return ret; | |
}; | |
/** | |
* Array indexOf compatibility. | |
* | |
* @see bit.ly/a5Dxa2 | |
* @api public | |
*/ | |
util.indexOf = function (arr, o, i) { | |
for (var j = arr.length, i = i < 0 ? i + j < 0 ? 0 : i + j : i || 0; | |
i < j && arr[i] !== o; i++) {} | |
return j <= i ? -1 : i; | |
}; | |
/** | |
* Converts enumerables to array. | |
* | |
* @api public | |
*/ | |
util.toArray = function (enu) { | |
var arr = []; | |
for (var i = 0, l = enu.length; i < l; i++) | |
arr.push(enu[i]); | |
return arr; | |
}; | |
/** | |
* UA / engines detection namespace. | |
* | |
* @namespace | |
*/ | |
util.ua = {}; | |
/** | |
* Whether the UA supports CORS for XHR. | |
* | |
* @api public | |
*/ | |
util.ua.hasCORS = 'undefined' != typeof XMLHttpRequest && (function () { | |
try { | |
var a = new XMLHttpRequest(); | |
} catch (e) { | |
return false; | |
} | |
return a.withCredentials != undefined; | |
})(); | |
/** | |
* Detect webkit. | |
* | |
* @api public | |
*/ | |
util.ua.webkit = 'undefined' != typeof navigator | |
&& /webkit/i.test(navigator.userAgent); | |
/** | |
* Detect iPad/iPhone/iPod. | |
* | |
* @api public | |
*/ | |
util.ua.iDevice = 'undefined' != typeof navigator | |
&& /iPad|iPhone|iPod/i.test(navigator.userAgent); | |
})('undefined' != typeof io ? io : module.exports, this); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, io) { | |
/** | |
* Expose constructor. | |
*/ | |
exports.EventEmitter = EventEmitter; | |
/** | |
* Event emitter constructor. | |
* | |
* @api public. | |
*/ | |
function EventEmitter () {}; | |
/** | |
* Adds a listener | |
* | |
* @api public | |
*/ | |
EventEmitter.prototype.on = function (name, fn) { | |
if (!this.$events) { | |
this.$events = {}; | |
} | |
if (!this.$events[name]) { | |
this.$events[name] = fn; | |
} else if (io.util.isArray(this.$events[name])) { | |
this.$events[name].push(fn); | |
} else { | |
this.$events[name] = [this.$events[name], fn]; | |
} | |
return this; | |
}; | |
EventEmitter.prototype.addListener = EventEmitter.prototype.on; | |
/** | |
* Adds a volatile listener. | |
* | |
* @api public | |
*/ | |
EventEmitter.prototype.once = function (name, fn) { | |
var self = this; | |
function on () { | |
self.removeListener(name, on); | |
fn.apply(this, arguments); | |
}; | |
on.listener = fn; | |
this.on(name, on); | |
return this; | |
}; | |
/** | |
* Removes a listener. | |
* | |
* @api public | |
*/ | |
EventEmitter.prototype.removeListener = function (name, fn) { | |
if (this.$events && this.$events[name]) { | |
var list = this.$events[name]; | |
if (io.util.isArray(list)) { | |
var pos = -1; | |
for (var i = 0, l = list.length; i < l; i++) { | |
if (list[i] === fn || (list[i].listener && list[i].listener === fn)) { | |
pos = i; | |
break; | |
} | |
} | |
if (pos < 0) { | |
return this; | |
} | |
list.splice(pos, 1); | |
if (!list.length) { | |
delete this.$events[name]; | |
} | |
} else if (list === fn || (list.listener && list.listener === fn)) { | |
delete this.$events[name]; | |
} | |
} | |
return this; | |
}; | |
/** | |
* Removes all listeners for an event. | |
* | |
* @api public | |
*/ | |
EventEmitter.prototype.removeAllListeners = function (name) { | |
if (name === undefined) { | |
this.$events = {}; | |
return this; | |
} | |
if (this.$events && this.$events[name]) { | |
this.$events[name] = null; | |
} | |
return this; | |
}; | |
/** | |
* Gets all listeners for a certain event. | |
* | |
* @api publci | |
*/ | |
EventEmitter.prototype.listeners = function (name) { | |
if (!this.$events) { | |
this.$events = {}; | |
} | |
if (!this.$events[name]) { | |
this.$events[name] = []; | |
} | |
if (!io.util.isArray(this.$events[name])) { | |
this.$events[name] = [this.$events[name]]; | |
} | |
return this.$events[name]; | |
}; | |
/** | |
* Emits an event. | |
* | |
* @api public | |
*/ | |
EventEmitter.prototype.emit = function (name) { | |
if (!this.$events) { | |
return false; | |
} | |
var handler = this.$events[name]; | |
if (!handler) { | |
return false; | |
} | |
var args = Array.prototype.slice.call(arguments, 1); | |
if ('function' == typeof handler) { | |
handler.apply(this, args); | |
} else if (io.util.isArray(handler)) { | |
var listeners = handler.slice(); | |
for (var i = 0, l = listeners.length; i < l; i++) { | |
listeners[i].apply(this, args); | |
} | |
} else { | |
return false; | |
} | |
return true; | |
}; | |
})( | |
'undefined' != typeof io ? io : module.exports | |
, 'undefined' != typeof io ? io : module.parent.exports | |
); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
/** | |
* Based on JSON2 (http://www.JSON.org/js.html). | |
*/ | |
(function (exports, nativeJSON) { | |
"use strict"; | |
// use native JSON if it's available | |
if (nativeJSON && nativeJSON.parse){ | |
return exports.JSON = { | |
parse: nativeJSON.parse | |
, stringify: nativeJSON.stringify | |
}; | |
} | |
var JSON = exports.JSON = {}; | |
function f(n) { | |
// Format integers to have at least two digits. | |
return n < 10 ? '0' + n : n; | |
} | |
function date(d, key) { | |
return isFinite(d.valueOf()) ? | |
d.getUTCFullYear() + '-' + | |
f(d.getUTCMonth() + 1) + '-' + | |
f(d.getUTCDate()) + 'T' + | |
f(d.getUTCHours()) + ':' + | |
f(d.getUTCMinutes()) + ':' + | |
f(d.getUTCSeconds()) + 'Z' : null; | |
}; | |
var cx = /[\u0000\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g, | |
escapable = /[\\\"\x00-\x1f\x7f-\x9f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g, | |
gap, | |
indent, | |
meta = { // table of character substitutions | |
'\b': '\\b', | |
'\t': '\\t', | |
'\n': '\\n', | |
'\f': '\\f', | |
'\r': '\\r', | |
'"' : '\\"', | |
'\\': '\\\\' | |
}, | |
rep; | |
function quote(string) { | |
// If the string contains no control characters, no quote characters, and no | |
// backslash characters, then we can safely slap some quotes around it. | |
// Otherwise we must also replace the offending characters with safe escape | |
// sequences. | |
escapable.lastIndex = 0; | |
return escapable.test(string) ? '"' + string.replace(escapable, function (a) { | |
var c = meta[a]; | |
return typeof c === 'string' ? c : | |
'\\u' + ('0000' + a.charCodeAt(0).toString(16)).slice(-4); | |
}) + '"' : '"' + string + '"'; | |
} | |
function str(key, holder) { | |
// Produce a string from holder[key]. | |
var i, // The loop counter. | |
k, // The member key. | |
v, // The member value. | |
length, | |
mind = gap, | |
partial, | |
value = holder[key]; | |
// If the value has a toJSON method, call it to obtain a replacement value. | |
if (value instanceof Date) { | |
value = date(key); | |
} | |
// If we were called with a replacer function, then call the replacer to | |
// obtain a replacement value. | |
if (typeof rep === 'function') { | |
value = rep.call(holder, key, value); | |
} | |
// What happens next depends on the value's type. | |
switch (typeof value) { | |
case 'string': | |
return quote(value); | |
case 'number': | |
// JSON numbers must be finite. Encode non-finite numbers as null. | |
return isFinite(value) ? String(value) : 'null'; | |
case 'boolean': | |
case 'null': | |
// If the value is a boolean or null, convert it to a string. Note: | |
// typeof null does not produce 'null'. The case is included here in | |
// the remote chance that this gets fixed someday. | |
return String(value); | |
// If the type is 'object', we might be dealing with an object or an array or | |
// null. | |
case 'object': | |
// Due to a specification blunder in ECMAScript, typeof null is 'object', | |
// so watch out for that case. | |
if (!value) { | |
return 'null'; | |
} | |
// Make an array to hold the partial results of stringifying this object value. | |
gap += indent; | |
partial = []; | |
// Is the value an array? | |
if (Object.prototype.toString.apply(value) === '[object Array]') { | |
// The value is an array. Stringify every element. Use null as a placeholder | |
// for non-JSON values. | |
length = value.length; | |
for (i = 0; i < length; i += 1) { | |
partial[i] = str(i, value) || 'null'; | |
} | |
// Join all of the elements together, separated with commas, and wrap them in | |
// brackets. | |
v = partial.length === 0 ? '[]' : gap ? | |
'[\n' + gap + partial.join(',\n' + gap) + '\n' + mind + ']' : | |
'[' + partial.join(',') + ']'; | |
gap = mind; | |
return v; | |
} | |
// If the replacer is an array, use it to select the members to be stringified. | |
if (rep && typeof rep === 'object') { | |
length = rep.length; | |
for (i = 0; i < length; i += 1) { | |
if (typeof rep[i] === 'string') { | |
k = rep[i]; | |
v = str(k, value); | |
if (v) { | |
partial.push(quote(k) + (gap ? ': ' : ':') + v); | |
} | |
} | |
} | |
} else { | |
// Otherwise, iterate through all of the keys in the object. | |
for (k in value) { | |
if (Object.prototype.hasOwnProperty.call(value, k)) { | |
v = str(k, value); | |
if (v) { | |
partial.push(quote(k) + (gap ? ': ' : ':') + v); | |
} | |
} | |
} | |
} | |
// Join all of the member texts together, separated with commas, | |
// and wrap them in braces. | |
v = partial.length === 0 ? '{}' : gap ? | |
'{\n' + gap + partial.join(',\n' + gap) + '\n' + mind + '}' : | |
'{' + partial.join(',') + '}'; | |
gap = mind; | |
return v; | |
} | |
} | |
// If the JSON object does not yet have a stringify method, give it one. | |
JSON.stringify = function (value, replacer, space) { | |
// The stringify method takes a value and an optional replacer, and an optional | |
// space parameter, and returns a JSON text. The replacer can be a function | |
// that can replace values, or an array of strings that will select the keys. | |
// A default replacer method can be provided. Use of the space parameter can | |
// produce text that is more easily readable. | |
var i; | |
gap = ''; | |
indent = ''; | |
// If the space parameter is a number, make an indent string containing that | |
// many spaces. | |
if (typeof space === 'number') { | |
for (i = 0; i < space; i += 1) { | |
indent += ' '; | |
} | |
// If the space parameter is a string, it will be used as the indent string. | |
} else if (typeof space === 'string') { | |
indent = space; | |
} | |
// If there is a replacer, it must be a function or an array. | |
// Otherwise, throw an error. | |
rep = replacer; | |
if (replacer && typeof replacer !== 'function' && | |
(typeof replacer !== 'object' || | |
typeof replacer.length !== 'number')) { | |
throw new Error('JSON.stringify'); | |
} | |
// Make a fake root object containing our value under the key of ''. | |
// Return the result of stringifying the value. | |
return str('', {'': value}); | |
}; | |
// If the JSON object does not yet have a parse method, give it one. | |
JSON.parse = function (text, reviver) { | |
// The parse method takes a text and an optional reviver function, and returns | |
// a JavaScript value if the text is a valid JSON text. | |
var j; | |
function walk(holder, key) { | |
// The walk method is used to recursively walk the resulting structure so | |
// that modifications can be made. | |
var k, v, value = holder[key]; | |
if (value && typeof value === 'object') { | |
for (k in value) { | |
if (Object.prototype.hasOwnProperty.call(value, k)) { | |
v = walk(value, k); | |
if (v !== undefined) { | |
value[k] = v; | |
} else { | |
delete value[k]; | |
} | |
} | |
} | |
} | |
return reviver.call(holder, key, value); | |
} | |
// Parsing happens in four stages. In the first stage, we replace certain | |
// Unicode characters with escape sequences. JavaScript handles many characters | |
// incorrectly, either silently deleting them, or treating them as line endings. | |
text = String(text); | |
cx.lastIndex = 0; | |
if (cx.test(text)) { | |
text = text.replace(cx, function (a) { | |
return '\\u' + | |
('0000' + a.charCodeAt(0).toString(16)).slice(-4); | |
}); | |
} | |
// In the second stage, we run the text against regular expressions that look | |
// for non-JSON patterns. We are especially concerned with '()' and 'new' | |
// because they can cause invocation, and '=' because it can cause mutation. | |
// But just to be safe, we want to reject all unexpected forms. | |
// We split the second stage into 4 regexp operations in order to work around | |
// crippling inefficiencies in IE's and Safari's regexp engines. First we | |
// replace the JSON backslash pairs with '@' (a non-JSON character). Second, we | |
// replace all simple value tokens with ']' characters. Third, we delete all | |
// open brackets that follow a colon or comma or that begin the text. Finally, | |
// we look to see that the remaining characters are only whitespace or ']' or | |
// ',' or ':' or '{' or '}'. If that is so, then the text is safe for eval. | |
if (/^[\],:{}\s]*$/ | |
.test(text.replace(/\\(?:["\\\/bfnrt]|u[0-9a-fA-F]{4})/g, '@') | |
.replace(/"[^"\\\n\r]*"|true|false|null|-?\d+(?:\.\d*)?(?:[eE][+\-]?\d+)?/g, ']') | |
.replace(/(?:^|:|,)(?:\s*\[)+/g, ''))) { | |
// In the third stage we use the eval function to compile the text into a | |
// JavaScript structure. The '{' operator is subject to a syntactic ambiguity | |
// in JavaScript: it can begin a block or an object literal. We wrap the text | |
// in parens to eliminate the ambiguity. | |
j = eval('(' + text + ')'); | |
// In the optional fourth stage, we recursively walk the new structure, passing | |
// each name/value pair to a reviver function for possible transformation. | |
return typeof reviver === 'function' ? | |
walk({'': j}, '') : j; | |
} | |
// If the text is not JSON parseable, then a SyntaxError is thrown. | |
throw new SyntaxError('JSON.parse'); | |
}; | |
})( | |
'undefined' != typeof io ? io : module.exports | |
, typeof JSON !== 'undefined' ? JSON : undefined | |
); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, io) { | |
/** | |
* Parser namespace. | |
* | |
* @namespace | |
*/ | |
var parser = exports.parser = {}; | |
/** | |
* Packet types. | |
*/ | |
var packets = parser.packets = [ | |
'disconnect' | |
, 'connect' | |
, 'heartbeat' | |
, 'message' | |
, 'json' | |
, 'event' | |
, 'ack' | |
, 'error' | |
, 'noop' | |
]; | |
/** | |
* Errors reasons. | |
*/ | |
var reasons = parser.reasons = [ | |
'transport not supported' | |
, 'client not handshaken' | |
, 'unauthorized' | |
]; | |
/** | |
* Errors advice. | |
*/ | |
var advice = parser.advice = [ | |
'reconnect' | |
]; | |
/** | |
* Shortcuts. | |
*/ | |
var JSON = io.JSON | |
, indexOf = io.util.indexOf; | |
/** | |
* Encodes a packet. | |
* | |
* @api private | |
*/ | |
parser.encodePacket = function (packet) { | |
var type = indexOf(packets, packet.type) | |
, id = packet.id || '' | |
, endpoint = packet.endpoint || '' | |
, ack = packet.ack | |
, data = null; | |
switch (packet.type) { | |
case 'error': | |
var reason = packet.reason ? indexOf(reasons, packet.reason) : '' | |
, adv = packet.advice ? indexOf(advice, packet.advice) : ''; | |
if (reason !== '' || adv !== '') | |
data = reason + (adv !== '' ? ('+' + adv) : ''); | |
break; | |
case 'message': | |
if (packet.data !== '') | |
data = packet.data; | |
break; | |
case 'event': | |
var ev = { name: packet.name }; | |
if (packet.args && packet.args.length) { | |
ev.args = packet.args; | |
} | |
data = JSON.stringify(ev); | |
break; | |
case 'json': | |
data = JSON.stringify(packet.data); | |
break; | |
case 'connect': | |
if (packet.qs) | |
data = packet.qs; | |
break; | |
case 'ack': | |
data = packet.ackId | |
+ (packet.args && packet.args.length | |
? '+' + JSON.stringify(packet.args) : ''); | |
break; | |
} | |
// construct packet with required fragments | |
var encoded = [ | |
type | |
, id + (ack == 'data' ? '+' : '') | |
, endpoint | |
]; | |
// data fragment is optional | |
if (data !== null && data !== undefined) | |
encoded.push(data); | |
return encoded.join(':'); | |
}; | |
/** | |
* Encodes multiple messages (payload). | |
* | |
* @param {Array} messages | |
* @api private | |
*/ | |
parser.encodePayload = function (packets) { | |
var decoded = ''; | |
if (packets.length == 1) | |
return packets[0]; | |
for (var i = 0, l = packets.length; i < l; i++) { | |
var packet = packets[i]; | |
decoded += '\ufffd' + packet.length + '\ufffd' + packets[i]; | |
} | |
return decoded; | |
}; | |
/** | |
* Decodes a packet | |
* | |
* @api private | |
*/ | |
var regexp = /([^:]+):([0-9]+)?(\+)?:([^:]+)?:?([\s\S]*)?/; | |
parser.decodePacket = function (data) { | |
var pieces = data.match(regexp); | |
if (!pieces) return {}; | |
var id = pieces[2] || '' | |
, data = pieces[5] || '' | |
, packet = { | |
type: packets[pieces[1]] | |
, endpoint: pieces[4] || '' | |
}; | |
// whether we need to acknowledge the packet | |
if (id) { | |
packet.id = id; | |
if (pieces[3]) | |
packet.ack = 'data'; | |
else | |
packet.ack = true; | |
} | |
// handle different packet types | |
switch (packet.type) { | |
case 'error': | |
var pieces = data.split('+'); | |
packet.reason = reasons[pieces[0]] || ''; | |
packet.advice = advice[pieces[1]] || ''; | |
break; | |
case 'message': | |
packet.data = data || ''; | |
break; | |
case 'event': | |
try { | |
var opts = JSON.parse(data); | |
packet.name = opts.name; | |
packet.args = opts.args; | |
} catch (e) { } | |
packet.args = packet.args || []; | |
break; | |
case 'json': | |
try { | |
packet.data = JSON.parse(data); | |
} catch (e) { } | |
break; | |
case 'connect': | |
packet.qs = data || ''; | |
break; | |
case 'ack': | |
var pieces = data.match(/^([0-9]+)(\+)?(.*)/); | |
if (pieces) { | |
packet.ackId = pieces[1]; | |
packet.args = []; | |
if (pieces[3]) { | |
try { | |
packet.args = pieces[3] ? JSON.parse(pieces[3]) : []; | |
} catch (e) { } | |
} | |
} | |
break; | |
case 'disconnect': | |
case 'heartbeat': | |
break; | |
}; | |
return packet; | |
}; | |
/** | |
* Decodes data payload. Detects multiple messages | |
* | |
* @return {Array} messages | |
* @api public | |
*/ | |
parser.decodePayload = function (data) { | |
// IE doesn't like data[i] for unicode chars, charAt works fine | |
if (data.charAt(0) == '\ufffd') { | |
var ret = []; | |
for (var i = 1, length = ''; i < data.length; i++) { | |
if (data.charAt(i) == '\ufffd') { | |
ret.push(parser.decodePacket(data.substr(i + 1).substr(0, length))); | |
i += Number(length) + 1; | |
length = ''; | |
} else { | |
length += data.charAt(i); | |
} | |
} | |
return ret; | |
} else { | |
return [parser.decodePacket(data)]; | |
} | |
}; | |
})( | |
'undefined' != typeof io ? io : module.exports | |
, 'undefined' != typeof io ? io : module.parent.exports | |
); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, io) { | |
/** | |
* Expose constructor. | |
*/ | |
exports.Transport = Transport; | |
/** | |
* This is the transport template for all supported transport methods. | |
* | |
* @constructor | |
* @api public | |
*/ | |
function Transport (socket, sessid) { | |
this.socket = socket; | |
this.sessid = sessid; | |
}; | |
/** | |
* Apply EventEmitter mixin. | |
*/ | |
io.util.mixin(Transport, io.EventEmitter); | |
/** | |
* Indicates whether heartbeats is enabled for this transport | |
* | |
* @api private | |
*/ | |
Transport.prototype.heartbeats = function () { | |
return true; | |
}; | |
/** | |
* Handles the response from the server. When a new response is received | |
* it will automatically update the timeout, decode the message and | |
* forwards the response to the onMessage function for further processing. | |
* | |
* @param {String} data Response from the server. | |
* @api private | |
*/ | |
Transport.prototype.onData = function (data) { | |
this.clearCloseTimeout(); | |
// If the connection in currently open (or in a reopening state) reset the close | |
// timeout since we have just received data. This check is necessary so | |
// that we don't reset the timeout on an explicitly disconnected connection. | |
if (this.socket.connected || this.socket.connecting || this.socket.reconnecting) { | |
this.setCloseTimeout(); | |
} | |
if (data !== '') { | |
// todo: we should only do decodePayload for xhr transports | |
var msgs = io.parser.decodePayload(data); | |
if (msgs && msgs.length) { | |
for (var i = 0, l = msgs.length; i < l; i++) { | |
this.onPacket(msgs[i]); | |
} | |
} | |
} | |
return this; | |
}; | |
/** | |
* Handles packets. | |
* | |
* @api private | |
*/ | |
Transport.prototype.onPacket = function (packet) { | |
this.socket.setHeartbeatTimeout(); | |
if (packet.type == 'heartbeat') { | |
return this.onHeartbeat(); | |
} | |
if (packet.type == 'connect' && packet.endpoint == '') { | |
this.onConnect(); | |
} | |
if (packet.type == 'error' && packet.advice == 'reconnect') { | |
this.isOpen = false; | |
} | |
this.socket.onPacket(packet); | |
return this; | |
}; | |
/** | |
* Sets close timeout | |
* | |
* @api private | |
*/ | |
Transport.prototype.setCloseTimeout = function () { | |
if (!this.closeTimeout) { | |
var self = this; | |
this.closeTimeout = setTimeout(function () { | |
self.onDisconnect(); | |
}, this.socket.closeTimeout); | |
} | |
}; | |
/** | |
* Called when transport disconnects. | |
* | |
* @api private | |
*/ | |
Transport.prototype.onDisconnect = function () { | |
if (this.isOpen) this.close(); | |
this.clearTimeouts(); | |
this.socket.onDisconnect(); | |
return this; | |
}; | |
/** | |
* Called when transport connects | |
* | |
* @api private | |
*/ | |
Transport.prototype.onConnect = function () { | |
this.socket.onConnect(); | |
return this; | |
}; | |
/** | |
* Clears close timeout | |
* | |
* @api private | |
*/ | |
Transport.prototype.clearCloseTimeout = function () { | |
if (this.closeTimeout) { | |
clearTimeout(this.closeTimeout); | |
this.closeTimeout = null; | |
} | |
}; | |
/** | |
* Clear timeouts | |
* | |
* @api private | |
*/ | |
Transport.prototype.clearTimeouts = function () { | |
this.clearCloseTimeout(); | |
if (this.reopenTimeout) { | |
clearTimeout(this.reopenTimeout); | |
} | |
}; | |
/** | |
* Sends a packet | |
* | |
* @param {Object} packet object. | |
* @api private | |
*/ | |
Transport.prototype.packet = function (packet) { | |
this.send(io.parser.encodePacket(packet)); | |
}; | |
/** | |
* Send the received heartbeat message back to server. So the server | |
* knows we are still connected. | |
* | |
* @param {String} heartbeat Heartbeat response from the server. | |
* @api private | |
*/ | |
Transport.prototype.onHeartbeat = function (heartbeat) { | |
this.packet({ type: 'heartbeat' }); | |
}; | |
/** | |
* Called when the transport opens. | |
* | |
* @api private | |
*/ | |
Transport.prototype.onOpen = function () { | |
this.isOpen = true; | |
this.clearCloseTimeout(); | |
this.socket.onOpen(); | |
}; | |
/** | |
* Notifies the base when the connection with the Socket.IO server | |
* has been disconnected. | |
* | |
* @api private | |
*/ | |
Transport.prototype.onClose = function () { | |
var self = this; | |
/* FIXME: reopen delay causing a infinit loop | |
this.reopenTimeout = setTimeout(function () { | |
self.open(); | |
}, this.socket.options['reopen delay']);*/ | |
this.isOpen = false; | |
this.socket.onClose(); | |
this.onDisconnect(); | |
}; | |
/** | |
* Generates a connection url based on the Socket.IO URL Protocol. | |
* See <https://github.com/learnboost/socket.io-node/> for more details. | |
* | |
* @returns {String} Connection url | |
* @api private | |
*/ | |
Transport.prototype.prepareUrl = function () { | |
var options = this.socket.options; | |
return this.scheme() + '://' | |
+ options.host + ':' + options.port + '/' | |
+ options.resource + '/' + io.protocol | |
+ '/' + this.name + '/' + this.sessid; | |
}; | |
/** | |
* Generates a connection url based on the Socket.IO URL Protocol. | |
* This is only called for the websocket transport and uses wsport. | |
* Added by @vene | |
* | |
* See <https://github.com/learnboost/socket.io-node/> for more details. | |
* | |
* @returns {String} Connection url | |
* @api private | |
*/ | |
Transport.prototype.prepareWsUrl = function () { | |
var options = this.socket.options; | |
return this.scheme() + '://' | |
+ options.host + ':' + options.wsport + '/' | |
+ options.resource + '/' + io.protocol | |
+ '/' + this.name + '/' + this.sessid; | |
}; | |
/** | |
* Checks if the transport is ready to start a connection. | |
* | |
* @param {Socket} socket The socket instance that needs a transport | |
* @param {Function} fn The callback | |
* @api private | |
*/ | |
Transport.prototype.ready = function (socket, fn) { | |
fn.call(this); | |
}; | |
})( | |
'undefined' != typeof io ? io : module.exports | |
, 'undefined' != typeof io ? io : module.parent.exports | |
); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, io, global) { | |
/** | |
* Expose constructor. | |
*/ | |
exports.Socket = Socket; | |
/** | |
* Create a new `Socket.IO client` which can establish a persistent | |
* connection with a Socket.IO enabled server. | |
* | |
* @api public | |
*/ | |
function Socket (options) { | |
this.options = { | |
port: 80 | |
, wsport: 80 // added by @vene | |
, secure: false | |
, document: 'document' in global ? document : false | |
, resource: 'socket.io' | |
, transports: io.transports | |
, 'connect timeout': 10000 | |
, 'try multiple transports': true | |
, 'reconnect': true | |
, 'reconnection delay': 500 | |
, 'reconnection limit': Infinity | |
, 'reopen delay': 3000 | |
, 'max reconnection attempts': 10 | |
, 'sync disconnect on unload': false | |
, 'auto connect': true | |
, 'flash policy port': 10843 | |
, 'manualFlush': false | |
}; | |
io.util.merge(this.options, options); | |
this.connected = false; | |
this.open = false; | |
this.connecting = false; | |
this.reconnecting = false; | |
this.namespaces = {}; | |
this.buffer = []; | |
this.doBuffer = false; | |
if (this.options['sync disconnect on unload'] && | |
(!this.isXDomain() || io.util.ua.hasCORS)) { | |
var self = this; | |
io.util.on(global, 'beforeunload', function () { | |
self.disconnectSync(); | |
}, false); | |
} | |
if (this.options['auto connect']) { | |
this.connect(); | |
} | |
}; | |
/** | |
* Apply EventEmitter mixin. | |
*/ | |
io.util.mixin(Socket, io.EventEmitter); | |
/** | |
* Returns a namespace listener/emitter for this socket | |
* | |
* @api public | |
*/ | |
Socket.prototype.of = function (name) { | |
if (!this.namespaces[name]) { | |
this.namespaces[name] = new io.SocketNamespace(this, name); | |
if (name !== '') { | |
this.namespaces[name].packet({ type: 'connect' }); | |
} | |
} | |
return this.namespaces[name]; | |
}; | |
/** | |
* Emits the given event to the Socket and all namespaces | |
* | |
* @api private | |
*/ | |
Socket.prototype.publish = function () { | |
this.emit.apply(this, arguments); | |
var nsp; | |
for (var i in this.namespaces) { | |
if (this.namespaces.hasOwnProperty(i)) { | |
nsp = this.of(i); | |
nsp.$emit.apply(nsp, arguments); | |
} | |
} | |
}; | |
/** | |
* Performs the handshake | |
* | |
* @api private | |
*/ | |
function empty () { }; | |
Socket.prototype.handshake = function (fn) { | |
var self = this | |
, options = this.options; | |
function complete (data) { | |
if (data instanceof Error) { | |
self.connecting = false; | |
self.onError(data.message); | |
} else { | |
fn.apply(null, data.split(':')); | |
} | |
}; | |
var url = [ | |
'http' + (options.secure ? 's' : '') + ':/' | |
, options.host + ':' + options.port | |
, options.resource | |
, io.protocol | |
, io.util.query(this.options.query, 't=' + +new Date) | |
].join('/'); | |
if (this.isXDomain() && !io.util.ua.hasCORS) { | |
var insertAt = document.getElementsByTagName('script')[0] | |
, script = document.createElement('script'); | |
script.src = url + '&jsonp=' + io.j.length; | |
insertAt.parentNode.insertBefore(script, insertAt); | |
io.j.push(function (data) { | |
complete(data); | |
script.parentNode.removeChild(script); | |
}); | |
} else { | |
var xhr = io.util.request(); | |
xhr.open('GET', url, true); | |
if (this.isXDomain()) { | |
xhr.withCredentials = true; | |
} | |
xhr.onreadystatechange = function () { | |
if (xhr.readyState == 4) { | |
xhr.onreadystatechange = empty; | |
if (xhr.status == 200) { | |
complete(xhr.responseText); | |
} else if (xhr.status == 403) { | |
self.onError(xhr.responseText); | |
} else { | |
self.connecting = false; | |
!self.reconnecting && self.onError(xhr.responseText); | |
} | |
} | |
}; | |
xhr.send(null); | |
} | |
}; | |
/** | |
* Find an available transport based on the options supplied in the constructor. | |
* | |
* @api private | |
*/ | |
Socket.prototype.getTransport = function (override) { | |
var transports = override || this.transports, match; | |
for (var i = 0, transport; transport = transports[i]; i++) { | |
if (io.Transport[transport] | |
&& io.Transport[transport].check(this) | |
&& (!this.isXDomain() || io.Transport[transport].xdomainCheck(this))) { | |
return new io.Transport[transport](this, this.sessionid); | |
} | |
} | |
return null; | |
}; | |
/** | |
* Connects to the server. | |
* | |
* @param {Function} [fn] Callback. | |
* @returns {io.Socket} | |
* @api public | |
*/ | |
Socket.prototype.connect = function (fn) { | |
if (this.connecting) { | |
return this; | |
} | |
var self = this; | |
self.connecting = true; | |
this.handshake(function (sid, heartbeat, close, transports) { | |
self.sessionid = sid; | |
self.closeTimeout = close * 1000; | |
self.heartbeatTimeout = heartbeat * 1000; | |
if(!self.transports) | |
self.transports = self.origTransports = (transports ? io.util.intersect( | |
transports.split(',') | |
, self.options.transports | |
) : self.options.transports); | |
self.setHeartbeatTimeout(); | |
function connect (transports){ | |
if (self.transport) self.transport.clearTimeouts(); | |
self.transport = self.getTransport(transports); | |
if (!self.transport) return self.publish('connect_failed'); | |
// once the transport is ready | |
self.transport.ready(self, function () { | |
self.connecting = true; | |
self.publish('connecting', self.transport.name); | |
self.transport.open(); | |
if (self.options['connect timeout']) { | |
self.connectTimeoutTimer = setTimeout(function () { | |
if (!self.connected) { | |
self.connecting = false; | |
if (self.options['try multiple transports']) { | |
var remaining = self.transports; | |
while (remaining.length > 0 && remaining.splice(0,1)[0] != | |
self.transport.name) {} | |
if (remaining.length){ | |
connect(remaining); | |
} else { | |
self.publish('connect_failed'); | |
} | |
} else { | |
// Nothing left to try, so we fail. Branch added by @vene. | |
self.publish('connect_failed'); | |
} | |
} | |
}, self.options['connect timeout']); | |
} | |
}); | |
} | |
connect(self.transports); | |
self.once('connect', function (){ | |
clearTimeout(self.connectTimeoutTimer); | |
fn && typeof fn == 'function' && fn(); | |
}); | |
}); | |
return this; | |
}; | |
/** | |
* Clears and sets a new heartbeat timeout using the value given by the | |
* server during the handshake. | |
* | |
* @api private | |
*/ | |
Socket.prototype.setHeartbeatTimeout = function () { | |
clearTimeout(this.heartbeatTimeoutTimer); | |
if(this.transport && !this.transport.heartbeats()) return; | |
var self = this; | |
this.heartbeatTimeoutTimer = setTimeout(function () { | |
self.transport.onClose(); | |
}, this.heartbeatTimeout); | |
}; | |
/** | |
* Sends a message. | |
* | |
* @param {Object} data packet. | |
* @returns {io.Socket} | |
* @api public | |
*/ | |
Socket.prototype.packet = function (data) { | |
if (this.connected && !this.doBuffer) { | |
this.transport.packet(data); | |
} else { | |
this.buffer.push(data); | |
} | |
return this; | |
}; | |
/** | |
* Sets buffer state | |
* | |
* @api private | |
*/ | |
Socket.prototype.setBuffer = function (v) { | |
this.doBuffer = v; | |
if (!v && this.connected && this.buffer.length) { | |
if (!this.options['manualFlush']) { | |
this.flushBuffer(); | |
} | |
} | |
}; | |
/** | |
* Flushes the buffer data over the wire. | |
* To be invoked manually when 'manualFlush' is set to true. | |
* | |
* @api public | |
*/ | |
Socket.prototype.flushBuffer = function() { | |
this.transport.payload(this.buffer); | |
this.buffer = []; | |
}; | |
/** | |
* Disconnect the established connect. | |
* | |
* @returns {io.Socket} | |
* @api public | |
*/ | |
Socket.prototype.disconnect = function () { | |
if (this.connected || this.connecting) { | |
if (this.open) { | |
this.of('').packet({ type: 'disconnect' }); | |
} | |
// handle disconnection immediately | |
this.onDisconnect('booted'); | |
} | |
return this; | |
}; | |
/** | |
* Disconnects the socket with a sync XHR. | |
* | |
* @api private | |
*/ | |
Socket.prototype.disconnectSync = function () { | |
// ensure disconnection | |
var xhr = io.util.request(); | |
var uri = [ | |
'http' + (this.options.secure ? 's' : '') + ':/' | |
, this.options.host + ':' + this.options.port | |
, this.options.resource | |
, io.protocol | |
, '' | |
, this.sessionid | |
].join('/') + '/?disconnect=1'; | |
xhr.open('GET', uri, false); | |
xhr.send(null); | |
// handle disconnection immediately | |
this.onDisconnect('booted'); | |
}; | |
/** | |
* Check if we need to use cross domain enabled transports. Cross domain would | |
* be a different port or different domain name. | |
* | |
* @returns {Boolean} | |
* @api private | |
*/ | |
Socket.prototype.isXDomain = function () { | |
var port = global.location.port || | |
('https:' == global.location.protocol ? 443 : 80); | |
return this.options.host !== global.location.hostname | |
|| this.options.port != port; | |
}; | |
/** | |
* Called upon handshake. | |
* | |
* @api private | |
*/ | |
Socket.prototype.onConnect = function () { | |
if (!this.connected) { | |
this.connected = true; | |
this.connecting = false; | |
if (!this.doBuffer) { | |
// make sure to flush the buffer | |
this.setBuffer(false); | |
} | |
this.emit('connect'); | |
} | |
}; | |
/** | |
* Called when the transport opens | |
* | |
* @api private | |
*/ | |
Socket.prototype.onOpen = function () { | |
this.open = true; | |
}; | |
/** | |
* Called when the transport closes. | |
* | |
* @api private | |
*/ | |
Socket.prototype.onClose = function () { | |
this.open = false; | |
clearTimeout(this.heartbeatTimeoutTimer); | |
}; | |
/** | |
* Called when the transport first opens a connection | |
* | |
* @param text | |
*/ | |
Socket.prototype.onPacket = function (packet) { | |
this.of(packet.endpoint).onPacket(packet); | |
}; | |
/** | |
* Handles an error. | |
* | |
* @api private | |
*/ | |
Socket.prototype.onError = function (err) { | |
if (err && err.advice) { | |
if (err.advice === 'reconnect' && (this.connected || this.connecting)) { | |
this.disconnect(); | |
if (this.options.reconnect) { | |
this.reconnect(); | |
} | |
} | |
} | |
this.publish('error', err && err.reason ? err.reason : err); | |
}; | |
/** | |
* Called when the transport disconnects. | |
* | |
* @api private | |
*/ | |
Socket.prototype.onDisconnect = function (reason) { | |
var wasConnected = this.connected | |
, wasConnecting = this.connecting; | |
this.connected = false; | |
this.connecting = false; | |
this.open = false; | |
if (wasConnected || wasConnecting) { | |
this.transport.close(); | |
this.transport.clearTimeouts(); | |
if (wasConnected) { | |
this.publish('disconnect', reason); | |
if ('booted' != reason && this.options.reconnect && !this.reconnecting) { | |
this.reconnect(); | |
} | |
} | |
} | |
}; | |
/** | |
* Called upon reconnection. | |
* | |
* @api private | |
*/ | |
Socket.prototype.reconnect = function () { | |
this.reconnecting = true; | |
this.reconnectionAttempts = 0; | |
this.reconnectionDelay = this.options['reconnection delay']; | |
var self = this | |
, maxAttempts = this.options['max reconnection attempts'] | |
, tryMultiple = this.options['try multiple transports'] | |
, limit = this.options['reconnection limit']; | |
function reset () { | |
if (self.connected) { | |
for (var i in self.namespaces) { | |
if (self.namespaces.hasOwnProperty(i) && '' !== i) { | |
self.namespaces[i].packet({ type: 'connect' }); | |
} | |
} | |
self.publish('reconnect', self.transport.name, self.reconnectionAttempts); | |
} | |
clearTimeout(self.reconnectionTimer); | |
self.removeListener('connect_failed', maybeReconnect); | |
self.removeListener('connect', maybeReconnect); | |
self.reconnecting = false; | |
delete self.reconnectionAttempts; | |
delete self.reconnectionDelay; | |
delete self.reconnectionTimer; | |
delete self.redoTransports; | |
self.options['try multiple transports'] = tryMultiple; | |
}; | |
function maybeReconnect () { | |
if (!self.reconnecting) { | |
return; | |
} | |
if (self.connected) { | |
return reset(); | |
}; | |
if (self.connecting && self.reconnecting) { | |
return self.reconnectionTimer = setTimeout(maybeReconnect, 1000); | |
} | |
if (self.reconnectionAttempts++ >= maxAttempts) { | |
if (!self.redoTransports) { | |
self.on('connect_failed', maybeReconnect); | |
self.options['try multiple transports'] = true; | |
self.transports = self.origTransports; | |
self.transport = self.getTransport(); | |
self.redoTransports = true; | |
self.connect(); | |
} else { | |
self.publish('reconnect_failed'); | |
reset(); | |
} | |
} else { | |
if (self.reconnectionDelay < limit) { | |
self.reconnectionDelay *= 2; // exponential back off | |
} | |
self.connect(); | |
self.publish('reconnecting', self.reconnectionDelay, self.reconnectionAttempts); | |
self.reconnectionTimer = setTimeout(maybeReconnect, self.reconnectionDelay); | |
} | |
}; | |
this.options['try multiple transports'] = false; | |
this.reconnectionTimer = setTimeout(maybeReconnect, this.reconnectionDelay); | |
this.on('connect', maybeReconnect); | |
}; | |
})( | |
'undefined' != typeof io ? io : module.exports | |
, 'undefined' != typeof io ? io : module.parent.exports | |
, this | |
); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, io) { | |
/** | |
* Expose constructor. | |
*/ | |
exports.SocketNamespace = SocketNamespace; | |
/** | |
* Socket namespace constructor. | |
* | |
* @constructor | |
* @api public | |
*/ | |
function SocketNamespace (socket, name) { | |
this.socket = socket; | |
this.name = name || ''; | |
this.flags = {}; | |
this.json = new Flag(this, 'json'); | |
this.ackPackets = 0; | |
this.acks = {}; | |
}; | |
/** | |
* Apply EventEmitter mixin. | |
*/ | |
io.util.mixin(SocketNamespace, io.EventEmitter); | |
/** | |
* Copies emit since we override it | |
* | |
* @api private | |
*/ | |
SocketNamespace.prototype.$emit = io.EventEmitter.prototype.emit; | |
/** | |
* Creates a new namespace, by proxying the request to the socket. This | |
* allows us to use the synax as we do on the server. | |
* | |
* @api public | |
*/ | |
SocketNamespace.prototype.of = function () { | |
return this.socket.of.apply(this.socket, arguments); | |
}; | |
/** | |
* Sends a packet. | |
* | |
* @api private | |
*/ | |
SocketNamespace.prototype.packet = function (packet) { | |
packet.endpoint = this.name; | |
this.socket.packet(packet); | |
this.flags = {}; | |
return this; | |
}; | |
/** | |
* Sends a message | |
* | |
* @api public | |
*/ | |
SocketNamespace.prototype.send = function (data, fn) { | |
var packet = { | |
type: this.flags.json ? 'json' : 'message' | |
, data: data | |
}; | |
if ('function' == typeof fn) { | |
packet.id = ++this.ackPackets; | |
packet.ack = true; | |
this.acks[packet.id] = fn; | |
} | |
return this.packet(packet); | |
}; | |
/** | |
* Emits an event | |
* | |
* @api public | |
*/ | |
SocketNamespace.prototype.emit = function (name) { | |
var args = Array.prototype.slice.call(arguments, 1) | |
, lastArg = args[args.length - 1] | |
, packet = { | |
type: 'event' | |
, name: name | |
}; | |
if ('function' == typeof lastArg) { | |
packet.id = ++this.ackPackets; | |
packet.ack = 'data'; | |
this.acks[packet.id] = lastArg; | |
args = args.slice(0, args.length - 1); | |
} | |
packet.args = args; | |
return this.packet(packet); | |
}; | |
/** | |
* Disconnects the namespace | |
* | |
* @api private | |
*/ | |
SocketNamespace.prototype.disconnect = function () { | |
if (this.name === '') { | |
this.socket.disconnect(); | |
} else { | |
this.packet({ type: 'disconnect' }); | |
this.$emit('disconnect'); | |
} | |
return this; | |
}; | |
/** | |
* Handles a packet | |
* | |
* @api private | |
*/ | |
SocketNamespace.prototype.onPacket = function (packet) { | |
var self = this; | |
function ack () { | |
self.packet({ | |
type: 'ack' | |
, args: io.util.toArray(arguments) | |
, ackId: packet.id | |
}); | |
}; | |
switch (packet.type) { | |
case 'connect': | |
this.$emit('connect'); | |
break; | |
case 'disconnect': | |
if (this.name === '') { | |
this.socket.onDisconnect(packet.reason || 'booted'); | |
} else { | |
this.$emit('disconnect', packet.reason); | |
} | |
break; | |
case 'message': | |
case 'json': | |
var params = ['message', packet.data]; | |
if (packet.ack == 'data') { | |
params.push(ack); | |
} else if (packet.ack) { | |
this.packet({ type: 'ack', ackId: packet.id }); | |
} | |
this.$emit.apply(this, params); | |
break; | |
case 'event': | |
var params = [packet.name].concat(packet.args); | |
if (packet.ack == 'data') | |
params.push(ack); | |
this.$emit.apply(this, params); | |
break; | |
case 'ack': | |
if (this.acks[packet.ackId]) { | |
this.acks[packet.ackId].apply(this, packet.args); | |
delete this.acks[packet.ackId]; | |
} | |
break; | |
case 'error': | |
if (packet.advice){ | |
this.socket.onError(packet); | |
} else { | |
if (packet.reason == 'unauthorized') { | |
this.$emit('connect_failed', packet.reason); | |
} else { | |
this.$emit('error', packet.reason); | |
} | |
} | |
break; | |
} | |
}; | |
/** | |
* Flag interface. | |
* | |
* @api private | |
*/ | |
function Flag (nsp, name) { | |
this.namespace = nsp; | |
this.name = name; | |
}; | |
/** | |
* Send a message | |
* | |
* @api public | |
*/ | |
Flag.prototype.send = function () { | |
this.namespace.flags[this.name] = true; | |
this.namespace.send.apply(this.namespace, arguments); | |
}; | |
/** | |
* Emit an event | |
* | |
* @api public | |
*/ | |
Flag.prototype.emit = function () { | |
this.namespace.flags[this.name] = true; | |
this.namespace.emit.apply(this.namespace, arguments); | |
}; | |
})( | |
'undefined' != typeof io ? io : module.exports | |
, 'undefined' != typeof io ? io : module.parent.exports | |
); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, io, global) { | |
/** | |
* Expose constructor. | |
*/ | |
exports.websocket = WS; | |
/** | |
* The WebSocket transport uses the HTML5 WebSocket API to establish an | |
* persistent connection with the Socket.IO server. This transport will also | |
* be inherited by the FlashSocket fallback as it provides a API compatible | |
* polyfill for the WebSockets. | |
* | |
* @constructor | |
* @extends {io.Transport} | |
* @api public | |
*/ | |
function WS (socket) { | |
io.Transport.apply(this, arguments); | |
}; | |
/** | |
* Inherits from Transport. | |
*/ | |
io.util.inherit(WS, io.Transport); | |
/** | |
* Transport name | |
* | |
* @api public | |
*/ | |
WS.prototype.name = 'websocket'; | |
/** | |
* Initializes a new `WebSocket` connection with the Socket.IO server. We attach | |
* all the appropriate listeners to handle the responses from the server. | |
* | |
* @returns {Transport} | |
* @api public | |
*/ | |
WS.prototype.open = function () { | |
var query = io.util.query(this.socket.options.query) | |
, self = this | |
, Socket | |
if (!Socket) { | |
Socket = global.MozWebSocket || global.WebSocket; | |
} | |
// Change by @vene: use ws-specific url generator to allow a different port | |
this.websocket = new Socket(this.prepareWsUrl() + query); | |
this.websocket.onopen = function () { | |
self.onOpen(); | |
self.socket.setBuffer(false); | |
}; | |
this.websocket.onmessage = function (ev) { | |
self.onData(ev.data); | |
}; | |
this.websocket.onclose = function () { | |
self.onClose(); | |
self.socket.setBuffer(true); | |
}; | |
this.websocket.onerror = function (e) { | |
self.onError(e); | |
}; | |
return this; | |
}; | |
/** | |
* Send a message to the Socket.IO server. The message will automatically be | |
* encoded in the correct message format. | |
* | |
* @returns {Transport} | |
* @api public | |
*/ | |
// Do to a bug in the current IDevices browser, we need to wrap the send in a | |
// setTimeout, when they resume from sleeping the browser will crash if | |
// we don't allow the browser time to detect the socket has been closed | |
if (io.util.ua.iDevice) { | |
WS.prototype.send = function (data) { | |
var self = this; | |
setTimeout(function() { | |
self.websocket.send(data); | |
},0); | |
return this; | |
}; | |
} else { | |
WS.prototype.send = function (data) { | |
this.websocket.send(data); | |
return this; | |
}; | |
} | |
/** | |
* Payload | |
* | |
* @api private | |
*/ | |
WS.prototype.payload = function (arr) { | |
for (var i = 0, l = arr.length; i < l; i++) { | |
this.packet(arr[i]); | |
} | |
return this; | |
}; | |
/** | |
* Disconnect the established `WebSocket` connection. | |
* | |
* @returns {Transport} | |
* @api public | |
*/ | |
WS.prototype.close = function () { | |
this.websocket.close(); | |
return this; | |
}; | |
/** | |
* Handle the errors that `WebSocket` might be giving when we | |
* are attempting to connect or send messages. | |
* | |
* @param {Error} e The error. | |
* @api private | |
*/ | |
WS.prototype.onError = function (e) { | |
this.socket.onError(e); | |
}; | |
/** | |
* Returns the appropriate scheme for the URI generation. | |
* | |
* @api private | |
*/ | |
WS.prototype.scheme = function () { | |
return this.socket.options.secure ? 'wss' : 'ws'; | |
}; | |
/** | |
* Checks if the browser has support for native `WebSockets` and that | |
* it's not the polyfill created for the FlashSocket transport. | |
* | |
* @return {Boolean} | |
* @api public | |
*/ | |
WS.check = function () { | |
return ('WebSocket' in global && !('__addTask' in WebSocket)) | |
|| 'MozWebSocket' in global; | |
}; | |
/** | |
* Check if the `WebSocket` transport support cross domain communications. | |
* | |
* @returns {Boolean} | |
* @api public | |
*/ | |
WS.xdomainCheck = function () { | |
return true; | |
}; | |
/** | |
* Add the transport to your public io.transports array. | |
* | |
* @api private | |
*/ | |
io.transports.push('websocket'); | |
})( | |
'undefined' != typeof io ? io.Transport : module.exports | |
, 'undefined' != typeof io ? io : module.parent.exports | |
, this | |
); | |
/** | |
* socket.io | |
* Copyright(c) 2011 LearnBoost <dev@learnboost.com> | |
* MIT Licensed | |
*/ | |
(function (exports, io) { | |
/** | |
* Expose constructor. | |
*/ | |
exports.flashsocket = Flashsocket; | |
/** | |
* The FlashSocket transport. This is a API wrapper for the HTML5 WebSocket | |
* specification. It uses a .swf file to communicate with the server. If you want | |
* to serve the .swf file from a other server than where the Socket.IO script is | |
* coming from you need to use the insecure version of the .swf. More information | |
* about this can be found on the github page. | |
* | |
* @constructor | |
* @extends {io.Transport.websocket} | |
* @api public | |
*/ | |
function Flashsocket () { | |