Add new EurekaMsg

Author: jawoznia

types/eureka.go

@@ -0,0 +1,16 @@
+package types
+
+// EurekaPayload defines a single packet sent in the EurekaSendPacketMsg
+//
+// Payload value should be encoded in a format defined by the channel version,
+// and the module on the other side should know how to parse this.
+type EurekaPayload struct {
+	// The port id on the chain where the packet is sent to (external chain).
+	DestinationPort string `json:"destination_port"`
+	// Version of the receiving contract.
+	Version string `json:"version"`
+	// Encoding used to serialize the Value.
+	Encoding string `json:"encoding"`
+	// Encoded payload data
+	Value []byte `json:"value"`
+}

types/msg.go

@@ -60,6 +60,7 @@ type CosmosMsg struct {
 	Staking      *StakingMsg      `json:"staking,omitempty"`
 	Any          *AnyMsg          `json:"any,omitempty"`
 	Wasm         *WasmMsg         `json:"wasm,omitempty"`
+	Eureka       *EurekaMsg       `json:"eureka,omitempty"`
 }
 
 func (m *CosmosMsg) UnmarshalJSON(data []byte) error {
@@ -74,6 +75,7 @@ func (m *CosmosMsg) UnmarshalJSON(data []byte) error {
 		Any          *AnyMsg          `json:"any,omitempty"`
 		Wasm         *WasmMsg         `json:"wasm,omitempty"`
 		Stargate     *AnyMsg          `json:"stargate,omitempty"`
+		Eureka       *EurekaMsg       `json:"eureka,omitempty"`
 	}
 	var tmp InternalCosmosMsg
 	err := json.Unmarshal(data, &tmp)
@@ -97,6 +99,7 @@ func (m *CosmosMsg) UnmarshalJSON(data []byte) error {
 		Staking:      tmp.Staking,
 		Any:          tmp.Any,
 		Wasm:         tmp.Wasm,
+		Eureka:       tmp.Eureka,
 	}
 	return nil
 }
@@ -350,6 +353,18 @@ type WasmMsg struct {
 	ClearAdmin   *ClearAdminMsg   `json:"clear_admin,omitempty"`
 }
 
+// These are messages in the IBC lifecycle using the new Eureka approach. Only usable by IBC-enabled contracts
+type EurekaMsg struct {
+	SendPacket *EurekaSendPacketMsg `json:"execute,omitempty"`
+}
+
+// Sends an IBC packet with given payloads over the existing channel.
+type EurekaSendPacketMsg struct {
+	ChannelID string          `json:"channel_id"`
+	Data      []EurekaPayload `json:"data"`
+	Timestamp uint64          `json:"timestamp,string,omitempty"`
+}
+
 // ExecuteMsg is used to call another defined contract on this chain.
 // The calling contract requires the callee to be defined beforehand,
 // and the address should have been defined in initialization.