test: fix and unit tests for query pending cctx within rate limit

changelog.md

@@ -83,6 +83,7 @@
 * [1985](https://github.com/zeta-chain/node/pull/1985) - improve fungible module coverage
 * [1992](https://github.com/zeta-chain/node/pull/1992) - remove setupKeeper from crosschain module
 * [2008](https://github.com/zeta-chain/node/pull/2008) - add test for connector bytecode update
+* [2060](https://github.com/zeta-chain/node/pull/2060) - add unit test for rate limiter query
 
 ### Fixes
 

docs/openapi/openapi.swagger.yaml

@@ -54013,6 +54013,11 @@ definitions:
       total_pending:
         type: string
         format: uint64
+      current_withdraw_window:
+        type: string
+        format: int64
+      current_withdraw_rate:
+        type: string
       rate_limit_exceeded:
         type: boolean
   crosschainQueryMessagePassingProtocolFeeResponse:

proto/crosschain/query.proto

@@ -270,7 +270,9 @@ message QueryListPendingCctxWithinRateLimitRequest {
 message QueryListPendingCctxWithinRateLimitResponse {
   repeated CrossChainTx cross_chain_tx = 1;
   uint64 total_pending = 2;
-  bool rate_limit_exceeded = 3;
+  int64 current_withdraw_window = 3;
+  string current_withdraw_rate = 4;
+  bool rate_limit_exceeded = 5;
 }
 
 message QueryLastZetaHeightRequest {}

typescript/crosschain/query_pb.d.ts

@@ -910,7 +910,17 @@ export declare class QueryListPendingCctxWithinRateLimitResponse extends Message
   totalPending: bigint;
 
   /**
-   * @generated from field: bool rate_limit_exceeded = 3;
+   * @generated from field: int64 current_withdraw_window = 3;
+   */
+  currentWithdrawWindow: bigint;
+
+  /**
+   * @generated from field: string current_withdraw_rate = 4;
+   */
+  currentWithdrawRate: string;
+
+  /**
+   * @generated from field: bool rate_limit_exceeded = 5;
    */
   rateLimitExceeded: boolean;
 

x/crosschain/keeper/grpc_query_cctx.go

@@ -16,6 +16,9 @@ import (
 const (
 	// MaxPendingCctxs is the maximum number of pending cctxs that can be queried
 	MaxPendingCctxs = 500
+
+	// MaxLookbackNonce is the maximum number of nonces to look back to find missed pending cctxs
+	MaxLookbackNonce = 1000
 )
 
 func (k Keeper) ZetaAccounting(c context.Context, _ *types.QueryZetaAccountingRequest) (*types.QueryZetaAccountingResponse, error) {
@@ -122,7 +125,7 @@ func (k Keeper) ListPendingCctx(c context.Context, req *types.QueryListPendingCc
 	// now query the previous nonces up to 1000 prior to find any pending cctx that we might have missed
 	// need this logic because a confirmation of higher nonce will automatically update the p.NonceLow
 	// therefore might mask some lower nonce cctx that is still pending.
-	startNonce := pendingNonces.NonceLow - 1000
+	startNonce := pendingNonces.NonceLow - MaxLookbackNonce
 	if startNonce < 0 {
 		startNonce = 0
 	}