first commit

Author: snozza

.gitignore

@@ -0,0 +1 @@
+.env

app.js

@@ -0,0 +1,68 @@
+require('dotenv').load({ silent: true });
+
+const express = require('express');
+const co = require('co');
+const bodyParser = require('body-parser');
+const Client = require('ssh2');
+const fs = require('fs');
+const path = require('path');
+const config = require('./config');
+const { notFound, errorMiddleware } = require('./errors');
+
+const app = new express();
+const FILENAME = 'tps.dat';
+const connSettings = {
+  host: config.sftpHost,
+  port: config.sftpPort,
+  username: config.sftpUsername,
+  password: config.sftpPassword
+};
+const numbers = {};
+
+app.use(bodyParser.json());
+
+app.post('/search', (req, res, next) => {
+  if (!Array.isArray(req.body)) {
+    return next({ message: 'Must provide array of numbers', status: 400 })
+  }
+  const results = req.body.map((num) => {
+    return {
+      number: num,
+      canCall: numbers[num.replace(/\s/g, '')] || false
+    };
+  });
+
+  res.json({ results });
+});
+
+app.use(notFound);
+app.use(errorMiddleware);
+
+const conn = new Client();
+conn.on('ready', () => {
+  const moveFrom = `./${FILENAME}`;
+  const moveTo = `/tmp/${FILENAME}`;
+
+  conn.sftp((err, sftp) => {
+    if (err) {
+      throw err;
+    }
+
+    sftp.fastGet(moveFrom, moveTo, {}, (downloadErr) => {
+      if (downloadErr) {
+        throw downloadErr;
+      }
+
+      // turn into map for constant lookup
+      // trim spaces from numbers
+      fs.readFileSync(`/tmp/${FILENAME}`).toString().split(/\r?\n/).forEach(num => {
+        numbers[num] = true;
+      });
+
+      app.listen(config.PORT, () => {
+        console.log(`App listening on ${config.PORT}`);
+      });
+
+    });
+  });
+}).connect(connSettings);

config.js

@@ -0,0 +1,7 @@
+const config = exports;
+
+config.PORT = process.env.PORT || 3000;
+config.sftpHost = process.env.SFTP_HOST;
+config.sftpPort = process.env.SFTP_PORT;
+config.sftpUsername = process.env.SFTP_USERNAME;
+config.sftpPassword = process.env.SFTP_PASSWORD;

errors.js

@@ -0,0 +1,20 @@
+function notFound(req, res, next) {
+  const err = new Error('Page Not Found');
+  err.status = 404;
+  next(err);
+}
+
+// eslint-disable-next-line
+function errorMiddleware(err, req, res, next) {
+  console.log(err);
+  res.status(err.status || err.statusCode || 500);
+  return res.json({
+    message: err.message,
+    errors: err.errors || []
+  });
+}
+
+module.exports = {
+  notFound,
+  errorMiddleware
+};

package.json

@@ -0,0 +1,18 @@
+{
+  "name": "tps-lookup",
+  "version": "1.0.0",
+  "description": "Lookup TPS numbers",
+  "main": "app.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "Andrew Snead",
+  "license": "ISC",
+  "dependencies": {
+    "body-parser": "^1.17.2",
+    "co": "^4.6.0",
+    "dotenv": "^4.0.0",
+    "express": "^4.15.3",
+    "ssh2": "^0.5.5"
+  }
+}

tmp/tps.dat

@@ -0,0 +1 @@
+07752193947