-
Notifications
You must be signed in to change notification settings - Fork 1.7k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* rmn home reader test * go mod tidy * get latest ccip commit * lint * changeset * use final commit * test fixing * cleaup method * fix lint * addressing comments * using latest ccip commit * change frequency * use latest ccip commit * bump ccip * fix test * err check * tidy * increase eventually time * tidy * change chainlink-ccip * mod change * script go.mod change * fix encoding * 100ms
- Loading branch information
Showing
3 changed files
with
272 additions
and
23 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,5 @@ | ||
| --- | ||
| "chainlink": minor | ||
| --- | ||
|
|
||
| #internal: Adding test for rmn home reader |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
174 changes: 174 additions & 0 deletions
174
core/capabilities/ccip/ccip_integration_tests/rmn/rmn_home_test.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,174 @@ | ||
| package rmn | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "math/big" | ||
| "slices" | ||
| "testing" | ||
| "time" | ||
|
|
||
| "github.com/smartcontractkit/chainlink/v2/core/capabilities/ccip/ccip_integration_tests/integrationhelpers" | ||
|
|
||
| "github.com/smartcontractkit/chainlink-ccip/pkg/consts" | ||
| "github.com/smartcontractkit/chainlink-common/pkg/types" | ||
|
|
||
| "github.com/stretchr/testify/require" | ||
|
|
||
| "github.com/ethereum/go-ethereum/accounts/abi/bind" | ||
|
|
||
| readerpkg "github.com/smartcontractkit/chainlink-ccip/pkg/reader" | ||
| "github.com/smartcontractkit/chainlink/v2/core/internal/testutils" | ||
| "github.com/smartcontractkit/chainlink/v2/core/logger" | ||
|
|
||
| "github.com/smartcontractkit/chainlink/v2/core/gethwrappers/ccip/generated/rmn_home" | ||
| ) | ||
|
|
||
| func TestRMNHomeReader_GetRMNNodesInfo(t *testing.T) { | ||
| ctx := testutils.Context(t) | ||
| lggr := logger.TestLogger(t) | ||
| uni := integrationhelpers.NewTestUniverse(ctx, t, lggr) | ||
| zeroBytes := [32]byte{0} | ||
|
|
||
| const ( | ||
| chainID1 = 1 | ||
| minObservers1 = 1 | ||
| observerBitmap1 = 1 | ||
|
|
||
| chainID2 = 2 | ||
| minObservers2 = 0 | ||
| observerBitmap2 = 1 | ||
| ) | ||
|
|
||
| //================================Deploy and configure RMNHome=============================== | ||
| rmnHomeAddress, _, rmnHome, err := rmn_home.DeployRMNHome(uni.Transactor, uni.Backend) | ||
| require.NoError(t, err) | ||
| uni.Backend.Commit() | ||
|
|
||
| staticConfig, dynamicConfig, err := integrationhelpers.GenerateRMNHomeConfigs( | ||
| "PeerID1", | ||
| "0123456789abcdef0123456789abcdef0123456789abcdef0123456789abcdef", | ||
| "This is a sample offchain configuration in the static config", | ||
| chainID1, | ||
| minObservers1, | ||
| big.NewInt(observerBitmap1), | ||
| ) | ||
| require.NoError(t, err) | ||
|
|
||
| _, err = rmnHome.SetCandidate(uni.Transactor, staticConfig, dynamicConfig, zeroBytes) | ||
| require.NoError(t, err) | ||
| uni.Backend.Commit() | ||
|
|
||
| configDigest, err := rmnHome.GetCandidateDigest(&bind.CallOpts{}) | ||
| require.NoError(t, err) | ||
|
|
||
| _, err = rmnHome.PromoteCandidateAndRevokeActive(uni.Transactor, configDigest, zeroBytes) | ||
| require.NoError(t, err) | ||
| uni.Backend.Commit() | ||
|
|
||
| rmnHomeBoundContract := types.BoundContract{ | ||
| Address: rmnHomeAddress.String(), | ||
| Name: consts.ContractNameRMNHome, | ||
| } | ||
|
|
||
| err = uni.HomeContractReader.Bind(testutils.Context(t), []types.BoundContract{rmnHomeBoundContract}) | ||
| require.NoError(t, err) | ||
|
|
||
| rmnHomeReader := readerpkg.NewRMNHomePoller(uni.HomeContractReader, rmnHomeBoundContract, lggr, 100*time.Millisecond) | ||
|
|
||
| err = rmnHomeReader.Start(testutils.Context(t)) | ||
| require.NoError(t, err) | ||
|
|
||
| t.Cleanup(func() { | ||
| err1 := rmnHomeReader.Close() | ||
| require.NoError(t, err1) | ||
| }) | ||
|
|
||
| //================================Test RMNHome Reader=============================== | ||
| expectedNodesInfo := integrationhelpers.GenerateExpectedRMNHomeNodesInfo(staticConfig, chainID1) | ||
|
|
||
| require.Eventually( | ||
| t, | ||
| assertRMNHomeNodesInfo(t, rmnHomeReader, configDigest, expectedNodesInfo, nil), | ||
| 5*time.Second, | ||
| 100*time.Millisecond, | ||
| ) | ||
|
|
||
| // Add a new candidate config | ||
| staticConfig2, dynamicConfig2, err := integrationhelpers.GenerateRMNHomeConfigs( | ||
| "PeerID2", | ||
| "1123456789abcdef0123456789abcdef0123456789abcdef0123456789abcdef", | ||
| "This is a sample offchain configuration in the static config 2", | ||
| chainID2, | ||
| minObservers2, | ||
| big.NewInt(observerBitmap2), | ||
| ) | ||
| require.NoError(t, err) | ||
|
|
||
| _, err = rmnHome.SetCandidate(uni.Transactor, staticConfig2, dynamicConfig2, zeroBytes) | ||
| require.NoError(t, err) | ||
| uni.Backend.Commit() | ||
|
|
||
| candidateConfigDigest, err := rmnHome.GetCandidateDigest(&bind.CallOpts{}) | ||
| require.NoError(t, err) | ||
|
|
||
| expectedCandidateNodesInfo := integrationhelpers.GenerateExpectedRMNHomeNodesInfo(staticConfig2, chainID2) | ||
|
|
||
| require.Eventually( | ||
| t, | ||
| assertRMNHomeNodesInfo(t, rmnHomeReader, candidateConfigDigest, expectedCandidateNodesInfo, nil), | ||
| 5*time.Second, | ||
| 100*time.Millisecond, | ||
| ) | ||
|
|
||
| // Promote the candidate config | ||
| _, err = rmnHome.PromoteCandidateAndRevokeActive(uni.Transactor, candidateConfigDigest, configDigest) | ||
| require.NoError(t, err) | ||
| uni.Backend.Commit() | ||
|
|
||
| require.Eventually( | ||
| t, | ||
| assertRMNHomeNodesInfo(t, rmnHomeReader, candidateConfigDigest, expectedCandidateNodesInfo, &configDigest), | ||
| 5*time.Second, | ||
| 100*time.Millisecond, | ||
| ) | ||
| } | ||
|
|
||
| func assertRMNHomeNodesInfo( | ||
| t *testing.T, | ||
| rmnHomeReader readerpkg.RMNHome, | ||
| configDigest [32]byte, | ||
| expectedNodesInfo []readerpkg.HomeNodeInfo, | ||
| prevConfigDigest *[32]byte, | ||
| ) func() bool { | ||
| return func() bool { | ||
| nodesInfo, err := rmnHomeReader.GetRMNNodesInfo(configDigest) | ||
| if err != nil { | ||
| t.Logf("Error getting RMN nodes info: %v", err) | ||
| return false | ||
| } | ||
|
|
||
| equal := slices.EqualFunc(expectedNodesInfo, nodesInfo, func(a, b readerpkg.HomeNodeInfo) bool { | ||
| return a.ID == b.ID && | ||
| a.PeerID == b.PeerID && | ||
| bytes.Equal(*a.OffchainPublicKey, *b.OffchainPublicKey) && | ||
| a.SupportedSourceChains.Equal(b.SupportedSourceChains) | ||
| }) | ||
|
|
||
| if !equal { | ||
| t.Logf("Expected nodes info doesn't match actual nodes info") | ||
| t.Logf("Expected: %+v", expectedNodesInfo) | ||
| t.Logf("Actual: %+v", nodesInfo) | ||
| return false | ||
| } | ||
|
|
||
| if prevConfigDigest != nil { | ||
| isPrevConfigStillSet := rmnHomeReader.IsRMNHomeConfigDigestSet(*prevConfigDigest) | ||
| if isPrevConfigStillSet { | ||
| t.Logf("Previous config is still set") | ||
| return false | ||
| } | ||
| } | ||
|
|
||
| return true | ||
| } | ||
| } |