fix(coprocessor): verify input via eth_getLogs

.github/workflows/coprocessor-dependency-analysis.yml

@@ -55,7 +55,7 @@ jobs:
       - name: Install cargo tools
         run: |
           cargo binstall --no-confirm --force \
-            cargo-audit@0.21.0 \
+            cargo-audit@0.22.0 \
             cargo-deny@0.16.2
 
       - name: Check that Cargo.lock is the source of truth

charts/coprocessor/Chart.yaml

@@ -1,6 +1,6 @@
 name: coprocessor
 description: A helm chart to distribute and deploy Zama fhevm Co-Processor services
-version: 0.7.10
+version: 0.7.12
 apiVersion: v2
 keywords:
   - fhevm

charts/coprocessor/values.yaml

@@ -360,13 +360,14 @@ gwListener:
     - --provider-max-retries=4294967295
     - --provider-retry-interval=4s
     - --log-level=INFO
-    - --get-logs-poll-interval=1s
+    - --get-logs-poll-interval=500ms
     - --get-logs-block-batch-size=100
     - --service-name=gw-listener
-    ### Catchup parameters (optional)
-    # --catchup-kms-generation-from-block BLOCK_NUMBER
+    - --log-last-processed-every-number-of-updates=50
+    ### Replay parameters (optional)
+    # --replay-from-block BLOCK_NUMBER
     # To go back in time from latest block
-    # --catchup-kms-generation-from-block -NB_BLOCK
+    # --replay-from-block -NB_BLOCK
 
   # Service ports configuration
   ports:

coprocessor/fhevm-engine/gw-listener/src/bin/gw_listener.rs

@@ -66,18 +66,21 @@ struct Conf {
     #[arg(long)]
     host_chain_id: Option<u64>,
 
-    #[arg(long, default_value = "1s", value_parser = parse_duration)]
+    #[arg(long, default_value = "500ms", value_parser = parse_duration)]
     get_logs_poll_interval: Duration,
 
     #[arg(long, default_value_t = 100)]
     get_logs_block_batch_size: u64,
 
+    #[arg(long, default_value_t = 50)]
+    log_last_processed_every_number_of_updates: u64,
+
     /// gw-listener service name in OTLP traces
     #[arg(long, default_value = "gw-listener")]
     pub service_name: String,
 
-    #[arg(long, default_value = None, help = "Can be negative from last processed block", allow_hyphen_values = true)]
-    pub catchup_kms_generation_from_block: Option<i64>,
+    #[arg(long, default_value = None, help = "Can be negative from last processed block", allow_hyphen_values = true, alias = "catchup-kms-generation-from-block")]
+    pub replay_from_block: Option<i64>,
 }
 
 fn install_signal_handlers(cancel_token: CancellationToken) -> anyhow::Result<()> {
@@ -158,7 +161,8 @@ async fn main() -> anyhow::Result<()> {
         health_check_timeout: conf.health_check_timeout,
         get_logs_poll_interval: conf.get_logs_poll_interval,
         get_logs_block_batch_size: conf.get_logs_block_batch_size,
-        catchup_kms_generation_from_block: conf.catchup_kms_generation_from_block,
+        replay_from_block: conf.replay_from_block,
+        log_last_processed_every_number_of_updates: conf.log_last_processed_every_number_of_updates,
     };
 
     let gw_listener = GatewayListener::new(