refactor: use streaming for cli refs and refs local

Author: dirkmc

src/cli/commands/refs-local.js

@@ -10,14 +10,21 @@ module.exports = {
   handler ({ getIpfs, resolve }) {
     resolve((async () => {
       const ipfs = await getIpfs()
-      const refs = await ipfs.refs.local()
-      for (const ref of refs) {
-        if (ref.err) {
-          print(ref.err, true, true)
-        } else {
-          print(ref.ref)
-        }
-      }
+
+      return new Promise((resolve, reject) => {
+        const stream = ipfs.refs.localReadableStream()
+
+        stream.on('error', reject)
+        stream.on('end', resolve)
+
+        stream.on('data', (ref) => {
+          if (ref.err) {
+            print(ref.err, true, true)
+          } else {
+            print(ref.ref)
+          }
+        })
+      })
     })())
   }
 }

src/cli/commands/refs.js

@@ -45,14 +45,21 @@ module.exports = {
 
       const ipfs = await getIpfs()
       const k = [key].concat(keys)
-      const refs = await ipfs.refs(k, { recursive, format, edges, unique, maxDepth })
-      for (const ref of refs) {
-        if (ref.err) {
-          print(ref.err, true, true)
-        } else {
-          print(ref.ref)
-        }
-      }
+
+      return new Promise((resolve, reject) => {
+        const stream = ipfs.refsReadableStream(k, { recursive, format, edges, unique, maxDepth })
+
+        stream.on('error', reject)
+        stream.on('end', resolve)
+
+        stream.on('data', (ref) => {
+          if (ref.err) {
+            print(ref.err, true, true)
+          } else {
+            print(ref.ref)
+          }
+        })
+      })
     })())
   }
 }