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);