test(cketh): build the live balance-scan harness on the shared fixtures

rs/ethereum/cketh/minter/BUILD.bazel

@@ -299,6 +299,10 @@ rust_test(
         "tests/deposit_from_cex_demo/MockUSDT.sol",
         # End-to-end balance scan on a live PocketIC + local anvil node.
         ":cketh_minter_debug.wasm.gz",
+        "//rs/ethereum/ledger-suite-orchestrator:ledger_suite_orchestrator_canister.wasm.gz",
+        "//rs/ledger_suite/icrc1/archive:archive_canister_u256.wasm.gz",
+        "//rs/ledger_suite/icrc1/index-ng:index_ng_canister_u256.wasm.gz",
+        "//rs/ledger_suite/icrc1/ledger:ledger_canister_u256.wasm.gz",
         "//rs/pocket_ic_server:pocket-ic-server",
         "@evm_rpc.wasm.gz//file",
     ],
@@ -309,6 +313,10 @@ rust_test(
         "CARGO_MANIFEST_DIR": "rs/ethereum/cketh/minter",
         "CKETH_MINTER_WASM_PATH": "$(rootpath :cketh_minter_debug.wasm.gz)",
         "EVM_RPC_CANISTER_WASM_PATH": "$(rootpath @evm_rpc.wasm.gz//file)",
+        "INDEX_CANISTER_WASM_PATH": "$(rootpath //rs/ledger_suite/icrc1/index-ng:index_ng_canister_u256.wasm.gz)",
+        "LEDGER_ARCHIVE_NODE_CANISTER_WASM_PATH": "$(rootpath //rs/ledger_suite/icrc1/archive:archive_canister_u256.wasm.gz)",
+        "LEDGER_CANISTER_WASM_PATH": "$(rootpath //rs/ledger_suite/icrc1/ledger:ledger_canister_u256.wasm.gz)",
+        "LEDGER_SUITE_ORCHESTRATOR_WASM_PATH": "$(rootpath //rs/ethereum/ledger-suite-orchestrator:ledger_suite_orchestrator_canister.wasm.gz)",
         "POCKET_IC_BIN": "$(rootpath //rs/pocket_ic_server:pocket-ic-server)",
     },
     deps = [

rs/ethereum/cketh/minter/tests/ckerc20.rs

@@ -150,12 +150,10 @@ mod deposit_erc20 {
     use ic_cketh_minter::state::automatic_deposits::DEPOSIT_ADDRESS_SCAN_WINDOW;
     use ic_cketh_test_utils::DEFAULT_USER_SUBACCOUNT;
     use ic_cketh_test_utils::ckerc20::CkErc20Setup;
-    use ic_cketh_test_utils::new_pocket_ic;
-    use std::sync::Arc;
 
     #[test]
     fn should_trap_when_ckerc20_feature_not_active() {
-        let ckerc20 = CkErc20Setup::new_without_ckerc20_active(Arc::new(new_pocket_ic()));
+        let ckerc20 = CkErc20Setup::new_without_ckerc20_active();
         let caller = ckerc20.caller();
         ckerc20
             .call_minter_deposit_erc20(caller, None)
@@ -407,21 +405,20 @@ mod withdraw_erc20 {
         CKETH_TRANSFER_FEE, DEFAULT_BLOCK_HASH, DEFAULT_BLOCK_NUMBER,
         DEFAULT_CKERC20_WITHDRAWAL_TRANSACTION, DEFAULT_CKERC20_WITHDRAWAL_TRANSACTION_FEE,
         DEFAULT_CKERC20_WITHDRAWAL_TRANSACTION_HASH, DEFAULT_PRINCIPAL_ID, EXPECTED_BALANCE,
-        JsonRpcProvider, new_pocket_ic,
+        JsonRpcProvider,
     };
     use ic_ledger_suite_orchestrator_test_utils::CKERC20_TRANSFER_FEE;
     use icrc_ledger_types::icrc3::transactions::Burn;
     use num_bigint::BigUint;
     use num_traits::ToPrimitive;
     use serde_bytes::ByteBuf;
     use std::convert::identity;
-    use std::sync::Arc;
 
     const NOT_SUPPORTED_CKERC20_LEDGER_ID: Principal = Principal::management_canister();
 
     #[test]
     fn should_trap_when_ckerc20_feature_not_active() {
-        CkErc20Setup::new_without_ckerc20_active(Arc::new(new_pocket_ic()))
+        CkErc20Setup::new_without_ckerc20_active()
             .call_minter_withdraw_erc20(
                 Principal::anonymous(),
                 0_u8,

rs/ethereum/cketh/minter/tests/deposit_from_cex.rs

@@ -26,7 +26,7 @@ use ic_cketh_minter::balance_scan::batcher::{
 };
 use ic_cketh_minter::numeric::Erc20Value;
 use ic_cketh_test_utils::anvil::{Anvil, DEV_ACCOUNT, address_from_hex, deploy_mock_erc20};
-use ic_cketh_test_utils::live_scan::{CkErc20LiveScanSetup, Holding, SupportedToken};
+use ic_cketh_test_utils::live_scan::{Holding, LiveBalanceScanSetup, SupportedToken};
 use ic_ethereum_types::Address;
 use std::time::Duration;
 
@@ -194,7 +194,7 @@ fn should_flag_only_deposits_at_or_above_the_per_token_minimum() {
     const USDC_ABOVE_MINIMUM: u128 = 15_000_000;
     const USDT_BELOW_MINIMUM: u128 = 1_000_000;
 
-    let setup = CkErc20LiveScanSetup::new_live();
+    let setup = LiveBalanceScanSetup::new_live();
     let deposits = [
         (
             setup.depositor(1),

rs/ethereum/cketh/test_utils/src/ckerc20.rs

@@ -13,7 +13,7 @@ use crate::{
     DEPOSIT_WITH_SUBACCOUNT_HELPER_CONTRACT_ADDRESS, ERC20_HELPER_CONTRACT_ADDRESS,
     ETH_HELPER_CONTRACT_ADDRESS, LAST_SCRAPED_BLOCK_NUMBER_AT_INSTALL, LedgerBalance, MAX_TICKS,
     RECEIVED_ERC20_EVENT_TOPIC, RECEIVED_ETH_OR_ERC20_WITH_SUBACCOUNT_EVENT_TOPIC, assert_reply,
-    format_ethereum_address_to_eip_55, new_pocket_ic,
+    format_ethereum_address_to_eip_55,
 };
 use assert_matches::assert_matches;
 use candid::{Decode, Encode, Nat, Principal};
@@ -62,7 +62,7 @@ pub struct CkErc20Setup {
 
 impl Default for CkErc20Setup {
     fn default() -> Self {
-        Self::new(Arc::new(new_pocket_ic()))
+        Self::new()
     }
 }
 
@@ -73,8 +73,14 @@ impl AsRef<CkEthSetup> for CkErc20Setup {
 }
 
 impl CkErc20Setup {
-    pub fn new(env: Arc<PocketIc>) -> Self {
-        let mut ckerc20 = Self::new_without_ckerc20_active(env);
+    pub fn new() -> Self {
+        Self::with_cketh(CkEthSetup::default())
+    }
+
+    /// Activates the ckERC20 feature on an existing ckETH fixture: the balance-scan harness in
+    /// [`crate::live_scan`] supplies one backed by a live anvil node rather than the mocked default.
+    pub(crate) fn with_cketh(cketh: CkEthSetup) -> Self {
+        let mut ckerc20 = Self::without_ckerc20_active(cketh);
         ckerc20.cketh = ckerc20
             .cketh
             .upgrade_minter_to_add_orchestrator_id(
@@ -84,8 +90,14 @@ impl CkErc20Setup {
         ckerc20
     }
 
-    pub fn new_without_ckerc20_active(env: Arc<PocketIc>) -> Self {
-        let cketh = CkEthSetup::new(env.clone());
+    pub fn new_without_ckerc20_active() -> Self {
+        Self::without_ckerc20_active(CkEthSetup::default())
+    }
+
+    /// The ckETH fixture builds the PocketIC instance (its Ethereum backend decides how), and the
+    /// orchestrator is then created on that same instance so both share one replica.
+    fn without_ckerc20_active(cketh: CkEthSetup) -> Self {
+        let env = cketh.env.clone();
         let orchestrator = LedgerSuiteOrchestrator::new(
             env.clone(),
             LedgerSuiteOrchestratorInitArg {