feat(consensus): make consensus aware of TIP 1017

crates/commonware-node/Cargo.toml

@@ -12,6 +12,7 @@ workspace = true
 
 [dependencies]
 tempo-alloy.workspace = true
+tempo-chainspec.workspace = true
 tempo-commonware-node-config.workspace = true
 tempo-dkg-onchain-artifacts.workspace = true
 tempo-node.workspace = true
@@ -45,8 +46,10 @@ eyre.workspace = true
 futures.workspace = true
 governor.workspace = true
 indexmap.workspace = true
+itertools.workspace = true
 jiff = { workspace = true, features = ["std"] }
 parking_lot.workspace = true
+pin-project = "1.1.10"
 prometheus-client.workspace = true
 rand_08.workspace = true
 
@@ -63,4 +66,3 @@ reth-rpc-convert.workspace = true
 
 tokio = { workspace = true, features = ["macros", "sync"] }
 tracing.workspace = true
-pin-project = "1.1.10"

crates/commonware-node/src/consensus/application/actor.rs

@@ -515,6 +515,10 @@ impl Inner<Init> {
             );
             info!(
                 %outcome.epoch,
+                outcome.network_identity = %outcome.network_identity(),
+                outcome.dealers = ?outcome.dealers(),
+                outcome.players = ?outcome.players(),
+                outcome.next_players = ?outcome.next_players(),
                 "received DKG outcome; will include in payload builder attributes",
             );
             outcome.encode().into()
@@ -822,7 +826,7 @@ async fn verify_block<TContext: Pacer>(
         PayloadStatusEnum::Syncing => {
             bail!(
                 "failed validating block because payload is still syncing, \
-                this means the parent block was available to the consensus
+                this means the parent block was available to the consensus \
                 layer but not the execution layer"
             )
         }

crates/commonware-node/src/consensus/engine.rs

@@ -281,10 +281,22 @@ where
         )
         .await;
 
+        let (executor, executor_mailbox) = crate::executor::init(
+            context.with_label("executor"),
+            crate::executor::Config {
+                execution_node: execution_node.clone(),
+                last_finalized_height,
+                marshal: marshal_mailbox.clone(),
+                fcu_heartbeat_interval: self.fcu_heartbeat_interval,
+            },
+        )
+        .wrap_err("failed initialization executor actor")?;
+
         let (peer_manager, peer_manager_mailbox) = peer_manager::init(
             context.with_label("peer_manager"),
             peer_manager::Config {
                 execution_node: execution_node.clone(),
+                executor: executor_mailbox.clone(),
                 oracle: self.peer_manager.clone(),
                 epoch_strategy: epoch_strategy.clone(),
                 last_finalized_height,
@@ -324,17 +336,6 @@ where
             self.feed_state,
         );
 
-        let (executor, executor_mailbox) = crate::executor::init(
-            context.with_label("executor"),
-            crate::executor::Config {
-                execution_node: execution_node.clone(),
-                last_finalized_height,
-                marshal: marshal_mailbox.clone(),
-                fcu_heartbeat_interval: self.fcu_heartbeat_interval,
-            },
-        )
-        .wrap_err("failed initialization executor actor")?;
-
         let (application, application_mailbox) = application::init(super::application::Config {
             context: context.with_label("application"),
             fee_recipient: self.fee_recipient,