gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-05-30 20:57:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add inclusion list sse event

Browse Source
This commit is contained in:
Eitan Seri-Levi
2025-03-20 23:59:32 -06:00
parent 411860fe58
commit 77e86b102d
6 changed files with 39 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
beacon_node/beacon_chain/src/beacon_chain.rs
View File

@@ -2391,10 +2391,13 @@ impl<T: BeaconChainTypes> BeaconChain<T> {
let _timer =
metrics::start_timer(&metrics::UNAGGREGATED_ATTESTATION_GOSSIP_VERIFICATION_TIMES);
GossipVerifiedInclusionList::verify(inclusion_list, self).inspect(|_v| {
// TODO(focil) emit event
if let Some(_event_handler) = self.event_handler.as_ref() {}
GossipVerifiedInclusionList::verify(inclusion_list, self).inspect(|v| {
metrics::inc_counter(&metrics::INCLUSION_LIST_PROCESSING_SUCCESSES);
if let Some(event_handler) = self.event_handler.as_ref() {
event_handler.register(EventKind::InclusionList(Box::new(
v.signed_il.clone(),
)));
}
})
}

15
beacon_node/beacon_chain/src/events.rs
View File

@@ -25,6 +25,7 @@ pub struct ServerSentEventHandler<E: EthSpec> {
attester_slashing_tx: Sender<EventKind<E>>,
bls_to_execution_change_tx: Sender<EventKind<E>>,
block_gossip_tx: Sender<EventKind<E>>,
inclusion_list_tx: Sender<EventKind<E>>,
log: Logger,
}
@@ -55,6 +56,7 @@ impl<E: EthSpec> ServerSentEventHandler<E> {
let (attester_slashing_tx, _) = broadcast::channel(capacity);
let (bls_to_execution_change_tx, _) = broadcast::channel(capacity);
let (block_gossip_tx, _) = broadcast::channel(capacity);
let (inclusion_list_tx, _) = broadcast::channel(capacity);
Self {
attestation_tx,
@@ -75,6 +77,7 @@ impl<E: EthSpec> ServerSentEventHandler<E> {
attester_slashing_tx,
bls_to_execution_change_tx,
block_gossip_tx,
inclusion_list_tx,
log,
}
}
@@ -161,6 +164,10 @@ impl<E: EthSpec> ServerSentEventHandler<E> {
.block_gossip_tx
.send(kind)
.map(|count| log_count("block gossip", count)),
EventKind::InclusionList(_) => self
.inclusion_list_tx
.send(kind)
.map(|count| log_count("inclusion list", count)),
};
if let Err(SendError(event)) = result {
trace!(self.log, "No receivers registered to listen for event"; "event" => ?event);
@@ -239,6 +246,10 @@ impl<E: EthSpec> ServerSentEventHandler<E> {
self.block_gossip_tx.subscribe()
}
pub fn subscribe_inclusion_list(&self) -> Receiver<EventKind<E>> {
self.inclusion_list_tx.subscribe()
}
pub fn has_attestation_subscribers(&self) -> bool {
self.attestation_tx.receiver_count() > 0
}
@@ -302,4 +313,8 @@ impl<E: EthSpec> ServerSentEventHandler<E> {
pub fn has_block_gossip_subscribers(&self) -> bool {
self.block_gossip_tx.receiver_count() > 0
}
pub fn has_inclusion_list_subscribers(&self) -> bool {
self.inclusion_list_tx.receiver_count() > 0
}
}