fix: Add temp logs and flag

Took 1 hour 20 minutes

Author: dianacarvalho1

src/evm/decoder.rs

@@ -225,6 +225,16 @@ where
         let mut contracts_map = HashMap::new();
         let mut msg_failed_components = HashSet::new();
 
+        {
+            let state_guard = self.state.read().await;
+            info!(
+                " ===== [{:?}] Processing update : n states: {:?}, n components {:?}",
+                self.registry.keys(),
+                state_guard.states.len(),
+                state_guard.components.len()
+            );
+        }
+
         let header = msg
             .state_msgs
             .values()
@@ -306,6 +316,7 @@ where
 
                 // Remove components from state and add to removed_pairs
                 for (id, component) in removed_components {
+                    println!("Removing component {id}");
                     state_guard.components.remove(&id);
                     state_guard.states.remove(&id);
                     removed_pairs.insert(id, component);
@@ -845,6 +856,13 @@ where
                 .extend(values);
         }
 
+        info!(
+            " ===== [{:?}] Processed update : n states: {:?}, n components {:?}",
+            self.registry.keys(),
+            state_guard.states.len(),
+            state_guard.components.len()
+        );
+
         // Send the tick with all updated states
         Ok(Update::new(block_number_or_timestamp, updated_states, new_pairs)
             .set_removed_pairs(removed_pairs)

tycho-integration-test/src/main.rs

@@ -100,6 +100,10 @@ struct Cli {
     /// The RFQ stream will skip messages for this duration (in seconds) after processing a message
     #[arg(long, default_value_t = 600)]
     skip_messages_duration: u64,
+
+    /// Disable processing updates (process_update function)
+    #[arg(long, default_value_t = false)]
+    disable_process_update: bool,
 }
 
 impl Debug for Cli {
@@ -217,8 +221,13 @@ async fn run(cli: Cli) -> miette::Result<()> {
             .into_diagnostic()
             .wrap_err("Failed to acquire permit")?;
         tokio::spawn(async move {
-            if let Err(e) = process_update(cli, chain, rpc_tools, protocol_pairs, &update).await {
-                warn!("{}", format_error_chain(&e));
+            if !cli.disable_process_update {
+                if let Err(e) = process_update(cli, chain, rpc_tools, protocol_pairs, &update).await
+                {
+                    warn!("{}", format_error_chain(&e));
+                }
+            } else {
+                info!("Skipping update {:?}", update.update.block_number_or_timestamp)
             }
             drop(permit);
         });