Correct proposal cid on provider side

This commit is contained in:
Łukasz Magiera 2019-11-07 00:59:56 +01:00
parent cfac6f3272
commit d45544c90c

View File

@ -193,7 +193,7 @@ func (p *Provider) onUpdated(ctx context.Context, update minerDealUpdate) {
} }
func (p *Provider) newDeal(s inet.Stream, proposal Proposal) (MinerDeal, error) { func (p *Provider) newDeal(s inet.Stream, proposal Proposal) (MinerDeal, error) {
proposalNd, err := cborrpc.AsIpld(&proposal) proposalNd, err := cborrpc.AsIpld(proposal.DealProposal)
if err != nil { if err != nil {
return MinerDeal{}, err return MinerDeal{}, err
} }
@ -222,7 +222,7 @@ func (p *Provider) HandleStream(s inet.Stream) {
deal, err := p.newDeal(s, proposal) deal, err := p.newDeal(s, proposal)
if err != nil { if err != nil {
log.Error(err) log.Errorf("%+v", err)
s.Close() s.Close()
return return
} }