Skip to content

Commit 73edd81

Browse files
hannahhowardhannahhoward
committed
feat(deps): update go-graphsync v0.8.0
Update to go-graphsync v0.8.0 with go-ipld-prime linksystem branch & trusted store.
1 parent 8c6657b commit 73edd81

24 files changed

+195
-128
lines changed

‎benchmarks/testinstance/testinstance.go

+4-7
Original file line numberDiff line numberDiff line change
@@ -109,8 +109,7 @@ func Close(instances []Instance) error {
109109
// Instance is a test instance of bitswap + dependencies for integration testing
110110
type Instance struct {
111111
Peer peer.ID
112-
Loader ipld.Loader
113-
Storer ipld.Storer
112+
LinkSystem ipld.LinkSystem
114113
BlockStore blockstore.Blockstore
115114
Graphsync graphsync.GraphExchange
116115
Manager datatransfer.Manager
@@ -164,9 +163,8 @@ func NewInstance(ctx context.Context, net tn.Network, tempDir string, diskBasedD
164163
return Instance{}, err
165164
}
166165

167-
loader := storeutil.LoaderForBlockstore(bstore)
168-
storer := storeutil.StorerForBlockstore(bstore)
169-
gs := gsimpl.New(ctx, gsNet, loader, storer, gsimpl.RejectAllRequestsByDefault())
166+
linkSystem := storeutil.LinkSystemForBlockstore(bstore)
167+
gs := gsimpl.New(ctx, gsNet, linkSystem, gsimpl.RejectAllRequestsByDefault())
170168
transport := gstransport.NewTransport(p, gs)
171169
dt, err := dtimpl.NewDataTransfer(namespace.Wrap(dstore, datastore.NewKey("/data-transfers/transfers")), os.TempDir(), dtNet, transport)
172170
if err != nil {
@@ -198,8 +196,7 @@ func NewInstance(ctx context.Context, net tn.Network, tempDir string, diskBasedD
198196
Peer: p,
199197
Graphsync: gs,
200198
Manager: dt,
201-
Loader: loader,
202-
Storer: storer,
199+
LinkSystem: linkSystem,
203200
BlockStore: bstore,
204201
blockstoreDelay: bsdelay,
205202
ds: dstore,

‎channels/channel_state.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ func (c channelState) BaseCID() cid.Cid { return c.baseCid }
8181
func (c channelState) Selector() ipld.Node {
8282
builder := basicnode.Prototype.Any.NewBuilder()
8383
reader := bytes.NewReader(c.selector.Raw)
84-
err := dagcbor.Decoder(builder, reader)
84+
err := dagcbor.Decode(builder, reader)
8585
if err != nil {
8686
log.Error(err)
8787
}

‎channels/channels_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -393,7 +393,7 @@ func TestMigrationsV0(t *testing.T) {
393393

394394
allSelector := builder.NewSelectorSpecBuilder(basicnode.Prototype.Any).Matcher().Node()
395395
allSelectorBuf := new(bytes.Buffer)
396-
err := dagcbor.Encoder(allSelector, allSelectorBuf)
396+
err := dagcbor.Encode(allSelector, allSelectorBuf)
397397
require.NoError(t, err)
398398
allSelectorBytes := allSelectorBuf.Bytes()
399399

@@ -513,7 +513,7 @@ func TestMigrationsV1(t *testing.T) {
513513
receivedCids := make([][]cid.Cid, numChannels)
514514
allSelector := builder.NewSelectorSpecBuilder(basicnode.Prototype.Any).Matcher().Node()
515515
allSelectorBuf := new(bytes.Buffer)
516-
err := dagcbor.Encoder(allSelector, allSelectorBuf)
516+
err := dagcbor.Encode(allSelector, allSelectorBuf)
517517
require.NoError(t, err)
518518
allSelectorBytes := allSelectorBuf.Bytes()
519519
selfPeer := testutil.GeneratePeers(1)[0]

‎channels/internal/internalchannel_cbor_gen.go

+10-3
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎channels/internal/migrations/v0/v0_cbor_gen.go

+4
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎channels/internal/migrations/v1/v1_cbor_gen.go

+5-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎encoding/encoding.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ func Encode(value Encodable) ([]byte, error) {
2727
}
2828
if ipldEncodable, ok := value.(ipld.Node); ok {
2929
buf := new(bytes.Buffer)
30-
err := dagcbor.Encoder(ipldEncodable, buf)
30+
err := dagcbor.Encode(ipldEncodable, buf)
3131
if err != nil {
3232
return nil, err
3333
}
@@ -79,7 +79,7 @@ type ipldDecoder struct {
7979
func (decoder *ipldDecoder) DecodeFromCbor(encoded []byte) (Encodable, error) {
8080
builder := decoder.style.NewBuilder()
8181
buf := bytes.NewReader(encoded)
82-
err := dagcbor.Decoder(builder, buf)
82+
err := dagcbor.Decode(builder, buf)
8383
if err != nil {
8484
return nil, err
8585
}

‎go.mod

+8-8
Original file line numberDiff line numberDiff line change
@@ -8,30 +8,30 @@ require (
88
github.com/filecoin-project/go-statemachine v0.0.0-20200925024713-05bd7c71fbfe
99
github.com/hannahhoward/cbor-gen-for v0.0.0-20200817222906-ea96cece81f1
1010
github.com/hannahhoward/go-pubsub v0.0.0-20200423002714-8d62886cc36e
11-
github.com/ipfs/go-block-format v0.0.2
11+
github.com/ipfs/go-block-format v0.0.3
1212
github.com/ipfs/go-blockservice v0.1.3
1313
github.com/ipfs/go-cid v0.0.7
1414
github.com/ipfs/go-datastore v0.4.5
15-
github.com/ipfs/go-ds-badger v0.2.3
16-
github.com/ipfs/go-graphsync v0.6.1
15+
github.com/ipfs/go-ds-badger v0.2.6
16+
github.com/ipfs/go-graphsync v0.8.0
1717
github.com/ipfs/go-ipfs-blockstore v1.0.1
1818
github.com/ipfs/go-ipfs-blocksutil v0.0.1
1919
github.com/ipfs/go-ipfs-chunker v0.0.5
2020
github.com/ipfs/go-ipfs-delay v0.0.1
2121
github.com/ipfs/go-ipfs-exchange-offline v0.0.1
2222
github.com/ipfs/go-ipfs-files v0.0.8
23-
github.com/ipfs/go-ipld-cbor v0.0.4
23+
github.com/ipfs/go-ipld-cbor v0.0.5
2424
github.com/ipfs/go-ipld-format v0.2.0
2525
github.com/ipfs/go-log/v2 v2.1.1
2626
github.com/ipfs/go-merkledag v0.3.2
2727
github.com/ipfs/go-unixfs v0.2.4
28-
github.com/ipld/go-ipld-prime v0.5.1-0.20201021195245-109253e8a018
28+
github.com/ipld/go-ipld-prime v0.9.1-0.20210324083106-dc342a9917db
2929
github.com/jbenet/go-random v0.0.0-20190219211222-123a90aedc0c
3030
github.com/jpillora/backoff v1.0.0
31-
github.com/libp2p/go-libp2p v0.12.0
32-
github.com/libp2p/go-libp2p-core v0.7.0
31+
github.com/libp2p/go-libp2p v0.13.0
32+
github.com/libp2p/go-libp2p-core v0.8.5
3333
github.com/stretchr/testify v1.6.1
34-
github.com/whyrusleeping/cbor-gen v0.0.0-20200826160007-0b9f6c5fb163
34+
github.com/whyrusleeping/cbor-gen v0.0.0-20210219115102-f37d292932f2
3535
go.uber.org/atomic v1.6.0
3636
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1
3737
)

0 commit comments

Comments
 (0)