Add support for start and end ranges at query time

brycebaril · Nov 8, 2015 · 2439c83 · 2439c83
1 parent a1d0143
commit 2439c83
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.start) opts.minVersion = options.start
+    if (options.until) opts.maxVersion = options.until
+    return ts(db.versionStream(key, opts).pipe(toTimestream()))
   }
   db.timeStream = db.ts
 
   return db
-}
+}