francoREST.js

#!/usr/bin/env/node
console.log("Hey James Franco");

var env = require('node-env-file');
var Twit = require('twit');
var Q = require('q');
var Mailgun = require('mailgun').Mailgun;
var mgRecipients = require('./mailgun-recipients');

env(__dirname + '/.env');

// credentials stored in local, uncommitted .env file
var T = new Twit({
	consumer_key:         process.env.TWITTER_CONSUMER_KEY 
	, consumer_secret:      process.env.TWITTER_CONSUMER_SECRET
	, access_token:         process.env.TWITTER_ACCESS_TOKEN
	, access_token_secret:  process.env.TWITTER_ACCESS_TOKEN_SECRET
});

var mg = new Mailgun(process.env.MAILGUN_API_KEY);

// search twitter for (count) number of tweets to @jamesfrancotv. returns promise that fullfills with array of tweets
function getMentions(count) {
	return Q.Promise(function (resolve, reject) {
		T.get('search/tweets', { q: "@jamesfrancotv", count: count }, function(error, data, response) {
			if (error) reject(error);
			else resolve(data.statuses);
		});
	});
}

// retweets tweet with tweetID, asynchronously returns response via callback.
function reTweetID(tweetID) {
	return Q.Promise(function (fullfill, reject) {
		T.post('statuses/retweet/:id', { id: tweetID.toString() }, function(error, data, response) {
			if (error) reject(error.allErrors);
			else fullfill(data);
		});
	});	
}

function favoriteTweetID(tweetID) {
	return Q.Promise(function (fullfill, reject) {
		T.post('favorites/create', { id: tweetID.toString() }, function(error, data, response) {
			if (error) reject(error.message);
			else fullfill(data);
		});	
	});
}

// retweets (count) number of replies to @jamesfrancotv's tweets
function sayHeyToJames(count) {
	var favoriteCount = 0;
	var retweetCount = 0;
	var favoriteErrorCount = 0;
	var retweetErrorCount = 0;
	// get promise for tweet array of mentions
	getMentions(count)
	.then(function (tweets) {
		// create array of promises to favorite all the tweets
		var favorites = tweets.map(function(tweet) {
			return favoriteTweetID(tweet.id_str)
			.then(function (data) {
				// count the successful favorites
				favoriteCount ++;				
			})
			.catch(function (reject) {
				// count and error log the favorite failures
				favoriteErrorCount ++;
				console.error('favorite error: ' + reject);
			});
		});
		// create array of promises to retweet all the tweets
		var retweets = tweets.map(function(tweet) {
			return reTweetID(tweet.id_str)
			.then(function (data) {
				// count successful retweets
				retweetCount ++;			
			})
			.catch(function (reject) {
				// count and error log the retweet failures
				retweetErrorCount ++;
				console.error(Date() + 'retweet error:' + reject);
			});
		});
		// combine both promise arrays
		var both = favorites.concat(retweets);
		// return a promise for the whole fulfilled array that will wait for all promises to either fulfill or reject
		return Q.allSettled(both);
	})
	.then(function() {
		// log final results
		var results = '\n' + Date() 
			+ '\n retweeted: ' + retweetCount 
			+ '\n favorited: ' + favoriteCount 
			+ '\n retweet errors: ' + retweetErrorCount 
			+ '\n favorite errors: ' + favoriteErrorCount;

			// mailgun update to mgRecipients
		mg.sendText('heyjamesfranco@heyjamesfranco.com', //sender
			mgRecipients, //recipient(s)
			"franco update", //subject
			results, // text
			null,
			null,
			function(error) { //callback
				if (error) {
					console.error(Date() + 'mailgun error' + error);	
				}
			});
		
		console.log(results);
	});
}

if(require.main == module) {
	console.error(Date() + 'Invoked at command line.');
	var args = process.argv;
    // can take positive numerical argument to say hey to james that many times
    if (args.length != 3 || Number.isNaN(args[2]) || args[2] < 1) {
    	sayHeyToJames(1);  

    } else {
    	sayHeyToJames(args[2]);
    }
} else {
	console.error(Date() + 'Invoked via library call');
}

exports.sayHeyToJames = sayHeyToJames;