delete from cache only new blacklist entries
This commit is contained in:
@@ -5,7 +5,7 @@ var md5 = require('md5');
|
|||||||
var LRU = require('lru-cache');
|
var LRU = require('lru-cache');
|
||||||
var bodyParser = require('body-parser');
|
var bodyParser = require('body-parser');
|
||||||
var fs = require('fs');
|
var fs = require('fs');
|
||||||
var blackList;
|
var blackList = new Set();
|
||||||
|
|
||||||
var app = express();
|
var app = express();
|
||||||
|
|
||||||
@@ -170,7 +170,7 @@ setInterval(() => {
|
|||||||
|
|
||||||
var updateBlackList = () => {
|
var updateBlackList = () => {
|
||||||
var ids = fs.readFileSync(process.env.BLACK_LIST || '/dev/null', 'utf-8').split(/\n+/).filter(Boolean);
|
var ids = fs.readFileSync(process.env.BLACK_LIST || '/dev/null', 'utf-8').split(/\n+/).filter(Boolean);
|
||||||
ids.forEach(id => CACHE.del(id));
|
ids.filter(id => !blackList.has(id)).forEach(id => CACHE.del(id));
|
||||||
blackList = new Set(ids);
|
blackList = new Set(ids);
|
||||||
log('black list updated, entries:', blackList.size);
|
log('black list updated, entries:', blackList.size);
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user