awesome-auth-client/js/auth-socket.js

var AuthSocket, HuntingWebSocket, config, getSocketType, guid, json, storage,
  __bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; };

json = require('./util').json;

storage = window.localStorage;

guid = require('./guid');

config = require('./config');

HuntingWebSocket = require('./hunting-websocket');

getSocketType = function(urls) {
  var protocol;
  protocol = /(\w+)/.exec(urls[0])[1];
  if (protocol.indexOf('http') === 0) {
    console.log("Using http!");
    return 'http';
  }
  console.log("Using websocket!");
  return 'ws';
};

AuthSocket = (function() {
  function AuthSocket(opts) {
    this.authenticateSocket = __bind(this.authenticateSocket, this);
    this.send = __bind(this.send, this);
    this.destinationUrls = opts.urls;
    this.authSocket = new HuntingWebSocket(opts.authServers || config.authServers);
    this.socketType = getSocketType(opts.urls);
    this.events = {};
    this.appMapping = opts.appName;
    this.callbacks = {};
    this.authSocket.onclose = (function(_this) {
      return function(evt) {
        return _this.onclose(evt);
      };
    })(this);
    this.authSocket.onreconnect = (function(_this) {
      return function(evt) {
        return _this.authenticateSocket();
      };
    })(this);
    this.authSocket.onopen = (function(_this) {
      return function(evt) {
        _this.authenticateSocket();
        return _this.onopen(evt);
      };
    })(this);
    this.authSocket.onerror = (function(_this) {
      return function(err) {
        console.log("Error connecting to auth server");
        return _this.onerror(err);
      };
    })(this);
    this.authSocket.onmessage = (function(_this) {
      return function(message) {
        var msg;
        try {
          msg = JSON.parse(message.data);
          if ((msg != null ? msg.destinationError : void 0) && _this.events.error) {
            console.log("Error connecting to destination socket");
            return _this.events.error(msg.destinationError);
          } else {
            if (msg.httpCorrelationId && _this.callbacks[msg.httpCorrelationId]) {
              _this.callbacks[msg.httpCorrelationId](msg.message || msg);
              return delete _this.callbacks[msg.httpCorrelationId];
            } else {
              return _this.onmessage(message);
            }
          }
        } catch (_error) {
          return _this.onmessage(message);
        }
      };
    })(this);
  }

  AuthSocket.prototype.send = function(message) {
    var request;
    request = {
      destinationUrls: this.destinationUrls,
      appMapping: this.appMapping
    };
    if (message.callback) {
      request.httpCorrelationId = guid();
      this.callbacks[request.httpCorrelationId] = message.callback;
    }
    request[this.socketType] = message;
    return this.authSocket.send(json(request));
  };

  AuthSocket.prototype.close = function() {
    return this.authSocket.close();
  };

  AuthSocket.prototype.authenticateSocket = function() {
    var request, _ref;
    request = {
      checkAuth: {
        appMapping: this.appMapping,
        token: (_ref = JSON.parse(storage.getItem("aa-token-" + this.appMapping))) != null ? _ref.token : void 0,
        destinationUrls: this.destinationUrls,
        openSocket: this.socketType === "ws"
      }
    };
    return this.authSocket.send(json(request));
  };

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

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

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

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

  return AuthSocket;

})();

module.exports = AuthSocket;