fix redis mock incr()
This commit is contained in:
parent
efb7970ecb
commit
0d92343d55
@ -1,11 +1,12 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
|
// this is a mock version of the Redis API,
|
||||||
|
// emulating Redis if it is not available locally
|
||||||
var notRedis = {
|
var notRedis = {
|
||||||
state: {},
|
state: {},
|
||||||
topics: {},
|
topics: {},
|
||||||
|
|
||||||
publish: function(topic, msg, cb) {
|
publish: function(topic, msg, cb) {
|
||||||
//console.log("[notredis] publish",topic,msg);
|
|
||||||
if (!this.topics[topic]) {
|
if (!this.topics[topic]) {
|
||||||
this.topics[topic] = {
|
this.topics[topic] = {
|
||||||
subscribers: []
|
subscribers: []
|
||||||
@ -43,7 +44,7 @@ var notRedis = {
|
|||||||
t.subscribers.push(handle);
|
t.subscribers.push(handle);
|
||||||
}
|
}
|
||||||
|
|
||||||
cb(null, handle, topics.length);
|
cb(null, topics.length);
|
||||||
return handle;
|
return handle;
|
||||||
},
|
},
|
||||||
|
|
||||||
@ -82,7 +83,7 @@ var notRedis = {
|
|||||||
incr: function(key, cb) {
|
incr: function(key, cb) {
|
||||||
if (!this.state[key]) this.state[key] = 0;
|
if (!this.state[key]) this.state[key] = 0;
|
||||||
this.state[key]++;
|
this.state[key]++;
|
||||||
cb();
|
cb(null, this.state[key]);
|
||||||
},
|
},
|
||||||
|
|
||||||
expire: function() {
|
expire: function() {
|
||||||
|
Loading…
Reference in New Issue
Block a user