Added emailing

Author: Justin Terry

lib/api/controllers/alertsController.js

@@ -3,6 +3,7 @@ var DynamoDB = require("../../database/DynamoDB");
 var CognitoErrors = require('../../auth/CognitoErrors')
 var DynamoDBErrors = require('../../database/DynamoDBErrors')
 var Texter = require('../../communications/texter');
+var Emailer = require('../../communications/emailer');
 
 var response = {
     error: null,
@@ -20,6 +21,7 @@ exports.createAlert = function(req, res) {
             }
             res.status(200).send(response);
             Texter.sendMessage(req.body);
+            Emailer.sendEmail(req.body);
         }).catch(err => {
             // Error was generated, update response and send.
             response.error = true;

lib/communications/emailer.js

@@ -0,0 +1,74 @@
+// Load the AWS SDK for Node.js
+var AWS = require('aws-sdk');
+var DynamoDB = require('../database/DynamoDB');
+// Set the region 
+AWS.config.update({region: 'us-east-1'});
+var baseURL = 'https://master.d34e7o1nxh5a7i.amplifyapp.com/?query=';
+
+// Create sendEmail params 
+var params = {
+  Destination: { /* required */
+    ToAddresses: []
+  },
+  Message: { /* required */
+    Body: { /* required */
+      Html: {
+       Charset: "UTF-8",
+       Data: ""
+      },
+      Text: {
+       Charset: "UTF-8",
+       Data: "TEXT_FORMAT_BODY"
+      }
+     },
+     Subject: {
+      Charset: 'UTF-8',
+      Data: 'SafeHopper ALERT!'
+     }
+    },
+  Source: '[email protected]', /* required */
+  ReplyToAddresses: [
+     '[email protected]',
+    /* more items */
+  ],
+};
+
+exports.sendEmail = function(req) {
+    getContacts(req);
+}
+
+function sendMessage(contacts, alertId, name) {
+    if(contacts != null){
+        var text = "SafeHopper Alert!\n" + name + 
+                                    " is requesting your help.\n\n Follow this link to see their current loction:\n" + 
+                                    baseURL + alertId;
+        params.Message.Body.Html.Data = text;
+        for(var i = 0; i < contacts.length; i++){
+            params.Destination.ToAddresses[i] = contacts[i].email;
+        }
+
+        // Create the promise and SES service object
+        var sendPromise = new AWS.SES({apiVersion: '2010-12-01'}).sendEmail(params).promise();
+
+        // Handle promise's fulfilled/rejected states
+        sendPromise.then(
+        function(data) {
+            console.log(data.MessageId);
+        }).catch(
+            function(err) {
+            console.error(err, err.stack);
+        });
+    }
+}
+
+function getContacts(req) {
+    var body = {
+        userEmail: req.email,
+    }
+    DynamoDB.getContacts(body).then(result => {
+        sendMessage(result, req.alertId, req.name);
+    }).catch(err => {
+        // Error was generated
+        console.log("ERROR: can't get contacts");
+    })
+}

lib/communications/texter.js

@@ -1,8 +1,8 @@
 var twilio = require('twilio');
 var DynamoDB = require('../database/DynamoDB');
 
-var accountSid = process.env.ACCOUNT_SID; // Your Account SID from www.twilio.com/console
-var authToken = process.env.AUTH_TOKEN;   // Your Auth Token from www.twilio.com/console
+var accountSid = process.env.ACCOUNT_SID;
+var authToken = process.env.AUTH_TOKEN;
 var baseURL = 'https://master.d34e7o1nxh5a7i.amplifyapp.com/?query=';
 
 var twilio = require('twilio');
@@ -34,7 +34,7 @@ function getContacts(req) {
     DynamoDB.getContacts(body).then(result => {
         sendText(result, req.alertId, req.name);
     }).catch(err => {
-        // Error was generated, update response and send.
+        // Error was generated
         console.log("ERROR: can't get contacts");
     })
 }