Expose flumedb.views

flumedb · Dec 22, 2018 · 20a1820 · 20a1820
1 parent 1f6c42c
commit 20a1820
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 5 deletions.
diff --git a/README.md b/README.md
@@ -168,6 +168,10 @@ closes all flumeviews.
 
 set to true if `flumedb.close()` has been called
 
+#### flumedb.views => object
+
+flumeviews that are currently being used by flumedb
+
 ---
 
 ### flumelog api

diff --git a/index.js b/index.js
@@ -31,7 +31,6 @@ function asyncify () {
 }
 
 module.exports = function (log, isReady, mapper) {
-  var views = []
   var meta = {}
 
   log.get = count(log.get, 'get')
@@ -120,7 +119,7 @@ module.exports = function (log, isReady, mapper) {
         {get: get, stream: stream, since: log.since, filename: log.filename}
         , name)
 
-      views[name] = flume[name] = wrap(sv, flume)
+      flume.views[name] = flume[name] = wrap(sv, flume)
       meta[name] = flume[name].meta
       sv.since.once(function build (upto) {
         log.since.once(function (since) {
@@ -149,7 +148,7 @@ module.exports = function (log, isReady, mapper) {
     },
     rebuild: function (cb) {
       throwIfClosed('rebuild')
-      return cont.para(map(views, function (sv) {
+      return cont.para(map(flume.views, function (sv) {
         return function (cb) {
           sv.destroy(function (err) {
             if(err) return cb(err)
@@ -173,14 +172,15 @@ module.exports = function (log, isReady, mapper) {
     close: function (cb) {
       if(flume.closed) return cb()
       flume.closed = true
-      cont.para(map(views, function (sv, k) {
+      cont.para(map(flume.views, function (sv, k) {
         return function (cb) {
           if(sv.close) sv.close(cb)
           else cb()
         }
       })) (cb)
 
-    }
+    },
+    views: {}
   }
   return flume
 }

diff --git a/test/memlog.js b/test/memlog.js
@@ -14,6 +14,14 @@ module.exports = function (db) {
     return statistics(acc, data.foo)
   }))
 
+  tape('views', function (t) {
+    console.log(db)
+    console.log(db.views)
+    t.notEqual(db.views, undefined, 'views are accessible')
+    t.equal(Object.keys(db.views).length, 1, 'view count is correct')
+    t.end()
+  })
+
   tape('empty db', function (t) {
     db.stats.get(function (err, value) {
       if(err) throw err