multiblob - npm Package Compare versions

Comparing version 1.7.1 to 1.8.0

index.js

@@ -1,15 +0,17 @@
-var cont    = require('cont')
-var pull    = require('pull-stream')
-var defer   = require('pull-defer')
-var path    = require('path')
-var toPull  = require('stream-to-pull-stream')
-var explain = require('explain-error')
-var mkdirp  = require('mkdirp')
-var rimraf  = require('rimraf')
-var fs      = require('fs')
-var glob    = require('pull-glob')
-var paramap = require('pull-paramap')
+var cont     = require('cont')
+var pull     = require('pull-stream')
+var defer    = require('pull-defer')
+var path     = require('path')
+var toPull   = require('stream-to-pull-stream')
+var explain  = require('explain-error')
+var mkdirp   = require('mkdirp')
+var rimraf   = require('rimraf')
+var fs       = require('fs')
+var glob     = require('pull-glob')
+var paramap  = require('pull-paramap')
+var cat      = require('pull-cat')
+var Notify   = require('pull-notify')
 
-var util    = require('./util')
-var createHash = util.createHash, toPath = util.toPath, isHash = util.isHash
+var u = require('./util')
+var createHash = u.createHash, toPath = u.toPath, isHash = u.isHash
 
@@ -33,2 +35,4 @@ function write (filename, cb) {
 
+  var newBlob = Notify()
+
   config = config || {}
@@ -92,3 +96,5 @@ config.hash = config.hash || 'blake2s'
 
+  var listeners = []
 
+
   return {
@@ -156,3 +162,3 @@ get: function (opts) {
               if(err) cb(explain(err, 'could not move file'))
-              else    cb(null, hasher.digest)
+              else    newBlob(p), cb(null, hasher.digest)
             })
@@ -170,7 +176,17 @@ })
     ls: function (opts) {
-      var long = opts && (opts.size || opts.long)
+      opts = opts || {}
+      var long = (opts.size || opts.long)
+      var live = opts.live
+      var source = glob(path.join(dir, '*', '*', '*'))
+      if(live)
+        source = cat([
+          source, pull.once({sync: true}), newBlob.listen()
+        ])
+
       return pull(
-        glob(path.join(dir, '*', '*', '*')),
+        source,
         long
         ? paramap(function (filename, cb) {
+            //handle the sync event...
+            if(live && filename.sync) return cb(null, filename)
             fs.stat(filename, function (err, stat) {
@@ -181,2 +197,3 @@ cb(err, {id: toHash(filename), size: stat.size, ts: +stat.ctime})
         : pull.map(function (filename) {
+            if(live && filename.sync) return filename
             return toHash(filename)
@@ -183,0 +200,0 @@ })

package.json

 {
   "name": "multiblob",
   "description": "",
-  "version": "1.7.1",
+  "version": "1.8.0",
   "homepage": "https://github.com/dominictarr/multiblob",
@@ -11,13 +11,15 @@ "repository": {
   "dependencies": {
+    "blake2s": "~1.0.1",
+    "cont": "~1.0.1",
+    "explain-error": "~1.0.1",
     "mkdirp": "~0.5.0",
-    "pull-stream": "~2.26.0",
-    "cont": "~1.0.1",
-    "blake2s": "~1.0.1",
+    "pull-cat": "^1.1.8",
     "pull-defer": "~0.1.1",
-    "stream-to-pull-stream": "~1.6.1",
-    "explain-error": "~1.0.1",
     "pull-glob": "~1.0.1",
+    "pull-notify": "0.0.0",
+    "pull-paramap": "~1.1.3",
+    "pull-stream": "~2.26.0",
     "rc": "~0.5.4",
     "rimraf": "~2.2.8",
-    "pull-paramap": "~1.1.3"
+    "stream-to-pull-stream": "~1.6.1"
   },
@@ -24,0 +26,0 @@ "devDependencies": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

18076

increased by14%

Number of package files

11

increased by10%

Lines of code

509

increased by17.55%

Worsened metrics

Dependency count

13

increased by18.18%

Dependency changes

• + Addedpull-cat@^1.1.8

• + Addedpull-notify@0.0.0

• + Addedpull-cat@1.1.11(transitive)

• + Addedpull-core@1.0.0(transitive)

• + Addedpull-notify@0.0.0(transitive)

• + Addedpull-pushable@1.1.4(transitive)

• + Addedpull-stream@2.18.3(transitive)