Skip to content

feat(blockchain): add chain-event bus (head/block/justified/finalized) #516

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
pablodeymo merged 9 commits into from
Jul 21, 2026
Merged

feat(blockchain): add chain-event bus (head/block/justified/finalized) #516

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
60d9c2e
feat(blockchain): add chain-event bus (head/block/justified/finalized)
MegaRedHand Jul 15, 2026
d9b4c37
refactor(blockchain): emit head before justified_checkpoint in diff_a…
MegaRedHand Jul 17, 2026
4b7a2ae
refactor(blockchain): move ChainEventSnapshot into events module
MegaRedHand Jul 17, 2026
9cbe5b7
test(blockchain): drop chain_event_diff_head_recency_boundary
MegaRedHand Jul 17, 2026
8464e6a
refactor(blockchain): drop unused EventBus::disabled
MegaRedHand Jul 17, 2026
cc1d413
Merge branch 'main' into feat/chain-events-bus
MegaRedHand Jul 17, 2026
55d1310
fix(blockchain): beacon-align chain events; emit proposer checkpoints
MegaRedHand Jul 17, 2026
22b296f
Merge remote-tracking branch 'origin/main' into feat/chain-events-bus
MegaRedHand Jul 20, 2026
88b49b4
Merge branch 'main' into feat/chain-events-bus
MegaRedHand Jul 20, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions Cargo.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

10 changes: 8 additions & 2 deletions bin/ethlambda/src/main.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ use serde::Deserialize;
use tracing::{error, info, warn};
use tracing_subscriber::{EnvFilter, Layer, Registry, layer::SubscriberExt};

use ethlambda_blockchain::{BlockChain, BlockChainConfig, SyncStatusController};
use ethlambda_blockchain::{BlockChain, BlockChainConfig, EventBus, SyncStatusController};
use ethlambda_rpc::RpcConfig;
use ethlambda_storage::{
MAX_RESUMABLE_DB_STATE_AGE, StorageBackend, Store, backend::RocksDBBackend,
Expand Down Expand Up @@ -235,6 +235,12 @@ async fn main() -> eyre::Result<()> {
// metric's startup value.
let sync_status = SyncStatusController::default();

// Chain-event bus: the blockchain actor is the sole publisher. No consumer
// subscribes yet — the RPC SSE endpoint (follow-up PR) will attach here;
// until then the receiver-count guard in `emit` makes every emission a
// no-op.
let events = EventBus::default();

let blockchain_config = BlockChainConfig {
aggregator: aggregator.clone(),
sync_status_controller: sync_status.clone(),
Expand All @@ -247,7 +253,7 @@ async fn main() -> eyre::Result<()> {
},
};

let blockchain = BlockChain::spawn(store.clone(), validator_keys, blockchain_config);
let blockchain = BlockChain::spawn(store.clone(), validator_keys, blockchain_config, events);

let built = build_swarm(SwarmConfig {
node_key: node_p2p_key,
Expand Down
2 changes: 0 additions & 2 deletions crates/blockchain/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,6 @@ tracing.workspace = true
hex.workspace = true

[dev-dependencies]
serde = { workspace = true }
serde_json = { workspace = true }
hex = { workspace = true }
libssz.workspace = true
libssz-types.workspace = true
Expand Down
Loading