Skip to content

Commit

Permalink
[TT-1140] Cl node test log scanner (#13161)
Browse files Browse the repository at this point in the history 
* add back functionality that checks cl node logs after tests for errors

* add comment, newer CTF version

* use CTF release version

* ignore expected errors in cl node logs

* fix go.mod

* fix load tests

* fix lints

* fix lints again

* fix another vrfv2 log error

* use CTF release version

* [TT-922, TT-943] Migrate automation and log poller tests to Seth (#12688)

* WIP#1

* fix load test

* lints

* lints again

* uncomment tests

* fix logtrigger mercury test

* set privilege before starting consumer

* WIP#2

* WIP#2 - with high concurrency upkeep registration fails

* more or less working

* WIP#4

* small fixes

* fix lints

* use latest Seth

* Migrated keeper benchmark, kind of

* migrate keeper smoke tests

* bunch of optimisation

* migrate automation chaos test

* migrate log poller tests to Seth

* use anysynced key with log poller

* fix some of failing smoke tests

* fix go mod

* use correct Seth version

* better automation some test structure

* better automation some test structure

* go mod

* fix issues with missing LINK funds

* fix keeper test

* fix automation test

* clean up, comments, migrate keeper benchmark test

* mend

* use latest Seth

* cleanups, comments, etc

* clean ups, automation tests + keeper tests now always test multiple contracts

* use newer action version

* debug results when upkeeps fails

* run automation tests with post-failure debug

* run automation tests with post-failure debug

* better staleness report

* more debug for basic automation tests

* more assertions

* try with sleep

* increase performance check timeout to 3m

* separate config from consumer start

* more debug for performance chcek

* try with just 1 contract

* one more clean up

* run keeper tests in CI to test them

* solve automation load test registration failures

* subscribe to headers in benchmark test to observe upkeeps

* centralised ephemeral keys on testnet check, fixed keeper smoke tests, added root key buffer check

* do not fail, when on testnet and ephemeral keys are !=0, set them 0 instead

* don't fail in test config, display warning if eph addresses are set and set them to 0

* fix possible nil pointer, remove block range timeout, mutex for error appending

* update seth version

* use buffered channel to read subscription headers from EVM node

* benchmark test increase RR mem and set DEBUG log level

* use CTF's concurrent executor to deploy contracts in parallel

* change architecture so that we have only 1 subscription and then we fan out the header to all goroutines; use SafeEVMHeader

* benchmark test increase geth disk and gaslimit

* decrease log level, latest seth and ctf

* update CTF dependency

* use concurrent executor in automation load test

* remove local replace

* add header subscription reconnect handling

* print return funds error

* limit automation load test deployment concurrency

* latest Seth + fix gun

* do not run keeper smoke tests on each commit anymore

* add one more error message

* use tagged CTF

* use latest Seth

* use latest Seth

* fix go.mod

* forget about smart reconnect, just do it in a loop

* use latest Seth

* check if context has error before executing any of contract calling wrapper functions

* prettify code + latest Seth

* update Seth

* optional retrying of read-only contract calls; used only by keeper benchmark test

* update Seth, estimate gas for funds sending

* fix new automation test, update Seth to v1.0.7

* increase timeout

* fix max price smoke test

* fix CreateOCRKeeperJobs for v2.0

* remove resolved TODO

* code review changes

* code review changes

* code review changes vol 2

* use CTF release version

* bump mod version

---------

Co-authored-by: anirudhwarrier <[email protected]>

* add exception to other chaos log poller smoke tests

---------

Co-authored-by: anirudhwarrier <[email protected]>
  • Loading branch information
@Tofel @anirudhwarrier
Tofel and anirudhwarrier authored May 15, 2024
1 parent 4f502c9 commit 6ee7c81
Show file tree
Hide file tree
Showing 13 changed files with 237 additions and 69 deletions.
16 changes: 14 additions & 2 deletions integration-tests/actions/vrf/vrfv2/setup_steps.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -320,7 +320,16 @@ func SetupVRFV2WrapperEnvironment(
return wrapperContracts, &wrapperSubID, nil
}

func SetupVRFV2Universe(ctx context.Context, t *testing.T, testConfig tc.TestConfig, chainID int64, cleanupFn func(), newEnvConfig vrfcommon.NewEnvConfig, l zerolog.Logger) (*test_env.CLClusterTestEnv, *vrfcommon.VRFContracts, *vrfcommon.VRFKeyData, map[vrfcommon.VRFNodeType]*vrfcommon.VRFNode, error) {
func SetupVRFV2Universe(
ctx context.Context,
t *testing.T,
testConfig tc.TestConfig,
chainID int64,
cleanupFn func(),
newEnvConfig vrfcommon.NewEnvConfig,
l zerolog.Logger,
chainlinkNodeLogScannerSettings test_env.ChainlinkNodeLogScannerSettings,
) (*test_env.CLClusterTestEnv, *vrfcommon.VRFContracts, *vrfcommon.VRFKeyData, map[vrfcommon.VRFNodeType]*vrfcommon.VRFNode, error) {
var (
env *test_env.CLClusterTestEnv
vrfContracts *vrfcommon.VRFContracts
Expand All @@ -334,7 +343,7 @@ func SetupVRFV2Universe(ctx context.Context, t *testing.T, testConfig tc.TestCon
return nil, nil, nil, nil, fmt.Errorf("%s, err: %w", "Error setting up VRF V2 for Existing env", err)
}
} else {
vrfContracts, vrfKey, env, nodeTypeToNodeMap, err = SetupVRFV2ForNewEnv(ctx, t, testConfig, chainID, cleanupFn, newEnvConfig, l)
vrfContracts, vrfKey, env, nodeTypeToNodeMap, err = SetupVRFV2ForNewEnv(ctx, t, testConfig, chainID, cleanupFn, newEnvConfig, l, chainlinkNodeLogScannerSettings)
if err != nil {
return nil, nil, nil, nil, fmt.Errorf("%s, err: %w", "Error setting up VRF V2 for New env", err)
}
Expand All @@ -350,17 +359,20 @@ func SetupVRFV2ForNewEnv(
cleanupFn func(),
newEnvConfig vrfcommon.NewEnvConfig,
l zerolog.Logger,
chainlinkNodeLogScannerSettings test_env.ChainlinkNodeLogScannerSettings,
) (*vrfcommon.VRFContracts, *vrfcommon.VRFKeyData, *test_env.CLClusterTestEnv, map[vrfcommon.VRFNodeType]*vrfcommon.VRFNode, error) {
network, err := actions.EthereumNetworkConfigFromConfig(l, &testConfig)
if err != nil {
return nil, nil, nil, nil, fmt.Errorf("%s, err: %w", "Error building ethereum network config", err)
}

env, err := test_env.NewCLTestEnvBuilder().
WithTestInstance(t).
WithTestConfig(&testConfig).
WithPrivateEthereumNetwork(network.EthereumNetworkConfig).
WithCLNodes(len(newEnvConfig.NodesToCreate)).
WithFunding(big.NewFloat(*testConfig.Common.ChainlinkNodeFunding)).
WithChainlinkNodeLogScanner(chainlinkNodeLogScannerSettings).
WithCustomCleanup(cleanupFn).
Build()

Expand Down
15 changes: 13 additions & 2 deletions integration-tests/actions/vrf/vrfv2plus/setup_steps.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -371,7 +371,16 @@ func SetupVRFV2PlusWrapperEnvironment(
return wrapperContracts, wrapperSubID, nil
}

func SetupVRFV2PlusUniverse(ctx context.Context, t *testing.T, testConfig tc.TestConfig, chainID int64, cleanupFn func(), newEnvConfig vrfcommon.NewEnvConfig, l zerolog.Logger) (*test_env.CLClusterTestEnv, *vrfcommon.VRFContracts, *vrfcommon.VRFKeyData, map[vrfcommon.VRFNodeType]*vrfcommon.VRFNode, error) {
func SetupVRFV2PlusUniverse(
ctx context.Context,
t *testing.T,
testConfig tc.TestConfig,
chainID int64,
cleanupFn func(),
newEnvConfig vrfcommon.NewEnvConfig,
l zerolog.Logger,
chainlinkNodeLogScannerSettings test_env.ChainlinkNodeLogScannerSettings,
) (*test_env.CLClusterTestEnv, *vrfcommon.VRFContracts, *vrfcommon.VRFKeyData, map[vrfcommon.VRFNodeType]*vrfcommon.VRFNode, error) {
var (
env *test_env.CLClusterTestEnv
vrfContracts *vrfcommon.VRFContracts
Expand All @@ -385,7 +394,7 @@ func SetupVRFV2PlusUniverse(ctx context.Context, t *testing.T, testConfig tc.Tes
return nil, nil, nil, nil, fmt.Errorf("%s, err: %w", "Error setting up VRF V2 Plus for Existing env", err)
}
} else {
vrfContracts, vrfKey, env, nodeTypeToNode, err = SetupVRFV2PlusForNewEnv(ctx, t, testConfig, chainID, cleanupFn, newEnvConfig, l)
vrfContracts, vrfKey, env, nodeTypeToNode, err = SetupVRFV2PlusForNewEnv(ctx, t, testConfig, chainID, cleanupFn, newEnvConfig, l, chainlinkNodeLogScannerSettings)
if err != nil {
return nil, nil, nil, nil, fmt.Errorf("%s, err: %w", "Error setting up VRF V2 Plus for New env", err)
}
Expand All @@ -401,6 +410,7 @@ func SetupVRFV2PlusForNewEnv(
cleanupFn func(),
newEnvConfig vrfcommon.NewEnvConfig,
l zerolog.Logger,
chainlinkNodeLogScannerSettings test_env.ChainlinkNodeLogScannerSettings,
) (*vrfcommon.VRFContracts, *vrfcommon.VRFKeyData, *test_env.CLClusterTestEnv, map[vrfcommon.VRFNodeType]*vrfcommon.VRFNode, error) {
network, err := actions.EthereumNetworkConfigFromConfig(l, &testConfig)
if err != nil {
Expand All @@ -412,6 +422,7 @@ func SetupVRFV2PlusForNewEnv(
WithPrivateEthereumNetwork(network.EthereumNetworkConfig).
WithCLNodes(len(newEnvConfig.NodesToCreate)).
WithFunding(big.NewFloat(*testConfig.Common.ChainlinkNodeFunding)).
WithChainlinkNodeLogScanner(chainlinkNodeLogScannerSettings).
WithCustomCleanup(cleanupFn).
Build()
if err != nil {
Expand Down
148 changes: 122 additions & 26 deletions integration-tests/docker/test_env/test_env_builder.go
View file
Original file line number Diff line number Diff line change
@@ -1,22 +1,27 @@
package test_env

import (
"errors"
"context"
"fmt"
"math/big"
"os"
"slices"
"testing"

"github.com/pkg/errors"
"github.com/rs/zerolog"
"github.com/rs/zerolog/log"
"github.com/smartcontractkit/seth"
"go.uber.org/zap/zapcore"
"golang.org/x/sync/errgroup"

"github.com/smartcontractkit/chainlink-testing-framework/blockchain"
ctf_config "github.com/smartcontractkit/chainlink-testing-framework/config"
"github.com/smartcontractkit/chainlink-testing-framework/docker/test_env"
"github.com/smartcontractkit/chainlink-testing-framework/logging"
"github.com/smartcontractkit/chainlink-testing-framework/logstream"
"github.com/smartcontractkit/chainlink-testing-framework/networks"
"github.com/smartcontractkit/chainlink-testing-framework/testreporters"
"github.com/smartcontractkit/chainlink-testing-framework/utils/osutil"

evmcfg "github.com/smartcontractkit/chainlink/v2/core/chains/evm/config/toml"
Expand All @@ -35,38 +40,65 @@ const (
CleanUpTypeCustom CleanUpType = "custom"
)

type ChainlinkNodeLogScannerSettings struct {
FailingLogLevel zapcore.Level
Threshold uint
AllowedMessages []testreporters.AllowedLogMessage
}

type CLTestEnvBuilder struct {
hasLogStream bool
hasKillgrave bool
hasForwarders bool
hasSeth bool
hasEVMClient bool
clNodeConfig *chainlink.Config
secretsConfig string
clNodesCount int
clNodesOpts []func(*ClNode)
customNodeCsaKeys []string
defaultNodeCsaKeys []string
l zerolog.Logger
t *testing.T
te *CLClusterTestEnv
isNonEVM bool
cleanUpType CleanUpType
cleanUpCustomFn func()
chainOptionsFn []ChainOption
evmNetworkOption []EVMNetworkOption
privateEthereumNetworks []*ctf_config.EthereumNetworkConfig
testConfig ctf_config.GlobalTestConfig
hasLogStream bool
hasKillgrave bool
hasForwarders bool
hasSeth bool
hasEVMClient bool
clNodeConfig *chainlink.Config
secretsConfig string
clNodesCount int
clNodesOpts []func(*ClNode)
customNodeCsaKeys []string
defaultNodeCsaKeys []string
l zerolog.Logger
t *testing.T
te *CLClusterTestEnv
isNonEVM bool
cleanUpType CleanUpType
cleanUpCustomFn func()
chainOptionsFn []ChainOption
evmNetworkOption []EVMNetworkOption
privateEthereumNetworks []*ctf_config.EthereumNetworkConfig
testConfig ctf_config.GlobalTestConfig
chainlinkNodeLogScannerSettings *ChainlinkNodeLogScannerSettings

/* funding */
ETHFunds *big.Float
}

var DefaultAllowedMessages = []testreporters.AllowedLogMessage{
testreporters.NewAllowedLogMessage("Failed to get LINK balance", "Happens only when we deploy LINK token for test purposes. Harmless.", zapcore.ErrorLevel, testreporters.WarnAboutAllowedMsgs_No),
}

var DefaultChainlinkNodeLogScannerSettings = ChainlinkNodeLogScannerSettings{
FailingLogLevel: zapcore.DPanicLevel,
Threshold: 1, // we want to fail on the first concerning log
AllowedMessages: DefaultAllowedMessages,
}

func GetDefaultChainlinkNodeLogScannerSettingsWithExtraAllowedMessages(extraAllowedMessages ...testreporters.AllowedLogMessage) ChainlinkNodeLogScannerSettings {
allowedMessages := append(DefaultAllowedMessages, extraAllowedMessages...)
return ChainlinkNodeLogScannerSettings{
FailingLogLevel: zapcore.DPanicLevel,
Threshold: 1,
AllowedMessages: allowedMessages,
}
}

func NewCLTestEnvBuilder() *CLTestEnvBuilder {
return &CLTestEnvBuilder{
l: log.Logger,
hasLogStream: true,
hasEVMClient: true,
l: log.Logger,
hasLogStream: true,
hasEVMClient: true,
chainlinkNodeLogScannerSettings: &DefaultChainlinkNodeLogScannerSettings,
}
}

Expand Down Expand Up @@ -114,6 +146,16 @@ func (b *CLTestEnvBuilder) WithoutLogStream() *CLTestEnvBuilder {
return b
}

func (b *CLTestEnvBuilder) WithoutChainlinkNodeLogScanner() *CLTestEnvBuilder {
b.chainlinkNodeLogScannerSettings = &ChainlinkNodeLogScannerSettings{}
return b
}

func (b *CLTestEnvBuilder) WithChainlinkNodeLogScanner(settings ChainlinkNodeLogScannerSettings) *CLTestEnvBuilder {
b.chainlinkNodeLogScannerSettings = &settings
return b
}

func (b *CLTestEnvBuilder) WithCLNodes(clNodesCount int) *CLTestEnvBuilder {
b.clNodesCount = clNodesCount
return b
Expand Down Expand Up @@ -231,6 +273,12 @@ func (b *CLTestEnvBuilder) Build() (*CLClusterTestEnv, error) {
}

if b.hasLogStream {
loggingConfig := b.testConfig.GetLoggingConfig()
// we need to enable logging to file if we want to scan logs
if b.chainlinkNodeLogScannerSettings != nil && !slices.Contains(loggingConfig.LogStream.LogTargets, string(logstream.File)) {
b.l.Debug().Msg("Enabling logging to file in order to support Chainlink node log scanning")
loggingConfig.LogStream.LogTargets = append(loggingConfig.LogStream.LogTargets, string(logstream.File))
}
b.te.LogStream, err = logstream.NewLogStream(b.te.t, b.testConfig.GetLoggingConfig())
if err != nil {
return nil, err
Expand Down Expand Up @@ -279,11 +327,55 @@ func (b *CLTestEnvBuilder) Build() (*CLClusterTestEnv, error) {
b.l.Info().Str("Absolute path", logPath).Msg("LogStream logs folder location")
}

var scanClNodeLogs = func() {
//filter out non-cl logs
logLocation := b.te.LogStream.GetLogLocation()
logFiles, err := testreporters.FindAllLogFilesToScan(logLocation, "cl-node")
if err != nil {
b.l.Warn().Err(err).Msg("Error looking for Chainlink Node log files to scan")
} else {
// we ignore the context returned by errgroup here, since we have no way of interrupting ongoing scanning of logs
verifyLogsGroup, _ := errgroup.WithContext(context.Background())
for _, f := range logFiles {
file := f
verifyLogsGroup.Go(func() error {
logErr := testreporters.VerifyLogFile(file, b.chainlinkNodeLogScannerSettings.FailingLogLevel, b.chainlinkNodeLogScannerSettings.Threshold, b.chainlinkNodeLogScannerSettings.AllowedMessages...)
if logErr != nil {
return errors.Wrapf(logErr, "Found a concerning log in %s", file.Name())
}
return nil
})
}
if err := verifyLogsGroup.Wait(); err != nil {
b.l.Error().Err(err).Msg("Found a concerning log. Failing test.")
b.t.Fatalf("Found a concerning log in Chainklink Node logs: %v", err)
}
}
b.l.Info().Msg("Finished scanning Chainlink Node logs for concerning errors")
}

if b.t.Failed() || *b.testConfig.GetLoggingConfig().TestLogCollect {
// we can't do much if this fails, so we just log the error in logstream
_ = b.te.LogStream.FlushAndShutdown()
flushErr := b.te.LogStream.FlushAndShutdown()
if flushErr != nil {
b.l.Error().Err(flushErr).Msg("Error flushing and shutting down LogStream")
return
}
b.te.LogStream.PrintLogTargetsLocations()
b.te.LogStream.SaveLogLocationInTestSummary()

// if test hasn't failed, but we have chainlinkNodeLogScannerSettings, we should check the logs
if !b.t.Failed() && b.chainlinkNodeLogScannerSettings != nil {
scanClNodeLogs()
}
} else if b.chainlinkNodeLogScannerSettings != nil {
flushErr := b.te.LogStream.FlushAndShutdown()
if flushErr != nil {
b.l.Error().Err(flushErr).Msg("Error flushing and shutting down LogStream")
return
}

scanClNodeLogs()
}
})
}
Expand All @@ -303,6 +395,10 @@ func (b *CLTestEnvBuilder) Build() (*CLClusterTestEnv, error) {
}
}

if b.te.LogStream == nil && b.chainlinkNodeLogScannerSettings != nil {
log.Warn().Msg("Chainlink node log scanner settings provided, but LogStream is not enabled. Ignoring Chainlink node log scanner settings, as no logs will be available.")
}

// in this case we will use the builder only to start chains, not the cluster, because currently we support only 1 network config per cluster
if len(b.privateEthereumNetworks) > 1 {
b.te.rpcProviders = make(map[int64]*test_env.RpcProvider)
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ require (
github.com/slack-go/slack v0.12.2
github.com/smartcontractkit/chainlink-automation v1.0.3
github.com/smartcontractkit/chainlink-common v0.1.7-0.20240514153505-0ddba5aa4d2c
github.com/smartcontractkit/chainlink-testing-framework v1.28.11
github.com/smartcontractkit/chainlink-testing-framework v1.28.12
github.com/smartcontractkit/chainlink-vrf v0.0.0-20231120191722-fef03814f868
github.com/smartcontractkit/chainlink/v2 v2.0.0-00010101000000-000000000000
github.com/smartcontractkit/libocr v0.0.0-20240419185742-fd3cab206b2c
Expand Down
4 changes: 2 additions & 2 deletions integration-tests/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1524,8 +1524,8 @@ github.com/smartcontractkit/chainlink-solana v1.0.3-0.20240510181707-46b1311a5a8
github.com/smartcontractkit/chainlink-solana v1.0.3-0.20240510181707-46b1311a5a83/go.mod h1:RdAtOeBUWq2zByw2kEbwPlXaPIb7YlaDOmnn+nVUBJI=
github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20240508155030-1024f2b55c69 h1:ssh/w3oXWu+C6bE88GuFRC1+0Bx/4ihsbc80XMLrl2k=
github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20240508155030-1024f2b55c69/go.mod h1:VsfjhvWgjxqWja4q+FlXEtX5lu8BSxn10xRo6gi948g=
github.com/smartcontractkit/chainlink-testing-framework v1.28.11 h1:6IcgmK/6UAfmcOYSiXudVlOa60MkbObTxA68hSJT4O4=
github.com/smartcontractkit/chainlink-testing-framework v1.28.11/go.mod h1:x1zDOz8zcLjEvs9fNA9y/DMguLam/2+CJdpxX0+rM8A=
github.com/smartcontractkit/chainlink-testing-framework v1.28.12 h1:15ssos9DvWekvj6JjmiPjTYsj/uw12HvTWlm1FHdYaA=
github.com/smartcontractkit/chainlink-testing-framework v1.28.12/go.mod h1:x1zDOz8zcLjEvs9fNA9y/DMguLam/2+CJdpxX0+rM8A=
github.com/smartcontractkit/chainlink-testing-framework/grafana v0.0.0-20240328204215-ac91f55f1449 h1:fX/xmGm1GBsD1ZZnooNT+eWA0hiTAqFlHzOC5CY4dy8=
github.com/smartcontractkit/chainlink-testing-framework/grafana v0.0.0-20240328204215-ac91f55f1449/go.mod h1:DC8sQMyTlI/44UCTL8QWFwb0bYNoXCfjwCv2hMivYZU=
github.com/smartcontractkit/chainlink-vrf v0.0.0-20231120191722-fef03814f868 h1:FFdvEzlYwcuVHkdZ8YnZR/XomeMGbz5E2F2HZI3I3w8=
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/load/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ require (
github.com/slack-go/slack v0.12.2
github.com/smartcontractkit/chainlink-automation v1.0.3
github.com/smartcontractkit/chainlink-common v0.1.7-0.20240514153505-0ddba5aa4d2c
github.com/smartcontractkit/chainlink-testing-framework v1.28.11
github.com/smartcontractkit/chainlink-testing-framework v1.28.12
github.com/smartcontractkit/chainlink/integration-tests v0.0.0-20240214231432-4ad5eb95178c
github.com/smartcontractkit/chainlink/v2 v2.9.0-beta0.0.20240216210048-da02459ddad8
github.com/smartcontractkit/libocr v0.0.0-20240419185742-fd3cab206b2c
Expand Down
4 changes: 2 additions & 2 deletions integration-tests/load/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1514,8 +1514,8 @@ github.com/smartcontractkit/chainlink-solana v1.0.3-0.20240510181707-46b1311a5a8
github.com/smartcontractkit/chainlink-solana v1.0.3-0.20240510181707-46b1311a5a83/go.mod h1:RdAtOeBUWq2zByw2kEbwPlXaPIb7YlaDOmnn+nVUBJI=
github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20240508155030-1024f2b55c69 h1:ssh/w3oXWu+C6bE88GuFRC1+0Bx/4ihsbc80XMLrl2k=
github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20240508155030-1024f2b55c69/go.mod h1:VsfjhvWgjxqWja4q+FlXEtX5lu8BSxn10xRo6gi948g=
github.com/smartcontractkit/chainlink-testing-framework v1.28.11 h1:6IcgmK/6UAfmcOYSiXudVlOa60MkbObTxA68hSJT4O4=
github.com/smartcontractkit/chainlink-testing-framework v1.28.11/go.mod h1:x1zDOz8zcLjEvs9fNA9y/DMguLam/2+CJdpxX0+rM8A=
github.com/smartcontractkit/chainlink-testing-framework v1.28.12 h1:15ssos9DvWekvj6JjmiPjTYsj/uw12HvTWlm1FHdYaA=
github.com/smartcontractkit/chainlink-testing-framework v1.28.12/go.mod h1:x1zDOz8zcLjEvs9fNA9y/DMguLam/2+CJdpxX0+rM8A=
github.com/smartcontractkit/chainlink-testing-framework/grafana v0.0.0-20240328204215-ac91f55f1449 h1:fX/xmGm1GBsD1ZZnooNT+eWA0hiTAqFlHzOC5CY4dy8=
github.com/smartcontractkit/chainlink-testing-framework/grafana v0.0.0-20240328204215-ac91f55f1449/go.mod h1:DC8sQMyTlI/44UCTL8QWFwb0bYNoXCfjwCv2hMivYZU=
github.com/smartcontractkit/chainlink-vrf v0.0.0-20231120191722-fef03814f868 h1:FFdvEzlYwcuVHkdZ8YnZR/XomeMGbz5E2F2HZI3I3w8=
Expand Down
4 changes: 2 additions & 2 deletions integration-tests/load/vrfv2/vrfv2_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ func TestVRFV2Performance(t *testing.T) {
UseTestCoordinator: true,
}

testEnv, vrfContracts, vrfKey, _, err = vrfv2.SetupVRFV2Universe(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l)
testEnv, vrfContracts, vrfKey, _, err = vrfv2.SetupVRFV2Universe(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l, test_env.DefaultChainlinkNodeLogScannerSettings)
require.NoError(t, err, "error setting up VRFV2 universe")

evmClient, err := testEnv.GetEVMClient(chainID)
Expand Down Expand Up @@ -243,7 +243,7 @@ func TestVRFV2BHSPerformance(t *testing.T) {
UseTestCoordinator: true,
}

testEnv, vrfContracts, vrfKey, _, err = vrfv2.SetupVRFV2Universe(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l)
testEnv, vrfContracts, vrfKey, _, err = vrfv2.SetupVRFV2Universe(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l, test_env.DefaultChainlinkNodeLogScannerSettings)
require.NoError(t, err, "error setting up VRFV2 universe")

evmClient, err := testEnv.GetEVMClient(chainID)
Expand Down
4 changes: 2 additions & 2 deletions integration-tests/load/vrfv2plus/vrfv2plus_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ func TestVRFV2PlusPerformance(t *testing.T) {
NumberOfTxKeysToCreate: *vrfv2PlusConfig.General.NumberOfSendingKeysToCreate,
}

testEnv, vrfContracts, vrfKey, _, err = vrfv2plus.SetupVRFV2PlusUniverse(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l)
testEnv, vrfContracts, vrfKey, _, err = vrfv2plus.SetupVRFV2PlusUniverse(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l, test_env.DefaultChainlinkNodeLogScannerSettings)
require.NoError(t, err, "error setting up VRFV2Plus universe")

evmClient, err := testEnv.GetEVMClient(chainID)
Expand Down Expand Up @@ -240,7 +240,7 @@ func TestVRFV2PlusBHSPerformance(t *testing.T) {
NumberOfTxKeysToCreate: *vrfv2PlusConfig.General.NumberOfSendingKeysToCreate,
}

testEnv, vrfContracts, vrfKey, _, err = vrfv2plus.SetupVRFV2PlusUniverse(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l)
testEnv, vrfContracts, vrfKey, _, err = vrfv2plus.SetupVRFV2PlusUniverse(testcontext.Get(t), t, testConfig, chainID, cleanupFn, newEnvConfig, l, test_env.DefaultChainlinkNodeLogScannerSettings)
require.NoError(t, err, "error setting up VRFV2Plus universe")

evmClient, err := testEnv.GetEVMClient(chainID)
Expand Down
Loading

0 comments on commit 6ee7c81

Please sign in to comment.