chore: Bump Rust toolchain to 1.91.1

.github/actions/prepare/action.yml

@@ -14,7 +14,7 @@ runs:
   using: composite
   steps:
     - name: setup rust tool chain
-      uses: dtolnay/rust-toolchain@1.88.0  # v1.88.0
+      uses: dtolnay/rust-toolchain@1.91.1  # v1.91.1
       with:
         components: ${{ (inputs.components != '') && format('{0}, rustfmt, clippy', inputs.components) || 'rustfmt, clippy' }}
     - name: Install libsodium

Cargo.toml

@@ -2,7 +2,7 @@
 name = "openzeppelin-relayer"
 version = "1.4.0"
 edition = "2021"
-rust-version = "1.88"         #MSRV
+rust-version = "1.91"         #MSRV
 
 [features]
 default = []

rust-toolchain.toml

@@ -1,5 +1,5 @@
 [toolchain]
-channel = "1.88.0"
+channel = "1.91.1"
 profile = "minimal"
 components = [
     "rustc",

src/jobs/handlers/transaction_cleanup_handler.rs

@@ -329,7 +329,7 @@ async fn process_status_cleanup(
         };
 
         let page_result = transaction_repo
-            .find_by_status_paginated(relayer_id, &[status.clone()], query, true)
+            .find_by_status_paginated(relayer_id, std::slice::from_ref(status), query, true)
             .await
             .map_err(|e| {
                 eyre::eyre!(

src/queues/sqs/worker.rs

@@ -903,7 +903,7 @@ fn poll_error_backoff_secs(consecutive_errors: u32) -> u64 {
 
     // Once well past the ceiling, periodically try the base interval
     // to quickly detect when the SQS endpoint recovers.
-    if consecutive_errors >= 7 && consecutive_errors % RECOVERY_PROBE_EVERY == 0 {
+    if consecutive_errors >= 7 && consecutive_errors.is_multiple_of(RECOVERY_PROBE_EVERY) {
         return base;
     }
 

src/repositories/api_key/api_key_in_memory.rs

@@ -39,7 +39,7 @@ impl InMemoryApiKeyRepository {
         }
     }
 
-    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<T>, RepositoryError> {
+    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<'_, T>, RepositoryError> {
         Ok(lock.lock().await)
     }
 }

src/repositories/network/network_in_memory.rs

@@ -40,7 +40,7 @@ impl InMemoryNetworkRepository {
         }
     }
 
-    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<T>, RepositoryError> {
+    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<'_, T>, RepositoryError> {
         Ok(lock.lock().await)
     }
 

src/repositories/notification/notification_in_memory.rs

@@ -39,7 +39,7 @@ impl InMemoryNotificationRepository {
         }
     }
 
-    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<T>, RepositoryError> {
+    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<'_, T>, RepositoryError> {
         Ok(lock.lock().await)
     }
 }

src/repositories/plugin/plugin_in_memory.rs

@@ -60,7 +60,7 @@ impl InMemoryPluginRepository {
         Ok(store.get(id).cloned())
     }
 
-    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<T>, RepositoryError> {
+    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<'_, T>, RepositoryError> {
         Ok(lock.lock().await)
     }
 }

src/repositories/relayer/relayer_in_memory.rs

@@ -30,7 +30,7 @@ impl InMemoryRelayerRepository {
             store: Mutex::new(HashMap::new()),
         }
     }
-    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<T>, RepositoryError> {
+    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<'_, T>, RepositoryError> {
         Ok(lock.lock().await)
     }
 }

src/repositories/signer/signer_in_memory.rs

@@ -38,7 +38,7 @@ impl InMemorySignerRepository {
         }
     }
 
-    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<T>, RepositoryError> {
+    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<'_, T>, RepositoryError> {
         Ok(lock.lock().await)
     }
 }

src/repositories/transaction/transaction_in_memory.rs

@@ -43,7 +43,7 @@ impl InMemoryTransactionRepository {
         }
     }
 
-    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<T>, RepositoryError> {
+    async fn acquire_lock<T>(lock: &Mutex<T>) -> Result<MutexGuard<'_, T>, RepositoryError> {
         Ok(lock.lock().await)
     }
 

src/services/plugins/pool_executor.rs

@@ -485,7 +485,7 @@ impl PoolManager {
                     last_log_time = now;
                 } else {
                     suppressed_count += 1;
-                    if suppressed_count % 100 == 0 {
+                    if suppressed_count.is_multiple_of(100) {
                         tracing::warn!(
                             target: "pool_server",
                             suppressed = suppressed_count,