.addPullStream

Author: daviddias

package.json

@@ -44,6 +44,8 @@
     "peer-id": "~0.10.2",
     "peer-info": "~0.11.0",
     "promisify-es6": "^1.0.3",
+    "pull": "^2.1.1",
+    "pull-pushable": "^2.1.1",
     "pump": "^1.0.2",
     "qs": "^6.5.1",
     "readable-stream": "^2.3.3",

src/files/add-pull-stream.js

@@ -0,0 +1,30 @@
+'use strict'
+
+const addCmd = require('./add.js')
+const pull = require('pull-stream')
+const pushable = require('pull-pushable')
+
+module.exports = (send) => {
+  const add = addCmd(send)
+
+  return (options) => {
+    options = options || {}
+
+    const source = pushable()
+    const sink = pull.collect((err, tuples) => {
+      if (err) { return source.end(err) }
+
+      add(tuples, options, (err, filesAdded) => {
+        if (err) { return source.end(err) }
+
+        filesAdded.forEach((file) => source.push(file))
+        source.end()
+      })
+    })
+
+    return {
+      sink: sink,
+      source: source
+    }
+  }
+}

src/files/index.js

@@ -8,7 +8,7 @@ module.exports = (arg) => {
   return {
     add: require('./add')(send),
     addReadableStream: require('./add-readable-stream')(send),
-    // addPullStream: require('./add-pull-stream')(send),
+    addPullStream: require('./add-pull-stream')(send),
     cat: require('./cat')(send),
     // catReadableStream: require('./cat-readable-stream')(send),
     // catPullStream: require('./cat-pull-stream')(send),

src/utils/load-commands.js

@@ -5,10 +5,10 @@ function requireCommands () {
     // add and createAddStream alias
     add: require('../files/add'),
     addReadableStream: require('../files/add-readable-stream'),
-    // addPullStream: require('../files/add-pull-stream'),
+    addPullStream: require('../files/add-pull-stream'),
     cat: require('../files/cat'),
     // catReadableStream: require('../files/cat-readable-stream'),
-    // catPullStream: require('../files/add-pull-stream'),
+    // catPullStream: require('../files/cat-pull-stream'),
     get: require('../files/get'),
     // getReadableStream: require('../files/get-readable-stream'),
     // getPullStream: require('../files/get-pull-stream'),