Add limit query param to the receipts endpoint

Author: maximopalopoli

aggregation_mode/batcher/src/db.rs

@@ -79,16 +79,16 @@ impl Db {
         .await
     }
 
-    pub async fn get_tasks_by_address(
+    pub async fn get_tasks_by_address_with_limit(
         &self,
         address: &str,
         limit: i64,
     ) -> Result<Vec<Receipt>, sqlx::Error> {
         sqlx::query_as::<_, Receipt>(
             "SELECT status,merkle_path,nonce,address FROM tasks
                 WHERE address = $1
-                LIMIT $2
-                ORDER BY nonce DESC",
+                ORDER BY nonce DESC
+                LIMIT $2",
         )
         .bind(address.to_lowercase())
         .bind(limit)

aggregation_mode/batcher/src/server/http.rs

@@ -206,6 +206,8 @@ impl BatcherServer {
                 .json(AppResponse::new_unsucessfull("Invalid address", 400));
         }
 
+        let limit = params.limit.unwrap_or(100); // We take 100 as the default limit value
+
         let address = params.address.to_lowercase();
 
         let query = if let Some(nonce) = params.nonce {
@@ -214,7 +216,10 @@ impl BatcherServer {
                 .get_tasks_by_address_and_nonce(&address, nonce)
                 .await
         } else {
-            state.db.get_tasks_by_address(&address, 100).await
+            state
+                .db
+                .get_tasks_by_address_with_limit(&address, limit)
+                .await
         };
 
         let Ok(receipts) = query else {

aggregation_mode/batcher/src/server/types.rs

@@ -28,11 +28,14 @@ impl AppResponse {
     }
 }
 
-/// Query parameters accepted by `GET /proof/merkle`, containing an optional proof id.
+/// Query parameters accepted by `GET /proof/merkle`. Requires an address, and accepts a nonce
+/// and a limit for the amount of tasks included in the query (the maximum value is 100).
+/// Note: The limit value will only be taken into account if nonce is None.
 #[derive(Deserialize, Clone)]
 pub(super) struct GetReceiptsQueryParams {
     pub address: String,
     pub nonce: Option<i64>,
+    pub limit: Option<i64>,
 }
 
 #[derive(Serialize, Deserialize, Clone, Debug)]