Gecko [ www.foryou-vip.com ]

Name	Size	Permission	Date
fixtures	[ DIR ]	drwxr-xr-x	2022-06-27 18:41
BufferPool.test.js	1.89 KB	-rw-r--r--	2012-02-29 08:49
Receiver.hixie.test.js	3.04 KB	-rw-r--r--	2012-06-18 22:08
Receiver.test.js	8.64 KB	-rw-r--r--	2012-06-18 21:30
Sender.hixie.test.js	3.43 KB	-rw-r--r--	2012-05-19 12:12
Sender.test.js	739 B	-rw-r--r--	2012-02-29 14:54
Validation.test.js	1.83 KB	-rw-r--r--	2012-02-29 08:49
WebSocket.integration.js	1.04 KB	-rw-r--r--	2012-02-29 08:49
WebSocket.test.js	42.55 KB	-rw-r--r--	2012-06-26 18:27
WebSocketServer.test.js	31.26 KB	-rw-r--r--	2012-06-18 21:44
autobahn-server.js	732 B	-rw-r--r--	2012-02-29 08:49
autobahn.js	1.38 KB	-rw-r--r--	2012-05-20 12:21
hybi-common.js	2.2 KB	-rw-r--r--	2012-02-29 08:49
testserver.js	4.24 KB	-rw-r--r--	2012-06-18 21:33

Rename

var assert = require('assert')
  , expect = require('expect.js')
  , Receiver = require('../lib/Receiver.hixie');
require('./hybi-common');

describe('Receiver', function() {
  it('can parse text message', function() {
    var p = new Receiver();
    var packet = '00 48 65 6c 6c 6f ff';

var gotData = false;
    p.ontext = function(data) {
      gotData = true;
      assert.equal('Hello', data);
    };

p.add(getBufferFromHexString(packet));
    expect(gotData).to.equal(true);
  });

it('can parse multiple text messages', function() {
    var p = new Receiver();
    var packet = '00 48 65 6c 6c 6f ff 00 48 65 6c 6c 6f ff';

var gotData = false;
    var messages = [];
    p.ontext = function(data) {
      gotData = true;
      messages.push(data);
    };

p.add(getBufferFromHexString(packet));
    expect(gotData).to.equal(true);
    for (var i = 0; i < 2; ++i) {
      expect(messages[i]).to.equal('Hello');
    }
  });

it('can parse empty message', function() {
    var p = new Receiver();
    var packet = '00 ff';

var gotData = false;
    p.ontext = function(data) {
      gotData = true;
      assert.equal('', data);
    };

p.add(getBufferFromHexString(packet));
    expect(gotData).to.equal(true);
  });

it('can parse text messages delivered over multiple frames', function() {
    var p = new Receiver();
    var packets = [
      '00 48',
      '65 6c 6c',
      '6f ff 00 48',
      '65',
      '6c 6c 6f',
      'ff'
    ];

var gotData = false;
    var messages = [];
    p.ontext = function(data) {
      gotData = true;
      messages.push(data);
    };

for (var i = 0; i < packets.length; ++i) {
      p.add(getBufferFromHexString(packets[i]));
    }
    expect(gotData).to.equal(true);
    for (var i = 0; i < 2; ++i) {
      expect(messages[i]).to.equal('Hello');
    }
  });

it('emits an error if a payload doesnt start with 0x00', function() {
    var p = new Receiver();
    var packets = [
      '00 6c ff',
      '00 6c ff ff',
      'ff 00 6c ff 00 6c ff',
      '00',
      '6c 6c 6f',
      'ff'
    ];

var gotData = false;
    var gotError = false;
    var messages = [];
    p.ontext = function(data) {
      gotData = true;
      messages.push(data);
    };
    p.onerror = function(reason, code) {
      gotError = code == true;
    };

for (var i = 0; i < packets.length && !gotError; ++i) {
      p.add(getBufferFromHexString(packets[i]));
    }
    expect(gotError).to.equal(true);
    expect(messages[0]).to.equal('l');
    expect(messages[1]).to.equal('l');
    expect(messages.length).to.equal(2);
  });

it('can parse close messages', function() {
    var p = new Receiver();
    var packets = [
      'ff 00'
    ];

var gotClose = false;
    var gotError = false;
    p.onclose = function() {
      gotClose = true;
    };
    p.onerror = function(reason, code) {
      gotError = code == true;
    };

for (var i = 0; i < packets.length && !gotError; ++i) {
      p.add(getBufferFromHexString(packets[i]));
    }
    expect(gotClose).to.equal(true);
    expect(gotError).to.equal(false);
  });
});