sendQueued.js

var crypto = require('crypto');
var Knex = require('knex');
var twilio = require('twilio');
var client = twilio(process.env.TWILIO_ACCOUNT_SID, process.env.TWILIO_AUTH_TOKEN);
var db = require('./db.js');
var knex = Knex.initialize({
  client: 'pg',
  connection: process.env.DATABASE_URL
});
var moment = require('moment');


// Finds reminders for cases happening tomorrow
var findQueued = function() {
  return knex('queued')
    .where('sent', false)
    .select();
};

findQueued().exec(sendQueuedMessage);

function sendQueuedMessage(err, queued) {
  if (queued.length === 0) {
    console.log('No queued messages to send today.');
    process.exit();
  }

  var count = 0;
  queued.forEach(function(queuedCitation) {
    db.findCitation(queuedCitation.citation_id, function(err, results) {
      var decipher = crypto.createDecipher('aes256', process.env.PHONE_ENCRYPTION_KEY);
      var phone = decipher.update(queuedCitation.phone, 'hex', 'utf8') + decipher.final('utf8');

      if (results && results.length > 0) {
        var match = results[0];
        var name = cleanupName(match.defendant);
        var date = moment(match.date).format('dddd, MMM Do');
        var body = 'Your Atlanta Municipal Court information was found: a court case for ' + name + ' on ' + date + ' at ' + match.time +', in courtroom ' + match.room +'. Call us at (404) 954-7914 with any questions.';

        client.sendMessage({
          to: phone,
          from: process.env.TWILIO_PHONE_NUMBER,
          body: body,
        }, function(err, result) {
          if (err) return console.log(err);
          console.log('Queued message sent to ' + phone);
          count++;
          if (count === queued.length) process.exit();
        });

        knex('queued')
          .where('queued_id', '=', queuedCitation.queued_id)
          .update({'sent': true})
          .exec(function(err, results) {
            if (err) console.log(err);
          });
      } else {
        var daysSinceCreation = moment().diff(moment(queuedCitation.created_at), 'days');
        console.log('Queued message created ' + daysSinceCreation + ' days ago.');

        var ALLOWABLE_QUEUED_DAYS = 16;
        if (daysSinceCreation > ALLOWABLE_QUEUED_DAYS) {
          knex('queued')
            .where('queued_id', '=', queuedCitation.queued_id)
            .update({'sent': true})
            .exec(function(err, results) {
              if (err) console.log(err);
            });

          client.sendMessage({
            to: phone,
            from: process.env.TWILIO_PHONE_NUMBER,
            body: 'We haven\'t been able to find your court case. Please call us at (404) 954-7914. -Atlanta Municipal Court',
          }, function(err, result) {
            if (err) return console.log(err);
            count++;
            if (count === queued.length) process.exit();
          });
        }  else {
          count++;
          if (count === queued.length) setTimeout(function() { process.exit(); }, 5000);
        }
      }
    });
  });
}

var cleanupName = function(name) {
  // Switch LAST, FIRST to FIRST LAST
  var bits = name.split(',');
  name = bits[1] + ' ' + bits[0];
  name = name.trim();

  // Change FIRST LAST to First Last
  name = name.replace(/\w\S*/g, function(txt) { return txt.charAt(0).toUpperCase() + txt.substr(1).toLowerCase(); });

  return name;
};