typo

Cargo.toml

@@ -1,6 +1,12 @@
 [workspace]
 # Extra tooling projects will be added.
-members = ["anchor", "anchor/client", "anchor/http_api", "anchor/qbft"]
+members = [
+    "anchor",
+    "anchor/client",
+    "anchor/http_api",
+    "anchor/qbft",
+    "anchor/types",
+]
 resolver = "2"
 
 [workspace.package]
@@ -10,6 +16,7 @@ edition = "2021"
 client = { path = "anchor/client" }
 qbft = { path = "anchor/qbft" }
 http_api = { path = "anchor/http_api" }
+types = { path = "anchor/types" }
 task_executor = { git = "https://github.com/sigp/lighthouse", branch = "anchor", default-features = false, features = [
     "tracing",
 ] }
@@ -24,6 +31,7 @@ futures = "0.3.30"
 # dirs = "3"
 hyper = "1.4"
 serde = { version = "1.0.208", features = ["derive"] }
+ethereum_serde_utils = "0.7.0"
 tokio = { version = "1.39.2", features = [
     "rt",
     "rt-multi-thread",
@@ -33,6 +41,8 @@ tokio = { version = "1.39.2", features = [
 ] }
 tracing = "0.1.40"
 tracing-subscriber = { version = "0.3.18", features = ["fmt", "env-filter"] }
+arbitrary = { version = "1.3.2", features = ["derive"] }
+
 
 [profile.maxperf]
 inherits = "release"

anchor/qbft/src/lib.rs

@@ -234,17 +234,17 @@ where
     fn start_round(&mut self) {
         debug!(round = *self.current_round, "Starting new round",);
 
-        // Remove old unnecessary round change message
+        // Remove round change messages that would be for previous rounds
         self.round_change_messages
             .retain(|&round, _value| round >= self.current_round);
 
+        // Initialise the instance state for the round
+        self.state = InstanceState::AwaitingProposal;
+
         // Check if we are the leader
         if self.check_leader(&self.operator_id()) {
             // We are the leader
             debug!("Current leader");
-
-            self.state = InstanceState::AwaitingProposal;
-
             // Check justification of round change quorum
             if let Some(validated_data) = self.justify_round_change_quorum().cloned() {
                 debug!(
@@ -257,9 +257,6 @@ where
                 self.send_proposal(self.start_data.clone());
                 self.send_prepare(self.start_data.clone());
             }
-        } else {
-            // We are not the leader, so await a proposal from a leader
-            self.state = InstanceState::AwaitingProposal;
         }
     }
 

anchor/src/main.rs

@@ -1,7 +1,6 @@
 use tracing::{error, info};
 
 mod environment;
-
 use client::Client;
 use environment::Environment;
 use task_executor::ShutdownReason;