/socket.io.js
Last active Mar 8, 2019
socketio-client 0.9.16 fork
| /*! 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 () { | |
| io.Transport.websocket.apply(this, arguments); | |
| }; | |
| /** | |
| * Inherits from Transport. | |
| */ | |
| io.util.inherit(Flashsocket, io.Transport.websocket); | |
| /** | |
| * Transport name | |
| * | |
| * @api public | |
| */ | |
| Flashsocket.prototype.name = 'flashsocket'; | |
| /** | |
| * Disconnect the established `FlashSocket` connection. This is done by adding a | |
| * new task to the FlashSocket. The rest will be handled off by the `WebSocket` | |
| * transport. | |
| * | |
| * @returns {Transport} | |
| * @api public | |
| */ | |
| Flashsocket.prototype.open = function () { | |
| var self = this | |
| , args = arguments; | |
| WebSocket.__addTask(function () { | |
| io.Transport.websocket.prototype.open.apply(self, args); | |
| }); | |
| return this; | |
| }; | |
| /** | |
| * Sends a message to the Socket.IO server. This is done by adding a new | |
| * task to the FlashSocket. The rest will be handled off by the `WebSocket` | |
| * transport. | |
| * | |
| * @returns {Transport} | |
| * @api public | |
| */ | |
| Flashsocket.prototype.send = function () { | |
| var self = this, args = arguments; | |
| WebSocket.__addTask(function () { | |
| io.Transport.websocket.prototype.send.apply(self, args); | |
| }); | |
| return this; | |
| }; | |
| /** | |
| * Disconnects the established `FlashSocket` connection. | |
| * | |
| * @returns {Transport} | |
| * @api public | |
| */ | |
| Flashsocket.prototype.close = function () { | |
| WebSocket.__tasks.length = 0; | |
| io.Transport.websocket.prototype.close.call(this); | |
| return this; | |
| }; | |
| /** | |
| * The WebSocket fall back needs to append the flash container to the body | |
| * element, so we need to make sure we have access to it. Or defer the call | |
| * until we are sure there is a body element. | |
| * | |
| * @param {Socket} socket The socket instance that needs a transport | |
| * @param {Function} fn The callback | |
| * @api private | |
| */ | |
| Flashsocket.prototype.ready = function (socket, fn) { | |
| function init () { | |
| var options = socket.options | |
| , port = options['flash policy port'] | |
| , path = [ | |
| 'http' + (options.secure ? 's' : '') + ':/' | |
| , options.host + ':' + options.port | |
| , options.resource | |
| , 'static/flashsocket' | |
| , 'WebSocketMain' + (socket.isXDomain() ? 'Insecure' : '') + '.swf' | |
| ]; | |
| // Only start downloading the swf file when the checked that this browser | |
| // actually supports it | |
| if (!Flashsocket.loaded) { | |
| if (typeof WEB_SOCKET_SWF_LOCATION === 'undefined') { | |
| // Set the correct file based on the XDomain settings | |
| WEB_SOCKET_SWF_LOCATION = path.join('/'); | |
| } | |
| if (port !== 843) { | |
| WebSocket.loadFlashPolicyFile('xmlsocket://' + options.host + ':' + port); | |
| } | |
| WebSocket.__initialize(); | |
| Flashsocket.loaded = true; | |
| } | |
| fn.call(self); | |
| } | |
| var self = this; | |
| if (document.body) return init(); | |
| io.util.load(init); | |
| }; | |
| /** | |
| * Check if the FlashSocket transport is supported as it requires that the Adobe | |
| * Flash Player plug-in version `10.0.0` or greater is installed. And also check if | |
| * the polyfill is correctly loaded. | |
| * | |
| * @returns {Boolean} | |
| * @api public | |
| */ | |
| Flashsocket.check = function () { | |
| if ( | |
| typeof WebSocket == 'undefined' | |
| || !('__initialize' in WebSocket) || !swfobject | |
| ) return false; | |
| return swfobject.getFlashPlayerVersion().major >= 10; | |
| }; | |
| /** | |
| * Check if the FlashSocket transport can be used as cross domain / cross origin | |
| * transport. Because we can't see which type (secure or insecure) of .swf is used | |
| * we will just return true. | |
| * | |
| * @returns {Boolean} | |
| * @api public | |
| */ | |
| Flashsocket.xdomainCheck = function () { | |
| return true; | |
| }; | |
| /** | |
| * Disable AUTO_INITIALIZATION | |
| */ | |
| if (typeof window != 'undefined') { | |
| WEB_SOCKET_DISABLE_AUTO_INITIALIZATION = true; | |
| } | |
| /** | |
| * Add the transport to your public io.transports array. | |
| * | |
| * @api private | |
| */ | |
| io.transports.push('flashsocket'); | |
| })( | |
| 'undefined' != typeof io ? io.Transport : module.exports | |
| , 'undefined' != typeof io ? io : module.parent.exports | |
| ); | |
| /* SWFObject v2.2 <http://code.google.com/p/swfobject/> | |
| is released under the MIT License <http://www.opensource.org/licenses/mit-license.php> | |
| */ | |
| if ('undefined' != typeof window) { | |
| 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[(['Active'].concat('Object').join('X'))]!=D){try{var ad=new window[(['Active'].concat('Object').join('X'))](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;Y<X;Y++){U[Y]()}}function K(X){if(J){X()}else{U[U.length]=X}}function s(Y){if(typeof O.addEventListener!=D){O.addEventListener("load",Y,false)}else{if(typeof j.addEventListener!=D){j.addEventListener("load",Y,false)}else{if(typeof O.attachEvent!=D){i(O,"onload",Y)}else{if(typeof O.onload=="function"){var X=O.onload;O.onload=function(){X();Y()}}else{O.onload=Y}}}}}function h(){if(T){V()}else{H()}}function V(){var X=j.getElementsByTagName("body")[0];var aa=C(r);aa.setAttribute("type",q);var Z=X.appendChild(aa);if(Z){var Y=0;(function(){if(typeof Z.GetVariable!=D){var ab=Z.GetVariable("$version");if(ab){ab=ab.split(" ")[1].split(",");M.pv=[parseInt(ab[0],10),parseInt(ab[1],10),parseInt(ab[2],10)]}}else{if(Y<10){Y++;setTimeout(arguments.callee,10);return}}X.removeChild(aa);Z=null;H()})()}else{H()}}function H(){var ag=o.length;if(ag>0){for(var af=0;af<ag;af++){var Y=o[af].id;var ab=o[af].callbackFn;var aa={success:false,id:Y};if(M.pv[0]>0){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<ac;ad++){if(X[ad].getAttribute("name").toLowerCase()!="movie"){ah[X[ad].getAttribute("name")]=X[ad].getAttribute("value")}}P(ai,ah,Y,ab)}else{p(ae);if(ab){ab(aa)}}}}}else{w(Y,true);if(ab){var Z=z(Y);if(Z&&typeof Z.SetVariable!=D){aa.success=true;aa.ref=Z}ab(aa)}}}}}function z(aa){var X=null;var Y=c(aa);if(Y&&Y.nodeName=="OBJECT"){if(typeof Y.SetVariable!=D){X=Y}else{var Z=Y.getElementsByTagName(r)[0];if(Z){X=Z}}}return X}function A(){return !a&&F("6.0.65")&&(M.win||M.mac)&&!(M.wk&&M.wk<312)}function P(aa,ab,X,Z){a=true;E=Z||null;B={success:false,id:X};var ae=c(X);if(ae){if(ae.nodeName=="OBJECT"){l=g(ae);Q=null}else{l=ae;Q=X}aa.id=R;if(typeof aa.width==D||(!/%$/.test(aa.width)&&parseInt(aa.width,10)<310)){aa.width="310"}if(typeof aa.height==D||(!/%$/.test(aa.height)&&parseInt(aa.height,10)<137)){aa.height="137"}j.title=j.title.slice(0,47)+" - Flash Player Installation";var ad=M.ie&&M.win?(['Active'].concat('').join('X')):"PlugIn",ac="MMredirectURL="+O.location.toString().replace(/&/g,"%26")+"&MMplayerType="+ad+"&MMdoctitle="+j.title;if(typeof ab.flashvars!=D){ab.flashvars+="&"+ac}else{ab.flashvars=ac}if(M.ie&&M.win&&ae.readyState!=4){var Y=C("div");X+="SWFObjectNew";Y.setAttribute("id",X);ae.parentNode.insertBefore(Y,ae);ae.style.display="none";(function(){if(ae.readyState==4){ae.parentNode.removeChild(ae)}else{setTimeout(arguments.callee,10)}})()}u(aa,ab,X)}}function p(Y){if(M.ie&&M.win&&Y.readyState!=4){var X=C("div");Y.parentNode.insertBefore(X,Y);X.parentNode.replaceChild(g(Y),X);Y.style.display="none";(function(){if(Y.readyState==4){Y.parentNode.removeChild(Y)}else{setTimeout(arguments.callee,10)}})()}else{Y.parentNode.replaceChild(g(Y),Y)}}function g(ab){var aa=C("div");if(M.win&&M.ie){aa.innerHTML=ab.innerHTML}else{var Y=ab.getElementsByTagName(r)[0];if(Y){var ad=Y.childNodes;if(ad){var X=ad.length;for(var Z=0;Z<X;Z++){if(!(ad[Z].nodeType==1&&ad[Z].nodeName=="PARAM")&&!(ad[Z].nodeType==8)){aa.appendChild(ad[Z].cloneNode(true))}}}}}return aa}function u(ai,ag,Y){var X,aa=c(Y);if(M.wk&&M.wk<312){return X}if(aa){if(typeof ai.id==D){ai.id=Y}if(M.ie&&M.win){var ah="";for(var ae in ai){if(ai[ae]!=Object.prototype[ae]){if(ae.toLowerCase()=="data"){ag.movie=ai[ae]}else{if(ae.toLowerCase()=="styleclass"){ah+=' class="'+ai[ae]+'"'}else{if(ae.toLowerCase()!="classid"){ah+=" "+ae+'="'+ai[ae]+'"'}}}}}var af="";for(var ad in ag){if(ag[ad]!=Object.prototype[ad]){af+='<param name="'+ad+'" value="'+ag[ad]+'" />'}}aa.outerHTML='<object classid="clsid:D27CDB6E-AE6D-11cf-96B8-444553540000"'+ah+">"+af+"</object>";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, |