more tests

Author: pasupulaphani

lib/redis_pool.js

@@ -8,8 +8,8 @@ const debug = require("debug")("simpleRedisPool");
 
 function RedisPool (name, redisOptions, poolOptions) {
 
+  this.name = name;
   this._redisDb = redisOptions.db || 0;
-
   let _pool = null;
 
   const factory = {
@@ -56,9 +56,6 @@ function RedisPool (name, redisOptions, poolOptions) {
   // Now that the pool settings are ready create a pool instance.
   _pool = genericPool.createPool(factory, poolOptions);
 
-  // set name
-  this.name = name;
-
   // Acquire a database connection and use an optional priority.
   this.acquire = (priority) => {
     return _pool.acquire(priority);

lib/redis_store.js

@@ -41,7 +41,9 @@ function RedisStore (name, redisOptions, poolOptions) {
 
   this.del = (key) => wrapFunc(pool, (conn) => conn.delAsync(key));
 
-  this.ttlInSeconds = (key) => wrapFunc(pool, (conn) => conn.ttlInSecondsAsync(key));
+  this.expire = (key, ttlInSeconds) => wrapFunc(pool, (conn) => conn.expireAsync(key, ttlInSeconds));
+
+  this.ttlInSeconds = (key) => wrapFunc(pool, (conn) => conn.ttlAsync(key));
 
   this.keys = (pattern) => {
     if (!pattern || pattern === "") {
@@ -51,7 +53,6 @@ function RedisStore (name, redisOptions, poolOptions) {
     return wrapFunc(pool, (conn) => conn.keysAsync(pattern));
   };
 
-
   this.deleteAll = (pattern) => {
     if (!pattern || pattern === "") {
       pattern = "*";

test/redis_store.js

@@ -115,4 +115,149 @@ describe("redisStore", function () {
         });
     });
   });
+
+  describe("expire", function () {
+    it("should set a key with expire in seconds", function (done) {
+
+      const key = "key";
+      const value = "make it expire";
+      const ttlInSeconds = 1;
+
+      store.set(key, value)
+        .then(function (test) {
+          test.should.be.ok();
+        });
+
+      store.expire(key, ttlInSeconds)
+        .then(function (v) {
+          v.should.be.ok();
+        });
+
+      Bluebird.delay(ttlInSeconds * 1000)
+        .done(() => {
+          return store.get(key)
+            .then(function (v) {
+              should(v).be.null;
+              done();
+            });
+        });
+    });
+
+    it("should return null expiring non-existing key", function (done) {
+      store.expire("unknownKey", 10)
+        .then(function (v) {
+          should(v).be.null;
+          done();
+        });
+    });
+  });
+
+  describe("ttl", function () {
+    it("should return ttl left for a key in seconds", function (done) {
+
+      const key = "key";
+      const value = "make it expire";
+      const ttlInSeconds = 10;
+
+      store.setex(key, value, ttlInSeconds)
+        .then(function (test) {
+          test.should.be.ok();
+        });
+
+      store.ttlInSeconds(key)
+        .then(function (v) {
+
+          // it should be same as the time elapsed is very vvery small
+          v.should.be.equal(ttlInSeconds);
+          done();
+        });
+
+    });
+
+    it("should return null on ttl for a non-existing key", function (done) {
+      store.ttlInSeconds("unknownKey")
+        .then(function (v) {
+          should(v).be.null;
+          done();
+        });
+    });
+  });
+
+  describe("keys", function () {
+
+    beforeEach(function (done) {
+      store.deleteAll()
+        .then(() => done());
+    });
+
+    it("should return all the keys", function (done) {
+
+      const keyValues = {key1: "value1", key2: "value2"};
+
+      for (var key in keyValues) {
+        store.set(key, keyValues[key]);
+      }
+
+      store.keys()
+        .then(function (keys) {
+          keyValues.should.have.keys(keys[0], keys[1]);
+          done();
+        });
+    });
+
+    it("should return all the keys matches pattern", function (done) {
+
+      const keyValues = {key1: "value1", key2: "value2"};
+
+      for (var key in keyValues) {
+        store.set(key, keyValues[key]);
+      }
+
+      store.keys("key[2]")
+        .then(function (keys) {
+          keys.should.containEql("key2");
+          done();
+        });
+    });
+  });
+
+  describe("deleteAll", function () {
+
+    beforeEach(function () {
+      const keyValues = {key1: "value1", key2: "value2"};
+
+      for (var key in keyValues) {
+        store.set(key, keyValues[key]);
+      }
+    });
+
+    it("should delete all the keys", function (done) {
+
+      store.deleteAll()
+        .then(function (v) {
+          v.should.be.ok();
+        });
+
+      store.keys()
+        .then(function (keys) {
+          keys.should.be.empty();
+          done();
+        });
+    });
+
+    it("should delete all the keys matches pattern", function (done) {
+
+      store.deleteAll("key[2]")
+        .then(function (v) {
+          v.should.be.ok();
+        });
+
+      store.keys()
+        .then(function (keys) {
+          keys.should.be.not.empty();
+          keys.should.not.containEql("key2");
+          done();
+        });
+    });
+  });
 });