imp: add page result to ics29-fee queries (#3054)

cosmos · Feb 8, 2023 · 5dba356 · 5dba356
1 parent a244245
commit 5dba356
Show file tree

Hide file tree

Showing 3 changed files with 281 additions and 88 deletions.
diff --git a/modules/apps/29-fee/keeper/grpc_query.go b/modules/apps/29-fee/keeper/grpc_query.go
@@ -25,7 +25,7 @@ func (k Keeper) IncentivizedPackets(goCtx context.Context, req *types.QueryIncen
 
 	var identifiedPackets []types.IdentifiedPacketFees
 	store := prefix.NewStore(ctx.KVStore(k.storeKey), []byte(types.FeesInEscrowPrefix))
-	_, err := query.Paginate(store, req.Pagination, func(key, value []byte) error {
+	pagination, err := query.Paginate(store, req.Pagination, func(key, value []byte) error {
 		packetID, err := types.ParseKeyFeesInEscrow(types.FeesInEscrowPrefix + string(key))
 		if err != nil {
 			return err
@@ -41,6 +41,7 @@ func (k Keeper) IncentivizedPackets(goCtx context.Context, req *types.QueryIncen
 
 	return &types.QueryIncentivizedPacketsResponse{
 		IncentivizedPackets: identifiedPackets,
+		Pagination:          pagination,
 	}, nil
 }
 
@@ -75,7 +76,7 @@ func (k Keeper) IncentivizedPacketsForChannel(goCtx context.Context, req *types.
 	var packets []*types.IdentifiedPacketFees
 	keyPrefix := types.KeyFeesInEscrowChannelPrefix(req.PortId, req.ChannelId)
 	store := prefix.NewStore(ctx.KVStore(k.storeKey), keyPrefix)
-	_, err := query.Paginate(store, req.Pagination, func(key, value []byte) error {
+	pagination, err := query.Paginate(store, req.Pagination, func(key, value []byte) error {
 		packetID, err := types.ParseKeyFeesInEscrow(string(keyPrefix) + string(key))
 		if err != nil {
 			return err
@@ -94,6 +95,7 @@ func (k Keeper) IncentivizedPacketsForChannel(goCtx context.Context, req *types.
 
 	return &types.QueryIncentivizedPacketsForChannelResponse{
 		IncentivizedPackets: packets,
+		Pagination:          pagination,
 	}, nil
 }
 
@@ -217,7 +219,7 @@ func (k Keeper) FeeEnabledChannels(goCtx context.Context, req *types.QueryFeeEna
 
 	var feeEnabledChannels []types.FeeEnabledChannel
 	store := prefix.NewStore(ctx.KVStore(k.storeKey), []byte(types.FeeEnabledKeyPrefix))
-	_, err := query.Paginate(store, req.Pagination, func(key, value []byte) error {
+	pagination, err := query.Paginate(store, req.Pagination, func(key, value []byte) error {
 		portID, channelID, err := types.ParseKeyFeeEnabled(types.FeeEnabledKeyPrefix + string(key))
 		if err != nil {
 			return err
@@ -238,6 +240,7 @@ func (k Keeper) FeeEnabledChannels(goCtx context.Context, req *types.QueryFeeEna
 
 	return &types.QueryFeeEnabledChannelsResponse{
 		FeeEnabledChannels: feeEnabledChannels,
+		Pagination:         pagination,
 	}, nil
 }