Skip to content

Commit 3e62c4c

Browse files
committed
Add SSZ types, content negotiation, and encoding helpers
Introduce EncodingType, AcceptedEncodings, and content negotiation primitives for SSZ support in the PBS pipeline. Includes: - EncodingType enum with FromStr/Display and MIME param tolerance - AcceptedEncodings with q-value aware Accept header parsing - SSZ bid value extraction from SignedBuilderBid by fork - deserialize_body and parse_response_encoding_and_fork helpers - Per-fork type aliases for BuilderBid and ExecutionPayloadHeader - SszValueError, PbsError::GeneralRequest, PbsClientError variants - Comprehensive unit tests for all new types and helpers - New deps: headers-accept, mediatype
1 parent b994451 commit 3e62c4c

4 files changed

Lines changed: 6 additions & 7 deletions

File tree

‎crates/common/src/config/mux.rs‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,6 @@ impl MuxKeysLoader {
236236
"Mux keys URL {url} is insecure; consider using HTTPS if possible instead"
237237
);
238238
}
239-
let url = url.as_str();
240239
let client = reqwest::ClientBuilder::new().timeout(http_timeout).build()?;
241240
let response = client.get(url).send().await?;
242241
let pubkey_bytes = safe_read_http_response(response, MUXER_HTTP_MAX_LENGTH).await?;

‎crates/pbs/src/mev_boost/register_validator.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -187,8 +187,8 @@ async fn send_register_validator(
187187
.with_label_values(&[code.as_str(), REGISTER_VALIDATOR_ENDPOINT_TAG, &relay.id])
188188
.inc();
189189

190-
safe_read_http_response(res, MAX_SIZE_DEFAULT).await.inspect_err(|e| {
191-
error!(relay_id = relay.id.as_ref(), retry, %e, "failed registration");
190+
safe_read_http_response(res, MAX_SIZE_DEFAULT).await.inspect_err(|err| {
191+
error!(relay_id = relay.id.as_ref(), retry, %err, "failed registration");
192192
})?;
193193

194194
debug!(

‎crates/pbs/src/mev_boost/status.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,8 +73,8 @@ async fn send_relay_check(relay: &RelayClient, headers: HeaderMap) -> Result<(),
7373
let code = res.status();
7474
RELAY_STATUS_CODE.with_label_values(&[code.as_str(), STATUS_ENDPOINT_TAG, &relay.id]).inc();
7575

76-
safe_read_http_response(res, MAX_SIZE_DEFAULT).await.inspect_err(|e| {
77-
error!(relay_id = relay.id.as_ref(), %e, "status failed");
76+
safe_read_http_response(res, MAX_SIZE_DEFAULT).await.inspect_err(|err| {
77+
error!(relay_id = relay.id.as_ref(), %err, "status failed");
7878
})?;
7979

8080
debug!(relay_id = relay.id.as_ref(),?code, latency = ?request_latency, "status passed");

‎crates/pbs/src/mev_boost/submit_block.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -203,8 +203,8 @@ async fn send_submit_block(
203203

204204
let response_bytes = safe_read_http_response(res, MAX_SIZE_SUBMIT_BLOCK_RESPONSE)
205205
.await
206-
.inspect_err(|e| {
207-
warn!(relay_id = relay.id.as_ref(), retry, %e, "failed to get payload (this might be ok if other relays have it)");
206+
.inspect_err(|err| {
207+
warn!(relay_id = relay.id.as_ref(), retry, %err, "failed to get payload (this might be ok if other relays have it)");
208208
})?;
209209

210210
if api_version != &BuilderApiVersion::V1 {

0 commit comments

Comments
 (0)