Consensus finality update

Author: TheNewAutonomy

crates/catalyst-cli/src/node.rs

@@ -20,9 +20,11 @@ pub struct LsuCidGossip {
     ///
     /// NOTE: `impl_catalyst_serialize!` doesn't support `Option<T>`, so we encode "none" as "".
     pub proof_cid: String,
+    /// CID of `LsuFinalityCertificateV1` (bincode). Empty if not yet assembled (coordinated network upgrade).
+    pub finality_cid: String,
 }
 
-impl_catalyst_serialize!(LsuCidGossip, cycle, lsu_hash, cid, prev_state_root, state_root, proof_cid);
+impl_catalyst_serialize!(LsuCidGossip, cycle, lsu_hash, cid, prev_state_root, state_root, proof_cid, finality_cid);
 
 impl NetworkMessage for LsuCidGossip {
     fn serialize(&self) -> CatalystResult<Vec<u8>> {
@@ -241,3 +243,82 @@ impl LsuGossip {
     }
 }
 
+/// One validator attestation: Ed25519/Ristretto Schnorr signature over `H_cert` (ADR 0001).
+#[derive(Debug, Clone, PartialEq, serde::Serialize, serde::Deserialize)]
+pub struct LsuFinalityAttestationMsg {
+    pub chain_id: u64,
+    pub genesis_hash: [u8; 32],
+    pub cycle: u64,
+    pub lsu_hash: [u8; 32],
+    pub committee_hash: [u8; 32],
+    pub vote_list_hash: [u8; 32],
+    pub producer_id: String,
+    pub signature: Vec<u8>,
+}
+
+impl_catalyst_serialize!(
+    LsuFinalityAttestationMsg,
+    chain_id,
+    genesis_hash,
+    cycle,
+    lsu_hash,
+    committee_hash,
+    vote_list_hash,
+    producer_id,
+    signature
+);
+
+impl NetworkMessage for LsuFinalityAttestationMsg {
+    fn serialize(&self) -> CatalystResult<Vec<u8>> {
+        CatalystSerialize::serialize(self)
+    }
+
+    fn deserialize(data: &[u8]) -> CatalystResult<Self> {
+        CatalystDeserialize::deserialize(data)
+    }
+
+    fn message_type(&self) -> MessageType {
+        MessageType::LsuFinalityAttestation
+    }
+
+    fn priority(&self) -> u8 {
+        MessagePriority::High as u8
+    }
+
+    fn ttl(&self) -> u32 {
+        300
+    }
+}
+
+/// Announces where to fetch the assembled quorum certificate for a cycle.
+#[derive(Debug, Clone, PartialEq, serde::Serialize, serde::Deserialize)]
+pub struct LsuFinalityCidMsg {
+    pub cycle: u64,
+    pub lsu_hash: [u8; 32],
+    pub finality_cid: String,
+}
+
+impl_catalyst_serialize!(LsuFinalityCidMsg, cycle, lsu_hash, finality_cid);
+
+impl NetworkMessage for LsuFinalityCidMsg {
+    fn serialize(&self) -> CatalystResult<Vec<u8>> {
+        CatalystSerialize::serialize(self)
+    }
+
+    fn deserialize(data: &[u8]) -> CatalystResult<Self> {
+        CatalystDeserialize::deserialize(data)
+    }
+
+    fn message_type(&self) -> MessageType {
+        MessageType::LsuFinalityCid
+    }
+
+    fn priority(&self) -> u8 {
+        MessagePriority::High as u8
+    }
+
+    fn ttl(&self) -> u32 {
+        300
+    }
+}
+

crates/catalyst-cli/src/sync.rs

@@ -10,7 +10,16 @@ pub mod types;
 // The executable engine.
 pub mod consensus;
 
+/// LSU finality certificate (ADR 0001).
+pub mod lsu_finality;
+
 pub use consensus::CollaborativeConsensus;
+pub use phases::hash_producer_list_merkle;
+pub use lsu_finality::{
+    bft_vote_threshold, committee_hash_ordered_producer_list, h_cert_v1, parse_producer_hex32,
+    verify_finality_attestation, verify_lsu_finality_certificate, LsuFinalityCertificateV1,
+    LsuFinalityVerifyError, ProducerFinalityVote, FINALITY_CERT_STYLE_INDIVIDUAL, MAX_FINALITY_VOTES,
+};
 pub use types::{
     ConsensusConfig, CycleNumber, ProducerCandidate, ProducerId, ProducerOutput, ProducerQuantity, ProducerVote,
     LedgerStateUpdate, PartialLedgerStateUpdate, TransactionEntry,