ICA relay tests

modules/apps/27-interchain-accounts/keeper/handshake.go

@@ -1,6 +1,8 @@
 package keeper
 
 import (
+	"fmt"
+
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
 	capabilitytypes "github.com/cosmos/cosmos-sdk/x/capability/types"
@@ -28,6 +30,7 @@ func (k Keeper) OnChanOpenInit(
 	counterparty channeltypes.Counterparty,
 	version string,
 ) error {
+	fmt.Print(portID, channelID)
 	if order != channeltypes.ORDERED {
 		return sdkerrors.Wrapf(channeltypes.ErrInvalidChannelOrdering, "invalid channel ordering: %s, expected %s", order.String(), channeltypes.ORDERED.String())
 	}

modules/apps/27-interchain-accounts/keeper/keeper_test.go

@@ -6,6 +6,7 @@ import (
 	"github.com/stretchr/testify/suite"
 
 	"github.com/cosmos/ibc-go/modules/apps/27-interchain-accounts/types"
+	channeltypes "github.com/cosmos/ibc-go/modules/core/04-channel/types"
 	ibctesting "github.com/cosmos/ibc-go/testing"
 )
 
@@ -44,6 +45,22 @@ func (suite *KeeperTestSuite) TestIsBound() {
 	suite.Require().True(isBound)
 }
 
+// InitInterchainAccount is a helper function for starting the channel handshake
+func InitInterchainAccount(endpoint *ibctesting.Endpoint, owner string) error {
+	portID := endpoint.Chain.GetSimApp().ICAKeeper.GeneratePortId(owner, endpoint.ConnectionID)
+	channelSequence := endpoint.Chain.App.GetIBCKeeper().ChannelKeeper.GetNextChannelSequence(endpoint.Chain.GetContext())
+
+	if err := endpoint.Chain.GetSimApp().ICAKeeper.InitInterchainAccount(endpoint.Chain.GetContext(), endpoint.ConnectionID, owner); err != nil {
+		return err
+	}
+
+	// update port/channel ids
+	endpoint.ChannelID = channeltypes.FormatChannelIdentifier(channelSequence)
+	endpoint.ChannelConfig.PortID = portID
+	endpoint.Chain.NextBlock()
+	return nil
+}
+
 func (suite *KeeperTestSuite) TestGetPort() {
 	port := suite.chainA.GetSimApp().ICAKeeper.GetPort(suite.chainA.GetContext())
 	suite.Require().Equal(types.PortID, port)

modules/apps/27-interchain-accounts/keeper/relay.go

@@ -39,7 +39,6 @@ func (k Keeper) createOutgoingPacket(
 	destinationChannel string,
 	data interface{},
 ) ([]byte, error) {
-
 	if data == nil {
 		return []byte{}, types.ErrInvalidOutgoingData
 	}

modules/apps/27-interchain-accounts/keeper/relay_test.go

@@ -0,0 +1,80 @@
+package keeper_test
+
+import (
+	ibctesting "github.com/cosmos/ibc-go/testing"
+)
+
+func (suite *KeeperTestSuite) TestTrySendTx() {
+	var (
+		path *ibctesting.Path
+	)
+
+	testCases := []struct {
+		name     string
+		malleate func()
+		expPass  bool
+	}{
+		{
+			"success", func() {}, true,
+		},
+		//		{
+		//			"active channel not found", func() {
+		//				// need to ensure no active channel set
+		//			}, false,
+		//		},
+		//		{
+		//			"channel not found", func() {
+		//				// need to close the channel
+		//			}, false,
+		//		},
+		//		{
+		//			"invalid packet data", func() {
+		//				// should fail when passing something other than sdk.Msg
+		//			}, false,
+		//		},
+		//		{
+		//			"module does not own channel capability", func() {
+		//				// should fail if module capability not ok
+		//			}, false,
+		//		},
+		//		{
+		//			"next sequence not found", func() {
+		//				// should fail when next sequence is not found
+		//			}, false,
+		//		},
+	}
+
+	for _, tc := range testCases {
+		tc := tc
+
+		suite.Run(tc.name, func() {
+			suite.SetupTest() // reset
+			path = NewICAPath(suite.chainA, suite.chainB)
+			suite.coordinator.SetupConnections(path)
+
+			err := InitInterchainAccount(path.EndpointA, "owner")
+			suite.Require().NoError(err)
+
+			err = path.EndpointB.ChanOpenTry()
+			suite.Require().NoError(err)
+
+			err = path.EndpointA.ChanOpenAck()
+			suite.Require().NoError(err)
+
+			err = path.EndpointB.ChanOpenConfirm()
+			suite.Require().NoError(err)
+
+			// ensure counterparty is up to date
+			path.EndpointA.UpdateClient()
+
+			tc.malleate() // explicitly change fields in channel and testChannel
+
+			if tc.expPass {
+				suite.Require().NoError(err)
+			} else {
+				suite.Require().Error(err)
+			}
+
+		})
+	}
+}