lukechilds
/
node-cache-manager
mirror of https://github.com/lukechilds/node-cache-manager.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
Browse Source

test cases passing. but not enough coverage.

feature/specify-what-to-cache
Sean Cady 10 years ago
parent
6249034237
commit
1c341dd985
2 changed files with 106 additions and 56 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 113
      lib/multi_caching.js
  2. 31
      test/stores/options.unit.js

113
lib/multi_caching.js
View File

@ -6,17 +6,27 @@ var domain = require('domain');
/**
* Module that lets you specify a hierarchy of caches.
*/
var multi_caching = function(caches) {
var multi_caching = function (caches) {
var self = {};
if (!Array.isArray(caches)) { throw new Error('multi_caching requires an array of caches'); }
if (!Array.isArray(caches)) {
throw new Error('multi_caching requires an array of caches');
}
self.queues = {};
function get_from_highest_priority_cache(key, cb, options) {
function get_from_highest_priority_cache(key, options, cb) {
if (typeof options === 'function') {
cb = options;
options = undefined;
}
var i = 0;
async.forEachSeries(caches, function(cache, async_cb) {
cache.store.get(key, function(err, result) {
if (err) { return cb(err); }
async.forEachSeries(caches, function (cache, async_cb) {
if(typeof options === 'object'){
cache.store.get(key, options, function (err, result) {
if (err) {
return cb(err);
}
if (result) {
// break out of async loop.
return cb(err, result, i);
@ -24,13 +34,32 @@ var multi_caching = function(caches) {
i += 1;
async_cb(err);
}, options);
});
}else{
cache.store.get(key, function (err, result) {
if (err) {
return cb(err);
}
if (result) {
// break out of async loop.
return cb(err, result, i);
}
i += 1;
async_cb(err);
});
}
}, cb);
}
function set_in_multiple_caches(caches, opts, cb) {
async.forEach(caches, function(cache, async_cb) {
cache.store.set(opts.key, opts.value, opts.ttl, async_cb, opts.options);
async.forEach(caches, function (cache, async_cb) {
if (typeof opts.options !== 'object') {
cache.store.set(opts.key, opts.value, opts.ttl, async_cb);
} else {
cache.store.set(opts.key, opts.value, opts.options, async_cb);
}
}, cb);
}
@ -39,8 +68,8 @@ var multi_caching = function(caches) {
*
* When a key is found in a lower cache, all higher levels are updated
*/
self.get_and_pass_up = function(key, cb) {
get_from_highest_priority_cache(key, function(err, result, index) {
self.get_and_pass_up = function (key, cb) {
get_from_highest_priority_cache(key, function (err, result, index) {
if (err) {
return cb(err);
}
@ -49,7 +78,7 @@ var multi_caching = function(caches) {
if (result !== undefined && index) {
var cachesToUpdate = caches.slice(0, index);
async.forEach(cachesToUpdate, function(cache, async_cb) {
async.forEach(cachesToUpdate, function (cache, async_cb) {
cache.set(key, result, result.ttl, async_cb);
});
}
@ -66,11 +95,10 @@ var multi_caching = function(caches) {
* If a key doesn't exist in a higher-priority cache but exists in a lower-priority
* cache, it gets set in all higher-priority caches.
*/
self.wrap = function(key, work, ttl, cb, options) {
if (typeof ttl === 'function') {
cb = ttl;
options = cb;
ttl = undefined;
self.wrap = function (key, work, options, cb) {
if (typeof options === 'function') {
cb = options;
options = undefined;
}
if (self.queues[key]) {
@ -81,14 +109,14 @@ var multi_caching = function(caches) {
self.queues[key] = [{cb: cb, domain: process.domain}];
function fillCallbacks(err, data) {
self.queues[key].forEach(function(task) {
self.queues[key].forEach(function (task) {
var taskDomain = task.domain || domain.create();
taskDomain.bind(task.cb)(err, data);
});
delete self.queues[key];
}
get_from_highest_priority_cache(key, function(err, result, index) {
get_from_highest_priority_cache(key, function (err, result, index) {
if (err) {
return fillCallbacks(err);
} else if (result) {
@ -96,19 +124,23 @@ var multi_caching = function(caches) {
var opts = {
key: key,
value: result,
ttl: ttl,
options: options
};
set_in_multiple_caches(caches_to_update, opts, function(err) {
if (typeof options !== 'object') {
opts.ttl = options;
}
set_in_multiple_caches(caches_to_update, opts, function (err) {
fillCallbacks(err, result);
});
} else {
domain
.create()
.on('error', function(err) {
.on('error', function (err) {
fillCallbacks(err);
})
.bind(work)(function(err, data) {
.bind(work)(function (err, data) {
if (err) {
fillCallbacks(err);
return;
@ -116,10 +148,13 @@ var multi_caching = function(caches) {
var opts = {
key: key,
value: data,
ttl: ttl,
options: options
};
set_in_multiple_caches(caches, opts, function(err) {
if (typeof options !== 'object') {
opts.ttl = options;
}
set_in_multiple_caches(caches, opts, function (err) {
if (err) {
fillCallbacks(err);
} else {
@ -131,23 +166,37 @@ var multi_caching = function(caches) {
});
};
self.set = function(key, value, ttl, cb, options) {
self.set = function (key, value, options, cb) {
var opts = {
key: key,
value: value,
ttl: ttl,
options: options
};
if (typeof options !== 'object') {
opts.ttl = options;
}
set_in_multiple_caches(caches, opts, cb);
};
self.get = function(key, cb, options) {
get_from_highest_priority_cache(key, cb, options);
self.get = function (key, options, cb) {
if (typeof options === 'function') {
cb = options;
options = false;
}
get_from_highest_priority_cache(key, options, cb);
};
self.del = function(key, cb, options) {
async.forEach(caches, function(cache, async_cb) {
cache.store.del(key, async_cb, options);
self.del = function (key, options, cb) {
if (typeof options === 'function') {
cb = options;
options = false;
}
async.forEach(caches, function (cache, async_cb) {
if(typeof options ==='object'){
cache.store.del(key, options, async_cb );
}else{
cache.store.del(key, async_cb );
}
}, cb);
};

31
test/stores/options.unit.js
View File

@ -11,7 +11,7 @@ var testStore = function(args) {
var self = {};
self.name = "options";
self.get = function(key, cb, options) {
self.get = function(key, options, cb) {
if (options && options.value) {
return cb(null, options.value + "ValueOption");
} else if (options && options.fn) {
@ -21,7 +21,7 @@ var testStore = function(args) {
return cb("Error No Options");
};
self.set = function(key, value, ttl, cb, options) {
self.set = function(key, value, options, cb) {
if (options && options.value) {
memoryFlag = options.value + "ValueOption";
return cb();
@ -32,7 +32,7 @@ var testStore = function(args) {
return cb("Error No Options");
};
self.del = function(key, cb, options) {
self.del = function(key, options, cb) {
if (options && options.value) {
memoryFlag = options.value + "ValueOption";
return cb();
@ -64,10 +64,10 @@ describe("Methods with options", function() {
it("lets us pass options by value", function(done) {
var options = {value: value};
testCache.get(key, function(err, response) {
testCache.get(key, options, function(err, response) {
assert.equal(response, value + "ValueOption");
done();
}, options);
});
});
it("lets us pass options by function", function(done) {
@ -77,9 +77,9 @@ describe("Methods with options", function() {
done();
}
};
testCache.get(key, function(err, response) {
testCache.get(key , options, function(err, response) {
assert.equal(response, "GetFunctionOption");
}, options);
});
});
});
describe("set with options", function() {
@ -91,21 +91,22 @@ describe("Methods with options", function() {
});
it("lets us pass options by value", function(done) {
var options = {value: value};
testCache.set(key, value, ttl, function() {
assert.equal(memoryFlag,value + "ValueOption");
var options = {ttl: ttl, value: value};
testCache.set(key, value, options, function() {
assert.equal(memoryFlag, value + "ValueOption");
done();
}, options);
});
});
it("lets us pass options by function", function(done) {
var options = {
ttl: ttl,
fn: function(response) {
assert.equal(response, "SetFunctionOption");
done();
}
};
testCache.set(key, value, ttl, function() {}, options);
testCache.set(key, value, options, function() {}, options);
});
});
describe("delete with options", function() {
@ -117,10 +118,10 @@ describe("Methods with options", function() {
it("lets us pass options by value", function(done) {
var options = {value: value};
testCache.del(key, function() {
testCache.del(key, options, function() {
assert.equal(memoryFlag,value + "ValueOption");
done();
}, options);
});
});
it("lets us pass options by function", function(done) {
@ -130,7 +131,7 @@ describe("Methods with options", function() {
done();
}
};
testCache.del(key, function() {}, options);
testCache.del(key, options, function() {}, options);
});
});
});

Write Preview
Loading…
Cancel
Save