fail test if deal errors

This commit is contained in:
whyrusleeping 2019-11-06 12:54:40 -08:00 committed by Łukasz Magiera
parent 41d13b12a0
commit 480e7899ef
3 changed files with 4 additions and 2 deletions

View File

@ -72,10 +72,13 @@ func TestDealFlow(t *testing.T, b APIBuilder) {
t.Fatal("deal rejected") t.Fatal("deal rejected")
case api.DealFailed: case api.DealFailed:
t.Fatal("deal failed") t.Fatal("deal failed")
case api.DealError:
t.Fatal("deal errored")
case api.DealComplete: case api.DealComplete:
fmt.Println("COMPLETE", di) fmt.Println("COMPLETE", di)
break break
} }
fmt.Println("Deal state: ", di.State)
time.Sleep(time.Second / 2) time.Sleep(time.Second / 2)
} }
} }

View File

@ -12,7 +12,7 @@ import (
const sectorSize = 1024 const sectorSize = 1024
func TestSealAndVerify(t *testing.T) { func TestSealAndVerify(t *testing.T) {
//t.Skip("this is slow") t.Skip("this is slow")
//os.Setenv("BELLMAN_NO_GPU", "1") //os.Setenv("BELLMAN_NO_GPU", "1")
build.SectorSizes = []uint64{sectorSize} build.SectorSizes = []uint64{sectorSize}

View File

@ -92,7 +92,6 @@ func (a *API) ClientStartDeal(ctx context.Context, data cid.Cid, miner address.A
} }
c, err := a.DealClient.Start(ctx, proposal) c, err := a.DealClient.Start(ctx, proposal)
// TODO: send updated voucher with PaymentVerifySector for cheaper validation (validate the sector the miner sent us first!)
if err != nil { if err != nil {
return nil, xerrors.Errorf("failed to start deal: %w", err) return nil, xerrors.Errorf("failed to start deal: %w", err)
} }