Removed unneeded call timeout for driver RPC. (#894)

Driver RPC call retry timeout config parameter.

Author: mskrzypkows

Cargo.lock

@@ -13,7 +13,7 @@ resolver = "2"
 default-members = ["node"]
 
 [workspace.package]
-version = "1.34.0"
+version = "1.34.1"
 edition = "2024"
 repository = "https://github.com/NethermindEth/Catalyst"
 license = "MIT"

Cargo.toml

@@ -34,6 +34,7 @@ pub struct Config {
     pub rpc_l2_execution_layer_timeout: Duration,
     pub rpc_driver_preconf_timeout: Duration,
     pub rpc_driver_status_timeout: Duration,
+    pub rpc_driver_retry_timeout: Duration,
     // Taiko contracts
     pub taiko_anchor_address: Address,
     pub taiko_bridge_address: Address,
@@ -218,6 +219,12 @@ impl Config {
             .map_err(|e| anyhow::anyhow!("RPC_DRIVER_STATUS_TIMEOUT_MS must be a number: {}", e))?;
         let rpc_driver_status_timeout = Duration::from_millis(rpc_driver_status_timeout);
 
+        let rpc_driver_retry_timeout = std::env::var("RPC_DRIVER_RETRY_TIMEOUT_MS")
+            .unwrap_or("1000".to_string())
+            .parse::<u64>()
+            .map_err(|e| anyhow::anyhow!("RPC_DRIVER_RETRY_TIMEOUT_MS must be a number: {}", e))?;
+        let rpc_driver_retry_timeout = Duration::from_millis(rpc_driver_retry_timeout);
+
         let rpc_l2_execution_layer_timeout = std::env::var("RPC_L2_EXECUTION_LAYER_TIMEOUT_MS")
             .unwrap_or("1000".to_string())
             .parse::<u64>()
@@ -467,6 +474,7 @@ impl Config {
             rpc_l2_execution_layer_timeout,
             rpc_driver_preconf_timeout,
             rpc_driver_status_timeout,
+            rpc_driver_retry_timeout,
             taiko_anchor_address,
             taiko_bridge_address,
             max_bytes_size_of_batch,
@@ -520,6 +528,7 @@ jwt secret file path: {}
 rpc L2 EL timeout: {}ms
 rpc driver preconf timeout: {}ms
 rpc driver status timeout: {}ms
+rpc driver retry timeout: {}ms
 taiko anchor address: {}
 taiko bridge address: {}
 max bytes per tx list from taiko driver: {}
@@ -580,6 +589,7 @@ watchdog max counter: {}
             config.rpc_l2_execution_layer_timeout.as_millis(),
             config.rpc_driver_preconf_timeout.as_millis(),
             config.rpc_driver_status_timeout.as_millis(),
+            config.rpc_driver_retry_timeout.as_millis(),
             config.taiko_anchor_address,
             config.taiko_bridge_address,
             config.max_bytes_per_tx_list,

common/src/config/mod.rs

@@ -4,6 +4,6 @@ pub struct TaikoDriverConfig {
     pub driver_url: String,
     pub rpc_driver_preconf_timeout: Duration,
     pub rpc_driver_status_timeout: Duration,
+    pub rpc_driver_retry_timeout: Duration,
     pub jwt_secret_bytes: [u8; 32],
-    pub call_timeout: Duration,
 }

common/src/l2/taiko_driver/config.rs

@@ -17,7 +17,7 @@ pub struct TaikoDriver {
     preconf_rpc: HttpRPCClient,
     status_rpc: HttpRPCClient,
     metrics: Arc<Metrics>,
-    call_timeout: Duration,
+    retry_timeout: Duration,
 }
 
 impl TaikoDriver {
@@ -40,7 +40,7 @@ impl TaikoDriver {
                 anyhow::anyhow!("Failed to create HttpRPCClient for driver status: {}", e)
             })?,
             metrics,
-            call_timeout: config.call_timeout,
+            retry_timeout: config.rpc_driver_retry_timeout,
         })
     }
 
@@ -89,7 +89,7 @@ impl TaikoDriver {
         let start_time = std::time::Instant::now();
 
         match client
-            .retry_request_with_timeout(method, endpoint, payload, self.call_timeout)
+            .retry_request_with_timeout(method, endpoint, payload, self.retry_timeout)
             .await
         {
             Ok(response) => {

common/src/l2/taiko_driver/mod.rs

@@ -14,6 +14,7 @@ pub struct TaikoConfig {
     pub taiko_bridge_address: Address,
     pub rpc_driver_preconf_timeout: Duration,
     pub rpc_driver_status_timeout: Duration,
+    pub rpc_driver_retry_timeout: Duration,
     pub preconf_heartbeat_ms: u64,
     pub signer: Arc<Signer>,
 }
@@ -38,6 +39,7 @@ impl TaikoConfig {
             taiko_bridge_address: config.taiko_bridge_address,
             rpc_driver_preconf_timeout: config.rpc_driver_preconf_timeout,
             rpc_driver_status_timeout: config.rpc_driver_status_timeout,
+            rpc_driver_retry_timeout: config.rpc_driver_retry_timeout,
             preconf_heartbeat_ms: config.preconf_heartbeat_ms,
             signer,
         })

pacaya/src/l2/config.rs

@@ -25,7 +25,7 @@ use common::{
         l2_tx_lists::{self, PreBuiltTxList},
     },
 };
-use std::{sync::Arc, time::Duration};
+use std::sync::Arc;
 use tracing::{debug, trace};
 
 pub struct Taiko {
@@ -49,8 +49,8 @@ impl Taiko {
             driver_url: taiko_config.driver_url.clone(),
             rpc_driver_preconf_timeout: taiko_config.rpc_driver_preconf_timeout,
             rpc_driver_status_timeout: taiko_config.rpc_driver_status_timeout,
+            rpc_driver_retry_timeout: taiko_config.rpc_driver_retry_timeout,
             jwt_secret_bytes: taiko_config.jwt_secret_bytes,
-            call_timeout: Duration::from_millis(taiko_config.preconf_heartbeat_ms / 2),
         };
         Ok(Self {
             protocol_config,

pacaya/src/l2/taiko.rs

@@ -18,7 +18,7 @@ use common::{
     shared::{l2_slot_info_v2::L2SlotInfoV2, l2_tx_lists::PreBuiltTxList},
 };
 use pacaya::l2::config::TaikoConfig;
-use std::{sync::Arc, time::Duration};
+use std::sync::Arc;
 use taiko_alethia_reth::validation::ANCHOR_V3_V4_GAS_LIMIT;
 use taiko_bindings::anchor::Anchor;
 use taiko_bindings::inbox::IInbox::Config;
@@ -45,8 +45,8 @@ impl Taiko {
             driver_url: taiko_config.driver_url.clone(),
             rpc_driver_preconf_timeout: taiko_config.rpc_driver_preconf_timeout,
             rpc_driver_status_timeout: taiko_config.rpc_driver_status_timeout,
+            rpc_driver_retry_timeout: taiko_config.rpc_driver_retry_timeout,
             jwt_secret_bytes: taiko_config.jwt_secret_bytes,
-            call_timeout: Duration::from_millis(taiko_config.preconf_heartbeat_ms / 2),
         };
 
         let l2_execution_layer = Arc::new(