WATCH: increment delrev for keys that exist but expire in the meantime.

Changelog.md

@@ -1,6 +1,14 @@
 Changelog
 =========
 
+## v0.2.2 - November 21, 2014
+
+* Bugfix: WATCH for keys that do not yet exist.
+
+## v0.2.1 - August 22, 2014
+
+* Added extended SET parameters [EX/PX/NX/XX]
+
 ## v0.2.0 - April 25, 2014
 
 * Support for `detect_buffers` and `return_buffers`.

lib/backend.js

@@ -198,13 +198,15 @@ exports.Backend = function() {
     if (key === undefined)
       throw new Error("WOOT! key param for getKey is undefined.");
 
-    if (!entry || entry.expire < Date.now()) {
-      delete state[key];
-      delrev[key] = rev;
-      entry = null;
+    if (entry) {
+      if (entry.expire < Date.now()) {
+        delete state[key];
+        delrev[key] = ++rev;
+        entry = null;
+      }
+      else if (!(entry.value instanceof VALID_TYPE))
+        throw new Error("WOOT! keyspace entry value is not a valid Type.");
     }
-    else if (!(entry.value instanceof VALID_TYPE))
-      throw new Error("WOOT! keyspace entry value is not a valid Type.");
 
     if (Type) {
       if (entry && !(entry.value instanceof Type))

package.json

@@ -1,5 +1,5 @@
 {   "name": "fakeredis",
-    "version": "0.2.1",
+    "version": "0.2.2",
     "description": "Fake redis for testing, works as a drop-in replacement for node_redis",
     "keywords": [ "test", "spec", "fake", "redis", "simulated", "implementation", "client" ],
     "author": "Hristo Dachev <tutini@gmail.com>",

test.js

@@ -453,15 +453,14 @@ process.stdout.write ( 'testing fakeredis ...\n\n' );
 ( function ()
 {
     var multi,
-        redis  = fake.createClient ( "transactions-1" ),
-        redis2 = fake.createClient ( "transactions-1" );
+        redis = fake.createClient("transactions-3");
 
     redis.WATCH ( "abc" );
     redis.GET( "abc" );
     multi = redis.MULTI ();
     multi.SET ( "abc", "dfgdfg" );
-    multi.exec ( test("EXEC succeeds", null, ['OK'] ) );
-    redis.GET ( "abc", test ( "GET succeeds", null, "dfgdfg" ) );
+    multi.exec ( test("WATCH NONEX EXEC succeeds", null, ['OK'] ) );
+    redis.GET ( "abc", test ( "WATCH NONEX GET succeeds", null, "dfgdfg" ) );
 }
 () );