Last active
April 6, 2020 14:44
-
-
Save rodrigolive/5546320 to your computer and use it in GitHub Desktop.
Mojolicious websocket app that mimicks this one: http://www.html5rocks.com/en/tutorials/frameworks/angular-websockets/?redirect_from_locale=es $ cpanm Mojolicious Class::Date
$ perl socket-app1.pl daemon
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
use Mojolicious::Lite; | |
use Protocol::SocketIO::Message; | |
use Protocol::SocketIO::Handshake; | |
use Class::Date; | |
any '/' => 'index'; | |
any '/view1' => 'index'; | |
any '/view2' => 'index'; | |
any '/partials/:name' => sub { | |
my $self = shift; | |
$self->render( $self->param('name') ); #text=>q{<p>This is the partial for view 1.</p><p>The current time is {{time}}</p>} ); | |
}; | |
any '/socket.io/:id/' => sub { | |
my $self = shift; | |
say $self->req->body; | |
#$self->render( text=>'i3C6QG6qLZ7LrBAiBW9k:60:60:websocket,htmlfile,xhr-polling,jsonp-polling' ); | |
my $handshake = Protocol::SocketIO::Handshake->new( | |
session_id => 1234567890, | |
heartbeat_timeout => 10, | |
close_timeout => 15, | |
transports => [qw/websocket xhr-polling/] | |
); | |
$self->render( text=>$handshake ); | |
}; | |
my $clients = {}; | |
my $delay = Mojo::IOLoop->delay; | |
Mojo::IOLoop->recurring( 1 => sub { | |
for my $id( keys %$clients ) { | |
# send name | |
$clients->{$id}->send( Protocol::SocketIO::Message->new( type => 'event', data=>{ name=>'send:name', args=>[{ name=>'Jamie '.$id }] }) ); | |
# send time | |
$clients->{$id}->send( Protocol::SocketIO::Message->new( type => 'event', data=>{ name=>'send:time', args=>[{ time=>''.Class::Date->now }] }) ); | |
} | |
}); | |
websocket '/socket.io/:id/websocket/:oid' => sub { | |
my $self = shift; | |
app->log->debug(sprintf 'Client connected: %s', $self->tx); | |
my $id = sprintf "%s", $self->tx; | |
$clients->{$id} = $self->tx; | |
$self->tx->send( Protocol::SocketIO::Message->new( type => 'connect') ); | |
$self->tx->send( Protocol::SocketIO::Message->new( type => 'event', data=>{ name=>'send:name', args=>[{ name=>'Jamie starting...' }] }) ); | |
$self->on(message => sub { | |
my ($self, $msg) = @_; | |
# no messages are being sent for now | |
}); | |
$self->on(finish => sub { | |
app->log->debug('Client disconnected'); | |
delete $clients->{$id}; | |
}); | |
}; | |
app->start; | |
__DATA__ | |
@@index.html.ep | |
<!DOCTYPE html> | |
<html ng-app="myApp"> | |
<head> | |
<meta charset="utf8"> | |
<base href="/"> | |
<title>Angular Socket.io Seed App</title> | |
<link rel="stylesheet" href="app.css"> | |
</head> | |
<body> | |
<div ng-controller="AppCtrl"> | |
<h2>Helloo {{name}}</h2> | |
<ul class="menu"> | |
<li><a href="view1">view1</a></li> | |
<li><a href="view2">view2</a></li> | |
</ul> | |
<div ng-view></div> | |
<div> | |
Angular Socket.io seed app: v<span app-version></span></div> | |
</div> | |
<script src="https://ajax.googleapis.com/ajax/libs/angularjs/1.0.6/angular.min.js"></script> | |
<script src="socket.js"> </script> | |
<script src="app.js"> </script> | |
</body> | |
</html> | |
@@partial1.html.ep | |
<p>This is the partial for view 1.</p><p>The current time is {{time}}</p> | |
@@partial2.html.ep | |
<p>This is the partial for view 2.</p><p>Showing of 'interpolate' filter: | |
{{ 'Current version is v%VERSION%.' | interpolate }}</p> | |
@@app.js | |
'use strict'; | |
// Declare app level module which depends on filters, and services | |
var app = angular.module('myApp', ['myApp.filters', 'myApp.services', 'myApp.directives']). | |
config(['$routeProvider', '$locationProvider', function($routeProvider, $locationProvider) { | |
$routeProvider.when('/view1', {templateUrl: 'partials/partial1', controller: MyCtrl1}); | |
$routeProvider.when('/view2', {templateUrl: 'partials/partial2', controller: MyCtrl2}); | |
$routeProvider.otherwise({redirectTo: '/view1'}); | |
$locationProvider.html5Mode(true); | |
}]); | |
/* Controllers */ | |
function AppCtrl($scope, socket) { | |
socket.on('send:name', function (data) { | |
$scope.name = data.name; | |
}); | |
} | |
function MyCtrl1($scope, socket) { | |
socket.on('send:time', function (data) { | |
$scope.time = data.time; | |
}); | |
} | |
MyCtrl1.$inject = ['$scope', 'socket']; | |
function MyCtrl2() { | |
} | |
MyCtrl2.$inject = []; | |
/* Directives */ | |
angular.module('myApp.directives', []). | |
directive('appVersion', ['version', function(version) { | |
return function(scope, elm, attrs) { | |
elm.text(version); | |
}; | |
}]); | |
/* Filters */ | |
angular.module('myApp.filters', []). | |
filter('interpolate', ['version', function(version) { | |
return function(text) { | |
return String(text).replace(/\%VERSION\%/mg, version); | |
} | |
}]); | |
/* Services */ | |
// Demonstrate how to register services | |
// In this case it is a simple value service. | |
angular.module('myApp.services', []). | |
value('version', '0.1'). | |
factory('socket', function ($rootScope) { | |
var socket = io.connect(); | |
return { | |
on: function (eventName, callback) { | |
socket.on(eventName, function () { | |
var args = arguments; | |
$rootScope.$apply(function () { | |
callback.apply(socket, args); | |
}); | |
}); | |
}, | |
emit: function (eventName, data, callback) { | |
socket.emit(eventName, data, function () { | |
var args = arguments; | |
$rootScope.$apply(function () { | |
if (callback) { | |
callback.apply(socket, args); | |
} | |
}); | |
}) | |
} | |
}; | |
}); | |
@@app.css | |
/* app css stylesheet */ | |
.menu { | |
list-style: none; | |
border-bottom: 0.1em solid black; | |
margin-bottom: 2em; | |
padding: 0 0 0.5em; | |
} | |
.menu:before { | |
content: "["; | |
} | |
.menu:after { | |
content: "]"; | |
} | |
.menu > li { | |
display: inline; | |
} | |
.menu > li:before { | |
content: "|"; | |
padding-right: 0.3em; | |
} | |
.menu > li:nth-child(1):before { | |
content: ""; | |
padding: 0; | |
} | |
@@socket.js | |
/*! Socket.IO.js build:0.9.11, development. Copyright(c) 2011 LearnBoost <dev@learnboost.com> MIT Licensed */ | |
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.11'; | |
/** | |
* 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; | |
}; | |
/** | |
* 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 | |
, 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'); | |
} | |
} | |
} | |
}, 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; | |
} | |
this.websocket = new Socket(this.prepareUrl() + 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, global) { | |
/** | |
* Expose constructor. | |
* | |
* @api public | |
*/ | |
exports.XHR = XHR; | |
/** | |
* XHR constructor | |
* | |
* @costructor | |
* @api public | |
*/ | |
function XHR (socket) { | |
if (!socket) return; | |
io.Transport.apply(this, arguments); | |
this.sendBuffer = []; | |
}; | |
/** | |
* Inherits from Transport. | |
*/ | |
io.util.inherit(XHR, io.Transport); | |
/** | |
* Establish a connection | |
* | |
* @returns {Transport} | |
* @api public | |
*/ | |
XHR.prototype.open = function () { | |
this.socket.setBuffer(false); | |
this.onOpen(); | |
this.get(); | |
// we need to make sure the request succeeds since we have no indication | |
// whether the request opened or not until it succeeded. | |
this.setCloseTimeout(); | |
return this; | |
}; | |
/** | |
* Check if we need to send data to the Socket.IO server, if we have data in our | |
* buffer we encode it and forward it to the `post` method. | |
* | |
* @api private | |
*/ | |
XHR.prototype.payload = function (payload) { | |
var msgs = []; | |
for (var i = 0, l = payload.length; i < l; i++) { | |
msgs.push(io.parser.encodePacket(payload[i])); | |
} | |
this.send(io.parser.encodePayload(msgs)); | |
}; | |
/** | |
* Send data to the Socket.IO server. | |
* | |
* @param data The message | |
* @returns {Transport} | |
* @api public | |
*/ | |
XHR.prototype.send = function (data) { | |
this.post(data); | |
return this; | |
}; | |
/** | |
* Posts a encoded message to the Socket.IO server. | |
* | |
* @param {String} data A encoded message. | |
* @api private | |
*/ | |
function empty () { }; | |
XHR.prototype.post = function (data) { | |
var self = this; | |
this.socket.setBuffer(true); | |
function stateChange () { | |
if (this.readyState == 4) { | |
this.onreadystatechange = empty; | |
self.posting = false; | |
if (this.status == 200){ | |
self.socket.setBuffer(false); | |
} else { | |
self.onClose(); | |
} | |
} | |
} | |
function onload () { | |
this.onload = empty; | |
self.socket.setBuffer(false); | |
}; | |
this.sendXHR = this.request('POST'); | |
if (global.XDomainRequest && this.sendXHR instanceof XDomainRequest) { | |
this.sendXHR.onload = this.sendXHR.onerror = onload; | |
} else { | |
this.sendXHR.onreadystatechange = stateChange; | |
} | |
this.sendXHR.send(data); | |
}; | |
/** | |
* Disconnects the established `XHR` connection. | |
* | |
* @returns {Transport} | |
* @api public | |
*/ | |
XHR.prototype.close = function () { | |
this.onClose(); | |
return this; | |
}; | |
/** | |
* Generates a configured XHR request | |
* | |
* @param {String} url The url that needs to be requested. | |
* @param {String} method The method the request should use. | |
* @returns {XMLHttpRequest} | |
* @api private | |
*/ | |
XHR.prototype.request = function (method) { | |
var req = io.util.request(this.socket.isXDomain()) | |
, query = io.util.query(this.socket.options.query, 't=' + +new Date); | |
req.open(method || 'GET', this.prepareUrl() + query, true); | |
if (method == 'POST') { | |
try { | |
if (req.setRequestHeader) { | |
req.setRequestHeader('Content-type', 'text/plain;charset=UTF-8'); | |
} else { | |
// XDomainRequest | |
req.contentType = 'text/plain'; | |
} | |
} catch (e) {} | |
} | |
return req; | |
}; | |
/** | |
* Returns the scheme to use for the transport URLs. | |
* | |
* @api private | |
*/ | |
XHR.prototype.scheme = function () { | |
return this.socket.options.secure ? 'https' : 'http'; | |
}; | |
/** | |
* Check if the XHR transports are supported | |
* | |
* @param {Boolean} xdomain Check if we support cross domain requests. | |
* @returns {Boolean} | |
* @api public | |
*/ | |
XHR.check = function (socket, xdomain) { | |
try { | |
var request = io.util.request(xdomain), | |
usesXDomReq = (global.XDomainRequest && request instanceof XDomainRequest), | |
socketProtocol = (socket && socket.options && socket.options.secure ? 'https:' : 'http:'), | |
isXProtocol = (global.location && socketProtocol != global.location.protocol); | |
if (request && !(usesXDomReq && isXProtocol)) { | |
return true; | |
} | |
} catch(e) {} | |
return false; | |
}; | |
/** | |
* Check if the XHR transport supports cross domain requests. | |
* | |
* @returns {Boolean} | |
* @api public | |
*/ | |
XHR.xdomainCheck = function (socket) { | |
return XHR.check(socket, true); | |
}; | |
})( | |
'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.htmlfile = HTMLFile; | |
/** | |
* The HTMLFile transport creates a `forever iframe` based transport | |
* for Internet Explorer. Regular forever iframe implementations will | |
* continuously trigger the browsers buzy indicators. If the forever iframe | |
* is created inside a `htmlfile` these indicators will not be trigged. | |
* | |
* @constructor | |
* @extends {io.Transport.XHR} | |
* @api public | |
*/ | |
function HTMLFile (socket) { | |
io.Transport.XHR.apply(this, arguments); | |
}; | |
/** | |
* Inherits from XHR transport. | |
*/ | |
io.util.inherit(HTMLFile, io.Transport.XHR); | |
/** | |
* Transport name | |
* | |
* @api public | |
*/ | |
HTMLFile.prototype.name = 'htmlfile'; | |
/** | |
* Creates a new Ac...eX `htmlfile` with a forever loading iframe | |
* that can be used to listen to messages. Inside the generated | |
* `htmlfile` a reference will be made to the HTMLFile transport. | |
* | |
* @api private | |
*/ | |
HTMLFile.prototype.get = function () { | |
this.doc = new window[(['Active'].concat('Object').join('X'))]('htmlfile'); | |
this.doc.open(); | |
this.doc.write('<html></html>'); | |
this.doc.close(); | |
this.doc.parentWindow.s = this; | |
var iframeC = this.doc.createElement('div'); | |
iframeC.className = 'socketio'; | |
this.doc.body.appendChild(iframeC); | |
this.iframe = this.doc.createElement('iframe'); | |
iframeC.appendChild(this.iframe); | |
var self = this | |
, query = io.util.query(this.socket.options.query, 't='+ +new Date); | |
this.iframe.src = this.prepareUrl() + query; | |
io.util.on(window, 'unload', function () { | |
self.destroy(); | |
}); | |
}; | |
/** | |
* The Socket.IO server will write script tags inside the forever | |
* iframe, this function will be used as callback for the incoming | |
* information. | |
* | |
* @param {String} data The message | |
* @param {document} doc Reference to the context | |
* @api private | |
*/ | |
HTMLFile.prototype._ = function (data, doc) { | |
this.onData(data); | |
try { | |
var script = doc.getElementsByTagName('script')[0]; | |
script.parentNode.removeChild(script); | |
} catch (e) { } | |
}; | |
/** | |
* Destroy the established connection, iframe and `htmlfile`. | |
* And calls the `CollectGarbage` function of Internet Explorer | |
* to release the memory. | |
* | |
* @api private | |
*/ | |
HTMLFile.prototype.destroy = function () { | |
if (this.iframe){ | |
try { | |
this.iframe.src = 'about:blank'; | |
} catch(e){} | |
this.doc = null; | |
this.iframe.parentNode.removeChild(this.iframe); | |
this.iframe = null; | |
CollectGarbage(); | |
} | |
}; | |
/** | |
* Disconnects the established connection. | |
* | |
* @returns {Transport} Chaining. | |
* @api public | |
*/ | |
HTMLFile.prototype.close = function () { | |
this.destroy(); | |
return io.Transport.XHR.prototype.close.call(this); | |
}; | |
/** | |
* Checks if the browser supports this transport. The browser | |
* must have an `Ac...eXObject` implementation. | |
* | |
* @return {Boolean} | |
* @api public | |
*/ | |
HTMLFile.check = function (socket) { | |
if (typeof window != "undefined" && (['Active'].concat('Object').join('X')) in window){ | |
try { | |
var a = new window[(['Active'].concat('Object').join('X'))]('htmlfile'); | |
return a && io.Transport.XHR.check(socket); | |
} catch(e){} | |
} | |
return false; | |
}; | |
/** | |
* Check if cross domain requests are supported. | |
* | |
* @returns {Boolean} | |
* @api public | |
*/ | |
HTMLFile.xdomainCheck = function () { | |
// we can probably do handling for sub-domains, we should | |
// test that it's cross domain but a subdomain here | |
return false; | |
}; | |
/** | |
* Add the transport to your public io.transports array. | |
* | |
* @api private | |
*/ | |
io.transports.push('htmlfile'); | |
})( | |
'undefined' != typeof io ? io.Transport : 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['xhr-polling'] = XHRPolling; | |
/** | |
* The XHR-polling transport uses long polling XHR requests to create a | |
* "persistent" connection with the server. | |
* | |
* @constructor | |
* @api public | |
*/ | |
function XHRPolling () { | |
io.Transport.XHR.apply(this, arguments); | |
}; | |
/** | |
* Inherits from XHR transport. | |
*/ | |
io.util.inherit(XHRPolling, io.Transport.XHR); | |
/** | |
* Merge the properties from XHR transport | |
*/ | |
io.util.merge(XHRPolling, io.Transport.XHR); | |
/** | |
* Transport name | |
* | |
* @api public | |
*/ | |
XHRPolling.prototype.name = 'xhr-polling'; | |
/** | |
* Indicates whether heartbeats is enabled for this transport | |
* | |
* @api private | |
*/ | |
XHRPolling.prototype.heartbeats = function () { | |
return false; | |
}; | |
/** | |
* Establish a connection, for iPhone and Android this will be done once the page | |
* is loaded. | |
* | |
* @returns {Transport} Chaining. | |
* @api public | |
*/ | |
XHRPolling.prototype.open = function () { | |
var self = this; | |
io.Transport.XHR.prototype.open.call(self); | |
return false; | |
}; | |
/** | |
* Starts a XHR request to wait for incoming messages. | |
* | |
* @api private | |
*/ | |
function empty () {}; | |
XHRPolling.prototype.get = function () { | |
if (!this.isOpen) return; | |
var self = this; | |
function stateChange () { | |
if (this.readyState == 4) { | |
this.onreadystatechange = empty; | |
if (this.status == 200) { | |
self.onData(this.responseText); | |
self.get(); | |
} else { | |
self.onClose(); | |
} | |
} | |
}; | |
function onload () { | |
this.onload = empty; | |
this.onerror = empty; | |
self.retryCounter = 1; | |
self.onData(this.responseText); | |
self.get(); | |
}; | |
function onerror () { | |
self.retryCounter ++; | |
if(!self.retryCounter || self.retryCounter > 3) { | |
self.onClose(); | |
} else { | |
self.get(); | |
} | |
}; | |
this.xhr = this.request(); | |
if (global.XDomainRequest && this.xhr instanceof XDomainRequest) { | |
this.xhr.onload = onload; | |
this.xhr.onerror = onerror; | |
} else { | |
this.xhr.onreadystatechange = stateChange; | |
} | |
this.xhr.send(null); | |
}; | |
/** | |
* Handle the unclean close behavior. | |
* | |
* @api private | |
*/ | |
XHRPolling.prototype.onClose = function () { | |
io.Transport.XHR.prototype.onClose.call(this); | |
if (this.xhr) { | |
this.xhr.onreadystatechange = this.xhr.onload = this.xhr.onerror = empty; | |
try { | |
this.xhr.abort(); | |
} catch(e){} | |
this.xhr = null; | |
} | |
}; | |
/** | |
* Webkit based browsers show a infinit spinner when you start a XHR request | |
* before the browsers onload event is called so we need to defer opening of | |
* the transport until the onload event is called. Wrapping the cb in our | |
* defer method solve this. | |
* | |
* @param {Socket} socket The socket instance that needs a transport | |
* @param {Function} fn The callback | |
* @api private | |
*/ | |
XHRPolling.prototype.ready = function (socket, fn) { | |
var self = this; | |
io.util.defer(function () { | |
fn.call(self); | |
}); | |
}; | |
/** | |
* Add the transport to your public io.transports array. | |
* | |
* @api private | |
*/ | |
io.transports.push('xhr-polling'); | |
})( | |
'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, global) { | |
/** | |
* There is a way to hide the loading indicator in Firefox. If you create and | |
* remove a iframe it will stop showing the current loading indicator. | |
* Unfortunately we can't feature detect that and UA sniffing is evil. | |
* | |
* @api private | |
*/ | |
var indicator = global.document && "MozAppearance" in | |
global.document.documentElement.style; | |
/** | |
* Expose constructor. | |
*/ | |
exports['jsonp-polling'] = JSONPPolling; | |
/** | |
* The JSONP transport creates an persistent connection by dynamically | |
* inserting a script tag in the page. This script tag will receive the | |
* information of the Socket.IO server. When new information is received | |
* it creates a new script tag for the new data stream. | |
* | |
* @constructor | |
* @extends {io.Transport.xhr-polling} | |
* @api public | |
*/ | |
function JSONPPolling (socket) { | |
io.Transport['xhr-polling'].apply(this, arguments); | |
this.index = io.j.length; | |
var self = this; | |
io.j.push(function (msg) { | |
self._(msg); | |
}); | |
}; | |
/** | |
* Inherits from XHR polling transport. | |
*/ | |
io.util.inherit(JSONPPolling, io.Transport['xhr-polling']); | |
/** | |
* Transport name | |
* | |
* @api public | |
*/ | |
JSONPPolling.prototype.name = 'jsonp-polling'; | |
/** | |
* Posts a encoded message to the Socket.IO server using an iframe. | |
* The iframe is used because script tags can create POST based requests. | |
* The iframe is positioned outside of the view so the user does not | |
* notice it's existence. | |
* | |
* @param {String} data A encoded message. | |
* @api private | |
*/ | |
JSONPPolling.prototype.post = function (data) { | |
var self = this | |
, query = io.util.query( | |
this.socket.options.query | |
, 't='+ (+new Date) + '&i=' + this.index | |
); | |
if (!this.form) { | |
var form = document.createElement('form') | |
, area = document.createElement('textarea') | |
, id = this.iframeId = 'socketio_iframe_' + this.index | |
, iframe; | |
form.className = 'socketio'; | |
form.style.position = 'absolute'; | |
form.style.top = '0px'; | |
form.style.left = '0px'; | |
form.style.display = 'none'; | |
form.target = id; | |
form.method = 'POST'; | |
form.setAttribute('accept-charset', 'utf-8'); | |
area.name = 'd'; | |
form.appendChild(area); | |
document.body.appendChild(form); | |
this.form = form; | |
this.area = area; | |
} | |
this.form.action = this.prepareUrl() + query; | |
function complete () { | |
initIframe(); | |
self.socket.setBuffer(false); | |
}; | |
function initIframe () { | |
if (self.iframe) { | |
self.form.removeChild(self.iframe); | |
} | |
try { | |
// ie6 dynamic iframes with target="" support (thanks Chris Lambacher) | |
iframe = document.createElement('<iframe name="'+ self.iframeId +'">'); | |
} catch (e) { | |
iframe = document.createElement('iframe'); | |
iframe.name = self.iframeId; | |
} | |
iframe.id = self.iframeId; | |
self.form.appendChild(iframe); | |
self.iframe = iframe; | |
}; | |
initIframe(); | |
// we temporarily stringify until we figure out how to prevent | |
// browsers from turning `\n` into `\r\n` in form inputs | |
this.area.value = io.JSON.stringify(data); | |
try { | |
this.form.submit(); | |
} catch(e) {} | |
if (this.iframe.attachEvent) { | |
iframe.onreadystatechange = function () { | |
if (self.iframe.readyState == 'complete') { | |
complete(); | |
} | |
}; | |
} else { | |
this.iframe.onload = complete; | |
} | |
this.socket.setBuffer(true); | |
}; | |
/** | |
* Creates a new JSONP poll that can be used to listen | |
* for messages from the Socket.IO server. | |
* | |
* @api private | |
*/ | |
JSONPPolling.prototype.get = function () { | |
var self = this | |
, script = document.createElement('script') | |
, query = io.util.query( | |
this.socket.options.query | |
, 't='+ (+new Date) + '&i=' + this.index | |
); | |
if (this.script) { | |
this.script.parentNode.removeChild(this.script); | |
this.script = null; | |
} | |
script.async = true; | |
script.src = this.prepareUrl() + query; | |
script.onerror = function () { | |
self.onClose(); | |
}; | |
var insertAt = document.getElementsByTagName('script')[0]; | |
insertAt.parentNode.insertBefore(script, insertAt); | |
this.script = script; | |
if (indicator) { | |
setTimeout(function () { | |
var iframe = document.createElement('iframe'); | |
document.body.appendChild(iframe); | |
document.body.removeChild(iframe); | |
}, 100); | |
} | |
}; | |
/** | |
* Callback function for the incoming message stream from the Socket.IO server. | |
* | |
* @param {String} data The message | |
* @api private | |
*/ | |
JSONPPolling.prototype._ = function (msg) { | |
this.onData(msg); | |
if (this.isOpen) { | |
this.get(); | |
} | |
return this; | |
}; | |
/** | |
* The indicator hack only works after onload | |
* | |
* @param {Socket} socket The socket instance that needs a transport | |
* @param {Function} fn The callback | |
* @api private | |
*/ | |
JSONPPolling.prototype.ready = function (socket, fn) { | |
var self = this; | |
if (!indicator) return fn.call(this); | |
io.util.load(function () { | |
fn.call(self); | |
}); | |
}; | |
/** | |
* Checks if browser supports this transport. | |
* | |
* @return {Boolean} | |
* @api public | |
*/ | |
JSONPPolling.check = function () { | |
return 'document' in global; | |
}; | |
/** | |
* Check if cross domain requests are supported | |
* | |
* @returns {Boolean} | |
* @api public | |
*/ | |
JSONPPolling.xdomainCheck = function () { | |
return true; | |
}; | |
/** | |
* Add the transport to your public io.transports array. | |
* | |
* @api private | |
*/ | |
io.transports.push('jsonp-polling'); | |
})( | |
'undefined' != typeof io ? io.Transport : module.exports | |
, 'undefined' != typeof io ? io : module.parent.exports | |
, this | |
); | |
if (typeof define === "function" && define.amd) { | |
define([], function () { return io; }); | |
} | |
})(); | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment