feat: update to latest ipld-resolver

Author: daviddias

src/builder/builder.js

@@ -62,10 +62,7 @@ module.exports = function (createChunker, ipldResolver, createReducer, _options)
     waterfall([
       (cb) => DAGNode.create(d.marshal(), cb),
       (node, cb) => {
-        ipldResolver.put({
-          node: node,
-          cid: new CID(node.multihash)
-        }, (err) => cb(err, node))
+        ipldResolver.put(node, new CID(node.multihash), (err) => cb(err, node))
       }
     ], (err, node) => {
       if (err) {
@@ -104,12 +101,8 @@ module.exports = function (createChunker, ipldResolver, createReducer, _options)
         })
       }),
       pull.asyncMap((leaf, callback) => {
-        ipldResolver.put(
-          {
-            node: leaf.DAGNode,
-            cid: new CID(leaf.DAGNode.multihash)
-          },
-          err => callback(err, leaf)
+        ipldResolver.put(leaf.DAGNode, new CID(leaf.DAGNode.multihash),
+          (err) => callback(err, leaf)
         )
       }),
       pull.map((leaf) => {

src/builder/reduce.js

@@ -34,10 +34,7 @@ module.exports = function (file, ipldResolver, options) {
     waterfall([
       (cb) => DAGNode.create(f.marshal(), links, cb),
       (node, cb) => {
-        ipldResolver.put({
-          node: node,
-          cid: new CID(node.multihash)
-        }, (err) => cb(err, node))
+        ipldResolver.put(node, new CID(node.multihash), (err) => cb(err, node))
       }
     ], (err, node) => {
       if (err) {

src/exporter/dir.js

@@ -30,7 +30,7 @@ function dirExporter (node, name, ipldResolver) {
       path: path.join(name, link.name),
       hash: link.multihash
     })),
-    paramap((item, cb) => ipldResolver.get(new CID(item.hash), (err, n) => {
+    paramap((item, cb) => ipldResolver.get(new CID(item.hash), (err, result) => {
       if (err) {
         return cb(err)
       }
@@ -40,10 +40,12 @@ function dirExporter (node, name, ipldResolver) {
         size: item.size
       }
 
+      const node = result.value
+
       cb(null, switchType(
-        n,
-        () => cat([pull.values([dir]), dirExporter(n, item.path, ipldResolver)]),
-        () => fileExporter(n, item.path, ipldResolver)
+        node,
+        () => cat([pull.values([dir]), dirExporter(node, item.path, ipldResolver)]),
+        () => fileExporter(node, item.path, ipldResolver)
       ))
     })),
     pull.flatten()

src/exporter/file.js

@@ -20,7 +20,8 @@ module.exports = (node, name, ipldResolver) => {
   function visitor (node) {
     return pull(
       pull.values(node.links),
-      paramap((link, cb) => ipldResolver.get(new CID(link.multihash), cb))
+      paramap((link, cb) => ipldResolver.get(new CID(link.multihash), cb)),
+      pull.asyncMap((result, cb) => cb(null, result.value))
     )
   }
 

src/exporter/index.js

@@ -33,7 +33,7 @@ module.exports = (hash, ipldResolver, options) => {
       return pull.empty()
     }
     return pull(
-      ipldResolver.getStream(new CID(item.hash)),
+      ipldResolver._getStream(new CID(item.hash)),
       pull.map((node) => switchType(
         node,
         () => dirExporter(node, item.path, ipldResolver),
@@ -45,7 +45,7 @@ module.exports = (hash, ipldResolver, options) => {
 
   // Traverse the DAG
   return pull(
-    ipldResolver.getStream(new CID(hash)),
+    ipldResolver._getStream(new CID(hash)),
     pull.map((node) => switchType(
       node,
       () => traverse.widthFirst({path: hash, hash}, visitor),

src/importer/flush-tree.js

@@ -135,10 +135,7 @@ function traverse (tree, sizeIndex, path, ipldResolver, source, done) {
       (node, cb) => {
         sizeIndex[mh.toB58String(node.multihash)] = node.size
 
-        ipldResolver.put({
-          node: node,
-          cid: new CID(node.multihash)
-        }, (err) => cb(err, node))
+        ipldResolver.put(node, new CID(node.multihash), (err) => cb(err, node))
       }
     ], (err, node) => {
       if (err) {

test/test-exporter.js

@@ -28,29 +28,26 @@ module.exports = (repo) => {
     it('ensure hash inputs are sanitized', (done) => {
       const hash = 'QmQmZQxSKQppbsWfVzBvg59Cn3DKtsNVQ94bjAxg2h3Lb8'
       const mhBuf = new Buffer(bs58.decode(hash))
+      const cid = new CID(hash)
 
-      pull(
-        ipldResolver.getStream(new CID(hash)),
-        pull.map((node) => UnixFS.unmarshal(node.data)),
-        pull.collect((err, nodes) => {
-          expect(err).to.not.exist
-
-          const unmarsh = nodes[0]
+      ipldResolver.get(cid, (err, result) => {
+        expect(err).to.not.exist
+        const node = result.value
+        const unmarsh = UnixFS.unmarshal(node.data)
 
-          pull(
-            exporter(mhBuf, ipldResolver),
-            pull.collect(onFiles)
-          )
+        pull(
+          exporter(mhBuf, ipldResolver),
+          pull.collect(onFiles)
+        )
 
-          function onFiles (err, files) {
-            expect(err).to.not.exist
-            expect(files).to.have.length(1)
-            expect(files[0]).to.have.property('path', hash)
+        function onFiles (err, files) {
+          expect(err).to.not.exist
+          expect(files).to.have.length(1)
+          expect(files[0]).to.have.property('path', hash)
 
-            fileEql(files[0], unmarsh.data, done)
-          }
-        })
-      )
+          fileEql(files[0], unmarsh.data, done)
+        }
+      })
     })
 
     it('export a file with no links', (done) => {
@@ -59,7 +56,7 @@ module.exports = (repo) => {
       pull(
         zip(
           pull(
-            ipldResolver.getStream(new CID(hash)),
+            ipldResolver._getStream(new CID(hash)),
             pull.map((node) => UnixFS.unmarshal(node.data))
           ),
           exporter(hash, ipldResolver)
@@ -176,7 +173,7 @@ function fileEql (f1, f2, done) {
 
       try {
         if (f2) {
-          expect(Buffer.concat(data)).to.be.eql(f2)
+          expect(Buffer.concat(data)).to.eql(f2)
         } else {
           expect(data).to.exist
         }