Ssz state (#1749)

## Issue Addressed

NA

## Proposed Changes

Adds a `lighthouse/beacon/states/:state_id/ssz` endpoint to allow us to pull the genesis state from the API.

## Additional Info

NA

beacon_node/http_api/Cargo.toml

@@ -24,6 +24,7 @@ lighthouse_metrics = { path = "../../common/lighthouse_metrics" }
 lazy_static = "1.4.0"
 warp_utils = { path = "../../common/warp_utils" }
 slot_clock = { path = "../../common/slot_clock" }
+eth2_ssz = { path = "../../consensus/ssz" }
 bs58 = "0.3.1"
 
 [dev-dependencies]

beacon_node/http_api/src/lib.rs

@@ -28,6 +28,7 @@ use parking_lot::Mutex;
 use serde::{Deserialize, Serialize};
 use slog::{crit, error, info, trace, warn, Logger};
 use slot_clock::SlotClock;
+use ssz::Encode;
 use state_id::StateId;
 use state_processing::per_slot_processing;
 use std::borrow::Cow;
@@ -41,7 +42,7 @@ use types::{
     Hash256, ProposerSlashing, PublicKey, RelativeEpoch, SignedAggregateAndProof,
     SignedBeaconBlock, SignedVoluntaryExit, Slot, YamlConfig,
 };
-use warp::Filter;
+use warp::{http::Response, Filter};
 use warp_utils::task::{blocking_json_task, blocking_task};
 
 const API_PREFIX: &str = "eth";
@@ -1768,7 +1769,7 @@ pub fn serve<T: BeaconChainTypes>(
         .and(warp::path::param::<Epoch>())
         .and(warp::path("global"))
         .and(warp::path::end())
-        .and(chain_filter)
+        .and(chain_filter.clone())
         .and_then(|epoch: Epoch, chain: Arc<BeaconChain<T>>| {
             blocking_json_task(move || {
                 validator_inclusion::global_validator_inclusion_data(epoch, &chain)
@@ -1776,6 +1777,30 @@ pub fn serve<T: BeaconChainTypes>(
             })
         });
 
+    // GET lighthouse/beacon/states/{state_id}/ssz
+    let get_lighthouse_beacon_states_ssz = warp::path("lighthouse")
+        .and(warp::path("beacon"))
+        .and(warp::path("states"))
+        .and(warp::path::param::<StateId>())
+        .and(warp::path("ssz"))
+        .and(warp::path::end())
+        .and(chain_filter)
+        .and_then(|state_id: StateId, chain: Arc<BeaconChain<T>>| {
+            blocking_task(move || {
+                let state = state_id.state(&chain)?;
+                Response::builder()
+                    .status(200)
+                    .header("Content-Type", "application/ssz")
+                    .body(state.as_ssz_bytes())
+                    .map_err(|e| {
+                        warp_utils::reject::custom_server_error(format!(
+                            "failed to create response: {}",
+                            e
+                        ))
+                    })
+            })
+        });
+
     // Define the ultimate set of routes that will be provided to the server.
     let routes = warp::get()
         .and(
@@ -1818,6 +1843,7 @@ pub fn serve<T: BeaconChainTypes>(
                 .or(get_lighthouse_proto_array.boxed())
                 .or(get_lighthouse_validator_inclusion_global.boxed())
                 .or(get_lighthouse_validator_inclusion.boxed())
+                .or(get_lighthouse_beacon_states_ssz.boxed())
                 .boxed(),
         )
         .or(warp::post()

beacon_node/http_api/tests/tests.rs

@@ -1571,6 +1571,23 @@ impl ApiTester {
 
         self
     }
+
+    pub async fn test_get_lighthouse_beacon_states_ssz(self) -> Self {
+        for state_id in self.interesting_state_ids() {
+            let result = self
+                .client
+                .get_lighthouse_beacon_states_ssz(&state_id)
+                .await
+                .unwrap();
+
+            let mut expected = self.get_state(state_id);
+            expected.as_mut().map(|state| state.drop_all_caches());
+
+            assert_eq!(result, expected, "{:?}", state_id);
+        }
+
+        self
+    }
 }
 
 #[tokio::test(core_threads = 2)]
@@ -1871,5 +1888,7 @@ async fn lighthouse_endpoints() {
         .test_get_lighthouse_validator_inclusion()
         .await
         .test_get_lighthouse_validator_inclusion_global()
+        .await
+        .test_get_lighthouse_beacon_states_ssz()
         .await;
 }