signaling_server/service/node_modules/engine.io-client/lib/transport.js

   1 /**
   2  * Module dependencies.
   3  */
   4
   5 var parser = require('engine.io-parser');
   6 var Emitter = require('component-emitter');
   7
   8 /**
   9  * Module exports.
  10  */
  11
  12 module.exports = Transport;
  13
  14 /**
  15  * Transport abstract constructor.
  16  *
  17  * @param {Object} options.
  18  * @api private
  19  */
  20
  21 function Transport (opts) {
  22   this.path = opts.path;
  23   this.hostname = opts.hostname;
  24   this.port = opts.port;
  25   this.secure = opts.secure;
  26   this.query = opts.query;
  27   this.timestampParam = opts.timestampParam;
  28   this.timestampRequests = opts.timestampRequests;
  29   this.readyState = '';
  30   this.agent = opts.agent || false;
  31   this.socket = opts.socket;
  32   this.enablesXDR = opts.enablesXDR;
  33   this.withCredentials = opts.withCredentials;
  34
  35   // SSL options for Node.js client
  36   this.pfx = opts.pfx;
  37   this.key = opts.key;
  38   this.passphrase = opts.passphrase;
  39   this.cert = opts.cert;
  40   this.ca = opts.ca;
  41   this.ciphers = opts.ciphers;
  42   this.rejectUnauthorized = opts.rejectUnauthorized;
  43   this.forceNode = opts.forceNode;
  44
  45   // results of ReactNative environment detection
  46   this.isReactNative = opts.isReactNative;
  47
  48   // other options for Node.js client
  49   this.extraHeaders = opts.extraHeaders;
  50   this.localAddress = opts.localAddress;
  51 }
  52
  53 /**
  54  * Mix in `Emitter`.
  55  */
  56
  57 Emitter(Transport.prototype);
  58
  59 /**
  60  * Emits an error.
  61  *
  62  * @param {String} str
  63  * @return {Transport} for chaining
  64  * @api public
  65  */
  66
  67 Transport.prototype.onError = function (msg, desc) {
  68   var err = new Error(msg);
  69   err.type = 'TransportError';
  70   err.description = desc;
  71   this.emit('error', err);
  72   return this;
  73 };
  74
  75 /**
  76  * Opens the transport.
  77  *
  78  * @api public
  79  */
  80
  81 Transport.prototype.open = function () {
  82   if ('closed' === this.readyState || '' === this.readyState) {
  83     this.readyState = 'opening';
  84     this.doOpen();
  85   }
  86
  87   return this;
  88 };
  89
  90 /**
  91  * Closes the transport.
  92  *
  93  * @api private
  94  */
  95
  96 Transport.prototype.close = function () {
  97   if ('opening' === this.readyState || 'open' === this.readyState) {
  98     this.doClose();
  99     this.onClose();
 100   }
 101
 102   return this;
 103 };
 104
 105 /**
 106  * Sends multiple packets.
 107  *
 108  * @param {Array} packets
 109  * @api private
 110  */
 111
 112 Transport.prototype.send = function (packets) {
 113   if ('open' === this.readyState) {
 114     this.write(packets);
 115   } else {
 116     throw new Error('Transport not open');
 117   }
 118 };
 119
 120 /**
 121  * Called upon open
 122  *
 123  * @api private
 124  */
 125
 126 Transport.prototype.onOpen = function () {
 127   this.readyState = 'open';
 128   this.writable = true;
 129   this.emit('open');
 130 };
 131
 132 /**
 133  * Called with data.
 134  *
 135  * @param {String} data
 136  * @api private
 137  */
 138
 139 Transport.prototype.onData = function (data) {
 140   var packet = parser.decodePacket(data, this.socket.binaryType);
 141   this.onPacket(packet);
 142 };
 143
 144 /**
 145  * Called with a decoded packet.
 146  */
 147
 148 Transport.prototype.onPacket = function (packet) {
 149   this.emit('packet', packet);
 150 };
 151
 152 /**
 153  * Called upon close.
 154  *
 155  * @api private
 156  */
 157
 158 Transport.prototype.onClose = function () {
 159   this.readyState = 'closed';
 160   this.emit('close');
 161 };