awesome-auth-client/js/reconnecting-websocket.js

var RECONNECT_TIMEOUT, ReconnectingWebSocket,
  __bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; };

RECONNECT_TIMEOUT = 3 * 1000;

ReconnectingWebSocket = (function() {
  function ReconnectingWebSocket(url, reconnectTimeout) {
    this.url = url;
    this.connect = __bind(this.connect, this);
    this.forceclose = false;
    this.reconnectTimeout = reconnectTimeout || RECONNECT_TIMEOUT;
    this.readyState = WebSocket.CONNECTING;
    this.connectionCount = 0;
    this.connect();
  }

  ReconnectingWebSocket.prototype.connect = function() {
    this.ws = new WebSocket(this.url);
    this.ws.onopen = (function(_this) {
      return function(event) {
        _this.readyState = WebSocket.OPEN;
        if (_this.connectionCount++) {
          return _this.onreconnect(event);
        } else {
          return _this.onopen(event);
        }
      };
    })(this);
    this.ws.onclose = (function(_this) {
      return function(event) {
        if (_this.forceclose) {
          _this.readyState = WebSocket.CLOSED;
          return _this.onclose(event);
        } else {
          _this.readyState = WebSocket.CONNECTING;
          return setTimeout(_this.connect, _this.reconnectTimeout);
        }
      };
    })(this);
    this.ws.onmessage = (function(_this) {
      return function(event) {
        return _this.onmessage(event);
      };
    })(this);
    return this.ws.onerror = (function(_this) {
      return function(event) {
        return _this.onerror(event);
      };
    })(this);
  };

  ReconnectingWebSocket.prototype.send = function(data) {
    try {
      return this.ws.send(data);
    } catch (_error) {
      return this.connect();
    }
  };

  ReconnectingWebSocket.prototype.close = function() {
    this.forceclose = true;
    return this.ws.close();
  };

  ReconnectingWebSocket.prototype.onopen = function(event) {};

  ReconnectingWebSocket.prototype.onclose = function(event) {};

  ReconnectingWebSocket.prototype.onreconnect = function(event) {};

  ReconnectingWebSocket.prototype.onmessage = function(event) {};

  ReconnectingWebSocket.prototype.onerror = function(event) {};

  ReconnectingWebSocket.prototype.onsend = function(event) {};

  return ReconnectingWebSocket;

})();

module.exports = ReconnectingWebSocket;