test: using live rpc endpoint

Author: krsnapaudel

backend/crates/bridge/src/status.rs

@@ -104,7 +104,7 @@ impl RpcClientManager {
     ///
     /// - **Attempt 0**: Immediate (no delay)
     /// - **Attempt 1**: After ~2s delay
-    /// - **Attempt 2**: After ~3s delay  
+    /// - **Attempt 2**: After ~3s delay
     /// - **Attempt 3**: After ~5s delay
     /// - Total: ~10 seconds per operator
     ///

backend/crates/bridge/src/withdrawal_indexer/task.rs

@@ -304,6 +304,65 @@ poll_interval_s = 0
         assert_eq!(state.last_scanned_block, 10);
     }
 
+    /// Smoke test against a live alpen-reth endpoint.
+    ///
+    /// Run with:
+    ///   `ETH_RPC_URL=https://rpc.testnet.alpenlabs.io cargo test -p status-bridge \
+    ///        live_smoke -- --ignored --nocapture`
+    ///
+    /// Verifies that the deployed event ABI still matches our pinned
+    /// `alpen-reth-primitives` and that our decoder accepts every log returned
+    /// by the precompile filter.
+    #[tokio::test]
+    #[ignore = "hits a live RPC; opt in with ETH_RPC_URL set + --ignored"]
+    async fn live_smoke() {
+        let url = match std::env::var("ETH_RPC_URL") {
+            Ok(u) if !u.is_empty() => u,
+            _ => {
+                eprintln!("ETH_RPC_URL unset; skipping");
+                return;
+            }
+        };
+        let rpc = JsonRpcEthClient::new(&url).expect("build rpc client");
+
+        let head = rpc.block_number().await.expect("block_number");
+        assert!(head > 0, "live chain head should be > 0");
+        eprintln!("live head = {head}");
+
+        // Public testnet caps eth_getLogs at 100k blocks per request.
+        let from = head.saturating_sub(100_000);
+        let logs = rpc
+            .get_logs(
+                from,
+                head,
+                BRIDGEOUT_PRECOMPILE_ADDRESS,
+                WithdrawalIntentEvent::SIGNATURE_HASH,
+            )
+            .await
+            .expect("get_logs");
+        eprintln!("found {} bridgeout logs in [{from}, {head}]", logs.len());
+
+        let mut total_sub_units = 0usize;
+        for log in &logs {
+            let rows = decoder::decode(log).unwrap_or_else(|e| {
+                panic!(
+                    "decode failed for tx {:?} log_index {}: {e}",
+                    log.transaction_hash, log.log_index
+                )
+            });
+            assert!(
+                !rows.is_empty(),
+                "every accepted log expands into ≥ 1 sub-unit"
+            );
+            total_sub_units += rows.len();
+        }
+        eprintln!(
+            "decoded {} logs into {} sub-units total",
+            logs.len(),
+            total_sub_units
+        );
+    }
+
     #[tokio::test]
     async fn restart_replay_is_idempotent() {
         let db = MockWithdrawalIndexerDb::default();