Persist reports in memory

lib/options.js

@@ -8,6 +8,8 @@ module.exports = function getOptions(argv) {
       cert: argv.cert || process.env.npm_package_remotedev_cert || null,
       passphrase: argv.passphrase || process.env.npm_package_remotedev_passphrase || null
     },
+    adapter: argv.adapter || process.env.npm_package_remotedev_adapter,
+    db: argv.adapter || process.env.npm_package_remotedev_db,
     logLevel: argv.logLevel || 3
   };
 }

lib/store.js

@@ -0,0 +1,32 @@
+var uuid = require('node-uuid');
+var JSData = require('js-data');
+
+var store;
+var adapter;
+var Report;
+
+function add(data) {
+  var obj = {
+    id: uuid.v4(),
+    type: data.type,
+    payload: data.payload
+  };
+  if (!adapter) {
+    return new Promise(function(resolve) {
+      var report = Report.inject(obj);
+      return resolve(report);
+    });
+  }
+  return Report.create(obj);
+}
+
+function createStore(options) {
+  store = new JSData.DS();
+  Report = store.defineResource('report');
+
+  return {
+    add: add
+  };
+}
+
+module.exports = createStore;

lib/worker.js

@@ -2,10 +2,12 @@ var path = require('path');
 var app = require('express')();
 var bodyParser = require('body-parser');
 var cors = require('cors');
+var createStore = require('./store');
 
 module.exports.run = function(worker) {
   var httpServer = worker.httpServer;
   var scServer = worker.scServer;
+  var store;
 
   httpServer.on('request', app);
 
@@ -20,8 +22,11 @@ module.exports.run = function(worker) {
   app.use(bodyParser.json());
   app.post('/', function(req, res) {
     if (!req.body) return res.status(404).end();
-    scServer.exchange.publish('log', req.body);
-    res.send('OK');
+    if (!store) store = createStore(worker.options);
+    store.add(req.body).then(function(r) {
+      scServer.exchange.publish('log', req.body);
+      res.send({ id: r.id });
+    });
   });
 
   scServer.addMiddleware(scServer.MIDDLEWARE_EMIT, function (req, next) {