diff --git a/applications/launchpad/gui-react/build/.gitkeep b/applications/launchpad/gui-react/build/.gitkeep new file mode 100644 index 0000000000..e69de29bb2 diff --git a/dan_layer/core/src/models/hot_stuff_message.rs b/dan_layer/core/src/models/hot_stuff_message.rs index cb4e037325..3e31ad48f2 100644 --- a/dan_layer/core/src/models/hot_stuff_message.rs +++ b/dan_layer/core/src/models/hot_stuff_message.rs @@ -172,7 +172,7 @@ impl HotStuffMessage { asset_public_key: PublicKey, ) -> Self { Self { - message_type: HotStuffMessageType::Commit, + message_type: HotStuffMessageType::Decide, node, justify: commit_qc, view_number, diff --git a/dan_layer/core/src/models/mod.rs b/dan_layer/core/src/models/mod.rs index 7ad265fe53..b277ee4875 100644 --- a/dan_layer/core/src/models/mod.rs +++ b/dan_layer/core/src/models/mod.rs @@ -165,6 +165,7 @@ pub enum HotStuffMessageType { Prepare, PreCommit, Commit, + Decide, // Special type Genesis, } @@ -176,6 +177,7 @@ impl HotStuffMessageType { HotStuffMessageType::Prepare => 2, HotStuffMessageType::PreCommit => 3, HotStuffMessageType::Commit => 4, + HotStuffMessageType::Decide => 5, HotStuffMessageType::Genesis => 255, } } @@ -190,6 +192,7 @@ impl TryFrom for HotStuffMessageType { 2 => Ok(HotStuffMessageType::Prepare), 3 => Ok(HotStuffMessageType::PreCommit), 4 => Ok(HotStuffMessageType::Commit), + 5 => Ok(HotStuffMessageType::Decide), 255 => Ok(HotStuffMessageType::Genesis), _ => Err("Not a value message type".to_string()), } diff --git a/dan_layer/core/src/workers/states/decide_state.rs b/dan_layer/core/src/workers/states/decide_state.rs index d88e235b9f..166731efea 100644 --- a/dan_layer/core/src/workers/states/decide_state.rs +++ b/dan_layer/core/src/workers/states/decide_state.rs @@ -85,7 +85,7 @@ impl DecideState { } } }, - r = inbound_services.wait_for_qc(HotStuffMessageType::Prepare, current_view.view_id()) => { + r = inbound_services.wait_for_qc(HotStuffMessageType::Commit, current_view.view_id()) => { let (from, message) = r?; let leader= self.committee.leader_for_view(current_view.view_id).clone(); if let Some(event) = self.process_replica_message(&message, current_view, &from, &leader, &mut unit_of_work, payload_provider).await? {