// Create Docker
// Run Docker
// Grab Twitter
// save to firebase
// send link
// shut it down

const TwitterCrawler = require('twitter-crawler');
const fs = require('fs');
const log = require('winston');
const Promise = require('bluebird');

const getEnvCredentials = () =>
  process.env.TWITTER_CREDENTIALS ? JSON.parse(process.env.TWITTER_CREDENTIALS) : [];

const credentials = [{
  consumer_key: '...',
  consumer_secret: '...',
  access_token_key: '...',
  access_token_secret: '...',
  enabled: true
}].concat(getEnvCredentials());


const bind = (object, method) => object[method].bind(object);

function saveOutput(obj, filename) {
  fs.writeFile(`${__dirname}/output/${filename}`, JSON.stringify(obj, null, '  '));
}

const crawler = new TwitterCrawler(credentials);
const crawlList = ["DataCamp"];

module.exports = Promise.all(crawlList.map((twitterHandle) => {
  // Get user
  log.info(`Obtaining user with id ${twitterHandle}...`);
  return crawler.getUser(twitterHandle)
    .then((user) => {
      log.info(
        `Obtained info for user ${user.name} (${user.id}). ` +
        `Storing in output/${twitterHandle}_user.json`
      );
      saveOutput(user, `${twitterHandle}_user.json`);
      // Crawl tweets
      log.info('Obtaining tweets...');
      return crawler.getTweets(twitterHandle, {})
        .then((tweets) => {
          log.info(
            `Obtained ${tweets.length} tweets for user ${user.name} (${user.id}). ` +
            `Storing in output/${twitterHandle}_tweets.json`
          );

          saveOutput(tweets, `${twitterHandle}_tweets.json`);
          log.info('Crawling finished.');
        });
    })
    .catch(bind(log, 'error'));
}));