just fix

Author: niran

crates/simulator/src/lib.rs

@@ -47,7 +47,9 @@ async fn init_dependencies<Node>(
     database_url: String,
     kafka_brokers: String,
     kafka_topic: String,
-) -> Result<ListenerDependencies<BundleSimulatorImpl<RethSimulationEngine<Node>, TipsSimulationPublisher>>>
+) -> Result<
+    ListenerDependencies<BundleSimulatorImpl<RethSimulationEngine<Node>, TipsSimulationPublisher>>,
+>
 where
     Node: FullNodeComponents,
     <Node as FullNodeComponents>::Evm: ConfigureEvm<NextBlockEnvCtx = OpNextBlockEnvAttributes>,
@@ -128,10 +130,8 @@ where
         )
         .await?;
 
-        let shared_worker_pool = SimulationWorkerPool::new(
-            Arc::new(dependencies.simulator),
-            max_concurrent_simulations,
-        );
+        let shared_worker_pool =
+            SimulationWorkerPool::new(Arc::new(dependencies.simulator), max_concurrent_simulations);
 
         let exex_listener = ExExEventListener::new(
             exex_ctx,

crates/simulator/tests/bundle_simulator_impl_test.rs

@@ -175,4 +175,3 @@ async fn test_bundle_simulator_impl_various_error_types() {
         }
     }
 }
-

crates/simulator/tests/common/builders.rs

@@ -1,7 +1,6 @@
 #![allow(dead_code)]
 
 /// Test data builders for creating complex test scenarios
-
 use alloy_primitives::{Address, Bytes, B256, U256};
 use alloy_rpc_types_mev::EthSendBundle;
 use std::collections::HashMap;
@@ -51,8 +50,6 @@ impl TestBundleBuilder {
         self
     }
 
-
-
     pub fn build(self) -> EthSendBundle {
         EthSendBundle {
             txs: self.txs,
@@ -255,7 +252,6 @@ impl ScenarioBuilder {
         self
     }
 
-
     pub fn add_simple_bundle(mut self, num_txs: usize) -> Self {
         let mut builder = TestBundleBuilder::new().with_block_number(self.block_number);
 
@@ -279,4 +275,3 @@ impl ScenarioBuilder {
             .collect()
     }
 }
-

crates/simulator/tests/common/fixtures.rs

@@ -1,7 +1,6 @@
 #![allow(dead_code)]
 
 /// Test fixtures and pre-configured test data
-
 use alloy_primitives::Bytes;
 use alloy_rpc_types_mev::EthSendBundle;
 
@@ -63,7 +62,6 @@ pub mod transactions {
             0x50, 0x60, 0x70, 0x80,
         ])
     }
-
 }
 
 /// Pre-configured bundles for testing
@@ -89,7 +87,6 @@ pub mod bundles {
             .build()
     }
 
-
     /// Large bundle for stress testing
     pub fn large_bundle(num_txs: usize) -> EthSendBundle {
         let mut builder = TestBundleBuilder::new().with_block_number(blocks::BLOCK_18M);
@@ -101,7 +98,6 @@ pub mod bundles {
 
         builder.build()
     }
-
 }
 
 /// Test scenarios combining multiple fixtures
@@ -143,4 +139,3 @@ pub mod scenarios {
         }
     }
 }
-

crates/simulator/tests/common/mock_bundle_simulator.rs

@@ -19,8 +19,6 @@ impl MockBundleSimulator {
     pub fn new(engine: MockSimulationEngine, publisher: MockSimulationPublisher) -> Self {
         Self { engine, publisher }
     }
-
-
 }
 
 #[async_trait]
@@ -56,4 +54,3 @@ impl BundleSimulator for MockBundleSimulator {
         Ok(())
     }
 }
-

crates/simulator/tests/common/mocks.rs

@@ -1,7 +1,6 @@
 #![allow(dead_code)]
 
 /// Reusable mock implementations for testing
-
 use alloy_primitives::{Address, U256};
 use async_trait::async_trait;
 use std::collections::HashMap;
@@ -44,7 +43,6 @@ impl MockSimulationEngine {
         self
     }
 
-
     pub fn simulation_count(&self) -> usize {
         self.simulations.lock().unwrap().len()
     }
@@ -129,7 +127,6 @@ impl MockSimulationPublisher {
     pub fn published_count(&self) -> usize {
         self.published.lock().unwrap().len()
     }
-
 }
 
 #[async_trait]

crates/simulator/tests/common/mod.rs

@@ -1,7 +1,6 @@
 #![allow(dead_code)]
 
 /// Common test utilities and infrastructure for simulator testing
-
 pub mod builders;
 pub mod fixtures;
 pub mod mock_bundle_simulator;
@@ -13,7 +12,6 @@ use std::collections::HashMap;
 use tips_simulator::types::{SimulationRequest, SimulationResult};
 use uuid::Uuid;
 
-
 /// Helper to create a simple test bundle
 pub fn create_test_bundle(num_txs: usize, block_number: u64) -> EthSendBundle {
     let mut txs = Vec::new();
@@ -83,7 +81,4 @@ pub mod assertions {
             "Successful simulation should not have error"
         );
     }
-
-
 }
-

crates/simulator/tests/publisher_test.rs

@@ -1,8 +1,8 @@
 /// Unit tests for the SimulationPublisher implementation
 mod common;
 
-use common::builders::*;
 use alloy_primitives::{Address, B256, U256};
+use common::builders::*;
 use std::collections::HashMap;
 
 // These tests focus on the logic that can be tested without requiring
@@ -12,16 +12,16 @@ use std::collections::HashMap;
 async fn test_state_diff_conversion_logic() {
     // Test the state diff conversion logic that TipsSimulationPublisher uses
     let mut original_state_diff = HashMap::new();
-    
+
     // Create test data with multiple accounts and storage slots
     for i in 0..3 {
         let addr = Address::random();
         let mut storage = HashMap::new();
-        
+
         for j in 0..5 {
             storage.insert(U256::from(i * 10 + j), U256::from((i + 1) * 100 + j));
         }
-        
+
         original_state_diff.insert(addr, storage);
     }
 
@@ -39,12 +39,12 @@ async fn test_state_diff_conversion_logic() {
 
     // Verify conversion
     assert_eq!(converted.len(), original_state_diff.len());
-    
+
     for (address, original_storage) in &original_state_diff {
         assert!(converted.contains_key(address));
         let converted_storage = &converted[address];
         assert_eq!(converted_storage.len(), original_storage.len());
-        
+
         for (key, value) in original_storage {
             let key_bytes = key.to_be_bytes::<32>();
             let storage_key = B256::from(key_bytes);
@@ -53,21 +53,20 @@ async fn test_state_diff_conversion_logic() {
     }
 }
 
-
 #[test]
 fn test_large_state_diff_handling() {
     // Test handling of large state diffs
     let mut large_state_diff = HashMap::new();
-    
+
     // Create a large state diff with many accounts and storage slots
     for i in 0..100 {
         let addr = Address::random();
         let mut storage = HashMap::new();
-        
+
         for j in 0..50 {
             storage.insert(U256::from(i * 1000 + j), U256::from(j * 12345));
         }
-        
+
         large_state_diff.insert(addr, storage);
     }
 
@@ -90,8 +89,6 @@ fn test_large_state_diff_handling() {
     }
 }
 
-
-
 #[test]
 fn test_execution_time_bounds() {
     // Test execution time edge cases
@@ -106,26 +103,28 @@ fn test_execution_time_bounds() {
         let result = SimulationResultBuilder::successful()
             .with_execution_time_us(execution_time)
             .build();
-        
-        assert_eq!(result.execution_time_us, execution_time, "Failed for: {}", description);
+
+        assert_eq!(
+            result.execution_time_us, execution_time,
+            "Failed for: {}",
+            description
+        );
     }
 }
 
-
-
 #[test]
 fn test_multiple_addresses_same_storage() {
     // Test multiple addresses with the same storage patterns
     let addresses = vec![Address::random(), Address::random(), Address::random()];
     let mut state_diff = HashMap::new();
-    
+
     for addr in &addresses {
         let mut storage = HashMap::new();
         storage.insert(U256::from(1), U256::from(100));
         storage.insert(U256::from(2), U256::from(200));
         state_diff.insert(*addr, storage);
     }
-    
+
     // Convert
     let mut converted = HashMap::new();
     for (address, storage) in &state_diff {
@@ -137,7 +136,7 @@ fn test_multiple_addresses_same_storage() {
         }
         converted.insert(*address, storage_map);
     }
-    
+
     assert_eq!(converted.len(), 3);
     for addr in &addresses {
         assert!(converted.contains_key(addr));