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

test progress

Browse Source
This commit is contained in:
Eitan Seri-Levi
2025-02-06 13:38:33 +02:00
parent 7414f485a3
commit 51984ab54d
6 changed files with 37 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
beacon_node/http_api/src/inclusion_list_duties.rs
View File

@@ -14,9 +14,7 @@ pub fn inclusion_list_duties<T: BeaconChainTypes>(
) -> Result<ApiDuties, warp::reject::Rejection> {
let current_epoch = chain
.epoch()
// TODO(focil) unwrap
.unwrap();
// .map_err(warp_utils::reject::beacon_chain_error)?;
.map_err(warp_utils::reject::unhandled_error)?;
// Determine what the current epoch would be if we fast-forward our system clock by
// `MAXIMUM_GOSSIP_CLOCK_DISPARITY`.
@@ -37,8 +35,7 @@ pub fn inclusion_list_duties<T: BeaconChainTypes>(
let head_block_root = chain.canonical_head.cached_head().head_block_root();
let (duties, dependent_root) = chain
.validator_inclusion_list_duties(request_indices, request_epoch, head_block_root)
// TODO(focil) unwrap
.unwrap();
.map_err(warp_utils::reject::unhandled_error)?;
//.map_err(warp_utils::reject::beacon_chain_error)?;
convert_to_api_response(duties, request_indices, dependent_root, chain)
} else if request_epoch > current_epoch + 1 {
@@ -77,8 +74,7 @@ fn convert_to_api_response<T: BeaconChainTypes>(
let usize_indices = indices.iter().map(|i| *i as usize).collect::<Vec<_>>();
let index_to_pubkey_map = chain
.validator_pubkey_bytes_many(&usize_indices)
// TODO(focil) unwrap
.unwrap();
.map_err(warp_utils::reject::unhandled_error)?;
// .map_err(warp_utils::reject::beacon_chain_error)?;
let data = duties

8
beacon_node/http_api/src/lib.rs
View File

@@ -3592,9 +3592,7 @@ pub fn serve<T: BeaconChainTypes>(
task_spawner.spawn_async_with_rejection(Priority::P0, async move {
not_synced_filter?;
let current_slot = chain.slot().unwrap();
// TODO(focil) unwrap
// .map_err(warp_utils::reject::beacon_chain_error)?;
let current_slot = chain.slot().map_err(warp_utils::reject::unhandled_error)?;
// allow a tolerance of one slot to account for clock skew
//
@@ -3610,9 +3608,7 @@ pub fn serve<T: BeaconChainTypes>(
.produce_inclusion_list(query.slot)
.await
.map(api_types::GenericResponse::from)
// TODO(focil) unwrap
.unwrap();
// .map_err(warp_utils::reject::beacon_chain_error)?;
.map_err(warp_utils::reject::unhandled_error)?;
Ok::<_, warp::reject::Rejection>(warp::reply::json(&data).into_response())
})
},