Skip to content

Commit

Permalink
(test): Run LogPollerWrapperTest v1/v2 tests sequentially
Browse files Browse the repository at this point in the history
  • Loading branch information
justinkaseman committed Feb 19, 2024
1 parent 09df392 commit 1ba2c06
Showing 1 changed file with 0 additions and 8 deletions.
8 changes: 0 additions & 8 deletions core/services/relay/evm/functions/logpoller_wrapper_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,6 @@ func getMockedRequestLogV2(t *testing.T) logpoller.Log {
}

func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV1(t *testing.T) {
t.Parallel()
lp, lpWrapper, client := setUp(t, 100_000) // check only once
lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil)

Expand Down Expand Up @@ -153,7 +152,6 @@ func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV1(t *testing.T
}

func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV2(t *testing.T) {
t.Parallel()
lp, lpWrapper, client := setUp(t, 100_000) // check only once
lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil)

Expand Down Expand Up @@ -185,7 +183,6 @@ func TestLogPollerWrapper_SingleSubscriberEmptyEvents_CoordinatorV2(t *testing.T
}

func TestLogPollerWrapper_ErrorOnZeroAddresses(t *testing.T) {
t.Parallel()
lp, lpWrapper, client := setUp(t, 100_000) // check only once
lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil)

Expand All @@ -197,7 +194,6 @@ func TestLogPollerWrapper_ErrorOnZeroAddresses(t *testing.T) {
}

func TestLogPollerWrapper_LatestEvents_ReorgHandlingV1(t *testing.T) {
t.Parallel()
lp, lpWrapper, client := setUp(t, 100_000)
lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil)
client.On("CallContract", mock.Anything, ethereum.CallMsg{ // getContractById
Expand Down Expand Up @@ -243,7 +239,6 @@ func TestLogPollerWrapper_LatestEvents_ReorgHandlingV1(t *testing.T) {
}

func TestLogPollerWrapper_LatestEvents_ReorgHandlingV2(t *testing.T) {
t.Parallel()
lp, lpWrapper, client := setUp(t, 100_000)
lp.On("LatestBlock").Return(logpoller.LogPollerBlock{BlockNumber: int64(100)}, nil)
client.On("CallContract", mock.Anything, ethereum.CallMsg{ // getContractById
Expand Down Expand Up @@ -289,7 +284,6 @@ func TestLogPollerWrapper_LatestEvents_ReorgHandlingV2(t *testing.T) {
}

func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_TruncatesLogs(t *testing.T) {
t.Parallel()
_, lpWrapper, _ := setUp(t, 100_000)

inputLogs := make([]logpoller.Log, maxLogsToProcess+100)
Expand All @@ -307,7 +301,6 @@ func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_TruncatesLogs(t *testin
}

func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_SkipsInvalidLog(t *testing.T) {
t.Parallel()
_, lpWrapper, _ := setUp(t, 100_000)
inputLogs := []logpoller.Log{getMockedRequestLogV1(t)}
inputLogs[0].Topics = [][]byte{[]byte("invalid topic")}
Expand All @@ -322,7 +315,6 @@ func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_SkipsInvalidLog(t *test
}

func TestLogPollerWrapper_FilterPreviouslyDetectedEvents_FiltersPreviouslyDetectedEvent(t *testing.T) {
t.Parallel()
_, lpWrapper, _ := setUp(t, 100_000)
mockedRequestLog := getMockedRequestLogV1(t)
inputLogs := []logpoller.Log{mockedRequestLog}
Expand Down

0 comments on commit 1ba2c06

Please sign in to comment.