cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

on chain deals: Improve some errors

Browse Source
This commit is contained in:
Łukasz Magiera 2019-10-23 12:42:52 +02:00
parent 8e7e5d3085
commit bd77bba676
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
chain/deals/client.go
View File

@ -180,23 +180,23 @@ func (c *Client) Start(ctx context.Context, p ClientDealProposal) (cid.Cid, erro
} }
if err := api.SignWith(ctx, c.w.Sign, p.Client, &proposal); err != nil { if err := api.SignWith(ctx, c.w.Sign, p.Client, &proposal); err != nil {
return cid.Undef, err return cid.Undef, xerrors.Errorf("signing deal proposal failed: %w", err)
} }
proposalNd, err := cborrpc.AsIpld(proposal) proposalNd, err := cborrpc.AsIpld(proposal)
if err != nil { if err != nil {
return cid.Undef, err return cid.Undef, xerrors.Errorf("getting proposal node failed: %w", err)
} }
s, err := c.h.NewStream(ctx, p.MinerID, DealProtocolID) s, err := c.h.NewStream(ctx, p.MinerID, DealProtocolID)
if err != nil { if err != nil {
s.Reset() s.Reset()
return cid.Undef, err return cid.Undef, xerrors.Errorf("connecting to storage provider failed: %w", err)
} }
if err := cborrpc.WriteCborRPC(s, proposal); err != nil { if err := cborrpc.WriteCborRPC(s, proposal); err != nil {
s.Reset() s.Reset()
return cid.Undef, err return cid.Undef, xerrors.Errorf("sending proposal to storage provider failed: %w", err)
} }
deal := ClientDeal{ deal := ClientDeal{