feat: add refsReadableStream()

Author: dirkmc

src/files-regular/index.js

@@ -22,6 +22,7 @@ module.exports = (arg) => {
     lsReadableStream: require('../files-regular/ls-readable-stream')(send),
     lsPullStream: require('../files-regular/ls-pull-stream')(send),
     refs: require('../files-regular/refs')(send),
+    refsReadableStream: require('../files-regular/refs-readable-stream')(send),
     refsPullStream: require('../files-regular/refs-pull-stream')(send)
   }
 }

src/files-regular/refs-readable-stream.js

@@ -0,0 +1,22 @@
+'use strict'
+
+const Stream = require('readable-stream')
+const refs = require('./refs')
+
+module.exports = (arg) => {
+  const refsFn = refs(arg)
+
+  return (args, opts) => {
+    const pt = new Stream.PassThrough({ objectMode: true })
+
+    refsFn(args, opts, (err, res) => {
+      if (err) {
+        return pt.emit('error', err)
+      }
+      res.forEach((item) => pt.write(item))
+      pt.end()
+    })
+
+    return pt
+  }
+}

src/utils/load-commands.js

@@ -19,6 +19,7 @@ function requireCommands () {
     lsReadableStream: require('../files-regular/ls-readable-stream'),
     lsPullStream: require('../files-regular/ls-pull-stream'),
     refs: require('../files-regular/refs'),
+    refsReadableStream: require('../files-regular/refs-readable-stream'),
     refsPullStream: require('../files-regular/refs-pull-stream'),
 
     // Files MFS (Mutable Filesystem)