RanchiMall/flocore-node
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #289 from cmgustavo/fix/threshold-cleaner

Browse Source 
Configurable threshold of Cleaner plugin
This commit is contained in:
Matias Alejo Garcia 2015-01-20 16:25:43 -03:00
commit 22cc5e173a
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
plugins/cleaner.js
View File

@ -4,13 +4,13 @@ var preconditions = require('preconditions').singleton();
var microtime = require('microtime'); var microtime = require('microtime');
var cron = require('cron'); var cron = require('cron');
var CronJob = cron.CronJob; var CronJob = cron.CronJob;
var Threshold = (process.env.CLEANER_THRESHOLD_DAYS || 30) *24*60*60; // in seconds
module.exports.init = function(config) { module.exports.init = function(config) {
var cronTime = config.cronTime || '0 * * * *'; var cronTime = config.cronTime || '0 * * * *';
logger.info('Using cleaner plugin with cronTime ' + cronTime); logger.info('Using cleaner plugin with cronTime ' + cronTime + ' and threshold of ' + Threshold + ' seconds');
var onTick = function() { var onTick = function() {
var limit = microtime.now() - 1000 * 1000 * config.threshold; var limit = microtime.now() - 1000 * 1000 * Threshold;
mdb.removeUpTo(limit, function(err, n) { mdb.removeUpTo(limit, function(err, n) {
if (err) logger.error(err); if (err) logger.error(err);
else logger.info('Ran cleaner task, removed ' + n); else logger.info('Ran cleaner task, removed ' + n);

1
plugins/config-cleaner.js
View File

@ -1,6 +1,5 @@
module.exports = { module.exports = {
cronTime: '0 * * * *', // run each hour cronTime: '0 * * * *', // run each hour
threshold: 30*24*60*60, // 30 days, in seconds
}; };