.catReadableStream

Author: daviddias

src/files/cat-readable-stream.js

@@ -0,0 +1,29 @@
+'use strict'
+
+const cleanCID = require('../utils/clean-cid')
+const v = require('is-ipfs')
+const Stream = require('readable-stream')
+
+module.exports = (send) => {
+  return (hash, opts) => {
+    opts = opts || {}
+
+    const pt = new Stream.PassThrough()
+
+    try {
+      hash = cleanCID(hash)
+    } catch (err) {
+      if (!v.ipfsPath(hash)) {
+        return pt.destroy(err)
+      }
+    }
+
+    send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
+      if (err) { return pt.destroy(err) }
+
+      stream.pipe(pt)
+    })
+
+    return pt
+  }
+}

src/files/index.js

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

src/utils/load-commands.js

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