From fe682c173f5781629022b1c28b520d9cef754843 Mon Sep 17 00:00:00 2001 From: Manuel Araoz Date: Mon, 1 Sep 2014 17:33:46 -0300 Subject: [PATCH] cleaner plugin: optimize getMessages --- lib/MessageDb.js | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/lib/MessageDb.js b/lib/MessageDb.js index 75ca0ec..fd77530 100644 --- a/lib/MessageDb.js +++ b/lib/MessageDb.js @@ -97,10 +97,10 @@ MessageDb.prototype.getMessages = function(to, lower_ts, upper_ts, cb) { var list = []; lower_ts = lower_ts || 1; var opts = { - end: messageKey(to, lower_ts), - start: messageKey(to, upper_ts), + start: messageKey(to, lower_ts), + end: messageKey(to, upper_ts), // limit: limit, TODO - reverse: true, + reverse: false, }; db.createReadStream(opts) @@ -112,12 +112,13 @@ MessageDb.prototype.getMessages = function(to, lower_ts, upper_ts, cb) { return cb(err); }) .on('end', function() { - return cb(null, list.reverse()); + return cb(null, list); }); }; -MessageDb.prototype.remove = function(ts) { - +MessageDb.prototype.removeUpTo = function(ts) { + var opts = {}; + db.createKeyStream(opts); }; module.exports = soop(MessageDb);