cargo fmt

Author: Mechanix97

aggregation_mode/src/backend/config.rs

@@ -27,8 +27,11 @@ impl Config {
         Ok(config)
     }
 
-    pub fn save_to_file(&self, file_path: &str) -> Result<(), Box<dyn std::error::Error>>  {
-        let mut file = OpenOptions::new().write(true).truncate(true).open(file_path)?;
+    pub fn save_to_file(&self, file_path: &str) -> Result<(), Box<dyn std::error::Error>> {
+        let mut file = OpenOptions::new()
+            .write(true)
+            .truncate(true)
+            .open(file_path)?;
         let content = serde_yaml::to_string(&self)?;
         file.write_all(content.as_bytes())?;
         Ok(())

aggregation_mode/src/backend/fetcher.rs

@@ -24,7 +24,7 @@ pub enum ProofsFetcherError {
 pub struct ProofsFetcher {
     rpc_provider: RPCProvider,
     aligned_service_manager: AlignedLayerServiceManagerContract,
-    last_processed_block: u64
+    last_processed_block: u64,
 }
 
 impl ProofsFetcher {
@@ -58,16 +58,15 @@ impl ProofsFetcher {
 
         info!(
             "Fetching proofs from batch logs starting from block number {} upto {}",
-            self.last_processed_block,
-            current_block
+            self.last_processed_block, current_block
         );
-            
+
         // Subscribe to NewBatch event from AlignedServiceManager
         let logs = self
             .aligned_service_manager
             .NewBatchV3_filter()
             .from_block(self.last_processed_block)
-            .to_block(current_block)        
+            .to_block(current_block)
             .query()
             .await
             .map_err(|_| ProofsFetcherError::QueryingLogs)?;