Debug

Author: pawanjay176

builder-server/src/server.rs

@@ -78,6 +78,7 @@ where
     let slot = block.slot();
     let res = api_impl.as_ref().submit_blinded_block(block).await;
 
+    dbg!("in submit_blinded_block");
     build_response_with_headers(res, content_type, api_impl.as_ref().fork_name_at_slot(slot)).await
 }
 
@@ -114,5 +115,6 @@ where
         .as_ref()
         .get_header(slot, parent_hash, pubkey)
         .await;
+    tracing::info!("Got response from builder, constructing response");
     build_response_with_headers(res, content_type, api_impl.as_ref().fork_name_at_slot(slot)).await
 }

common/src/lib.rs

@@ -32,6 +32,14 @@ where
 
     let resp = match result {
         Ok(body) => {
+            tracing::info!(
+                "Got a valid response from builder, content-type {:?}",
+                content_type
+            );
+            println!(
+                "Got a valid response from builder, content-type {:?}",
+                content_type
+            );
             let mut response = response_builder.status(200);
 
             if let Some(response_headers) = response.headers_mut() {
@@ -78,11 +86,14 @@ where
                         StatusCode::INTERNAL_SERVER_ERROR
                     })?,
             };
-
-            response.body(Body::from(body_content)).map_err(|e| {
+            dbg!(&body_content.len());
+            let resp = response.body(Body::from(body_content)).map_err(|e| {
                 error!(error = ?e);
+                dbg!(&e);
                 StatusCode::INTERNAL_SERVER_ERROR
-            })
+            });
+            dbg!(&resp);
+            resp
         }
         Err(body) => {
             let mut response = response_builder.status(body.code);
@@ -241,9 +252,9 @@ where
         let content_type = headers
             .get(CONTENT_TYPE)
             .and_then(|value| value.to_str().ok());
-
+        dbg!(&headers);
         let fork_name = headers
-            .get("")
+            .get(CONSENSUS_VERSION_HEADER)
             .and_then(|value| ForkName::from_str(value.to_str().unwrap()).ok());
 
         let bytes = Bytes::from_request(req, _state)
@@ -363,7 +374,7 @@ where
 }
 
 // Headers
-#[derive(Default, Clone, Copy)]
+#[derive(Default, Clone, Copy, Debug)]
 pub enum ContentType {
     #[default]
     Json,
@@ -540,3 +551,43 @@ impl FromStr for Accept {
         accept_type.ok_or_else(|| "accept header is not supported".to_string())
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use std::usize;
+
+    use super::*;
+    use axum::body::to_bytes;
+    use beacon_api_types::{
+        Blob, BlobsBundle, EthSpec, ExecutionPayload, ExecutionPayloadAndBlobs,
+        ExecutionPayloadDeneb, FullPayloadContents, KzgCommitment, KzgProof, MainnetEthSpec,
+    };
+
+    #[tokio::test]
+    async fn test_something() {
+        let payload_and_blobs: ExecutionPayloadAndBlobs<MainnetEthSpec> =
+            ExecutionPayloadAndBlobs {
+                blobs_bundle: BlobsBundle {
+                    commitments: vec![KzgCommitment::empty_for_testing()].into(),
+                    proofs: vec![KzgProof::empty()].into(),
+                    blobs: vec![Blob::<MainnetEthSpec>::new(vec![
+                        42;
+                        MainnetEthSpec::bytes_per_blob()
+                    ])
+                    .unwrap()]
+                    .into(),
+                },
+                execution_payload: ExecutionPayload::Deneb(ExecutionPayloadDeneb {
+                    ..Default::default()
+                }),
+            };
+        let full_payload = FullPayloadContents::PayloadAndBlobs(payload_and_blobs);
+        let resp = build_response_with_headers(Ok(full_payload), ContentType::Ssz, ForkName::Deneb)
+            .await
+            .unwrap();
+        let body = to_bytes(resp.into_body(), usize::MAX).await.unwrap();
+        dbg!(&body.len());
+        FullPayloadContents::<MainnetEthSpec>::from_ssz_bytes_by_fork(&body, ForkName::Deneb)
+            .unwrap();
+    }
+}