sns stuff

package.json

@@ -31,6 +31,7 @@
   "dependencies": {
     "@google/maps": "^0.3.0",
     "auth0-lock": "^10.4.1",
+    "aws-sdk": "^2.6.11",
     "body-parser": "^1.15.2",
     "express": "~4.14.0",
     "font-awesome": "~4.6.3",

services/api.js

@@ -3,7 +3,7 @@ const agent = require('../src/agent')
 const moment = require('moment')
 const clients = require('./clients')
 const shelters = require('./shelters')
-const texting = require('./texting')
+const snsSubscribe = require('./snsSubscribe')
 
 const router = express.Router()
 
@@ -17,7 +17,7 @@ router.get('/now', (req, res, next) => {
   .catch(next)
 })
 
-router.get('/texting', texting)
+router.post('/subscribe', snsSubscribe)
 
 router.use('/clients', clients)
 

services/aws/getSNS.js

@@ -0,0 +1,3 @@
+const AWS = require('aws-sdk')
+
+module.exports = () => new AWS.SNS({region: 'us-east-1'})

services/texting.js → services/snsGetTopic.js

@@ -1,4 +1,3 @@
-const express = require('express')
 const mango = require('./mango')
 
 const shelterMango = (shelterId) => ({
@@ -13,8 +12,8 @@ const shelterMango = (shelterId) => ({
   fields: ['_id', 'sns-topic']
 })
 
-const getTopic = (req, res, next) =>
- mango('shelters', shelterMango(req.query.shelterId))
-  .then((shelters) => res.json(shelters))
+const getTopic = (shelterId) =>
+ mango('shelters', shelterMango(shelterId))
+  .then((shelters) => shelters[0]['sns-topic'])
 
 module.exports = getTopic

services/snsSend.js

@@ -0,0 +1,16 @@
+const snsGetTopic = require('./snsGetTopic')
+const getSNS = require('./aws/getSNS')
+
+const publishToTopic = (TopicArn, Endpoint) =>
+ getSNS().subscribe({
+   TopicArn,
+   Endpoint,
+   Protocol: 'sms'
+ }).promise()
+
+const send = (req, res, next) =>
+  snsGetTopic(req.query.shelterId)
+  .then((topic) => publishToTopic(topic))
+  .then((resp) => res.json(resp))
+
+module.exports = send

services/snsSubscribe.js

@@ -0,0 +1,16 @@
+const snsGetTopic = require('./snsGetTopic')
+const getSNS = require('./aws/getSNS')
+
+const subscribeToTopic = (TopicArn, Endpoint) =>
+ getSNS().subscribe({
+   TopicArn,
+   Endpoint,
+   Protocol: 'sms'
+ }).promise()
+
+const subscribe = (req, res, next) =>
+  snsGetTopic(req.query.shelterId)
+  .then((topic) => subscribeToTopic(topic, req.query.phone))
+  .then((resp) => res.json(resp))
+
+module.exports = subscribe