get retrieval pricing input should not error out on a deal state fetch
This commit is contained in:
parent
a577bf340e
commit
8ecdc929b4
@ -138,7 +138,8 @@ func (rpn *retrievalProviderNode) GetRetrievalPricingInput(ctx context.Context,
|
|||||||
for _, dealID := range storageDeals {
|
for _, dealID := range storageDeals {
|
||||||
ds, err := rpn.full.StateMarketStorageDeal(ctx, dealID, tsk)
|
ds, err := rpn.full.StateMarketStorageDeal(ctx, dealID, tsk)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return resp, xerrors.Errorf("failed to look up deal %d on chain: err=%w", dealID, err)
|
log.Warnf("failed to look up deal %d on chain: err=%w", dealID, err)
|
||||||
|
continue
|
||||||
}
|
}
|
||||||
if ds.Proposal.VerifiedDeal {
|
if ds.Proposal.VerifiedDeal {
|
||||||
resp.VerifiedDeal = true
|
resp.VerifiedDeal = true
|
||||||
|
@ -92,6 +92,32 @@ func TestGetPricingInput(t *testing.T) {
|
|||||||
expectedVerified: true,
|
expectedVerified: true,
|
||||||
},
|
},
|
||||||
|
|
||||||
|
"success even if one deal state fetch errors out but the other deal is verified and has the required piececid": {
|
||||||
|
fFnc: func(n *mocks.MockFullNode) {
|
||||||
|
out1 := &api.MarketDeal{
|
||||||
|
Proposal: market.DealProposal{
|
||||||
|
PieceCID: testnet.GenerateCids(1)[0],
|
||||||
|
},
|
||||||
|
}
|
||||||
|
out2 := &api.MarketDeal{
|
||||||
|
Proposal: market.DealProposal{
|
||||||
|
PieceCID: pcid,
|
||||||
|
PieceSize: paddedSize,
|
||||||
|
VerifiedDeal: true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
n.EXPECT().ChainHead(gomock.Any()).Return(tsk, nil).Times(1)
|
||||||
|
gomock.InOrder(
|
||||||
|
n.EXPECT().StateMarketStorageDeal(gomock.Any(), deals[0], key).Return(out1, xerrors.New("some error")),
|
||||||
|
n.EXPECT().StateMarketStorageDeal(gomock.Any(), deals[1], key).Return(out2, nil),
|
||||||
|
)
|
||||||
|
|
||||||
|
},
|
||||||
|
expectedPieceSize: unpaddedSize,
|
||||||
|
expectedVerified: true,
|
||||||
|
},
|
||||||
|
|
||||||
"verified is false if both deals are unverified and we get the correct piece size": {
|
"verified is false if both deals are unverified and we get the correct piece size": {
|
||||||
fFnc: func(n *mocks.MockFullNode) {
|
fFnc: func(n *mocks.MockFullNode) {
|
||||||
out1 := &api.MarketDeal{
|
out1 := &api.MarketDeal{
|
||||||
|
Loading…
Reference in New Issue
Block a user