fix: cargo fmt

Author: JuArce

aggregation_mode/src/backend/mod.rs

@@ -1,9 +1,9 @@
 pub mod config;
 pub mod fetcher;
 mod merkle_tree;
+mod retry;
 mod s3;
 mod types;
-mod retry;
 
 use crate::aggregators::{AlignedProof, ProofAggregationError, ZKVMEngine};
 

aggregation_mode/src/backend/retry.rs

@@ -30,7 +30,7 @@ impl<E: std::fmt::Display> std::error::Error for RetryError<E> where E: std::fmt
 
 /// Supports retries only on async functions. See: https://docs.rs/backon/latest/backon/#retry-an-async-function
 /// Runs with `jitter: false`.
-/// 
+///
 /// # Parameters
 /// * `function` - The async function to retry
 /// * `min_delay_millis` - Initial delay before first retry attempt (in milliseconds)
@@ -44,9 +44,9 @@ pub async fn retry_function<FutureFn, Fut, T, E>(
     max_times: usize,
     max_delay_seconds: u64,
 ) -> Result<T, RetryError<E>>
-    where
-        Fut: Future<Output = Result<T, RetryError<E>>>,
-        FutureFn: FnMut() -> Fut,
+where
+    Fut: Future<Output = Result<T, RetryError<E>>>,
+    FutureFn: FnMut() -> Fut,
 {
     let backoff = ExponentialBuilder::default()
         .with_min_delay(Duration::from_millis(min_delay_millis))

aggregation_mode/src/backend/s3.rs

@@ -1,7 +1,7 @@
-use std::time::Duration;
+use crate::backend::retry::{retry_function, RetryError};
 use aligned_sdk::common::types::VerificationData;
+use std::time::Duration;
 use tracing::{info, warn};
-use crate::backend::retry::{retry_function, RetryError};
 
 #[derive(Debug)]
 #[allow(dead_code)]
@@ -40,20 +40,22 @@ async fn get_aligned_batch_from_s3_retryable(
         .connect_timeout(CONNECT_TIMEOUT_SECONDS)
         .timeout(BATCH_DOWNLOAD_TIMEOUT_SECONDS)
         .build()
-        .map_err(|e| RetryError::Permanent(GetBatchProofsError::ReqwestClientFailed(e.to_string())))?;
-
-    let response = client
-        .get(&url)
-        .send()
-        .await
         .map_err(|e| {
-            warn!("Failed to send request to {}: {}", url, e);
-            RetryError::Transient(GetBatchProofsError::FetchingS3Batch(e.to_string()))
+            RetryError::Permanent(GetBatchProofsError::ReqwestClientFailed(e.to_string()))
         })?;
 
+    let response = client.get(&url).send().await.map_err(|e| {
+        warn!("Failed to send request to {}: {}", url, e);
+        RetryError::Transient(GetBatchProofsError::FetchingS3Batch(e.to_string()))
+    })?;
+
     if !response.status().is_success() {
         let status_code = response.status().as_u16();
-        let reason = response.status().canonical_reason().unwrap_or("").to_string();
+        let reason = response
+            .status()
+            .canonical_reason()
+            .unwrap_or("")
+            .to_string();
 
         // Determine if the error is retryable based on status code
         let error = GetBatchProofsError::StatusFailed((status_code, reason));
@@ -69,20 +71,16 @@ async fn get_aligned_batch_from_s3_retryable(
         };
     }
 
-    let bytes = response
-        .bytes()
-        .await
-        .map_err(|e| {
-            warn!("Failed to read response body from {}: {}", url, e);
-            RetryError::Transient(GetBatchProofsError::EmptyBody(e.to_string()))
-        })?;
+    let bytes = response.bytes().await.map_err(|e| {
+        warn!("Failed to read response body from {}: {}", url, e);
+        RetryError::Transient(GetBatchProofsError::EmptyBody(e.to_string()))
+    })?;
     let bytes: &[u8] = bytes.iter().as_slice();
 
-    let data: Vec<VerificationData> = ciborium::from_reader(bytes)
-        .map_err(|e| {
-            warn!("Failed to deserialize batch data from {}: {}", url, e);
-            RetryError::Permanent(GetBatchProofsError::Deserialization(e.to_string()))
-        })?;
+    let data: Vec<VerificationData> = ciborium::from_reader(bytes).map_err(|e| {
+        warn!("Failed to deserialize batch data from {}: {}", url, e);
+        RetryError::Permanent(GetBatchProofsError::Deserialization(e.to_string()))
+    })?;
 
     Ok(data)
 }