Skip to content

Commit fecbec2

Browse files
authored
Applies assertion funcs to beacon-chain/db tests (#6938)
* part1 * go tidy * Merge branch 'go-tidy' into apply-testutils-assertions-to-beaconchain-db * updated beacon-chain/db/kv tests * Merge branch 'master' into apply-testutils-assertions-to-beaconchain-db * Merge refs/heads/master into apply-testutils-assertions-to-beaconchain-db * Merge refs/heads/master into apply-testutils-assertions-to-beaconchain-db
1 parent 9a59c4b commit fecbec2

19 files changed

+357
-922
lines changed

beacon-chain/db/filters/BUILD.bazel

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,4 +15,5 @@ go_test(
1515
name = "go_default_test",
1616
srcs = ["filter_test.go"],
1717
embed = [":go_default_library"],
18+
deps = ["//shared/testutil/assert:go_default_library"],
1819
)

beacon-chain/db/filters/filter_test.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,8 @@ package filters
22

33
import (
44
"testing"
5+
6+
"github.com/prysmaticlabs/prysm/shared/testutil/assert"
57
)
68

79
func TestQueryFilter_ChainsCorrectly(t *testing.T) {
@@ -11,9 +13,7 @@ func TestQueryFilter_ChainsCorrectly(t *testing.T) {
1113
SetParentRoot([]byte{3, 4, 5})
1214

1315
filterSet := f.Filters()
14-
if len(filterSet) != 3 {
15-
t.Errorf("Expected 3 filters to have been set, received %d", len(filterSet))
16-
}
16+
assert.Equal(t, 3, len(filterSet), "Unexpected number of filters")
1717
for k, v := range filterSet {
1818
switch k {
1919
case StartSlot:

beacon-chain/db/kv/BUILD.bazel

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -82,12 +82,15 @@ go_test(
8282
deps = [
8383
"//beacon-chain/cache:go_default_library",
8484
"//beacon-chain/db/filters:go_default_library",
85+
"//beacon-chain/state:go_default_library",
8586
"//beacon-chain/state/stateutil:go_default_library",
8687
"//proto/beacon/p2p/v1:go_default_library",
8788
"//proto/testing:go_default_library",
8889
"//shared/bytesutil:go_default_library",
8990
"//shared/params:go_default_library",
9091
"//shared/testutil:go_default_library",
92+
"//shared/testutil/assert:go_default_library",
93+
"//shared/testutil/require:go_default_library",
9194
"@com_github_ethereum_go_ethereum//common:go_default_library",
9295
"@com_github_gogo_protobuf//proto:go_default_library",
9396
"@com_github_prysmaticlabs_ethereumapis//eth/v1alpha1:go_default_library",

beacon-chain/db/kv/archived_point_test.go

Lines changed: 17 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@ import (
55
"testing"
66

77
"github.com/prysmaticlabs/prysm/shared/testutil"
8+
"github.com/prysmaticlabs/prysm/shared/testutil/assert"
9+
"github.com/prysmaticlabs/prysm/shared/testutil/require"
810
)
911

1012
func TestArchivedPointIndexRoot_CanSaveRetrieve(t *testing.T) {
@@ -14,67 +16,33 @@ func TestArchivedPointIndexRoot_CanSaveRetrieve(t *testing.T) {
1416
r1 := [32]byte{'A'}
1517

1618
received := db.ArchivedPointRoot(ctx, i1)
17-
if r1 == received {
18-
t.Fatal("Should not have been saved")
19-
}
19+
require.NotEqual(t, r1, received, "Should not have been saved")
2020
st := testutil.NewBeaconState()
21-
if err := st.SetSlot(i1); err != nil {
22-
t.Fatal(err)
23-
}
24-
if err := db.SaveState(ctx, st, r1); err != nil {
25-
t.Fatal(err)
26-
}
21+
require.NoError(t, st.SetSlot(i1))
22+
require.NoError(t, db.SaveState(ctx, st, r1))
2723
received = db.ArchivedPointRoot(ctx, i1)
28-
if r1 != received {
29-
t.Error("Should have been saved")
30-
}
24+
assert.Equal(t, r1, received, "Should have been saved")
3125
}
3226

3327
func TestLastArchivedPoint_CanRetrieve(t *testing.T) {
3428
db := setupDB(t)
3529
ctx := context.Background()
3630
i, err := db.LastArchivedSlot(ctx)
37-
if err != nil {
38-
t.Fatal(err)
39-
}
40-
if i != 0 {
41-
t.Error("Did not get correct index")
42-
}
31+
require.NoError(t, err)
32+
assert.Equal(t, uint64(0), i, "Did not get correct index")
4333

4434
st := testutil.NewBeaconState()
45-
if err := db.SaveState(ctx, st, [32]byte{'A'}); err != nil {
46-
t.Error(err)
47-
}
35+
assert.NoError(t, db.SaveState(ctx, st, [32]byte{'A'}))
36+
assert.Equal(t, [32]byte{'A'}, db.LastArchivedRoot(ctx), "Did not get wanted root")
4837

49-
if db.LastArchivedRoot(ctx) != [32]byte{'A'} {
50-
t.Error("Did not get wanted root")
51-
}
38+
assert.NoError(t, st.SetSlot(2))
39+
assert.NoError(t, db.SaveState(ctx, st, [32]byte{'B'}))
40+
assert.Equal(t, [32]byte{'B'}, db.LastArchivedRoot(ctx))
5241

53-
if err := st.SetSlot(2); err != nil {
54-
t.Error(err)
55-
}
56-
57-
if err := db.SaveState(ctx, st, [32]byte{'B'}); err != nil {
58-
t.Error(err)
59-
}
60-
61-
if db.LastArchivedRoot(ctx) != [32]byte{'B'} {
62-
t.Error("Did not get wanted root")
63-
}
64-
65-
if err := st.SetSlot(3); err != nil {
66-
t.Error(err)
67-
}
68-
69-
if err := db.SaveState(ctx, st, [32]byte{'C'}); err != nil {
70-
t.Fatal(err)
71-
}
42+
assert.NoError(t, st.SetSlot(3))
43+
assert.NoError(t, db.SaveState(ctx, st, [32]byte{'C'}))
7244

7345
i, err = db.LastArchivedSlot(ctx)
74-
if err != nil {
75-
t.Fatal(err)
76-
}
77-
if i != 3 {
78-
t.Error("Did not get correct index")
79-
}
46+
require.NoError(t, err)
47+
assert.Equal(t, uint64(3), i, "Did not get correct index")
8048
}

beacon-chain/db/kv/backup_test.go

Lines changed: 8 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import (
99
eth "github.com/prysmaticlabs/ethereumapis/eth/v1alpha1"
1010
"github.com/prysmaticlabs/prysm/beacon-chain/state/stateutil"
1111
"github.com/prysmaticlabs/prysm/shared/testutil"
12+
"github.com/prysmaticlabs/prysm/shared/testutil/require"
1213
)
1314

1415
func TestStore_Backup(t *testing.T) {
@@ -17,30 +18,16 @@ func TestStore_Backup(t *testing.T) {
1718

1819
head := &eth.SignedBeaconBlock{Block: &eth.BeaconBlock{Slot: 5000}}
1920

20-
if err := db.SaveBlock(ctx, head); err != nil {
21-
t.Fatal(err)
22-
}
21+
require.NoError(t, db.SaveBlock(ctx, head))
2322
root, err := stateutil.BlockRoot(head.Block)
24-
if err != nil {
25-
t.Fatal(err)
26-
}
23+
require.NoError(t, err)
2724
st := testutil.NewBeaconState()
28-
if err := db.SaveState(ctx, st, root); err != nil {
29-
t.Fatal(err)
30-
}
31-
if err := db.SaveHeadBlockRoot(ctx, root); err != nil {
32-
t.Fatal(err)
33-
}
25+
require.NoError(t, db.SaveState(ctx, st, root))
26+
require.NoError(t, db.SaveHeadBlockRoot(ctx, root))
3427

35-
if err := db.Backup(ctx); err != nil {
36-
t.Fatal(err)
37-
}
28+
require.NoError(t, db.Backup(ctx))
3829

3930
files, err := ioutil.ReadDir(path.Join(db.databasePath, backupsDirectoryName))
40-
if err != nil {
41-
t.Fatal(err)
42-
}
43-
if len(files) == 0 {
44-
t.Fatal("No backups created.")
45-
}
31+
require.NoError(t, err)
32+
require.NotEqual(t, 0, len(files), "No backups created")
4633
}

0 commit comments

Comments
 (0)