WIP

Author: shousper

Cargo.toml

@@ -11,34 +11,40 @@ members = [
   "relay-server",
   "searcher-api-types",
   "searcher-client",
-  "common"
+  "common",
 ]
 
 [workspace.dependencies]
 async-trait = "0.1"
 axum = { version = "0.8", features = ["ws"] }
 bytes = "1.6"
-eth2 = { git = "https://github.com/cakevm/lighthouse", rev="68776b6" }
+eth2 = { git = "https://github.com/cakevm/lighthouse", rev = "68776b6" }
 ethereum_serde_utils = "0.8.0"
 ethereum_ssz = "0.9.0"
 ethereum_ssz_derive = "0.9.0"
 eyre = "0.6.12"
 flate2 = "1.0"
 futures = "0.3.30"
-http = "1.2"
-jsonrpsee = "0.24.9"
-jsonrpsee-core = "0.24.9"
+http = "1.3"
+jsonrpsee = "0.25.1"
+jsonrpsee-core = "0.25.1"
 mediatype = "0.19.13"
-reqwest = { version = "0.12.12", features = ["json"] }
+reqwest = { version = "0.12.19", features = ["json"] }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = { version = "1", features = ["raw_value"] }
 serde_with = "3.12.0"
 superstruct = "0.9.0"
-tokio = { version = "1", default-features = false, features = ["signal", "rt-multi-thread", "macros"] }
-tokio-tungstenite = "0.24.0"
+tokio = { version = "1", default-features = false, features = [
+  "signal",
+  "rt-multi-thread",
+  "macros",
+] }
+tokio-tungstenite = "0.26.2"
 tracing = { version = "0.1", features = ["attributes"] }
 url = "2.5.4"
 
 alloy-primitives = "1.0.0"
 alloy-rlp = "0.3.11"
-alloy-rpc-types-mev = "0.14.0"
+alloy-rpc-types-mev = "1.0.9"
+alloy-rpc-types-beacon = "1.0.9"
+alloy-rpc-types-engine = "1.0.9"

builder-server/Cargo.toml

@@ -6,17 +6,12 @@ edition = "2021"
 [dependencies]
 async-trait.workspace = true
 axum.workspace = true
-bytes.workspace = true
-ethereum_ssz.workspace = true
-flate2.workspace = true
-futures.workspace = true
 http.workspace = true
 builder-api-types = { path = "../builder-api-types" }
 ethereum-apis-common = { path = "../common" }
-serde.workspace = true
 serde_json.workspace = true
 tokio.workspace = true
-tracing.workspace = true
 
 [dev-dependencies]
 tower = "0.5.2"
+ethereum_ssz.workspace = true

common/Cargo.toml

@@ -4,12 +4,10 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-async-trait.workspace = true
 axum.workspace = true
 bytes.workspace = true
 ethereum_ssz.workspace = true
 flate2.workspace = true
-futures.workspace = true
 http.workspace = true
 mediatype.workspace = true
 serde.workspace = true

relay-api-types/Cargo.toml

@@ -9,4 +9,6 @@ ethereum_serde_utils.workspace = true
 ethereum_ssz.workspace = true
 ethereum_ssz_derive.workspace = true
 serde.workspace = true
-superstruct.workspace = true
+
+# Alloy dependencies
+alloy-rpc-types-beacon = { workspace = true, features = ["ssz"] }

relay-api-types/src/lib.rs

@@ -103,7 +103,7 @@ impl RelayClient {
     pub async fn submit_block<E>(
         &self,
         query_params: &SubmitBlockQueryParams,
-        body: &SubmitBlockRequest<E>,
+        body: &SubmitBlockRequest,
         content_type: ContentType,
         content_encoding: ContentEncoding,
     ) -> Result<(), Error>
@@ -219,7 +219,7 @@ impl RelayClient {
     pub async fn submit_block_optimistic_v2<E>(
         &self,
         query_params: &SubmitBlockQueryParams,
-        body: &SubmitBlockRequest<E>,
+        body: &SubmitBlockRequest,
         content_type: ContentType,
         content_encoding: ContentEncoding,
     ) -> Result<(), Error>
@@ -281,7 +281,7 @@ impl RelayClient {
             match message {
                 Ok(Message::Text(text)) => match serde_json::from_str::<TopBidUpdate>(&text) {
                     Ok(update) => Some(Ok(update)),
-                    Err(e) => Some(Err(Error::InvalidJson(e, text))),
+                    Err(e) => Some(Err(Error::InvalidJson(e, text.as_str().to_string()))),
                 },
                 Ok(Message::Binary(bin)) => match serde_json::from_slice::<TopBidUpdate>(&bin) {
                     Ok(update) => Some(Ok(update)),

relay-client/src/lib.rs

@@ -6,14 +6,10 @@ edition = "2021"
 [dependencies]
 async-trait.workspace = true
 axum.workspace = true
-bytes.workspace = true
-ethereum_ssz.workspace = true
 ethereum-apis-common = { path = "../common" }
-flate2.workspace = true
 futures.workspace = true
 http.workspace = true
 relay-api-types = { path = "../relay-api-types" }
-serde.workspace = true
 serde_json.workspace = true
 tokio.workspace = true
 tracing.workspace = true

relay-server/Cargo.toml

@@ -22,7 +22,7 @@ pub trait Builder<E: EthSpec> {
     async fn submit_block(
         &self,
         query_params: SubmitBlockQueryParams,
-        body: SubmitBlockRequest<E>,
+        body: SubmitBlockRequest,
     ) -> Result<(), ErrorResponse>;
     /// Submit a new block header to the relay.
     ///
@@ -39,7 +39,7 @@ pub trait Builder<E: EthSpec> {
     async fn submit_block_optimistic_v2(
         &self,
         query_params: SubmitBlockQueryParams,
-        body: SubmitBlockRequest<E>,
+        body: SubmitBlockRequest,
     ) -> Result<(), ErrorResponse>;
 
     /// Submit a cancellation for all bids.

relay-server/src/builder.rs

@@ -62,7 +62,7 @@ where
 async fn submit_block<I, A, E>(
     Query(query_params): Query<SubmitBlockQueryParams>,
     State(api_impl): State<I>,
-    JsonOrSszMaybeGzipped(body): JsonOrSszMaybeGzipped<SubmitBlockRequest<E>>,
+    JsonOrSszMaybeGzipped(body): JsonOrSszMaybeGzipped<SubmitBlockRequest>,
 ) -> Result<Response<Body>, StatusCode>
 where
     E: EthSpec,
@@ -78,7 +78,7 @@ where
 async fn submit_block_optimistic_v2<I, A, E>(
     Query(query_params): Query<SubmitBlockQueryParams>,
     State(api_impl): State<I>,
-    JsonOrSszMaybeGzipped(body): JsonOrSszMaybeGzipped<SubmitBlockRequest<E>>,
+    JsonOrSszMaybeGzipped(body): JsonOrSszMaybeGzipped<SubmitBlockRequest>,
 ) -> Result<Response<Body>, StatusCode>
 where
     E: EthSpec,

relay-server/src/server.rs

@@ -50,7 +50,7 @@ mod test {
         let resp = res.unwrap();
         assert_eq!(
             resp.bundle_hash.to_string(),
-            "0xbfe05fa7cb2f9de981eeefe7246c9c9be6f69c3a3b33a05fdbf6afac42ddd294"
+            "0x09ea03143e742135ad06cac0b440f94c2113fbb99bd50710459b1815ea8994cf"
         );
     }
 }