/transport`. This is
+ useful for load balancers that support prefix-based affinity
+ (HAProxy does).
+ * `JSESSIONID` cookie is being set by SockJS-node. Many load
+ balancers turn on sticky sessions if that cookie is set. This
+ technique is derived from Java applications, where sticky sessions
+ are often necessary. HAProxy does support this method, as well as
+ some hosting providers, for example CloudFoundry. In order to
+ enable this method on the client side, please supply a
+ `cookie:true` option to SockJS constructor.
+
+
+Development and testing
+-----------------------
+
+If you want to work on SockJS-node source code, you need to clone the
+git repo and follow these steps. First you need to install
+dependencies:
+
+ cd sockjs-node
+ npm install
+ npm install --dev
+ ln -s .. node_modules/sockjs
+
+You're ready to compile CoffeeScript:
+
+ make build
+
+If compilation succeeds you may want to test if your changes pass all
+the tests. Currently, there are two separate test suites. For both of
+them you need to start a SockJS-node test server (by default listening
+on port 8081):
+
+ make test_server
+
+### SockJS-protocol Python tests
+
+To run it run something like:
+
+ cd sockjs-protocol
+ make test_deps
+ ./venv/bin/python sockjs-protocol.py
+
+For details see
+[SockJS-protocol README](https://github.com/sockjs/sockjs-protocol#readme).
+
+### SockJS-client QUnit tests
+
+You need to start a second web server (by default listening on 8080)
+that is serving various static html and javascript files:
+
+ cd sockjs-client
+ make test
+
+At that point you should have two web servers running: sockjs-node on
+8081 and sockjs-client on 8080. When you open the browser on
+[http://localhost:8080/](http://localhost:8080/) you should be able
+run the QUnit tests against your sockjs-node server.
+
+For details see
+[SockJS-client README](https://github.com/sockjs/sockjs-client#readme).
+
+Additionally, if you're doing more serious development consider using
+`make serve`, which will automatically the server when you modify the
+source code.
+
+
+Various issues and design considerations
+----------------------------------------
+
+### Authorisation
+
+SockJS-node does not expose cookies to the application. This is done
+deliberately as using cookie-based authorisation with SockJS simply
+doesn't make sense and will lead to security issues.
+
+Cookies are a contract between a browser and an http server, and are
+identified by a domain name. If a browser has a cookie set for
+particular domain, it will pass it as a part of all http requests to
+the host. But to get various transports working, SockJS uses a middleman
+- an iframe hosted from target SockJS domain. That means the server
+will receive requests from the iframe, and not from the real
+domain. The domain of an iframe is the same as the SockJS domain. The
+problem is that any website can embed the iframe and communicate with
+it - and request establishing SockJS connection. Using cookies for
+authorisation in this scenario will result in granting full access to
+SockJS communication with your website from any website. This is a
+classic CSRF attack.
+
+Basically - cookies are not suited for SockJS model. If you want to
+authorise a session - provide a unique token on a page, send it as a
+first thing over SockJS connection and validate it on the server
+side. In essence, this is how cookies work.
+
+
+### Deploying SockJS on Heroku
+
+Long polling is known to cause problems on Heroku, but
+[workaround for SockJS is available](https://github.com/sockjs/sockjs-node/issues/57#issuecomment-5242187).
Index: frontend/node_modules/sockjs/index.js
===================================================================
--- frontend/node_modules/sockjs/index.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/index.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,1 @@
+module.exports = require('./lib/sockjs');
Index: frontend/node_modules/sockjs/lib/chunking-test.js
===================================================================
--- frontend/node_modules/sockjs/lib/chunking-test.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/chunking-test.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,95 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var utils;
+
+ utils = require('./utils');
+
+ exports.app = {
+ chunking_test: function(req, res, _, next_filter) {
+ var write;
+ res.setHeader('Content-Type', 'application/javascript; charset=UTF-8');
+ res.writeHead(200);
+ write = (function(_this) {
+ return function(payload) {
+ var x;
+ try {
+ return res.write(payload + '\n');
+ } catch (error) {
+ x = error;
+ }
+ };
+ })(this);
+ utils.timeout_chain([
+ [
+ 0, (function(_this) {
+ return function() {
+ return write('h');
+ };
+ })(this)
+ ], [
+ 1, (function(_this) {
+ return function() {
+ return write(Array(2049).join(' ') + 'h');
+ };
+ })(this)
+ ], [
+ 5, (function(_this) {
+ return function() {
+ return write('h');
+ };
+ })(this)
+ ], [
+ 25, (function(_this) {
+ return function() {
+ return write('h');
+ };
+ })(this)
+ ], [
+ 125, (function(_this) {
+ return function() {
+ return write('h');
+ };
+ })(this)
+ ], [
+ 625, (function(_this) {
+ return function() {
+ return write('h');
+ };
+ })(this)
+ ], [
+ 3125, (function(_this) {
+ return function() {
+ write('h');
+ return res.end();
+ };
+ })(this)
+ ]
+ ]);
+ return true;
+ },
+ info: function(req, res, _) {
+ var info;
+ info = {
+ websocket: this.options.websocket,
+ origins: !this.options.disable_cors ? ['*:*'] : void 0,
+ cookie_needed: !!this.options.jsessionid,
+ entropy: utils.random32()
+ };
+ if (typeof this.options.base_url === 'function') {
+ info.base_url = this.options.base_url();
+ } else if (this.options.base_url) {
+ info.base_url = this.options.base_url;
+ }
+ res.setHeader('Content-Type', 'application/json; charset=UTF-8');
+ res.writeHead(200);
+ return res.end(JSON.stringify(info));
+ },
+ info_options: function(req, res) {
+ res.statusCode = 204;
+ res.setHeader('Access-Control-Allow-Methods', 'OPTIONS, GET');
+ res.setHeader('Access-Control-Max-Age', res.cache_for);
+ return '';
+ }
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/iframe.js
===================================================================
--- frontend/node_modules/sockjs/lib/iframe.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/iframe.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,30 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var iframe_template, utils;
+
+ utils = require('./utils');
+
+ iframe_template = "\n\n\n \n \n \n \n\n\n Don't panic!
\n This is a SockJS hidden iframe. It's used for cross domain magic.
\n\n";
+
+ exports.app = {
+ iframe: function(req, res) {
+ var content, context, k, quoted_md5;
+ context = {
+ '{{ sockjs_url }}': this.options.sockjs_url
+ };
+ content = iframe_template;
+ for (k in context) {
+ content = content.replace(k, context[k]);
+ }
+ quoted_md5 = '"' + utils.md5_hex(content) + '"';
+ if ('if-none-match' in req.headers && req.headers['if-none-match'] === quoted_md5) {
+ res.statusCode = 304;
+ return '';
+ }
+ res.setHeader('Content-Type', 'text/html; charset=UTF-8');
+ res.setHeader('ETag', quoted_md5);
+ return content;
+ }
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/sockjs.js
===================================================================
--- frontend/node_modules/sockjs/lib/sockjs.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/sockjs.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,233 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var App, Listener, Server, chunking_test, events, fs, generate_dispatcher, iframe, sockjsVersion, trans_eventsource, trans_htmlfile, trans_jsonp, trans_websocket, trans_xhr, utils, webjs,
+ extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
+ hasProp = {}.hasOwnProperty,
+ bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; };
+
+ events = require('events');
+
+ fs = require('fs');
+
+ webjs = require('./webjs');
+
+ utils = require('./utils');
+
+ trans_websocket = require('./trans-websocket');
+
+ trans_jsonp = require('./trans-jsonp');
+
+ trans_xhr = require('./trans-xhr');
+
+ iframe = require('./iframe');
+
+ trans_eventsource = require('./trans-eventsource');
+
+ trans_htmlfile = require('./trans-htmlfile');
+
+ chunking_test = require('./chunking-test');
+
+ sockjsVersion = function() {
+ var pkg, x;
+ try {
+ pkg = fs.readFileSync(__dirname + '/../package.json', 'utf-8');
+ } catch (error) {
+ x = error;
+ }
+ if (pkg) {
+ return JSON.parse(pkg).version;
+ } else {
+ return null;
+ }
+ };
+
+ App = (function(superClass) {
+ extend(App, superClass);
+
+ function App() {
+ return App.__super__.constructor.apply(this, arguments);
+ }
+
+ App.prototype.welcome_screen = function(req, res) {
+ res.setHeader('content-type', 'text/plain; charset=UTF-8');
+ res.writeHead(200);
+ res.end("Welcome to SockJS!\n");
+ return true;
+ };
+
+ App.prototype.handle_404 = function(req, res) {
+ res.setHeader('content-type', 'text/plain; charset=UTF-8');
+ res.writeHead(404);
+ res.end('404 Error: Page not found\n');
+ return true;
+ };
+
+ App.prototype.disabled_transport = function(req, res, data) {
+ return this.handle_404(req, res, data);
+ };
+
+ App.prototype.h_sid = function(req, res, data) {
+ var jsid;
+ req.cookies = utils.parseCookie(req.headers.cookie);
+ if (typeof this.options.jsessionid === 'function') {
+ this.options.jsessionid(req, res);
+ } else if (this.options.jsessionid && res.setHeader) {
+ jsid = req.cookies['JSESSIONID'] || 'dummy';
+ res.setHeader('Set-Cookie', 'JSESSIONID=' + jsid + '; path=/');
+ }
+ return data;
+ };
+
+ App.prototype.log = function(severity, line) {
+ return this.options.log(severity, line);
+ };
+
+ return App;
+
+ })(webjs.GenericApp);
+
+ utils.objectExtend(App.prototype, iframe.app);
+
+ utils.objectExtend(App.prototype, chunking_test.app);
+
+ utils.objectExtend(App.prototype, trans_websocket.app);
+
+ utils.objectExtend(App.prototype, trans_jsonp.app);
+
+ utils.objectExtend(App.prototype, trans_xhr.app);
+
+ utils.objectExtend(App.prototype, trans_eventsource.app);
+
+ utils.objectExtend(App.prototype, trans_htmlfile.app);
+
+ generate_dispatcher = function(options) {
+ var opts_filters, p, prefix_dispatcher, t, transport_dispatcher;
+ p = (function(_this) {
+ return function(s) {
+ return new RegExp('^' + options.prefix + s + '[/]?$');
+ };
+ })(this);
+ t = (function(_this) {
+ return function(s) {
+ return [p('/([^/.]+)/([^/.]+)' + s), 'server', 'session'];
+ };
+ })(this);
+ opts_filters = function(options_filter) {
+ if (options_filter == null) {
+ options_filter = 'xhr_options';
+ }
+ return ['h_sid', 'xhr_cors', 'cache_for', options_filter, 'expose'];
+ };
+ prefix_dispatcher = [['GET', p(''), ['welcome_screen']], ['GET', p('/iframe[0-9-.a-z_]*.html'), ['iframe', 'cache_for', 'expose']], ['OPTIONS', p('/info'), opts_filters('info_options')], ['GET', p('/info'), ['xhr_cors', 'h_no_cache', 'info', 'expose']], ['OPTIONS', p('/chunking_test'), opts_filters()], ['POST', p('/chunking_test'), ['xhr_cors', 'expect_xhr', 'chunking_test']]];
+ transport_dispatcher = [['GET', t('/jsonp'), ['h_sid', 'h_no_cache', 'jsonp']], ['POST', t('/jsonp_send'), ['h_sid', 'h_no_cache', 'expect_form', 'jsonp_send']], ['POST', t('/xhr'), ['h_sid', 'h_no_cache', 'xhr_cors', 'xhr_poll']], ['OPTIONS', t('/xhr'), opts_filters()], ['POST', t('/xhr_send'), ['h_sid', 'h_no_cache', 'xhr_cors', 'expect_xhr', 'xhr_send']], ['OPTIONS', t('/xhr_send'), opts_filters()], ['POST', t('/xhr_streaming'), ['h_sid', 'h_no_cache', 'xhr_cors', 'xhr_streaming']], ['OPTIONS', t('/xhr_streaming'), opts_filters()], ['GET', t('/eventsource'), ['h_sid', 'h_no_cache', 'eventsource']], ['GET', t('/htmlfile'), ['h_sid', 'h_no_cache', 'htmlfile']]];
+ if (options.websocket) {
+ prefix_dispatcher.push(['GET', p('/websocket'), ['raw_websocket']]);
+ transport_dispatcher.push(['GET', t('/websocket'), ['sockjs_websocket']]);
+ } else {
+ prefix_dispatcher.push(['GET', p('/websocket'), ['cache_for', 'disabled_transport']]);
+ transport_dispatcher.push(['GET', t('/websocket'), ['cache_for', 'disabled_transport']]);
+ }
+ return prefix_dispatcher.concat(transport_dispatcher);
+ };
+
+ Listener = (function() {
+ function Listener(options1, emit) {
+ this.options = options1;
+ this.handler = bind(this.handler, this);
+ this.app = new App();
+ this.app.options = this.options;
+ this.app.emit = emit;
+ this.app.log('debug', 'SockJS v' + sockjsVersion() + ' ' + 'bound to ' + JSON.stringify(this.options.prefix));
+ this.dispatcher = generate_dispatcher(this.options);
+ this.webjs_handler = webjs.generateHandler(this.app, this.dispatcher);
+ this.path_regexp = new RegExp('^' + this.options.prefix + '([/].+|[/]?)$');
+ }
+
+ Listener.prototype.handler = function(req, res, extra) {
+ if (!req.url.match(this.path_regexp)) {
+ return false;
+ }
+ this.webjs_handler(req, res, extra);
+ return true;
+ };
+
+ Listener.prototype.getHandler = function() {
+ return (function(_this) {
+ return function(a, b, c) {
+ return _this.handler(a, b, c);
+ };
+ })(this);
+ };
+
+ return Listener;
+
+ })();
+
+ Server = (function(superClass) {
+ extend(Server, superClass);
+
+ function Server(user_options) {
+ this.options = {
+ prefix: '',
+ response_limit: 128 * 1024,
+ websocket: true,
+ faye_server_options: null,
+ jsessionid: false,
+ heartbeat_delay: 25000,
+ disconnect_delay: 5000,
+ log: function(severity, line) {
+ return console.log(line);
+ },
+ sockjs_url: 'https://cdn.jsdelivr.net/npm/sockjs-client@1/dist/sockjs.min.js'
+ };
+ if (user_options) {
+ utils.objectExtend(this.options, user_options);
+ }
+ }
+
+ Server.prototype.listener = function(handler_options) {
+ var options;
+ options = utils.objectExtend({}, this.options);
+ if (handler_options) {
+ utils.objectExtend(options, handler_options);
+ }
+ return new Listener(options, (function(_this) {
+ return function() {
+ return _this.emit.apply(_this, arguments);
+ };
+ })(this));
+ };
+
+ Server.prototype.installHandlers = function(http_server, handler_options) {
+ var handler;
+ handler = this.listener(handler_options).getHandler();
+ utils.overshadowListeners(http_server, 'request', handler);
+ utils.overshadowListeners(http_server, 'upgrade', handler);
+ return true;
+ };
+
+ Server.prototype.middleware = function(handler_options) {
+ var handler;
+ handler = this.listener(handler_options).getHandler();
+ handler.upgrade = handler;
+ return handler;
+ };
+
+ return Server;
+
+ })(events.EventEmitter);
+
+ exports.createServer = function(options) {
+ return new Server(options);
+ };
+
+ exports.listen = function(http_server, options) {
+ var srv;
+ srv = exports.createServer(options);
+ if (http_server) {
+ srv.installHandlers(http_server);
+ }
+ return srv;
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/trans-eventsource.js
===================================================================
--- frontend/node_modules/sockjs/lib/trans-eventsource.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/trans-eventsource.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,53 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var EventSourceReceiver, transport, utils,
+ extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
+ hasProp = {}.hasOwnProperty;
+
+ utils = require('./utils');
+
+ transport = require('./transport');
+
+ EventSourceReceiver = (function(superClass) {
+ extend(EventSourceReceiver, superClass);
+
+ function EventSourceReceiver() {
+ return EventSourceReceiver.__super__.constructor.apply(this, arguments);
+ }
+
+ EventSourceReceiver.prototype.protocol = "eventsource";
+
+ EventSourceReceiver.prototype.doSendFrame = function(payload) {
+ var data;
+ data = ['data: ', utils.escape_selected(payload, '\r\n\x00'), '\r\n\r\n'];
+ return EventSourceReceiver.__super__.doSendFrame.call(this, data.join(''));
+ };
+
+ return EventSourceReceiver;
+
+ })(transport.ResponseReceiver);
+
+ exports.app = {
+ eventsource: function(req, res) {
+ var headers, origin;
+ if (!req.headers['origin'] || req.headers['origin'] === 'null') {
+ origin = '*';
+ } else {
+ origin = req.headers['origin'];
+ res.setHeader('Access-Control-Allow-Credentials', 'true');
+ }
+ res.setHeader('Content-Type', 'text/event-stream');
+ res.setHeader('Access-Control-Allow-Origin', origin);
+ res.setHeader('Vary', 'Origin');
+ headers = req.headers['access-control-request-headers'];
+ if (headers) {
+ res.setHeader('Access-Control-Allow-Headers', headers);
+ }
+ res.writeHead(200);
+ res.write('\r\n');
+ transport.register(req, this, new EventSourceReceiver(req, res, this.options));
+ return true;
+ }
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/trans-htmlfile.js
===================================================================
--- frontend/node_modules/sockjs/lib/trans-htmlfile.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/trans-htmlfile.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,58 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var HtmlFileReceiver, iframe_template, transport, utils,
+ extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
+ hasProp = {}.hasOwnProperty;
+
+ utils = require('./utils');
+
+ transport = require('./transport');
+
+ iframe_template = "\n\n \n \nDon't panic!
\n ";
+
+ iframe_template += Array(1024 - iframe_template.length + 14).join(' ');
+
+ iframe_template += '\r\n\r\n';
+
+ HtmlFileReceiver = (function(superClass) {
+ extend(HtmlFileReceiver, superClass);
+
+ function HtmlFileReceiver() {
+ return HtmlFileReceiver.__super__.constructor.apply(this, arguments);
+ }
+
+ HtmlFileReceiver.prototype.protocol = "htmlfile";
+
+ HtmlFileReceiver.prototype.doSendFrame = function(payload) {
+ return HtmlFileReceiver.__super__.doSendFrame.call(this, '\r\n');
+ };
+
+ return HtmlFileReceiver;
+
+ })(transport.ResponseReceiver);
+
+ exports.app = {
+ htmlfile: function(req, res) {
+ var callback;
+ if (!('c' in req.query || 'callback' in req.query)) {
+ throw {
+ status: 500,
+ message: '"callback" parameter required'
+ };
+ }
+ callback = 'c' in req.query ? req.query['c'] : req.query['callback'];
+ if (/[^a-zA-Z0-9-_.]/.test(callback)) {
+ throw {
+ status: 500,
+ message: 'invalid "callback" parameter'
+ };
+ }
+ res.setHeader('Content-Type', 'text/html; charset=UTF-8');
+ res.writeHead(200);
+ res.write(iframe_template.replace(/{{ callback }}/g, callback));
+ transport.register(req, this, new HtmlFileReceiver(req, res, this.options));
+ return true;
+ }
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/trans-jsonp.js
===================================================================
--- frontend/node_modules/sockjs/lib/trans-jsonp.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/trans-jsonp.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,107 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var JsonpReceiver, transport,
+ extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
+ hasProp = {}.hasOwnProperty;
+
+ transport = require('./transport');
+
+ JsonpReceiver = (function(superClass) {
+ extend(JsonpReceiver, superClass);
+
+ JsonpReceiver.prototype.protocol = "jsonp-polling";
+
+ JsonpReceiver.prototype.max_response_size = 1;
+
+ function JsonpReceiver(req, res, options, callback1) {
+ this.callback = callback1;
+ JsonpReceiver.__super__.constructor.call(this, req, res, options);
+ }
+
+ JsonpReceiver.prototype.doSendFrame = function(payload) {
+ return JsonpReceiver.__super__.doSendFrame.call(this, "/**/" + this.callback + "(" + JSON.stringify(payload) + ");\r\n");
+ };
+
+ return JsonpReceiver;
+
+ })(transport.ResponseReceiver);
+
+ exports.app = {
+ jsonp: function(req, res, _, next_filter) {
+ var callback;
+ if (!('c' in req.query || 'callback' in req.query)) {
+ throw {
+ status: 500,
+ message: '"callback" parameter required'
+ };
+ }
+ callback = 'c' in req.query ? req.query['c'] : req.query['callback'];
+ if (/[^a-zA-Z0-9-_.]/.test(callback) || callback.length > 32) {
+ throw {
+ status: 500,
+ message: 'invalid "callback" parameter'
+ };
+ }
+ res.setHeader('X-Content-Type-Options', 'nosniff');
+ res.setHeader('Content-Type', 'application/javascript; charset=UTF-8');
+ res.writeHead(200);
+ transport.register(req, this, new JsonpReceiver(req, res, this.options, callback));
+ return true;
+ },
+ jsonp_send: function(req, res, query) {
+ var d, i, jsonp, len, message, x;
+ if (!query) {
+ throw {
+ status: 500,
+ message: 'Payload expected.'
+ };
+ }
+ if (typeof query === 'string') {
+ try {
+ d = JSON.parse(query);
+ } catch (error) {
+ x = error;
+ throw {
+ status: 500,
+ message: 'Broken JSON encoding.'
+ };
+ }
+ } else {
+ d = query.d;
+ }
+ if (typeof d === 'string' && d) {
+ try {
+ d = JSON.parse(d);
+ } catch (error) {
+ x = error;
+ throw {
+ status: 500,
+ message: 'Broken JSON encoding.'
+ };
+ }
+ }
+ if (!d || d.__proto__.constructor !== Array) {
+ throw {
+ status: 500,
+ message: 'Payload expected.'
+ };
+ }
+ jsonp = transport.Session.bySessionId(req.session);
+ if (jsonp === null) {
+ throw {
+ status: 404
+ };
+ }
+ for (i = 0, len = d.length; i < len; i++) {
+ message = d[i];
+ jsonp.didMessage(message);
+ }
+ res.setHeader('Content-Length', '2');
+ res.setHeader('Content-Type', 'text/plain; charset=UTF-8');
+ res.writeHead(200);
+ res.end('ok');
+ return true;
+ }
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/trans-websocket.js
===================================================================
--- frontend/node_modules/sockjs/lib/trans-websocket.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/trans-websocket.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,248 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var FayeWebsocket, RawWebsocketSessionReceiver, Transport, WebSocketReceiver, transport, utils,
+ extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
+ hasProp = {}.hasOwnProperty;
+
+ FayeWebsocket = require('faye-websocket');
+
+ utils = require('./utils');
+
+ transport = require('./transport');
+
+ exports.app = {
+ _websocket_check: function(req, connection, head) {
+ if (!FayeWebsocket.isWebSocket(req)) {
+ throw {
+ status: 400,
+ message: 'Not a valid websocket request'
+ };
+ }
+ },
+ sockjs_websocket: function(req, connection, head) {
+ var ws;
+ this._websocket_check(req, connection, head);
+ ws = new FayeWebsocket(req, connection, head, null, this.options.faye_server_options);
+ ws.onopen = (function(_this) {
+ return function() {
+ return transport.registerNoSession(req, _this, new WebSocketReceiver(ws, connection));
+ };
+ })(this);
+ return true;
+ },
+ raw_websocket: function(req, connection, head) {
+ var ver, ws;
+ this._websocket_check(req, connection, head);
+ ver = req.headers['sec-websocket-version'] || '';
+ if (['8', '13'].indexOf(ver) === -1) {
+ throw {
+ status: 400,
+ message: 'Only supported WebSocket protocol is RFC 6455.'
+ };
+ }
+ ws = new FayeWebsocket(req, connection, head, null, this.options.faye_server_options);
+ ws.onopen = (function(_this) {
+ return function() {
+ return new RawWebsocketSessionReceiver(req, connection, _this, ws);
+ };
+ })(this);
+ return true;
+ }
+ };
+
+ WebSocketReceiver = (function(superClass) {
+ extend(WebSocketReceiver, superClass);
+
+ WebSocketReceiver.prototype.protocol = "websocket";
+
+ function WebSocketReceiver(ws1, connection1) {
+ var x;
+ this.ws = ws1;
+ this.connection = connection1;
+ try {
+ this.connection.setKeepAlive(true, 5000);
+ this.connection.setNoDelay(true);
+ } catch (error) {
+ x = error;
+ }
+ this.ws.addEventListener('message', (function(_this) {
+ return function(m) {
+ return _this.didMessage(m.data);
+ };
+ })(this));
+ this.heartbeat_cb = (function(_this) {
+ return function() {
+ return _this.heartbeat_timeout();
+ };
+ })(this);
+ WebSocketReceiver.__super__.constructor.call(this, this.connection);
+ }
+
+ WebSocketReceiver.prototype.setUp = function() {
+ WebSocketReceiver.__super__.setUp.apply(this, arguments);
+ return this.ws.addEventListener('close', this.thingy_end_cb);
+ };
+
+ WebSocketReceiver.prototype.tearDown = function() {
+ this.ws.removeEventListener('close', this.thingy_end_cb);
+ return WebSocketReceiver.__super__.tearDown.apply(this, arguments);
+ };
+
+ WebSocketReceiver.prototype.didMessage = function(payload) {
+ var i, len, message, msg, results, x;
+ if (this.ws && this.session && payload.length > 0) {
+ try {
+ message = JSON.parse(payload);
+ } catch (error) {
+ x = error;
+ return this.didClose(3000, 'Broken framing.');
+ }
+ if (payload[0] === '[') {
+ results = [];
+ for (i = 0, len = message.length; i < len; i++) {
+ msg = message[i];
+ results.push(this.session.didMessage(msg));
+ }
+ return results;
+ } else {
+ return this.session.didMessage(message);
+ }
+ }
+ };
+
+ WebSocketReceiver.prototype.doSendFrame = function(payload) {
+ var x;
+ if (this.ws) {
+ try {
+ this.ws.send(payload);
+ return true;
+ } catch (error) {
+ x = error;
+ }
+ }
+ return false;
+ };
+
+ WebSocketReceiver.prototype.didClose = function(status, reason) {
+ var x;
+ if (status == null) {
+ status = 1000;
+ }
+ if (reason == null) {
+ reason = "Normal closure";
+ }
+ WebSocketReceiver.__super__.didClose.apply(this, arguments);
+ try {
+ this.ws.close(status, reason, false);
+ } catch (error) {
+ x = error;
+ }
+ this.ws = null;
+ return this.connection = null;
+ };
+
+ WebSocketReceiver.prototype.heartbeat = function() {
+ var hto_ref, supportsHeartbeats;
+ supportsHeartbeats = this.ws.ping(null, function() {
+ return clearTimeout(hto_ref);
+ });
+ if (supportsHeartbeats) {
+ return hto_ref = setTimeout(this.heartbeat_cb, 10000);
+ } else {
+ return WebSocketReceiver.__super__.heartbeat.apply(this, arguments);
+ }
+ };
+
+ WebSocketReceiver.prototype.heartbeat_timeout = function() {
+ if (this.session != null) {
+ return this.session.close(3000, 'No response from heartbeat');
+ }
+ };
+
+ return WebSocketReceiver;
+
+ })(transport.GenericReceiver);
+
+ Transport = transport.Transport;
+
+ RawWebsocketSessionReceiver = (function(superClass) {
+ extend(RawWebsocketSessionReceiver, superClass);
+
+ function RawWebsocketSessionReceiver(req, conn, server, ws1) {
+ this.ws = ws1;
+ this.prefix = server.options.prefix;
+ this.readyState = Transport.OPEN;
+ this.recv = {
+ connection: conn,
+ protocol: "websocket-raw"
+ };
+ this.connection = new transport.SockJSConnection(this);
+ this.decorateConnection(req);
+ server.emit('connection', this.connection);
+ this._end_cb = (function(_this) {
+ return function() {
+ return _this.didClose();
+ };
+ })(this);
+ this.ws.addEventListener('close', this._end_cb);
+ this._message_cb = (function(_this) {
+ return function(m) {
+ return _this.didMessage(m);
+ };
+ })(this);
+ this.ws.addEventListener('message', this._message_cb);
+ }
+
+ RawWebsocketSessionReceiver.prototype.didMessage = function(m) {
+ if (this.readyState === Transport.OPEN) {
+ this.connection.emit('data', m.data);
+ }
+ };
+
+ RawWebsocketSessionReceiver.prototype.send = function(payload) {
+ if (this.readyState !== Transport.OPEN) {
+ return false;
+ }
+ this.ws.send(payload);
+ return true;
+ };
+
+ RawWebsocketSessionReceiver.prototype.close = function(status, reason) {
+ if (status == null) {
+ status = 1000;
+ }
+ if (reason == null) {
+ reason = "Normal closure";
+ }
+ if (this.readyState !== Transport.OPEN) {
+ return false;
+ }
+ this.readyState = Transport.CLOSING;
+ this.ws.close(status, reason, false);
+ return true;
+ };
+
+ RawWebsocketSessionReceiver.prototype.didClose = function() {
+ var x;
+ if (!this.ws) {
+ return;
+ }
+ this.ws.removeEventListener('message', this._message_cb);
+ this.ws.removeEventListener('close', this._end_cb);
+ try {
+ this.ws.close(1000, "Normal closure", false);
+ } catch (error) {
+ x = error;
+ }
+ this.ws = null;
+ this.readyState = Transport.CLOSED;
+ this.connection.emit('end');
+ this.connection.emit('close');
+ return this.connection = null;
+ };
+
+ return RawWebsocketSessionReceiver;
+
+ })(transport.Session);
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/trans-xhr.js
===================================================================
--- frontend/node_modules/sockjs/lib/trans-xhr.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/trans-xhr.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,122 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var XhrPollingReceiver, XhrStreamingReceiver, transport, utils,
+ extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
+ hasProp = {}.hasOwnProperty;
+
+ transport = require('./transport');
+
+ utils = require('./utils');
+
+ XhrStreamingReceiver = (function(superClass) {
+ extend(XhrStreamingReceiver, superClass);
+
+ function XhrStreamingReceiver() {
+ return XhrStreamingReceiver.__super__.constructor.apply(this, arguments);
+ }
+
+ XhrStreamingReceiver.prototype.protocol = "xhr-streaming";
+
+ XhrStreamingReceiver.prototype.doSendFrame = function(payload) {
+ return XhrStreamingReceiver.__super__.doSendFrame.call(this, payload + '\n');
+ };
+
+ return XhrStreamingReceiver;
+
+ })(transport.ResponseReceiver);
+
+ XhrPollingReceiver = (function(superClass) {
+ extend(XhrPollingReceiver, superClass);
+
+ function XhrPollingReceiver() {
+ return XhrPollingReceiver.__super__.constructor.apply(this, arguments);
+ }
+
+ XhrPollingReceiver.prototype.protocol = "xhr-polling";
+
+ XhrPollingReceiver.prototype.max_response_size = 1;
+
+ return XhrPollingReceiver;
+
+ })(XhrStreamingReceiver);
+
+ exports.app = {
+ xhr_options: function(req, res) {
+ res.statusCode = 204;
+ res.setHeader('Access-Control-Allow-Methods', 'OPTIONS, POST');
+ res.setHeader('Access-Control-Max-Age', res.cache_for);
+ return '';
+ },
+ xhr_send: function(req, res, data) {
+ var d, i, jsonp, len, message, x;
+ if (!data) {
+ throw {
+ status: 500,
+ message: 'Payload expected.'
+ };
+ }
+ try {
+ d = JSON.parse(data);
+ } catch (error) {
+ x = error;
+ throw {
+ status: 500,
+ message: 'Broken JSON encoding.'
+ };
+ }
+ if (!d || d.__proto__.constructor !== Array) {
+ throw {
+ status: 500,
+ message: 'Payload expected.'
+ };
+ }
+ jsonp = transport.Session.bySessionId(req.session);
+ if (!jsonp) {
+ throw {
+ status: 404
+ };
+ }
+ for (i = 0, len = d.length; i < len; i++) {
+ message = d[i];
+ jsonp.didMessage(message);
+ }
+ res.setHeader('Content-Type', 'text/plain; charset=UTF-8');
+ res.writeHead(204);
+ res.end();
+ return true;
+ },
+ xhr_cors: function(req, res, content) {
+ var headers, origin;
+ if (this.options.disable_cors) {
+ return content;
+ }
+ if (!req.headers['origin']) {
+ origin = '*';
+ } else {
+ origin = req.headers['origin'];
+ res.setHeader('Access-Control-Allow-Credentials', 'true');
+ }
+ res.setHeader('Access-Control-Allow-Origin', origin);
+ res.setHeader('Vary', 'Origin');
+ headers = req.headers['access-control-request-headers'];
+ if (headers) {
+ res.setHeader('Access-Control-Allow-Headers', headers);
+ }
+ return content;
+ },
+ xhr_poll: function(req, res, _, next_filter) {
+ res.setHeader('Content-Type', 'application/javascript; charset=UTF-8');
+ res.writeHead(200);
+ transport.register(req, this, new XhrPollingReceiver(req, res, this.options));
+ return true;
+ },
+ xhr_streaming: function(req, res, _, next_filter) {
+ res.setHeader('Content-Type', 'application/javascript; charset=UTF-8');
+ res.writeHead(200);
+ res.write(Array(2049).join('h') + '\n');
+ transport.register(req, this, new XhrStreamingReceiver(req, res, this.options));
+ return true;
+ }
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/transport.js
===================================================================
--- frontend/node_modules/sockjs/lib/transport.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/transport.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,438 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var GenericReceiver, MAP, ResponseReceiver, Session, SockJSConnection, Transport, closeFrame, register, stream, utils, uuidv4,
+ extend = function(child, parent) { for (var key in parent) { if (hasProp.call(parent, key)) child[key] = parent[key]; } function ctor() { this.constructor = child; } ctor.prototype = parent.prototype; child.prototype = new ctor(); child.__super__ = parent.prototype; return child; },
+ hasProp = {}.hasOwnProperty;
+
+ stream = require('stream');
+
+ uuidv4 = require('uuid').v4;
+
+ utils = require('./utils');
+
+ Transport = (function() {
+ function Transport() {}
+
+ return Transport;
+
+ })();
+
+ Transport.CONNECTING = 0;
+
+ Transport.OPEN = 1;
+
+ Transport.CLOSING = 2;
+
+ Transport.CLOSED = 3;
+
+ closeFrame = function(status, reason) {
+ return 'c' + JSON.stringify([status, reason]);
+ };
+
+ SockJSConnection = (function(superClass) {
+ extend(SockJSConnection, superClass);
+
+ function SockJSConnection(_session) {
+ this._session = _session;
+ this.id = uuidv4();
+ this.headers = {};
+ this.prefix = this._session.prefix;
+ }
+
+ SockJSConnection.prototype.toString = function() {
+ return '';
+ };
+
+ SockJSConnection.prototype.write = function(string) {
+ return this._session.send('' + string);
+ };
+
+ SockJSConnection.prototype.end = function(string) {
+ if (string) {
+ this.write(string);
+ }
+ this.close();
+ return null;
+ };
+
+ SockJSConnection.prototype.close = function(code, reason) {
+ return this._session.close(code, reason);
+ };
+
+ SockJSConnection.prototype.destroy = function() {
+ this.end();
+ return this.removeAllListeners();
+ };
+
+ SockJSConnection.prototype.destroySoon = function() {
+ return this.destroy();
+ };
+
+ return SockJSConnection;
+
+ })(stream.Stream);
+
+ SockJSConnection.prototype.__defineGetter__('readable', function() {
+ return this._session.readyState === Transport.OPEN;
+ });
+
+ SockJSConnection.prototype.__defineGetter__('writable', function() {
+ return this._session.readyState === Transport.OPEN;
+ });
+
+ SockJSConnection.prototype.__defineGetter__('readyState', function() {
+ return this._session.readyState;
+ });
+
+ MAP = {};
+
+ Session = (function() {
+ function Session(session_id1, server) {
+ this.session_id = session_id1;
+ this.heartbeat_delay = server.options.heartbeat_delay;
+ this.disconnect_delay = server.options.disconnect_delay;
+ this.prefix = server.options.prefix;
+ this.send_buffer = [];
+ this.is_closing = false;
+ this.readyState = Transport.CONNECTING;
+ if (this.session_id) {
+ MAP[this.session_id] = this;
+ }
+ this.timeout_cb = (function(_this) {
+ return function() {
+ return _this.didTimeout();
+ };
+ })(this);
+ this.to_tref = setTimeout(this.timeout_cb, this.disconnect_delay);
+ this.connection = new SockJSConnection(this);
+ this.emit_open = (function(_this) {
+ return function() {
+ _this.emit_open = null;
+ return server.emit('connection', _this.connection);
+ };
+ })(this);
+ }
+
+ Session.prototype.register = function(req, recv) {
+ if (this.recv) {
+ recv.doSendFrame(closeFrame(2010, "Another connection still open"));
+ recv.didClose();
+ return;
+ }
+ if (this.to_tref) {
+ clearTimeout(this.to_tref);
+ this.to_tref = null;
+ }
+ if (this.readyState === Transport.CLOSING) {
+ this.flushToRecv(recv);
+ recv.doSendFrame(this.close_frame);
+ recv.didClose();
+ this.to_tref = setTimeout(this.timeout_cb, this.disconnect_delay);
+ return;
+ }
+ this.recv = recv;
+ this.recv.session = this;
+ this.decorateConnection(req);
+ if (this.readyState === Transport.CONNECTING) {
+ this.recv.doSendFrame('o');
+ this.readyState = Transport.OPEN;
+ process.nextTick(this.emit_open);
+ }
+ if (!this.recv) {
+ return;
+ }
+ this.tryFlush();
+ };
+
+ Session.prototype.decorateConnection = function(req) {
+ var address, headers, i, key, len, ref, remoteAddress, remotePort, socket, x;
+ if (!(socket = this.recv.connection)) {
+ socket = this.recv.response.connection;
+ }
+ try {
+ remoteAddress = socket.remoteAddress;
+ remotePort = socket.remotePort;
+ address = socket.address();
+ } catch (error) {
+ x = error;
+ }
+ if (remoteAddress) {
+ this.connection.remoteAddress = remoteAddress;
+ this.connection.remotePort = remotePort;
+ this.connection.address = address;
+ }
+ this.connection.url = req.url;
+ this.connection.pathname = req.pathname;
+ this.connection.protocol = this.recv.protocol;
+ headers = {};
+ ref = ['referer', 'x-client-ip', 'x-forwarded-for', 'x-forwarded-host', 'x-forwarded-port', 'x-cluster-client-ip', 'via', 'x-real-ip', 'x-forwarded-proto', 'x-ssl', 'dnt', 'host', 'user-agent', 'accept-language'];
+ for (i = 0, len = ref.length; i < len; i++) {
+ key = ref[i];
+ if (req.headers[key]) {
+ headers[key] = req.headers[key];
+ }
+ }
+ if (headers) {
+ return this.connection.headers = headers;
+ }
+ };
+
+ Session.prototype.unregister = function() {
+ var delay;
+ delay = this.recv.delay_disconnect;
+ this.recv.session = null;
+ this.recv = null;
+ if (this.to_tref) {
+ clearTimeout(this.to_tref);
+ }
+ if (delay) {
+ return this.to_tref = setTimeout(this.timeout_cb, this.disconnect_delay);
+ } else {
+ return this.timeout_cb();
+ }
+ };
+
+ Session.prototype.flushToRecv = function(recv) {
+ var ref, sb;
+ if (this.send_buffer.length > 0) {
+ ref = [this.send_buffer, []], sb = ref[0], this.send_buffer = ref[1];
+ recv.doSendBulk(sb);
+ return true;
+ }
+ return false;
+ };
+
+ Session.prototype.tryFlush = function() {
+ var x;
+ if (!this.flushToRecv(this.recv) || !this.to_tref) {
+ if (this.to_tref) {
+ clearTimeout(this.to_tref);
+ }
+ x = (function(_this) {
+ return function() {
+ if (_this.recv) {
+ _this.to_tref = setTimeout(x, _this.heartbeat_delay);
+ return _this.recv.heartbeat();
+ }
+ };
+ })(this);
+ this.to_tref = setTimeout(x, this.heartbeat_delay);
+ }
+ };
+
+ Session.prototype.didTimeout = function() {
+ if (this.to_tref) {
+ clearTimeout(this.to_tref);
+ this.to_tref = null;
+ }
+ if (this.readyState !== Transport.CONNECTING && this.readyState !== Transport.OPEN && this.readyState !== Transport.CLOSING) {
+ throw Error('INVALID_STATE_ERR');
+ }
+ if (this.recv) {
+ throw Error('RECV_STILL_THERE');
+ }
+ this.readyState = Transport.CLOSED;
+ this.connection.emit('end');
+ this.connection.emit('close');
+ this.connection = null;
+ if (this.session_id) {
+ delete MAP[this.session_id];
+ return this.session_id = null;
+ }
+ };
+
+ Session.prototype.didMessage = function(payload) {
+ if (this.readyState === Transport.OPEN) {
+ this.connection.emit('data', payload);
+ }
+ };
+
+ Session.prototype.send = function(payload) {
+ if (this.readyState !== Transport.OPEN) {
+ return false;
+ }
+ this.send_buffer.push('' + payload);
+ if (this.recv) {
+ this.tryFlush();
+ }
+ return true;
+ };
+
+ Session.prototype.close = function(status, reason) {
+ if (status == null) {
+ status = 1000;
+ }
+ if (reason == null) {
+ reason = "Normal closure";
+ }
+ if (this.readyState !== Transport.OPEN) {
+ return false;
+ }
+ this.readyState = Transport.CLOSING;
+ this.close_frame = closeFrame(status, reason);
+ if (this.recv) {
+ this.recv.doSendFrame(this.close_frame);
+ if (this.recv) {
+ this.recv.didClose();
+ }
+ if (this.recv) {
+ this.unregister();
+ }
+ }
+ return true;
+ };
+
+ return Session;
+
+ })();
+
+ Session.bySessionId = function(session_id) {
+ if (!session_id) {
+ return null;
+ }
+ return MAP[session_id] || null;
+ };
+
+ register = function(req, server, session_id, receiver) {
+ var session;
+ session = Session.bySessionId(session_id);
+ if (!session) {
+ session = new Session(session_id, server);
+ }
+ session.register(req, receiver);
+ return session;
+ };
+
+ exports.register = function(req, server, receiver) {
+ return register(req, server, req.session, receiver);
+ };
+
+ exports.registerNoSession = function(req, server, receiver) {
+ return register(req, server, void 0, receiver);
+ };
+
+ GenericReceiver = (function() {
+ function GenericReceiver(thingy) {
+ this.thingy = thingy;
+ this.setUp(this.thingy);
+ }
+
+ GenericReceiver.prototype.setUp = function() {
+ this.thingy_end_cb = (function(_this) {
+ return function() {
+ return _this.didAbort();
+ };
+ })(this);
+ this.thingy.addListener('close', this.thingy_end_cb);
+ return this.thingy.addListener('end', this.thingy_end_cb);
+ };
+
+ GenericReceiver.prototype.tearDown = function() {
+ this.thingy.removeListener('close', this.thingy_end_cb);
+ this.thingy.removeListener('end', this.thingy_end_cb);
+ return this.thingy_end_cb = null;
+ };
+
+ GenericReceiver.prototype.didAbort = function() {
+ this.delay_disconnect = false;
+ return this.didClose();
+ };
+
+ GenericReceiver.prototype.didClose = function() {
+ if (this.thingy) {
+ this.tearDown(this.thingy);
+ this.thingy = null;
+ }
+ if (this.session) {
+ return this.session.unregister();
+ }
+ };
+
+ GenericReceiver.prototype.doSendBulk = function(messages) {
+ var m, q_msgs;
+ q_msgs = (function() {
+ var i, len, results;
+ results = [];
+ for (i = 0, len = messages.length; i < len; i++) {
+ m = messages[i];
+ results.push(utils.quote(m));
+ }
+ return results;
+ })();
+ return this.doSendFrame('a' + '[' + q_msgs.join(',') + ']');
+ };
+
+ GenericReceiver.prototype.heartbeat = function() {
+ return this.doSendFrame('h');
+ };
+
+ return GenericReceiver;
+
+ })();
+
+ ResponseReceiver = (function(superClass) {
+ extend(ResponseReceiver, superClass);
+
+ ResponseReceiver.prototype.max_response_size = void 0;
+
+ ResponseReceiver.prototype.delay_disconnect = true;
+
+ function ResponseReceiver(request, response, options) {
+ var x;
+ this.request = request;
+ this.response = response;
+ this.options = options;
+ this.curr_response_size = 0;
+ try {
+ this.request.connection.setKeepAlive(true, 5000);
+ } catch (error) {
+ x = error;
+ }
+ ResponseReceiver.__super__.constructor.call(this, this.request.connection);
+ if (this.max_response_size === void 0) {
+ this.max_response_size = this.options.response_limit;
+ }
+ }
+
+ ResponseReceiver.prototype.doSendFrame = function(payload) {
+ var r, x;
+ this.curr_response_size += payload.length;
+ r = false;
+ try {
+ this.response.write(payload);
+ r = true;
+ } catch (error) {
+ x = error;
+ }
+ if (this.max_response_size && this.curr_response_size >= this.max_response_size) {
+ this.didClose();
+ }
+ return r;
+ };
+
+ ResponseReceiver.prototype.didClose = function() {
+ var x;
+ ResponseReceiver.__super__.didClose.apply(this, arguments);
+ try {
+ this.response.end();
+ } catch (error) {
+ x = error;
+ }
+ return this.response = null;
+ };
+
+ return ResponseReceiver;
+
+ })(GenericReceiver);
+
+ exports.GenericReceiver = GenericReceiver;
+
+ exports.Transport = Transport;
+
+ exports.Session = Session;
+
+ exports.ResponseReceiver = ResponseReceiver;
+
+ exports.SockJSConnection = SockJSConnection;
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/utils.js
===================================================================
--- frontend/node_modules/sockjs/lib/utils.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/utils.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,153 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var array_intersection, crypto, escapable, lookup, unroll_lookup;
+
+ crypto = require('crypto');
+
+ exports.array_intersection = array_intersection = function(arr_a, arr_b) {
+ var a, j, len, r;
+ r = [];
+ for (j = 0, len = arr_a.length; j < len; j++) {
+ a = arr_a[j];
+ if (arr_b.indexOf(a) !== -1) {
+ r.push(a);
+ }
+ }
+ return r;
+ };
+
+ exports.escape_selected = function(str, chars) {
+ var c, i, j, l, len, map, parts, r, ref, v;
+ map = {};
+ chars = '%' + chars;
+ for (j = 0, len = chars.length; j < len; j++) {
+ c = chars[j];
+ map[c] = escape(c);
+ }
+ r = new RegExp('([' + chars + '])');
+ parts = str.split(r);
+ for (i = l = 0, ref = parts.length; 0 <= ref ? l < ref : l > ref; i = 0 <= ref ? ++l : --l) {
+ v = parts[i];
+ if (v.length === 1 && v in map) {
+ parts[i] = map[v];
+ }
+ }
+ return parts.join('');
+ };
+
+ exports.buffer_concat = function(buf_a, buf_b) {
+ var dst;
+ dst = new Buffer(buf_a.length + buf_b.length);
+ buf_a.copy(dst);
+ buf_b.copy(dst, buf_a.length);
+ return dst;
+ };
+
+ exports.md5_hex = function(data) {
+ return crypto.createHash('md5').update(data).digest('hex');
+ };
+
+ exports.sha1_base64 = function(data) {
+ return crypto.createHash('sha1').update(data).digest('base64');
+ };
+
+ exports.timeout_chain = function(arr) {
+ var fun, ref, timeout, user_fun;
+ arr = arr.slice(0);
+ if (!arr.length) {
+ return;
+ }
+ ref = arr.shift(), timeout = ref[0], user_fun = ref[1];
+ fun = (function(_this) {
+ return function() {
+ user_fun();
+ return exports.timeout_chain(arr);
+ };
+ })(this);
+ return setTimeout(fun, timeout);
+ };
+
+ exports.objectExtend = function(dst, src) {
+ var k;
+ for (k in src) {
+ if (src.hasOwnProperty(k)) {
+ dst[k] = src[k];
+ }
+ }
+ return dst;
+ };
+
+ exports.overshadowListeners = function(ee, event, handler) {
+ var new_handler, old_listeners;
+ old_listeners = ee.listeners(event).slice(0);
+ ee.removeAllListeners(event);
+ new_handler = function() {
+ var j, len, listener;
+ if (handler.apply(this, arguments) !== true) {
+ for (j = 0, len = old_listeners.length; j < len; j++) {
+ listener = old_listeners[j];
+ listener.apply(this, arguments);
+ }
+ return false;
+ }
+ return true;
+ };
+ return ee.addListener(event, new_handler);
+ };
+
+ escapable = /[\x00-\x1f\ud800-\udfff\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufff0-\uffff]/g;
+
+ unroll_lookup = function(escapable) {
+ var c, i, unrolled;
+ unrolled = {};
+ c = (function() {
+ var j, results;
+ results = [];
+ for (i = j = 0; j < 65536; i = ++j) {
+ results.push(String.fromCharCode(i));
+ }
+ return results;
+ })();
+ escapable.lastIndex = 0;
+ c.join('').replace(escapable, function(a) {
+ return unrolled[a] = '\\u' + ('0000' + a.charCodeAt(0).toString(16)).slice(-4);
+ });
+ return unrolled;
+ };
+
+ lookup = unroll_lookup(escapable);
+
+ exports.quote = function(string) {
+ var quoted;
+ quoted = JSON.stringify(string);
+ escapable.lastIndex = 0;
+ if (!escapable.test(quoted)) {
+ return quoted;
+ }
+ return quoted.replace(escapable, function(a) {
+ return lookup[a];
+ });
+ };
+
+ exports.parseCookie = function(cookie_header) {
+ var cookie, cookies, j, len, parts, ref;
+ cookies = {};
+ if (cookie_header) {
+ ref = cookie_header.split(';');
+ for (j = 0, len = ref.length; j < len; j++) {
+ cookie = ref[j];
+ parts = cookie.split('=');
+ cookies[parts[0].trim()] = (parts[1] || '').trim();
+ }
+ }
+ return cookies;
+ };
+
+ exports.random32 = function() {
+ var foo, v;
+ foo = crypto.randomBytes(4);
+ v = [foo[0], foo[1], foo[2], foo[3]];
+ return v[0] + (v[1] * 256) + (v[2] * 256 * 256) + (v[3] * 256 * 256 * 256);
+ };
+
+}).call(this);
Index: frontend/node_modules/sockjs/lib/webjs.js
===================================================================
--- frontend/node_modules/sockjs/lib/webjs.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/lib/webjs.js (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,305 @@
+// Generated by CoffeeScript 1.12.7
+(function() {
+ var GenericApp, execute_request, fake_response, fs, http, querystring, url, utils;
+
+ url = require('url');
+
+ querystring = require('querystring');
+
+ fs = require('fs');
+
+ http = require('http');
+
+ utils = require('./utils');
+
+ execute_request = function(app, funs, req, res, data) {
+ var fun, results, x;
+ try {
+ results = [];
+ while (funs.length > 0) {
+ fun = funs.shift();
+ req.last_fun = fun;
+ results.push(data = app[fun](req, res, data, req.next_filter));
+ }
+ return results;
+ } catch (error1) {
+ x = error1;
+ if (typeof x === 'object' && 'status' in x) {
+ if (x.status === 0) {
+ return;
+ } else if ('handle_' + x.status in app) {
+ app['handle_' + x.status](req, res, x);
+ } else {
+ app['handle_error'](req, res, x);
+ }
+ } else {
+ app['handle_error'](req, res, x);
+ }
+ return app['log_request'](req, res, true);
+ }
+ };
+
+ fake_response = function(req, res) {
+ var headers;
+ headers = {
+ 'Connection': 'close'
+ };
+ res.writeHead = function(status, user_headers) {
+ var k, r, x;
+ if (user_headers == null) {
+ user_headers = {};
+ }
+ r = [];
+ r.push('HTTP/' + req.httpVersion + ' ' + status + ' ' + http.STATUS_CODES[status]);
+ utils.objectExtend(headers, user_headers);
+ for (k in headers) {
+ r.push(k + ': ' + headers[k]);
+ }
+ r = r.concat(['', '']);
+ try {
+ return res.write(r.join('\r\n'));
+ } catch (error1) {
+ x = error1;
+ }
+ };
+ return res.setHeader = function(k, v) {
+ return headers[k] = v;
+ };
+ };
+
+ exports.generateHandler = function(app, dispatcher) {
+ return function(req, res, head) {
+ var allowed_methods, found, funs, i, j, l, len, m, method, path, ref, row;
+ if (typeof res.writeHead === "undefined") {
+ fake_response(req, res);
+ }
+ utils.objectExtend(req, url.parse(req.url, true));
+ req.start_date = new Date();
+ found = false;
+ allowed_methods = [];
+ for (j = 0, len = dispatcher.length; j < len; j++) {
+ row = dispatcher[j];
+ method = row[0], path = row[1], funs = row[2];
+ if (path.constructor !== Array) {
+ path = [path];
+ }
+ m = req.pathname.match(path[0]);
+ if (!m) {
+ continue;
+ }
+ if (!req.method.match(new RegExp(method))) {
+ allowed_methods.push(method);
+ continue;
+ }
+ for (i = l = 1, ref = path.length; 1 <= ref ? l < ref : l > ref; i = 1 <= ref ? ++l : --l) {
+ req[path[i]] = m[i];
+ }
+ funs = funs.slice(0);
+ funs.push('log_request');
+ req.next_filter = function(data) {
+ return execute_request(app, funs, req, res, data);
+ };
+ req.next_filter(head);
+ found = true;
+ break;
+ }
+ if (!found) {
+ if (allowed_methods.length !== 0) {
+ app['handle_405'](req, res, allowed_methods);
+ } else {
+ app['handle_404'](req, res);
+ }
+ app['log_request'](req, res, true);
+ }
+ };
+ };
+
+ exports.GenericApp = GenericApp = (function() {
+ function GenericApp() {}
+
+ GenericApp.prototype.handle_404 = function(req, res, x) {
+ if (res.finished) {
+ return x;
+ }
+ res.writeHead(404, {});
+ res.end();
+ return true;
+ };
+
+ GenericApp.prototype.handle_405 = function(req, res, methods) {
+ res.writeHead(405, {
+ 'Allow': methods.join(', ')
+ });
+ res.end();
+ return true;
+ };
+
+ GenericApp.prototype.handle_error = function(req, res, x) {
+ if (res.finished) {
+ return x;
+ }
+ if (typeof x === 'object' && 'status' in x) {
+ res.writeHead(x.status, {});
+ res.end(x.message || "");
+ } else {
+ try {
+ res.writeHead(500, {});
+ res.end("500 - Internal Server Error");
+ } catch (error1) {
+ x = error1;
+ }
+ this.log('error', 'Exception on "' + req.method + ' ' + req.href + '" in filter "' + req.last_fun + '":\n' + (x.stack || x));
+ }
+ return true;
+ };
+
+ GenericApp.prototype.log_request = function(req, res, data) {
+ var td;
+ td = (new Date()) - req.start_date;
+ this.log('info', req.method + ' ' + req.url + ' ' + td + 'ms ' + (res.finished ? res.statusCode : '(unfinished)'));
+ return data;
+ };
+
+ GenericApp.prototype.log = function(severity, line) {
+ return console.log(line);
+ };
+
+ GenericApp.prototype.expose_html = function(req, res, content) {
+ if (res.finished) {
+ return content;
+ }
+ if (!res.getHeader('Content-Type')) {
+ res.setHeader('Content-Type', 'text/html; charset=UTF-8');
+ }
+ return this.expose(req, res, content);
+ };
+
+ GenericApp.prototype.expose_json = function(req, res, content) {
+ if (res.finished) {
+ return content;
+ }
+ if (!res.getHeader('Content-Type')) {
+ res.setHeader('Content-Type', 'application/json');
+ }
+ return this.expose(req, res, JSON.stringify(content));
+ };
+
+ GenericApp.prototype.expose = function(req, res, content) {
+ if (res.finished) {
+ return content;
+ }
+ if (content && !res.getHeader('Content-Type')) {
+ res.setHeader('Content-Type', 'text/plain');
+ }
+ if (content) {
+ res.setHeader('Content-Length', content.length);
+ }
+ res.writeHead(res.statusCode);
+ res.end(content, 'utf8');
+ return true;
+ };
+
+ GenericApp.prototype.serve_file = function(req, res, filename, next_filter) {
+ var a;
+ a = function(error, content) {
+ if (error) {
+ res.writeHead(500);
+ res.end("can't read file");
+ } else {
+ res.setHeader('Content-length', content.length);
+ res.writeHead(res.statusCode, res.headers);
+ res.end(content, 'utf8');
+ }
+ return next_filter(true);
+ };
+ fs.readFile(filename, a);
+ throw {
+ status: 0
+ };
+ };
+
+ GenericApp.prototype.cache_for = function(req, res, content) {
+ var exp;
+ res.cache_for = res.cache_for || 365 * 24 * 60 * 60;
+ res.setHeader('Cache-Control', 'public, max-age=' + res.cache_for);
+ exp = new Date();
+ exp.setTime(exp.getTime() + res.cache_for * 1000);
+ res.setHeader('Expires', exp.toGMTString());
+ return content;
+ };
+
+ GenericApp.prototype.h_no_cache = function(req, res, content) {
+ res.setHeader('Cache-Control', 'no-store, no-cache, no-transform, must-revalidate, max-age=0');
+ return content;
+ };
+
+ GenericApp.prototype.expect_form = function(req, res, _data, next_filter) {
+ var data;
+ data = new Buffer(0);
+ req.on('data', (function(_this) {
+ return function(d) {
+ return data = utils.buffer_concat(data, new Buffer(d, 'binary'));
+ };
+ })(this));
+ req.on('end', (function(_this) {
+ return function() {
+ var q;
+ data = data.toString('utf-8');
+ switch ((req.headers['content-type'] || '').split(';')[0]) {
+ case 'application/x-www-form-urlencoded':
+ q = querystring.parse(data);
+ break;
+ case 'text/plain':
+ case '':
+ q = data;
+ break;
+ default:
+ _this.log('error', "Unsupported content-type " + req.headers['content-type']);
+ q = void 0;
+ }
+ return next_filter(q);
+ };
+ })(this));
+ throw {
+ status: 0
+ };
+ };
+
+ GenericApp.prototype.expect_xhr = function(req, res, _data, next_filter) {
+ var data;
+ data = new Buffer(0);
+ req.on('data', (function(_this) {
+ return function(d) {
+ return data = utils.buffer_concat(data, new Buffer(d, 'binary'));
+ };
+ })(this));
+ req.on('end', (function(_this) {
+ return function() {
+ var q;
+ data = data.toString('utf-8');
+ switch ((req.headers['content-type'] || '').split(';')[0]) {
+ case 'text/plain':
+ case 'T':
+ case 'application/json':
+ case 'application/xml':
+ case '':
+ case 'text/xml':
+ q = data;
+ break;
+ default:
+ _this.log('error', 'Unsupported content-type ' + req.headers['content-type']);
+ q = void 0;
+ }
+ return next_filter(q);
+ };
+ })(this));
+ throw {
+ status: 0
+ };
+ };
+
+ return GenericApp;
+
+ })();
+
+}).call(this);
Index: frontend/node_modules/sockjs/package.json
===================================================================
--- frontend/node_modules/sockjs/package.json (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
+++ frontend/node_modules/sockjs/package.json (revision 9af201e94b5a79beb92a30858fc54de4bc3b9449)
@@ -0,0 +1,43 @@
+{
+ "name": "sockjs",
+ "description": "SockJS-node is a server counterpart of SockJS-client a JavaScript library that provides a WebSocket-like object in the browser. SockJS gives you a coherent, cross-browser, Javascript API which creates a low latency, full duplex, cross-domain communication channel between the browser and the web server.",
+ "version": "0.3.24",
+ "author": "Marek Majkowski",
+ "bugs": {
+ "url": "https://github.com/sockjs/sockjs-node/issues"
+ },
+ "contributors": [
+ {
+ "name": "Bryce Kahle",
+ "email": "bkahle@gmail.com"
+ },
+ {
+ "name": "Marek Majkowski",
+ "email": "deadbeef@popcount.org"
+ }
+ ],
+ "dependencies": {
+ "faye-websocket": "^0.11.3",
+ "uuid": "^8.3.2",
+ "websocket-driver": "^0.7.4"
+ },
+ "devDependencies": {
+ "coffeescript": "^1.12.7"
+ },
+ "homepage": "https://github.com/sockjs/sockjs-node",
+ "keywords": [
+ "websockets",
+ "websocket"
+ ],
+ "license": "MIT",
+ "main": "index",
+ "repository": {
+ "type": "git",
+ "url": "https://github.com/sockjs/sockjs-node.git"
+ },
+ "scripts": {
+ "version": "make build && git add Changelog",
+ "postversion": "npm publish",
+ "postpublish": "git push origin --all && git push origin --tags"
+ }
+}