Added --db option to CLI.

README.md

@@ -42,6 +42,7 @@ $ ./bin/ponte --help
     -V, --version        output the version number
     -m, --mqtt-port <n>  the mqtt port to listen to
     -p, --http-port <n>  the hqtt port to listen to
+    -d, --db <path>      the path were to store the database
     -c, --config <c>     the config file to use (override every other
      option)
     -v, --verbose        set the bunyan log to INFO
@@ -130,6 +131,7 @@ These are the new features you should expect in the coming
 months:
 
 * [ ] Better bootstrap sequence.
+* [ ] Allow and document embedding inside other Node apps.
 * [ ] Add Web Hooks support.
 * [ ] Document configuration options.
 * [ ] Add WebSocket and Server-Sent Events support.

lib/cli.js

@@ -15,6 +15,7 @@ module.exports = function(args, done) {
     .version(pkg.version)
     .option("-m, --mqtt-port <n>", "the mqtt port to listen to", parseInt)
     .option("-p, --http-port <n>", "the mqtt port to listen to", parseInt)
+    .option("-d, --db <path>", "the path were to store the database")
     .option("-c, --config <c>", "the config file to use (override every other option)")
     .option("-v, --verbose", "set the bunyan log to INFO")
     .option("--very-verbose", "set the bunyan log to DEBUG");
@@ -29,6 +30,8 @@ module.exports = function(args, done) {
     },
     mqtt: {
       port: program.mqttPort
+    },
+    persistence: {
     }
   };
 
@@ -38,6 +41,11 @@ module.exports = function(args, done) {
     opts.logger.level = 20;
   } 
 
+  if (program.db) {
+    opts.persistence.path = program.db;
+    opts.persistence.type = "level";
+  }
+
   if (program.config) {
     opts = require(path.resolve(program.config));
   }

lib/persistence.js

@@ -9,5 +9,6 @@ var persistences = {
 
 module.exports = function(opts, done) {
   var factory = persistences[opts.type] || persistences.memory;
-  done(null, factory(opts, done));
+  delete opts.type;
+  done(null, factory(opts));
 };

package.json

@@ -24,7 +24,8 @@
     "sinon": "~1.7.3",
     "mocha": "~1.12.0",
     "jshint": "~2.1.4",
-    "supertest": "~0.7.1"
+    "supertest": "~0.7.1",
+    "tmp": "0.0.20"
   },
   "dependencies": {
     "express": "~3.3.4",

test/cli_spec.js

@@ -1,6 +1,8 @@
 
 var ponte = require("../");
 var async = require("async");
+var tmp   = require("tmp");
+var mosca = require("mosca");
 
 describe("ponte.cli", function() {
 
@@ -118,4 +120,22 @@ describe("ponte.cli", function() {
       expect(server.options.logger).to.have.property("name", "Config Test Logger");
     });
   });
+
+  it("should create a leveldb with the --db flag", function(done) {
+
+    tmp.dir(function (err, path, fd) {
+      if (err) {
+        done(err);
+        return;
+      }
+
+      args.push("--db");
+      args.push(path);
+
+      startServer(done, function(server) {
+        expect(server.persistence).to.be.instanceOf(mosca.persistence.LevelUp);
+        expect(server.persistence.options.path).to.eql(path);
+      });
+    });
+  });
 });