e6f51498b6
* Upgrade to IBC v4.2.0 with interchain-accounts v0.2.4 * Fix linter issues * Test version handshake * Add more ibc e2e scenarios * Add fee middleware to wasm * Get ibc app version from middleware
92 lines
3.5 KiB
Go
92 lines
3.5 KiB
Go
package e2e
|
|
|
|
import (
|
|
"bytes"
|
|
"testing"
|
|
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
"github.com/cosmos/cosmos-sdk/types/address"
|
|
banktypes "github.com/cosmos/cosmos-sdk/x/bank/types"
|
|
hosttypes "github.com/cosmos/ibc-go/v4/modules/apps/27-interchain-accounts/host/types"
|
|
icatypes "github.com/cosmos/ibc-go/v4/modules/apps/27-interchain-accounts/types"
|
|
channeltypes "github.com/cosmos/ibc-go/v4/modules/core/04-channel/types"
|
|
ibctesting "github.com/cosmos/ibc-go/v4/testing"
|
|
intertxtypes "github.com/cosmos/interchain-accounts/x/inter-tx/types"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
wasmibctesting "github.com/CosmWasm/wasmd/x/wasm/ibctesting"
|
|
)
|
|
|
|
func TestICA(t *testing.T) {
|
|
// scenario:
|
|
// given a host and controller chain
|
|
// when an ica is registered on the controller chain
|
|
// and the channel is established to the host chain
|
|
// then the ICA owner can submit a message via IBC
|
|
// to control their account on the host chain
|
|
coord := wasmibctesting.NewCoordinator(t, 2)
|
|
hostChain := coord.GetChain(ibctesting.GetChainID(0))
|
|
hostParams := hosttypes.NewParams(true, []string{sdk.MsgTypeURL(&banktypes.MsgSend{})})
|
|
hostChain.App.ICAHostKeeper.SetParams(hostChain.GetContext(), hostParams)
|
|
|
|
controllerChain := coord.GetChain(ibctesting.GetChainID(1))
|
|
|
|
path := wasmibctesting.NewPath(controllerChain, hostChain)
|
|
coord.SetupConnections(path)
|
|
|
|
ownerAddr := sdk.AccAddress(controllerChain.SenderPrivKey.PubKey().Address())
|
|
msg := intertxtypes.NewMsgRegisterAccount(ownerAddr.String(), path.EndpointA.ConnectionID, "")
|
|
res, err := controllerChain.SendMsgs(msg)
|
|
chanID, portID, version := parseIBCChannelEvents(t, res)
|
|
|
|
// next open channels on both sides
|
|
path.EndpointA.ChannelID = chanID
|
|
path.EndpointA.ChannelConfig = &ibctesting.ChannelConfig{
|
|
PortID: portID,
|
|
Version: version,
|
|
Order: channeltypes.ORDERED,
|
|
}
|
|
path.EndpointB.ChannelConfig = &ibctesting.ChannelConfig{
|
|
PortID: icatypes.PortID,
|
|
Version: icatypes.Version,
|
|
Order: channeltypes.ORDERED,
|
|
}
|
|
coord.CreateChannels(path)
|
|
|
|
// assert ICA exists on controller
|
|
icaRsp, err := controllerChain.App.InterTxKeeper.InterchainAccount(sdk.WrapSDKContext(controllerChain.GetContext()), &intertxtypes.QueryInterchainAccountRequest{
|
|
Owner: ownerAddr.String(),
|
|
ConnectionId: path.EndpointA.ConnectionID,
|
|
})
|
|
require.NoError(t, err)
|
|
icaAddr := sdk.MustAccAddressFromBech32(icaRsp.InterchainAccountAddress)
|
|
hostChain.Fund(icaAddr, sdk.NewInt(1_000))
|
|
|
|
// submit a tx
|
|
targetAddr := sdk.AccAddress(bytes.Repeat([]byte{1}, address.Len))
|
|
sendCoin := sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(100))
|
|
payloadMsg := banktypes.NewMsgSend(icaAddr, targetAddr, sdk.NewCoins(sendCoin))
|
|
msg2, err := intertxtypes.NewMsgSubmitTx(payloadMsg, path.EndpointA.ConnectionID, ownerAddr.String())
|
|
require.NoError(t, err)
|
|
res, err = controllerChain.SendMsgs(msg2)
|
|
require.NoError(t, err)
|
|
|
|
assert.Equal(t, 1, len(controllerChain.PendingSendPackets))
|
|
require.NoError(t, coord.RelayAndAckPendingPackets(path))
|
|
|
|
gotBalance := hostChain.Balance(targetAddr, sdk.DefaultBondDenom)
|
|
assert.Equal(t, sendCoin.String(), gotBalance.String())
|
|
}
|
|
|
|
func parseIBCChannelEvents(t *testing.T, res *sdk.Result) (string, string, string) {
|
|
t.Helper()
|
|
chanID, err := ibctesting.ParseChannelIDFromEvents(res.GetEvents())
|
|
require.NoError(t, err)
|
|
portID, err := wasmibctesting.ParsePortIDFromEvents(res.GetEvents())
|
|
require.NoError(t, err)
|
|
version, err := wasmibctesting.ParseChannelVersionFromEvents(res.GetEvents())
|
|
require.NoError(t, err)
|
|
return chanID, portID, version
|
|
}
|