gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-06-15 09:48:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

linting

Browse Source
This commit is contained in:
Eitan Seri-Levi
2026-04-27 13:14:48 +02:00
parent 4746dc5629
commit 732123abbb
1 changed files with 30 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
beacon_node/http_api/src/beacon/execution_payload_envelope.rs
View File

@@ -125,42 +125,40 @@ pub async fn publish_execution_payload_envelope<T: BeaconChainTypes>(
})?;
// Build and publish data column sidecars from the blobs.
if let Some((blobs, kzg_proofs)) = blobs_and_proofs {
if !blobs.is_empty() {
let gossip_verified_columns =
build_gloas_data_columns(&chain, beacon_block_root, slot, &blobs, kzg_proofs)?;
if let Some((blobs, kzg_proofs)) = blobs_and_proofs
&& !blobs.is_empty()
{
let gossip_verified_columns =
build_gloas_data_columns(&chain, beacon_block_root, slot, &blobs, kzg_proofs)?;
if !gossip_verified_columns.is_empty() {
crate::publish_blocks::publish_column_sidecars(
network_tx,
&gossip_verified_columns,
&chain,
if !gossip_verified_columns.is_empty() {
crate::publish_blocks::publish_column_sidecars(
network_tx,
&gossip_verified_columns,
&chain,
)
.map_err(|_| {
warp_utils::reject::custom_server_error(
"unable to publish data column sidecars".into(),
)
.map_err(|_| {
warp_utils::reject::custom_server_error(
"unable to publish data column sidecars".into(),
)
})?;
})?;
let epoch = slot.epoch(T::EthSpec::slots_per_epoch());
let sampling_column_indices = chain.sampling_columns_for_epoch(epoch);
let sampling_columns = gossip_verified_columns
.into_iter()
.filter(|col| sampling_column_indices.contains(&col.index()))
.collect::<Vec<_>>();
let epoch = slot.epoch(T::EthSpec::slots_per_epoch());
let sampling_column_indices = chain.sampling_columns_for_epoch(epoch);
let sampling_columns = gossip_verified_columns
.into_iter()
.filter(|col| sampling_column_indices.contains(&col.index()))
.collect::<Vec<_>>();
if !sampling_columns.is_empty() {
if let Err(e) =
Box::pin(chain.process_gossip_data_columns(sampling_columns, || Ok(())))
.await
{
error!(
%slot,
error = ?e,
"Failed to process sampling data columns during envelope publication"
);
}
}
if !sampling_columns.is_empty()
&& let Err(e) =
Box::pin(chain.process_gossip_data_columns(sampling_columns, || Ok(()))).await
{
error!(
%slot,
error = ?e,
"Failed to process sampling data columns during envelope publication"
);
}
}
}