fix(coprocessor): align host listener and poller dependence params

Author: rudy-6-4

charts/coprocessor/values.yaml

@@ -157,8 +157,8 @@ hostListener:
 
     ### Dependence chains parameters
     # - --dependence-cache-size=10000
-    # - --dependence-by-connexity   # Whether to build connected components or linear chains
-    # - --dependence-cross-block    # Do chains cross L1 block boundaries (default no)
+    # - --dependence-by-connexity   # Whether to build connected components or linear chains (default no)
+    # - --dependence-cross-block    # Do chains cross L1 block boundaries (default yes)
 
     ### Catchup parameters (optional)
     # - --catchup-margin
@@ -270,6 +270,11 @@ hostListenerPoller:
     ### Prometheus metrics
     - --metrics-addr=0.0.0.0:9100  # Address for Prometheus metrics HTTP server
 
+    ### Dependence chains parameters
+    # - --dependence-cache-size=10000
+    # - --dependence-by-connexity   # Whether to build connected components or linear chains (default no)
+    # - --dependence-cross-block    # Do chains cross L1 block boundaries (default yes)
+
   # Service ports configuration
   ports:
     metrics: 9100

coprocessor/fhevm-engine/host-listener/src/bin/poller.rs

@@ -9,6 +9,10 @@ use tracing::Level;
 
 use fhevm_engine_common::metrics_server;
 use fhevm_engine_common::utils::DatabaseURL;
+use host_listener::cmd::{
+    DEFAULT_DEPENDENCE_BY_CONNEXITY, DEFAULT_DEPENDENCE_CACHE_SIZE,
+    DEFAULT_DEPENDENCE_CROSS_BLOCK,
+};
 use host_listener::poller::{run_poller, PollerConfig};
 
 #[derive(Parser, Debug, Clone)]
@@ -93,6 +97,27 @@ struct Args {
 
     #[arg(long, default_value = "host-listener-poller")]
     service_name: String,
+
+    #[arg(
+        long,
+        default_value_t = DEFAULT_DEPENDENCE_CACHE_SIZE,
+        help = "Pre-computation dependence chain cache size"
+    )]
+    pub dependence_cache_size: u16,
+
+    #[arg(
+        long,
+        default_value_t = DEFAULT_DEPENDENCE_BY_CONNEXITY,
+        help = "Dependence chain are connected components"
+    )]
+    pub dependence_by_connexity: bool,
+
+    #[arg(
+        long,
+        default_value_t = DEFAULT_DEPENDENCE_CROSS_BLOCK,
+        help = "Dependence chain are across blocks"
+    )]
+    pub dependence_cross_block: bool,
 }
 
 #[tokio::main]
@@ -131,6 +156,9 @@ async fn main() -> anyhow::Result<()> {
         max_http_retries: args.max_http_retries,
         rpc_compute_units_per_second: args.rpc_compute_units_per_second,
         health_port: args.health_port,
+        dependence_cache_size: args.dependence_cache_size,
+        dependence_by_connexity: args.dependence_by_connexity,
+        dependence_cross_block: args.dependence_cross_block,
     };
 
     run_poller(config).await

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

@@ -36,6 +36,9 @@ const REORG_RETRY_GET_BLOCK: u64 = 10; // retry 10 times to get logs for a block
 const RETRY_GET_BLOCK_DELAY_IN_MS: u64 = 100;
 
 const DEFAULT_BLOCK_TIME: u64 = 12;
+pub const DEFAULT_DEPENDENCE_CACHE_SIZE: u16 = 10_000;
+pub const DEFAULT_DEPENDENCE_BY_CONNEXITY: bool = false;
+pub const DEFAULT_DEPENDENCE_CROSS_BLOCK: bool = false;
 
 #[derive(Parser, Debug, Clone)]
 #[command(version, about, long_about = None)]
@@ -101,21 +104,21 @@ pub struct Args {
 
     #[arg(
         long,
-        default_value = "10000",
+        default_value_t = DEFAULT_DEPENDENCE_CACHE_SIZE,
         help = "Pre-computation dependence chain cache size"
     )]
     pub dependence_cache_size: u16,
 
     #[arg(
         long,
-        default_value_t = false,
+        default_value_t = DEFAULT_DEPENDENCE_BY_CONNEXITY,
         help = "Dependence chain are connected components"
     )]
     pub dependence_by_connexity: bool,
 
     #[arg(
         long,
-        default_value_t = false,
+        default_value_t = DEFAULT_DEPENDENCE_CROSS_BLOCK,
         help = "Dependence chain are across blocks"
     )]
     pub dependence_cross_block: bool,

coprocessor/fhevm-engine/host-listener/src/poller/mod.rs

@@ -28,7 +28,6 @@ use crate::poller::metrics::{
     inc_blocks_processed, inc_db_errors, inc_rpc_errors,
 };
 
-const DEFAULT_DEPENDENCE_CACHE_SIZE: u16 = 128;
 const MAX_DB_RETRIES: u64 = 10;
 /// Exit after this many consecutive RPC failures (after retries exhausted).
 /// Orchestrator will restart with fresh state.
@@ -84,6 +83,10 @@ pub struct PollerConfig {
     /// Higher values = less throttling.
     pub rpc_compute_units_per_second: u64,
     pub health_port: u16,
+    // Dependence chain settings
+    pub dependence_cache_size: u16,
+    pub dependence_by_connexity: bool,
+    pub dependence_cross_block: bool,
 }
 
 pub async fn run_poller(config: PollerConfig) -> Result<()> {
@@ -133,7 +136,7 @@ pub async fn run_poller(config: PollerConfig) -> Result<()> {
     let mut db = Database::new(
         &config.database_url,
         &config.coprocessor_api_key,
-        DEFAULT_DEPENDENCE_CACHE_SIZE,
+        config.dependence_cache_size,
     )
     .await?;
 
@@ -293,6 +296,8 @@ pub async fn run_poller(config: PollerConfig) -> Result<()> {
                 acl_address,
                 tfhe_address,
                 config.retry_interval,
+                config.dependence_by_connexity,
+                config.dependence_cross_block,
             )
             .await
             {
@@ -356,20 +361,29 @@ pub async fn run_poller(config: PollerConfig) -> Result<()> {
     }
 }
 
+#[allow(clippy::too_many_arguments)]
 async fn ingest_with_retry(
     chain_id: u64,
     db: &mut Database,
     block_logs: &BlockLogs<Log>,
     acl_address: Address,
     tfhe_address: Address,
     retry_interval: Duration,
+    dependency_by_connexity: bool,
+    dependency_cross_block: bool,
 ) -> Result<u64, (sqlx::Error, u64)> {
     let mut errors = 0;
     let acl = Some(acl_address);
     let tfhe = Some(tfhe_address);
     loop {
         match ingest_block_logs(
-            chain_id, db, block_logs, &acl, &tfhe, false, false,
+            chain_id,
+            db,
+            block_logs,
+            &acl,
+            &tfhe,
+            dependency_by_connexity,
+            dependency_cross_block,
         )
         .await
         {

coprocessor/fhevm-engine/host-listener/tests/poller_integration_tests.rs

@@ -197,6 +197,9 @@ async fn poller_catches_up_to_safe_tip(
         max_http_retries: 0,
         rpc_compute_units_per_second: 1000,
         health_port: 18081,
+        dependence_cache_size: 10_000,
+        dependence_by_connexity: false,
+        dependence_cross_block: false,
     };
 
     let poller_handle = tokio::spawn(run_poller(config));