From 2daf2b2af25428abaed90e838cb086d7c19dad38 Mon Sep 17 00:00:00 2001 From: Andrii Date: Mon, 20 May 2024 17:00:10 +0300 Subject: [PATCH] Fixed failing integration test --- .../tests/access/cohort3/grpc_state_stream_test.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/integration/tests/access/cohort3/grpc_state_stream_test.go b/integration/tests/access/cohort3/grpc_state_stream_test.go index ac7b36ad665..d4f77b9245d 100644 --- a/integration/tests/access/cohort3/grpc_state_stream_test.go +++ b/integration/tests/access/cohort3/grpc_state_stream_test.go @@ -234,8 +234,10 @@ func (s *GrpcStateStreamSuite) TestHappyPath() { targetEvent := flow.EventType("flow.AccountCreated") - foundANTxCount := 0 + foundANTxTestCount := 0 + foundANTxControlCount := 0 foundONTxCount := 0 + messageIndex := counters.NewMonotonousCounter(0) r := NewResponseTracker(compareEventsResponse, 3) @@ -252,16 +254,16 @@ func (s *GrpcStateStreamSuite) TestHappyPath() { if has(event.Events, targetEvent) { s.T().Logf("adding access test events: %d %d %v", event.Height, len(event.Events), event.Events) r.Add(s.T(), event.Height, "access_test", event) - foundANTxCount++ + foundANTxTestCount++ } case event := <-controlANEvents: if has(event.Events, targetEvent) { if ok := messageIndex.Set(event.MessageIndex); !ok { s.Require().NoErrorf(err, "messageIndex isn`t sequential") } - s.T().Logf("adding control events: %d %d %v", event.Height, len(event.Events), event.Events) r.Add(s.T(), event.Height, "access_control", event) + foundANTxControlCount++ } case event := <-testONEvents: if has(event.Events, targetEvent) { @@ -271,7 +273,9 @@ func (s *GrpcStateStreamSuite) TestHappyPath() { } } - if foundANTxCount >= txCount && foundONTxCount >= txCount { + if foundANTxTestCount >= txCount && + foundONTxCount >= txCount && + foundANTxControlCount >= txCount { break } }