Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[E2E Test] Sequencer Rotation happy flow with only sequencer coming and syncing over DA #396

Merged
merged 5 commits into from
Sep 30, 2024
Merged

[E2E Test] Sequencer Rotation happy flow with only sequencer coming and syncing over DA #396

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
bb1f869
add Test_SeqRotation_OneSeq_EVM
ThanhNhann Aug 27, 2024
8d190e6
Merge branch 'main' into nhan/seq_rotation_with_one_seq
anhductn2001 Sep 29, 2024
f1131ec
Merge branch 'main' into nhan/seq_rotation_with_one_seq
anhductn2001 Sep 30, 2024
a3aaa26
fix tests
anhductn2001 Sep 30, 2024
4bb7fe6
Merge branch 'main' into nhan/seq_rotation_with_one_seq
anhductn2001 Sep 30, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions Makefile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -250,6 +250,9 @@ e2e-test-fullnode-sync-block-sync-evm: clean-e2e

e2e-test-fullnode-disconnect-block-sync-evm: clean-e2e
cd tests && go test -timeout=30m -race -v -run TestSync_BlockSync_fn_disconnect_EVM .

e2e-test-sequencer-rotation-oneseq-da-evm: clean-e2e
cd tests && go test -timeout=30m -race -v -run Test_SeqRotation_OneSeq_DA_EVM .

e2e-test-sequencer-rotation-oneseq-p2p-evm: clean-e2e
cd tests && go test -timeout=45m -race -v -run Test_SqcRotation_OneSqc_P2P_EVM .
Expand Down Expand Up @@ -488,6 +491,7 @@ e2e-test-all: e2e-test-ibc-success-evm \
e2e-test-eibc-fee-market-success-evm \
e2e-test-admc-metadata-not-found-evm \
e2e-test-fullnode-sync-block-sync-evm \
e2e-test-seq-rotation-one-seq-evm \
e2e-test-ibc-success-wasm \
e2e-test-ibc-timeout-wasm \
e2e-test-ibc-grace-period-wasm \
Expand Down Expand Up @@ -560,6 +564,7 @@ e2e-test-all: e2e-test-ibc-success-evm \
e2e-test-eibc-fee-market-success-evm \
e2e-test-admc-metadata-not-found-evm \
e2e-test-fullnode-sync-block-sync-evm \
e2e-test-seq-rotation-one-seq-evm \
e2e-test-ibc-success-wasm \
e2e-test-ibc-timeout-wasm \
e2e-test-ibc-grace-period-wasm \
Expand Down
357 changes: 357 additions & 0 deletions tests/sequencer_rotation_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,363 @@ import (
"github.com/decentrio/rollup-e2e-testing/testutil"
)

func Test_SeqRotation_OneSeq_DA_EVM(t *testing.T) {
if testing.Short() {
t.Skip()
}

ctx := context.Background()

go StartDA()

// setup config for rollapp 1
settlement_layer_rollapp1 := "dymension"
settlement_node_address := fmt.Sprintf("http://dymension_100-1-val-0-%s:26657", t.Name())
rollapp1_id := "rollappevm_1234-1"
gas_price_rollapp1 := "0adym"
maxIdleTime1 := "3s"
maxProofTime := "500ms"
configFileOverrides := overridesDymintToml(settlement_layer_rollapp1, settlement_node_address, rollapp1_id, gas_price_rollapp1, maxIdleTime1, maxProofTime, "20s", true)

modifyHubGenesisKV := append(
dymensionGenesisKV,
cosmos.GenesisKV{
Key: "app_state.sequencer.params.unbonding_time",
Value: "300s",
},
cosmos.GenesisKV{
Key: "app_state.staking.params.unbonding_time",
Value: "300s",
},
)

modifyRAGenesisKV := append(
rollappEVMGenesisKV,
cosmos.GenesisKV{
Key: "app_state.sequencers.params.unbonding_time",
Value: "300s",
},
cosmos.GenesisKV{
Key: "app_state.staking.params.unbonding_time",
Value: "300s",
},
cosmos.GenesisKV{
Key: "app_state.rollappparams.params.da",
Value: "grpc",
},
)

// Create chain factory with dymension
numHubVals := 1
numHubFullNodes := 1
numRollAppVals := 1
numRollAppFn := 1

cf := test.NewBuiltinChainFactory(zaptest.NewLogger(t), []*test.ChainSpec{
{
Name: "rollapp1",
ChainConfig: ibc.ChainConfig{
Type: "rollapp-dym",
Name: "rollapp-temp",
ChainID: "rollappevm_1234-1",
Images: []ibc.DockerImage{rollappEVMImage},
Bin: "rollappd",
Bech32Prefix: "ethm",
Denom: "urax",
CoinType: "60",
GasPrices: "0.0urax",
GasAdjustment: 1.1,
TrustingPeriod: "112h",
EncodingConfig: encodingConfig(),
NoHostMount: false,
ModifyGenesis: modifyRollappEVMGenesis(modifyRAGenesisKV),
ConfigFileOverrides: configFileOverrides,
},
NumValidators: &numRollAppVals,
NumFullNodes: &numRollAppFn,
},
{
Name: "dymension-hub",
ChainConfig: ibc.ChainConfig{
Type: "hub-dym",
Name: "dymension",
ChainID: "dymension_100-1",
Images: []ibc.DockerImage{dymensionImage},
Bin: "dymd",
Bech32Prefix: "dym",
Denom: "adym",
CoinType: "60",
GasPrices: "0.0adym",
EncodingConfig: encodingConfig(),
GasAdjustment: 1.1,
TrustingPeriod: "112h",
NoHostMount: false,
ModifyGenesis: modifyDymensionGenesis(modifyHubGenesisKV),
ConfigFileOverrides: nil,
},
NumValidators: &numHubVals,
NumFullNodes: &numHubFullNodes,
},
})

// Get chains from the chain factory
chains, err := cf.Chains(t.Name())
require.NoError(t, err)

rollapp1 := chains[0].(*dym_rollapp.DymRollApp)
dymension := chains[1].(*dym_hub.DymHub)

// Relayer Factory
client, network := test.DockerSetup(t)

// relayer for rollapp 1
r := test.NewBuiltinRelayerFactory(ibc.CosmosRly, zaptest.NewLogger(t),
relayer.CustomDockerImage(RelayerMainRepo, relayerVersion, "100:1000"), relayer.ImagePull(pullRelayerImage),
).Build(t, client, "relayer", network)

ic := test.NewSetup().
AddRollUp(dymension, rollapp1).
AddRelayer(r, "relayer").
AddLink(test.InterchainLink{
Chain1: dymension,
Chain2: rollapp1,
Relayer: r,
Path: ibcPath,
})

rep := testreporter.NewNopReporter()
eRep := rep.RelayerExecReporter(t)

err = ic.Build(ctx, eRep, test.InterchainBuildOptions{
TestName: t.Name(),
Client: client,
NetworkID: network,
SkipPathCreation: true,
}, nil, "", nil, true, 195)
require.NoError(t, err)

// Check IBC Transfer before switch
// CreateChannel(ctx, t, r, eRep, dymension.CosmosChain, rollapp1.CosmosChain, ibcPath)

// // Create some user accounts on both chains
// users := test.GetAndFundTestUsers(t, ctx, t.Name(), walletAmount, dymension, rollapp1)

// // Get our Bech32 encoded user addresses
// dymensionUser, rollappUser := users[0], users[1]

// dymensionUserAddr := dymensionUser.FormattedAddress()
// rollappUserAddr := rollappUser.FormattedAddress()

// channel, err := ibc.GetTransferChannel(ctx, r, eRep, dymension.Config().ChainID, rollapp1.Config().ChainID)
// require.NoError(t, err)

// err = r.StartRelayer(ctx, eRep, ibcPath)
// require.NoError(t, err)

// err = testutil.WaitForBlocks(ctx, 10, dymension, rollapp1)
// require.NoError(t, err)

// // Send a normal ibc tx from RA -> Hub
// transferData := ibc.WalletData{
// Address: dymensionUserAddr,
// Denom: rollapp1.Config().Denom,
// Amount: transferAmount,
// }

// // Compose an IBC transfer and send from rollapp -> Hub
// _, err = rollapp1.SendIBCTransfer(ctx, channel.ChannelID, rollappUserAddr, transferData, ibc.TransferOptions{})
// require.NoError(t, err)

// err = testutil.WaitForBlocks(ctx, 10, dymension, rollapp1)
// require.NoError(t, err)

// rollappHeight, err := rollapp1.GetNode().Height(ctx)
// require.NoError(t, err)

// // Assert balance was updated on the hub
// testutil.AssertBalance(t, ctx, rollapp1, rollappUserAddr, rollapp1.Config().Denom, walletAmount.Sub(transferData.Amount))

// // wait until the packet is finalized
// isFinalized, err := dymension.WaitUntilRollappHeightIsFinalized(ctx, rollapp1.GetChainID(), rollappHeight, 300)
// require.NoError(t, err)
// require.True(t, isFinalized)

// _, err = dymension.GetNode().FinalizePacketsUntilHeight(ctx, dymensionUserAddr, rollapp1.GetChainID(), fmt.Sprint(rollappHeight))
// require.NoError(t, err)

// // Get the IBC denom for urax on Hub
// rollappTokenDenom := transfertypes.GetPrefixedDenom(channel.Counterparty.PortID, channel.Counterparty.ChannelID, rollapp1.Config().Denom)
// rollappIBCDenom := transfertypes.ParseDenomTrace(rollappTokenDenom).IBCDenom()

// testutil.AssertBalance(t, ctx, dymension, dymensionUserAddr, rollappIBCDenom, transferAmount.Sub(bridgingFee))

// // Get original account balances
// dymensionOrigBal, err := dymension.GetBalance(ctx, dymensionUserAddr, dymension.Config().Denom)
// require.NoError(t, err)

// // Compose an IBC transfer and send from dymension -> rollapp
// transferData = ibc.WalletData{
// Address: rollappUserAddr,
// Denom: dymension.Config().Denom,
// Amount: transferAmount,
// }

// // Compose an IBC transfer and send from Hub -> rollapp
// _, err = dymension.SendIBCTransfer(ctx, channel.ChannelID, dymensionUserAddr, transferData, ibc.TransferOptions{})
// require.NoError(t, err)

// // Assert balance was updated on the hub
// testutil.AssertBalance(t, ctx, dymension, dymensionUserAddr, dymension.Config().Denom, dymensionOrigBal.Sub(transferData.Amount))

// err = testutil.WaitForBlocks(ctx, 10, dymension, rollapp1)
// require.NoError(t, err)

// // Get the IBC denom
// dymensionTokenDenom := transfertypes.GetPrefixedDenom(channel.Counterparty.PortID, channel.Counterparty.ChannelID, dymension.Config().Denom)
// dymensionIBCDenom := transfertypes.ParseDenomTrace(dymensionTokenDenom).IBCDenom()

// testutil.AssertBalance(t, ctx, dymension, dymensionUserAddr, dymension.Config().Denom, dymensionOrigBal.Sub(transferData.Amount))
// erc20MAcc, err := rollapp1.Validators[0].QueryModuleAccount(ctx, "erc20")
// require.NoError(t, err)
// erc20MAccAddr := erc20MAcc.Account.BaseAccount.Address
// testutil.AssertBalance(t, ctx, rollapp1, erc20MAccAddr, dymensionIBCDenom, transferData.Amount)

cmd := append([]string{rollapp1.FullNodes[0].Chain.Config().Bin}, "dymint", "show-sequencer", "--home", rollapp1.FullNodes[0].HomeDir())
pub1, _, err := rollapp1.GetNode().Exec(ctx, cmd, nil)
require.NoError(t, err)

err = dymension.GetNode().CreateKeyWithKeyDir(ctx, "sequencer", rollapp1.GetNode().HomeDir())
require.NoError(t, err)

sequencer, err := dymension.AccountKeyBech32WithKeyDir(ctx, "sequencer", rollapp1.GetNode().HomeDir())
require.NoError(t, err)

fund := ibc.WalletData{
Address: sequencer,
Denom: dymension.Config().Denom,
Amount: math.NewInt(10_000_000_000_000).MulRaw(100_000_000),
}
err = dymension.SendFunds(ctx, "faucet", fund)
require.NoError(t, err)

// Wait a few blocks for relayer to start and for user accounts to be created
err = testutil.WaitForBlocks(ctx, 5, dymension)
require.NoError(t, err)

command := []string{"sequencer", "create-sequencer", string(pub1), rollapp1.Config().ChainID, "1000000000adym", rollapp1.GetSequencerKeyDir() + "/metadata_sequencer1.json",
"--broadcast-mode", "async", "--keyring-dir", rollapp1.GetNode().HomeDir() + "/sequencer_keys"}

_, err = dymension.FullNodes[0].ExecTx(ctx, "sequencer", command...)
require.NoError(t, err)

res, err := dymension.QueryShowSequencerByRollapp(ctx, rollapp1.Config().ChainID)
require.NoError(t, err)
require.Equal(t, len(res.Sequencers), 2, "should have 2 sequences")

// Unbond sequencer1
err = dymension.Unbond(ctx, "sequencer", rollapp1.GetSequencerKeyDir())
require.NoError(t, err)

seqAddr, err := dymension.AccountKeyBech32WithKeyDir(ctx, "sequencer", rollapp1.GetSequencerKeyDir())
require.NoError(t, err)

queryGetSequencerResponse, err := dymension.QueryShowSequencer(ctx, seqAddr)
require.NoError(t, err)
require.Equal(t, "OPERATING_STATUS_BONDED", queryGetSequencerResponse.Sequencer.Status)

err = testutil.WaitForBlocks(ctx, 10, dymension, rollapp1)
require.NoError(t, err)

lastBlock, err := rollapp1.Height(ctx)
require.NoError(t, err)

time.Sleep(180 * time.Second)

queryGetSequencerResponse, err = dymension.QueryShowSequencer(ctx, seqAddr)
require.NoError(t, err)
require.Equal(t, "OPERATING_STATUS_UNBONDING", queryGetSequencerResponse.Sequencer.Status)

// Chain halted
err = testutil.WaitForBlocks(ctx, 5, dymension, rollapp1)
require.Error(t, err)

time.Sleep(300 * time.Second)

queryGetSequencerResponse, err = dymension.QueryShowSequencer(ctx, seqAddr)
require.NoError(t, err)
require.Equal(t, "OPERATING_STATUS_UNBONDED", queryGetSequencerResponse.Sequencer.Status)

err = rollapp1.StopAllNodes(ctx)
require.NoError(t, err)

_ = rollapp1.StartAllNodes(ctx)

time.Sleep(30 * time.Second)

afterBlock, err := rollapp1.Height(ctx)
require.NoError(t, err)
require.True(t, afterBlock > lastBlock)

// // Compose an IBC transfer and send from rollapp -> Hub
// _, err = rollapp1.SendIBCTransfer(ctx, channel.ChannelID, rollappUserAddr, transferData, ibc.TransferOptions{})
// require.NoError(t, err)

// err = testutil.WaitForBlocks(ctx, 10, dymension, rollapp1)
// require.NoError(t, err)

// // Check IBC after switch
// rollappHeight, err = rollapp1.GetNode().Height(ctx)
// require.NoError(t, err)

// // Assert balance was updated on the hub
// testutil.AssertBalance(t, ctx, rollapp1, rollappUserAddr, rollapp1.Config().Denom, walletAmount.Sub(transferData.Amount))

// // wait until the packet is finalized
// isFinalized, err = dymension.WaitUntilRollappHeightIsFinalized(ctx, rollapp1.GetChainID(), rollappHeight, 300)
// require.NoError(t, err)
// require.True(t, isFinalized)

// _, err = dymension.GetNode().FinalizePacketsUntilHeight(ctx, dymensionUserAddr, rollapp1.GetChainID(), fmt.Sprint(rollappHeight))
// require.NoError(t, err)

// // Get the IBC denom for urax on Hub
// rollappTokenDenom = transfertypes.GetPrefixedDenom(channel.Counterparty.PortID, channel.Counterparty.ChannelID, rollapp1.Config().Denom)
// rollappIBCDenom = transfertypes.ParseDenomTrace(rollappTokenDenom).IBCDenom()

// testutil.AssertBalance(t, ctx, dymension, dymensionUserAddr, rollappIBCDenom, transferAmount.Sub(bridgingFee))

// // Get original account balances
// dymensionOrigBal, err = dymension.GetBalance(ctx, dymensionUserAddr, dymension.Config().Denom)
// require.NoError(t, err)

// // Compose an IBC transfer and send from dymension -> rollapp
// transferData = ibc.WalletData{
// Address: rollappUserAddr,
// Denom: dymension.Config().Denom,
// Amount: transferAmount,
// }

// // Compose an IBC transfer and send from Hub -> rollapp
// _, err = dymension.SendIBCTransfer(ctx, channel.ChannelID, dymensionUserAddr, transferData, ibc.TransferOptions{})
// require.NoError(t, err)

// // Assert balance was updated on the hub
// testutil.AssertBalance(t, ctx, dymension, dymensionUserAddr, dymension.Config().Denom, dymensionOrigBal.Sub(transferData.Amount))

// err = testutil.WaitForBlocks(ctx, 10, dymension, rollapp1)
// require.NoError(t, err)

// // Get the IBC denom
// dymensionTokenDenom = transfertypes.GetPrefixedDenom(channel.Counterparty.PortID, channel.Counterparty.ChannelID, dymension.Config().Denom)
// dymensionIBCDenom = transfertypes.ParseDenomTrace(dymensionTokenDenom).IBCDenom()

// testutil.AssertBalance(t, ctx, dymension, dymensionUserAddr, dymension.Config().Denom, dymensionOrigBal.Sub(transferData.Amount))
// erc20MAcc, err = rollapp1.Validators[0].QueryModuleAccount(ctx, "erc20")
// require.NoError(t, err)
// erc20MAccAddr = erc20MAcc.Account.BaseAccount.Address
// testutil.AssertBalance(t, ctx, rollapp1, erc20MAccAddr, dymensionIBCDenom, transferData.Amount)
}

func Test_SeqRotation_NoSeq_DA_EVM(t *testing.T) {
if testing.Short() {
t.Skip()
Expand Down
Loading