Skip to content
This repository was archived by the owner on Jun 27, 2023. It is now read-only.

Commit 62b6cb1

Browse files
committed
gx update and fix code to use new Cid type
1 parent 76afbe2 commit 62b6cb1

File tree

3 files changed

+26
-26
lines changed

3 files changed

+26
-26
lines changed

io/pbdagreader.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ type PBDagReader struct {
2929
promises []*ipld.NodePromise
3030

3131
// the cid of each child of the current node
32-
links []*cid.Cid
32+
links []cid.Cid
3333

3434
// the index of the child link currently being read from
3535
linkPosition int
@@ -151,9 +151,9 @@ func (dr *PBDagReader) loadBufNode(node ipld.Node) error {
151151
}
152152
}
153153

154-
func getLinkCids(n ipld.Node) []*cid.Cid {
154+
func getLinkCids(n ipld.Node) []cid.Cid {
155155
links := n.Links()
156-
out := make([]*cid.Cid, 0, len(links))
156+
out := make([]cid.Cid, 0, len(links))
157157
for _, l := range links {
158158
out = append(out, l.Cid)
159159
}

mod/dagmodifier.go

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -233,33 +233,33 @@ func (dm *DagModifier) Sync() error {
233233

234234
// modifyDag writes the data in 'dm.wrBuf' over the data in 'node' starting at 'offset'
235235
// returns the new key of the passed in node.
236-
func (dm *DagModifier) modifyDag(n ipld.Node, offset uint64) (*cid.Cid, error) {
236+
func (dm *DagModifier) modifyDag(n ipld.Node, offset uint64) (cid.Cid, error) {
237237
// If we've reached a leaf node.
238238
if len(n.Links()) == 0 {
239239
switch nd0 := n.(type) {
240240
case *mdag.ProtoNode:
241241
f, err := ft.FromBytes(nd0.Data())
242242
if err != nil {
243-
return nil, err
243+
return cid.Cid{}, err
244244
}
245245

246246
_, err = dm.wrBuf.Read(f.Data[offset:])
247247
if err != nil && err != io.EOF {
248-
return nil, err
248+
return cid.Cid{}, err
249249
}
250250

251251
// Update newly written node..
252252
b, err := proto.Marshal(f)
253253
if err != nil {
254-
return nil, err
254+
return cid.Cid{}, err
255255
}
256256

257257
nd := new(mdag.ProtoNode)
258258
nd.SetData(b)
259259
nd.SetCidBuilder(nd0.CidBuilder())
260260
err = dm.dagserv.Add(dm.ctx, nd)
261261
if err != nil {
262-
return nil, err
262+
return cid.Cid{}, err
263263
}
264264

265265
return nd.Cid(), nil
@@ -273,7 +273,7 @@ func (dm *DagModifier) modifyDag(n ipld.Node, offset uint64) (*cid.Cid, error) {
273273
// copy in new data
274274
n, err := dm.wrBuf.Read(bytes[offset:])
275275
if err != nil && err != io.EOF {
276-
return nil, err
276+
return cid.Cid{}, err
277277
}
278278

279279
// copy remaining data
@@ -284,11 +284,11 @@ func (dm *DagModifier) modifyDag(n ipld.Node, offset uint64) (*cid.Cid, error) {
284284

285285
nd, err := mdag.NewRawNodeWPrefix(bytes, nd0.Cid().Prefix())
286286
if err != nil {
287-
return nil, err
287+
return cid.Cid{}, err
288288
}
289289
err = dm.dagserv.Add(dm.ctx, nd)
290290
if err != nil {
291-
return nil, err
291+
return cid.Cid{}, err
292292
}
293293

294294
return nd.Cid(), nil
@@ -297,12 +297,12 @@ func (dm *DagModifier) modifyDag(n ipld.Node, offset uint64) (*cid.Cid, error) {
297297

298298
node, ok := n.(*mdag.ProtoNode)
299299
if !ok {
300-
return nil, ErrNotUnixfs
300+
return cid.Cid{}, ErrNotUnixfs
301301
}
302302

303303
f, err := ft.FromBytes(node.Data())
304304
if err != nil {
305-
return nil, err
305+
return cid.Cid{}, err
306306
}
307307

308308
var cur uint64
@@ -311,20 +311,20 @@ func (dm *DagModifier) modifyDag(n ipld.Node, offset uint64) (*cid.Cid, error) {
311311
if cur+bs > offset {
312312
child, err := node.Links()[i].GetNode(dm.ctx, dm.dagserv)
313313
if err != nil {
314-
return nil, err
314+
return cid.Cid{}, err
315315
}
316316

317317
k, err := dm.modifyDag(child, offset-cur)
318318
if err != nil {
319-
return nil, err
319+
return cid.Cid{}, err
320320
}
321321

322322
node.Links()[i].Cid = k
323323

324324
// Recache serialized node
325325
_, err = node.EncodeProtobuf(true)
326326
if err != nil {
327-
return nil, err
327+
return cid.Cid{}, err
328328
}
329329

330330
if dm.wrBuf.Len() == 0 {

package.json

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -32,15 +32,15 @@
3232
},
3333
{
3434
"author": "why",
35-
"hash": "QmRDaC5z6yXkXTTSWzaxs2sSVBon5RRCN6eNtMmpuHtKCr",
35+
"hash": "QmSRe5UvVPLJ6LAtVH9gQZwEL4nbck5b5zNe4MChh3LJHk",
3636
"name": "go-merkledag",
37-
"version": "1.0.13"
37+
"version": "1.1.0"
3838
},
3939
{
4040
"author": "hector",
41-
"hash": "QmXD4grfThQ4LwVoEEfe4dgR7ukmbV9TppM5Q4SPowp7hU",
41+
"hash": "QmNkDLE6uKA69ucLesAjHkE3y7XAHTbn9tKYcpFtR2CuXE",
4242
"name": "go-ipfs-posinfo",
43-
"version": "0.0.6"
43+
"version": "0.1.0"
4444
},
4545
{
4646
"author": "Stebalien",
@@ -50,15 +50,15 @@
5050
},
5151
{
5252
"author": "hsanjuan",
53-
"hash": "QmXzBbJo2sLf3uwjNTeoWYiJV7CjAhkiA4twtLvwJSSNdK",
53+
"hash": "QmSfbTprAMaCPSVJhAnDyCHs4ohsnrAE4x2dQLSvSmYqZu",
5454
"name": "go-ipfs-chunker",
55-
"version": "0.0.11"
55+
"version": "0.1.0"
5656
},
5757
{
5858
"author": "whyrusleeping",
59-
"hash": "QmZFbDTY9jfSBms2MchvYM9oYRbAF19K7Pby47yDBfpPrb",
59+
"hash": "QmcRoKTXnq18qQRZFa4jWwWvMQkxzWRpxCwcpCCFgnLUGi",
6060
"name": "go-cid",
61-
"version": "0.8.0"
61+
"version": "1.0.0"
6262
},
6363
{
6464
"author": "whyrusleeping",
@@ -68,9 +68,9 @@
6868
},
6969
{
7070
"author": "whyrusleeping",
71-
"hash": "QmX5CsuHyVZeTLxgRSYkgLSDQKb9UjE8xnhQzCEJWWWFsC",
71+
"hash": "QmRurKMTJEe88d8LQHeDDqc1sBf4wZVJ8PvjVqu6gEw5ee",
7272
"name": "go-ipld-format",
73-
"version": "0.5.8"
73+
"version": "0.6.0"
7474
}
7575
],
7676
"gxVersion": "0.12.1",

0 commit comments

Comments
 (0)