k8s-overleaf/olgitbridge/lib/socket.io-client/test/parser.test.js

/*!
 * socket.io-node
 * Copyright(c) 2011 LearnBoost <dev@learnboost.com>
 * MIT Licensed
 */

(function (module, io, should) {

  var parser = io.parser;

  module.exports = {

    'decoding error packet': function () {
      parser.decodePacket('7:::').should().eql({
          type: 'error'
        , reason: ''
        , advice: ''
        , endpoint: ''
      });
    },

    'decoding error packet with reason': function () {
      parser.decodePacket('7:::0').should().eql({
          type: 'error'
        , reason: 'transport not supported'
        , advice: ''
        , endpoint: ''
      });
    },

    'decoding error packet with reason and advice': function () {
      parser.decodePacket('7:::2+0').should().eql({
          type: 'error'
        , reason: 'unauthorized'
        , advice: 'reconnect'
        , endpoint: ''
      });
    },

    'decoding error packet with endpoint': function () {
      parser.decodePacket('7::/woot').should().eql({
          type: 'error'
        , reason: ''
        , advice: ''
        , endpoint: '/woot'
      });
    },

    'decoding ack packet': function () {
      parser.decodePacket('6:::140').should().eql({
          type: 'ack'
        , ackId: '140'
        , endpoint: ''
        , args: []
      });
    },

    'decoding ack packet with args': function () {
      parser.decodePacket('6:::12+["woot","wa"]').should().eql({
          type: 'ack'
        , ackId: '12'
        , endpoint: ''
        , args: ['woot', 'wa']
      });
    },

    'decoding ack packet with bad json': function () {
      var thrown = false;

      try {
        parser.decodePacket('6:::1+{"++]').should().eql({
            type: 'ack'
          , ackId: '1'
          , endpoint: ''
          , args: []
        });
      } catch (e) {
        thrown = true;
      }

      thrown.should().be_false;
    },

    'decoding json packet': function () {
      parser.decodePacket('4:::"2"').should().eql({
          type: 'json'
        , endpoint: ''
        , data: '2'
      });
    },

    'decoding json packet with message id and ack data': function () {
      parser.decodePacket('4:1+::{"a":"b"}').should().eql({
          type: 'json'
        , id: 1
        , ack: 'data'
        , endpoint: ''
        , data: { a: 'b' }
      });
    },

    'decoding an event packet': function () {
      parser.decodePacket('5:::{"name":"woot"}').should().eql({
          type: 'event'
        , name: 'woot'
        , endpoint: ''
        , args: []
      });
    },

    'decoding an event packet with message id and ack': function () {
      parser.decodePacket('5:1+::{"name":"tobi"}').should().eql({
          type: 'event'
        , id: 1
        , ack: 'data'
        , endpoint: ''
        , name: 'tobi'
        , args: []
      });
    },

    'decoding an event packet with data': function () {
      parser.decodePacket('5:::{"name":"edwald","args":[{"a": "b"},2,"3"]}')
      .should().eql({
          type: 'event'
        , name: 'edwald'
        , endpoint: ''
        , args: [{a: 'b'}, 2, '3']
      });
    },

    'decoding a message packet': function () {
      parser.decodePacket('3:::woot').should().eql({
          type: 'message'
        , endpoint: ''
        , data: 'woot'
      });
    },

    'decoding a message packet with id and endpoint': function () {
      parser.decodePacket('3:5:/tobi').should().eql({
          type: 'message'
        , id: 5
        , ack: true
        , endpoint: '/tobi'
        , data: ''
      });
    },

    'decoding a heartbeat packet': function () {
      parser.decodePacket('2:::').should().eql({
          type: 'heartbeat'
        , endpoint: ''
      });
    },

    'decoding a connection packet': function () {
      parser.decodePacket('1::/tobi').should().eql({
          type: 'connect'
        , endpoint: '/tobi'
        , qs: ''
      });
    },

    'decoding a connection packet with query string': function () {
      parser.decodePacket('1::/test:?test=1').should().eql({
          type: 'connect'
        , endpoint: '/test'
        , qs: '?test=1'
      });
    },

    'decoding a disconnection packet': function () {
      parser.decodePacket('0::/woot').should().eql({
          type: 'disconnect'
        , endpoint: '/woot'
      });
    },

    'encoding error packet': function () {
      parser.encodePacket({
          type: 'error'
        , reason: ''
        , advice: ''
        , endpoint: ''
      }).should().eql('7::');
    },

    'encoding error packet with reason': function () {
      parser.encodePacket({
          type: 'error'
        , reason: 'transport not supported'
        , advice: ''
        , endpoint: ''
      }).should().eql('7:::0');
    },

    'encoding error packet with reason and advice': function () {
      parser.encodePacket({
          type: 'error'
        , reason: 'unauthorized'
        , advice: 'reconnect'
        , endpoint: ''
      }).should().eql('7:::2+0');
    },

    'encoding error packet with endpoint': function () {
      parser.encodePacket({
          type: 'error'
        , reason: ''
        , advice: ''
        , endpoint: '/woot'
      }).should().eql('7::/woot');
    },

    'encoding ack packet': function () {
      parser.encodePacket({
          type: 'ack'
        , ackId: '140'
        , endpoint: ''
        , args: []
      }).should().eql('6:::140');
    },

    'encoding ack packet with args': function () {
      parser.encodePacket({
          type: 'ack'
        , ackId: '12'
        , endpoint: ''
        , args: ['woot', 'wa']
      }).should().eql('6:::12+["woot","wa"]');
    },

    'encoding json packet': function () {
      parser.encodePacket({
          type: 'json'
        , endpoint: ''
        , data: '2'
      }).should().eql('4:::"2"');
    },

    'encoding json packet with message id and ack data': function () {
      parser.encodePacket({
          type: 'json'
        , id: 1
        , ack: 'data'
        , endpoint: ''
        , data: { a: 'b' }
      }).should().eql('4:1+::{"a":"b"}');
    },

    'encoding an event packet': function () {
      parser.encodePacket({
          type: 'event'
        , name: 'woot'
        , endpoint: ''
        , args: []
      }).should().eql('5:::{"name":"woot"}');
    },

    'encoding an event packet with message id and ack': function () {
      parser.encodePacket({
          type: 'event'
        , id: 1
        , ack: 'data'
        , endpoint: ''
        , name: 'tobi'
        , args: []
      }).should().eql('5:1+::{"name":"tobi"}');
    },

    'encoding an event packet with data': function () {
      parser.encodePacket({
          type: 'event'
        , name: 'edwald'
        , endpoint: ''
        , args: [{a: 'b'}, 2, '3']
      }).should().eql('5:::{"name":"edwald","args":[{"a":"b"},2,"3"]}');
    },

    'encoding a message packet': function () {
      parser.encodePacket({
          type: 'message'
        , endpoint: ''
        , data: 'woot'
      }).should().eql('3:::woot');
    },

    'encoding a message packet with id and endpoint': function () {
      parser.encodePacket({
          type: 'message'
        , id: 5
        , ack: true
        , endpoint: '/tobi'
        , data: ''
      }).should().eql('3:5:/tobi');
    },

    'encoding a heartbeat packet': function () {
      parser.encodePacket({
          type: 'heartbeat'
        , endpoint: ''
      }).should().eql('2::');
    },

    'encoding a connection packet': function () {
      parser.encodePacket({
          type: 'connect'
        , endpoint: '/tobi'
        , qs: ''
      }).should().eql('1::/tobi');
    },

    'encoding a connection packet with query string': function () {
      parser.encodePacket({
          type: 'connect'
        , endpoint: '/test'
        , qs: '?test=1'
      }).should().eql('1::/test:?test=1');
    },

    'encoding a disconnection packet': function () {
      parser.encodePacket({
          type: 'disconnect'
        , endpoint: '/woot'
      }).should().eql('0::/woot');
    },

    'test decoding a payload': function () {
      parser.decodePayload('\ufffd5\ufffd3:::5\ufffd7\ufffd3:::53d'
        + '\ufffd3\ufffd0::').should().eql([
          { type: 'message', data: '5', endpoint: '' }
        , { type: 'message', data: '53d', endpoint: '' }
        , { type: 'disconnect', endpoint: '' }
      ]);
    },

    'test encoding a payload': function () {
      parser.encodePayload([
          parser.encodePacket({ type: 'message', data: '5', endpoint: '' })
        , parser.encodePacket({ type: 'message', data: '53d', endpoint: '' })
      ]).should().eql('\ufffd5\ufffd3:::5\ufffd7\ufffd3:::53d')
    },

    'test decoding newline': function () {
      parser.decodePacket('3:::\n').should().eql({
          type: 'message'
        , endpoint: ''
        , data: '\n'
      });
    }

  };

})(
    'undefined' == typeof module ? module = {} : module
  , 'undefined' == typeof io ? require('socket.io-client') : io
  , 'undefined' == typeof should ? require('should') : should
);