feat: Erasure coding mk2

Author: clabby

Cargo.lock

@@ -15,18 +15,19 @@ license = "MIT OR Apache-2.0"
 [workspace.dependencies]
 alto-client = { version = "0.0.16", path = "client" }
 alto-types = { version = "0.0.16", path = "types" }
-commonware-broadcast ="0.0.63"
-commonware-codec ="0.0.63"
-commonware-consensus ="0.0.63"
-commonware-cryptography ="0.0.63"
-commonware-deployer = { version = "0.0.63", default-features = false }
-commonware-macros ="0.0.63"
-commonware-p2p ="0.0.63"
-commonware-resolver ="0.0.63"
-commonware-runtime ="0.0.63"
-commonware-storage ="0.0.63"
-commonware-stream ="0.0.63"
-commonware-utils ="0.0.63"
+commonware-broadcast = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-codec = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-consensus = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-cryptography = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-coding = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-deployer = {  git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2", default-features = false }
+commonware-macros = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-p2p = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-resolver = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-runtime = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-storage = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-stream = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
+commonware-utils = { git = "https://github.com/commonwarexyz/monorepo.git", branch = "cl/consensus-coding-mk2" }
 thiserror = "2.0.12"
 bytes = "1.7.1"
 rand = "0.8.5"
@@ -58,3 +59,7 @@ overflow-checks = true
 # Although overflow checks are enabled by default in "test", we explicitly
 # enable them here for clarity.
 overflow-checks = true
+
+[profile.profiling]
+inherits = "release"
+debug = true

Cargo.toml

@@ -15,6 +15,7 @@ alto-types = { workspace = true }
 alto-client = { workspace = true }
 commonware-broadcast = { workspace = true }
 commonware-codec = { workspace = true }
+commonware-coding = { workspace = true }
 commonware-consensus = { workspace = true }
 commonware-cryptography = { workspace = true }
 commonware-deployer = { workspace = true }

chain/Cargo.toml

@@ -0,0 +1,86 @@
+use alto_types::{Block, PublicKey, Scheme};
+use commonware_consensus::{
+    marshal::{
+        ancestry::{AncestorStream, AncestryProvider},
+        coding::types::CodingCommitment,
+        Update,
+    },
+    simplex::types::Context,
+    Application, Block as _, Reporter,
+};
+use commonware_cryptography::{Digestible, Hasher, Sha256};
+use commonware_runtime::{Clock, Metrics, Spawner};
+use commonware_utils::{SystemTimeExt, Acknowledgement};
+use futures::StreamExt;
+use rand::Rng;
+use tracing::info;
+
+/// Genesis message to use during initialization.
+const GENESIS: &[u8] = b"commonware is neat";
+
+#[derive(Clone)]
+pub struct AltoApp {
+    genesis: Block,
+}
+
+impl AltoApp {
+    pub fn new() -> Self {
+        let genesis = Block::new(Sha256::hash(GENESIS), 0, 0, Vec::new());
+        Self { genesis }
+    }
+}
+
+impl Default for AltoApp {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+impl<E> Application<E> for AltoApp
+where
+    E: Rng + Spawner + Metrics + Clock,
+{
+    type SigningScheme = Scheme;
+    type Context = Context<CodingCommitment, PublicKey>;
+    type Block = Block;
+
+    async fn genesis(&mut self) -> Self::Block {
+        self.genesis.clone()
+    }
+
+    async fn propose<A: AncestryProvider<Block = Self::Block>>(
+        &mut self,
+        (mut runtime_context, _context): (E, Self::Context),
+        mut ancestry: AncestorStream<A, Self::Block>,
+    ) -> Option<Self::Block> {
+        let parent = ancestry.next().await?;
+
+        // Create a new block
+        let mut current = runtime_context.current().epoch_millis();
+        if current <= parent.timestamp {
+            current = parent.timestamp + 1;
+        }
+
+        // Generate some random data.
+        let mut junk = vec![0u8; 8 * 1024 * 1024];
+        runtime_context.fill_bytes(&mut junk);
+
+        Some(Block::new(
+            parent.digest(),
+            parent.height + 1,
+            current,
+            junk,
+        ))
+    }
+}
+
+impl Reporter for AltoApp {
+    type Activity = Update<Block>;
+
+    async fn report(&mut self, activity: Self::Activity) {
+        if let Update::Block(block, ack_rx) = activity {
+            info!(height = block.height(), "finalized block");
+            ack_rx.acknowledge();
+        }
+    }
+}