slackbot-new.js

var async = require('async'),
    https = require('https'),
    querystring = require('querystring'),
    ws = require('ws');

function slackbot(token) { 
    this.token = token;
    this.handlers = [];
    this.messageID = 0;
    this.selfData = {};
    this.mention = "";
    return this;
}

slackbot.prototype.api = function(method, params, cb) {
  var options, post_data, req;

  params['token'] = this.token;
  post_data = querystring.stringify(params);

  options = {
    hostname: 'api.slack.com',
    method: 'POST',
    path: '/api/' + method,
    headers: {
      'Content-Type': 'application/x-www-form-urlencoded',
      'Content-Length': post_data.length
    }
  };

  req = https.request(options);

  req.on('response', function(res) {
    var buffer;
    buffer = '';
    res.on('data', function(chunk) {
      return buffer += chunk;
    });
    return res.on('end', function() {
      var value;
      if (cb != null) {
        if (res.statusCode === 200) {
          value = JSON.parse(buffer);
          return cb(value);
        } else {
          return cb({
            'ok': false,
            'error': 'API response: ' + res.statusCode
          });
        }
      }
    });
  });
  
  req.on('error', function(error) {
    if (cb != null) {
      return cb({
        'ok': false,
        'error': error.errno
      });
    }
  });
  
  req.write(post_data);
  return req.end();
};

slackbot.prototype.use = function(fn) {
    this.handlers.push(fn);
    return this;
};

slackbot.prototype.handle = function(data) {
    async.series(this.handlers.map(function(fn) {
        return function(cb) {
            fn(data, cb);
        };
    }));
    return this;
};

slackbot.prototype.sendMessage = function(channel, text) {
  var message = {
    id: ++this.messageID,
    type: 'message',
    channel: channel,
    text: text
  };
  return this.ws.send(JSON.stringify(message));
};

slackbot.prototype.connect = function() {
    var self = this;
    self.api('rtm.start', {agent: 'node-slack', simple_latest: true, no_unreads: true}, function(data) {
      self.selfData = data.self;
      self.mention = "<@" + self.selfData.id + ">";
      self.ws = new ws(data.url);
      self.ws.on('message', function(data, flags) {
        var message = JSON.parse(data);
        self.handle(message);
      });
    });    
};

module.exports = slackbot;