Add support for start and end ranges at query time

brycebaril · Nov 8, 2015 · 96725b3 · 96725b3
1 parent a1d0143
commit 96725b3
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/timestreamdb.js b/timestreamdb.js
@@ -36,10 +36,14 @@ function TimestreamDB(instance, options) {
 
   var db = Version(instance, options)
 
-  db.ts = function (key) {
-    return ts(db.versionStream(key, {reverse: true}).pipe(toTimestream()))
+  db.ts = function (key, options) {
+    var opts = {reverse: true}
+
+    if (options.from) opts.minVersion = options.from
+    if (options.to) opts.maxVersion = options.to
+    return ts(db.versionStream(key, opts).pipe(toTimestream()))
   }
   db.timeStream = db.ts
 
   return db
-}
+}