Method queryElBlockNumberAndKzg

ethstorage/archiver/api.go:167–196

(queryUrl string)

}

func (a *API) queryElBlockNumberAndKzg(queryUrl string) (uint64, []string, *httpError) {
	resp, err := http.Get(queryUrl)
	if err != nil {
		return 0, nil, errServerError
	}
	defer resp.Body.Close()

	respObj := &struct {
		Data struct {
			Message struct {
				Body struct {
					ExecutionPayload struct {
						BlockNumber string `json:"block_number"`
					} `json:"execution_payload"`
					BlobKzgCommitments []string `json:"blob_kzg_commitments"`
				} `json:"body"`
			} `json:"message"`
		} `json:"data"`
	}{}
	err = json.NewDecoder(resp.Body).Decode(&respObj)
	if err != nil {
		return 0, nil, errUnknownBlock
	}
	body := respObj.Data.Message.Body
	elBlock, err := strconv.ParseUint(body.ExecutionPayload.BlockNumber, 10, 64)
	if err != nil {
		return 0, nil, errUnknownBlock
	}
	return elBlock, body.BlobKzgCommitments, nil
}

// Deprecated since Fusaka
func (a *API) buildSidecar(kvIndex uint64, kzgCommitment []byte, blobHash common.Hash) (*BlobSidecar, *httpError) {