feat: add ReplacementMessageReceived msg from batcher

Author: uri-99

batcher/aligned-batcher/src/connection.rs

@@ -6,7 +6,7 @@ use aligned_sdk::{
 };
 use futures_util::{stream::SplitSink, SinkExt};
 use lambdaworks_crypto::merkle_tree::merkle::MerkleTree;
-use log::{error, info};
+use log::{error, debug};
 use serde::Serialize;
 use tokio::{net::TcpStream, sync::RwLock};
 use tokio_tungstenite::{
@@ -45,7 +45,7 @@ pub(crate) async fn send_batch_inclusion_data_responses(
             Ok(_) => (),
         }
 
-        info!("Response sent");
+        debug!("Response sent");
     }
 
     Ok(())

batcher/aligned-batcher/src/lib.rs

@@ -669,6 +669,8 @@ impl Batcher {
                 if let Err(e) = old_sink.close().await {
                     // we dont want to exit here, just log the error
                     warn!("Error closing sink: {e:?}");
+                } else {
+                    info!("Old websocket sink closed");
                 }
             } else {
                 warn!(
@@ -693,6 +695,10 @@ impl Batcher {
             "Replacement entry is valid, incrementing fee for sender: {:?}, nonce: {:?}, max_fee: {:?}",
             replacement_entry.sender, replacement_entry.nonced_verification_data.nonce, replacement_max_fee
         );
+        send_message(
+            ws_conn_sink.clone(),
+            ResponseMessage::ReplacementMessageReceived,
+        ).await;
 
         // remove the old entry and insert the new one
         // note that the entries are considered equal for the priority queue

batcher/aligned-sdk/src/core/types.rs

@@ -366,7 +366,8 @@ pub enum ResponseMessage {
     InvalidReplacementMessage,
     AddToBatchError,
     EthRpcError,
-    InvalidPaymentServiceAddress(Address, Address)
+    InvalidPaymentServiceAddress(Address, Address),
+    ReplacementMessageReceived,
 }
 
 #[derive(Debug, Clone, Copy)]