x/ibc: implement ADR 032 typed events

proto/ibc/applications/transfer/v1/event.proto

@@ -0,0 +1,62 @@
+syntax = "proto3";
+package ibc.applications.transfer.v1;
+
+option go_package = "github.com/cosmos/cosmos-sdk/x/ibc/applications/transfer/types";
+
+import "gogoproto/gogo.proto";
+import "ibc/core/channel/v1/channel.proto";
+
+// EventOnRecvPacket is a typed event emitted on receiving packet
+message EventOnRecvPacket {
+    string receiver = 1;
+
+    string denom = 2;
+
+    uint64 amount = 3;
+
+    bool success = 4; 
+}
+
+// EventOnAcknowledgementPacket is a typed event emitted on packet acknowledgement
+message EventOnAcknowledgementPacket {
+    string receiver = 1;
+
+    string denom = 2;
+
+    uint64 amount = 3;
+
+    ibc.core.channel.v1.Acknowledgement acknowledgement = 4 [(gogoproto.nullable) = false];
+}
+
+// EventAcknowledgementSuccess is a typed event emitted on packet acknowledgement success
+message EventAcknowledgementSuccess {
+    bytes success = 1;
+}
+
+// EventAcknowledgementError is a typed event emitted on packet acknowledgement error
+message EventAcknowledgementError {
+    string error = 1;
+}
+
+// EventOnTimeoutPacket is a typed event emitted on packet timeout
+message EventOnTimeoutPacket {
+    string refund_receiver = 1;
+
+    string refund_denom = 2;
+
+    uint64 refund_amount = 3;
+}
+
+// EventTransfer is a typed event emitted on ibc transfer
+message EventTransfer {
+    string sender = 1;
+
+    string receiver = 2;
+}
+
+// EventDenominationTrace is a typed event for denomination trace
+message EventDenominationTrace {
+    bytes trace_hash = 1 [(gogoproto.casttype) = "github.com/tendermint/tendermint/libs/bytes.HexBytes"];
+
+    string denom = 2;
+}

proto/ibc/applications/transfer/v1/tx.proto

@@ -33,7 +33,7 @@ message MsgTransfer {
   // Timeout height relative to the current block height.
   // The timeout is disabled when set to 0.
   ibc.core.client.v1.Height timeout_height = 6
-      [(gogoproto.moretags) = "yaml:\"timeout_height\"", (gogoproto.nullable) = false];
+      [(gogoproto.moretags) = "yaml:\"timeout_height\""];
   // Timeout timestamp (in nanoseconds) relative to the current block timestamp.
   // The timeout is disabled when set to 0.
   uint64 timeout_timestamp = 7 [(gogoproto.moretags) = "yaml:\"timeout_timestamp\""];

proto/ibc/core/channel/v1/channel.proto

@@ -109,7 +109,7 @@ message Packet {
   bytes data = 6;
   // block height after which the packet times out
   ibc.core.client.v1.Height timeout_height = 7
-      [(gogoproto.moretags) = "yaml:\"timeout_height\"", (gogoproto.nullable) = false];
+      [(gogoproto.moretags) = "yaml:\"timeout_height\""];
   // block timestamp (in nanoseconds) after which the packet times out
   uint64 timeout_timestamp = 8 [(gogoproto.moretags) = "yaml:\"timeout_timestamp\""];
 }

proto/ibc/core/channel/v1/event.proto

@@ -0,0 +1,187 @@
+syntax = "proto3";
+package ibc.core.channel.v1;
+
+option go_package = "github.com/cosmos/cosmos-sdk/x/ibc/core/04-channel/types";
+
+import "ibc/core/channel/v1/channel.proto";
+import "google/protobuf/any.proto";
+import "cosmos_proto/cosmos.proto";
+
+// EventChannelOpenInit is a typed event emitted on channel open init
+message EventChannelOpenInit {
+    string port_id = 1;
+
+    string channel_id = 2;
+
+    string counterparty_port_id = 3;
+
+    string counterparty_channel_id = 4;
+
+    string connection_id = 5;
+}
+
+// EventChannelOpenTry is a typed event emitted on channel open try
+message EventChannelOpenTry {
+    string port_id = 1;
+
+    string channel_id = 2;
+
+    string counterparty_port_id = 3;
+
+    string counterparty_channel_id = 4;
+
+    string connection_id = 5;
+}
+
+// EventChannelOpenAck is a typed event emitted on channel open acknowledgement
+message EventChannelOpenAck {
+    string port_id = 1;
+
+    string channel_id = 2;
+
+    string counterparty_port_id = 3;
+
+    string counterparty_channel_id = 4;
+
+    string connection_id = 5;
+}
+
+// EventChannelCloseInit is a typed event emitted on channel close init
+message EventChannelCloseInit {
+    string port_id = 1;
+
+    string channel_id = 2;
+
+    string counterparty_port_id = 3;
+
+    string counterparty_channel_id = 4;
+
+    string connection_id = 5;
+}
+
+// EventChannelOpenConfirm is a typed event emitted on channel open confirm
+message EventChannelOpenConfirm {
+    string port_id = 1;
+
+    string channel_id = 2;
+
+    string counterparty_port_id = 3;
+
+    string counterparty_channel_id = 4;
+
+    string connection_id = 5;
+}
+
+// EventChannelCloseConfirm is a typed event emitted on channel close confirm
+message EventChannelCloseConfirm {
+    string port_id = 1;
+
+    string channel_id = 2;
+
+    string counterparty_port_id = 3;
+
+    string counterparty_channel_id = 4;
+
+    string connection_id = 5;
+}
+
+// EventChannelSendPacket is a typed event emitted when packet is sent
+message EventChannelSendPacket {
+    bytes data = 1;
+
+    google.protobuf.Any timeout_height  = 2 [(cosmos_proto.accepts_interface) = "Height"];
+
+    uint64 timeout_timestamp = 3;
+
+    uint64 sequence = 4;
+
+    string src_port = 5;
+
+    string src_channel = 6;
+
+    string dst_port = 7;
+
+    string dst_channel = 8;
+
+    Order channel_ordering = 9;
+}
+
+// EventChannelRecvPacket is a typed event emitted when packet is received in channel
+message EventChannelRecvPacket {
+    bytes data = 1;
+
+    google.protobuf.Any timeout_height  = 2 [(cosmos_proto.accepts_interface) = "Height"];
+
+    uint64 timeout_timestamp = 3;
+
+    uint64 sequence = 4;
+
+    string src_port = 5;
+
+    string src_channel = 6;
+
+    string dst_port = 7;
+
+    string dst_channel = 8;
+
+    Order channel_ordering = 9;
+}
+
+// EventChannelWriteAck is a typed event emitted on write acknowledgement
+message EventChannelWriteAck {
+    bytes data = 1;
+
+    google.protobuf.Any timeout_height  = 2 [(cosmos_proto.accepts_interface) = "Height"];
+
+    uint64 timeout_timestamp = 3;
+
+    uint64 sequence = 4;
+
+    string src_port = 5;
+
+    string src_channel = 6;
+
+    string dst_port = 7;
+
+    string dst_channel = 8;
+
+    bytes acknowledgement = 9;
+}
+
+// EventChannelAckPacket is a typed event emitted when packet acknowledgement is executed
+message EventChannelAckPacket {
+    google.protobuf.Any timeout_height  = 1 [(cosmos_proto.accepts_interface) = "Height"];
+
+    uint64 timeout_timestamp = 2;
+
+    uint64 sequence = 3;
+
+    string src_port = 4;
+
+    string src_channel = 5;
+
+    string dst_port = 6;
+
+    string dst_channel = 7;
+
+    Order channel_ordering = 8;
+}
+
+// EventChannelTimeoutPacket is a typed event emitted when packet is timeout
+message EventChannelTimeoutPacket {
+    google.protobuf.Any timeout_height  = 1 [(cosmos_proto.accepts_interface) = "Height"];
+
+    uint64 timeout_timestamp = 2;
+
+    uint64 sequence = 3;
+
+    string src_port = 4;
+
+    string src_channel = 5;
+
+    string dst_port = 6;
+
+    string dst_channel = 7;
+
+    Order channel_ordering = 8;
+}

proto/ibc/core/channel/v1/query.proto

@@ -110,7 +110,7 @@ message QueryChannelResponse {
   // merkle proof of existence
   bytes proof = 2;
   // height at which the proof was retrieved
-  ibc.core.client.v1.Height proof_height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height proof_height = 3;
 }
 
 // QueryChannelsRequest is the request type for the Query/Channels RPC method
@@ -126,7 +126,7 @@ message QueryChannelsResponse {
   // pagination response
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
   // query block height
-  ibc.core.client.v1.Height height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height height = 3;
 }
 
 // QueryConnectionChannelsRequest is the request type for the
@@ -146,7 +146,7 @@ message QueryConnectionChannelsResponse {
   // pagination response
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
   // query block height
-  ibc.core.client.v1.Height height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height height = 3;
 }
 
 // QueryChannelClientStateRequest is the request type for the Query/ClientState
@@ -166,7 +166,7 @@ message QueryChannelClientStateResponse {
   // merkle proof of existence
   bytes proof = 2;
   // height at which the proof was retrieved
-  ibc.core.client.v1.Height proof_height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height proof_height = 3;
 }
 
 // QueryChannelConsensusStateRequest is the request type for the
@@ -192,7 +192,7 @@ message QueryChannelConsensusStateResponse {
   // merkle proof of existence
   bytes proof = 3;
   // height at which the proof was retrieved
-  ibc.core.client.v1.Height proof_height = 4 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height proof_height = 4;
 }
 
 // QueryPacketCommitmentRequest is the request type for the
@@ -215,7 +215,7 @@ message QueryPacketCommitmentResponse {
   // merkle proof of existence
   bytes proof = 2;
   // height at which the proof was retrieved
-  ibc.core.client.v1.Height proof_height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height proof_height = 3;
 }
 
 // QueryPacketCommitmentsRequest is the request type for the
@@ -236,7 +236,7 @@ message QueryPacketCommitmentsResponse {
   // pagination response
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
   // query block height
-  ibc.core.client.v1.Height height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height height = 3;
 }
 
 // QueryPacketReceiptRequest is the request type for the
@@ -259,7 +259,7 @@ message QueryPacketReceiptResponse {
   // merkle proof of existence
   bytes proof = 3;
   // height at which the proof was retrieved
-  ibc.core.client.v1.Height proof_height = 4 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height proof_height = 4;
 }
 
 // QueryPacketAcknowledgementRequest is the request type for the
@@ -282,7 +282,7 @@ message QueryPacketAcknowledgementResponse {
   // merkle proof of existence
   bytes proof = 2;
   // height at which the proof was retrieved
-  ibc.core.client.v1.Height proof_height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height proof_height = 3;
 }
 
 // QueryPacketAcknowledgementsRequest is the request type for the
@@ -303,7 +303,7 @@ message QueryPacketAcknowledgementsResponse {
   // pagination response
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
   // query block height
-  ibc.core.client.v1.Height height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height height = 3;
 }
 
 // QueryUnreceivedPacketsRequest is the request type for the
@@ -323,7 +323,7 @@ message QueryUnreceivedPacketsResponse {
   // list of unreceived packet sequences
   repeated uint64 sequences = 1;
   // query block height
-  ibc.core.client.v1.Height height = 2 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height height = 2;
 }
 
 // QueryUnreceivedAcks is the request type for the
@@ -343,7 +343,7 @@ message QueryUnreceivedAcksResponse {
   // list of unreceived acknowledgement sequences
   repeated uint64 sequences = 1;
   // query block height
-  ibc.core.client.v1.Height height = 2 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height height = 2;
 }
 
 // QueryNextSequenceReceiveRequest is the request type for the
@@ -363,5 +363,5 @@ message QueryNextSequenceReceiveResponse {
   // merkle proof of existence
   bytes proof = 2;
   // height at which the proof was retrieved
-  ibc.core.client.v1.Height proof_height = 3 [(gogoproto.nullable) = false];
+  ibc.core.client.v1.Height proof_height = 3;
 }