example/iot-gateway/node_modules/engine.io/lib/transport.js

   1
   2 /**
   3  * Module dependencies.
   4  */
   5
   6 var EventEmitter = require('events').EventEmitter
   7   , parser = require('engine.io-parser')
   8   , debug = require('debug')('engine:transport');
   9
  10 /**
  11  * Expose the constructor.
  12  */
  13
  14 module.exports = Transport;
  15
  16 /**
  17  * Noop function.
  18  *
  19  * @api private
  20  */
  21
  22 function noop () {}
  23
  24 /**
  25  * Transport constructor.
  26  *
  27  * @param {http.ServerRequest} request
  28  * @api public
  29  */
  30
  31 function Transport (req) {
  32   this.readyState = 'open';
  33   this.discarded = false;
  34 }
  35
  36 /**
  37  * Inherits from EventEmitter.
  38  */
  39
  40 Transport.prototype.__proto__ = EventEmitter.prototype;
  41
  42 /**
  43  * Flags the transport as discarded.
  44  *
  45  * @api private
  46  */
  47
  48 Transport.prototype.discard = function () {
  49   this.discarded = true;
  50 };
  51
  52 /**
  53  * Called with an incoming HTTP request.
  54  *
  55  * @param {http.ServerRequest} request
  56  * @api private
  57  */
  58
  59 Transport.prototype.onRequest = function (req) {
  60   debug('setting request');
  61   this.req = req;
  62 };
  63
  64 /**
  65  * Closes the transport.
  66  *
  67  * @api private
  68  */
  69
  70 Transport.prototype.close = function (fn) {
  71   if ('closed' == this.readyState || 'closing' == this.readyState) return;
  72
  73   this.readyState = 'closing';
  74   this.doClose(fn || noop);
  75 };
  76
  77 /**
  78  * Called with a transport error.
  79  *
  80  * @param {String} message error
  81  * @param {Object} error description
  82  * @api private
  83  */
  84
  85 Transport.prototype.onError = function (msg, desc) {
  86   if (this.listeners('error').length) {
  87     var err = new Error(msg);
  88     err.type = 'TransportError';
  89     err.description = desc;
  90     this.emit('error', err);
  91   } else {
  92     debug('ignored transport error %s (%s)', msg, desc);
  93   }
  94 };
  95
  96 /**
  97  * Called with parsed out a packets from the data stream.
  98  *
  99  * @param {Object} packet
 100  * @api private
 101  */
 102
 103 Transport.prototype.onPacket = function (packet) {
 104   this.emit('packet', packet);
 105 };
 106
 107 /**
 108  * Called with the encoded packet data.
 109  *
 110  * @param {String} data
 111  * @api private
 112  */
 113
 114 Transport.prototype.onData = function (data) {
 115   this.onPacket(parser.decodePacket(data));
 116 };
 117
 118 /**
 119  * Called upon transport close.
 120  *
 121  * @api private
 122  */
 123
 124 Transport.prototype.onClose = function () {
 125   this.readyState = 'closed';
 126   this.emit('close');
 127 };