summaryrefslogtreecommitdiff
path: root/node_modules/ws/test/WebSocketServer.test.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/ws/test/WebSocketServer.test.js')
-rw-r--r--node_modules/ws/test/WebSocketServer.test.js1103
1 files changed, 1103 insertions, 0 deletions
diff --git a/node_modules/ws/test/WebSocketServer.test.js b/node_modules/ws/test/WebSocketServer.test.js
new file mode 100644
index 0000000..c21fd97
--- /dev/null
+++ b/node_modules/ws/test/WebSocketServer.test.js
@@ -0,0 +1,1103 @@
+var http = require('http')
+ , https = require('https')
+ , WebSocket = require('../')
+ , WebSocketServer = WebSocket.Server
+ , fs = require('fs')
+ , should = require('should');
+
+var port = 8000;
+
+function getArrayBuffer(buf) {
+ var l = buf.length;
+ var arrayBuf = new ArrayBuffer(l);
+ for (var i = 0; i < l; ++i) {
+ arrayBuf[i] = buf[i];
+ }
+ return arrayBuf;
+}
+
+function areArraysEqual(x, y) {
+ if (x.length != y.length) return false;
+ for (var i = 0, l = x.length; i < l; ++i) {
+ if (x[i] !== y[i]) return false;
+ }
+ return true;
+}
+
+describe('WebSocketServer', function() {
+ describe('#ctor', function() {
+ it('throws an error if no option object is passed', function() {
+ var gotException = false;
+ try {
+ var wss = new WebSocketServer();
+ }
+ catch (e) {
+ gotException = true;
+ }
+ gotException.should.be.ok;
+ });
+
+ it('throws an error if no port or server is specified', function() {
+ var gotException = false;
+ try {
+ var wss = new WebSocketServer({});
+ }
+ catch (e) {
+ gotException = true;
+ }
+ gotException.should.be.ok;
+ });
+
+ it('does not throw an error if no port or server is specified, when the noServer option is true', function() {
+ var gotException = false;
+ try {
+ var wss = new WebSocketServer({noServer: true});
+ }
+ catch (e) {
+ gotException = true;
+ }
+ gotException.should.eql(false);
+ });
+
+ it('emits an error if http server bind fails', function(done) {
+ var wss = new WebSocketServer({port: 1});
+ wss.on('error', function() { done(); });
+ });
+
+ it('starts a server on a given port', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var ws = new WebSocket('ws://localhost:' + port);
+ });
+ wss.on('connection', function(client) {
+ wss.close();
+ done();
+ });
+ });
+
+ it('uses a precreated http server', function (done) {
+ var srv = http.createServer();
+ srv.listen(++port, function () {
+ var wss = new WebSocketServer({server: srv});
+ var ws = new WebSocket('ws://localhost:' + port);
+
+ wss.on('connection', function(client) {
+ wss.close();
+ srv.close();
+ done();
+ });
+ });
+ });
+
+ it('uses a precreated http server listening on unix socket', function (done) {
+ var srv = http.createServer();
+ var sockPath = '/tmp/ws_socket_'+new Date().getTime()+'.'+Math.floor(Math.random() * 1000);
+ srv.listen(sockPath, function () {
+ var wss = new WebSocketServer({server: srv});
+ var ws = new WebSocket('ws+unix://'+sockPath);
+
+ wss.on('connection', function(client) {
+ wss.close();
+ srv.close();
+ done();
+ });
+ });
+ });
+
+ it('emits path specific connection event', function (done) {
+ var srv = http.createServer();
+ srv.listen(++port, function () {
+ var wss = new WebSocketServer({server: srv});
+ var ws = new WebSocket('ws://localhost:' + port+'/endpointName');
+
+ wss.on('connection/endpointName', function(client) {
+ wss.close();
+ srv.close();
+ done();
+ });
+ });
+ });
+
+ it('can have two different instances listening on the same http server with two different paths', function(done) {
+ var srv = http.createServer();
+ srv.listen(++port, function () {
+ var wss1 = new WebSocketServer({server: srv, path: '/wss1'})
+ , wss2 = new WebSocketServer({server: srv, path: '/wss2'});
+ var doneCount = 0;
+ wss1.on('connection', function(client) {
+ wss1.close();
+ if (++doneCount == 2) {
+ srv.close();
+ done();
+ }
+ });
+ wss2.on('connection', function(client) {
+ wss2.close();
+ if (++doneCount == 2) {
+ srv.close();
+ done();
+ }
+ });
+ var ws1 = new WebSocket('ws://localhost:' + port + '/wss1');
+ var ws2 = new WebSocket('ws://localhost:' + port + '/wss2?foo=1');
+ });
+ });
+
+ it('cannot have two different instances listening on the same http server with the same path', function(done) {
+ var srv = http.createServer();
+ srv.listen(++port, function () {
+ var wss1 = new WebSocketServer({server: srv, path: '/wss1'});
+ try {
+ var wss2 = new WebSocketServer({server: srv, path: '/wss1'});
+ }
+ catch (e) {
+ wss1.close();
+ srv.close();
+ done();
+ }
+ });
+ });
+ });
+
+ describe('#close', function() {
+ it('will close all clients', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var ws = new WebSocket('ws://localhost:' + port);
+ ws.on('close', function() {
+ if (++closes == 2) done();
+ });
+ });
+ var closes = 0;
+ wss.on('connection', function(client) {
+ client.on('close', function() {
+ if (++closes == 2) done();
+ });
+ wss.close();
+ });
+ });
+
+ it('does not close a precreated server', function(done) {
+ var srv = http.createServer();
+ var realClose = srv.close;
+ srv.close = function() {
+ should.fail('must not close pre-created server');
+ }
+ srv.listen(++port, function () {
+ var wss = new WebSocketServer({server: srv});
+ var ws = new WebSocket('ws://localhost:' + port);
+ wss.on('connection', function(client) {
+ wss.close();
+ srv.close = realClose;
+ srv.close();
+ done();
+ });
+ });
+ });
+
+ it('cleans up websocket data on a precreated server', function(done) {
+ var srv = http.createServer();
+ srv.listen(++port, function () {
+ var wss1 = new WebSocketServer({server: srv, path: '/wss1'})
+ , wss2 = new WebSocketServer({server: srv, path: '/wss2'});
+ (typeof srv._webSocketPaths).should.eql('object');
+ Object.keys(srv._webSocketPaths).length.should.eql(2);
+ wss1.close();
+ Object.keys(srv._webSocketPaths).length.should.eql(1);
+ wss2.close();
+ (typeof srv._webSocketPaths).should.eql('undefined');
+ srv.close();
+ done();
+ });
+ });
+ });
+
+ describe('#clients', function() {
+ it('returns a list of connected clients', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ wss.clients.length.should.eql(0);
+ var ws = new WebSocket('ws://localhost:' + port);
+ });
+ wss.on('connection', function(client) {
+ wss.clients.length.should.eql(1);
+ wss.close();
+ done();
+ });
+ });
+
+ it('can be disabled', function(done) {
+ var wss = new WebSocketServer({port: ++port, clientTracking: false}, function() {
+ wss.clients.length.should.eql(0);
+ var ws = new WebSocket('ws://localhost:' + port);
+ });
+ wss.on('connection', function(client) {
+ wss.clients.length.should.eql(0);
+ wss.close();
+ done();
+ });
+ });
+
+ it('is updated when client terminates the connection', function(done) {
+ var ws;
+ var wss = new WebSocketServer({port: ++port}, function() {
+ ws = new WebSocket('ws://localhost:' + port);
+ });
+ wss.on('connection', function(client) {
+ client.on('close', function() {
+ wss.clients.length.should.eql(0);
+ wss.close();
+ done();
+ });
+ ws.terminate();
+ });
+ });
+
+ it('is updated when client closes the connection', function(done) {
+ var ws;
+ var wss = new WebSocketServer({port: ++port}, function() {
+ ws = new WebSocket('ws://localhost:' + port);
+ });
+ wss.on('connection', function(client) {
+ client.on('close', function() {
+ wss.clients.length.should.eql(0);
+ wss.close();
+ done();
+ });
+ ws.close();
+ });
+ });
+ });
+
+ describe('#options', function() {
+ it('exposes options passed to constructor', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ wss.options.port.should.eql(port);
+ wss.close();
+ done();
+ });
+ });
+ });
+
+ describe('#handleUpgrade', function() {
+ it('can be used for a pre-existing server', function (done) {
+ var srv = http.createServer();
+ srv.listen(++port, function () {
+ var wss = new WebSocketServer({noServer: true});
+ srv.on('upgrade', function(req, socket, upgradeHead) {
+ wss.handleUpgrade(req, socket, upgradeHead, function(client) {
+ client.send('hello');
+ });
+ });
+ var ws = new WebSocket('ws://localhost:' + port);
+ ws.on('message', function(message) {
+ message.should.eql('hello');
+ wss.close();
+ srv.close();
+ done();
+ });
+ });
+ });
+ });
+
+ describe('hybi mode', function() {
+ describe('connection establishing', function() {
+ it('does not accept connections with no sec-websocket-key', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(400);
+ wss.close();
+ done();
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('does not accept connections with no sec-websocket-version', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ=='
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(400);
+ wss.close();
+ done();
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('does not accept connections with invalid sec-websocket-version', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 12
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(400);
+ wss.close();
+ done();
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('client can be denied', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o) {
+ return false;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 8,
+ 'Sec-WebSocket-Origin': 'http://foobar.com'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(401);
+ process.nextTick(function() {
+ wss.close();
+ done();
+ });
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('client can be accepted', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o) {
+ return true;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 13,
+ 'Origin': 'http://foobar.com'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ });
+ wss.on('connection', function(ws) {
+ ws.terminate();
+ wss.close();
+ done();
+ });
+ wss.on('error', function() {});
+ });
+
+ it('verifyClient gets client origin', function(done) {
+ var verifyClientCalled = false;
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(info) {
+ info.origin.should.eql('http://foobarbaz.com');
+ verifyClientCalled = true;
+ return false;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 13,
+ 'Origin': 'http://foobarbaz.com'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ verifyClientCalled.should.be.ok;
+ wss.close();
+ done();
+ });
+ });
+ wss.on('error', function() {});
+ });
+
+ it('verifyClient gets original request', function(done) {
+ var verifyClientCalled = false;
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(info) {
+ info.req.headers['sec-websocket-key'].should.eql('dGhlIHNhbXBsZSBub25jZQ==');
+ verifyClientCalled = true;
+ return false;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 13,
+ 'Origin': 'http://foobarbaz.com'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ verifyClientCalled.should.be.ok;
+ wss.close();
+ done();
+ });
+ });
+ wss.on('error', function() {});
+ });
+
+ it('verifyClient has secure:true for ssl connections', function(done) {
+ var options = {
+ key: fs.readFileSync('test/fixtures/key.pem'),
+ cert: fs.readFileSync('test/fixtures/certificate.pem')
+ };
+ var app = https.createServer(options, function (req, res) {
+ res.writeHead(200);
+ res.end();
+ });
+ var success = false;
+ var wss = new WebSocketServer({
+ server: app,
+ verifyClient: function(info) {
+ success = info.secure === true;
+ return true;
+ }
+ });
+ app.listen(++port, function() {
+ var ws = new WebSocket('wss://localhost:' + port);
+ });
+ wss.on('connection', function(ws) {
+ app.close();
+ ws.terminate();
+ wss.close();
+ success.should.be.ok;
+ done();
+ });
+ });
+
+ it('verifyClient has secure:false for non-ssl connections', function(done) {
+ var app = http.createServer(function (req, res) {
+ res.writeHead(200);
+ res.end();
+ });
+ var success = false;
+ var wss = new WebSocketServer({
+ server: app,
+ verifyClient: function(info) {
+ success = info.secure === false;
+ return true;
+ }
+ });
+ app.listen(++port, function() {
+ var ws = new WebSocket('ws://localhost:' + port);
+ });
+ wss.on('connection', function(ws) {
+ app.close();
+ ws.terminate();
+ wss.close();
+ success.should.be.ok;
+ done();
+ });
+ });
+
+ it('client can be denied asynchronously', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o, cb) {
+ process.nextTick(function() {
+ cb(false);
+ });
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 8,
+ 'Sec-WebSocket-Origin': 'http://foobar.com'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(401);
+ process.nextTick(function() {
+ wss.close();
+ done();
+ });
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('client can be accepted asynchronously', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o, cb) {
+ process.nextTick(function() {
+ cb(true);
+ });
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 13,
+ 'Origin': 'http://foobar.com'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ });
+ wss.on('connection', function(ws) {
+ ws.terminate();
+ wss.close();
+ done();
+ });
+ wss.on('error', function() {});
+ });
+
+ it('handles messages passed along with the upgrade request (upgrade head)', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o) {
+ return true;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 13,
+ 'Origin': 'http://foobar.com'
+ }
+ };
+ var req = http.request(options);
+ req.write(new Buffer([0x81, 0x05, 0x48, 0x65, 0x6c, 0x6c, 0x6f], 'binary'));
+ req.end();
+ });
+ wss.on('connection', function(ws) {
+ ws.on('message', function(data) {
+ data.should.eql('Hello');
+ ws.terminate();
+ wss.close();
+ done();
+ });
+ });
+ wss.on('error', function() {});
+ });
+
+ it('selects the first protocol by default', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocol: 'prot1, prot2'});
+ ws.on('open', function(client) {
+ ws.protocol.should.eql('prot1');
+ wss.close();
+ done();
+ });
+ });
+ });
+
+ it('selects the last protocol via protocol handler', function(done) {
+ var wss = new WebSocketServer({port: ++port, handleProtocols: function(ps, cb) {
+ cb(true, ps[ps.length-1]); }}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocol: 'prot1, prot2'});
+ ws.on('open', function(client) {
+ ws.protocol.should.eql('prot2');
+ wss.close();
+ done();
+ });
+ });
+ });
+
+ it('client detects invalid server protocol', function(done) {
+ var wss = new WebSocketServer({port: ++port, handleProtocols: function(ps, cb) {
+ cb(true, 'prot3'); }}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocol: 'prot1, prot2'});
+ ws.on('open', function(client) {
+ done(new Error('connection must not be established'));
+ });
+ ws.on('error', function() {
+ done();
+ });
+ });
+ });
+
+ it('client detects no server protocol', function(done) {
+ var wss = new WebSocketServer({port: ++port, handleProtocols: function(ps, cb) {
+ cb(true); }}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocol: 'prot1, prot2'});
+ ws.on('open', function(client) {
+ done(new Error('connection must not be established'));
+ });
+ ws.on('error', function() {
+ done();
+ });
+ });
+ });
+
+ it('client refuses server protocols', function(done) {
+ var wss = new WebSocketServer({port: ++port, handleProtocols: function(ps, cb) {
+ cb(false); }}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocol: 'prot1, prot2'});
+ ws.on('open', function(client) {
+ done(new Error('connection must not be established'));
+ });
+ ws.on('error', function() {
+ done();
+ });
+ });
+ });
+
+ it('server detects invalid protocol handler', function(done) {
+ var wss = new WebSocketServer({port: ++port, handleProtocols: function(ps, cb) {
+ // not calling callback is an error and shouldn't timeout
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'websocket',
+ 'Sec-WebSocket-Key': 'dGhlIHNhbXBsZSBub25jZQ==',
+ 'Sec-WebSocket-Version': 13,
+ 'Sec-WebSocket-Origin': 'http://foobar.com'
+ }
+ };
+ options.port = port;
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(501);
+ wss.close();
+ done();
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+ });
+
+ describe('messaging', function() {
+ it('can send and receive data', function(done) {
+ var data = new Array(65*1024);
+ for (var i = 0; i < data.length; ++i) {
+ data[i] = String.fromCharCode(65 + ~~(25 * Math.random()));
+ }
+ data = data.join('');
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var ws = new WebSocket('ws://localhost:' + port);
+ ws.on('message', function(message, flags) {
+ ws.send(message);
+ });
+ });
+ wss.on('connection', function(client) {
+ client.on('message', function(message) {
+ message.should.eql(data);
+ wss.close();
+ done();
+ });
+ client.send(data);
+ });
+ });
+ });
+ });
+
+ describe('hixie mode', function() {
+ it('can be disabled', function(done) {
+ var wss = new WebSocketServer({port: ++port, disableHixie: true}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(401);
+ process.nextTick(function() {
+ wss.close();
+ done();
+ });
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ describe('connection establishing', function() {
+ it('does not accept connections with no sec-websocket-key1', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(400);
+ wss.close();
+ done();
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('does not accept connections with no sec-websocket-key2', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(400);
+ wss.close();
+ done();
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('accepts connections with valid handshake', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ });
+ wss.on('connection', function(ws) {
+ ws.terminate();
+ wss.close();
+ done();
+ });
+ wss.on('error', function() {});
+ });
+
+ it('client can be denied', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o) {
+ return false;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(401);
+ process.nextTick(function() {
+ wss.close();
+ done();
+ });
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('client can be accepted', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o) {
+ return true;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ });
+ wss.on('connection', function(ws) {
+ ws.terminate();
+ wss.close();
+ done();
+ });
+ wss.on('error', function() {});
+ });
+
+ it('verifyClient gets client origin', function(done) {
+ var verifyClientCalled = false;
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(info) {
+ info.origin.should.eql('http://foobarbaz.com');
+ verifyClientCalled = true;
+ return false;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Origin': 'http://foobarbaz.com',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ req.on('response', function(res) {
+ verifyClientCalled.should.be.ok;
+ wss.close();
+ done();
+ });
+ });
+ wss.on('error', function() {});
+ });
+
+ it('verifyClient gets original request', function(done) {
+ var verifyClientCalled = false;
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(info) {
+ info.req.headers['sec-websocket-key1'].should.eql('3e6b263 4 17 80');
+ verifyClientCalled = true;
+ return false;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Origin': 'http://foobarbaz.com',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ req.on('response', function(res) {
+ verifyClientCalled.should.be.ok;
+ wss.close();
+ done();
+ });
+ });
+ wss.on('error', function() {});
+ });
+
+ it('client can be denied asynchronously', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o, cb) {
+ cb(false);
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Origin': 'http://foobarbaz.com',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ req.on('response', function(res) {
+ res.statusCode.should.eql(401);
+ process.nextTick(function() {
+ wss.close();
+ done();
+ });
+ });
+ });
+ wss.on('connection', function(ws) {
+ done(new Error('connection must not be established'));
+ });
+ wss.on('error', function() {});
+ });
+
+ it('client can be accepted asynchronously', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o, cb) {
+ cb(true);
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Origin': 'http://foobarbaz.com',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.end();
+ });
+ wss.on('connection', function(ws) {
+ wss.close();
+ done();
+ });
+ wss.on('error', function() {});
+ });
+
+ it('handles messages passed along with the upgrade request (upgrade head)', function(done) {
+ var wss = new WebSocketServer({port: ++port, verifyClient: function(o) {
+ return true;
+ }}, function() {
+ var options = {
+ port: port,
+ host: '127.0.0.1',
+ headers: {
+ 'Connection': 'Upgrade',
+ 'Upgrade': 'WebSocket',
+ 'Sec-WebSocket-Key1': '3e6b263 4 17 80',
+ 'Sec-WebSocket-Key2': '17 9 G`ZD9 2 2b 7X 3 /r90',
+ 'Origin': 'http://foobar.com'
+ }
+ };
+ var req = http.request(options);
+ req.write('WjN}|M(6');
+ req.write(new Buffer([0x00, 0x48, 0x65, 0x6c, 0x6c, 0x6f, 0xff], 'binary'));
+ req.end();
+ });
+ wss.on('connection', function(ws) {
+ ws.on('message', function(data) {
+ data.should.eql('Hello');
+ ws.terminate();
+ wss.close();
+ done();
+ });
+ });
+ wss.on('error', function() {});
+ });
+ });
+ });
+
+ describe('client properties', function() {
+ it('protocol is exposed', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocol: 'hi'});
+ });
+ wss.on('connection', function(client) {
+ client.protocol.should.eql('hi');
+ wss.close();
+ done();
+ });
+ });
+
+ it('protocolVersion is exposed', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocolVersion: 8});
+ });
+ wss.on('connection', function(client) {
+ client.protocolVersion.should.eql(8);
+ wss.close();
+ done();
+ });
+ });
+
+ it('upgradeReq is the original request object', function(done) {
+ var wss = new WebSocketServer({port: ++port}, function() {
+ var ws = new WebSocket('ws://localhost:' + port, {protocolVersion: 8});
+ });
+ wss.on('connection', function(client) {
+ client.upgradeReq.httpVersion.should.eql('1.1');
+ wss.close();
+ done();
+ });
+ });
+ });
+
+});
generated by cgit v1.2.3-70-g09d2 (git 2.51.0) at 2025-12-10 06:46:10 +0000