fix: use "ipld" instead of "ipld-resolver"

The "ipld-resolver" has been renamed to just "ipld".

Author: vmx

package.json

@@ -60,8 +60,8 @@
     "cids": "~0.5.2",
     "deep-extend": "~0.5.0",
     "ipfs-unixfs": "~0.1.14",
+    "ipld": "^0.15.0",
     "ipld-dag-pb": "~0.13.1",
-    "ipld-resolver": "~0.14.1",
     "left-pad": "^1.2.0",
     "lodash": "^4.17.5",
     "multihashes": "~0.4.13",

src/builder/builder.js

@@ -19,7 +19,7 @@ const defaultOptions = {
   }
 }
 
-module.exports = function (createChunker, ipldResolver, createReducer, _options) {
+module.exports = function (createChunker, ipld, createReducer, _options) {
   const options = extend({}, defaultOptions, _options)
 
   return function (source) {
@@ -69,7 +69,7 @@ module.exports = function (createChunker, ipldResolver, createReducer, _options)
           cid = cid.toV1()
         }
 
-        ipldResolver.put(node, { cid }, (err) => cb(err, node))
+        ipld.put(node, { cid }, (err) => cb(err, node))
       }
     ], (err, node) => {
       if (err) {
@@ -92,7 +92,7 @@ module.exports = function (createChunker, ipldResolver, createReducer, _options)
       return callback(new Error('invalid content'))
     }
 
-    const reducer = createReducer(reduce(file, ipldResolver, options), options)
+    const reducer = createReducer(reduce(file, ipld, options), options)
 
     let previous
     let count = 0
@@ -121,7 +121,7 @@ module.exports = function (createChunker, ipldResolver, createReducer, _options)
           cid = cid.toV1()
         }
 
-        ipldResolver.put(leaf.DAGNode, { cid }, (err) => callback(err, leaf))
+        ipld.put(leaf.DAGNode, { cid }, (err) => callback(err, leaf))
       }),
       pull.map((leaf) => {
         return {

src/builder/create-build-stream.js

@@ -3,7 +3,7 @@
 const pullPushable = require('pull-pushable')
 const pullWrite = require('pull-write')
 
-module.exports = function createBuildStream (createStrategy, ipldResolver, options) {
+module.exports = function createBuildStream (createStrategy, _ipld, options) {
   const source = pullPushable()
 
   const sink = pullWrite(

src/builder/index.js

@@ -16,17 +16,17 @@ const defaultOptions = {
   reduceSingleLeafToSelf: false
 }
 
-module.exports = function (Chunker, ipldResolver, _options) {
+module.exports = function (Chunker, ipld, _options) {
   assert(Chunker, 'Missing chunker creator function')
-  assert(ipldResolver, 'Missing IPLD Resolver')
+  assert(ipld, 'Missing IPLD')
 
   const options = Object.assign({}, defaultOptions, _options)
 
   const strategyName = options.strategy
   const reducer = reducers[strategyName]
   assert(reducer, 'Unknown importer build strategy name: ' + strategyName)
 
-  const createStrategy = Builder(Chunker, ipldResolver, reducer, options)
+  const createStrategy = Builder(Chunker, ipld, reducer, options)
 
-  return createBuildStream(createStrategy, ipldResolver, options)
+  return createBuildStream(createStrategy, ipld, options)
 }

src/builder/reduce.js

@@ -8,7 +8,7 @@ const CID = require('cids')
 const DAGLink = dagPB.DAGLink
 const DAGNode = dagPB.DAGNode
 
-module.exports = function (file, ipldResolver, options) {
+module.exports = function (file, ipld, options) {
   return function (leaves, callback) {
     if (leaves.length === 1 && (leaves[0].single || options.reduceSingleLeafToSelf)) {
       const leave = leaves[0]
@@ -42,7 +42,7 @@ module.exports = function (file, ipldResolver, options) {
           cid = cid.toV1()
         }
 
-        ipldResolver.put(node, { cid }, (err) => cb(err, node))
+        ipld.put(node, { cid }, (err) => cb(err, node))
       }
     ], (err, node) => {
       if (err) {

src/importer/dir-flat.js

@@ -48,7 +48,7 @@ class DirFlat extends Dir {
     )
   }
 
-  flush (path, ipldResolver, source, callback) {
+  flush (path, ipld, source, callback) {
     const links = Object.keys(this._children)
       .map((key) => {
         const child = this._children[key]
@@ -70,7 +70,7 @@ class DirFlat extends Dir {
             cid = cid.toV1()
           }
 
-          ipldResolver.put(node, { cid }, (err) => callback(err, node))
+          ipld.put(node, { cid }, (err) => callback(err, node))
         },
         (node, callback) => {
           this.multihash = node.multihash

src/importer/dir-sharded.js

@@ -70,8 +70,8 @@ class DirSharded extends Dir {
     this._bucket.eachLeafSeries(iterator, callback)
   }
 
-  flush (path, ipldResolver, source, callback) {
-    flush(this._options, this._bucket, path, ipldResolver, source, (err, node) => {
+  flush (path, ipld, source, callback) {
+    flush(this._options, this._bucket, path, ipld, source, (err, node) => {
       if (err) {
         callback(err)
       } else {
@@ -89,7 +89,7 @@ function createDirSharded (props, _options) {
   return new DirSharded(props, _options)
 }
 
-function flush (options, bucket, path, ipldResolver, source, callback) {
+function flush (options, bucket, path, ipld, source, callback) {
   const children = bucket._children // TODO: intromission
   let index = 0
   const links = []
@@ -119,7 +119,7 @@ function flush (options, bucket, path, ipldResolver, source, callback) {
   function collectChild (child, index, callback) {
     const labelPrefix = leftPad(index.toString(16).toUpperCase(), 2, '0')
     if (Bucket.isBucket(child)) {
-      flush(options, child, path, ipldResolver, null, (err, node) => {
+      flush(options, child, path, ipld, null, (err, node) => {
         if (err) {
           callback(err)
           return // early
@@ -154,7 +154,7 @@ function flush (options, bucket, path, ipldResolver, source, callback) {
             cid = cid.toV1()
           }
 
-          ipldResolver.put(node, { cid }, (err) => callback(err, node))
+          ipld.put(node, { cid }, (err) => callback(err, node))
         },
         (node, callback) => {
           const pushable = {

src/importer/flush-tree.js

@@ -9,7 +9,7 @@ const waterfall = require('async/waterfall')
 const DAGLink = dagPB.DAGLink
 const DAGNode = dagPB.DAGNode
 
-module.exports = (files, ipldResolver, source, callback) => {
+module.exports = (files, ipld, source, callback) => {
   // 1) convert files to a tree
   const fileTree = createTree(files)
 
@@ -26,7 +26,7 @@ module.exports = (files, ipldResolver, source, callback) => {
   const sizeIndex = createSizeIndex(files)
 
   // 3) bottom up flushing
-  traverse(fileTree, sizeIndex, null, ipldResolver, source, callback)
+  traverse(fileTree, sizeIndex, null, ipld, source, callback)
 }
 
 /*
@@ -106,13 +106,13 @@ function createSizeIndex (files) {
  *  If the value is not an object
  *    add as a link to the dirNode
  */
-function traverse (tree, sizeIndex, path, ipldResolver, source, done) {
+function traverse (tree, sizeIndex, path, ipld, source, done) {
   mapValues(tree, (node, key, cb) => {
     if (isLeaf(node)) {
       return cb(null, node)
     }
 
-    traverse(node, sizeIndex, path ? `${path}/${key}` : key, ipldResolver, source, cb)
+    traverse(node, sizeIndex, path ? `${path}/${key}` : key, ipld, source, cb)
   }, (err, tree) => {
     if (err) {
       return done(err)
@@ -135,7 +135,7 @@ function traverse (tree, sizeIndex, path, ipldResolver, source, done) {
       (node, cb) => {
         sizeIndex[mh.toB58String(node.multihash)] = node.size
 
-        ipldResolver.put(node, {
+        ipld.put(node, {
           cid: new CID(node.multihash)
         }, (err) => cb(err, node))
       }

src/importer/index.js

@@ -17,7 +17,7 @@ const defaultOptions = {
   chunker: 'fixed'
 }
 
-module.exports = function (ipldResolver, _options) {
+module.exports = function (ipld, _options) {
   const options = Object.assign({}, defaultOptions, _options)
   const Chunker = chunkers[options.chunker]
   assert(Chunker, 'Unknkown chunker named ' + options.chunker)
@@ -39,9 +39,9 @@ module.exports = function (ipldResolver, _options) {
     source: pushable()
   }
 
-  const dagStream = DAGBuilder(Chunker, ipldResolver, options)
+  const dagStream = DAGBuilder(Chunker, ipld, options)
 
-  const treeBuilder = createTreeBuilder(ipldResolver, options)
+  const treeBuilder = createTreeBuilder(ipld, options)
   const treeBuilderStream = treeBuilder.stream()
   const pausable = pause(() => {})
 

src/importer/tree-builder.js

@@ -18,7 +18,7 @@ const defaultOptions = {
   onlyHash: false
 }
 
-function createTreeBuilder (ipldResolver, _options) {
+function createTreeBuilder (ipld, _options) {
   const options = Object.assign({}, defaultOptions, _options)
 
   const queue = createQueue(consumeQueue, 1)
@@ -202,7 +202,7 @@ function createTreeBuilder (ipldResolver, _options) {
     // don't flush directory unless it's been modified
 
     tree.dirty = false
-    tree.flush(path, ipldResolver, stream.source, (err, node) => {
+    tree.flush(path, ipld, stream.source, (err, node) => {
       if (err) {
         callback(err)
       } else {