Implement /beacon/headers endpoint (#8966)

prysmaticlabs · Jun 1, 2021 · d71033f · d71033f
1 parent f112e14
commit d71033f
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/shared/gateway/api_middleware.go b/shared/gateway/api_middleware.go
@@ -63,6 +63,7 @@ func (m *ApiProxyMiddleware) Run() error {
 	m.handleApiEndpoint("/eth/v1/beacon/states/{state_id}/validators/{validator_id}")
 	m.handleApiEndpoint("/eth/v1/beacon/states/{state_id}/validator_balances")
 	m.handleApiEndpoint("/eth/v1/beacon/states/{state_id}/committees")
+	m.handleApiEndpoint("/eth/v1/beacon/headers")
 	m.handleApiEndpoint("/eth/v1/beacon/headers/{block_id}")
 	m.handleApiEndpoint("/eth/v1/beacon/blocks")
 	m.handleApiEndpoint("/eth/v1/beacon/blocks/{block_id}")
@@ -614,6 +615,12 @@ func getEndpointData(endpoint string) (endpointData, error) {
 			getResponse:           &StateCommitteesResponseJson{},
 			err:                   &DefaultErrorJson{},
 		}, nil
+	case "/eth/v1/beacon/headers":
+		return endpointData{
+			getRequestQueryParams: []queryParam{{name: "slot"}, {name: "parent_root", hex: true}},
+			getResponse:           &BlockHeadersResponseJson{},
+			err:                   &DefaultErrorJson{},
+		}, nil
 	case "/eth/v1/beacon/headers/{block_id}":
 		return endpointData{getResponse: &BlockHeaderResponseJson{}, err: &DefaultErrorJson{}}, nil
 	case "/eth/v1/beacon/blocks":

diff --git a/shared/gateway/middleware_structs.go b/shared/gateway/middleware_structs.go
@@ -59,6 +59,11 @@ type StateCommitteesResponseJson struct {
 	Data []*CommitteeJson `json:"data"`
 }
 
+// BlockHeadersResponseJson is used in /beacon/headers API endpoint.
+type BlockHeadersResponseJson struct {
+	Data []*BlockHeaderContainerJson `json:"data"`
+}
+
 // BlockHeaderResponseJson is used in /beacon/headers/{block_id} API endpoint.
 type BlockHeaderResponseJson struct {
 	Data *BlockHeaderContainerJson `json:"data"`