twitter_agent.js

var twit = require('twit');
var config = require('./config.js');
var fs = require('fs');
var express     = require('express');
var app         = express();

var Twitter = new twit(config);

var tweetArray = new Object();

function saveTweets(data, queryString) {
  if(data){
    // fs.writeFile("./tweets.json", data, function(err) {
    //     if(err) {
    //         return console.log(err);
    //     }
        tweetArray[queryString] = {'content': data, 'lastQueryTime': Date.now()};
        console.log("Tweets saved!");
    // });
  }
}

function search(queryCount=25, queryString) {
  return new Promise(function(resolve, reject) {


  var lastQueryTime = tweetArray[queryString] ? tweetArray[queryString]['lastQueryTime'] : 0;
  var timeElapsed = Date.now() - lastQueryTime;
  console.log('Time Elapsed: ' + timeElapsed);
  if(timeElapsed < 5000){
    resolve(tweetArray[queryString]['content']);
  }

  var params = {
    q: queryString + ' -filter:retweets -filter:replies',
    //result_type: 'recent',
    count: queryCount,
    tweet_mode: 'extended',
    lang: 'en'
  }

  Twitter.get('search/tweets', params, function(err, data) {
      // if there no errors
        if (!err) {
          //console.log(data);
          saveTweets(data, queryString);
          resolve(data);
        }
        // if unable to Search a tweet
        else {
          console.log('Something went wrong while SEARCHING...');
        }
    });
  });
}

// search();
//setInterval(search, 5000);

app.get('/', (req, res) => res.status(200).send(
  {message: 'This is not the API you\'re looking for'}
));

app.get('/androidsummit/twitter', function(req, res) {

  var token = req.headers['x-api-key'];
  var queryString = req.query.queryString || 'androidsummit';

  // validate token
  if (token === config.api_token) {
    var count = 25;
    if(req.query.count){
      count = req.query.count;
    }

    search(count, queryString).then(function(data) {
      res.status(200).json(tweetArray[queryString]['content']);
    });

  } else {
    // if there is no token
    // return an error
    return res.status(403).send({
        success: false,
        message: 'Are you sure you\'re in the right spot?'
    });
  }

});


app.listen(config.port, function() {
  console.log('Twitter agent listening on port ' + config.port);
});