mailer.js

var outlook = require('node-outlook')
  , authHelper = require('./authHelper')
  , credentials = require('./credentials')
  , outlook_refresh = require('outlook-refresh')
  , moment = require('moment-timezone')
  , fs = require("fs")
  , savedRefresh = require('./token.json')
  , bot = require('./bot')

var savedToken, refreshToken, text, channel, username, emoji;

var alertCounter = 0;

// Use below for stage/prod
var momenttime = moment().tz("America/Los_Angeles").format();

// Use below for dev
// var momenttime = moment().tz("America/New_York").format();

// console.log('this is momenttime', momenttime);

var savedTime = momenttime;

// check what was saved
// console.log('this is the saved refresh token: ', savedRefresh);
// console.log('this is the local email: ', localEmail);
// var savedEmail = localEmail;

var refresh = function (){
  outlook_refresh(refreshToken, credentials.oauthcredID, credentials.oauthcredSecret, function (err, res){
    if (err){
      console.log('refresh error: ', err);
      outlook_refresh(savedRefresh, credentials.oauthcredID, credentials.oauthcredSecret, function (err, res){
        if (err){
          console.log('still not refreshing: ', err);
        } else {
          console.log('Calling for mailerRefresh1');
          mailerRefresh(res);
        }
      })
    } else {
      console.log('Calling for mailerRefresh2');
      mailerRefresh(res);
    }
  }); 
};

var mailerRefresh = function (res){
  savedToken = res.token;
  console.log('refresh triggered');
  refreshToken = res.refreshToken;
  console.log('this is the new refresh token');
  var newJSON = JSON.stringify(refreshToken);
  fs.writeFile('./token.json', newJSON, function (err){
    if(err){
        return handleError(err);
    } else {
      // console.log('your json has been saved');
      console.log(newJSON);
    }
  });
  setTimeout(refresh, 1800000); // 1000 = 1 sec, currently 30 mins
}

var tokenReceived = function (res, error, token){
  if (error){
    console.log("Access token error: ", error.message);
  }
  else {
    savedToken = token.token.access_token;
    // savedEmail = authHelper.getEmailFromIdToken(token.token.id_token);
    refreshToken = token.token.refresh_token;
    // console.log(token);
    // console.log('This is the token: '+savedToken);
    // console.log('This is the email: '+credentials.inbox);
    // console.log('This is the refresh token: '+refreshToken);
    // console.log("We've auth'ed!");

    var newJSON = JSON.stringify(refreshToken);
    fs.writeFile('./token.json', newJSON, function (err){
      if(err){
          return handleError(err);
      } else {
        // console.log('your json has been saved');
        // console.log(newJSON);
      }
    });

    // Use below for stage/prod
    // res.redirect(302, 'https://data.lohud.com/bots/trellobot/');
    res.redirect(302, 'https://trellobot.lohudblogs.com/');
    // Use below for dev
    // res.redirect(302, 'http://localhost:8080/');
    // res.end();
  }
};

var getValueFromCookie = function (valueName, cookie){
  if (cookie.indexOf(valueName) !== -1){
    var start = cookie.indexOf(valueName) + valueName.length + 1;
    var end = cookie.indexOf(';', start);
    end = end === -1 ? cookie.length : end;
    return cookie.substring(start, end);
  }
};

var checkMail = function (req, res){
  
  // Use below for stage/prod
  var date = moment().tz("America/Los_Angeles").format();

  channel = '#audience';
  username = 'OutlookBot';
  emoji = ':calculon:';

  // Use below for dev
  // var date = moment().tz("America/New_York").format();

  // console.log('Checking mail now');
  // console.log('Initial savedTime check: '+savedTime);
  // console.log('Initial date check: '+date);
  // console.log('Now we check for savedToken');
  // console.log(savedToken);

  // console.log('Now we check for savedEmail');
  // console.log(savedEmail);

  // t = new Date();

  if (savedToken == undefined){
    console.log(date, 'mailer.js broke!');
    alertCounter ++;
    if (alertCounter == 60){
      alertCounter = 0;
      text = 'Our outlook authentication is dead! Please re-login at `http://trellobot.lohudblogs.com` with our digital@gannett.com account!';
      bot.sendMessage(text, channel, username, emoji);
    };
    rePingMail();
  } else {
    var queryParams = {
      '$filter':"ReceivedDateTime ge "+savedTime+" and From/EmailAddress/Address eq 'noreply.ap@notification.ap.org'",
      // '$filter':"ReceivedDateTime ge "+savedTime,
      '$select': 'Subject,ReceivedDateTime,From',
      // '$orderby': 'ReceivedDateTime desc',
      '$top': 10,
      // '$search': '"from:noreply.ap@notification.ap.org"'
    };
    
    // console.log('this is the queryParams');
    // console.log(queryParams);

    // Set the API endpoint to use the v2.0 endpoint
    outlook.base.setApiEndpoint('https://outlook.office.com/api/v2.0');
    // Set the anchor mailbox to the user's SMTP address
    // Throwing errors for some reason
    outlook.base.setAnchorMailbox(credentials.inbox);

    outlook.mail.getMessages({token: savedToken, odataParams: queryParams},
      function (error, result){

        // console.log(result);

        if (error){
          console.log('getMessages returned an error: ' + error);
          rePingMail(result);
        } else if (result){
          rePingMail(result);
        }
      }
    );
  }
  // setTimeout(checkMail, 100000); // 10 secs
  // setTimeout(checkMail, 10000);
  // console.log(date, 'mail pinged');
  // console.log(date);
  // console.log(savedTime);
  savedTime = date;
};

var rePingMail = function (result){
  // console.log(result);

  channel = '#audience';
  username = 'Associated Press';
  emoji = ':Deathstar:';

  if (result == undefined){
    console.log('this is rePing saying mailerjs is broken');
  } else {
    var inbox = result['value'];
    // console.log(inbox);
    for (var x = 0; x < inbox.length; x++){
      text = "`AP NOTIFICATION:` *"+inbox[x]['Subject']+"*";
      bot.sendMessage(text, channel, username, emoji);
    }
  }
  var date = moment().tz("America/Los_Angeles").format();
  // console.log(date, 'mail pinged');
  setTimeout(checkMail, 30000);
};

module.exports = {
  tokenReceived: tokenReceived,
  getValueFromCookie: getValueFromCookie,
  checkMail: checkMail,
  refresh: refresh,
  rePingMail: rePingMail
}