From 1c1e6dda10561463426cfaf55e461038ca010989 Mon Sep 17 00:00:00 2001 From: Eitan Seri- Levi Date: Tue, 3 Feb 2026 20:28:41 -0800 Subject: [PATCH] Fmt --- beacon_node/http_api/src/lib.rs | 17 ++++++++++++----- .../src/publish_execution_payload_envelope.rs | 6 +++--- beacon_node/http_api/tests/tests.rs | 1 - 3 files changed, 15 insertions(+), 9 deletions(-) diff --git a/beacon_node/http_api/src/lib.rs b/beacon_node/http_api/src/lib.rs index 812d0244e5..35885e2091 100644 --- a/beacon_node/http_api/src/lib.rs +++ b/beacon_node/http_api/src/lib.rs @@ -1504,7 +1504,9 @@ pub fn serve( network_tx: UnboundedSender>| { task_spawner.spawn_async_with_rejection(Priority::P0, async move { publish_execution_payload_envelope::publish_execution_payload_envelope( - envelope, chain, &network_tx, + envelope, + chain, + &network_tx, ) .await }) @@ -1517,7 +1519,10 @@ pub fn serve( .and(warp::path("beacon")) .and(warp::path("execution_payload_envelope")) .and(warp::path::end()) - .and(warp::header::exact(CONTENT_TYPE_HEADER, SSZ_CONTENT_TYPE_HEADER)) + .and(warp::header::exact( + CONTENT_TYPE_HEADER, + SSZ_CONTENT_TYPE_HEADER, + )) .and(warp::body::bytes()) .and(task_spawner_filter.clone()) .and(chain_filter.clone()) @@ -1531,10 +1536,12 @@ pub fn serve( let envelope = SignedExecutionPayloadEnvelope::::from_ssz_bytes(&body_bytes) .map_err(|e| { - warp_utils::reject::custom_bad_request(format!("invalid SSZ: {e:?}")) - })?; + warp_utils::reject::custom_bad_request(format!("invalid SSZ: {e:?}")) + })?; publish_execution_payload_envelope::publish_execution_payload_envelope( - envelope, chain, &network_tx, + envelope, + chain, + &network_tx, ) .await }) diff --git a/beacon_node/http_api/src/publish_execution_payload_envelope.rs b/beacon_node/http_api/src/publish_execution_payload_envelope.rs index 0496f94a92..1e4225505c 100644 --- a/beacon_node/http_api/src/publish_execution_payload_envelope.rs +++ b/beacon_node/http_api/src/publish_execution_payload_envelope.rs @@ -17,9 +17,9 @@ pub async fn publish_execution_payload_envelope( let beacon_block_root = envelope.message.beacon_block_root; // Basic validation: check that the slot is reasonable - let current_slot = chain - .slot() - .map_err(|_| warp_utils::reject::custom_server_error("Unable to get current slot".into()))?; + let current_slot = chain.slot().map_err(|_| { + warp_utils::reject::custom_server_error("Unable to get current slot".into()) + })?; // Don't accept envelopes too far in the future if slot > current_slot + 1 { diff --git a/beacon_node/http_api/tests/tests.rs b/beacon_node/http_api/tests/tests.rs index 392f7c7869..df943b0e6c 100644 --- a/beacon_node/http_api/tests/tests.rs +++ b/beacon_node/http_api/tests/tests.rs @@ -7721,7 +7721,6 @@ async fn block_production_v4_ssz() { .await; } - #[tokio::test(flavor = "multi_thread", worker_threads = 2)] async fn blinded_block_production_full_payload_premerge() { ApiTester::new().await.test_blinded_block_production().await;