cargo fmt

Author: Mechanix97

batcher/aligned-batcher/src/lib.rs

@@ -1052,32 +1052,40 @@ impl Batcher {
 
         let batch_queue_len = batch_state_lock.batch_queue.len();
 
-        let new_entry =  BatchQueueEntry::new(
+        let new_entry = BatchQueueEntry::new(
             verification_data,
             verification_data_comm,
             ws_conn_sink,
             proof_submitter_sig,
             proof_submitter_addr,
-            );
-        let new_entry_priority = BatchQueueEntryPriority::new(max_fee, nonce) ;
+        );
+        let new_entry_priority = BatchQueueEntryPriority::new(max_fee, nonce);
 
-        if  batch_queue_len + 1 > self.max_batch_proof_qty {
-            let (lowest_priority_entry, lowest_priority_entry_priority) = 
+        if batch_queue_len + 1 > self.max_batch_proof_qty {
+            let (lowest_priority_entry, lowest_priority_entry_priority) =
                 get_lowest_priority_entry(&batch_state_lock.batch_queue).unwrap();
-                
-            if lowest_priority_entry_priority <  new_entry_priority {
-                if batch_state_lock.batch_queue.remove(&lowest_priority_entry).is_none(){
+
+            if lowest_priority_entry_priority < new_entry_priority {
+                if batch_state_lock
+                    .batch_queue
+                    .remove(&lowest_priority_entry)
+                    .is_none()
+                {
                     //err
                 }
-                
+
                 // todo send msg to the removed entry ws
 
-                batch_state_lock.batch_queue.push(new_entry, new_entry_priority);    
+                batch_state_lock
+                    .batch_queue
+                    .push(new_entry, new_entry_priority);
             } else {
                 // can't accept the new proof
             }
         } else {
-            batch_state_lock.batch_queue.push(new_entry, new_entry_priority );
+            batch_state_lock
+                .batch_queue
+                .push(new_entry, new_entry_priority);
         }
 
         // Update metrics

batcher/aligned-batcher/src/types/batch_queue.rs

@@ -212,7 +212,9 @@ fn calculate_fee_per_proof(batch_len: usize, gas_price: U256, constant_gas_cost:
     U256::from(gas_per_proof) * gas_price
 }
 
-pub(crate) fn get_lowest_priority_entry(batch_queue: &BatchQueue) -> Option<(BatchQueueEntry, BatchQueueEntryPriority)> {
+pub(crate) fn get_lowest_priority_entry(
+    batch_queue: &BatchQueue,
+) -> Option<(BatchQueueEntry, BatchQueueEntryPriority)> {
     let mut lowest_fee_entry: Option<(BatchQueueEntry, BatchQueueEntryPriority)> = None;
 
     for (entry, priority) in batch_queue {
@@ -224,10 +226,10 @@ pub(crate) fn get_lowest_priority_entry(batch_queue: &BatchQueue) -> Option<(Bat
             }
             None => {
                 lowest_fee_entry = Some((entry.clone(), priority.clone()));
-            } 
+            }
         }
     }
-    
+
     lowest_fee_entry
 }