Handle EurekaSendMsg

go.mod

@@ -225,6 +225,7 @@ replace (
 	// dgrijalva/jwt-go is deprecated and doesn't receive security updates.
 	// See: https://github.com/cosmos/cosmos-sdk/issues/13134
 	github.com/dgrijalva/jwt-go => github.com/golang-jwt/jwt/v4 v4.4.2
+	github.com/CosmWasm/wasmvm/v2 => github.com/CosmWasm/wasmvm/v2 v2.2.2-0.20250213170323-ec956d351a70
 	// Fix upstream GHSA-h395-qcrw-5vmq vulnerability.
 	// See: https://github.com/cosmos/cosmos-sdk/issues/10409
 	github.com/gin-gonic/gin => github.com/gin-gonic/gin v1.8.1

go.sum

@@ -229,6 +229,8 @@ github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03
 github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
 github.com/CosmWasm/wasmvm/v2 v2.2.1 h1:cmOnM+TDfUl2VRugeo1eJBw4U/Lw0WLviuQHKSo9DVQ=
 github.com/CosmWasm/wasmvm/v2 v2.2.1/go.mod h1:bMhLQL4Yp9CzJi9A83aR7VO9wockOsSlZbT4ztOl6bg=
+github.com/CosmWasm/wasmvm/v2 v2.2.2-0.20250213170323-ec956d351a70 h1:Wt7fazex4eq9s+43X/rFM4pZ0v68XIi+2CdQMPr56OQ=
+github.com/CosmWasm/wasmvm/v2 v2.2.2-0.20250213170323-ec956d351a70/go.mod h1:bMhLQL4Yp9CzJi9A83aR7VO9wockOsSlZbT4ztOl6bg=
 github.com/DataDog/datadog-go v3.2.0+incompatible/go.mod h1:LButxg5PwREeZtORoXG3tL4fMGNddJ+vMq1mwgfaqoQ=
 github.com/DataDog/datadog-go v4.8.3+incompatible h1:fNGaYSuObuQb5nzeTQqowRAd9bpDIRRV4/gUtIBjh8Q=
 github.com/DataDog/datadog-go v4.8.3+incompatible/go.mod h1:LButxg5PwREeZtORoXG3tL4fMGNddJ+vMq1mwgfaqoQ=

x/wasm/keeper/handler_plugin_encoders.go

@@ -9,6 +9,7 @@ import (
 	ibctransfertypes "github.com/cosmos/ibc-go/v10/modules/apps/transfer/types"
 	ibcclienttypes "github.com/cosmos/ibc-go/v10/modules/core/02-client/types"
 	channeltypes "github.com/cosmos/ibc-go/v10/modules/core/04-channel/types"
+	channelv2types "github.com/cosmos/ibc-go/v10/modules/core/04-channel/v2/types"
 
 	errorsmod "cosmossdk.io/errors"
 	sdkmath "cosmossdk.io/math"
@@ -36,13 +37,15 @@ type (
 	AnyEncoder          func(ctx sdk.Context, sender sdk.AccAddress, msg *wasmvmtypes.AnyMsg) ([]sdk.Msg, error)
 	WasmEncoder         func(sender sdk.AccAddress, msg *wasmvmtypes.WasmMsg) ([]sdk.Msg, error)
 	IBCEncoder          func(ctx sdk.Context, sender sdk.AccAddress, contractIBCPortID string, msg *wasmvmtypes.IBCMsg) ([]sdk.Msg, error)
+	EurekaEncoder       func(sender sdk.AccAddress, msg *wasmvmtypes.EurekaMsg) ([]sdk.Msg, error)
 )
 
 type MessageEncoders struct {
 	Bank         func(sender sdk.AccAddress, msg *wasmvmtypes.BankMsg) ([]sdk.Msg, error)
 	Custom       func(sender sdk.AccAddress, msg json.RawMessage) ([]sdk.Msg, error)
 	Distribution func(sender sdk.AccAddress, msg *wasmvmtypes.DistributionMsg) ([]sdk.Msg, error)
 	IBC          func(ctx sdk.Context, sender sdk.AccAddress, contractIBCPortID string, msg *wasmvmtypes.IBCMsg) ([]sdk.Msg, error)
+	Eureka       func(sender sdk.AccAddress, msg *wasmvmtypes.EurekaMsg) ([]sdk.Msg, error)
 	Staking      func(sender sdk.AccAddress, msg *wasmvmtypes.StakingMsg) ([]sdk.Msg, error)
 	Any          func(ctx sdk.Context, sender sdk.AccAddress, msg *wasmvmtypes.AnyMsg) ([]sdk.Msg, error)
 	Wasm         func(sender sdk.AccAddress, msg *wasmvmtypes.WasmMsg) ([]sdk.Msg, error)
@@ -55,6 +58,7 @@ func DefaultEncoders(unpacker codectypes.AnyUnpacker, portSource types.ICS20Tran
 		Custom:       NoCustomMsg,
 		Distribution: EncodeDistributionMsg,
 		IBC:          EncodeIBCMsg(portSource),
+		Eureka:       EncodeEurekaMsg,
 		Staking:      EncodeStakingMsg,
 		Any:          EncodeAnyMsg(unpacker),
 		Wasm:         EncodeWasmMsg,
@@ -78,6 +82,9 @@ func (e MessageEncoders) Merge(o *MessageEncoders) MessageEncoders {
 	if o.IBC != nil {
 		e.IBC = o.IBC
 	}
+	if o.Eureka != nil {
+		e.Eureka = o.Eureka
+	}
 	if o.Staking != nil {
 		e.Staking = o.Staking
 	}
@@ -103,6 +110,8 @@ func (e MessageEncoders) Encode(ctx sdk.Context, contractAddr sdk.AccAddress, co
 		return e.Distribution(contractAddr, msg.Distribution)
 	case msg.IBC != nil:
 		return e.IBC(ctx, contractAddr, contractIBCPortID, msg.IBC)
+	case msg.Eureka != nil:
+		return e.Eureka(contractAddr, msg.Eureka)
 	case msg.Staking != nil:
 		return e.Staking(contractAddr, msg.Staking)
 	case msg.Any != nil:
@@ -360,6 +369,33 @@ func EncodeIBCMsg(portSource types.ICS20TransferPortSource) func(ctx sdk.Context
 	}
 }
 
+func EncodeEurekaMsg(sender sdk.AccAddress, msg *wasmvmtypes.EurekaMsg) ([]sdk.Msg, error) {
+	switch {
+	case msg.SendPacket != nil:
+		var payloads []channelv2types.Payload
+		for i := range msg.SendPacket.Payloads {
+			payloads = append(payloads, channelv2types.Payload{
+				// TODO: Verify if source port can be set to contract address
+				SourcePort:      sender.String(),
+				DestinationPort: msg.SendPacket.Payloads[i].DestinationPort,
+				Version:         msg.SendPacket.Payloads[i].Version,
+				Encoding:        msg.SendPacket.Payloads[i].Encoding,
+				Value:           msg.SendPacket.Payloads[i].Value,
+			})
+		}
+		msg := &channelv2types.MsgSendPacket{
+			SourceClient:     msg.SendPacket.ChannelID,
+			TimeoutTimestamp: msg.SendPacket.Timeout,
+			Payloads:         payloads,
+			// Do we set it?
+			// Signer:           "signer",
+		}
+		return []sdk.Msg{msg}, nil
+	default:
+		return nil, errorsmod.Wrap(types.ErrUnknownMsg, "unknown variant of Eureka")
+	}
+}
+
 func EncodeGovMsg(sender sdk.AccAddress, msg *wasmvmtypes.GovMsg) ([]sdk.Msg, error) {
 	switch {
 	case msg.Vote != nil:

x/wasm/keeper/handler_plugin_encoders_test.go

@@ -9,6 +9,7 @@ import (
 	ibctransfertypes "github.com/cosmos/ibc-go/v10/modules/apps/transfer/types"
 	clienttypes "github.com/cosmos/ibc-go/v10/modules/core/02-client/types" //nolint:staticcheck
 	channeltypes "github.com/cosmos/ibc-go/v10/modules/core/04-channel/types"
+	channelv2types "github.com/cosmos/ibc-go/v10/modules/core/04-channel/v2/types"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
@@ -933,6 +934,73 @@ func TestEncodeGovMsg(t *testing.T) {
 	}
 }
 
+func TestEncodeEurekaMsg(t *testing.T) {
+	var (
+		myAddr   = RandomAccountAddress(t)
+		destAddr = RandomAccountAddress(t)
+	)
+
+	cases := map[string]struct {
+		sender             sdk.AccAddress
+		srcMsg             wasmvmtypes.CosmosMsg
+		transferPortSource types.ICS20TransferPortSource
+		// set if valid
+		output []sdk.Msg
+		// set if expect mapping fails
+		expError bool
+	}{
+		"EurekaMsg SendPacket": {
+			sender: myAddr,
+			srcMsg: wasmvmtypes.CosmosMsg{
+				Eureka: &wasmvmtypes.EurekaMsg{
+					SendPacket: &wasmvmtypes.EurekaSendPacketMsg{
+						ChannelID: myAddr.String(),
+						Payloads: []wasmvmtypes.EurekaPayload{
+							{
+								DestinationPort: "wasm." + destAddr.String(),
+								Version:         "v1",
+								Encoding:        "json",
+								Value:           []byte{},
+							},
+						},
+						Timeout: 1000,
+					},
+				},
+			},
+			output: []sdk.Msg{
+				&channelv2types.MsgSendPacket{
+					SourceClient:     myAddr.String(),
+					TimeoutTimestamp: 1000,
+					Signer:           "",
+					Payloads: []channelv2types.Payload{
+						{
+							SourcePort:      myAddr.String(),
+							DestinationPort: "wasm." + destAddr.String(),
+							Version:         "v1",
+							Encoding:        "json",
+							Value:           []byte{},
+						},
+					},
+				},
+			},
+		},
+	}
+	encodingConfig := MakeEncodingConfig(t)
+	for name, tc := range cases {
+		t.Run(name, func(t *testing.T) {
+			var ctx sdk.Context
+			encoder := DefaultEncoders(encodingConfig.Codec, tc.transferPortSource)
+			res, gotEncErr := encoder.Encode(ctx, tc.sender, "myIBCPort", tc.srcMsg)
+			if tc.expError {
+				assert.Error(t, gotEncErr)
+				return
+			}
+			require.NoError(t, gotEncErr)
+			assert.Equal(t, tc.output, res)
+		})
+	}
+}
+
 func TestConvertWasmCoinToSdkCoin(t *testing.T) {
 	specs := map[string]struct {
 		src    wasmvmtypes.Coin