cargo fmt

Author: MarcosNicolau

crates/batcher/src/lib.rs

@@ -558,9 +558,7 @@ impl Batcher {
         // Process each event
         for event in events {
             let user_address = event.user;
-            debug!(
-                "Processing BalanceUnlocked event for user: {user_address:?}"
-            );
+            debug!("Processing BalanceUnlocked event for user: {user_address:?}");
 
             // Check if user has proofs in queue
             //
@@ -1781,9 +1779,7 @@ impl Batcher {
         let last_uploaded_batch_block_lock = self.last_uploaded_batch_block.lock().await;
 
         if current_batch_len < 1 {
-            info!(
-                "Current batch has {current_batch_len} proofs. Waiting for more proofs..."
-            );
+            info!("Current batch has {current_batch_len} proofs. Waiting for more proofs...");
             return None;
         }
 
@@ -1833,9 +1829,7 @@ impl Batcher {
         .ok()?;
 
         let extracted = finalized_batch.len();
-        info!(
-            "Extracted {extracted} proofs from queue for batch processing"
-        );
+        info!("Extracted {extracted} proofs from queue for batch processing");
 
         // Update queue metrics after successful batch extraction
         let queue_len = batch_state_lock.batch_queue.len();
@@ -1845,9 +1839,7 @@ impl Batcher {
                     .update_queue_metrics(queue_len as i64, queue_size_bytes as i64);
             }
             Err(e) => {
-                error!(
-                    "Failed to calculate batch size for queue metrics update: {e:?}"
-                );
+                error!("Failed to calculate batch size for queue metrics update: {e:?}");
                 // Still update queue length metric, set size to 0 due to calculation error
                 self.metrics.update_queue_metrics(queue_len as i64, 0);
             }
@@ -2025,9 +2017,7 @@ impl Batcher {
             .update_user_states_from_queue_state(users_with_restored_proofs)
             .await
         {
-            error!(
-                "Failed to update user states after proof restoration: {e:?}"
-            );
+            error!("Failed to update user states after proof restoration: {e:?}");
         }
     }
 
@@ -2159,9 +2149,7 @@ impl Batcher {
             .update_user_states_from_queue_state(users_in_batch)
             .await
         {
-            error!(
-                "Failed to update user states after batch confirmation: {e:?}"
-            );
+            error!("Failed to update user states after batch confirmation: {e:?}");
             // Continue with the rest of the process since batch was already submitted successfully
         }
 
@@ -2669,8 +2657,7 @@ impl Batcher {
                 .await
                 .is_ok()
             {
-                let secondary_url =
-                    format!("{download_endpoint_secondary}/{file_name}");
+                let secondary_url = format!("{download_endpoint_secondary}/{file_name}");
                 successful_urls.push(secondary_url.clone());
                 info!("Successfully uploaded batch to secondary S3: {secondary_url}");
             } else {

crates/sdk/src/common/errors.rs

@@ -186,7 +186,10 @@ impl fmt::Display for SubmitError {
             SubmitError::InvalidNonce => write!(f, "Invalid nonce"),
             SubmitError::InvalidMaxFee => write!(f, "Invalid max fee"),
             SubmitError::BatchSubmissionFailed(merkle_root) => {
-                write!(f, "Could not create task with batch merkle root {merkle_root}")
+                write!(
+                    f,
+                    "Could not create task with batch merkle root {merkle_root}"
+                )
             }
             SubmitError::GenericError(e) => write!(f, "Generic error: {e}"),
             SubmitError::InvalidSignature => write!(f, "Invalid Signature"),

crates/sdk/src/communication/messaging.rs

@@ -135,9 +135,7 @@ pub async fn receive(
         ) {
             Ok(data) => data,
             Err(e) => {
-                warn!(
-                    "Error while matching batcher response with sent data: {e:?}"
-                );
+                warn!("Error while matching batcher response with sent data: {e:?}");
                 aligned_submitted_data.push(Err(e));
                 break;
             }
@@ -227,9 +225,7 @@ async fn handle_batcher_response(msg: Message) -> Result<BatchInclusionData, Sub
             ))
         }
         Ok(SubmitProofResponseMessage::InvalidProof(reason)) => {
-            error!(
-                "Batcher responded with invalid proof: {reason}. Funds have not been spent."
-            );
+            error!("Batcher responded with invalid proof: {reason}. Funds have not been spent.");
             Err(SubmitError::InvalidProof(reason))
         }
         Ok(SubmitProofResponseMessage::CreateNewTaskError(merkle_root, error)) => {
@@ -255,9 +251,7 @@ async fn handle_batcher_response(msg: Message) -> Result<BatchInclusionData, Sub
             Err(SubmitError::ProofQueueFlushed)
         }
         Ok(SubmitProofResponseMessage::Error(e)) => {
-            error!(
-                "Batcher responded with error: {e}. Funds have not been spent."
-            );
+            error!("Batcher responded with error: {e}. Funds have not been spent.");
             Err(SubmitError::GenericError(e))
         }
         Ok(SubmitProofResponseMessage::UnderpricedProof) => {