Add redis implementation

Author: pseudomuto

lib/store.js

@@ -1,5 +1,4 @@
 var trie = require('./trie.js');
-var exec = require('child_process').exec;
 
 var NotImplemented = function (name) {
   return {
@@ -42,3 +41,7 @@ exports.MemoryStore = function () {
 exports.ExternalStore = function (command) {
   return require("./store/external.js").create(BaseStore, command);
 };
+
+exports.RedisStore = function (host, port, db) {
+  return require("./store/redis.js").create(BaseStore, host, port, db);
+};

lib/store/redis.js

@@ -0,0 +1,115 @@
+var redis = require("redis");
+
+var DEFAULT_HOST = "127.0.0.1";
+var DEFAULT_PORT = 6379;
+var DEFAULT_DB   = 0;
+
+function createClient(host, port, db) {
+  var client = redis.createClient(
+    port || DEFAULT_PORT,
+    host || DEFAULT_HOST
+  );
+
+  if (db || 0 !== DEFAULT_DB) {
+    client.select(db);
+  }
+
+  return client;
+}
+
+exports.create = function (BaseStore, host, port, db) {
+  var client = createClient(host, port, db);
+
+  return Object.create(BaseStore, {
+    get: {
+      value: function (path, cb) {
+        var that = this;
+
+        client.hgetall(path, function (err, res) {
+          that.notify(cb, res || undefined);
+        });
+      }
+    },
+    getTarget: {
+      value: function (path, cb) {
+        var that = this;
+
+        this.get(path, function (data) {
+          if (!data) {
+            that.notify(cb);
+            return;
+          }
+
+          that.notify(cb, {
+            prefix: path,
+            data: data
+          });
+        });
+      }
+    },
+    getAll: {
+      value: function (cb) {
+        var that = this;
+
+        client.keys("*", function (err, keys) {
+          if (err || keys.length === 0) {
+            that.notify(cb, {});
+            return;
+          }
+
+          var routes = {};
+          var multi  = client.multi();
+
+          // queue up a command per key
+          keys.forEach(function (key) { multi.hgetall(key); });
+
+          multi.exec(function (err, values) {
+            keys.forEach(function (key, index) {
+              routes[key] = values[index];
+            });
+
+            that.notify(cb, routes);
+          });
+        });
+      }
+    },
+    add: {
+      value: function (path, data, cb) {
+        var that = this;
+
+        client.hmset(path, data, function (err, res) {
+          that.notify(cb);
+        });
+      }
+    },
+    update: {
+      value: function (path, data, cb) {
+        var that = this;
+
+        this.get(path, function (current) {
+          client.hmset(path, Object.assign(current, data), function (err, res) {
+            that.notify(cb);
+          });
+        });
+      }
+    },
+    remove: {
+      value: function (path, cb) {
+        var that = this;
+
+        client.del(path, function (err, res) {
+          that.notify(cb);
+        });
+      }
+    },
+    hasRoute: {
+      value: function (path, cb) {
+        var that = this;
+
+        client.exists(path, function (err, res) {
+          that.notify(cb, res === 1);
+        });
+      }
+    }
+  });
+};

package.json

@@ -18,6 +18,7 @@
   "devDependencies": {
     "jasmine": "^2.5.1",
     "jshint": "^2.9.2",
+    "redis": "~2.6",
     "nyc": "^6.4.0",
     "request": "~2",
     "ws": "^1.1"
@@ -29,6 +30,7 @@
     "lib/store.js",
     "lib/store/external.js",
     "lib/store/memory.js",
+    "lib/store/redis.js",
     "lib/trie.js",
     "lib/error/*.html",
     "bin/configurable-http-proxy"

test/store_spec.js

@@ -99,10 +99,10 @@ var sharedExamples = {
       it("merges supplied data with existing data", function (done) {
         var store = this.subject;
 
-        store.add("/my_route", { "version": 1, "test": "value" }, function () {
-          store.update("/my_route", { "version": 2 }, function () {
+        store.add("/my_route", { "version": "1", "test": "value" }, function () {
+          store.update("/my_route", { "version": "2" }, function () {
             store.get("/my_route", function (route) {
-              expect(route.version).toEqual(2);
+              expect(route.version).toEqual("2");
               expect(route.test).toEqual("value");
               done();
             });
@@ -173,4 +173,16 @@ describe("store", function () {
 
     sharedExamples.store.apply(this);
   });
+
+  describe("RedisStore", function () {
+    beforeEach(function () {
+      this.subject = storeProvider.RedisStore();
+    });
+
+    afterEach(function (done) {
+      require("redis").createClient().flushdb(done);
+    });
+
+    sharedExamples.store.apply(this);
+  });
 });