app.js

var express = require('express');
var bodyParser = require('body-parser');
var Twitter = require('twitter');
var twitterJT = new Twitter({
  consumer_key: process.env.TWITTER_CONSUMER_KEY,
  consumer_secret: process.env.TWITTER_CONSUMER_SECRET,
  access_token_key: process.env.TWITTER_ACCESS_TOKEN_KEY,
  access_token_secret: process.env.TWITTER_ACCESS_TOKEN_SECRET
});
var twitterGG = new Twitter({
  consumer_key: process.env.GG_TWITTER_CONSUMER_KEY,
  consumer_secret: process.env.GG_TWITTER_CONSUMER_SECRET,
  access_token_key: process.env.GG_TWITTER_ACCESS_TOKEN_KEY,
  access_token_secret: process.env.GG_TWITTER_ACCESS_TOKEN_SECRET
});
var twitterSW = new Twitter({
  consumer_key: process.env.SW_TWITTER_CONSUMER_KEY,
  consumer_secret: process.env.SW_TWITTER_CONSUMER_SECRET,
  access_token_key: process.env.SW_TWITTER_ACCESS_TOKEN_KEY,
  access_token_secret: process.env.SW_TWITTER_ACCESS_TOKEN_SECRET
});

var app = express();
var port = process.env.PORT || 3000;

app.use(bodyParser.urlencoded({ extended: true }));

function postToTwitter(twitter, command, text, user_name, token, cb) {
  if ( !process.env.SLACK_TOKEN || token != process.env.SLACK_TOKEN ) {
    throw new Error( 'Slack token is invalid' );
  }

  if (text == undefined || text == null || text == '') {
    var valid_commands = [];

    if ( !(process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/status_update/g)) )
      valid_commands.push( command + " a status update" );
    if ( !(process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/reply/g)) )
      valid_commands.push( command + "@user a reply to a tweet" + " | " + "https://twitter.com/SupportKit/status/650007346236760064" );
    if ( !(process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/retweet/g)) )
      valid_commands.push( command + " retweet" + " | " + "https://twitter.com/SupportKit/status/650007346236760064" );
    if ( !(process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/favorite/g)) )
      valid_commands.push( command + " favorite" + " | " + "https://twitter.com/SupportKit/status/650007346236760064" );

    throw new Error( valid_commands.join("\n") );
  }

  // only authorize certain slack users to tweet, if null, allow all slack users
  if ( process.env.ALLOWED_SLACK_USERS && 
      !process.env.ALLOWED_SLACK_USERS.match('\\b(' + user_name + ')\\b') ) {
    throw new Error('This slack user, ' + user_name + ', is not authorized to tweet.');
  }

  var tweet = text.split('|');
  var tweet_status = tweet.shift().trim().replace(/\/$/, ''); 
  var tweet_status_id = ( tweet_status_id = tweet.shift() ) ? tweet_status_id.trim().replace(/\/$/, '') : null;

  if ( !tweet_status ) {
    throw new Error('Nothing to tweet about.')
  }

  // retweet
  if (  tweet_status.match(/^retweet$/) ) {
    if ( process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/retweet/g) )
      throw new Error('favorites are disabled');

    if ( id = getStatusId(tweet_status_id) )  
      twitter.post('statuses/retweet', {id: id}, function(error, tweet, response) {
        cb(error, tweet, 'retweeted');
      });
    else
      throw new Error('Unable to retweet. Please specify a valid status id or url.');
  } 
  // favorite
  else if ( tweet_status.match(/^favo(u?)rite$/) ) {
    if ( process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/favo(u?)rite/g) )
      throw new Error('favorites are disabled');

    if ( id = getStatusId(tweet_status_id) )
      twitter.post('favorites/create', {id: id}, function(error, tweet, response) {
        cb(error, tweet, 'favorited');
      }); 
    else
      throw new Error('Unable to favorite. Please specify a valid status id or url.');
  } 
  // reply
  else if ( tweet_status_id && ( id = getStatusId( tweet_status_id ) ) ) {
    if ( process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/reply/g) )
      throw new Error('replies are disabled');

    if ( tweet_status[0] != '@' ) 
      throw new Error('Replies must being with @twitter_username');

    if ( id )
      twitter.post('statuses/update', {status: tweet_status, in_reply_to_status_id: id}, function(error, tweet, response) {
      cb(error, tweet, 'replied');
    });
    else
      throw new Error('Unable to reply. Please specify a valid status id or url.');
  } 
  // status update
  else {
    if ( process.env.DISABLED_FUNCTIONS && process.env.DISABLED_FUNCTIONS.match(/status_update/g) )
      throw new Error('status updates are disabled');

    twitter.post('statuses/update', {status: tweet_status + ' @the_greggiles @scottMTBer'}, function(error, tweet, response) {
        cb(error, tweet, 'status updated');
      });
  }

  function getStatusId(status) {
    if ( status.match(/^https?:\/\/twitter\.com\/(?:#!\/)?(\w+)\/status(es)?\/(\d+)$/) || status.match(/^[0-9]*$/) ) {
      return status.split('/').pop();
    }

    return null;
  }
}

app.post('/*', function(req, res, next) {
  var command = req.body.command,
      text = req.body.text,
      user_name = req.body.user_name,
      token = req.body.token;

  var resp = '';


  postToTwitter(twitterJT, command, text, user_name, token, function (error, tweet, action) {
    if (error) resp = "JTree :" + next(error[0]);
    else resp = "JTree " + action + ": " + tweet.text;
    if (user_name = 'greggiles') {
      postToTwitter(twitterGG, command, text, user_name, token, function (error, tweet, action) {
        if (error) resp = resp + "Greg: " + next(error[0]);
        else resp = resp + "Greg " + action + ": " + tweet.text;
        res.status(200).send(action + ": " + resp);
      });
    }
    else if (user_name = 'wally') {
      postToTwitter(twitterSW, command, text, user_name, token, function (error, tweet, action) {
        if (error) resp = resp + "Wally: " + next(error[0]);
        else resp = resp + "Wally " + action + ": " + tweet.text;
        //if (error) return next(error[0]);
        res.status(200).send(action + ": " + resp);
      });
    }
    else {
      //if (error) return next(error[0]);
      res.status(200).send(action + ": " + resp);
    }
  });
});
// test route
app.get('/', function (req, res) {
  var resp = 'Data from Twitter Tests<br>';
  var params = {count: 1};
  twitterJT.get('statuses/mentions_timeline.json', params, function(error, tweets, response){
    resp = resp + "<br> JTree <br> ";
    if (!error) {
      resp = resp + JSON.stringify(tweets) + "<br>";
    }
    else
    {
      resp = resp + JSON.stringify(error) + "<br>";
    }
    twitterGG.get('statuses/mentions_timeline.json', params, function(error, tweets, response){
      resp = resp + "<br> Greg <br> ";
      if (!error) {
        resp = resp + JSON.stringify(tweets) + "<br>";
      }
      else
      {
        resp = resp + JSON.stringify(error) + "<br>";
      }
    });
    twitterSW.get('statuses/mentions_timeline.json', params, function(error, tweets, response){
      resp = resp + "<br> Scott <br> ";
      if (!error) {
        resp = resp + JSON.stringify(tweets) + "<br>";
      }
      else
      {
        // res.write(next(error[0]));

        resp = resp + JSON.stringify(error) + "<br>";
      }
      res.status(200).send(resp);
    });
  });

  // res.status(200).send('Forked from SupportKit.IO! Slack to Twitter feed. rev2')
});

// error handler
app.use(function (err, req, res, next) {
  console.log(err.message);
  res.status(400).send(err.message);
});

app.listen(port, function () {
  console.log('Started Tweet from Slack ' + port);
});