.getReadableStream

Author: daviddias

src/files/cat-readable-stream.js

@@ -3,6 +3,7 @@
 const cleanCID = require('../utils/clean-cid')
 const v = require('is-ipfs')
 const Stream = require('readable-stream')
+const pump = require('pump')
 
 module.exports = (send) => {
   return (hash, opts) => {
@@ -21,7 +22,7 @@ module.exports = (send) => {
     send({ path: 'cat', args: hash, buffer: opts.buffer }, (err, stream) => {
       if (err) { return pt.destroy(err) }
 
-      stream.pipe(pt)
+      pump(stream, pt)
     })
 
     return pt

src/files/get-readable-stream.js

@@ -0,0 +1,34 @@
+'use strict'
+
+const cleanCID = require('../utils/clean-cid')
+const TarStreamToObjects = require('../utils/tar-stream-to-objects')
+const v = require('is-ipfs')
+const Stream = require('readable-stream')
+const pump = require('pump')
+
+module.exports = (send) => {
+  return (path, opts) => {
+    opts = opts || {}
+
+    const pt = new Stream.PassThrough({objectMode: true})
+
+    try {
+      path = cleanCID(path)
+    } catch (err) {
+      if (!v.ipfsPath(path)) {
+        return pt.destroy(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 pt.destroy(err) }
+
+      pump(stream, pt)
+    })
+
+    return pt
+  }
+}

src/files/index.js

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

src/utils/load-commands.js

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