Add delayedack filter by type

CHANGELOG.md

@@ -41,6 +41,7 @@ Ref: https://keepachangelog.com/en/1.0.0/
 
 ### Features
 
+- (delayedack) [#850](https://github.com/dymensionxyz/dymension/issues/850) Add type filter for delayedack
 - (delayedack) [#728](https://github.com/dymensionxyz/dymension/issues/728) Create eibc order on err ack from rollapp
 - (delayedack) [#672](https://github.com/dymensionxyz/dymension/issues/672) Delayedack invariant for finalized and reverted packets
 - (evm) [#668](https://github.com/dymensionxyz/dymension/issues/668) Integrate virtual frontier bank contract

go.mod

@@ -18,7 +18,7 @@ require (
 	github.com/golang/protobuf v1.5.3
 	github.com/gorilla/mux v1.8.1
 	github.com/grpc-ecosystem/grpc-gateway v1.16.0
-	github.com/osmosis-labs/osmosis/v15 v15.2.1
+	github.com/osmosis-labs/osmosis/v15 v15.2.0
 	github.com/spf13/cast v1.5.0
 	github.com/spf13/cobra v1.8.0
 	github.com/spf13/pflag v1.0.5

proto/dymension/common/rollapp_packet.proto

@@ -4,6 +4,7 @@ package dymensionxyz.dymension.common;
 import "gogoproto/gogo.proto";
 import "ibc/core/channel/v1/channel.proto"; 
 import "dymension/common/status.proto";
+import "dymension/common/type.proto";
 
 option go_package = "github.com/dymensionxyz/dymension/v3/x/common/types";
 
@@ -14,11 +15,6 @@ message RollappPacket {
     Status status = 4;
     uint64 ProofHeight = 5;
     bytes relayer = 6;
-    enum Type {
-      ON_RECV = 0;
-      ON_ACK = 1;
-      ON_TIMEOUT = 2;
-    } 
     Type type = 7;
     // stores the result of onAck, onTimeout or onRecv/writeAck
     string error = 8;

proto/dymension/common/status.proto

@@ -3,13 +3,10 @@ package dymensionxyz.dymension.common;
 
 import "gogoproto/gogo.proto";
 
-
 option go_package = "github.com/dymensionxyz/dymension/v3/x/common/types";
 
-
 enum Status {
     PENDING = 0;
     FINALIZED = 1;
     REVERTED = 3;
 }
-

proto/dymension/common/type.proto

@@ -0,0 +1,13 @@
+syntax = "proto3";
+package dymensionxyz.dymension.common;
+
+import "gogoproto/gogo.proto";
+
+option go_package = "github.com/dymensionxyz/dymension/v3/x/common/types";
+
+enum Type {
+  ON_RECV = 0;
+  ON_ACK = 1;
+  ON_TIMEOUT = 2;
+  UNDEFINED = -1;
+}

proto/dymension/delayedack/query.proto

@@ -6,6 +6,7 @@ import "google/api/annotations.proto";
 import "cosmos/base/query/v1beta1/pagination.proto";
 import "dymension/delayedack/params.proto";
 import "dymension/common/status.proto";
+import "dymension/common/type.proto";
 import "dymension/common/rollapp_packet.proto";
 
 option go_package = "github.com/dymensionxyz/dymension/v3/x/delayedack/types";
@@ -21,8 +22,6 @@ service Query {
 	rpc GetPackets(QueryRollappPacketsRequest) returns (QueryRollappPacketListResponse) {
 		option (google.api.http).get = "/dymensionxyz/dymension/delayedack/packets/{rollappId}/{status}";
 	}
-
-
 }
 
 // QueryParamsRequest is request type for the Query/Params RPC method.
@@ -34,11 +33,11 @@ message QueryParamsResponse {
   Params params = 1 [(gogoproto.nullable) = false];
 }
 
-
 message QueryRollappPacketsRequest {
 	string rollappId = 1;
 	common.Status status = 2;
-	cosmos.base.query.v1beta1.PageRequest pagination = 3;
+	common.Type type = 3;
+	cosmos.base.query.v1beta1.PageRequest pagination = 4;
 }
 
 message QueryRollappPacketListResponse {

x/common/types/packet_uid.go

@@ -1,17 +1,17 @@
 package types
 
-import fmt "fmt"
+import "fmt"
 
 // PacketUID is a unique identifier for an Rollapp IBC packet on the hub
 type PacketUID struct {
-	Type              RollappPacket_Type
+	Type              Type
 	RollappHubPort    string
 	RollappHubChannel string
 	Sequence          uint64
 }
 
 // NewPacketUID creates a new PacketUID with the provided details.
-func NewPacketUID(packetType RollappPacket_Type, hubPort string, hubChannel string, sequence uint64) PacketUID {
+func NewPacketUID(packetType Type, hubPort string, hubChannel string, sequence uint64) PacketUID {
 	return PacketUID{
 		Type:              packetType,
 		RollappHubPort:    hubPort,

x/common/types/rollapp_packet.go

@@ -40,9 +40,9 @@ func (r RollappPacket) RestoreOriginalTransferTarget() (RollappPacket, error) {
 	}
 	if r.OriginalTransferTarget != "" { // It can be empty if the eibc order was never fulfilled
 		switch r.Type {
-		case RollappPacket_ON_RECV:
+		case Type_ON_RECV:
 			transferPacketData.Receiver = r.OriginalTransferTarget
-		case RollappPacket_ON_ACK, RollappPacket_ON_TIMEOUT:
+		case Type_ON_ACK, Type_ON_TIMEOUT:
 			transferPacketData.Sender = r.OriginalTransferTarget
 		}
 		r.Packet.Data = transferPacketData.GetBytes()