getPullStream

Author: daviddias

src/files/get-pull-stream.js

@@ -0,0 +1,44 @@
+'use strict'
+
+const cleanCID = require('../utils/clean-cid')
+const TarStreamToObjects = require('../utils/tar-stream-to-objects')
+const v = require('is-ipfs')
+const through = require('through2')
+const pull = require('pull-stream')
+const toPull = require('stream-to-pull-stream')
+const deferred = require('pull-defer')
+
+module.exports = (send) => {
+  return (path, opts) => {
+    opts = opts || {}
+
+    const p = deferred.source()
+
+    try {
+      path = cleanCID(path)
+    } catch (err) {
+      if (!v.ipfsPath(path)) {
+        return p.end(err)
+      }
+    }
+
+    const request = { path: 'get', args: path, qs: opts }
+
+    // Convert the response stream to TarStream objects
+    send.andTransform(request, TarStreamToObjects, (err, stream) => {
+      if (err) { return p.end(err) }
+
+      const files = []
+      stream.pipe(through.obj((file, enc, next) => {
+        if (file.content) {
+          files.push({ path: file.path, content: toPull(file.content) })
+        } else {
+          files.push(file)
+        }
+        next()
+      }, () => p.resolve(pull.values(files))))
+    })
+
+    return p
+  }
+}

src/files/index.js

@@ -14,7 +14,7 @@ module.exports = (arg) => {
     catPullStream: require('./cat-pull-stream')(send),
     get: require('./get')(send),
     getReadableStream: require('./get-readable-stream')(send),
-    // getPullStream: require('./get-pull-stream')(send),
+    getPullStream: require('./get-pull-stream')(send),
     cp: require('./cp')(send),
     ls: require('./ls')(send),
     mkdir: require('./mkdir')(send),

src/utils/load-commands.js

@@ -11,7 +11,7 @@ function requireCommands () {
     catPullStream: require('../files/cat-pull-stream'),
     get: require('../files/get'),
     getReadableStream: require('../files/get-readable-stream'),
-    // getPullStream: require('../files/get-pull-stream'),
+    getPullStream: require('../files/get-pull-stream'),
     bitswap: require('../bitswap'),
     block: require('../block'),
     bootstrap: require('../bootstrap'),