Skip to content

Commit f82b852

Browse files
committed
fixes
1 parent 978a7ab commit f82b852

File tree

3 files changed

+15
-12
lines changed

3 files changed

+15
-12
lines changed

crates/common/src/pbs/config.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ pub struct RelayConfig {
2121
/// Optional headers to send with each request
2222
pub headers: Option<HashMap<String, String>>,
2323
/// Whether to enable timing games
24+
#[serde(default = "default_bool::<false>")]
2425
pub enable_timing_games: bool,
2526
/// Target time in slot when to send the first header request
2627
pub target_first_request_ms: Option<u64>,

crates/pbs/src/mev_boost/get_header.rs

Lines changed: 14 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ use cb_common::{
1414
use futures::future::join_all;
1515
use reqwest::{header::USER_AGENT, StatusCode};
1616
use tokio::time::sleep;
17-
use tracing::{debug, error, warn};
17+
use tracing::{debug, error, warn, Instrument};
1818

1919
use crate::{
2020
constants::{GET_HEADER_ENDPOINT_TAG, TIMEOUT_ERROR_CODE, TIMEOUT_ERROR_CODE_STR},
@@ -119,16 +119,19 @@ async fn send_timed_get_header(
119119
debug!(send_freq_ms, timeout_left_ms, "TG: sending multiple header requests");
120120

121121
loop {
122-
handles.push(tokio::spawn(send_one_get_header(
123-
url.clone(),
124-
params,
125-
relay.clone(),
126-
chain,
127-
headers.clone(),
128-
timeout_left_ms,
129-
pbs_config.skip_sigverify,
130-
pbs_config.min_bid_wei,
131-
)));
122+
handles.push(tokio::spawn(
123+
send_one_get_header(
124+
url.clone(),
125+
params,
126+
relay.clone(),
127+
chain,
128+
headers.clone(),
129+
timeout_left_ms,
130+
pbs_config.skip_sigverify,
131+
pbs_config.min_bid_wei,
132+
)
133+
.in_current_span(),
134+
));
132135

133136
if timeout_left_ms > send_freq_ms {
134137
// enough time for one more

tests/tests/pbs_integration.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@ fn get_pbs_static_config(port: u16) -> PbsConfig {
3636
skip_sigverify: false,
3737
min_bid_wei: U256::ZERO,
3838
late_in_slot_time_ms: u64::MAX,
39-
skip_header_late_in_slot: false,
4039
}
4140
}
4241

0 commit comments

Comments
 (0)