consensus-logic, sequencer: minor cleanup

alpenlabs · Jul 25, 2024 · 4e03a47 · 4e03a47
1 parent 5594b49
commit 4e03a47
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 9 deletions.
diff --git a/crates/consensus-logic/src/worker.rs b/crates/consensus-logic/src/worker.rs
@@ -186,11 +186,9 @@ fn handle_sync_event<D: Database, E: ExecEngineCtl>(
         error!(%ev_idx, "failed to submit new CSM state to FCM");
     }
 
-    let status = CsmStatus {
-        last_sync_ev_idx: ev_idx,
-        chain_tip_blkid: new_state.sync().map(|ss| *ss.chain_tip_blkid()),
-        finalized_blkid: new_state.sync().map(|ss| *ss.finalized_blkid()),
-    };
+    let mut status = CsmStatus::default();
+    status.set_last_sync_ev_idx(ev_idx);
+    status.update_from_client_state(new_state.as_ref());
     if csm_status_tx.send(status).is_err() {
         error!(%ev_idx, "failed to submit new CSM status update");
     }

diff --git a/sequencer/src/main.rs b/sequencer/src/main.rs
@@ -134,10 +134,6 @@ fn main_inner(args: Args) -> anyhow::Result<()> {
         warn!("network not set to regtest, ignoring");
     }
 
-    // Create dataflow channels.
-    let (_cout_tx, _cout_rx) = mpsc::channel::<operation::ClientUpdateOutput>(64);
-    // TODO connect up these other channels
-
     // Init engine controller.
     let eng_ctl = alpen_vertex_evmctl::stub::StubController::new(time::Duration::from_millis(100));
     let eng_ctl = Arc::new(eng_ctl);