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

explicitly handle each deal status, as per PR feedback

Browse Source
This commit is contained in:
laser 2020-06-23 12:14:41 -07:00
parent 8adc831a31
commit 06162290af
1 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
node/impl/client/client.go
View File

@ -348,12 +348,34 @@ func (a *API) ClientRetrieve(ctx context.Context, order api.RetrievalOrder, ref
unsubscribe := a.Retrieval.SubscribeToEvents(func(event retrievalmarket.ClientEvent, state retrievalmarket.ClientDealState) { unsubscribe := a.Retrieval.SubscribeToEvents(func(event retrievalmarket.ClientEvent, state retrievalmarket.ClientDealState) {
if state.PayloadCID.Equals(order.Root) { if state.PayloadCID.Equals(order.Root) {
switch state.Status { switch state.Status {
case retrievalmarket.DealStatusRejected: case
retrievalResult <- xerrors.Errorf("Retrieval Proposal Rejected: %s", state.Message) retrievalmarket.DealStatusCompleted:
case retrievalmarket.DealStatusFailed, retrievalmarket.DealStatusErrored:
retrievalResult <- xerrors.Errorf("Retrieval Error: %s", state.Message)
case retrievalmarket.DealStatusCompleted:
retrievalResult <- nil retrievalResult <- nil
case
retrievalmarket.DealStatusRejected:
retrievalResult <- xerrors.Errorf("Retrieval Proposal Rejected: %s", state.Message)
case
retrievalmarket.DealStatusDealNotFound,
retrievalmarket.DealStatusErrored,
retrievalmarket.DealStatusFailed:
retrievalResult <- xerrors.Errorf("Retrieval Error: %s", state.Message)
case
retrievalmarket.DealStatusAccepted,
retrievalmarket.DealStatusAwaitingAcceptance,
retrievalmarket.DealStatusBlocksComplete,
retrievalmarket.DealStatusFinalizing,
retrievalmarket.DealStatusFundsNeeded,
retrievalmarket.DealStatusFundsNeededLastPayment,
retrievalmarket.DealStatusNew,
retrievalmarket.DealStatusOngoing,
retrievalmarket.DealStatusPaymentChannelAddingFunds,
retrievalmarket.DealStatusPaymentChannelAllocatingLane,
retrievalmarket.DealStatusPaymentChannelCreating,
retrievalmarket.DealStatusPaymentChannelReady,
retrievalmarket.DealStatusVerified:
return
default:
retrievalResult <- xerrors.Errorf("Unhandled Retrieval Status: %+v", state.Status)
} }
} }
}) })