From e78b6ea0e42592e293832c0566d3c84483915555 Mon Sep 17 00:00:00 2001 From: Makram Kamaleddine Date: Tue, 16 Jul 2024 23:03:20 +0300 Subject: [PATCH] fix replay logic slightly --- .../ocr3/plugins/ccip_integration_tests/ocr3_node_test.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/core/services/ocr3/plugins/ccip_integration_tests/ocr3_node_test.go b/core/services/ocr3/plugins/ccip_integration_tests/ocr3_node_test.go index 195b0f437f..73c8fdea35 100644 --- a/core/services/ocr3/plugins/ccip_integration_tests/ocr3_node_test.go +++ b/core/services/ocr3/plugins/ccip_integration_tests/ocr3_node_test.go @@ -177,12 +177,16 @@ func TestIntegration_OCR3Nodes(t *testing.T) { replayBlock = endBlock } } + replayBlocks[chainID] = replayBlock } // replay the log poller on all the chains so that the logs are in the db. // otherwise the plugins won't pick them up. + // TODO: this is happening too early, we need to wait for the chain readers to get their config + // and register the LP filters before this has any effect. for _, node := range nodes { for chainID, replayBlock := range replayBlocks { + t.Logf("Replaying logs for chain %d from block %d", chainID, replayBlock) require.NoError(t, node.app.ReplayFromBlock(big.NewInt(int64(chainID)), replayBlock, false), "failed to replay logs") } }