fix: use pipeline customisation instead of bloating importer

Author: achingbrain

package.json

@@ -73,7 +73,7 @@
     "ipfs-multipart": "^0.3.0",
     "ipfs-unixfs": "^0.3.0",
     "ipfs-unixfs-exporter": "^0.40.0",
-    "ipfs-unixfs-importer": "ipfs/js-ipfs-unixfs-importer#support-dagnodes-as-content",
+    "ipfs-unixfs-importer": "ipfs/js-ipfs-unixfs-importer#expose-internals-for-customisation",
     "ipfs-utils": "^0.4.2",
     "ipld-dag-pb": "^0.18.0",
     "it-last": "^1.0.1",

src/core/chmod.js

@@ -18,6 +18,7 @@ const exporter = require('ipfs-unixfs-exporter')
 const last = require('it-last')
 const cp = require('./cp')
 const rm = require('./rm')
+const persist = require('ipfs-unixfs-importer/src/utils/persist')
 
 const defaultOptions = {
   flush: true,
@@ -191,7 +192,23 @@ module.exports = (context) => {
             }
           }
         },
-        (source) => importer(source, context.ipld, options),
+        (source) => importer(source, context.ipld, {
+          ...options,
+          dagBuilder: async function * (source, ipld, options) {
+            for await (const entry of source) {
+              yield async function () {
+                const cid = await persist(entry.content, ipld, options)
+
+                return {
+                  cid,
+                  path: entry.path,
+                  unixfs: UnixFS.unmarshal(entry.content.Data),
+                  node: entry.content
+                }
+              }
+            }
+          }
+        }),
         (nodes) => last(nodes)
       )