BeaconConsensusEngineEvent generic data prims

[emhane]

Describe the feature

Make BeaconConsensusEngineEvent generic over primitive types as BeaconConsensusEngineEvent<N: NodePrimitives = reth_primitives::EthPrimitives>. Pass generics N::BlockHeader and N::BlockBody, to the contained SealedHeader and SealedBlock. Update the impl body accordingly.

reth/crates/consensus/beacon/src/engine/event.rs

Lines 11 to 57 in 6695d07

	/// Events emitted by [`crate::BeaconConsensusEngine`].
	#[derive(Clone, Debug)]
	pub enum BeaconConsensusEngineEvent {
	/// The fork choice state was updated, and the current fork choice status
	ForkchoiceUpdated(ForkchoiceState, ForkchoiceStatus),
	/// A block was added to the fork chain.
	ForkBlockAdded(Arc<SealedBlock>, Duration),
	/// A block was added to the canonical chain, and the elapsed time validating the block
	CanonicalBlockAdded(Arc<SealedBlock>, Duration),
	/// A canonical chain was committed, and the elapsed time committing the data
	CanonicalChainCommitted(Box<SealedHeader>, Duration),
	/// The consensus engine is involved in live sync, and has specific progress
	LiveSyncProgress(ConsensusEngineLiveSyncProgress),
	}
	impl BeaconConsensusEngineEvent {
	/// Returns the canonical header if the event is a
	/// [`BeaconConsensusEngineEvent::CanonicalChainCommitted`].
	pub const fn canonical_header(&self) -> Option<&SealedHeader> {
	match self {
	Self::CanonicalChainCommitted(header, _) => Some(header),
	_ => None,
	}
	}
	}
	impl Display for BeaconConsensusEngineEvent {
	fn fmt(&self, f: &mut Formatter<'_>) -> Result {
	match self {
	Self::ForkchoiceUpdated(state, status) => {
	write!(f, "ForkchoiceUpdated({state:?}, {status:?})")
	}
	Self::ForkBlockAdded(block, duration) => {
	write!(f, "ForkBlockAdded({:?}, {duration:?})", block.num_hash())
	}
	Self::CanonicalBlockAdded(block, duration) => {
	write!(f, "CanonicalBlockAdded({:?}, {duration:?})", block.num_hash())
	}
	Self::CanonicalChainCommitted(block, duration) => {
	write!(f, "CanonicalChainCommitted({:?}, {duration:?})", block.num_hash())
	}
	Self::LiveSyncProgress(progress) => {
	write!(f, "LiveSyncProgress({progress:?})")
	}
	}
	}
	}

Additional context

No response

[programskillforverification]

Can I take this one?