Related to issue #2 - AWS setup (SNS) + dotenv config updates + SNS integration

.env

@@ -0,0 +1,3 @@
+AWS_REGION=
+AWS_ACCOUNT=
+SNS_TOPIC=

.eslintrc

@@ -1,13 +1,10 @@
 {
     "parser": "babel-eslint",
-    "plugins": [
-      ""
-    ],
     "extends": [
-      "plugin:react/recommended"
+      "airbnb"
     ],
     "env": {
-      "browser": true,
+      "node": true,
       "jest": true
     },
     "rules": {
@@ -56,4 +53,4 @@
       }]
     }
   }
-
+

.gitignore

@@ -56,9 +56,6 @@ typings/
 # Yarn Integrity file
 .yarn-integrity
 
-# dotenv environment variables file
-.env
-
 # next.js build output
 .next
 
@@ -88,3 +85,5 @@ typings/
 SOURCES/
 SPECS/
 *.service
+
+.vscode

bake-scripts/20-cosmos-config

@@ -0,0 +1,43 @@
+#! /usr/bin/env python
+
+import json
+import pipes
+import sys
+import pwd
+import grp
+import os
+
+NAME = "digital-paper-edit-api"
+UID = pwd.getpwnam(NAME).pw_uid
+GID = grp.getgrnam(NAME).gr_gid
+
+
+def write_env(content, path):
+    f = open(path, "w")
+    for key, value in content.items():
+        f.write("%s=%s\n" % (key, pipes.quote(value)))
+    f.close()
+
+
+def merge_two_dicts(x, y):
+    z = x.copy()
+    z.update(y)
+    return z
+
+
+def main(argv):
+    out_dir = os.path.join("/usr/lib/", NAME)
+    path = os.path.join(out_dir, ".env.override")
+
+    raw = json.load(open(argv[1], "r"))
+    configs = merge_two_dicts(
+        raw["configuration"],
+        raw["secure_configuration"]
+    )
+    write_env(configs, path)
+    os.chown(path, UID, GID)
+    return 0
+
+
+if __name__ == "__main__":
+    sys.exit(main(sys.argv))

config/index.js

@@ -0,0 +1,13 @@
+const dotenv = require('dotenv');
+const fs = require('fs');
+
+const result = dotenv.config();
+
+if (result.error) {
+  throw result.error;
+}
+const envConfig = dotenv.parse(fs.readFileSync('.env.override'));
+
+envConfig.forEach((k) => {
+  process.env[k] = envConfig[k];
+});

index.js

@@ -2,20 +2,23 @@
 const express = require('express');
 const bodyParser = require('body-parser');
 const url = require('url');
+
 const app = express();
 const router = express.Router();
 
+require('./config');
+
 // https://stackoverflow.com/questions/24543847/req-body-empty-on-posts
 // https://github.com/expressjs/body-parser#limit
 // > Controls the maximum request body size. If this is a number, then the value specifies the number of bytes; if it is a string, the value is passed to the bytes library for parsing. Defaults to '100kb'.
 app.use(bodyParser.json( { limit: '50MB' } ));
 
 app.use(bodyParser.urlencoded({
-  extended: true
+  extended: true,
 }));
 const port = process.env.PORT || 8080;
 
-app.use(function (req, res, next) {
+app.use((req, res, next) => {
   res.header('Access-Control-Allow-Origin', '*');
   res.header('Access-Control-Allow-Methods', 'GET, PUT, POST, DELETE, OPTIONS');
   res.header('Access-Control-Allow-Headers', 'Origin, X-Requested-With, Content-Type, Accept, Authorization');
@@ -26,15 +29,15 @@ app.use(function (req, res, next) {
 
 // list all available rotues
 app.get('/', (req, res) => {
-  const fullUrl = req.protocol + '://' + req.get('host') + req.originalUrl;
+  const fullUrl = `${ req.protocol }://${ req.get('host') }${ req.originalUrl }`;
   const results = [];
   // https://stackoverflow.com/questions/14934452/how-to-get-all-registered-routes-in-express/14934933
-  app._router.stack.forEach(function(r) {
+  app._router.stack.forEach((r) => {
     if (r.route && r.route.path) {
       results.push({
         path: r.route.path,
         url: url.resolve(fullUrl, r.route.path),
-        methods: r.route.methods
+        methods: r.route.methods,
       });
     }
   });
@@ -50,6 +53,10 @@ require('./routes/annotations.js')(app);
 // TODO: status should probably not always return ok?
 // eg if server is failing/crashed should return something else
 // so that the instance can be terminated? or is not necessary to do this explicitly?
-require('./routes/status.js')(app);
+
+const status = require('./routes/status');
+
+app.get('/status', status.healthCheck);
+app.get('/queue', status.sendMessage);
 
 app.listen(port, () => console.log(`App listening on port ${ port }!`));

lib/messageBroker.js

@@ -0,0 +1,33 @@
+const AWS = require('aws-sdk');
+
+const getTopicArn = () => [
+  'arn:aws:sns',
+  process.env.AWS_REGION,
+  process.env.AWS_ACCOUNT,
+  process.env.SNS_TOPIC,
+].join(':');
+
+const publish = (msg) => {
+  const sns = new AWS.SNS({
+    apiVersion: '2010-03-31',
+    region: process.env.AWS_REGION,
+  });
+
+  const params = {
+    Message: msg,
+    TopicArn: getTopicArn(),
+  };
+
+  const promisePublish = new Promise((resolve, reject) => {
+    sns.publish(params, (err, data) => {
+      if (err) {
+        reject(err);
+      }
+      resolve(data);
+    });
+  });
+
+  return promisePublish;
+};
+
+module.exports = { publish };