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

Remove TODO

Browse Source
This commit is contained in:
Eitan Seri- Levi
2026-02-04 11:19:30 -08:00
parent c606ba306b
commit fa33577bce
1 changed files with 31 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -22,10 +22,12 @@ pub use crate::canonical_head::CanonicalHead;
use crate::chain_config::ChainConfig; use crate::chain_config::ChainConfig;
use crate::custody_context::CustodyContextSsz; use crate::custody_context::CustodyContextSsz;
use crate::data_availability_checker::{ use crate::data_availability_checker::{
Availability, AvailabilityCheckError, AvailableBlock, AvailableBlockData, Availability as BlockAvailability, AvailabilityCheckError, AvailableBlock, AvailableBlockData,
DataAvailabilityChecker, DataColumnReconstructionResult, DataAvailabilityChecker, DataColumnReconstructionResult,
}; };
use crate::data_availability_checker_v2::DataAvailabilityChecker as DataAvailabilityCheckerV2; use crate::data_availability_checker_v2::{
Availability as PayloadAvailability, DataAvailabilityChecker as DataAvailabilityCheckerV2,
};
use crate::data_availability_router::{ use crate::data_availability_router::{
AvailabilityOutcome, DataAvailabilityRouter, ReconstructionOutcome, AvailabilityOutcome, DataAvailabilityRouter, ReconstructionOutcome,
}; };
@@ -3792,20 +3794,44 @@ impl<T: BeaconChainTypes> BeaconChain<T> {
match availability { match availability {
AvailabilityOutcome::Block(availability) => { AvailabilityOutcome::Block(availability) => {
match availability { match availability {
Availability::Available(block) => { BlockAvailability::Available(block) => {
publish_fn()?; publish_fn()?;
// Block is fully available, import into fork choice // Block is fully available, import into fork choice
self.import_available_block(block).await self.import_available_block(block).await
} }
Availability::MissingComponents(block_root) => Ok( BlockAvailability::MissingComponents(block_root) => Ok(
AvailabilityProcessingStatus::MissingComponents(slot, block_root), AvailabilityProcessingStatus::MissingComponents(slot, block_root),
), ),
} }
} }
AvailabilityOutcome::Payload(_availability) => todo!(), AvailabilityOutcome::Payload(availability) => match availability {
PayloadAvailability::Available(available_payload_data) => {
// TODO(gloas) execution publish_fn
// publish_fn()?;
// Payload data is fully available
let (block_root, data_columns) = *available_payload_data;
self.import_available_payload_data(block_root, data_columns)
.await
}
PayloadAvailability::MissingComponents(block_root) => Ok(
AvailabilityProcessingStatus::MissingComponents(slot, block_root),
),
},
} }
} }
#[instrument(skip_all)]
pub async fn import_available_payload_data(
self: &Arc<Self>,
block_root: Hash256,
_data_columns: Vec<Arc<DataColumnSidecar<T::EthSpec>>>,
) -> Result<AvailabilityProcessingStatus, BlockError> {
// TODO(gloas) this is just a stub implementation
// this function should mark payload data as available somehow
Ok(AvailabilityProcessingStatus::Imported(block_root))
}
#[instrument(skip_all)] #[instrument(skip_all)]
pub async fn import_available_block( pub async fn import_available_block(
self: &Arc<Self>, self: &Arc<Self>,