feat: add pagination to sensitive endpoints

proto/dymensionxyz/dymension/eibc/query.proto

@@ -60,6 +60,7 @@ message QueryDemandOrdersByStatusRequest {
   string denom = 7;
   // optional recipient address
   string recipient = 8;
+  cosmos.base.query.v1beta1.PageRequest pagination = 9;
 }
 
 enum FulfillmentState {
@@ -78,4 +79,5 @@ message QueryGetDemandOrderResponse {
 message QueryDemandOrdersByStatusResponse {
   // A list of demand orders with the given status
   repeated DemandOrder demand_orders = 1;
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }

proto/dymensionxyz/dymension/iro/query.proto

@@ -6,6 +6,7 @@ import "cosmos_proto/cosmos.proto";
 import "google/api/annotations.proto";
 import "dymensionxyz/dymension/iro/iro.proto";
 import "cosmos/base/v1beta1/coin.proto";
+import "cosmos/base/query/v1beta1/pagination.proto";
 
 option go_package = "github.com/dymensionxyz/dymension/v3/x/iro/types";
 
@@ -70,11 +71,13 @@ message QueryParamsResponse {
 message QueryPlansRequest {
   // tradable_only is an optional flag to filter out plans that have not started yet, and that are not settled.
   bool tradable_only = 1;
+  cosmos.base.query.v1beta1.PageRequest pagination = 2;
 }
 
 // QueryPlanResponse is the response type for the Query/QueryPlan RPC method.
 message QueryPlansResponse {
   repeated Plan plans = 1 [ (gogoproto.nullable) = false ];
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 
 // QueryPlanRequest is the request type for the Query/QueryPlan RPC method.

proto/dymensionxyz/dymension/rollapp/query.proto

@@ -140,10 +140,12 @@ message QueryGetStateInfoResponse {
 
 message QueryRegisteredDenomsRequest {
   string rollappId = 1;
+  cosmos.base.query.v1beta1.PageRequest pagination = 2;
 }
 
 message QueryRegisteredDenomsResponse {
   repeated string denoms = 1;
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 
 message QueryObsoleteDRSVersionsRequest {}

proto/dymensionxyz/dymension/sequencer/query.proto

@@ -88,19 +88,25 @@ message QuerySequencersResponse {
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 
-message QueryGetSequencersByRollappRequest { string rollappId = 1; }
+message QueryGetSequencersByRollappRequest {
+  string rollappId = 1;
+  cosmos.base.query.v1beta1.PageRequest pagination = 2;
+}
 
 message QueryGetSequencersByRollappResponse {
   repeated Sequencer sequencers = 1 [ (gogoproto.nullable) = false ];
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 
 message QueryGetSequencersByRollappByStatusRequest {
   string rollappId = 1;
   OperatingStatus status = 2;
+  cosmos.base.query.v1beta1.PageRequest pagination = 3;
 }
 
 message QueryGetSequencersByRollappByStatusResponse {
   repeated Sequencer sequencers = 1 [ (gogoproto.nullable) = false ];
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 
 // Request type for the GetProposerByRollapp RPC method.

x/delayedack/keeper/grpc_query.go

@@ -62,13 +62,13 @@ func (q Querier) GetPendingPacketsByAddress(goCtx context.Context, req *types.Qu
 	ctx := sdk.UnwrapSDKContext(goCtx)
 
 	// Get all pending rollapp packets until the latest finalized height
-	p, err := q.Keeper.GetPendingPacketsByAddress(ctx, req.Address)
+	p, pageResp, err := q.Keeper.GetPendingPacketsByAddressPaginated(ctx, req.Address, req.Pagination)
 	if err != nil {
 		return nil, fmt.Errorf("get pending packets by receiver %s: %w", req.Address, err)
 	}
 
 	return &types.QueryPendingPacketByAddressListResponse{
 		RollappPackets: p,
-		Pagination:     nil, // TODO: handle pagination
+		Pagination:     pageResp,
 	}, nil
 }

x/delayedack/keeper/rollapp_packet.go

@@ -5,10 +5,12 @@ import (
 
 	"cosmossdk.io/collections"
 	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/types/query"
 	transfertypes "github.com/cosmos/ibc-go/v7/modules/apps/transfer/types"
 
 	"github.com/dymensionxyz/gerr-cosmos/gerrc"
 
+	"github.com/dymensionxyz/dymension/v3/internal/collcompat"
 	commontypes "github.com/dymensionxyz/dymension/v3/x/common/types"
 	"github.com/dymensionxyz/dymension/v3/x/delayedack/types"
 )
@@ -77,6 +79,25 @@ func (k Keeper) GetPendingPacketsByAddress(ctx sdk.Context, receiver string) ([]
 	return packets, nil
 }
 
+// GetPendingPacketsByAddressPaginated retrieves rollapp packets from the KVStore by their receiver with pagination.
+func (k Keeper) GetPendingPacketsByAddressPaginated(ctx sdk.Context, receiver string, pageReq *query.PageRequest) (packets []commontypes.RollappPacket, pageResp *query.PageResponse, err error) {
+	_, pageResp, err = collcompat.CollectionPaginate(ctx, k.pendingPacketsByAddress, pageReq,
+		func(key collections.Pair[string, []byte], _ collections.NoValue) (bool, error) {
+			packet, err := k.GetRollappPacket(ctx, string(key.K2()))
+			if err != nil {
+				return true, err
+			}
+			packets = append(packets, *packet)
+			return false, nil
+		}, collcompat.WithCollectionPaginationPairPrefix[string, []byte](receiver),
+	)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	return packets, pageResp, nil
+}
+
 // GetRollappPacket retrieves a rollapp packet from the KVStore.
 func (k Keeper) GetRollappPacket(ctx sdk.Context, rollappPacketKey string) (*commontypes.RollappPacket, error) {
 	store := ctx.KVStore(k.storeKey)

x/eibc/client/cli/query_command_orders.go

@@ -26,12 +26,18 @@ func CmdListDemandOrdersByStatus() *cobra.Command {
 			if !ok {
 				return fmt.Errorf("invalid status: %s", args[0])
 			}
+
+			pageReq, err := client.ReadPageRequest(cmd.Flags())
+			if err != nil {
+				return err
+			}
+
 			request := &types.QueryDemandOrdersByStatusRequest{
-				Status: commontypes.Status(status),
-				Type:   commontypes.RollappPacket_UNDEFINED, // default to undefined, as '0' is a valid type
+				Status:     commontypes.Status(status),
+				Type:       commontypes.RollappPacket_UNDEFINED, // default to undefined, as '0' is a valid type
+				Pagination: pageReq,
 			}
 
-			var err error
 			request.RollappId, err = cmd.Flags().GetString("rollapp")
 			if err != nil {
 				return err

x/eibc/keeper/grpc_query.go

@@ -56,12 +56,15 @@ func (q Querier) DemandOrdersByStatus(goCtx context.Context, req *types.QueryDem
 		return nil, status.Error(codes.InvalidArgument, "empty request")
 	}
 	// Get the demand orders by status, with optional filters
-	demandOrders, err := q.ListDemandOrdersByStatus(sdk.UnwrapSDKContext(goCtx), req.Status, int(req.Limit), filterOpts(req)...)
+	demandOrders, pageResp, err := q.ListDemandOrdersByStatusPaginated(sdk.UnwrapSDKContext(goCtx), req.Status, req.Pagination, filterOpts(req)...)
 	if err != nil {
 		return nil, status.Error(codes.Internal, err.Error())
 	}
 	// Construct the response
-	return &types.QueryDemandOrdersByStatusResponse{DemandOrders: demandOrders}, nil
+	return &types.QueryDemandOrdersByStatusResponse{
+		DemandOrders: demandOrders,
+		Pagination:   pageResp,
+	}, nil
 }
 
 func filterOpts(req *types.QueryDemandOrdersByStatusRequest) []filterOption {

x/eibc/keeper/keeper.go

@@ -5,8 +5,10 @@ import (
 
 	"github.com/cometbft/cometbft/libs/log"
 	"github.com/cosmos/cosmos-sdk/codec"
+	"github.com/cosmos/cosmos-sdk/store/prefix"
 	storetypes "github.com/cosmos/cosmos-sdk/store/types"
 	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/types/query"
 	paramtypes "github.com/cosmos/cosmos-sdk/x/params/types"
 	"github.com/dymensionxyz/sdk-utils/utils/uevent"
 
@@ -198,6 +200,48 @@ outer:
 	return list, nil
 }
 
+func (k Keeper) ListDemandOrdersByStatusPaginated(
+	ctx sdk.Context,
+	status commontypes.Status,
+	pageReq *query.PageRequest,
+	opts ...filterOption,
+) (list []*types.DemandOrder, pageResp *query.PageResponse, err error) {
+	store := ctx.KVStore(k.storeKey)
+
+	var statusPrefix []byte
+	switch status {
+	case commontypes.Status_PENDING:
+		statusPrefix = types.PendingDemandOrderKeyPrefix
+	case commontypes.Status_FINALIZED:
+		statusPrefix = types.FinalizedDemandOrderKeyPrefix
+	default:
+		err = fmt.Errorf("invalid demand order status: %s", status)
+		return
+	}
+
+	prefixStore := prefix.NewStore(store, statusPrefix)
+
+	if pageReq == nil {
+		pageReq = &query.PageRequest{}
+	}
+
+	pageResp, err = query.Paginate(prefixStore, pageReq, func(key []byte, value []byte) error {
+		var val types.DemandOrder
+		if err := k.cdc.Unmarshal(value, &val); err != nil {
+			return err
+		}
+		for _, opt := range opts {
+			if !opt(val) {
+				return nil
+			}
+		}
+		list = append(list, &val)
+		return nil
+	})
+
+	return
+}
+
 /* -------------------------------------------------------------------------- */
 /*                               Hooks handling                               */
 /* -------------------------------------------------------------------------- */