fix(ethexe): multiple validators test fix (#4256)

ethexe/cli/src/service.rs

@@ -666,6 +666,10 @@ impl Service {
             .map(BlockCommitmentValidationRequest::from)
             .collect();
 
+        if block_requests.is_empty() && code_requests.is_empty() {
+            return Ok(());
+        }
+
         if let Some(network_sender) = maybe_network_sender {
             log::debug!("Request validation of aggregated commitments...");
 

ethexe/cli/src/tests.rs

@@ -485,7 +485,8 @@ async fn multiple_validators() {
     let mut validator2 = env.new_node(
         NodeConfig::default()
             .validator(env.validators[2])
-            .network(None, sequencer.multiaddr.clone()),
+            .network(None, sequencer.multiaddr.clone())
+            .db(validator2.db),
     );
     validator2.start_service().await;
 

ethexe/network/src/lib.rs

@@ -135,6 +135,9 @@ impl NetworkSender {
         (Self { tx }, rx)
     }
 
+    // TODO: consider to append salt here to be sure that message is unique.
+    // This is important for the cases of malfunctions in ethexe, when the same message
+    // needs to be sent again #4255
     pub fn publish_message(&self, data: impl Into<Vec<u8>>) {
         let _res = self
             .tx

ethexe/sequencer/src/lib.rs

@@ -195,6 +195,8 @@ impl Sequencer {
         &mut self,
         aggregated: AggregatedCommitments<CodeCommitment>,
     ) -> Result<()> {
+        log::debug!("Received code commitments: {aggregated:?}");
+
         Self::receive_commitments(
             aggregated,
             &self.validators,
@@ -207,6 +209,8 @@ impl Sequencer {
         &mut self,
         aggregated: AggregatedCommitments<BlockCommitment>,
     ) -> Result<()> {
+        log::debug!("Received block commitments: {aggregated:?}");
+
         Self::receive_commitments(
             aggregated,
             &self.validators,

ethexe/validator/src/lib.rs

@@ -98,6 +98,7 @@ impl Validator {
     ) -> Result<(Digest, Signature)> {
         let mut commitment_digests = Vec::new();
         for request in requests {
+            log::debug!("Receive code commitment for validation: {:?}", request);
             commitment_digests.push(request.to_digest());
             Self::validate_code_commitment(db, request)?;
         }
@@ -119,6 +120,7 @@ impl Validator {
     ) -> Result<(Digest, Signature)> {
         let mut commitment_digests = Vec::new();
         for request in requests.into_iter() {
+            log::debug!("Receive block commitment for validation: {:?}", request);
             commitment_digests.push(request.to_digest());
             Self::validate_block_commitment(db, request)?;
         }