fix: add pagination to deposit fetching

.generated-sources/emily/client/rust/private/docs/DepositApi.md

@@ -82,7 +82,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **status** | [**Status**](.md) | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 
@@ -112,7 +112,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **recipient** | **String** | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 
@@ -142,7 +142,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **txid** | **String** | txid associated with the Deposit. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 

.generated-sources/emily/client/rust/private/docs/WithdrawalApi.md

@@ -79,7 +79,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **status** | [**Status**](.md) | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 

.generated-sources/emily/client/rust/private/src/apis/deposit_api.rs

@@ -165,7 +165,7 @@ pub async fn get_deposits(
     configuration: &configuration::Configuration,
     status: models::Status,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsResponse, Error<GetDepositsError>> {
     let local_var_configuration = configuration;
 
@@ -213,7 +213,7 @@ pub async fn get_deposits_for_recipient(
     configuration: &configuration::Configuration,
     recipient: &str,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsResponse, Error<GetDepositsForRecipientError>> {
     let local_var_configuration = configuration;
 
@@ -264,7 +264,7 @@ pub async fn get_deposits_for_transaction(
     configuration: &configuration::Configuration,
     txid: &str,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsForTransactionResponse, Error<GetDepositsForTransactionError>> {
     let local_var_configuration = configuration;
 

.generated-sources/emily/client/rust/private/src/apis/withdrawal_api.rs

@@ -148,7 +148,7 @@ pub async fn get_withdrawals(
     configuration: &configuration::Configuration,
     status: models::Status,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetWithdrawalsResponse, Error<GetWithdrawalsError>> {
     let local_var_configuration = configuration;
 

.generated-sources/emily/client/rust/public/docs/DepositApi.md

@@ -82,7 +82,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **status** | [**Status**](.md) | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 
@@ -112,7 +112,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **recipient** | **String** | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 
@@ -142,7 +142,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **txid** | **String** | txid associated with the Deposit. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 

.generated-sources/emily/client/rust/public/docs/WithdrawalApi.md

@@ -79,7 +79,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **status** | [**Status**](.md) | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 

.generated-sources/emily/client/rust/public/src/apis/deposit_api.rs

@@ -165,7 +165,7 @@ pub async fn get_deposits(
     configuration: &configuration::Configuration,
     status: models::Status,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsResponse, Error<GetDepositsError>> {
     let local_var_configuration = configuration;
 
@@ -213,7 +213,7 @@ pub async fn get_deposits_for_recipient(
     configuration: &configuration::Configuration,
     recipient: &str,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsResponse, Error<GetDepositsForRecipientError>> {
     let local_var_configuration = configuration;
 
@@ -264,7 +264,7 @@ pub async fn get_deposits_for_transaction(
     configuration: &configuration::Configuration,
     txid: &str,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsForTransactionResponse, Error<GetDepositsForTransactionError>> {
     let local_var_configuration = configuration;
 

.generated-sources/emily/client/rust/public/src/apis/withdrawal_api.rs

@@ -148,7 +148,7 @@ pub async fn get_withdrawals(
     configuration: &configuration::Configuration,
     status: models::Status,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetWithdrawalsResponse, Error<GetWithdrawalsError>> {
     let local_var_configuration = configuration;
 

.generated-sources/emily/client/rust/testing/docs/DepositApi.md

@@ -82,7 +82,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **status** | [**Status**](.md) | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 
@@ -112,7 +112,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **recipient** | **String** | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 
@@ -142,7 +142,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **txid** | **String** | txid associated with the Deposit. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 

.generated-sources/emily/client/rust/testing/docs/WithdrawalApi.md

@@ -79,7 +79,7 @@ Name | Type | Description  | Required | Notes
 ------------- | ------------- | ------------- | ------------- | -------------
 **status** | [**Status**](.md) | the status to search by when getting all deposits. | [required] |
 **next_token** | Option<**String**> | the next token value from the previous return of this api call. |  |
-**page_size** | Option<**i32**> | the maximum number of items in the response list. |  |
+**page_size** | Option<**u32**> | the maximum number of items in the response list. |  |
 
 ### Return type
 

.generated-sources/emily/client/rust/testing/src/apis/deposit_api.rs

@@ -165,7 +165,7 @@ pub async fn get_deposits(
     configuration: &configuration::Configuration,
     status: models::Status,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsResponse, Error<GetDepositsError>> {
     let local_var_configuration = configuration;
 
@@ -213,7 +213,7 @@ pub async fn get_deposits_for_recipient(
     configuration: &configuration::Configuration,
     recipient: &str,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsResponse, Error<GetDepositsForRecipientError>> {
     let local_var_configuration = configuration;
 
@@ -264,7 +264,7 @@ pub async fn get_deposits_for_transaction(
     configuration: &configuration::Configuration,
     txid: &str,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetDepositsForTransactionResponse, Error<GetDepositsForTransactionError>> {
     let local_var_configuration = configuration;
 

.generated-sources/emily/client/rust/testing/src/apis/withdrawal_api.rs

@@ -148,7 +148,7 @@ pub async fn get_withdrawals(
     configuration: &configuration::Configuration,
     status: models::Status,
     next_token: Option<&str>,
-    page_size: Option<i32>,
+    page_size: Option<u32>,
 ) -> Result<models::GetWithdrawalsResponse, Error<GetWithdrawalsError>> {
     let local_var_configuration = configuration;
 

docker/mainnet/sbtc-signer/signer-config.toml.in

@@ -29,6 +29,12 @@ endpoints = [
     "https://[email protected]"
 ]
 
+# The pagination timeout, in seconds, used to fetch deposits and withdrawals
+# requests from Emily.
+# Required: true
+# Environment: SIGNER_EMILY__PAGINATION_TIMEOUT
+pagination_timeout = 30
+
 # !! ==============================================================================
 # !! Bitcoin Core Configuration
 # !! ==============================================================================

docker/sbtc/signer/signer-config.toml

@@ -35,6 +35,12 @@ endpoints = [
     "http://testApiKey@emily-server:3031",
 ]
 
+# The pagination timeout, in seconds, used to fetch deposits and withdrawals
+# requests from Emily.
+# Required: true
+# Environment: SIGNER_EMILY__PAGINATION_TIMEOUT
+pagination_timeout = 30
+
 # !! ==============================================================================
 # !! Bitcoin Core Configuration
 # !! ==============================================================================

emily/handler/src/api/handlers/deposit.rs

@@ -86,7 +86,7 @@ pub async fn get_deposit(
     params(
         ("txid" = String, Path, description = "txid associated with the Deposit."),
         ("nextToken" = Option<String>, Query, description = "the next token value from the previous return of this api call."),
-        ("pageSize" = Option<i32>, Query, description = "the maximum number of items in the response list.")
+        ("pageSize" = Option<u16>, Query, description = "the maximum number of items in the response list.")
     ),
     tag = "deposit",
     responses(
@@ -143,7 +143,7 @@ pub async fn get_deposits_for_transaction(
     params(
         ("status" = Status, Query, description = "the status to search by when getting all deposits."),
         ("nextToken" = Option<String>, Query, description = "the next token value from the previous return of this api call."),
-        ("pageSize" = Option<i32>, Query, description = "the maximum number of items in the response list.")
+        ("pageSize" = Option<u16>, Query, description = "the maximum number of items in the response list.")
     ),
     tag = "deposit",
     responses(
@@ -194,7 +194,7 @@ pub async fn get_deposits(
     params(
         ("recipient" = String, Path, description = "the status to search by when getting all deposits."),
         ("nextToken" = Option<String>, Query, description = "the next token value from the previous return of this api call."),
-        ("pageSize" = Option<i32>, Query, description = "the maximum number of items in the response list.")
+        ("pageSize" = Option<u16>, Query, description = "the maximum number of items in the response list.")
     ),
     tag = "deposit",
     responses(

emily/handler/src/api/handlers/withdrawal.rs

@@ -64,7 +64,7 @@ pub async fn get_withdrawal(context: EmilyContext, request_id: u64) -> impl warp
     params(
         ("status" = Status, Query, description = "the status to search by when getting all deposits."),
         ("nextToken" = Option<String>, Query, description = "the next token value from the previous return of this api call."),
-        ("pageSize" = Option<i32>, Query, description = "the maximum number of items in the response list.")
+        ("pageSize" = Option<u16>, Query, description = "the maximum number of items in the response list.")
     ),
     tag = "withdrawal",
     responses(

emily/handler/tests/integration/deposit.rs

@@ -335,7 +335,7 @@ async fn get_deposits() {
             &configuration,
             status,
             next_token.as_ref().and_then(|o| o.as_deref()),
-            Some(chunksize as i32),
+            Some(chunksize as u32),
         )
         .await
         .expect("Received an error after making a valid get deposits api call.");
@@ -456,7 +456,7 @@ async fn get_deposits_for_recipient() {
                 &configuration,
                 recipient,
                 next_token.as_ref().and_then(|o| o.as_deref()),
-                Some(chunksize as i32),
+                Some(chunksize as u32),
             )
             .await
             .expect("Received an error after making a valid get deposits for recipient api call.");

emily/handler/tests/integration/withdrawal.rs

@@ -139,11 +139,11 @@ async fn get_withdrawals() {
         expected_withdrawal_infos.push(expected_withdrawal_info);
     }
 
-    let chunksize: u16 = 2;
+    let chunksize = 2;
     // If the number of elements is an exact multiple of the chunk size the "final"
     // query will still have a next token, and the next query will now have a next
     // token and will return no additional data.
-    let expected_chunks = expected_withdrawal_infos.len() as u16 / chunksize + 1;
+    let expected_chunks = expected_withdrawal_infos.len() as u32 / chunksize + 1;
 
     // Act.
     // ----
@@ -157,7 +157,7 @@ async fn get_withdrawals() {
             &configuration,
             status,
             next_token.as_ref().and_then(|o| o.as_deref()),
-            Some(chunksize as i32),
+            Some(chunksize),
         )
         .await
         .expect("Received an error after making a valid get withdrawal api call.");
@@ -171,13 +171,13 @@ async fn get_withdrawals() {
 
     // Assert.
     // -------
-    assert_eq!(expected_chunks, gotten_withdrawal_info_chunks.len() as u16);
+    assert_eq!(expected_chunks, gotten_withdrawal_info_chunks.len() as u32);
     let max_chunk_size = gotten_withdrawal_info_chunks
         .iter()
         .map(|chunk| chunk.len())
         .max()
         .unwrap();
-    assert!(chunksize >= max_chunk_size as u16);
+    assert!(chunksize >= max_chunk_size as u32);
 
     let mut gotten_withdrawal_infos = gotten_withdrawal_info_chunks
         .into_iter()

emily/openapi-gen/generated-specs/private-emily-openapi-spec.json

@@ -389,7 +389,8 @@
             "schema": {
               "type": "integer",
               "format": "int32",
-              "nullable": true
+              "nullable": true,
+              "minimum": 0
             }
           }
         ],
@@ -672,7 +673,8 @@
             "schema": {
               "type": "integer",
               "format": "int32",
-              "nullable": true
+              "nullable": true,
+              "minimum": 0
             }
           }
         ],
@@ -798,7 +800,8 @@
             "schema": {
               "type": "integer",
               "format": "int32",
-              "nullable": true
+              "nullable": true,
+              "minimum": 0
             }
           }
         ],
@@ -1478,7 +1481,8 @@
             "schema": {
               "type": "integer",
               "format": "int32",
-              "nullable": true
+              "nullable": true,
+              "minimum": 0
             }
           }
         ],