actionHeroWebSocket.js

(function(exports){

  var actionHeroWebSocket = function(options, callback){
    var self = this;
    if(callback == null && typeof options == "function"){
      callback = options; options = null;
    }

    self.messageCount = 0;
    self.callbacks = {};
    self.id = null;
    self.events = {};

    self.options = self.defaults();
    for(var i in options){
      self.options[i] = options[i];
    }

    if(options && options.faye != null){
      self.faye = options.faye;
    }else if(window.Faye != null){
      self.faye = window.Faye;
    }else{
      self.faye = Faye;
    }
  }

  actionHeroWebSocket.prototype.defaults = function(){
    var host;
    if(typeof window != 'undefined'){ host = window.location.origin; }
    return {
      host: host,
      path: "/faye",
      setupChannel: "/_welcome",
      channelPrefix: "/client/websocket/connection/",
      startupDelay: 500,
      apiPath: "/api"
    }
  }

  actionHeroWebSocket.prototype.log = function(message){
    if(console && console.log){
      if(typeof message != "string"){ message = JSON.stringify(message); }
      var date = new Date();
      var times = [date.getHours().toString(), date.getMinutes().toString(), date.getSeconds().toString()];
      for(var i in times){
        if(times[i].length < 2){ times[i] = "0" + times[i]; }
      }
      console.log("[AH::client @ " + times.join(":") + "] " + message);
    }
  }

  actionHeroWebSocket.prototype.connect = function(callback){
    var self = this;

    self.client = new self.faye.Client(self.options.host + self.options.path);
    
    var initialMessage = self.client.publish(self.options.setupChannel, 'hello');
    
    initialMessage.callback(function() {
      self.id = self.client.getClientId();
      self.channel = self.options.channelPrefix + self.id;
      self.subscription = self.client.subscribe(self.channel, function(message) {
        self.handleMessage(message);
      });

      setTimeout(function(){
        self.setIP(function(err, ip){
            self.detailsView(function(details){
              callback(null, details);
            });
        });
      }, self.options.startupDelay);
      
    });

    initialMessage.errback(function(error) {
      callback(error, null);
    })
  }

  actionHeroWebSocket.prototype.send = function(args, callback){
    var self = this;
    if(typeof callback === "function"){
      self.messageCount++;
      self.callbacks[self.messageCount] = callback;
    }
    self.client.publish(self.channel, args).errback(function(err){
      self.log(err);
    });
  };

  actionHeroWebSocket.prototype.handleMessage = function(message){
    var self = this;
    if(message.context === "response"){
      if(typeof self.callbacks[message.messageCount] === 'function'){
        self.callbacks[message.messageCount](message);
      }
      delete self.callbacks[message.messageCount];
    }

    else if(message.context === "user"){
      if(typeof self.events.say === 'function'){
        self.events.say(message);
      }
    }

    else{
      if(typeof self.events.alert === 'function'){
        self.events.alert(message);
      }
    }
  };

  actionHeroWebSocket.prototype.setIP = function(callback){
    var self = this;
    try{
      var xmlhttp = new XMLHttpRequest();
      xmlhttp.onreadystatechange=function(){
        if (xmlhttp.readyState==4 && xmlhttp.status==200){
          var response = JSON.parse(xmlhttp.responseText);
          var ip = response.requestorInformation.remoteAddress;
          self.send({ event: 'setIP', ip: ip }, function(){
            callback(null, ip);
          });
        }
      }
      xmlhttp.open("GET", self.options.host + self.options.apiPath, true);
      xmlhttp.send();
    }catch(e){
      // can't make the ajax call, assume it's localhost
      var ip = "127.0.0.1";
      self.send({ event: 'setIP', ip: ip }, function(){
        callback(null, ip);
      });
    }
  }

  actionHeroWebSocket.prototype.action = function(action, params, callback){
    if(callback == null && typeof params == 'function'){
      callback = params;
      params = null;
    }
    if(params == null){ params = {}; }
    params.action = action;
    this.send({
      event: 'action', 
      params: params,
    }, callback);
  }

  actionHeroWebSocket.prototype.say = function(message, callback){
    this.send({
      event: 'say', 
      message: message,
    }, callback);
  }

  actionHeroWebSocket.prototype.detailsView = function(callback){
    this.send({event: 'detailsView'}, callback);
  }

  actionHeroWebSocket.prototype.roomView = function(callback){
    this.send({event: 'roomView'}, callback);
  }

  actionHeroWebSocket.prototype.roomChange = function(room, callback){
    this.room = room;
    this.send({event: 'roomChange', room: room}, callback);
  }

  actionHeroWebSocket.prototype.listenToRoom = function(room, callback){
    this.send({event: 'listenToRoom', room: room}, callback);
  }

  actionHeroWebSocket.prototype.silenceRoom = function(room, callback){
    this.send({event: 'silenceRoom', room: room}, callback);
  }

  actionHeroWebSocket.prototype.disconnect = function(){
    this.client.disconnect();
  }

  exports.actionHeroWebSocket = actionHeroWebSocket;

})(typeof exports === 'undefined' ? window : exports);