fix(coprocessor): fhevm-listner, disable alloy reconnection retry

alloy skips some events while reconnecting

Author: rudy-6-4

coprocessor/fhevm-engine/Cargo.lock

@@ -26,8 +26,6 @@ rustls = { workspace = true }
 serde = { workspace = true }
 sqlx = { workspace = true }
 tokio = { workspace = true }
-humantime = { workspace = true }
-
 
 # local dependencies
 fhevm-engine-common = { path = "../fhevm-engine-common" }

coprocessor/fhevm-engine/fhevm-listener/Cargo.toml

@@ -16,7 +16,6 @@ use alloy::rpc::types::{BlockNumberOrTag, Filter, Log};
 use alloy_sol_types::SolEventInterface;
 
 use clap::Parser;
-use humantime::parse_duration;
 
 use rustls;
 
@@ -76,12 +75,6 @@ pub struct Args {
         help = "Initial block time, refined on each block"
     )]
     pub initial_block_time: u64,
-
-    #[arg(long, default_value = "1000000")]
-    pub provider_max_retries: u32,
-
-    #[arg(long, default_value = "4s", value_parser = parse_duration)]
-    pub provider_retry_interval: Duration,
 }
 
 type RProvider = FillProvider<
@@ -98,9 +91,6 @@ type RProvider = FillProvider<
 // TODO: to merge with Levent works
 struct InfiniteLogIter {
     url: String,
-    max_retries: u32,
-    retry_interval: Duration,
-
     block_time: u64, /* A default value that is refined with real-time
                       * events data */
     no_block_immediate_recheck: bool,
@@ -149,8 +139,6 @@ impl InfiniteLogIter {
             current_event: None,
             last_block_event_count: 0,
             last_block_recheck_planned: 0,
-            max_retries: args.provider_max_retries,
-            retry_interval: args.provider_retry_interval,
         }
     }
 
@@ -249,8 +237,7 @@ impl InfiniteLogIter {
         let mut retry = 20;
         loop {
             let ws = WsConnect::new(&self.url)
-                .with_max_retries(self.max_retries)
-                .with_retry_interval(self.retry_interval);
+                .with_max_retries(0); // disabled, alloy skips events
 
             match ProviderBuilder::new().connect_ws(ws).await {
                 Ok(provider) => {

coprocessor/fhevm-engine/fhevm-listener/src/cmd/mod.rs

@@ -168,8 +168,6 @@ async fn test_listener_restart() -> Result<(), anyhow::Error> {
         start_at_block: None,
         end_at_block: None,
         catchup_margin: 5,
-        provider_max_retries: 5,
-        provider_retry_interval: Duration::from_secs(1),
     };
 
     // Start listener in background task