Skip to content

Commit 7de8020

Browse files
authored
feat: update to go-fil-markets v1.23.0 (#634)
1 parent d2e7441 commit 7de8020

File tree

4 files changed

+33
-19
lines changed

4 files changed

+33
-19
lines changed

go.mod

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -25,14 +25,14 @@ require (
2525
github.com/filecoin-project/go-data-transfer v1.15.2
2626
github.com/filecoin-project/go-fil-commcid v0.1.0
2727
github.com/filecoin-project/go-fil-commp-hashhash v0.1.0
28-
github.com/filecoin-project/go-fil-markets v1.22.2
28+
github.com/filecoin-project/go-fil-markets v1.23.0
2929
github.com/filecoin-project/go-jsonrpc v0.1.5
3030
github.com/filecoin-project/go-padreader v0.0.1
3131
github.com/filecoin-project/go-paramfetch v0.0.4
3232
github.com/filecoin-project/go-state-types v0.1.10
3333
github.com/filecoin-project/go-statestore v0.2.0
3434
github.com/filecoin-project/index-provider v0.8.1
35-
github.com/filecoin-project/lotus v1.17.0-rc1.0.20220630222754-f5225d7b25c4
35+
github.com/filecoin-project/lotus v1.17.0-rc1.0.20220706101903-9bcefce07b7c
3636
github.com/filecoin-project/specs-actors v0.9.15
3737
github.com/filecoin-project/specs-actors/v8 v8.0.1
3838
github.com/filecoin-project/specs-storage v0.4.1
@@ -62,8 +62,8 @@ require (
6262
github.com/ipfs/go-merkledag v0.6.0
6363
github.com/ipfs/go-metrics-interface v0.0.1
6464
github.com/ipfs/go-unixfs v0.3.1
65-
github.com/ipld/go-car v0.3.4-0.20220630140142-8171360c2218
66-
github.com/ipld/go-car/v2 v2.2.0
65+
github.com/ipld/go-car v0.4.1-0.20220706093353-3d969443294c
66+
github.com/ipld/go-car/v2 v2.4.1-0.20220706093353-3d969443294c
6767
github.com/ipld/go-ipld-prime v0.17.0
6868
github.com/ipld/go-ipld-selector-text-lite v0.0.1
6969
github.com/jbenet/go-random v0.0.0-20190219211222-123a90aedc0c
@@ -76,7 +76,7 @@ require (
7676
github.com/libp2p/go-libp2p-http v0.2.1
7777
github.com/libp2p/go-libp2p-kad-dht v0.15.0
7878
github.com/libp2p/go-libp2p-peerstore v0.7.0
79-
github.com/libp2p/go-libp2p-pubsub v0.7.0
79+
github.com/libp2p/go-libp2p-pubsub v0.7.1
8080
github.com/libp2p/go-libp2p-record v0.1.3
8181
github.com/libp2p/go-libp2p-resource-manager v0.3.0
8282
github.com/mattn/go-sqlite3 v1.14.10

go.sum

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -384,8 +384,8 @@ github.com/filecoin-project/go-fil-commcid v0.1.0 h1:3R4ds1A9r6cr8mvZBfMYxTS88Oq
384384
github.com/filecoin-project/go-fil-commcid v0.1.0/go.mod h1:Eaox7Hvus1JgPrL5+M3+h7aSPHc0cVqpSxA+TxIEpZQ=
385385
github.com/filecoin-project/go-fil-commp-hashhash v0.1.0 h1:imrrpZWEHRnNqqv0tN7LXep5bFEVOVmQWHJvl2mgsGo=
386386
github.com/filecoin-project/go-fil-commp-hashhash v0.1.0/go.mod h1:73S8WSEWh9vr0fDJVnKADhfIv/d6dCbAGaAGWbdJEI8=
387-
github.com/filecoin-project/go-fil-markets v1.22.2 h1:8E2rQ9yo0ycZXJ/noIqPqkwjkyidUvr6O0MUYtUy5cc=
388-
github.com/filecoin-project/go-fil-markets v1.22.2/go.mod h1:nuNgE+5tXuV3FVOKOVgcClBjH3UNE0gpgRYWCQEnvRM=
387+
github.com/filecoin-project/go-fil-markets v1.23.0 h1:gF138KL5QDAoDOJJqrUbFK9jwS+Sjq2P3qMSdHFtkA8=
388+
github.com/filecoin-project/go-fil-markets v1.23.0/go.mod h1:bBa1d5mnlgwXPnH+MdqpCUsI+gxyrPUPSRePQDY36Hw=
389389
github.com/filecoin-project/go-hamt-ipld v0.1.5 h1:uoXrKbCQZ49OHpsTCkrThPNelC4W3LPEk0OrS/ytIBM=
390390
github.com/filecoin-project/go-hamt-ipld v0.1.5/go.mod h1:6Is+ONR5Cd5R6XZoCse1CWaXZc0Hdb/JeX+EQCQzX24=
391391
github.com/filecoin-project/go-hamt-ipld/v2 v2.0.0 h1:b3UDemBYN2HNfk3KOXNuxgTTxlWi3xVvbQP0IT38fvM=
@@ -426,8 +426,8 @@ github.com/filecoin-project/go-storedcounter v0.1.0 h1:Mui6wSUBC+cQGHbDUBcO7rfh5
426426
github.com/filecoin-project/go-storedcounter v0.1.0/go.mod h1:4ceukaXi4vFURIoxYMfKzaRF5Xv/Pinh2oTnoxpv+z8=
427427
github.com/filecoin-project/index-provider v0.8.1 h1:ggoBWvMSWR91HZQCWfv8SZjoTGNyJBwNMLuN9bJZrbU=
428428
github.com/filecoin-project/index-provider v0.8.1/go.mod h1:c/Ym5HtWPp9NQgNc9dgSBMpSNsZ/DE9FEi9qVubl5RM=
429-
github.com/filecoin-project/lotus v1.17.0-rc1.0.20220630222754-f5225d7b25c4 h1:eTN81nkDbpiZMThtwoLq/MZge7dwkD6m+/6/zzJVT5k=
430-
github.com/filecoin-project/lotus v1.17.0-rc1.0.20220630222754-f5225d7b25c4/go.mod h1:q8OUXwhdN2tHShDP6p1yWvUQ3kYrKLtRs6cM+ujmTLc=
429+
github.com/filecoin-project/lotus v1.17.0-rc1.0.20220706101903-9bcefce07b7c h1:IwZSkh7WUaklkmm6XD60Sl9S9xdUVRCpuHBxCDwT4hs=
430+
github.com/filecoin-project/lotus v1.17.0-rc1.0.20220706101903-9bcefce07b7c/go.mod h1:jkDORkbxuvGjiztnefJf9tMHfKOwAC/Tn3FtWstPAMA=
431431
github.com/filecoin-project/pubsub v1.0.0 h1:ZTmT27U07e54qV1mMiQo4HDr0buo8I1LDHBYLXlsNXM=
432432
github.com/filecoin-project/pubsub v1.0.0/go.mod h1:GkpB33CcUtUNrLPhJgfdy4FDx4OMNR9k+46DHx/Lqrg=
433433
github.com/filecoin-project/specs-actors v0.9.13/go.mod h1:TS1AW/7LbG+615j4NsjMK1qlpAwaFsG9w0V2tg2gSao=
@@ -997,12 +997,13 @@ github.com/ipfs/tar-utils v0.0.2/go.mod h1:4qlnRWgTVljIMhSG2SqRYn66NT+3wrv/kZt9V
997997
github.com/ipld/edelweiss v0.1.2/go.mod h1:14NnBVHgrPO8cqDnKg7vc69LGI0aCAcax6mj21+99ec=
998998
github.com/ipld/go-car v0.1.0/go.mod h1:RCWzaUh2i4mOEkB3W45Vc+9jnS/M6Qay5ooytiBHl3g=
999999
github.com/ipld/go-car v0.3.2/go.mod h1:WEjynkVt04dr0GwJhry0KlaTeSDEiEYyMPOxDBQ17KE=
1000-
github.com/ipld/go-car v0.3.3/go.mod h1:/wkKF4908ULT4dFIFIUZYcfjAnj+KFnJvlh8Hsz1FbQ=
1001-
github.com/ipld/go-car v0.3.4-0.20220630140142-8171360c2218 h1:N2BGgZdt6s0E/KjFgejG+57OeNS8Da+RLQd482F39MA=
1002-
github.com/ipld/go-car v0.3.4-0.20220630140142-8171360c2218/go.mod h1:Uslcn4O9cBKK9wqHm/cLTFacg6RAPv6LZx2mxd2Ypl4=
1000+
github.com/ipld/go-car v0.4.0/go.mod h1:Uslcn4O9cBKK9wqHm/cLTFacg6RAPv6LZx2mxd2Ypl4=
1001+
github.com/ipld/go-car v0.4.1-0.20220706093353-3d969443294c h1:VP/ZM6OkD7uFBsJDB8W2/eOiLWPPGlzjzJC3uHdNvj4=
1002+
github.com/ipld/go-car v0.4.1-0.20220706093353-3d969443294c/go.mod h1:Uslcn4O9cBKK9wqHm/cLTFacg6RAPv6LZx2mxd2Ypl4=
10031003
github.com/ipld/go-car/v2 v2.1.1/go.mod h1:+2Yvf0Z3wzkv7NeI69i8tuZ+ft7jyjPYIWZzeVNeFcI=
1004-
github.com/ipld/go-car/v2 v2.2.0 h1:CxNhm5zBijR/68VLP+m40Rdq3s6l61+j4SVCOD3Wgl0=
1005-
github.com/ipld/go-car/v2 v2.2.0/go.mod h1:zjpRf0Jew9gHqSvjsKVyoq9OY9SWoEKdYCQUKVaaPT0=
1004+
github.com/ipld/go-car/v2 v2.4.0/go.mod h1:zjpRf0Jew9gHqSvjsKVyoq9OY9SWoEKdYCQUKVaaPT0=
1005+
github.com/ipld/go-car/v2 v2.4.1-0.20220706093353-3d969443294c h1:taGcTKh0NNSX7MPI4pjEfxUUXsT/r7RRoqDrSGQVTO8=
1006+
github.com/ipld/go-car/v2 v2.4.1-0.20220706093353-3d969443294c/go.mod h1:sDHqspWMwG6cC0lrid3Lq2xtIR4R6iy6ymCNT0drhaI=
10061007
github.com/ipld/go-codec-dagpb v1.2.0/go.mod h1:6nBN7X7h8EOsEejZGqC7tej5drsdBAXbMHyBT+Fne5s=
10071008
github.com/ipld/go-codec-dagpb v1.3.0/go.mod h1:ga4JTU3abYApDC3pZ00BC2RSvC3qfBb9MSJkMLSwnhA=
10081009
github.com/ipld/go-codec-dagpb v1.3.1/go.mod h1:ErNNglIi5KMur/MfFE/svtgQthzVvf+43MrzLbpcIZY=
@@ -1017,7 +1018,6 @@ github.com/ipld/go-ipld-prime v0.12.3/go.mod h1:PaeLYq8k6dJLmDUSLrzkEpoGV4PEfe/1
10171018
github.com/ipld/go-ipld-prime v0.14.0/go.mod h1:9ASQLwUFLptCov6lIYc70GRB4V7UTyLD0IJtrDJe6ZM=
10181019
github.com/ipld/go-ipld-prime v0.14.1/go.mod h1:QcE4Y9n/ZZr8Ijg5bGPT0GqYWgZ1704nH0RDcQtgTP0=
10191020
github.com/ipld/go-ipld-prime v0.14.2/go.mod h1:QcE4Y9n/ZZr8Ijg5bGPT0GqYWgZ1704nH0RDcQtgTP0=
1020-
github.com/ipld/go-ipld-prime v0.14.3-0.20211207234443-319145880958/go.mod h1:QcE4Y9n/ZZr8Ijg5bGPT0GqYWgZ1704nH0RDcQtgTP0=
10211021
github.com/ipld/go-ipld-prime v0.14.4-0.20211217152141-008fd70fc96f/go.mod h1:QcE4Y9n/ZZr8Ijg5bGPT0GqYWgZ1704nH0RDcQtgTP0=
10221022
github.com/ipld/go-ipld-prime v0.16.0/go.mod h1:axSCuOCBPqrH+gvXr2w9uAOulJqBPhHPT2PjoiiU1qA=
10231023
github.com/ipld/go-ipld-prime v0.17.0 h1:+U2peiA3aQsE7mrXjD2nYZaZrCcakoz2Wge8K42Ld8g=
@@ -1329,8 +1329,9 @@ github.com/libp2p/go-libp2p-protocol v0.0.1/go.mod h1:Af9n4PiruirSDjHycM1QuiMi/1
13291329
github.com/libp2p/go-libp2p-protocol v0.1.0/go.mod h1:KQPHpAabB57XQxGrXCNvbL6UEXfQqUgC/1adR2Xtflk=
13301330
github.com/libp2p/go-libp2p-pubsub v0.1.1/go.mod h1:ZwlKzRSe1eGvSIdU5bD7+8RZN/Uzw0t1Bp9R1znpR/Q=
13311331
github.com/libp2p/go-libp2p-pubsub v0.6.0/go.mod h1:nJv87QM2cU0w45KPR1rZicq+FmFIOD16zmT+ep1nOmg=
1332-
github.com/libp2p/go-libp2p-pubsub v0.7.0 h1:Fd9198JVc3pCsKuzd37TclzM0QcHA+uDyoiG2pvT7s4=
13331332
github.com/libp2p/go-libp2p-pubsub v0.7.0/go.mod h1:EuyBJFtF8qF67IEA98biwK8Xnw5MNJpJ/Z+8iWCMFwc=
1333+
github.com/libp2p/go-libp2p-pubsub v0.7.1 h1:e2CPBP5uxvDkE0FiS0obZGZPzt+xuBOc6PpG+50pIAo=
1334+
github.com/libp2p/go-libp2p-pubsub v0.7.1/go.mod h1:EuyBJFtF8qF67IEA98biwK8Xnw5MNJpJ/Z+8iWCMFwc=
13341335
github.com/libp2p/go-libp2p-pubsub-router v0.5.0/go.mod h1:TRJKskSem3C0aSb3CmRgPwq6IleVFzds6hS09fmZbGM=
13351336
github.com/libp2p/go-libp2p-quic-transport v0.1.1/go.mod h1:wqG/jzhF3Pu2NrhJEvE+IE0NTHNXslOPn9JQzyCAxzU=
13361337
github.com/libp2p/go-libp2p-quic-transport v0.10.0/go.mod h1:RfJbZ8IqXIhxBRm5hqUEJqjiiY8xmEuq3HUDS993MkA=

storagemarket/deal_execution.go

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -407,7 +407,11 @@ func GenerateCommP(filepath string) (cidAndSize *writer.DataCIDSize, finalErr er
407407

408408
// dump the CARv1 payload of the CARv2 file to the Commp Writer and get back the CommP.
409409
w := &writer.Writer{}
410-
written, err := io.Copy(w, rd.DataReader())
410+
r, err := rd.DataReader()
411+
if err != nil {
412+
return nil, fmt.Errorf("failed to get reader over CAR file data: %w", err)
413+
}
414+
written, err := io.Copy(w, r)
411415
if err != nil {
412416
return nil, fmt.Errorf("failed to write to CommP writer: %w", err)
413417
}
@@ -587,7 +591,14 @@ func (p *Provider) addPiece(ctx context.Context, pub event.Emitter, deal *types.
587591

588592
// Inflate the deal size so that it exactly fills a piece
589593
proposal := deal.ClientDealProposal.Proposal
590-
paddedReader, err := padreader.NewInflator(v2r.DataReader(), size, proposal.PieceSize.Unpadded())
594+
r, err := v2r.DataReader()
595+
if err != nil {
596+
return &dealMakingError{
597+
retry: types.DealRetryFatal,
598+
error: fmt.Errorf("failed to get data reader over CAR file: %w", err),
599+
}
600+
}
601+
paddedReader, err := padreader.NewInflator(r, size, proposal.PieceSize.Unpadded())
591602
if err != nil {
592603
return &dealMakingError{
593604
retry: types.DealRetryFatal,

storagemarket/provider_test.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1026,7 +1026,9 @@ func (h *ProviderHarness) AssertSealedContents(t *testing.T, carV2FilePath strin
10261026
require.NoError(t, err)
10271027
defer cr.Close()
10281028

1029-
actual, err := ioutil.ReadAll(cr.DataReader())
1029+
r, err := cr.DataReader()
1030+
require.NoError(t, err)
1031+
actual, err := ioutil.ReadAll(r)
10301032
require.NoError(t, err)
10311033

10321034
// the read-bytes also contains extra zeros for the padding magic, so just match without the padding bytes.

0 commit comments

Comments
 (0)