filter.js

var Twitter = require('twit');
var redis = require('redis');
var twit = new Twitter({
    consumer_key: process.env.TWITTER_CONSUMER_KEY,
    consumer_secret: process.env.TWITTER_CONSUMER_SECRET,
    access_token: process.env.ACCESS_TOKEN,
    access_token_secret: process.env.ACCESS_TOKEN_SECRET
});

var express = require('express');
var app = express();

app.get('/', function(req, res){
  res.send('Express is currently running smooooooothly.');
});

var port = process.env.PORT || 3000;
app.listen(port);
console.log("Express is running on port " + port);


var url = require('url');
var redisURL = url.parse(process.env.REDISCLOUD_URL || 'redis://127.0.0.1:6379');
var client = redis.createClient(redisURL.port, redisURL.hostname, {no_ready_check: true});
if (process.env.REDISCLOUD_URL) {
    client.auth(redisURL.auth.split(":")[1]);
}

var REDIS_KEY = 'screenNameCooldown';

var tweetCount = 0;

var tweetStream = twit.stream('statuses/filter', { track: '@ShoutGamers, @ShoutRTs' });
tweetStream.on('tweet', function(tweet) {
  
  console.log('Possible mention: ' + tweet.user.screen_name);
  var tweep = tweet.user.screen_name;
  var rtCheck = tweet.text.indexOf('RT');
  var spamSelling = tweet.text.toLowerCase().indexOf('selling');
  var spamTrain = tweet.text.toLowerCase().indexOf('train');
  var spamPeriscope = tweet.text.toLowerCase().indexOf('periscope');
  var spamAccount = tweet.text.toLowerCase().indexOf('account');
  
  //whitelisted user
  if ((rtCheck > 0 || rtCheck == -1) && (tweet.in_reply_to_user_id == null) && (tweep == 'F_for_FeLoN' || tweep == 'ebookeroo' || tweep == 'ReaIDirty' || tweep == 'buttchinnychin' || tweep == 'FaKiee_US' || tweep == 'TWinGSo_')) {
    console.log(' - whitelisted user, retweeting now');
    retweetById(tweet.id_str, tweep);
  }
  
  //tweet count over TWEET_COUNT
  if ((rtCheck > 0 || rtCheck == -1) && (tweet.in_reply_to_user_id == null) && (spamTrain == -1) && (spamPeriscope == -1) && (spamAccount == -1)) {
    tweetCount +=1;
    
    if (tweetCount >= process.env.TWEET_COUNT) {
      tweetCount = 0;
      twit.get('friendships/show', {source_screen_name: process.env.USERNAME, target_screen_name: tweet.user.screen_name}, function(err, reply) {
        console.log(' - looking up user: ' + tweet.user.screen_name);
        err;
        
        if (reply.relationship.target.following == true){
          
          if (spamSelling == -1) {
            retweetById(tweet.id_str, tweet.user.screen_name);
          }
          
          else {
            console.log(' - selling checkup');
            var spamFortnite = tweet.text.toLowerCase().indexOf('fortnite');
            
            if (spamFortnite == -1) {
              retweetById(tweet.id_str, tweet.user.screen_name);
            }
            else {
              console.log(' - fortnite/method selling NOPE');
            }}}
        else if(reply.relationship.target.following == false)
          {console.log(' - nope. user does not follow');}
      });
    }
    else {
      console.log(' - tweetCount: ' + tweetCount);
    }
    
  }
  else {
    console.log(' - Retweet/reply/train');
  }
});

var retweetById = function(idStr, screenName) {
      client.sadd(REDIS_KEY, screenName, function(err, reply) {
        if (err) {
            console.log(err);
        } else if (reply == 1 || screenName == process.env.TWITTER_DEBUG_USER) {
            console.log(' - This is a new user OR it is the debug user');
                      
                twit.post('statuses/retweet/:id', {id: idStr}, function(err, reply) {
                console.log("1 retweeted id:" + idStr);
                err;
                });
                      
        }
        else {
          console.log(' - not retweeted');
        }
      });
};

setInterval(function() {
    client.del(REDIS_KEY);
    console.log("database 1 cleared");
}, (60 * 60* 1000 * process.env.COOLDOWN1)); //time in hours

var http = require("http");
setInterval(function() {
    http.get("http://shoutg2.herokuapp.com");
}, 600000);