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

Commit a536678

Browse files
achingbrainachingbrain
committed
chore: upgrade dag-pb to the new, new api
1 parent 1a08a28 commit a536678

File tree

11 files changed

+34
-34
lines changed

11 files changed

+34
-34
lines changed

‎package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@
5050
"ipfs-unixfs": "~0.1.16",
5151
"ipfs-utils": "~0.1.0",
5252
"ipld-dag-cbor": "~0.15.0",
53-
"ipld-dag-pb": "~0.17.3",
53+
"ipld-dag-pb": "^0.18.1",
5454
"is-ipfs": "~0.6.1",
5555
"is-plain-object": "^3.0.0",
5656
"it-pushable": "^1.2.1",

‎src/dag/get.js

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ module.exports = (createCommon, options) => {
4949
const someData = Buffer.from('some other data')
5050

5151
try {
52-
pbNode = DAGNode.create(someData)
52+
pbNode = new DAGNode(someData)
5353
} catch (err) {
5454
return cb(err)
5555
}
@@ -62,15 +62,15 @@ module.exports = (createCommon, options) => {
6262
},
6363
(cb) => {
6464
try {
65-
nodePb = DAGNode.create(Buffer.from('I am inside a Protobuf'))
65+
nodePb = new DAGNode(Buffer.from('I am inside a Protobuf'))
6666
} catch (err) {
6767
return cb(err)
6868
}
6969

7070
cb()
7171
},
7272
(cb) => {
73-
dagPB.util.cid(dagPB.util.serialize(nodePb))
73+
dagPB.util.cid(nodePb.serialize())
7474
.then(cid => {
7575
cidPb = cid
7676
cb()
@@ -139,7 +139,7 @@ module.exports = (createCommon, options) => {
139139

140140
const node = result.value
141141

142-
dagPB.util.cid(dagPB.util.serialize(node))
142+
dagPB.util.cid(node.serialize())
143143
.then(cid => {
144144
expect(cid).to.eql(cidPb)
145145
done()
@@ -232,7 +232,7 @@ module.exports = (createCommon, options) => {
232232
it('should get a node added as CIDv0 with a CIDv1', done => {
233233
const input = Buffer.from(`TEST${Date.now()}`)
234234

235-
const node = dagPB.DAGNode.create(input)
235+
const node = new DAGNode(input)
236236

237237
ipfs.dag.put(node, { format: 'dag-pb', hashAlg: 'sha2-256' }, (err, cid) => {
238238
expect(err).to.not.exist()

‎src/dag/put.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ module.exports = (createCommon, options) => {
4242
const someData = Buffer.from('some data')
4343

4444
try {
45-
pbNode = DAGNode.create(someData)
45+
pbNode = new DAGNode(someData)
4646
} catch (err) {
4747
return done(err)
4848
}

‎src/dag/tree.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,15 +43,15 @@ module.exports = (createCommon, options) => {
4343
series([
4444
(cb) => {
4545
try {
46-
nodePb = dagPB.DAGNode.create(Buffer.from('I am inside a Protobuf'))
46+
nodePb = new DAGNode(Buffer.from('I am inside a Protobuf'))
4747
} catch (err) {
4848
return cb(err)
4949
}
5050

5151
cb()
5252
},
5353
(cb) => {
54-
dagPB.util.cid(dagPB.util.serialize(nodePb))
54+
dagPB.util.cid(nodePb.serialize())
5555
.then(cid => {
5656
cidPb = cid
5757
cb()

‎src/object/get.js

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ module.exports = (createCommon, options) => {
6767
// because js-ipfs-api can't infer if the
6868
// returned Data is Buffer or String
6969
if (typeof node.Data === 'string') {
70-
node = DAGNode.create(Buffer.from(node.Data), node.Links, node.size)
70+
node = new DAGNode(Buffer.from(node.Data), node.Links, node.size)
7171
}
7272

7373
node2 = node
@@ -96,7 +96,7 @@ module.exports = (createCommon, options) => {
9696
// because js-ipfs-api can't infer if the
9797
// returned Data is Buffer or String
9898
if (typeof node2.Data === 'string') {
99-
node2 = DAGNode.create(Buffer.from(node2.Data), node2.Links, node2.size)
99+
node2 = new DAGNode(Buffer.from(node2.Data), node2.Links, node2.size)
100100
}
101101

102102
expect(node1.Data).to.deep.equal(node2.Data)
@@ -133,7 +133,7 @@ module.exports = (createCommon, options) => {
133133
// because js-ipfs-api can't infer if the
134134
// returned Data is Buffer or String
135135
if (typeof node.Data === 'string') {
136-
node = DAGNode.create(Buffer.from(node.Data), node.Links, node.size)
136+
node = new DAGNode(Buffer.from(node.Data), node.Links, node.size)
137137
}
138138

139139
node2 = node
@@ -161,7 +161,7 @@ module.exports = (createCommon, options) => {
161161
// because js-ipfs-api can't infer if the
162162
// returned Data is Buffer or String
163163
if (typeof node2.Data === 'string') {
164-
node2 = DAGNode.create(Buffer.from(node2.Data), node2.Links, node2.size)
164+
node2 = new DAGNode(Buffer.from(node2.Data), node2.Links, node2.size)
165165
}
166166

167167
expect(node1.Data).to.deep.equal(node2.Data)
@@ -178,7 +178,7 @@ module.exports = (createCommon, options) => {
178178
series([
179179
(cb) => {
180180
try {
181-
node1a = DAGNode.create(Buffer.from('Some data 1'))
181+
node1a = new DAGNode(Buffer.from('Some data 1'))
182182
} catch (err) {
183183
return cb(err)
184184
}
@@ -187,7 +187,7 @@ module.exports = (createCommon, options) => {
187187
},
188188
(cb) => {
189189
try {
190-
node2 = DAGNode.create(Buffer.from('Some data 2'))
190+
node2 = new DAGNode(Buffer.from('Some data 2'))
191191
} catch (err) {
192192
return cb(err)
193193
}
@@ -219,7 +219,7 @@ module.exports = (createCommon, options) => {
219219
// because js-ipfs-api can't infer if the
220220
// returned Data is Buffer or String
221221
if (typeof node.Data === 'string') {
222-
node = DAGNode.create(Buffer.from(node.Data), node.Links, node.size)
222+
node = new DAGNode(Buffer.from(node.Data), node.Links, node.size)
223223
}
224224

225225
node1c = node
@@ -262,7 +262,7 @@ module.exports = (createCommon, options) => {
262262
// because js-ipfs-api can't infer if the
263263
// returned Data is Buffer or String
264264
if (typeof node.Data === 'string') {
265-
node = DAGNode.create(Buffer.from(node.Data), node.Links, node.size)
265+
node = new DAGNode(Buffer.from(node.Data), node.Links, node.size)
266266
}
267267
node1b = node
268268
cb()
@@ -305,7 +305,7 @@ module.exports = (createCommon, options) => {
305305
// because js-ipfs-api can't infer if the
306306
// returned Data is Buffer or String
307307
if (typeof node.Data === 'string') {
308-
node = DAGNode.create(Buffer.from(node.Data), node.Links, node.size)
308+
node = new DAGNode(Buffer.from(node.Data), node.Links, node.size)
309309
}
310310
node1b = node
311311
cb()

‎src/object/links.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ module.exports = (createCommon, options) => {
8080
series([
8181
(cb) => {
8282
try {
83-
node1a = DAGNode.create(Buffer.from('Some data 1'))
83+
node1a = new DAGNode(Buffer.from('Some data 1'))
8484
} catch (err) {
8585
return cb(err)
8686
}
@@ -89,7 +89,7 @@ module.exports = (createCommon, options) => {
8989
},
9090
(cb) => {
9191
try {
92-
node2 = DAGNode.create(Buffer.from('Some data 2'))
92+
node2 = new DAGNode(Buffer.from('Some data 2'))
9393
} catch (err) {
9494
return cb(err)
9595
}
@@ -104,7 +104,7 @@ module.exports = (createCommon, options) => {
104104
.then(node => {
105105
node1b = node
106106

107-
return dagPB.util.cid(dagPB.util.serialize(node1b))
107+
return dagPB.util.cid(node1b.serialize())
108108
})
109109
.then(cid => {
110110
node1bCid = cid

‎src/object/patch/add-link.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ module.exports = (createCommon, options) => {
6161
},
6262
(cb) => {
6363
try {
64-
node1a = DAGNode.create(obj.Data, obj.Links)
64+
node1a = new DAGNode(obj.Data, obj.Links)
6565
} catch (err) {
6666
return cb(err)
6767
}
@@ -70,7 +70,7 @@ module.exports = (createCommon, options) => {
7070
},
7171
(cb) => {
7272
try {
73-
node2 = DAGNode.create(Buffer.from('some other node'))
73+
node2 = new DAGNode(Buffer.from('some other node'))
7474
} catch (err) {
7575
return cb(err)
7676
}
@@ -95,7 +95,7 @@ module.exports = (createCommon, options) => {
9595
.then(node => {
9696
node1b = node
9797

98-
return dagPB.util.cid(dagPB.util.serialize(node), {
98+
return dagPB.util.cid(node.serialize(), {
9999
cidVersion: 0
100100
})
101101
})

‎src/object/put.js

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ module.exports = (createCommon, options) => {
100100
series([
101101
(cb) => {
102102
try {
103-
node = DAGNode.create(Buffer.from(hat()))
103+
node = new DAGNode(Buffer.from(hat()))
104104
} catch (err) {
105105
return cb(err)
106106
}
@@ -109,7 +109,7 @@ module.exports = (createCommon, options) => {
109109
},
110110
(cb) => {
111111
try {
112-
serialized = dagPB.util.serialize(node)
112+
serialized = node.serialize()
113113
} catch (err) {
114114
return cb(err)
115115
}
@@ -146,7 +146,7 @@ module.exports = (createCommon, options) => {
146146
})
147147

148148
it('should put a Protobuf DAGNode', (done) => {
149-
const dNode = DAGNode.create(Buffer.from(hat()))
149+
const dNode = new DAGNode(Buffer.from(hat()))
150150

151151
ipfs.object.put(dNode, (err, cid) => {
152152
expect(err).to.not.exist()
@@ -175,7 +175,7 @@ module.exports = (createCommon, options) => {
175175
series([
176176
(cb) => {
177177
try {
178-
node1a = DAGNode.create(Buffer.from(hat()))
178+
node1a = new DAGNode(Buffer.from(hat()))
179179
} catch (err) {
180180
return cb(err)
181181
}
@@ -184,7 +184,7 @@ module.exports = (createCommon, options) => {
184184
},
185185
(cb) => {
186186
try {
187-
node2 = DAGNode.create(Buffer.from(hat()))
187+
node2 = new DAGNode(Buffer.from(hat()))
188188
} catch (err) {
189189
return cb(err)
190190
}

‎src/object/stat.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ module.exports = (createCommon, options) => {
115115
series([
116116
(cb) => {
117117
try {
118-
node1a = DAGNode.create(Buffer.from('Some data 1'))
118+
node1a = new DAGNode(Buffer.from('Some data 1'))
119119
} catch (err) {
120120
return cb(err)
121121
}
@@ -124,7 +124,7 @@ module.exports = (createCommon, options) => {
124124
},
125125
(cb) => {
126126
try {
127-
node2 = DAGNode.create(Buffer.from('Some data 2'))
127+
node2 = new DAGNode(Buffer.from('Some data 2'))
128128
} catch (err) {
129129
return cb(err)
130130
}

‎src/object/utils.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,14 +5,14 @@ const dagPB = require('ipld-dag-pb')
55
const { DAGNode, DAGLink } = dagPB
66

77
const calculateCid = promisify((node, cb) => {
8-
dagPB.util.cid(dagPB.util.serialize(node), {
8+
dagPB.util.cid(node.serialize(), {
99
cidVersion: 0
1010
})
1111
.then(cid => cb(null, cid), cb)
1212
})
1313

1414
const createDAGNode = promisify((data, links, cb) => {
15-
cb(null, DAGNode.create(data, links))
15+
cb(null, new DAGNode(data, links))
1616
})
1717

1818
const addLinkToDAGNode = promisify((parent, link, cb) => {

‎src/repo/gc.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -184,7 +184,7 @@ module.exports = (createCommon, options) => {
184184
await ipfs.pin.rm(dataHash)
185185

186186
// Create a link to the data from an object
187-
const obj = await DAGNode.create(Buffer.from('fruit'), [{
187+
const obj = await new DAGNode(Buffer.from('fruit'), [{
188188
Name: 'p',
189189
Hash: dataHash,
190190
TSize: addRes[0].size

0 commit comments

Comments
 (0)