cleaner plugin: manual tests OK

lib/MessageDb.js

@@ -130,6 +130,9 @@ MessageDb.prototype.getAll = function(cb) {
     .on('data', function(data) {
       list.push(MessageDb.fromStorage(data));
     })
+    .on('error', function(err) {
+      return cb(err);
+    })
     .on('end', function() {
       return cb(null, list);
     });
@@ -144,12 +147,16 @@ MessageDb.prototype.removeUpTo = function(ts, cb) {
     .on('data', function(key) {
       var parsed = MessageDb.parseKey(key);
       if (parsed.ts < ts) {
+        logger.verbose('Deleting message ' + key);
         dels.push({
           type: 'del',
           key: key
         });
       }
     })
+    .on('error', function(err) {
+      return cb(err);
+    })
     .on('end', function() {
       db.batch(dels, function(err) {
         if (err) return cb(err);

plugins/cleaner.js

@@ -7,16 +7,19 @@ var CronJob = cron.CronJob;
 
 
 module.exports.init = function(config) {
-  logger.info('Using cleaner plugin');
-  logger.info(config);
-  var job = new CronJob({
-    cronTime: config.cronTime || '0 * * * *',
-    onTick: function() {
+  var cronTime = config.cronTime || '0 * * * *';
+  logger.info('Using cleaner plugin with cronTime ' + cronTime);
+  var onTick = function() {
     var limit = microtime.now() - 1000 * 1000 * config.threshold;
     mdb.removeUpTo(limit, function(err, n) {
-        logger.verbose('Ran cleaner task, removed ' + n);
-      });
-    },
-    start: true
+      if (err) logger.error(err);
+      else logger.info('Ran cleaner task, removed ' + n);
     });
   };
+  var job = new CronJob({
+    cronTime: cronTime,
+    onTick: onTick
+  });
+  onTick();
+  job.start();
+};

plugins/config-cleaner.js

@@ -1,6 +1,6 @@
 module.exports = {
 
   cronTime: '* * * * *',
-  threshold: 10, // in seconds
+  threshold: 2*24*60*60, // 2 days, in seconds
 
 };