Skip to content

Commit

Permalink
automation test config - add contract addresses
Browse files Browse the repository at this point in the history
  • Loading branch information
@anirudhwarrier
anirudhwarrier committed Sep 19, 2024
1 parent 561a057 commit b2b40c3
Show file tree
Hide file tree
Showing 8 changed files with 492 additions and 56 deletions.
142 changes: 95 additions & 47 deletions integration-tests/actions/automationv2/actions.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@ import (
"testing"
"time"

tt "github.com/smartcontractkit/chainlink/integration-tests/types"

"github.com/ethereum/go-ethereum/accounts/abi"
"github.com/ethereum/go-ethereum/common"
"github.com/lib/pq"
Expand Down Expand Up @@ -61,6 +63,8 @@ type NodeDetails struct {
type AutomationTest struct {
ChainClient *seth.Client

TestConfig tt.AutomationTestConfig

LinkToken contracts.LinkToken
Transcoder contracts.UpkeepTranscoder
LINKETHFeed contracts.MockLINKETHFeed
Expand Down Expand Up @@ -110,9 +114,11 @@ func NewAutomationTestK8s(
l zerolog.Logger,
chainClient *seth.Client,
chainlinkNodes []*client.ChainlinkK8sClient,
config tt.AutomationTestConfig,
) *AutomationTest {
return &AutomationTest{
ChainClient: chainClient,
TestConfig: config,
ChainlinkNodesk8s: chainlinkNodes,
IsOnk8s: true,
TransmitterKeyIndex: 0,
Expand All @@ -126,9 +132,11 @@ func NewAutomationTestDocker(
l zerolog.Logger,
chainClient *seth.Client,
chainlinkNodes []*client.ChainlinkClient,
config tt.AutomationTestConfig,
) *AutomationTest {
return &AutomationTest{
ChainClient: chainClient,
TestConfig: config,
ChainlinkNodes: chainlinkNodes,
IsOnk8s: false,
TransmitterKeyIndex: 0,
Expand Down Expand Up @@ -874,61 +882,101 @@ func (a *AutomationTest) setupDeployment(t *testing.T, addJobs bool) {
l.Info().Msg("Collected Node Details")
l.Debug().Interface("Node Details", a.NodeDetails).Msg("Node Details")

err = a.DeployLINK()
require.NoError(t, err, "Error deploying link token contract")
if a.TestConfig.GetAutomationConfig().UseExistingLinkTokenContract() {
linkAddress, err := a.TestConfig.GetAutomationConfig().LinkTokenContractAddress()
require.NoError(t, err, "Error getting link token contract address")
err = a.LoadLINK(linkAddress.String())
require.NoError(t, err, "Error loading link token contract")
} else {
err = a.DeployLINK()
require.NoError(t, err, "Error deploying link token contract")
}

err = a.DeployWETH()
require.NoError(t, err, "Error deploying weth token contract")
if a.TestConfig.GetAutomationConfig().UseExistingWethContract() {
wethAddress, err := a.TestConfig.GetAutomationConfig().WethContractAddress()
require.NoError(t, err, "Error getting weth token contract address")
err = a.LoadWETH(wethAddress.String())
require.NoError(t, err, "Error loading weth token contract")
} else {
err = a.DeployWETH()
require.NoError(t, err, "Error deploying weth token contract")
}

err = a.DeployLinkEthFeed()
require.NoError(t, err, "Error deploying link eth feed contract")
err = a.DeployGasFeed()
require.NoError(t, err, "Error deploying gas feed contract")
if a.TestConfig.GetAutomationConfig().UseExistingLinkEthFeedContract() {
linkEthFeedAddress, err := a.TestConfig.GetAutomationConfig().LinkEthFeedContractAddress()
require.NoError(t, err, "Error getting link eth feed contract address")
err = a.LoadLinkEthFeed(linkEthFeedAddress.String())
require.NoError(t, err, "Error loading link eth feed contract")
} else {
err = a.DeployLinkEthFeed()
require.NoError(t, err, "Error deploying link eth feed contract")
}

err = a.DeployEthUSDFeed()
require.NoError(t, err, "Error deploying eth usd feed contract")
if a.TestConfig.GetAutomationConfig().UseExistingEthGasFeedContract() {
gasFeedAddress, err := a.TestConfig.GetAutomationConfig().EthGasFeedContractAddress()
require.NoError(t, err, "Error getting gas feed contract address")
err = a.LoadEthGasFeed(gasFeedAddress.String())
require.NoError(t, err, "Error loading gas feed contract")
} else {
err = a.DeployGasFeed()
require.NoError(t, err, "Error deploying gas feed contract")
}

err = a.DeployLinkUSDFeed()
require.NoError(t, err, "Error deploying link usd feed contract")
if a.TestConfig.GetAutomationConfig().UseExistingEthUSDFeedContract() {
ethUsdFeedAddress, err := a.TestConfig.GetAutomationConfig().EthUSDFeedContractAddress()
require.NoError(t, err, "Error getting eth usd feed contract address")
err = a.LoadEthUSDFeed(ethUsdFeedAddress.String())
require.NoError(t, err, "Error loading eth usd feed contract")
} else {
err = a.DeployEthUSDFeed()
require.NoError(t, err, "Error deploying eth usd feed contract")
}

err = a.DeployTranscoder()
require.NoError(t, err, "Error deploying transcoder contract")
if a.TestConfig.GetAutomationConfig().UseExistingLinkUSDFeedContract() {
linkUsdFeedAddress, err := a.TestConfig.GetAutomationConfig().LinkUSDFeedContractAddress()
require.NoError(t, err, "Error getting link usd feed contract address")
err = a.LoadLinkUSDFeed(linkUsdFeedAddress.String())
require.NoError(t, err, "Error loading link usd feed contract")
} else {
err = a.DeployLinkUSDFeed()
require.NoError(t, err, "Error deploying link usd feed contract")
}

err = a.DeployRegistry()
require.NoError(t, err, "Error deploying registry contract")
err = a.DeployRegistrar()
require.NoError(t, err, "Error deploying registrar contract")
if a.TestConfig.GetAutomationConfig().UseExistingTranscoderContract() {
transcoderAddress, err := a.TestConfig.GetAutomationConfig().TranscoderContractAddress()
require.NoError(t, err, "Error getting transcoder contract address")
err = a.LoadTranscoder(transcoderAddress.String())
require.NoError(t, err, "Error loading transcoder contract")
} else {
err = a.DeployTranscoder()
require.NoError(t, err, "Error deploying transcoder contract")
}

if a.TestConfig.GetAutomationConfig().UseExistingRegistryContract() {
registryAddress, err := a.TestConfig.GetAutomationConfig().RegistryContractAddress()
require.NoError(t, err, "Error getting registry contract address")
err = a.LoadRegistry(registryAddress.String())
require.NoError(t, err, "Error loading registry contract")
if a.Registry.RegistryOwnerAddress() != a.ChainClient.MustGetRootKeyAddress() {
t.Error("Registry owner address is not the root key address")
t.FailNow()
}
} else {
err = a.DeployRegistry()
require.NoError(t, err, "Error deploying registry contract")
}

if a.TestConfig.GetAutomationConfig().UseExistingRegistrarContract() {
registrarAddress, err := a.TestConfig.GetAutomationConfig().RegistrarContractAddress()
require.NoError(t, err, "Error getting registrar contract address")
err = a.LoadRegistrar(registrarAddress.String())
require.NoError(t, err, "Error loading registrar contract")
} else {
err = a.DeployRegistrar()
require.NoError(t, err, "Error deploying registrar contract")
}

if addJobs {
a.AddJobsAndSetConfig(t)
}
}

func (a *AutomationTest) LoadAutomationDeployment(t *testing.T, linkTokenAddress,
linkEthFeedAddress, linkUsdFeedAddress, EthUsdFeedAddress, gasFeedAddress, transcoderAddress, registryAddress, registrarAddress string) {
l := logging.GetTestLogger(t)
err := a.CollectNodeDetails()
require.NoError(t, err, "Error collecting node details")
l.Info().Msg("Collected Node Details")
l.Debug().Interface("Node Details", a.NodeDetails).Msg("Node Details")

err = a.LoadLINK(linkTokenAddress)
require.NoError(t, err, "Error loading link token contract")

err = a.LoadLinkEthFeed(linkEthFeedAddress)
require.NoError(t, err, "Error loading link eth feed contract")
err = a.LoadEthGasFeed(gasFeedAddress)
require.NoError(t, err, "Error loading gas feed contract")
err = a.LoadEthUSDFeed(EthUsdFeedAddress)
require.NoError(t, err, "Error loading eth usd feed contract")
err = a.LoadLinkUSDFeed(linkUsdFeedAddress)
require.NoError(t, err, "Error loading link usd feed contract")
err = a.LoadTranscoder(transcoderAddress)
require.NoError(t, err, "Error loading transcoder contract")
err = a.LoadRegistry(registryAddress)
require.NoError(t, err, "Error loading registry contract")
err = a.LoadRegistrar(registrarAddress)
require.NoError(t, err, "Error loading registrar contract")

a.AddJobsAndSetConfig(t)
}
2 changes: 1 addition & 1 deletion integration-tests/benchmark/automation_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -126,7 +126,7 @@ func TestAutomationBenchmark(t *testing.T) {
}
}
})
keeperBenchmarkTest.Setup(testEnvironment, &config)
keeperBenchmarkTest.Setup(testEnvironment, config)
keeperBenchmarkTest.Run()
}

Expand Down
2 changes: 1 addition & 1 deletion integration-tests/chaos/automation_chaos_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -240,7 +240,7 @@ func TestAutomationChaos(t *testing.T) {
require.NoError(t, err, "Error tearing down environment")
})

a := automationv2.NewAutomationTestK8s(l, chainClient, chainlinkNodes)
a := automationv2.NewAutomationTestK8s(l, chainClient, chainlinkNodes, &config)
a.SetMercuryCredentialName("cred1")
a.RegistrySettings = actions.ReadRegistryConfig(config)
a.RegistrySettings.RegistryVersion = rv
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/load/automationv2_1/automationv2_1_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -311,7 +311,7 @@ Load Config:
multicallAddress, err := contracts.DeployMultiCallContract(chainClient)
require.NoError(t, err, "Error deploying multicall contract")

a := automationv2.NewAutomationTestK8s(l, chainClient, chainlinkNodes)
a := automationv2.NewAutomationTestK8s(l, chainClient, chainlinkNodes, &loadedTestConfig)
a.RegistrySettings = actions.ReadRegistryConfig(loadedTestConfig)
a.RegistrySettings.RegistryVersion = registryVersion
a.PluginConfig = actions.ReadPluginConfig(loadedTestConfig)
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/reorg/automation_reorg_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ func TestAutomationReorg(t *testing.T) {

gethRPCClient := ctfClient.NewRPCClient(evmNetwork.HTTPURLs[0], nil)

a := automationv2.NewAutomationTestDocker(l, sethClient, nodeClients)
a := automationv2.NewAutomationTestDocker(l, sethClient, nodeClients, &config)
a.SetMercuryCredentialName("cred1")
a.RegistrySettings = actions.ReadRegistryConfig(config)
a.RegistrySettings.RegistryVersion = registryVersion
Expand Down
2 changes: 1 addition & 1 deletion integration-tests/smoke/automation_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1435,7 +1435,7 @@ func setupAutomationTestDocker(
_ = actions.ReturnFundsFromNodes(l, sethClient, contracts.ChainlinkClientToChainlinkNodeWithKeysAndAddress(env.ClCluster.NodeAPIs()))
})

a := automationv2.NewAutomationTestDocker(l, sethClient, nodeClients)
a := automationv2.NewAutomationTestDocker(l, sethClient, nodeClients, automationTestConfig)
a.SetMercuryCredentialName("cred1")
a.RegistrySettings = registryConfig
a.RegistrarSettings = contracts.KeeperRegistrarSettings{
Expand Down
Loading

0 comments on commit b2b40c3

Please sign in to comment.