expire-unused-keys
Advanced tools
Comparing version 1.0.3 to 1.0.4
15
index.js
@@ -23,2 +23,8 @@ var EventEmitter = require('events').EventEmitter | ||
function filterForgotten(keys) { | ||
return keys.filter(function(key) { | ||
return forgotten.indexOf(key) === -1 | ||
}) | ||
} | ||
var checkForExpiredKeys = onlyLetOneTaskRunAtATime(function check(done) { | ||
@@ -33,5 +39,3 @@ var now = new Date().getTime() | ||
// Need to make sure that none of these keys were "forgotten" since we opened the read stream | ||
var expiringNow = batchKeys.filter(function(key) { | ||
return forgotten.indexOf(key) === -1 | ||
}) | ||
var expiringNow = filterForgotten(batchKeys) | ||
var batchObjects = expiringNow.map(function(key) { | ||
@@ -43,8 +47,7 @@ return {type: 'del', key: key} | ||
if (!err) { | ||
expiringNow.forEach(expirer.emit.bind(expirer, 'expire')) | ||
filterForgotten(expiringNow).forEach(expirer.emit.bind(expirer, 'expire')) | ||
} | ||
forgotten = [] | ||
done(err) | ||
}) | ||
forgotten = [] | ||
}) | ||
@@ -51,0 +54,0 @@ }) |
{ | ||
"name": "expire-unused-keys", | ||
"version": "1.0.3", | ||
"version": "1.0.4", | ||
"main": "./index.js", | ||
@@ -5,0 +5,0 @@ "author": { |
11977
11
270