catPullStream

Author: daviddias

package.json

@@ -45,11 +45,13 @@
     "peer-info": "~0.11.1",
     "promisify-es6": "^1.0.3",
     "pull": "^2.1.1",
+    "pull-defer": "^0.2.2",
     "pull-pushable": "^2.1.1",
     "pump": "^1.0.2",
     "qs": "^6.5.1",
     "readable-stream": "^2.3.3",
     "stream-http": "^2.7.2",
+    "stream-to-pull-stream": "^1.7.2",
     "streamifier": "^0.1.1",
     "tar-stream": "^1.5.5"
   },

src/files/cat-pull-stream.js

@@ -0,0 +1,30 @@
+'use strict'
+
+const cleanCID = require('../utils/clean-cid')
+const v = require('is-ipfs')
+const toPull = require('stream-to-pull-stream')
+const deferred = require('pull-defer')
+
+module.exports = (send) => {
+  return (hash, opts) => {
+    opts = opts || {}
+
+    const p = deferred.source()
+
+    try {
+      hash = cleanCID(hash)
+    } catch (err) {
+      if (!v.ipfsPath(hash)) {
+        return p.end(err)
+      }
+    }
+
+    send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
+      if (err) { return p.end(err) }
+
+      p.resolve(toPull(stream))
+    })
+
+    return p
+  }
+}

src/files/index.js

@@ -11,7 +11,7 @@ module.exports = (arg) => {
     addPullStream: require('./add-pull-stream')(send),
     cat: require('./cat')(send),
     catReadableStream: require('./cat-readable-stream')(send),
-    // catPullStream: require('./cat-pull-stream')(send),
+    catPullStream: require('./cat-pull-stream')(send),
     get: require('./get')(send),
     // getReadableStream: require('./get-readable-stream')(send),
     // getPullStream: require('./get-pull-stream')(send),

src/utils/load-commands.js

@@ -8,7 +8,7 @@ function requireCommands () {
     addPullStream: require('../files/add-pull-stream'),
     cat: require('../files/cat'),
     catReadableStream: require('../files/cat-readable-stream'),
-    // catPullStream: require('../files/cat-pull-stream'),
+    catPullStream: require('../files/cat-pull-stream'),
     get: require('../files/get'),
     // getReadableStream: require('../files/get-readable-stream'),
     // getPullStream: require('../files/get-pull-stream'),