@@ -178,7 +178,7 @@ func TestStateSyncLocalSummaryIsIncludedAmongFrontiersIfAvailable(t *testing.T)
178
178
require .NoError (syncer .Connected (context .Background (), vdr .NodeID , version .CurrentApp ))
179
179
}
180
180
181
- require .True ( syncer .locallyAvailableSummary == localSummary )
181
+ require .Equal ( localSummary , syncer .locallyAvailableSummary )
182
182
ws , ok := syncer .weightedSummaries [summaryID ]
183
183
require .True (ok )
184
184
require .True (bytes .Equal (ws .summary .Bytes (), summaryBytes ))
@@ -251,14 +251,14 @@ func TestBeaconsAreReachedForFrontiersUponStartup(t *testing.T) {
251
251
}
252
252
253
253
// check that vdrs are reached out for frontiers
254
- require .True ( len ( contactedFrontiersProviders ) == safeMath .Min (vdrs .Len (), common .MaxOutstandingBroadcastRequests ))
254
+ require .Len ( contactedFrontiersProviders , safeMath .Min (vdrs .Len (), common .MaxOutstandingBroadcastRequests ))
255
255
for beaconID := range contactedFrontiersProviders {
256
256
// check that beacon is duly marked as reached out
257
257
require .True (syncer .pendingSeeders .Contains (beaconID ))
258
258
}
259
259
260
260
// check that, obviously, no summary is yet registered
261
- require .True ( len ( syncer .weightedSummaries ) == 0 )
261
+ require .Empty ( syncer .weightedSummaries )
262
262
}
263
263
264
264
func TestUnRequestedStateSummaryFrontiersAreDropped (t * testing.T ) {
@@ -319,8 +319,8 @@ func TestUnRequestedStateSummaryFrontiersAreDropped(t *testing.T) {
319
319
math .MaxInt32 ,
320
320
summaryBytes ,
321
321
))
322
- require .True (syncer .pendingSeeders . Contains ( responsiveBeaconID ) ) // responsiveBeacon still pending
323
- require .True ( len ( syncer .weightedSummaries ) == 0 )
322
+ require .Contains (syncer .pendingSeeders , responsiveBeaconID ) // responsiveBeacon still pending
323
+ require .Empty ( syncer .weightedSummaries )
324
324
325
325
// check a response from unsolicited node is dropped
326
326
unsolicitedNodeID := ids .GenerateTestNodeID ()
@@ -330,7 +330,7 @@ func TestUnRequestedStateSummaryFrontiersAreDropped(t *testing.T) {
330
330
responsiveBeaconReqID ,
331
331
summaryBytes ,
332
332
))
333
- require .True ( len ( syncer .weightedSummaries ) == 0 )
333
+ require .Empty ( syncer .weightedSummaries )
334
334
335
335
// check a valid response is duly recorded
336
336
require .NoError (syncer .StateSummaryFrontier (
@@ -341,7 +341,7 @@ func TestUnRequestedStateSummaryFrontiersAreDropped(t *testing.T) {
341
341
))
342
342
343
343
// responsiveBeacon not pending anymore
344
- require .False (syncer .pendingSeeders . Contains ( responsiveBeaconID ) )
344
+ require .NotContains (syncer .pendingSeeders , responsiveBeaconID )
345
345
346
346
// valid summary is recorded
347
347
ws , ok := syncer .weightedSummaries [summaryID ]
@@ -413,11 +413,11 @@ func TestMalformedStateSummaryFrontiersAreDropped(t *testing.T) {
413
413
))
414
414
415
415
// responsiveBeacon not pending anymore
416
- require .False (syncer .pendingSeeders . Contains ( responsiveBeaconID ) )
416
+ require .NotContains (syncer .pendingSeeders , responsiveBeaconID )
417
417
418
418
// invalid summary is not recorded
419
419
require .True (isSummaryDecoded )
420
- require .True ( len ( syncer .weightedSummaries ) == 0 )
420
+ require .Empty ( syncer .weightedSummaries )
421
421
422
422
// even in case of invalid summaries, other listed vdrs
423
423
// are reached for data
@@ -481,8 +481,8 @@ func TestLateResponsesFromUnresponsiveFrontiersAreNotRecorded(t *testing.T) {
481
481
))
482
482
483
483
// unresponsiveBeacon not pending anymore
484
- require .False (syncer .pendingSeeders . Contains ( unresponsiveBeaconID ) )
485
- require .True (syncer .failedSeeders . Contains ( unresponsiveBeaconID ) )
484
+ require .NotContains (syncer .pendingSeeders , unresponsiveBeaconID )
485
+ require .Contains (syncer .failedSeeders , unresponsiveBeaconID )
486
486
487
487
// even in case of timeouts, other listed vdrs
488
488
// are reached for data
@@ -509,7 +509,7 @@ func TestLateResponsesFromUnresponsiveFrontiersAreNotRecorded(t *testing.T) {
509
509
))
510
510
511
511
// late summary is not recorded
512
- require .True ( len ( syncer .weightedSummaries ) == 0 )
512
+ require .Empty ( syncer .weightedSummaries )
513
513
}
514
514
515
515
func TestStateSyncIsRestartedIfTooManyFrontierSeedersTimeout (t * testing.T ) {
@@ -600,10 +600,10 @@ func TestStateSyncIsRestartedIfTooManyFrontierSeedersTimeout(t *testing.T) {
600
600
}
601
601
602
602
// check that some frontier seeders are reached again for the frontier
603
- require .True (syncer .pendingSeeders . Len () > 0 )
603
+ require .NotEmpty (syncer .pendingSeeders )
604
604
605
605
// check that no vote requests are issued
606
- require .True ( len ( contactedVoters ) == 0 )
606
+ require .Empty ( contactedVoters )
607
607
}
608
608
609
609
func TestVoteRequestsAreSentAsAllFrontierBeaconsResponded (t * testing.T ) {
@@ -768,8 +768,8 @@ func TestUnRequestedVotesAreDropped(t *testing.T) {
768
768
))
769
769
770
770
// responsiveVoter still pending
771
- require .True (syncer .pendingVoters . Contains ( responsiveVoterID ) )
772
- require .True (syncer .weightedSummaries [summaryID ].weight == 0 )
771
+ require .Contains (syncer .pendingVoters , responsiveVoterID )
772
+ require .Zero (syncer .weightedSummaries [summaryID ].weight )
773
773
774
774
// check a response from unsolicited node is dropped
775
775
unsolicitedVoterID := ids .GenerateTestNodeID ()
@@ -779,7 +779,7 @@ func TestUnRequestedVotesAreDropped(t *testing.T) {
779
779
responsiveVoterReqID ,
780
780
[]ids.ID {summaryID },
781
781
))
782
- require .True (syncer .weightedSummaries [summaryID ].weight == 0 )
782
+ require .Zero (syncer .weightedSummaries [summaryID ].weight )
783
783
784
784
// check a valid response is duly recorded
785
785
require .NoError (syncer .AcceptedStateSummary (
@@ -790,7 +790,7 @@ func TestUnRequestedVotesAreDropped(t *testing.T) {
790
790
))
791
791
792
792
// responsiveBeacon not pending anymore
793
- require .False (syncer .pendingSeeders . Contains ( responsiveVoterID ) )
793
+ require .NotContains (syncer .pendingSeeders , responsiveVoterID )
794
794
voterWeight := vdrs .GetWeight (responsiveVoterID )
795
795
require .Equal (voterWeight , syncer .weightedSummaries [summaryID ].weight )
796
796
@@ -890,14 +890,14 @@ func TestVotesForUnknownSummariesAreDropped(t *testing.T) {
890
890
require .False (found )
891
891
892
892
// check that responsiveVoter cannot cast another vote
893
- require .False (syncer .pendingSeeders . Contains ( responsiveVoterID ) )
893
+ require .NotContains (syncer .pendingSeeders , responsiveVoterID )
894
894
require .NoError (syncer .AcceptedStateSummary (
895
895
context .Background (),
896
896
responsiveVoterID ,
897
897
responsiveVoterReqID ,
898
898
[]ids.ID {summaryID },
899
899
))
900
- require .True (syncer .weightedSummaries [summaryID ].weight == 0 )
900
+ require .Zero (syncer .weightedSummaries [summaryID ].weight )
901
901
902
902
// other listed voters are reached out, even in the face of vote
903
903
// on unknown summary
0 commit comments