|
|
var assert = require('assert') , WebSocket = require('../') , server = require('./testserver');
var port = 20000;
function getArrayBuffer(buf) { var l = buf.length; var arrayBuf = new ArrayBuffer(l); var uint8View = new Uint8Array(arrayBuf);
for (var i = 0; i < l; i++) { uint8View[i] = buf[i]; } return uint8View.buffer; }
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('WebSocket', function() { it('communicates successfully with echo service', function(done) { var ws = new WebSocket('ws://echo.websocket.org/', {protocolVersion: 13, origin: 'http://websocket.org'}); var str = Date.now().toString(); var dataReceived = false; ws.on('open', function() { ws.send(str, {mask: true}); }); ws.on('close', function() { assert.equal(true, dataReceived); done(); }); ws.on('message', function(data, flags) { assert.equal(str, data); ws.terminate(); dataReceived = true; }); }); });
|