[consensus] Add consensus::marshal (#1306)

Co-authored-by: Patrick O'Grady <me@patrickogrady.xyz>

Author: BrendanChou

Cargo.lock

@@ -46,7 +46,7 @@ pub trait Read: Sized {
     /// collections or strings.
     ///
     /// Use `Cfg = ()` if no configuration is needed for a specific type.
-    type Cfg: Clone + Send + 'static;
+    type Cfg: Clone + Send + Sync + 'static;
 
     /// Reads a value from the buffer using the provided configuration `cfg`.
     ///

codec/src/codec.rs

@@ -12,7 +12,9 @@ documentation = "https://docs.rs/commonware-consensus"
 
 [dependencies]
 commonware-codec = { workspace = true }
+commonware-broadcast = { workspace = true }
 commonware-cryptography = { workspace = true }
+commonware-resolver = { workspace = true }
 commonware-utils = { workspace = true }
 bytes = { workspace = true }
 cfg-if = { workspace = true }
@@ -31,6 +33,7 @@ rand_distr = { workspace = true }
 tracing = { workspace = true }
 
 [dev-dependencies]
+commonware-resolver = { workspace = true, features = ["mocks"] }
 tracing-subscriber = { workspace = true }
 
 [lib]

consensus/Cargo.toml

@@ -5,17 +5,45 @@
 //! `commonware-consensus` is **ALPHA** software and is not yet recommended for production use. Developers should
 //! expect breaking changes and occasional instability.
 
+use commonware_codec::Codec;
+use commonware_cryptography::{Committable, Digestible};
+
 pub mod aggregation;
 pub mod ordered_broadcast;
 pub mod simplex;
 pub mod threshold_simplex;
 
+/// Viewable is a trait that provides access to the view (round) number.
+/// Any consensus message or object that is associated with a specific view should implement this.
+pub trait Viewable {
+    /// View is the type used to indicate the in-progress consensus decision.
+    type View;
+
+    /// Returns the view associated with this object.
+    fn view(&self) -> Self::View;
+}
+
+/// Block is the interface for a block in the blockchain.
+///
+/// Blocks are used to track the progress of the consensus engine.
+pub trait Block: Codec + Digestible + Committable + Send + Sync + 'static {
+    /// Get the height of the block.
+    fn height(&self) -> u64;
+
+    /// Get the parent block's digest.
+    fn parent(&self) -> Self::Commitment;
+}
+
 cfg_if::cfg_if! {
     if #[cfg(not(target_arch = "wasm32"))] {
         use commonware_cryptography::{Digest, PublicKey};
         use futures::channel::{oneshot, mpsc};
         use std::future::Future;
 
+        pub mod marshal;
+        mod reporter;
+        pub use reporter::*;
+
         /// Histogram buckets for measuring consensus latency.
         const LATENCY: [f64; 36] = [
             0.05, 0.1, 0.125, 0.15, 0.16, 0.17, 0.18, 0.19, 0.2, 0.21, 0.22, 0.23, 0.24, 0.25, 0.26, 0.27, 0.28, 0.29, 0.3, 0.31, 0.32, 0.33, 0.34, 0.35,