erigon-pulse/cl/beacon/handler/blocks.go

package handler

import (
	"context"
	"database/sql"
	"fmt"
	"io"
	"net/http"

	libcommon "github.com/ledgerwatch/erigon-lib/common"
	"github.com/ledgerwatch/erigon/cl/clparams"
	"github.com/ledgerwatch/erigon/cl/cltypes"
	"github.com/ledgerwatch/erigon/cl/persistence/beacon_indicies"
	"github.com/ledgerwatch/erigon/cmd/sentinel/sentinel/communication/ssz_snappy"
)

type headerResponse struct {
	Root      libcommon.Hash                   `json:"root"`
	Canonical bool                             `json:"canonical"`
	Header    *cltypes.SignedBeaconBlockHeader `json:"header"`
}

type getHeadersRequest struct {
	Slot       *uint64         `json:"slot,omitempty"`
	ParentRoot *libcommon.Hash `json:"root,omitempty"`
}

func (a *ApiHandler) rootFromBlockId(ctx context.Context, tx *sql.Tx, blockId *segmentID) (root libcommon.Hash, httpStatusErr int, err error) {
	switch {
	case blockId.head():
		root, _, err = a.forkchoiceStore.GetHead()
		if err != nil {
			return libcommon.Hash{}, http.StatusInternalServerError, err
		}
	case blockId.finalized():
		root = a.forkchoiceStore.FinalizedCheckpoint().BlockRoot()
	case blockId.justified():
		root = a.forkchoiceStore.JustifiedCheckpoint().BlockRoot()
	case blockId.genesis():
		root, err = beacon_indicies.ReadCanonicalBlockRoot(ctx, tx, 0)
		if err != nil {
			return libcommon.Hash{}, http.StatusInternalServerError, err
		}
		if root == (libcommon.Hash{}) {
			return libcommon.Hash{}, http.StatusNotFound, fmt.Errorf("genesis block not found")
		}
	case blockId.getSlot() != nil:
		root, err = beacon_indicies.ReadCanonicalBlockRoot(ctx, tx, *blockId.getSlot())
		if err != nil {
			return libcommon.Hash{}, http.StatusInternalServerError, err
		}
		if root == (libcommon.Hash{}) {
			return libcommon.Hash{}, http.StatusNotFound, fmt.Errorf("block not found %d", *blockId.getSlot())
		}
	case blockId.getRoot() != nil:
		// first check if it exists
		root = *blockId.getRoot()
	default:
		return libcommon.Hash{}, http.StatusInternalServerError, fmt.Errorf("cannot parse block id")
	}
	return
}

func (a *ApiHandler) getBlock(r *http.Request) (data any, finalized *bool, version *clparams.StateVersion, httpStatus int, err error) {
	var (
		tx          *sql.Tx
		blockId     *segmentID
		root        libcommon.Hash
		blkHeader   *cltypes.SignedBeaconBlockHeader
		blockReader io.ReadCloser
		isCanonical bool
	)

	ctx := r.Context()

	tx, err = a.indiciesDB.BeginTx(ctx, &sql.TxOptions{ReadOnly: true})
	if err != nil {
		httpStatus = http.StatusInternalServerError
		return
	}
	defer tx.Rollback()

	blockId, err = blockIdFromRequest(r)
	if err != nil {
		httpStatus = http.StatusBadRequest
		return
	}
	root, httpStatus, err = a.rootFromBlockId(ctx, tx, blockId)
	if err != nil {
		return
	}
	blkHeader, isCanonical, err = beacon_indicies.ReadSignedHeaderByBlockRoot(ctx, tx, root)
	if err != nil {
		return
	}
	if blkHeader == nil {
		httpStatus = http.StatusNotFound
		err = fmt.Errorf("block not found %x", root)
		return
	}

	blockReader, err = a.blockSource.BlockReader(ctx, blkHeader.Header.Slot, root)
	if err != nil {
		return
	}
	defer blockReader.Close()
	blk := cltypes.NewSignedBeaconBlock(a.beaconChainCfg)
	version = new(clparams.StateVersion)
	*version = a.beaconChainCfg.GetCurrentStateVersion(blkHeader.Header.Slot / a.beaconChainCfg.SlotsPerEpoch)
	if err = ssz_snappy.DecodeAndReadNoForkDigest(blockReader, blk, *version); err != nil {
		return
	}
	data = blk
	finalized = new(bool)
	httpStatus = http.StatusAccepted
	*finalized = isCanonical && blkHeader.Header.Slot <= a.forkchoiceStore.FinalizedSlot()
	return
}

func (a *ApiHandler) getBlockAttestations(r *http.Request) (data any, finalized *bool, version *clparams.StateVersion, httpStatus int, err error) {
	var (
		tx          *sql.Tx
		blockId     *segmentID
		root        libcommon.Hash
		blkHeader   *cltypes.SignedBeaconBlockHeader
		blockReader io.ReadCloser
		isCanonical bool
	)

	ctx := r.Context()

	tx, err = a.indiciesDB.BeginTx(ctx, &sql.TxOptions{ReadOnly: true})
	if err != nil {
		httpStatus = http.StatusInternalServerError
		return
	}
	defer tx.Rollback()

	blockId, err = blockIdFromRequest(r)
	if err != nil {
		httpStatus = http.StatusBadRequest
		return
	}
	root, httpStatus, err = a.rootFromBlockId(ctx, tx, blockId)
	if err != nil {
		return
	}
	blkHeader, isCanonical, err = beacon_indicies.ReadSignedHeaderByBlockRoot(ctx, tx, root)
	if err != nil {
		return
	}
	if blkHeader == nil {
		httpStatus = http.StatusNotFound
		err = fmt.Errorf("block not found %x", root)
		return
	}

	blockReader, err = a.blockSource.BlockReader(ctx, blkHeader.Header.Slot, root)
	if err != nil {
		return
	}
	defer blockReader.Close()
	blk := cltypes.NewSignedBeaconBlock(a.beaconChainCfg)
	version = new(clparams.StateVersion)
	*version = a.beaconChainCfg.GetCurrentStateVersion(blkHeader.Header.Slot / a.beaconChainCfg.SlotsPerEpoch)
	if err = ssz_snappy.DecodeAndReadNoForkDigest(blockReader, blk, *version); err != nil {
		return
	}

	data = blk.Block.Body.Attestations
	finalized = new(bool)
	httpStatus = http.StatusAccepted
	*finalized = isCanonical && blkHeader.Header.Slot <= a.forkchoiceStore.FinalizedSlot()
	return
}

func (a *ApiHandler) getBlockRoot(r *http.Request) (data any, finalized *bool, version *clparams.StateVersion, httpStatus int, err error) {
	var (
		tx          *sql.Tx
		blockId     *segmentID
		root        libcommon.Hash
		blockSlot   uint64
		isCanonical bool
	)

	ctx := r.Context()

	tx, err = a.indiciesDB.BeginTx(ctx, &sql.TxOptions{ReadOnly: true})
	if err != nil {
		httpStatus = http.StatusInternalServerError
		return
	}
	defer tx.Rollback()

	blockId, err = blockIdFromRequest(r)
	if err != nil {
		httpStatus = http.StatusBadRequest
		return
	}
	root, httpStatus, err = a.rootFromBlockId(ctx, tx, blockId)
	if err != nil {
		return
	}

	// check if the root exist
	var blk *cltypes.SignedBeaconBlockHeader
	blk, isCanonical, err = beacon_indicies.ReadSignedHeaderByBlockRoot(ctx, a.indiciesDB, root)
	if err != nil {
		httpStatus = http.StatusInternalServerError
		return
	}
	if blk == nil {
		httpStatus = http.StatusNotFound
		err = fmt.Errorf("could not find block: %x", root)
		return
	}
	blockSlot = blk.Header.Slot

	// Pack the response
	finalized = new(bool)
	*finalized = isCanonical && blockSlot <= a.forkchoiceStore.FinalizedSlot()
	data = struct{ Root libcommon.Hash }{Root: root}
	httpStatus = http.StatusAccepted
	return
}