How to use this._server.open method in Cypress

1var Faye = (typeof Faye === 'object') ? Faye : {};2if (typeof window !== 'undefined') window.Faye = Faye;3Faye.extend = function(dest, source, overwrite) {4  if (!source) return dest;5  for (var key in source) {6    if (!source.hasOwnProperty(key)) continue;7    if (dest.hasOwnProperty(key) && overwrite === false) continue;8    if (dest[key] !== source[key])9      dest[key] = source[key];10  }11  return dest;12};13Faye.extend(Faye, {14  VERSION:          '0.8.0',15  16  BAYEUX_VERSION:   '1.0',17  ID_LENGTH:        128,18  JSONP_CALLBACK:   'jsonpcallback',19  CONNECTION_TYPES: ['long-polling', 'cross-origin-long-polling', 'callback-polling', 'websocket', 'eventsource', 'in-process'],20  21  MANDATORY_CONNECTION_TYPES: ['long-polling', 'callback-polling', 'in-process'],22  23  ENV: (function() { return this })(),24  25  random: function(bitlength) {26    bitlength = bitlength || this.ID_LENGTH;27    if (bitlength > 32) {28      var parts  = Math.ceil(bitlength / 32),29          string = '';30      while (parts--) string += this.random(32);31      return string;32    }33    var limit   = Math.pow(2, bitlength) - 1,34        maxSize = limit.toString(36).length,35        string  = Math.floor(Math.random() * limit).toString(36);36    37    while (string.length < maxSize) string = '0' + string;38    return string;39  },40  41  copyObject: function(object) {42    var clone, i, key;43    if (object instanceof Array) {44      clone = [];45      i = object.length;46      while (i--) clone[i] = Faye.copyObject(object[i]);47      return clone;48    } else if (typeof object === 'object') {49      clone = {};50      for (key in object) clone[key] = Faye.copyObject(object[key]);51      return clone;52    } else {53      return object;54    }55  },56  57  commonElement: function(lista, listb) {58    for (var i = 0, n = lista.length; i < n; i++) {59      if (this.indexOf(listb, lista[i]) !== -1)60        return lista[i];61    }62    return null;63  },64  65  indexOf: function(list, needle) {66    if (list.indexOf) return list.indexOf(needle);67    68    for (var i = 0, n = list.length; i < n; i++) {69      if (list[i] === needle) return i;70    }71    return -1;72  },73  74  map: function(object, callback, context) {75    if (object.map) return object.map(callback, context);76    var result = [];77    78    if (object instanceof Array) {79      for (var i = 0, n = object.length; i < n; i++) {80        result.push(callback.call(context || null, object[i], i));81      }82    } else {83      for (var key in object) {84        if (!object.hasOwnProperty(key)) continue;85        result.push(callback.call(context || null, key, object[key]));86      }87    }88    return result;89  },90  91  filter: function(array, callback, context) {92    var result = [];93    for (var i = 0, n = array.length; i < n; i++) {94      if (callback.call(context || null, array[i], i))95        result.push(array[i]);96    }97    return result;98  },99  100  asyncEach: function(list, iterator, callback, context) {101    var n       = list.length,102        i       = -1,103        calls   = 0,104        looping = false;105    var iterate = function() {106      calls -= 1;107      i += 1;108      if (i === n) return callback && callback.call(context);109      iterator(list[i], resume);110    };111    var loop = function() {112      if (looping) return;113      looping = true;114      while (calls > 0) iterate();115      looping = false;116    };117    var resume = function() {118      calls += 1;119      loop();120    };121    resume();122  },123  124  // http://assanka.net/content/tech/2009/09/02/json2-js-vs-prototype/125  toJSON: function(object) {126    if (this.stringify)127      return this.stringify(object, function(key, value) {128        return (this[key] instanceof Array)129            ? this[key]130            : value;131      });132    133    return JSON.stringify(object);134  },135  136  timestamp: function() {137    var date   = new Date(),138        year   = date.getFullYear(),139        month  = date.getMonth() + 1,140        day    = date.getDate(),141        hour   = date.getHours(),142        minute = date.getMinutes(),143        second = date.getSeconds();144    145    var pad = function(n) {146      return n < 10 ? '0' + n : String(n);147    };148    149    return pad(year) + '-' + pad(month) + '-' + pad(day) + ' ' +150           pad(hour) + ':' + pad(minute) + ':' + pad(second);151  }152});153Faye.Class = function(parent, methods) {154  if (typeof parent !== 'function') {155    methods = parent;156    parent  = Object;157  }158  159  var klass = function() {160    if (!this.initialize) return this;161    return this.initialize.apply(this, arguments) || this;162  };163  164  var bridge = function() {};165  bridge.prototype = parent.prototype;166  167  klass.prototype = new bridge();168  Faye.extend(klass.prototype, methods);169  170  return klass;171};172Faye.Namespace = Faye.Class({173  initialize: function() {174    this._used = {};175  },176  177  exists: function(id) {178    return this._used.hasOwnProperty(id);179  },180  181  generate: function() {182    var name = Faye.random();183    while (this._used.hasOwnProperty(name))184      name = Faye.random();185    return this._used[name] = name;186  },187  188  release: function(id) {189    delete this._used[id];190  }191});192Faye.Error = Faye.Class({193  initialize: function(code, params, message) {194    this.code    = code;195    this.params  = Array.prototype.slice.call(params);196    this.message = message;197  },198  199  toString: function() {200    return this.code + ':' +201           this.params.join(',') + ':' +202           this.message;203  }204});205Faye.Error.parse = function(message) {206  message = message || '';207  if (!Faye.Grammar.ERROR.test(message)) return new this(null, [], message);208  var parts   = message.split(':'),209      code    = parseInt(parts[0]),210      params  = parts[1].split(','),211      message = parts[2];212  return new this(code, params, message);213};214Faye.Error.versionMismatch = function() {215  return new this(300, arguments, "Version mismatch").toString();216};217Faye.Error.conntypeMismatch = function() {218  return new this(301, arguments, "Connection types not supported").toString();219};220Faye.Error.extMismatch = function() {221  return new this(302, arguments, "Extension mismatch").toString();222};223Faye.Error.badRequest = function() {224  return new this(400, arguments, "Bad request").toString();225};226Faye.Error.clientUnknown = function() {227  return new this(401, arguments, "Unknown client").toString();228};229Faye.Error.parameterMissing = function() {230  return new this(402, arguments, "Missing required parameter").toString();231};232Faye.Error.channelForbidden = function() {233  return new this(403, arguments, "Forbidden channel").toString();234};235Faye.Error.channelUnknown = function() {236  return new this(404, arguments, "Unknown channel").toString();237};238Faye.Error.channelInvalid = function() {239  return new this(405, arguments, "Invalid channel").toString();240};241Faye.Error.extUnknown = function() {242  return new this(406, arguments, "Unknown extension").toString();243};244Faye.Error.publishFailed = function() {245  return new this(407, arguments, "Failed to publish").toString();246};247Faye.Error.serverError = function() {248  return new this(500, arguments, "Internal server error").toString();249};250Faye.Deferrable = {251  callback: function(callback, context) {252    if (!callback) return;253    254    if (this._deferredStatus === 'succeeded')255      return callback.apply(context, this._deferredArgs);256    257    this._callbacks = this._callbacks || [];258    this._callbacks.push([callback, context]);259  },260  261  timeout: function(seconds, message) {262    var _this = this;263    var timer = Faye.ENV.setTimeout(function() {264      _this.setDeferredStatus('failed', message);265    }, seconds * 1000);266    this._timer = timer;267  },268  269  errback: function(callback, context) {270    if (!callback) return;271    if (this._deferredStatus === 'failed')272      return callback.apply(context, this._deferredArgs);273    this._errbacks = this._errbacks || [];274    this._errbacks.push([callback, context]);275  },276  setDeferredStatus: function() {277    if (this._timer)278      Faye.ENV.clearTimeout(this._timer);279    var args   = Array.prototype.slice.call(arguments),280        status = args.shift(),281        callbacks;282    283    this._deferredStatus = status;284    this._deferredArgs = args;285    286    if (status === 'succeeded')287      callbacks = this._callbacks;288    else if (status === 'failed')289      callbacks = this._errbacks;290    291    if (!callbacks) return;292    293    var callback;294    while (callback = callbacks.shift())295      callback[0].apply(callback[1], this._deferredArgs);296  }297};298Faye.Publisher = {299  countListeners: function(eventType) {300    if (!this._subscribers || !this._subscribers[eventType]) return 0;301    return this._subscribers[eventType].length;302  },303  304  bind: function(eventType, listener, context) {305    this._subscribers = this._subscribers || {};306    var list = this._subscribers[eventType] = this._subscribers[eventType] || [];307    list.push([listener, context]);308  },309  310  unbind: function(eventType, listener, context) {311    if (!this._subscribers || !this._subscribers[eventType]) return;312    313    if (!listener) {314      delete this._subscribers[eventType];315      return;316    }317    var list = this._subscribers[eventType],318        i    = list.length;319    320    while (i--) {321      if (listener !== list[i][0]) continue;322      if (context && list[i][1] !== context) continue;323      list.splice(i,1);324    }325  },326  327  trigger: function() {328    var args = Array.prototype.slice.call(arguments),329        eventType = args.shift();330    331    if (!this._subscribers || !this._subscribers[eventType]) return;332    333    var listeners = this._subscribers[eventType],334        listener;335    336    for (var i = 0, n = listeners.length; i < n; i++) {337      listener = listeners[i];338      listener[0].apply(listener[1], args);339    }340  }341};342Faye.Timeouts = {343  addTimeout: function(name, delay, callback, context) {344    this._timeouts = this._timeouts || {};345    if (this._timeouts.hasOwnProperty(name)) return;346    var self = this;347    this._timeouts[name] = Faye.ENV.setTimeout(function() {348      delete self._timeouts[name];349      callback.call(context);350    }, 1000 * delay);351  },352  353  removeTimeout: function(name) {354    this._timeouts = this._timeouts || {};355    var timeout = this._timeouts[name];356    if (!timeout) return;357    clearTimeout(timeout);358    delete this._timeouts[name];359  }360};361Faye.Logging = {362  LOG_LEVELS: {363    error:  3,364    warn:   2,365    info:   1,366    debug:  0367  },368  369  logLevel: 'error',370  371  log: function(messageArgs, level) {372    if (!Faye.logger) return;373    374    var levels = Faye.Logging.LOG_LEVELS;375    if (levels[Faye.Logging.logLevel] > levels[level]) return;376    377    var messageArgs = Array.prototype.slice.apply(messageArgs),378        banner = ' [' + level.toUpperCase() + '] [Faye',379        klass  = this.className,380        381        message = messageArgs.shift().replace(/\?/g, function() {382          try {383            return Faye.toJSON(messageArgs.shift());384          } catch (e) {385            return '[Object]';386          }387        });388    389    for (var key in Faye) {390      if (klass) continue;391      if (typeof Faye[key] !== 'function') continue;392      if (this instanceof Faye[key]) klass = key;393    }394    if (klass) banner += '.' + klass;395    banner += '] ';396    397    Faye.logger(Faye.timestamp() + banner + message);398  }399};400(function() {401  for (var key in Faye.Logging.LOG_LEVELS)402    (function(level, value) {403      Faye.Logging[level] = function() {404        this.log(arguments, level);405      };406    })(key, Faye.Logging.LOG_LEVELS[key]);407})();408Faye.Grammar = {409  LOWALPHA:     /^[a-z]$/,410  UPALPHA:     /^[A-Z]$/,411  ALPHA:     /^([a-z]|[A-Z])$/,412  DIGIT:     /^[0-9]$/,413  ALPHANUM:     /^(([a-z]|[A-Z])|[0-9])$/,414  MARK:     /^(\-|\_|\!|\~|\(|\)|\$|\@)$/,415  STRING:     /^(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*$/,416  TOKEN:     /^(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)))+$/,417  INTEGER:     /^([0-9])+$/,418  CHANNEL_SEGMENT:     /^(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)))+$/,419  CHANNEL_SEGMENTS:     /^(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)))+(\/(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)))+)*$/,420  CHANNEL_NAME:     /^\/(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)))+(\/(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)))+)*$/,421  WILD_CARD:     /^\*{1,2}$/,422  CHANNEL_PATTERN:     /^(\/(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)))+)*\/\*{1,2}$/,423  VERSION_ELEMENT:     /^(([a-z]|[A-Z])|[0-9])(((([a-z]|[A-Z])|[0-9])|\-|\_))*$/,424  VERSION:     /^([0-9])+(\.(([a-z]|[A-Z])|[0-9])(((([a-z]|[A-Z])|[0-9])|\-|\_))*)*$/,425  CLIENT_ID:     /^((([a-z]|[A-Z])|[0-9]))+$/,426  ID:     /^((([a-z]|[A-Z])|[0-9]))+$/,427  ERROR_MESSAGE:     /^(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*$/,428  ERROR_ARGS:     /^(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*(,(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*)*$/,429  ERROR_CODE:     /^[0-9][0-9][0-9]$/,430  ERROR:     /^([0-9][0-9][0-9]:(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*(,(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*)*:(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*|[0-9][0-9][0-9]::(((([a-z]|[A-Z])|[0-9])|(\-|\_|\!|\~|\(|\)|\$|\@)| |\/|\*|\.))*)$/431};432Faye.Extensible = {433  addExtension: function(extension) {434    this._extensions = this._extensions || [];435    this._extensions.push(extension);436    if (extension.added) extension.added(this);437  },438  439  removeExtension: function(extension) {440    if (!this._extensions) return;441    var i = this._extensions.length;442    while (i--) {443      if (this._extensions[i] !== extension) continue;444      this._extensions.splice(i,1);445      if (extension.removed) extension.removed(this);446    }447  },448  449  pipeThroughExtensions: function(stage, message, callback, context) {450    this.debug('Passing through ? extensions: ?', stage, message);451    if (!this._extensions) return callback.call(context, message);452    var extensions = this._extensions.slice();453    454    var pipe = function(message) {455      if (!message) return callback.call(context, message);456      457      var extension = extensions.shift();458      if (!extension) return callback.call(context, message);459      460      if (extension[stage]) extension[stage](message, pipe);461      else pipe(message);462    };463    pipe(message);464  }465};466Faye.extend(Faye.Extensible, Faye.Logging);467Faye.Channel = Faye.Class({468  initialize: function(name) {469    this.id = this.name = name;470  },471  472  push: function(message) {473    this.trigger('message', message);474  },475  476  isUnused: function() {477    return this.countListeners('message') === 0;478  }479});480Faye.extend(Faye.Channel.prototype, Faye.Publisher);481Faye.extend(Faye.Channel, {482  HANDSHAKE:    '/meta/handshake',483  CONNECT:      '/meta/connect',484  SUBSCRIBE:    '/meta/subscribe',485  UNSUBSCRIBE:  '/meta/unsubscribe',486  DISCONNECT:   '/meta/disconnect',487  488  META:         'meta',489  SERVICE:      'service',490  491  expand: function(name) {492    var segments = this.parse(name),493        channels = ['/**', name];494    495    var copy = segments.slice();496    copy[copy.length - 1] = '*';497    channels.push(this.unparse(copy));498    499    for (var i = 1, n = segments.length; i < n; i++) {500      copy = segments.slice(0, i);501      copy.push('**');502      channels.push(this.unparse(copy));503    }504    505    return channels;506  },507  508  isValid: function(name) {509    return Faye.Grammar.CHANNEL_NAME.test(name) ||510           Faye.Grammar.CHANNEL_PATTERN.test(name);511  },512  513  parse: function(name) {514    if (!this.isValid(name)) return null;515    return name.split('/').slice(1);516  },517  518  unparse: function(segments) {519    return '/' + segments.join('/');520  },521  522  isMeta: function(name) {523    var segments = this.parse(name);524    return segments ? (segments[0] === this.META) : null;525  },526  527  isService: function(name) {528    var segments = this.parse(name);529    return segments ? (segments[0] === this.SERVICE) : null;530  },531  532  isSubscribable: function(name) {533    if (!this.isValid(name)) return null;534    return !this.isMeta(name) && !this.isService(name);535  },536  537  Set: Faye.Class({538    initialize: function() {539      this._channels = {};540    },541    542    getKeys: function() {543      var keys = [];544      for (var key in this._channels) keys.push(key);545      return keys;546    },547    548    remove: function(name) {549      delete this._channels[name];550    },551    552    hasSubscription: function(name) {553      return this._channels.hasOwnProperty(name);554    },555    556    subscribe: function(names, callback, context) {557      if (!callback) return;558      var name;559      for (var i = 0, n = names.length; i < n; i++) {560        name = names[i];561        var channel = this._channels[name] = this._channels[name] || new Faye.Channel(name);562        channel.bind('message', callback, context);563      }564    },565    566    unsubscribe: function(name, callback, context) {567      var channel = this._channels[name];568      if (!channel) return false;569      channel.unbind('message', callback, context);570      571      if (channel.isUnused()) {572        this.remove(name);573        return true;574      } else {575        return false;576      }577    },578    579    distributeMessage: function(message) {580      var channels = Faye.Channel.expand(message.channel);581      582      for (var i = 0, n = channels.length; i < n; i++) {583        var channel = this._channels[channels[i]];584        if (channel) channel.trigger('message', message.data);585      }586    }587  })588});589Faye.Publication = Faye.Class(Faye.Deferrable);590Faye.Subscription = Faye.Class({591  initialize: function(client, channels, callback, context) {592    this._client    = client;593    this._channels  = channels;594    this._callback  = callback;595    this._context     = context;596    this._cancelled = false;597  },598  599  cancel: function() {600    if (this._cancelled) return;601    this._client.unsubscribe(this._channels, this._callback, this._context);602    this._cancelled = true;603  },604  605  unsubscribe: function() {606    this.cancel();607  }608});609Faye.extend(Faye.Subscription.prototype, Faye.Deferrable);610Faye.Client = Faye.Class({611  UNCONNECTED:          1,612  CONNECTING:           2,613  CONNECTED:            3,614  DISCONNECTED:         4,615  616  HANDSHAKE:            'handshake',617  RETRY:                'retry',618  NONE:                 'none',619  620  CONNECTION_TIMEOUT:   60.0,621  DEFAULT_RETRY:        5.0,622  623  DEFAULT_ENDPOINT:     '/bayeux',624  INTERVAL:             0.0,625  626  initialize: function(endpoint, options) {627    this.info('New client created for ?', endpoint);628    629    this.endpoint   = endpoint || this.DEFAULT_ENDPOINT;630    this._cookies   = Faye.CookieJar && new Faye.CookieJar();631    this._headers   = {};632    this._options   = options || {};633    this._disabled  = [];634    this.retry      = this._options.retry || this.DEFAULT_RETRY;635    636    this._selectTransport(Faye.MANDATORY_CONNECTION_TYPES);637    638    this._state     = this.UNCONNECTED;639    this._channels  = new Faye.Channel.Set();640    this._messageId = 0;641    642    this._responseCallbacks = {};643    644    this._advice = {645      reconnect: this.RETRY,646      interval:  1000 * (this._options.interval || this.INTERVAL),647      timeout:   1000 * (this._options.timeout  || this.CONNECTION_TIMEOUT)648    };649    650    if (Faye.Event)651      Faye.Event.on(Faye.ENV, 'beforeunload', function() {652        if (Faye.indexOf(this._disabled, 'autodisconnect') < 0)653          this.disconnect();654      }, this);655  },656  657  disable: function(feature) {658    this._disabled.push(feature);659  },660  661  setHeader: function(name, value) {662    this._headers[name] = value;663  },664  665  getClientId: function() {666    return this._clientId;667  },668  getState: function() {669    switch (this._state) {670      case this.UNCONNECTED:  return 'UNCONNECTED';671      case this.CONNECTING:   return 'CONNECTING';672      case this.CONNECTED:    return 'CONNECTED';673      case this.DISCONNECTED: return 'DISCONNECTED';674    }675  },676  // Request677  // MUST include:  * channel678  //                * version679  //                * supportedConnectionTypes680  // MAY include:   * minimumVersion681  //                * ext682  //                * id683  // 684  // Success Response                             Failed Response685  // MUST include:  * channel                     MUST include:  * channel686  //                * version                                    * successful687  //                * supportedConnectionTypes                   * error688  //                * clientId                    MAY include:   * supportedConnectionTypes689  //                * successful                                 * advice690  // MAY include:   * minimumVersion                             * version691  //                * advice                                     * minimumVersion692  //                * ext                                        * ext693  //                * id                                         * id694  //                * authSuccessful695  handshake: function(callback, context) {696    if (this._advice.reconnect === this.NONE) return;697    if (this._state !== this.UNCONNECTED) return;698    699    this._state = this.CONNECTING;700    var self = this;701    702    this.info('Initiating handshake with ?', this.endpoint);703    704    this._send({705      channel:      Faye.Channel.HANDSHAKE,706      version:      Faye.BAYEUX_VERSION,707      supportedConnectionTypes: [this._transport.connectionType]708      709    }, function(response) {710      711      if (response.successful) {712        this._state     = this.CONNECTED;713        this._clientId  = response.clientId;714        715        var connectionTypes = Faye.filter(response.supportedConnectionTypes, function(connType) {716          return Faye.indexOf(this._disabled, connType) < 0;717        }, this);718        this._selectTransport(connectionTypes);719        720        this.info('Handshake successful: ?', this._clientId);721        722        this.subscribe(this._channels.getKeys(), true);723        if (callback) callback.call(context);724        725      } else {726        this.info('Handshake unsuccessful');727        Faye.ENV.setTimeout(function() { self.handshake(callback, context) }, this._advice.interval);728        this._state = this.UNCONNECTED;729      }730    }, this);731  },732  733  // Request                              Response734  // MUST include:  * channel             MUST include:  * channel735  //                * clientId                           * successful736  //                * connectionType                     * clientId737  // MAY include:   * ext                 MAY include:   * error738  //                * id                                 * advice739  //                                                     * ext740  //                                                     * id741  //                                                     * timestamp742  connect: function(callback, context) {743    if (this._advice.reconnect === this.NONE) return;744    if (this._state === this.DISCONNECTED) return;745    746    if (this._state === this.UNCONNECTED)747      return this.handshake(function() { this.connect(callback, context) }, this);748    749    this.callback(callback, context);750    if (this._state !== this.CONNECTED) return;751    752    this.info('Calling deferred actions for ?', this._clientId);753    this.setDeferredStatus('succeeded');754    this.setDeferredStatus('deferred');755    756    if (this._connectRequest) return;757    this._connectRequest = true;758    759    this.info('Initiating connection for ?', this._clientId);760    761    this._send({762      channel:        Faye.Channel.CONNECT,763      clientId:       this._clientId,764      connectionType: this._transport.connectionType765      766    }, this._cycleConnection, this);767  },768  769  // Request                              Response770  // MUST include:  * channel             MUST include:  * channel771  //                * clientId                           * successful772  // MAY include:   * ext                                * clientId773  //                * id                  MAY include:   * error774  //                                                     * ext775  //                                                     * id776  disconnect: function() {777    if (this._state !== this.CONNECTED) return;778    this._state = this.DISCONNECTED;779    780    this.info('Disconnecting ?', this._clientId);781    782    this._send({783      channel:    Faye.Channel.DISCONNECT,784      clientId:   this._clientId785      786    }, function(response) {787      if (response.successful) this._transport.close();788    }, this);789    790    this.info('Clearing channel listeners for ?', this._clientId);791    this._channels = new Faye.Channel.Set();792  },793  794  // Request                              Response795  // MUST include:  * channel             MUST include:  * channel796  //                * clientId                           * successful797  //                * subscription                       * clientId798  // MAY include:   * ext                                * subscription799  //                * id                  MAY include:   * error800  //                                                     * advice801  //                                                     * ext802  //                                                     * id803  //                                                     * timestamp804  subscribe: function(channel, callback, context) {805    if (channel instanceof Array) {806      for (var i = 0, n = channel.length; i < n; i++) {807        this.subscribe(channel[i], callback, context);808      }809      return;810    }811    812    var subscription = new Faye.Subscription(this, channel, callback, context),813        force        = (callback === true),814        hasSubscribe = this._channels.hasSubscription(channel);815    816    if (!force) {817      this._channels.subscribe([channel], callback, context);818      if (hasSubscribe) {819        subscription.setDeferredStatus('succeeded');820        return subscription;821      }822    }823    824    this.connect(function() {825      this.info('Client ? attempting to subscribe to ?', this._clientId, channel);826      827      this._send({828        channel:      Faye.Channel.SUBSCRIBE,829        clientId:     this._clientId,830        subscription: channel831        832      }, function(response) {833        if (!response.successful) {834          subscription.setDeferredStatus('failed', Faye.Error.parse(response.error));835          return this._channels.unsubscribe(channel, callback, context);836        }837        838        var channels = [].concat(response.subscription);839        this.info('Subscription acknowledged for ? to ?', this._clientId, channels);840        subscription.setDeferredStatus('succeeded');841      }, this);842    }, this);843    844    return subscription;845  },846  847  // Request                              Response848  // MUST include:  * channel             MUST include:  * channel849  //                * clientId                           * successful850  //                * subscription                       * clientId851  // MAY include:   * ext                                * subscription852  //                * id                  MAY include:   * error853  //                                                     * advice854  //                                                     * ext855  //                                                     * id856  //                                                     * timestamp857  unsubscribe: function(channel, callback, context) {858    if (channel instanceof Array) {859      for (var i = 0, n = channel.length; i < n; i++) {860        this.unsubscribe(channel[i], callback, context);861      }862      return;863    }864    865    var dead = this._channels.unsubscribe(channel, callback, context);866    if (!dead) return;867    868    this.connect(function() {869      this.info('Client ? attempting to unsubscribe from ?', this._clientId, channel);870      871      this._send({872        channel:      Faye.Channel.UNSUBSCRIBE,873        clientId:     this._clientId,874        subscription: channel875        876      }, function(response) {877        if (!response.successful) return;878        879        var channels = [].concat(response.subscription);880        this.info('Unsubscription acknowledged for ? from ?', this._clientId, channels);881      }, this);882    }, this);883  },884  885  // Request                              Response886  // MUST include:  * channel             MUST include:  * channel887  //                * data                               * successful888  // MAY include:   * clientId            MAY include:   * id889  //                * id                                 * error890  //                * ext                                * ext891  publish: function(channel, data) {892    var publication = new Faye.Publication();893    894    this.connect(function() {895      this.info('Client ? queueing published message to ?: ?', this._clientId, channel, data);896      897      this._send({898        channel:      channel,899        data:         data,900        clientId:     this._clientId901      }, function(response) {902        if (response.successful)903          publication.setDeferredStatus('succeeded');904        else905          publication.setDeferredStatus('failed', Faye.Error.parse(response.error));906      }, this);907    }, this);908    909    return publication;910  },911  912  receiveMessage: function(message) {913    this.pipeThroughExtensions('incoming', message, function(message) {914      if (!message) return;915      916      if (message.advice) this._handleAdvice(message.advice);917      918      var callback = this._responseCallbacks[message.id];919      if (callback) {920        delete this._responseCallbacks[message.id];921        callback[0].call(callback[1], message);922      }923      924      this._deliverMessage(message);925    }, this);926  },927  928  _selectTransport: function(transportTypes) {929    Faye.Transport.get(this, transportTypes, function(transport) {930      this._transport = transport;931      this._transport.cookies = this._cookies;932      this._transport.headers = this._headers;933      934      transport.bind('down', function() {935        if (this._transportUp !== undefined && !this._transportUp) return;936        this._transportUp = false;937        this.trigger('transport:down');938      }, this);939      940      transport.bind('up', function() {941        if (this._transportUp !== undefined && this._transportUp) return;942        this._transportUp = true;943        this.trigger('transport:up');944      }, this);945    }, this);946  },947  948  _send: function(message, callback, context) {949    message.id = this._generateMessageId();950    if (callback) this._responseCallbacks[message.id] = [callback, context];951    this.pipeThroughExtensions('outgoing', message, function(message) {952      if (!message) return;953      this._transport.send(message, this._advice.timeout / 1000);954    }, this);955  },956  957  _generateMessageId: function() {958    this._messageId += 1;959    if (this._messageId >= Math.pow(2,32)) this._messageId = 0;960    return this._messageId.toString(36);961  },962  _handleAdvice: function(advice) {963    Faye.extend(this._advice, advice);964    965    if (this._advice.reconnect === this.HANDSHAKE && this._state !== this.DISCONNECTED) {966      this._state    = this.UNCONNECTED;967      this._clientId = null;968      this._cycleConnection();969    }970  },971  972  _deliverMessage: function(message) {973    if (!message.channel || message.data === undefined) return;974    this.info('Client ? calling listeners for ? with ?', this._clientId, message.channel, message.data);975    this._channels.distributeMessage(message);976  },977  978  _teardownConnection: function() {979    if (!this._connectRequest) return;980    this._connectRequest = null;981    this.info('Closed connection for ?', this._clientId);982  },983  984  _cycleConnection: function() {985    this._teardownConnection();986    var self = this;987    Faye.ENV.setTimeout(function() { self.connect() }, this._advice.interval);988  }989});990Faye.extend(Faye.Client.prototype, Faye.Deferrable);991Faye.extend(Faye.Client.prototype, Faye.Publisher);992Faye.extend(Faye.Client.prototype, Faye.Logging);993Faye.extend(Faye.Client.prototype, Faye.Extensible);994Faye.Transport = Faye.extend(Faye.Class({995  MAX_DELAY: 0.0,996  batching:  true,997  initialize: function(client, endpoint) {998    this.debug('Created new ? transport for ?', this.connectionType, endpoint);999    this._client   = client;1000    this._endpoint = endpoint;1001    this._outbox   = [];1002  },1003  1004  close: function() {},1005  1006  send: function(message, timeout) {1007    this.debug('Client ? sending message to ?: ?',1008               this._client._clientId, this._endpoint, message);1009    if (!this.batching) return this.request([message], timeout);1010    this._outbox.push(message);1011    this._timeout = timeout;1012    if (message.channel === Faye.Channel.HANDSHAKE)1013      return this.flush();1014    if (message.channel === Faye.Channel.CONNECT)1015      this._connectMessage = message;1016    this.addTimeout('publish', this.MAX_DELAY, this.flush, this);1017  },1018  flush: function() {1019    this.removeTimeout('publish');1020    if (this._outbox.length > 1 && this._connectMessage)1021      this._connectMessage.advice = {timeout: 0};1022    this.request(this._outbox, this._timeout);1023    1024    this._connectMessage = null;1025    this._outbox = [];1026  },1027  1028  receive: function(responses) {1029    this.debug('Client ? received from ?: ?',1030               this._client._clientId, this._endpoint, responses);1031    1032    for (var i = 0, n = responses.length; i < n; i++) {1033      this._client.receiveMessage(responses[i]);1034    }1035  },1036  1037  retry: function(message, timeout) {1038    var called = false,1039        retry  = this._client.retry * 1000,1040        self   = this;1041    1042    return function() {1043      if (called) return;1044      called = true;1045      Faye.ENV.setTimeout(function() { self.request(message, timeout) }, retry);1046    };1047  }1048  1049}), {1050  get: function(client, connectionTypes, callback, context) {1051    var endpoint = client.endpoint;1052    if (connectionTypes === undefined) connectionTypes = this.supportedConnectionTypes();1053    1054    Faye.asyncEach(this._transports, function(pair, resume) {1055      var connType = pair[0], klass = pair[1];1056      if (Faye.indexOf(connectionTypes, connType) < 0) return resume();1057      1058      klass.isUsable(endpoint, function(isUsable) {1059        if (isUsable) callback.call(context, new klass(client, endpoint));1060        else resume();1061      });1062    }, function() {1063      throw new Error('Could not find a usable connection type for ' + endpoint);1064    });1065  },1066  1067  register: function(type, klass) {1068    this._transports.push([type, klass]);1069    klass.prototype.connectionType = type;1070  },1071  1072  _transports: [],1073  1074  supportedConnectionTypes: function() {1075    return Faye.map(this._transports, function(pair) { return pair[0] });1076  }1077});1078Faye.extend(Faye.Transport.prototype, Faye.Logging);1079Faye.extend(Faye.Transport.prototype, Faye.Publisher);1080Faye.extend(Faye.Transport.prototype, Faye.Timeouts);1081Faye.Set = Faye.Class({1082  initialize: function() {1083    this._index = {};1084  },1085  1086  add: function(item) {1087    var key = (item.id !== undefined) ? item.id : item;1088    if (this._index.hasOwnProperty(key)) return false;1089    this._index[key] = item;1090    return true;1091  },1092  1093  forEach: function(block, context) {1094    for (var key in this._index) {1095      if (this._index.hasOwnProperty(key))1096        block.call(context, this._index[key]);1097    }1098  },1099  1100  isEmpty: function() {1101    for (var key in this._index) {1102      if (this._index.hasOwnProperty(key)) return false;1103    }1104    return true;1105  },1106  1107  member: function(item) {1108    for (var key in this._index) {1109      if (this._index[key] === item) return true;1110    }1111    return false;1112  },1113  1114  remove: function(item) {1115    var key = (item.id !== undefined) ? item.id : item;1116    var removed = this._index.hasOwnProperty(key);1117    delete this._index[key];1118    return removed;1119  },1120  1121  toArray: function() {1122    var array = [];1123    this.forEach(function(item) { array.push(item) });1124    return array;1125  }1126});1127Faye.Engine = {1128  get: function(options) {1129    return new Faye.Engine.Proxy(options);1130  },1131  1132  METHODS: ['createClient', 'clientExists', 'destroyClient', 'ping', 'subscribe', 'unsubscribe']1133};1134Faye.Engine.Proxy = Faye.Class({1135  MAX_DELAY:  0.0,1136  INTERVAL:   0.0,1137  TIMEOUT:    60.0,1138  1139  className: 'Engine',1140  1141  initialize: function(options) {1142    this._options     = options || {};1143    this._connections = {};1144    this.interval     = this._options.interval || this.INTERVAL;1145    this.timeout      = this._options.timeout  || this.TIMEOUT;1146    1147    var engineClass = this._options.type || Faye.Engine.Memory;1148    this._engine    = engineClass.create(this, this._options);1149    1150    this.debug('Created new engine: ?', this._options);1151  },1152  1153  connect: function(clientId, options, callback, context) {1154    this.debug('Accepting connection from ?', clientId);1155    this._engine.ping(clientId);1156    var conn = this.connection(clientId, true);1157    conn.connect(options, callback, context);1158    this._engine.emptyQueue(clientId);1159  },1160  1161  hasConnection: function(clientId) {1162    return this._connections.hasOwnProperty(clientId);1163  },1164  1165  connection: function(clientId, create) {1166    var conn = this._connections[clientId];1167    if (conn || !create) return conn;1168    return this._connections[clientId] = new Faye.Engine.Connection(this, clientId);1169  },1170  1171  closeConnection: function(clientId) {1172    this.debug('Closing connection for ?', clientId);1173    delete this._connections[clientId];1174  },1175  1176  openSocket: function(clientId, socket) {1177    var conn = this.connection(clientId, true);1178    conn.socket = socket;1179  },1180  1181  deliver: function(clientId, messages) {1182    if (!messages || messages.length === 0) return false;1183    1184    var conn = this.connection(clientId, false);1185    if (!conn) return false;1186    1187    for (var i = 0, n = messages.length; i < n; i++) {1188      conn.deliver(messages[i]);1189    }1190    return true;1191  },1192  1193  generateId: function() {1194    return Faye.random();1195  },1196  1197  flush: function(clientId) {1198    this.debug('Flushing connection queue for ?', clientId);1199    var conn = this.connection(clientId, false);1200    if (conn) conn.flush(true);1201  },1202  1203  disconnect: function() {1204    if (this._engine.disconnect) return this._engine.disconnect();1205  },1206  1207  publish: function(message) {1208    var channels = Faye.Channel.expand(message.channel);1209    return this._engine.publish(message, channels);1210  }1211});1212Faye.Engine.METHODS.forEach(function(method) {1213  Faye.Engine.Proxy.prototype[method] = function() {1214    return this._engine[method].apply(this._engine, arguments);1215  };1216})1217Faye.extend(Faye.Engine.Proxy.prototype, Faye.Publisher);1218Faye.extend(Faye.Engine.Proxy.prototype, Faye.Logging);1219Faye.Engine.Connection = Faye.Class({1220  initialize: function(engine, id, options) {1221    this._engine  = engine;1222    this._id      = id;1223    this._options = options;1224    this._inbox   = [];1225  },1226  1227  deliver: function(message) {1228    if (this.socket) return this.socket.send(JSON.stringify([message]));1229    this._inbox.push(message);1230    this._beginDeliveryTimeout();1231  },1232  1233  connect: function(options, callback, context) {1234    options = options || {};1235    var timeout = (options.timeout !== undefined) ? options.timeout / 1000 : this._engine.timeout;1236    1237    this.setDeferredStatus('deferred');1238    this.callback(callback, context);1239    1240    this._beginDeliveryTimeout();1241    this._beginConnectionTimeout(timeout);1242  },1243  1244  flush: function(force) {1245    this._releaseConnection(force);1246    this.setDeferredStatus('succeeded', this._inbox);1247    this._inbox = [];1248  },1249  1250  _releaseConnection: function(force) {1251    if (force || !this.socket) this._engine.closeConnection(this._id);1252    this.removeTimeout('connection');1253    this.removeTimeout('delivery');1254  },1255  1256  _beginDeliveryTimeout: function() {1257    if (this._inbox.length === 0) return;1258    this.addTimeout('delivery', this._engine.MAX_DELAY, this.flush, this);1259  },1260  1261  _beginConnectionTimeout: function(timeout) {1262    this.addTimeout('connection', timeout, this.flush, this);1263  }1264});1265Faye.extend(Faye.Engine.Connection.prototype, Faye.Deferrable);1266Faye.extend(Faye.Engine.Connection.prototype, Faye.Timeouts);1267Faye.Engine.Memory = function(server, options) {1268  this._server    = server;1269  this._options   = options || {};1270  this._namespace = new Faye.Namespace();1271  this._clients   = {};1272  this._channels  = {};1273  this._messages  = {};1274};1275Faye.Engine.Memory.create = function(server, options) {1276  return new this(server, options);1277};1278Faye.Engine.Memory.prototype = {1279  createClient: function(callback, context) {1280    var clientId = this._namespace.generate();1281    this._server.debug('Created new client ?', clientId);1282    this.ping(clientId);1283    this._server.trigger('handshake', clientId);1284    callback.call(context, clientId);1285  },1286  1287  destroyClient: function(clientId, callback, context) {1288    if (!this._namespace.exists(clientId)) return;1289    var clients = this._clients;1290    1291    if (clients[clientId])1292      clients[clientId].forEach(function(channel) { this.unsubscribe(clientId, channel) }, this);1293    1294    this.removeTimeout(clientId);1295    this._namespace.release(clientId);1296    delete this._messages[clientId];1297    this._server.debug('Destroyed client ?', clientId);1298    this._server.trigger('disconnect', clientId);1299    if (callback) callback.call(context);1300  },1301  1302  clientExists: function(clientId, callback, context) {1303    callback.call(context, this._namespace.exists(clientId));1304  },1305  1306  ping: function(clientId) {1307    var timeout = this._server.timeout;1308    if (typeof timeout !== 'number') return;1309    1310    this._server.debug('Ping ?, ?', clientId, timeout);1311    this.removeTimeout(clientId);1312    this.addTimeout(clientId, 2 * timeout, function() {1313      this.destroyClient(clientId);1314    }, this);1315  },1316  1317  subscribe: function(clientId, channel, callback, context) {1318    var clients = this._clients, channels = this._channels;1319    1320    clients[clientId] = clients[clientId] || new Faye.Set();1321    var trigger = clients[clientId].add(channel);1322    1323    channels[channel] = channels[channel] || new Faye.Set();1324    channels[channel].add(clientId);1325    1326    this._server.debug('Subscribed client ? to channel ?', clientId, channel);1327    if (trigger) this._server.trigger('subscribe', clientId, channel);1328    if (callback) callback.call(context, true);1329  },1330  1331  unsubscribe: function(clientId, channel, callback, context) {1332    var clients  = this._clients,1333        channels = this._channels,1334        trigger  = false;1335    1336    if (clients[clientId]) {1337      trigger = clients[clientId].remove(channel);1338      if (clients[clientId].isEmpty()) delete clients[clientId];1339    }1340    1341    if (channels[channel]) {1342      channels[channel].remove(clientId);1343      if (channels[channel].isEmpty()) delete channels[channel];1344    }1345    1346    this._server.debug('Unsubscribed client ? from channel ?', clientId, channel);1347    if (trigger) this._server.trigger('unsubscribe', clientId, channel);1348    if (callback) callback.call(context, true);1349  },1350  1351  publish: function(message, channels) {1352    this._server.debug('Publishing message ?', message);1353    var messages = this._messages,1354        clients  = new Faye.Set(),1355        subs;1356    1357    for (var i = 0, n = channels.length; i < n; i++) {1358      subs = this._channels[channels[i]];1359      if (!subs) continue;1360      subs.forEach(clients.add, clients);1361    }1362    1363    clients.forEach(function(clientId) {1364      this._server.debug('Queueing for client ?: ?', clientId, message);1365      messages[clientId] = messages[clientId] || [];1366      messages[clientId].push(Faye.copyObject(message));1367      this.emptyQueue(clientId);1368    }, this);1369    1370    this._server.trigger('publish', message.clientId, message.channel, message.data);1371  },1372  1373  emptyQueue: function(clientId) {1374    if (!this._server.hasConnection(clientId)) return;1375    this._server.deliver(clientId, this._messages[clientId]);1376    delete this._messages[clientId];1377  }1378};1379Faye.extend(Faye.Engine.Memory.prototype, Faye.Timeouts);1380Faye.Server = Faye.Class({1381  initialize: function(options) {1382    this._options  = options || {};1383    var engineOpts = this._options.engine || {};1384    engineOpts.timeout = this._options.timeout;1385    this._engine   = Faye.Engine.get(engineOpts);1386    this.info('Created new server: ?', this._options);1387  },1388  1389  flushConnection: function(messages) {1390    var clientId = [].concat(messages)[0].clientId;1391    if (!clientId) return;1392    this.info('Flushing connection for ?', clientId);1393    this._engine.flush(clientId);1394  },1395  1396  openSocket: function(clientId, socket) {1397    this._engine.openSocket(clientId, socket);1398  },1399  1400  closeSocket: function(clientId) {1401    this._engine.flush(clientId);1402  },1403  1404  process: function(messages, local, callback, context) {1405    messages = [].concat(messages);1406    this.info('Processing messages: ? (local: ?)', messages, local);1407    if (messages.length === 0) return callback.call(context, []);1408    var processed = 0, responses = [], self = this;1409    1410    var gatherReplies = function(replies) {1411      responses = responses.concat(replies);1412      processed += 1;1413      if (processed < messages.length) return;1414      1415      var n = responses.length;1416      while (n--) {1417        if (!responses[n]) responses.splice(n,1);1418      }1419      self.info('Returning replies: ?', responses);1420      callback.call(context, responses);1421    };1422    1423    var handleReply = function(replies) {1424      var extended = 0, expected = replies.length;1425      if (expected === 0) gatherReplies(replies);1426      1427      for (var i = 0, n = replies.length; i < n; i++) {1428        this.debug('Processing reply: ?', replies[i]);1429        this.pipeThroughExtensions('outgoing', replies[i], function(message) {1430          replies[i] = message;1431          extended  += 1;1432          if (extended === expected) gatherReplies(replies);1433        });1434      }1435    };1436    1437    for (var i = 0, n = messages.length; i < n; i++) {1438      this.pipeThroughExtensions('incoming', messages[i], function(pipedMessage) {1439        this._handle(pipedMessage, local, handleReply, this);1440      }, this);1441    }1442  },1443  1444  _makeResponse: function(message) {1445    var response = {};1446    1447    if (message.id)       response.id       = message.id;1448    if (message.clientId) response.clientId = message.clientId;1449    if (message.channel)  response.channel  = message.channel;1450    if (message.error)    response.error    = message.error;1451    1452    response.successful = !response.error;1453    return response;1454  },1455  1456  _handle: function(message, local, callback, context) {1457    if (!message) return callback.call(context, []);1458    this.info('Handling message: ? (local: ?)', message, local);1459    1460    var channelName = message.channel,1461        error       = message.error,1462        response;1463    1464    if (Faye.Channel.isMeta(channelName))1465      return this._handleMeta(message, local, callback, context);1466    1467    if (!Faye.Grammar.CHANNEL_NAME.test(channelName))1468      error = Faye.Error.channelInvalid(channelName);1469    1470    if (!error) this._engine.publish(message);1471    1472    response = this._makeResponse(message);1473    if (error) response.error = error;1474    response.successful = !response.error;1475    callback.call(context, [response]);1476  },1477  1478  _handleMeta: function(message, local, callback, context) {1479    var method   = Faye.Channel.parse(message.channel)[1],1480        clientId = message.clientId;1481    1482    this[method](message, local, function(responses) {1483      responses = [].concat(responses);1484      for (var i = 0, n = responses.length; i < n; i++) this._advize(responses[i], message.connectionType);1485      callback.call(context, responses);1486    }, this);1487  },1488  1489  _advize: function(response, connectionType) {1490    if (Faye.indexOf([Faye.Channel.HANDSHAKE, Faye.Channel.CONNECT], response.channel) < 0)1491      return;1492    1493    var interval, timeout;1494    if (connectionType === 'eventsource') {1495      interval = Math.floor(this._engine.timeout * 1000);1496      timeout  = 0;1497    } else {1498      interval = Math.floor(this._engine.interval * 1000);1499      timeout  = Math.floor(this._engine.timeout * 1000);1500    }1501    1502    response.advice = response.advice || {};1503    if (response.error) {1504      Faye.extend(response.advice, {reconnect:  'handshake'}, false);1505    } else {1506      Faye.extend(response.advice, {1507        reconnect:  'retry',1508        interval:   interval,1509        timeout:    timeout1510      }, false);1511    }1512  },1513  1514  // MUST contain  * version1515  //               * supportedConnectionTypes1516  // MAY contain   * minimumVersion1517  //               * ext1518  //               * id1519  handshake: function(message, local, callback, context) {1520    var response = this._makeResponse(message);1521    response.version = Faye.BAYEUX_VERSION;1522    1523    if (!message.version)1524      response.error = Faye.Error.parameterMissing('version');1525    1526    var clientConns = message.supportedConnectionTypes,1527        commonConns;1528    1529    response.supportedConnectionTypes = Faye.CONNECTION_TYPES;1530    1531    if (clientConns) {1532      commonConns = Faye.filter(clientConns, function(conn) {1533        return Faye.indexOf(Faye.CONNECTION_TYPES, conn) >= 0;1534      });1535      if (commonConns.length === 0)1536        response.error = Faye.Error.conntypeMismatch(clientConns);1537    } else {1538      response.error = Faye.Error.parameterMissing('supportedConnectionTypes');1539    }1540    1541    response.successful = !response.error;1542    if (!response.successful) return callback.call(context, response);1543    1544    this._engine.createClient(function(clientId) {1545      response.clientId = clientId;1546      callback.call(context, response);1547    }, this);1548  },1549  1550  // MUST contain  * clientId1551  //               * connectionType1552  // MAY contain   * ext1553  //               * id1554  connect: function(message, local, callback, context) {1555    var response       = this._makeResponse(message),1556        clientId       = message.clientId,1557        connectionType = message.connectionType;1558    1559    this._engine.clientExists(clientId, function(exists) {1560      if (!exists)         response.error = Faye.Error.clientUnknown(clientId);1561      if (!clientId)       response.error = Faye.Error.parameterMissing('clientId');1562      1563      if (Faye.indexOf(Faye.CONNECTION_TYPES, connectionType) < 0)1564        response.error = Faye.Error.conntypeMismatch(connectionType);1565      1566      if (!connectionType) response.error = Faye.Error.parameterMissing('connectionType');1567      1568      response.successful = !response.error;1569      1570      if (!response.successful) {1571        delete response.clientId;1572        return callback.call(context, response);1573      }1574      1575      if (message.connectionType === 'eventsource') {1576        message.advice = message.advice || {};1577        message.advice.timeout = 0;1578      }1579      this._engine.connect(response.clientId, message.advice, function(events) {1580        callback.call(context, [response].concat(events));1581      });1582    }, this);1583  },1584  1585  // MUST contain  * clientId1586  // MAY contain   * ext1587  //               * id1588  disconnect: function(message, local, callback, context) {1589    var response = this._makeResponse(message),1590        clientId = message.clientId;1591    1592    this._engine.clientExists(clientId, function(exists) {1593      if (!exists)   response.error = Faye.Error.clientUnknown(clientId);1594      if (!clientId) response.error = Faye.Error.parameterMissing('clientId');1595      1596      response.successful = !response.error;1597      if (!response.successful) delete response.clientId;1598      1599      if (response.successful) this._engine.destroyClient(clientId);1600      callback.call(context, response);1601    }, this);1602  },1603  1604  // MUST contain  * clientId1605  //               * subscription1606  // MAY contain   * ext1607  //               * id1608  subscribe: function(message, local, callback, context) {1609    var response     = this._makeResponse(message),1610        clientId     = message.clientId,1611        subscription = message.subscription,1612        channel;1613    1614    subscription = subscription ? [].concat(subscription) : [];1615    1616    this._engine.clientExists(clientId, function(exists) {1617      if (!exists)               response.error = Faye.Error.clientUnknown(clientId);1618      if (!clientId)             response.error = Faye.Error.parameterMissing('clientId');1619      if (!message.subscription) response.error = Faye.Error.parameterMissing('subscription');1620      1621      response.subscription = message.subscription || [];1622      1623      for (var i = 0, n = subscription.length; i < n; i++) {1624        channel = subscription[i];1625        1626        if (response.error) return;1627        if (!local && !Faye.Channel.isSubscribable(channel)) response.error = Faye.Error.channelForbidden(channel);1628        if (!Faye.Channel.isValid(channel))                  response.error = Faye.Error.channelInvalid(channel);1629        1630        if (response.error) return;1631        this._engine.subscribe(clientId, channel);1632      }1633      1634      response.successful = !response.error;1635      callback.call(context, response);1636    }, this);1637  },1638  1639  // MUST contain  * clientId1640  //               * subscription1641  // MAY contain   * ext1642  //               * id1643  unsubscribe: function(message, local, callback, context) {1644    var response     = this._makeResponse(message),1645        clientId     = message.clientId,1646        subscription = message.subscription,1647        channel;1648    1649    subscription = subscription ? [].concat(subscription) : [];1650    1651    this._engine.clientExists(clientId, function(exists) {1652      if (!exists)               response.error = Faye.Error.clientUnknown(clientId);1653      if (!clientId)             response.error = Faye.Error.parameterMissing('clientId');1654      if (!message.subscription) response.error = Faye.Error.parameterMissing('subscription');1655      1656      response.subscription = message.subscription || [];1657      1658      for (var i = 0, n = subscription.length; i < n; i++) {1659        channel = subscription[i];1660        1661        if (response.error) return;1662        if (!local && !Faye.Channel.isSubscribable(channel)) response.error = Faye.Error.channelForbidden(channel);1663        if (!Faye.Channel.isValid(channel))                  response.error = Faye.Error.channelInvalid(channel);1664        1665        if (response.error) return;1666        this._engine.unsubscribe(clientId, channel);1667      }1668      1669      response.successful = !response.error;1670      callback.call(context, response);1671    }, this);1672  }1673});1674Faye.extend(Faye.Server.prototype, Faye.Logging);1675Faye.extend(Faye.Server.prototype, Faye.Extensible);1676Faye.Transport.NodeLocal = Faye.extend(Faye.Class(Faye.Transport, {1677  batching: false,1678  1679  request: function(message, timeout) {1680    message = Faye.copyObject(message);1681    this._endpoint.process(message, true, function(responses) {1682      this.receive(Faye.copyObject(responses));1683    }, this);1684  }1685}), {1686  isUsable: function(endpoint, callback, context) {1687    callback.call(context, endpoint instanceof Faye.Server);1688  }1689});1690Faye.Transport.register('in-process', Faye.Transport.NodeLocal);1691Faye.Transport.WebSocket = Faye.extend(Faye.Class(Faye.Transport, {1692  UNCONNECTED:  1,1693  CONNECTING:   2,1694  CONNECTED:    3,1695  batching:     false,1696  1697  request: function(messages, timeout) {1698    this._messages = this._messages || {};1699    for (var i = 0, n = messages.length; i < n; i++) {1700      this._messages[messages[i].id] = messages[i];1701    }1702    this.withSocket(function(socket) { socket.send(Faye.toJSON(messages)) });1703  },1704  1705  withSocket: function(callback, context) {1706    this.callback(callback, context);1707    this.connect();1708  },1709  1710  close: function() {1711    if (this._closed) return;1712    this._closed = true;1713    if (this._socket) this._socket.close();1714  },1715  1716  connect: function() {1717    if (this._closed) return;1718    1719    this._state = this._state || this.UNCONNECTED;1720    if (this._state !== this.UNCONNECTED) return;1721    1722    this._state = this.CONNECTING;1723    1724    var ws = Faye.Transport.WebSocket.getClass();1725    this._socket = new ws(Faye.Transport.WebSocket.getSocketUrl(this._endpoint));1726    var self = this;1727    1728    this._socket.onopen = function() {1729      self._state = self.CONNECTED;1730      self.setDeferredStatus('succeeded', self._socket);1731      self.trigger('up');1732    };1733    1734    this._socket.onmessage = function(event) {1735      var messages = [].concat(JSON.parse(event.data));1736      for (var i = 0, n = messages.length; i < n; i++) {1737        delete self._messages[messages[i].id];1738      }1739      self.receive(messages);1740    };1741    1742    this._socket.onclose = function() {1743      var wasConnected = (self._state === self.CONNECTED);1744      self.setDeferredStatus('deferred');1745      self._state = self.UNCONNECTED;1746      delete self._socket;1747      1748      if (wasConnected) return self.resend();1749      1750      var retry = self._client.retry * 1000;1751      Faye.ENV.setTimeout(function() { self.connect() }, retry);1752      self.trigger('down');1753    };1754  },1755  1756  resend: function() {1757    var messages = Faye.map(this._messages, function(id, msg) { return msg });1758    this.request(messages);1759  }1760}), {1761  WEBSOCKET_TIMEOUT: 1000,1762  1763  getSocketUrl: function(endpoint) {1764    if (Faye.URI) endpoint = Faye.URI.parse(endpoint).toURL();1765    return endpoint.replace(/^http(s?):/ig, 'ws$1:');1766  },1767  1768  getClass: function() {1769    return (Faye.WebSocket && Faye.WebSocket.Client) ||1770            Faye.ENV.WebSocket ||1771            Faye.ENV.MozWebSocket;1772  },1773  1774  isUsable: function(endpoint, callback, context) {1775    var ws = this.getClass();1776    if (!ws) return callback.call(context, false);1777    1778    var connected = false,1779        called    = false,1780        socketUrl = this.getSocketUrl(endpoint),1781        socket    = new ws(socketUrl);1782    1783    socket.onopen = function() {1784      connected = true;1785      socket.close();1786      callback.call(context, true);1787      called = true;1788      socket = null;1789    };1790    1791    var notconnected = function() {1792      if (!called && !connected) callback.call(context, false);1793      called = true;1794    };1795    1796    socket.onclose = socket.onerror = notconnected;1797    Faye.ENV.setTimeout(notconnected, this.WEBSOCKET_TIMEOUT);1798  }1799});1800Faye.extend(Faye.Transport.WebSocket.prototype, Faye.Deferrable);1801Faye.Transport.register('websocket', Faye.Transport.WebSocket);1802Faye.Transport.NodeHttp = Faye.extend(Faye.Class(Faye.Transport, {1803  request: function(message, timeout) {1804    var uri      = url.parse(this._endpoint),1805        secure   = (uri.protocol === 'https:'),1806        client   = secure ? https : http,1807        content  = new Buffer(JSON.stringify(message), 'utf8'),1808        retry    = this.retry(message, timeout),1809        self     = this;1810    1811    var cookies = this.cookies.getCookies({domain: uri.hostname, path: uri.pathname}),1812        params  = this._buildParams(uri, content, cookies, secure),1813        request = client.request(params);1814    1815    request.addListener('response', function(response) {1816      self._handleResponse(response, retry);1817      self._storeCookies(uri.hostname, response.headers['set-cookie']);1818    });1819    1820    request.addListener('error', function() {1821      retry();1822      self.trigger('down');1823    });1824    request.write(content);1825    request.end();1826  },1827  1828  _buildParams: function(uri, content, cookies, secure) {1829    return {1830      method:   'POST',1831      host:     uri.hostname,1832      port:     uri.port || (secure ? 443 : 80),1833      path:     uri.pathname,1834      headers:  Faye.extend({1835        'Content-Length': content.length,1836        'Content-Type':   'application/json',1837        'Cookie':         cookies.toValueString(),1838        'Host':           uri.hostname1839      }, this.headers)1840    };1841  },1842  1843  _handleResponse: function(response, retry) {1844    var message = null,1845        body    = '',1846        self    = this;1847    1848    response.addListener('data', function(c) { body += c.toString('utf8', 0, c.length) });1849    response.addListener('end', function() {1850      try {1851        message = JSON.parse(body);1852      } catch (e) {}1853      1854      if (message) {1855        self.receive(message);1856        self.trigger('up');1857      } else {1858        retry();1859        self.trigger('down');1860      }1861    });1862  },1863  1864  _storeCookies: function(hostname, cookies) {1865    if (!cookies) return;1866    var cookie;1867    1868    for (var i = 0, n = cookies.length; i < n; i++) {1869      cookie = this.cookies.setCookie(cookies[i]);1870      cookie = cookie[0] || cookie;1871      cookie.domain = cookie.domain || hostname;1872    }1873  }1874  1875}), {1876  isUsable: function(endpoint, callback, context) {1877    callback.call(context, typeof endpoint === 'string');1878  }1879});1880Faye.Transport.register('long-polling', Faye.Transport.NodeHttp);1881var crypto = require('crypto'),1882    fs     = require('fs'),1883    http   = require('http'),1884    https  = require('https'),1885    net    = require('net'),1886    path   = require('path'),1887    tls    = require('tls'),1888    url    = require('url'),1889    querystring = require('querystring');1890Faye.WebSocket   = require('faye-websocket');1891Faye.EventSource = Faye.WebSocket.EventSource;1892Faye.CookieJar   = require('cookiejar').CookieJar;1893Faye.logger = function(message) {1894  console.log(message);1895};1896Faye.withDataFor = function(transport, callback, context) {1897  var data = '';1898  transport.addListener('data', function(chunk) { data += chunk });1899  transport.addListener('end', function() {1900    callback.call(context, data);1901  });1902};1903Faye.NodeAdapter = Faye.Class({1904  DEFAULT_ENDPOINT: '/bayeux',1905  SCRIPT_PATH:      path.dirname(__filename) + '/faye-browser-min.js',1906  1907  TYPE_JSON:    {'Content-Type': 'application/json'},1908  TYPE_SCRIPT:  {'Content-Type': 'text/javascript'},1909  TYPE_TEXT:    {'Content-Type': 'text/plain'},1910  1911  initialize: function(options) {1912    this._options    = options || {};1913    this._endpoint   = this._options.mount || this.DEFAULT_ENDPOINT;1914    this._endpointRe = new RegExp('^' + this._endpoint + '(/[^/]*)*(\\.js)?$');1915    this._server     = new Faye.Server(this._options);1916    1917    var extensions = this._options.extensions;1918    if (!extensions) return;1919    1920    extensions = [].concat(extensions);1921    for (var i = 0, n = extensions.length; i < n; i++)1922      this.addExtension(extensions[i]);1923  },1924  1925  addExtension: function(extension) {1926    return this._server.addExtension(extension);1927  },1928  1929  removeExtension: function(extension) {1930    return this._server.removeExtension(extension);1931  },1932  1933  bind: function() {1934    return this._server._engine.bind.apply(this._server._engine, arguments);1935  },1936  1937  unbind: function() {1938    return this._server._engine.unbind.apply(this._server._engine, arguments);1939  },1940  1941  getClient: function() {1942    return this._client = this._client || new Faye.Client(this._server);1943  },1944  1945  listen: function(port, sslOptions, callback, context) {1946    var ssl = sslOptions && sslOptions.cert1947            ? { key:  fs.readFileSync(sslOptions.key),1948                cert: fs.readFileSync(sslOptions.cert)1949              }1950            : null;1951    1952    if (ssl && sslOptions.ca)1953      ssl.ca = Faye.map(sslOptions.ca, function(ca) { return fs.readFileSync(ca) });1954    1955    var httpServer = ssl1956                   ? https.createServer(ssl, function() {})1957                   : http.createServer(function() {});1958    1959    this.attach(httpServer);1960    httpServer.listen(port, function() {1961      if (callback) callback.call(context);1962    });1963    this._httpServer = httpServer;1964  },1965  1966  stop: function(callback, context) {1967    this._httpServer.addListener('close', function() {1968      if (callback) callback.call(context);1969    });1970    this._httpServer.close();1971  },1972  1973  attach: function(httpServer) {1974    this._overrideListeners(httpServer, 'request', 'handle');1975    this._overrideListeners(httpServer, 'upgrade', 'handleUpgrade');1976  },1977  1978  _overrideListeners: function(httpServer, event, method) {1979    var listeners = httpServer.listeners(event),1980        self      = this;1981    1982    httpServer.removeAllListeners(event);1983    1984    httpServer.addListener(event, function(request) {1985      if (self.check(request)) return self[method].apply(self, arguments);1986      1987      for (var i = 0, n = listeners.length; i < n; i++)1988        listeners[i].apply(this, arguments);1989    });1990  },1991  1992  check: function(request) {1993    var path = url.parse(request.url, true).pathname;1994    return !!this._endpointRe.test(path);1995  },1996  1997  handle: function(request, response) {1998    var requestUrl    = url.parse(request.url, true),1999        requestMethod = request.method,2000        self          = this;2001    2002    if (/\.js$/.test(requestUrl.pathname))2003      return this._serveClientScript(request, response);2004    2005    if (requestMethod === 'OPTIONS')2006      return this._handleOptions(request, response);2007    2008    if (Faye.EventSource.isEventSource(request))2009      return this.handleEventSource(request, response);2010    2011    if (requestMethod === 'GET')2012      return this._callWithParams(request, response, requestUrl.query);2013    2014    if (requestMethod === 'POST')2015      return Faye.withDataFor(request, function(data) {2016        var type   = (request.headers['content-type'] || '').split(';')[0],2017            params = (type === 'application/json')2018                   ? {message: data}2019                   : querystring.parse(data);2020        2021        self._callWithParams(request, response, params);2022      });2023    2024    this._returnError(response);2025  },2026  2027  handleUpgrade: function(request, socket, head) {2028    var ws       = new Faye.WebSocket(request, socket, head, null, {ping: this._options.ping}),2029        clientId = null,2030        self     = this;2031    2032    ws.onmessage = function(event) {2033      try {2034        var message = JSON.parse(event.data);2035        clientId = [].concat(message)[0].clientId;2036        2037        self.debug('Received via WebSocket[' + ws.version + ']: ?', message);2038        self._server.openSocket(clientId, ws);2039        2040        self._server.process(message, false, function(replies) {2041          if (ws) ws.send(JSON.stringify(replies));2042        });2043      } catch (e) {2044        self.error(e.message + '\nBacktrace:\n' + e.stack);2045      }2046    };2047    2048    ws.onclose = function(event) {2049      self._server.closeSocket(clientId);2050      ws = null;2051    };2052  },2053  2054  handleEventSource: function(request, response) {2055    var es       = new Faye.EventSource(request, response, {ping: this._options.ping}),2056        clientId = es.url.split('/').pop(),2057        self     = this;2058    2059    this.debug('Opened EventSource connection for ?', clientId);2060    this._server.openSocket(clientId, es);2061    2062    es.onclose = function(event) {2063      self._server.closeSocket(clientId);2064      es = null;2065    };2066  },2067  2068  _serveClientScript: function(request, response) {2069    this._clientScript = this._clientScript || fs.readFileSync(this.SCRIPT_PATH);2070    this._clientDigest = this._clientDigest || crypto.createHash('sha1').update(this._clientScript).digest('hex');2071    this._clientMtime  = this._clientMtime  || fs.statSync(this.SCRIPT_PATH).mtime;2072    2073    var headers = Faye.extend({}, this.TYPE_SCRIPT),2074        ims     = request.headers['if-modified-since'];2075    2076    headers['ETag'] = this._clientDigest;2077    headers['Last-Modified'] = this._clientMtime.toGMTString();2078    2079    if (request.headers['if-none-match'] === this._clientDigest) {2080      response.writeHead(304, headers);2081      response.end();2082    } else if (ims && this._clientMtime <= new Date(ims)) {2083      response.writeHead(304, headers);2084      response.end();2085    } else {2086      response.writeHead(200, headers);2087      response.write(this._clientScript);2088      response.end();2089    }2090  },2091  2092  _callWithParams: function(request, response, params) {2093    try {2094      var message = JSON.parse(params.message),2095          jsonp   = params.jsonp || Faye.JSONP_CALLBACK,2096          isGet   = (request.method === 'GET'),2097          type    = isGet ? this.TYPE_SCRIPT : this.TYPE_JSON;2098      this.debug('Received ?: ?', request.method, message);2099      if (isGet) this._server.flushConnection(message);2100      2101      this._server.process(message, false, function(replies) {2102        var body    = JSON.stringify(replies),2103            headers = Faye.extend({}, type),2104            origin  = request.headers.origin;2105        2106        if (isGet) {2107          body = jsonp + '(' + body + ');';2108          headers['Cache-Control'] = 'no-cache, no-store';2109        }2110        if (origin) headers['Access-Control-Allow-Origin'] = origin;2111        2112        this.debug('Returning ?', body);2113        response.writeHead(200, headers);2114        response.write(body);2115        response.end();2116      }, this);2117    } catch (e) {2118      this.error(e.message + '\nBacktrace:\n' + e.stack);2119      this._returnError(response);2120    }2121  },2122  2123  _handleOptions: function(request, response) {2124    var headers = {2125      'Access-Control-Allow-Origin':      '*',2126      'Access-Control-Allow-Credentials': 'false',2127      'Access-Control-Max-Age':           '86400',2128      'Access-Control-Allow-Methods':     'POST, GET, PUT, DELETE, OPTIONS',2129      'Access-Control-Allow-Headers':     'Accept, Content-Type, X-Requested-With'2130    };2131    response.writeHead(200, headers);2132    response.write('');2133    response.end();2134  },2135  2136  _returnError: function(response) {2137    response.writeHead(400, this.TYPE_TEXT);2138    response.write('Bad request');2139    response.end();2140  }2141});2142Faye.extend(Faye.NodeAdapter.prototype, Faye.Logging);...