Gecko [ www.ctm-euromeuble.fr ]

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')
  , Sender = require('../lib/Sender.hixie');
require('should');
require('./hybi-common');

describe('Sender', function() {
  describe('#send', function() {
    it('frames and sends a text message', function(done) {
      var message = 'Hello world';
      var received;
      var socket = {
        write: function(data, encoding, cb) {
          received = data;
          process.nextTick(cb);
        }
      };
      var sender = new Sender(socket, {});
      sender.send(message, {}, function() {
        received.toString('utf8').should.eql('\u0000' + message + '\ufffd');
        done();
      });
    });

it('frames and sends an empty message', function(done) {
      var socket = {
        write: function(data, encoding, cb) {
          done();
        }
      };
      var sender = new Sender(socket, {});
      sender.send('', {}, function() {});
    });

it('frames and sends a buffer', function(done) {
      var received;
      var socket = {
        write: function(data, encoding, cb) {
          received = data;
          process.nextTick(cb);
        }
      };
      var sender = new Sender(socket, {});
      sender.send(new Buffer('foobar'), {}, function() {
        received.toString('utf8').should.eql('\u0000foobar\ufffd');
        done();
      });
    });

it('throws an exception for binary data', function(done) {
      var socket = {
        write: function(data, encoding, cb) {
          process.nextTick(cb);
        }
      };
      var sender = new Sender(socket, {});
      sender.on('error', function() {
        done();
      });
      sender.send(new Buffer(100), {binary: true}, function() {});
    });

it('can fauxe stream data', function(done) {
      var received = [];
      var socket = {
        write: function(data, encoding, cb) {
          received.push(data);
          process.nextTick(cb);
        }
      };
      var sender = new Sender(socket, {});
      sender.send(new Buffer('foobar'), { fin: false }, function() {});
      sender.send('bazbar', { fin: false }, function() {});
      sender.send(new Buffer('end'), { fin: true }, function() {
        received[0].toString('utf8').should.eql('\u0000foobar');
        received[1].toString('utf8').should.eql('bazbar');
        received[2].toString('utf8').should.eql('end\ufffd');
        done();
      });
    });
  });

describe('#close', function() {
    it('sends a hixie close frame', function(done) {
      var received;
      var socket = {
        write: function(data, encoding, cb) {
          received = data;
          process.nextTick(cb);
        }
      };
      var sender = new Sender(socket, {});
      sender.close(null, null, null, function() {
        received.toString('utf8').should.eql('\ufffd\u0000');
        done();
      });
    });

it('sends a message end marker if fauxe streaming has started, before hixie close frame', function(done) {
      var received = [];
      var socket = {
        write: function(data, encoding, cb) {
          received.push(data);
          if (cb) process.nextTick(cb);
        }
      };
      var sender = new Sender(socket, {});
      sender.send(new Buffer('foobar'), { fin: false }, function() {});
      sender.close(null, null, null, function() {
        received[0].toString('utf8').should.eql('\u0000foobar');
        received[1].toString('utf8').should.eql('\ufffd');
        received[2].toString('utf8').should.eql('\ufffd\u0000');
        done();
      });
    });
  });
});