fix starting block delay

smartcontractkit · Feb 10, 2025 · 0b7c50c · 0b7c50c
1 parent 1487f8f
commit 0b7c50c
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 8 deletions.
diff --git a/integration-tests/common/common.go b/integration-tests/common/common.go
@@ -36,7 +36,7 @@ type Common struct {
 	TestConfig     *tc.TestConfig
 	TestEnvDetails *TestEnvDetails
 	ClConfig       map[string]interface{}
-	EnvVariables   map[string]interface{}
+	EnvVariables   map[string]string
 	Env            *environment.Environment
 	DockerEnv      *SolCLClusterTestEnv
 	AccountDetails *AccountDetails

diff --git a/integration-tests/soak/log_poller_test.go b/integration-tests/soak/log_poller_test.go
@@ -1,7 +1,6 @@
 package soak
 
 import (
-	"os"
 	"testing"
 
 	"github.com/stretchr/testify/require"
@@ -16,10 +15,10 @@ func TestLogPollerPerformance(t *testing.T) {
 	if err != nil {
 		t.Fatal(err)
 	}
-	config.EnvVariables = map[string]interface{}{
-		"LOG_POLLER_TEST":         os.Getenv("LOG_POLLER_TEST"), // MIMIC|MOCKER_RATE
-		"SOURCE_CONTRACT_ADDRESS": "",                           // only required for MIMIC test
-		"EVENTS_PER_SEC":          "10",                         // only used by MOCKED_RATE
+	config.EnvVariables = map[string]string{
+		"LOG_POLLER_TEST":         "MOCKER_RATE", // MIMIC|MOCKER_RATE
+		"SOURCE_CONTRACT_ADDRESS": "",            // only required for MIMIC test
+		"EVENTS_PER_SEC":          "10",          // only used by MOCKED_RATE
 	}
 	name := "lp-mimic-performance"
 	state, err := common.NewOCRv2State(t, 1, name, &config)

diff --git a/integration-tests/testconfig/testconfig.go b/integration-tests/testconfig/testconfig.go
@@ -40,7 +40,7 @@ type TestConfig struct {
 	OCR2                  *ocr2_config.Config              `toml:"OCR2"`
 	SolanaConfig          *SolanaConfig                    `toml:"SolanaConfig"`
 	ConfigurationName     string                           `toml:"-"`
-	EnvVariables          map[string]interface{}           `toml:"-"`
+	EnvVariables          map[string]string                `toml:"-"`
 
 	// getter funcs for passing parameters
 	GetChainID func() string

diff --git a/pkg/solana/logpoller/log_poller_mimic_contract.go b/pkg/solana/logpoller/log_poller_mimic_contract.go
@@ -69,7 +69,7 @@ func tryRegisterCCIPMessageSentFilter(ctx context.Context, lp *Service) error {
 		return fmt.Errorf("failed to get latest slot: %w", err)
 	}
 
-	startingBlock := slot - 500 // 8 hours delay
+	startingBlock := slot - 72000 // 8 hours delay
 	version := client.MaxSupportTransactionVersion
 	block, err := lp.client.GetBlockWithOpts(ctx, startingBlock, &rpc.GetBlockOpts{MaxSupportedTransactionVersion: &version})
 	if err != nil {