feat(consensus): implement consensus/qbft

Cargo.toml

@@ -5,6 +5,7 @@ members = [
     "crates/build-proto",
     "crates/cli",
     "crates/cluster",
+    "crates/consensus",
     "crates/core",
     "crates/crypto",
     "crates/dkg",
@@ -116,6 +117,7 @@ pluto-parsigex = { path = "crates/parsigex" }
 pluto-build-proto = { path = "crates/build-proto" }
 pluto-cli = { path = "crates/cli" }
 pluto-cluster = { path = "crates/cluster" }
+pluto-consensus = { path = "crates/consensus" }
 pluto-core = { path = "crates/core" }
 pluto-crypto = { path = "crates/crypto" }
 pluto-dkg = { path = "crates/dkg" }

crates/cli/Cargo.toml

@@ -20,6 +20,7 @@ tokio.workspace = true
 pluto-app.workspace = true
 pluto-eth1wrap.workspace = true
 pluto-cluster.workspace = true
+pluto-consensus.workspace = true
 pluto-dkg.workspace = true
 pluto-crypto.workspace = true
 pluto-relay-server.workspace = true

crates/cli/src/commands/create_cluster.rs

@@ -23,7 +23,7 @@ use pluto_cluster::{
     operator::Operator,
     registration::{BuilderRegistration, Registration},
 };
-use pluto_core::consensus::protocols;
+use pluto_consensus::protocols;
 use pluto_crypto::{
     blst_impl::BlstImpl,
     tbls::Tbls,

crates/cli/src/commands/create_dkg.rs

@@ -11,7 +11,7 @@ use pluto_cluster::{
     definition::{Creator, Definition},
     operator::Operator,
 };
-use pluto_core::consensus::protocols::is_supported_protocol_name;
+use pluto_consensus::protocols::is_supported_protocol_name;
 use pluto_eth2util::{
     deposit::{eths_to_gweis, verify_deposit_amounts},
     enr::Record,

crates/cli/src/commands/version.rs

@@ -40,7 +40,7 @@ fn run_with_writer<W: Write>(args: VersionArgs, writer: &mut W) -> Result<()> {
     }
 
     writeln!(writer, "Consensus protocols:")?;
-    for protocol in pluto_core::consensus::protocols::protocols() {
+    for protocol in pluto_consensus::protocols::protocols() {
         writeln!(writer, "\t{}", protocol)?;
     }
 
@@ -132,7 +132,7 @@ mod tests {
         );
 
         // Check that the first protocol is listed
-        let protocols = pluto_core::consensus::protocols::protocols();
+        let protocols = pluto_consensus::protocols::protocols();
         assert!(!protocols.is_empty(), "Should have at least one protocol");
         let first_protocol = protocols[0].to_string();
         assert!(

crates/consensus/Cargo.toml

@@ -0,0 +1,42 @@
+[package]
+name = "pluto-consensus"
+version.workspace = true
+edition.workspace = true
+repository.workspace = true
+license.workspace = true
+publish.workspace = true
+
+[dependencies]
+cancellation.workspace = true
+chrono.workspace = true
+crossbeam.workspace = true
+futures.workspace = true
+hex.workspace = true
+either.workspace = true
+k256.workspace = true
+libp2p.workspace = true
+pluto-core.workspace = true
+pluto-featureset.workspace = true
+pluto-k1util.workspace = true
+pluto-p2p.workspace = true
+pluto-ssz.workspace = true
+prost.workspace = true
+prost-types.workspace = true
+thiserror.workspace = true
+tokio.workspace = true
+tokio-util.workspace = true
+tracing.workspace = true
+
+[dev-dependencies]
+anyhow.workspace = true
+clap.workspace = true
+pluto-cluster.workspace = true
+pluto-eth2api.workspace = true
+pluto-eth2util.workspace = true
+serde_json.workspace = true
+ssz.workspace = true
+test-case.workspace = true
+tokio = { workspace = true, features = ["test-util"] }
+
+[lints]
+workspace = true