2011-03-31 08:11:11 +00:00
|
|
|
/*
|
2011-04-02 08:31:20 +00:00
|
|
|
* redis-store-test.js: Tests for the redis nconf storage engine.
|
2011-03-31 08:11:11 +00:00
|
|
|
*
|
|
|
|
* (C) 2011, Charlie Robbins
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
|
2011-04-02 07:03:16 +00:00
|
|
|
require.paths.unshift(require('path').join(__dirname, '..', 'lib'));
|
2011-03-31 08:11:11 +00:00
|
|
|
|
|
|
|
var vows = require('vows'),
|
|
|
|
assert = require('assert'),
|
2011-04-02 08:31:20 +00:00
|
|
|
nconf = require('nconf'),
|
|
|
|
data = require('./fixtures/data').data;
|
2011-03-31 08:11:11 +00:00
|
|
|
|
|
|
|
vows.describe('nconf/stores/redis').addBatch({
|
|
|
|
"When using the nconf redis store": {
|
|
|
|
topic: new nconf.stores.Redis(),
|
|
|
|
"the set() method": {
|
|
|
|
"with a literal": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.set('foo:literal', 'bazz', this.callback)
|
|
|
|
},
|
|
|
|
"should respond without an error": function (err, ok) {
|
|
|
|
assert.isNull(err);
|
|
|
|
}
|
|
|
|
},
|
|
|
|
"with an Array": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.set('foo:array', data.arr, this.callback)
|
|
|
|
},
|
|
|
|
"should respond without an": function (err, ok) {
|
|
|
|
assert.isNull(err);
|
|
|
|
}
|
|
|
|
},
|
|
|
|
"with an Object": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.set('foo:object', data.obj, this.callback)
|
|
|
|
},
|
|
|
|
"should respond without an error": function (err, ok) {
|
|
|
|
assert.isNull(err);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}).addBatch({
|
|
|
|
"When using the nconf redis store": {
|
|
|
|
topic: new nconf.stores.Redis(),
|
|
|
|
"the get() method": {
|
|
|
|
"with a literal value": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.get('foo:literal', this.callback);
|
|
|
|
},
|
|
|
|
"should respond with the correct value": function (err, value) {
|
|
|
|
assert.equal(value, data.literal);
|
|
|
|
}
|
|
|
|
},
|
|
|
|
"with an Array value": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.get('foo:array', this.callback);
|
|
|
|
},
|
|
|
|
"should respond with the correct value": function (err, value) {
|
|
|
|
assert.deepEqual(value, data.arr);
|
|
|
|
}
|
|
|
|
},
|
|
|
|
"with an Object value": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.get('foo:object', this.callback);
|
|
|
|
},
|
|
|
|
"should respond with the correct value": function (err, value) {
|
|
|
|
assert.deepEqual(value, data.obj);
|
|
|
|
}
|
2011-03-31 08:12:43 +00:00
|
|
|
},
|
|
|
|
"with a nested Object value": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.get('foo:object:auth', this.callback);
|
|
|
|
},
|
|
|
|
"should respond with the correct value": function (err, value) {
|
|
|
|
assert.deepEqual(value, data.obj.auth);
|
|
|
|
}
|
2011-03-31 08:11:11 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}).addBatch({
|
2011-04-02 07:03:16 +00:00
|
|
|
"When using the nconf redis store": {
|
|
|
|
topic: new nconf.stores.Redis(),
|
|
|
|
"the clear() method": {
|
|
|
|
topic: function (store) {
|
|
|
|
var that = this;
|
|
|
|
store.clear('foo', function (err) {
|
|
|
|
if (err) {
|
|
|
|
return that.callback(err);
|
|
|
|
}
|
|
|
|
|
|
|
|
store.get('foo', that.callback);
|
|
|
|
});
|
|
|
|
},
|
|
|
|
"should actually remove the value from Redis": function (err, value) {
|
|
|
|
assert.isNull(err);
|
|
|
|
assert.isNull(value);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}).addBatch({
|
|
|
|
"When using the nconf redis store": {
|
|
|
|
topic: new nconf.stores.Redis(),
|
|
|
|
"the save() method": {
|
|
|
|
topic: function (store) {
|
|
|
|
var that = this;
|
|
|
|
store.save(data, function (err) {
|
|
|
|
if (err) {
|
|
|
|
return that.callback(err);
|
|
|
|
}
|
|
|
|
|
|
|
|
store.get('obj', that.callback);
|
|
|
|
});
|
|
|
|
},
|
|
|
|
"should set all values correctly": function (err, value) {
|
|
|
|
assert.isNull(err);
|
|
|
|
assert.deepEqual(value, data.obj);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}).addBatch({
|
|
|
|
"When using the nconf redis store": {
|
|
|
|
topic: new nconf.stores.Redis(),
|
|
|
|
"the load() method": {
|
|
|
|
topic: function (store) {
|
|
|
|
store.load(this.callback);
|
|
|
|
},
|
|
|
|
"should respond with the correct object": function (err, value) {
|
|
|
|
assert.isNull(err);
|
|
|
|
assert.deepEqual(value, data);
|
|
|
|
}
|
2011-03-31 08:11:11 +00:00
|
|
|
}
|
2011-04-02 07:03:16 +00:00
|
|
|
}
|
|
|
|
}).addBatch({
|
|
|
|
"When using the nconf redis store": {
|
|
|
|
topic: new nconf.stores.Redis(),
|
|
|
|
"the reset() method": {
|
|
|
|
topic: function (store) {
|
|
|
|
var that = this;
|
|
|
|
this.store = store;
|
|
|
|
|
|
|
|
store.reset(function (err) {
|
|
|
|
if (err) {
|
|
|
|
return that.callback(err);
|
|
|
|
}
|
|
|
|
|
|
|
|
store.get('obj', that.callback);
|
|
|
|
});
|
|
|
|
},
|
|
|
|
"should remove all keys from redis": function (err, value) {
|
|
|
|
assert.isNull(err);
|
|
|
|
assert.isNull(value);
|
|
|
|
assert.length(Object.keys(this.store.cache.store), 0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2011-03-31 08:11:11 +00:00
|
|
|
}).export(module);
|