chore: improve logging

offchain/advance-runner/src/runner.rs

@@ -125,13 +125,13 @@ impl Runner {
                     .produce_outputs(proofs)
                     .await
                     .context(ProduceOutputsSnafu)?;
-                tracing::trace!("produced outputs in broker");
+                tracing::trace!("produced outputs in broker stream");
 
                 self.broker
                     .produce_rollups_claim(rollups_claim)
                     .await
                     .context(ProduceClaimSnafu)?;
-                tracing::info!("produced epoch claim");
+                tracing::info!("produced epoch claim in broker stream");
             }
             Err(source) => {
                 if let ServerManagerError::EmptyEpochError { .. } = source {

offchain/authority-claimer/src/checker.rs

@@ -127,14 +127,16 @@ impl DuplicateChecker for DefaultDuplicateChecker {
             .flatten() // Back to only one Option
             .map(|claim| claim.last_index + 1) // Maps to a number
             .unwrap_or(0); // If None, unwrap to 0
+        tracing::debug!("checking duplicate claim: expected_first_index={}, rollups_claim={:?}",
+                        expected_first_index, rollups_claim);
         if rollups_claim.first_index == expected_first_index {
-            // This claim is the one the blockchain expects, so it is not considered duplicate.
+            // This claim is the one the blockchain expects, so it is not considered a duplicate.
             Ok(false)
         } else if rollups_claim.last_index < expected_first_index {
             // This claim is already on the blockchain.
             Ok(true)
         } else {
-            // This claim is not on blockchain, but it isn't the one blockchain expects.
+            // This claim is not on the blockchain, but it isn't the one the blockchain expects.
             // If this happens, there is a bug on the dispatcher.
             Err(DuplicateCheckerError::ClaimMismatch {
                 expected_first_index,

offchain/dispatcher/src/drivers/context.rs

@@ -65,6 +65,13 @@ impl Context {
         broker: &impl BrokerSend,
     ) -> Result<(), BrokerFacadeError> {
         let input_block_number = input.block_added.number.as_u64();
+        let input_epoch = self.calculate_epoch(input_block_number);
+        self.last_finished_epoch.map(|last_finished_epoch| {
+            // Asserting that the calculated epoch comes after the last finished epoch.
+            // (If last_finished_epoch == None then we don't need the assertion.)
+            assert!(input_epoch > last_finished_epoch)
+        });
+
         self.finish_epoch_if_needed(input_block_number, broker)
             .await?;
 
@@ -76,13 +83,6 @@ impl Context {
             .inc();
 
         self.inputs_sent += 1;
-
-        let input_epoch = self.calculate_epoch(input_block_number);
-        self.last_finished_epoch.map(|last_finished_epoch| {
-            // Asserting that the calculated epoch comes after the last finished epoch.
-            // (If last_finished_epoch == None then we don't need the assertion.)
-            assert!(input_epoch > last_finished_epoch)
-        });
         self.last_input_epoch = Some(input_epoch);
 
         Ok(())

offchain/dispatcher/src/drivers/machine.rs

@@ -36,8 +36,9 @@ impl MachineDriver {
             }
         };
 
-        let block = block.number.as_u64();
-        context.finish_epoch_if_needed(block, broker).await?;
+        let block_number = block.number.as_u64();
+        tracing::debug!("reacting to standalone block {}", block_number);
+        context.finish_epoch_if_needed(block_number, broker).await?;
 
         Ok(())
     }

offchain/dispatcher/src/machine/rollups_broker.rs

@@ -185,10 +185,10 @@ impl BrokerSend for BrokerFacade {
         tracing::info!(?inputs_sent_count, "finishing epoch");
 
         let mut broker = self.broker.lock().await;
-        let status = self.broker_status(&mut broker).await?;
+        let status = self.broker_status(&mut broker).await?; // Epoch number gets incremented here!
 
         let event = build_next_finish_epoch(&status);
-        tracing::trace!(?event, "producing finish epoch event");
+        tracing::info!(?event, "producing finish epoch event");
 
         epoch_sanity_check!(event, inputs_sent_count);