[update] v0.0.45-50

Cargo.toml

@@ -10,16 +10,18 @@ resolver = "2"
 [workspace.dependencies]
 alto-client = { version = "0.0.6", path = "client" }
 alto-types = { version = "0.0.6", path = "types" }
-commonware-consensus = { version = "0.0.43" }
-commonware-cryptography = { version = "0.0.43" }
-commonware-deployer = { version = "0.0.43" }
-commonware-macros = { version = "0.0.43" }
-commonware-p2p = { version = "0.0.43" }
-commonware-resolver = { version = "0.0.43" }
-commonware-runtime = { version = "0.0.43" }
-commonware-storage = { version = "0.0.43" }
-commonware-stream = { version = "0.0.43" }
-commonware-utils = { version = "0.0.43" }
+commonware-broadcast = { version = "0.0.47" }
+commonware-codec = { version = "0.0.47" }
+commonware-consensus = { version = "0.0.47" }
+commonware-cryptography = { version = "0.0.47" }
+commonware-deployer = { version = "0.0.47" }
+commonware-macros = { version = "0.0.47" }
+commonware-p2p = { version = "0.0.47" }
+commonware-resolver = { version = "0.0.47" }
+commonware-runtime = { version = "0.0.47" }
+commonware-storage = { version = "0.0.47" }
+commonware-stream = { version = "0.0.47" }
+commonware-utils = { version = "0.0.47" }
 thiserror = "2.0.12"
 bytes = "1.7.1"
 rand = "0.8.5"

chain/Cargo.toml

@@ -13,6 +13,8 @@ documentation = "https://docs.rs/alto-chain"
 [dependencies]
 alto-types = { workspace = true }
 alto-client = { workspace = true }
+commonware-broadcast = { workspace = true }
+commonware-codec = { workspace = true }
 commonware-consensus = { workspace = true }
 commonware-cryptography = { workspace = true }
 commonware-deployer = { workspace = true }
@@ -32,8 +34,6 @@ tracing-subscriber = { workspace = true, features = ["fmt", "json"] }
 governor = { workspace = true }
 prometheus-client = { workspace = true }
 clap = { workspace = true }
-sysinfo = "0.33.1"
-axum = "0.8.1"
 uuid = "1.15.1"
 serde = { version = "1.0.218", features = ["derive"] }
 serde_yaml = "0.9.34"

chain/README.md

@@ -22,7 +22,7 @@ cargo install commonware-deployer
 ### Create Deployer Artifacts
 
 ```bash
-cargo run --bin setup -- generate --peers 50 --bootstrappers 5 --regions us-west-1,us-east-1,eu-west-1,ap-northeast-1,eu-north-1,ap-south-1,sa-east-1,eu-central-1,ap-northeast-2,ap-southeast-2 --monitoring-instance-type c7g.4xlarge --monitoring-storage-size 100 --instance-type c7g.xlarge --storage-size 40 --worker-threads 3 --log-level info --message-backlog 16384 --mailbox-size 16384 --dashboard dashboard.json --output assets
+cargo run --bin setup -- generate --peers 50 --bootstrappers 5 --regions us-west-1,us-east-1,eu-west-1,ap-northeast-1,eu-north-1,ap-south-1,sa-east-1,eu-central-1,ap-northeast-2,ap-southeast-2 --monitoring-instance-type c7g.4xlarge --monitoring-storage-size 100 --instance-type c7g.xlarge --storage-size 40 --worker-threads 3 --log-level info --message-backlog 16384 --mailbox-size 16384 --deque-size 10 --dashboard dashboard.json --output assets
 ```
 
 _We use 1 less `worker-threads` than the number of `vCPUs` to leave a core for `blocking-threads`._

chain/src/actors/application/actor.rs

@@ -4,9 +4,8 @@ use super::{
     Config,
 };
 use crate::actors::syncer;
-use alto_types::{Block, Finalization, Notarization, Seed};
-use commonware_consensus::threshold_simplex::Prover;
-use commonware_cryptography::{sha256::Digest, Hasher, Sha256};
+use alto_types::Block;
+use commonware_cryptography::{Digestible, Hasher, Sha256};
 use commonware_macros::select;
 use commonware_runtime::{Clock, Handle, Metrics, Spawner};
 use commonware_utils::SystemTimeExt;
@@ -55,7 +54,6 @@ const SYNCHRONY_BOUND: u64 = 500;
 /// Application actor.
 pub struct Actor<R: Rng + Spawner + Metrics + Clock> {
     context: R,
-    prover: Prover<Digest>,
     hasher: Sha256,
     mailbox: mpsc::Receiver<Message>,
 }
@@ -67,7 +65,6 @@ impl<R: Rng + Spawner + Metrics + Clock> Actor<R> {
         (
             Self {
                 context,
-                prover: config.prover,
                 hasher: Sha256::new(),
                 mailbox,
             },
@@ -213,26 +210,6 @@ impl<R: Rng + Spawner + Metrics + Clock> Actor<R> {
                         }
                     });
                 }
-                Message::Prepared { proof, payload } => {
-                    // Parse the proof
-                    let (view, parent, _, signature, seed) =
-                        self.prover.deserialize_notarization(proof).unwrap();
-                    let notarization = Notarization::new(view, parent, payload, signature.into());
-                    let seed = Seed::new(view, seed.into());
-
-                    // Send the notarization to the syncer
-                    syncer.notarized(notarization, seed).await;
-                }
-                Message::Finalized { proof, payload } => {
-                    // Parse the proof
-                    let (view, parent, _, signature, seed) =
-                        self.prover.deserialize_finalization(proof.clone()).unwrap();
-                    let finalization = Finalization::new(view, parent, payload, signature.into());
-                    let seed = Seed::new(view, seed.into());
-
-                    // Send the finalization to the syncer
-                    syncer.finalized(finalization, seed).await;
-                }
             }
         }
     }

chain/src/actors/application/ingress.rs

@@ -1,6 +1,6 @@
 use commonware_consensus::{
-    threshold_simplex::{Context, View},
-    Automaton as Au, Committer as Co, Proof, Relay as Re,
+    threshold_simplex::types::{Context, View},
+    Automaton, Relay,
 };
 use commonware_cryptography::sha256::Digest;
 use futures::{
@@ -26,14 +26,6 @@ pub enum Message {
         payload: Digest,
         response: oneshot::Sender<bool>,
     },
-    Prepared {
-        proof: Proof,
-        payload: Digest,
-    },
-    Finalized {
-        proof: Proof,
-        payload: Digest,
-    },
 }
 
 /// Mailbox for the application.
@@ -48,7 +40,7 @@ impl Mailbox {
     }
 }
 
-impl Au for Mailbox {
+impl Automaton for Mailbox {
     type Digest = Digest;
     type Context = Context<Self::Digest>;
 
@@ -97,7 +89,7 @@ impl Au for Mailbox {
     }
 }
 
-impl Re for Mailbox {
+impl Relay for Mailbox {
     type Digest = Digest;
 
     async fn broadcast(&mut self, digest: Self::Digest) {
@@ -107,21 +99,3 @@ impl Re for Mailbox {
             .expect("Failed to send broadcast");
     }
 }
-
-impl Co for Mailbox {
-    type Digest = Digest;
-
-    async fn prepared(&mut self, proof: Proof, payload: Self::Digest) {
-        self.sender
-            .send(Message::Prepared { proof, payload })
-            .await
-            .expect("Failed to send notarized");
-    }
-
-    async fn finalized(&mut self, proof: Proof, payload: Self::Digest) {
-        self.sender
-            .send(Message::Finalized { proof, payload })
-            .await
-            .expect("Failed to send finalized");
-    }
-}

chain/src/actors/application/mod.rs

@@ -1,8 +1,6 @@
-use commonware_consensus::threshold_simplex::Prover;
 use commonware_cryptography::{
     bls12381::primitives::{group, poly::Poly},
     ed25519::PublicKey,
-    sha256::Digest,
 };
 
 mod actor;
@@ -14,9 +12,6 @@ pub use supervisor::Supervisor;
 
 /// Configuration for the application.
 pub struct Config {
-    /// Prover used to decode opaque proofs from consensus.
-    pub prover: Prover<Digest>,
-
     /// Participants active in consensus.
     pub participants: Vec<PublicKey>,
 

chain/src/actors/application/supervisor.rs

@@ -1,10 +1,11 @@
 use alto_types::leader_index;
 use commonware_consensus::{
-    threshold_simplex::View, Activity, Proof, Supervisor as Su, ThresholdSupervisor as TSu,
+    threshold_simplex::types::{Seed, View},
+    Supervisor as Su, ThresholdSupervisor as TSu,
 };
 use commonware_cryptography::{
     bls12381::primitives::{
-        group::{self, Element},
+        group,
         poly::{self, Poly},
     },
     ed25519::PublicKey,
@@ -59,20 +60,15 @@ impl Su for Supervisor {
     fn is_participant(&self, _: Self::Index, candidate: &Self::PublicKey) -> Option<u32> {
         self.participants_map.get(candidate).cloned()
     }
-
-    async fn report(&self, _: Activity, _: Proof) {
-        // We don't report activity in this example but you would otherwise use
-        // this to collect uptime and fraud proofs.
-    }
 }
 
 impl TSu for Supervisor {
     type Seed = group::Signature;
     type Identity = poly::Public;
     type Share = group::Share;
 
-    fn leader(&self, _: Self::Index, seed: Self::Seed) -> Option<Self::PublicKey> {
-        let seed = seed.serialize();
+    fn leader(&self, view: Self::Index, seed: Self::Seed) -> Option<Self::PublicKey> {
+        let seed = Seed::new(view, seed);
         let index = leader_index(&seed, self.participants.len());
         Some(self.participants[index].clone())
     }