Add support for uploading SMS from CSV files

package.json

@@ -1,6 +1,6 @@
 {
   "name": "medic-conf",
-  "version": "1.13.0",
+  "version": "1.14.0",
   "description": "Configure Medic Mobile deployments",
   "main": "index.js",
   "scripts": {
@@ -41,6 +41,7 @@
   },
   "devDependencies": {
     "chai": "^4.0.0",
+    "chai-exclude": "^1.0.8",
     "express-pouchdb": "^2.3.7",
     "jshint": "^2.9.5",
     "lodash": "^4.17.4",

src/cli/supported-actions.js

@@ -10,6 +10,7 @@ module.exports = [
   'convert-contact-forms',
   'create-users',
   'csv-to-docs',
+  'csv-to-sms',
   'delete-forms',
   'delete-all-forms',
   'fetch-forms-from-google-drive',

src/fn/csv-to-sms.js

@@ -0,0 +1,32 @@
+const fs = require('../lib/sync-fs');
+const request = require('request-promise-native');
+const trace = require('../lib/log').trace;
+const uuid = require('uuid/v4');
+
+module.exports = (projectDir, couchUrl, extras) => {
+  const instanceUrl = couchUrl.replace(/\/medic$/, '');
+  const csvFiles = extras || ['sms.csv'];
+
+  trace('csv-to-sms', 'csv files:', csvFiles);
+
+  return csvFiles.map(fileName => `${projectDir}/${fileName}`)
+    .reduce((promiseChain, csvFile) => {
+      trace(`Processing csv file ${csvFile}…`);
+      const raw = fs.readCsv(csvFile);
+
+      const messages = raw.rows.map(row => ({
+      	id:           uuid(),
+	from:         row[raw.cols.indexOf('from')],
+	content:      row[raw.cols.indexOf('message')],
+	sms_sent:     Date.now(),
+	sms_received: Date.now(),
+      }));
+
+      return request({
+	uri: `${instanceUrl}/api/sms`,
+	method: 'POST',
+	json: true,
+	body: { messages },
+      });
+    }, Promise.resolve());
+};

test/api-stub.js

@@ -14,6 +14,11 @@ const opts = {
 };
 const app = express();
 app.use(bodyParser.json());
+app.post('/api/sms', (req, res) => {
+  module.exports.gatewayRequests.push(req.body);
+  res.write('{}');
+  res.end();
+});
 app.all('/api/*', mockMiddleware.requestHandler);
 app.use('/', stripAuth, expressPouch(memPouch, opts));
 
@@ -29,6 +34,8 @@ module.exports = {
 
     const port = server.address().port;
     module.exports.couchUrl = `http://admin:pass@localhost:${port}/medic`;
+
+    module.exports.gatewayRequests = [];
   },
   stop: () => {
     server.close();

test/data/csv-to-sms/expected.json

@@ -0,0 +1,14 @@
+[
+  {
+    "messages": [
+      {
+        "from": "+1234567890",
+        "content": "hello there"
+      },
+      {
+        "from": "+987654321",
+        "content": "goodnight, dear prince"
+      }
+    ]
+  }
+]

test/data/csv-to-sms/sms.csv

@@ -0,0 +1,3 @@
+from,message
++1234567890,hello there
++987654321,"goodnight, dear prince"

test/fn/csv-to-sms.spec.js

@@ -0,0 +1,31 @@
+const api = require('../api-stub');
+const fs = require('../../src/lib/sync-fs');
+const csvToSms = require('../../src/fn/csv-to-sms');
+
+const chai = require('chai');
+chai.use(require('chai-exclude'));
+const assert = chai.assert;
+
+describe('csv-to-sms', function() {
+  beforeEach(api.start);
+  afterEach(api.stop);
+
+  it('should upload SMS supplied in CSV format to medic-api', function() {
+
+    // given
+    const testDir = 'data/csv-to-sms';
+
+    // when
+    return csvToSms(testDir, api.couchUrl)
+      .then(() => {
+
+          // then
+	  const expected = fs.readJson(`${testDir}/expected.json`);
+          assert.deepEqualExcludingEvery(
+	      api.gatewayRequests, expected,
+	      ['id', 'sms_sent', 'sms_received']);
+
+      });
+
+  });
+});