feat: expose mfs files.read*Stream methods

Author: achingbrain

src/files/index.js

@@ -24,6 +24,8 @@ module.exports = (arg) => {
     rm: require('./rm')(send),
     ls: require('./ls')(send),
     read: require('./read')(send),
+    readReadableStream: require('./read-readable-stream')(send),
+    readPullStream: require('./read-pull-stream')(send),
     write: require('./write')(send),
     mv: require('./mv')(send)
   }

src/files/read-pull-stream.js

@@ -0,0 +1,29 @@
+'use strict'
+
+const toPull = require('stream-to-pull-stream')
+const deferred = require('pull-defer')
+
+module.exports = (send) => {
+  return (args, opts) => {
+    if (typeof (opts) === 'function') {
+      callback = opts
+      opts = {}
+    }
+
+    const p = deferred.source()
+
+    send({
+      path: 'files/read',
+      args: args,
+      qs: opts
+    }, (err, stream) => {
+      if (err) {
+        return p.abort(err)
+      }
+
+      p.resolve(toPull(stream))
+    })
+
+    return p
+  }
+}

src/files/read-readable-stream.js

@@ -0,0 +1,29 @@
+'use strict'
+
+const Stream = require('readable-stream')
+const pump = require('pump')
+
+module.exports = (send) => {
+  return (args, opts) => {
+    if (typeof (opts) === 'function') {
+      callback = opts
+      opts = {}
+    }
+
+    const pt = new Stream.PassThrough()
+
+    send({
+      path: 'files/read',
+      args: args,
+      qs: opts
+    }, (err, stream) => {
+      if (err) {
+        return pt.destroy(err)
+      }
+
+      pump(stream, pt)
+    })
+
+    return pt
+  }
+}