Skip to content
This repository was archived by the owner on Aug 12, 2020. It is now read-only.

Commit a80f4d8

Browse files
committed
fix: using the new IPLD API
1 parent db25fb9 commit a80f4d8

File tree

5 files changed

+6
-7
lines changed

5 files changed

+6
-7
lines changed

src/exporter/dir-flat.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ function dirExporter (node, name, ipldResolver, resolve, parent) {
2828
return cb(err)
2929
}
3030

31-
cb(null, resolve(n, item.path, ipldResolver, name, parent))
31+
cb(null, resolve(n.value, item.path, ipldResolver, name, parent))
3232
})),
3333
pull.flatten()
3434
)

src/exporter/dir-hamt-sharded.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ function shardedDirExporter (node, name, ipldResolver, resolve, parent) {
4040
return cb(err)
4141
}
4242

43-
cb(null, resolve(n, item.path, ipldResolver, (dir && dir[0]) || parent))
43+
cb(null, resolve(n.value, item.path, ipldResolver, (dir && dir[0]) || parent))
4444
})),
4545
pull.flatten()
4646
)

src/exporter/index.js

+2-3
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,8 @@ module.exports = (hash, ipldResolver) => {
1616

1717
return pull(
1818
ipldResolver.getStream(new CID(hash)),
19-
pull.map((node) => {
20-
return resolve(node, hash, ipldResolver)
21-
}),
19+
pull.map((result) => result.value),
20+
pull.map((node) => resolve(node, hash, ipldResolver)),
2221
pull.flatten()
2322
)
2423
}

src/importer/dir-flat.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -61,8 +61,8 @@ class DirFlat {
6161
(callback) => DAGNode.create(dir.marshal(), links, callback),
6262
(node, callback) => {
6363
ipldResolver.put(
64+
node,
6465
{
65-
node: node,
6666
cid: new CID(node.multihash)
6767
},
6868
(err) => callback(err, node))

src/importer/dir-sharded.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -147,8 +147,8 @@ function flush (options, bucket, path, ipldResolver, source, callback) {
147147
(callback) => DAGNode.create(dir.marshal(), links, callback),
148148
(node, callback) => {
149149
ipldResolver.put(
150+
node,
150151
{
151-
node: node,
152152
cid: new CID(node.multihash)
153153
},
154154
(err) => callback(err, node))

0 commit comments

Comments
 (0)