Function execute_test

testing/backtest-runner/src/main.rs:213–803

Complete test execution - everything happens here for isolation

(test_path: PathBuf, args: &Commands)

// Complete test execution - everything happens here for isolation
async fn execute_test(test_path: PathBuf, args: &Commands) -> Result<()> {
    let test_config = TestConfig::from_file(test_path.to_string_lossy().to_string()).await?;

    // Check if test is disabled
    if test_config.settings.disabled {
        println!("[{}] SKIPPED: Test disabled - {}", Local::now().format("%H:%M:%S.%3f"), test_path.display());
        return Ok(());
    }

    println!("[{}] TEST STARTED: {}", Local::now().format("%H:%M:%S.%3f"), test_path.display());
    println!("[{}] Block: {} | Timeout: {}s", Local::now().format("%H:%M:%S.%3f"), test_config.settings.block, args.timeout);

    // Create a fresh Anvil instance for this test
    let node_url = env::var("MAINNET_WS")?;
    let client = AnvilDebugProviderFactory::from_node_on_block(node_url, test_config.settings.block).await?;
    let priv_key = client.privkey()?.to_bytes().to_vec();

    let mut mock_server: Option<MockServer> = None;
    if test_config.modules.flashbots {
        // Start flashbots mock server
        mock_server = Some(MockServer::start().await);
        mount_flashbots_mock(mock_server.as_ref().unwrap()).await;
    }

    let multicaller_address = MulticallerDeployer::new()
        .set_code(client.clone(), address!("FCfCfcfC0AC30164AFdaB927F441F2401161F358"))
        .await?
        .address()
        .ok_or_eyre("MULTICALLER_NOT_DEPLOYED")?;
    info!("Multicaller deployed at {:?}", multicaller_address);

    let multicaller_encoder = MulticallerSwapEncoder::default_with_address(multicaller_address);

    let block_number = client.get_block_number().await?;
    info!("Current block_number={}", block_number);

    let block_response = client.get_block(block_number.into()).await?.unwrap();
    let block = <BlockTy<EthPrimitives> as TryFromBlockResponse<Ethereum>>::from_block_response(block_response)?;
    let block_header = block.header().clone();
    info!("Current block_header={:?}", block_header);

    let block_response = client.get_block(block_number.into()).await?.unwrap();

    let block_header_with_txes = <BlockTy<EthPrimitives> as TryFromBlockResponse<Ethereum>>::from_block_response(block_response)?;

    // Create AlloyDB connected to the forked Anvil instance
    let alloy_db =
        AlloyDB::new(client.clone(), BlockId::Number(BlockNumberOrTag::Number(block_number))).ok_or_eyre("Failed to create AlloyDB")?;
    let state_db = KabuDB::new().with_ext_db(alloy_db);
    let market_state_instance = MarketState::new(state_db);

    // Add default tokens for price actor

    info!("Creating blockchain and initial state");
    // Create Blockchain instance which manages all channels
    // Disable influxdb for test runner
    let blockchain = Blockchain::new_with_config(1, false); // Chain ID 1 for mainnet, influxdb disabled