mirror of
https://github.com/OffchainLabs/prysm.git
synced 2026-01-09 15:37:56 -05:00
98 lines
3.1 KiB
Go
98 lines
3.1 KiB
Go
package beacon_api
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"encoding/json"
|
|
"strconv"
|
|
|
|
"github.com/OffchainLabs/prysm/v7/api/server/structs"
|
|
"github.com/OffchainLabs/prysm/v7/consensus-types/primitives"
|
|
ethpb "github.com/OffchainLabs/prysm/v7/proto/prysm/v1alpha1"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
var beaconAPITogRPCValidatorStatus = map[string]ethpb.ValidatorStatus{
|
|
"pending_initialized": ethpb.ValidatorStatus_DEPOSITED,
|
|
"pending_queued": ethpb.ValidatorStatus_PENDING,
|
|
"active_ongoing": ethpb.ValidatorStatus_ACTIVE,
|
|
"active_exiting": ethpb.ValidatorStatus_EXITING,
|
|
"active_slashed": ethpb.ValidatorStatus_SLASHING,
|
|
"exited_unslashed": ethpb.ValidatorStatus_EXITED,
|
|
"exited_slashed": ethpb.ValidatorStatus_EXITED,
|
|
"withdrawal_possible": ethpb.ValidatorStatus_EXITED,
|
|
"withdrawal_done": ethpb.ValidatorStatus_EXITED,
|
|
}
|
|
|
|
func (c *beaconApiValidatorClient) fork(ctx context.Context) (*structs.GetStateForkResponse, error) {
|
|
const endpoint = "/eth/v1/beacon/states/head/fork"
|
|
|
|
stateForkResponseJson := &structs.GetStateForkResponse{}
|
|
|
|
if err := c.jsonRestHandler.Get(ctx, endpoint, stateForkResponseJson); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return stateForkResponseJson, nil
|
|
}
|
|
|
|
func (c *beaconApiValidatorClient) headers(ctx context.Context) (*structs.GetBlockHeadersResponse, error) {
|
|
const endpoint = "/eth/v1/beacon/headers"
|
|
|
|
blockHeadersResponseJson := &structs.GetBlockHeadersResponse{}
|
|
|
|
if err := c.jsonRestHandler.Get(ctx, endpoint, blockHeadersResponseJson); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return blockHeadersResponseJson, nil
|
|
}
|
|
|
|
func (c *beaconApiValidatorClient) liveness(ctx context.Context, epoch primitives.Epoch, validatorIndexes []string) (*structs.GetLivenessResponse, error) {
|
|
const endpoint = "/eth/v1/validator/liveness/"
|
|
url := endpoint + strconv.FormatUint(uint64(epoch), 10)
|
|
|
|
livenessResponseJson := &structs.GetLivenessResponse{}
|
|
|
|
marshalledJsonValidatorIndexes, err := json.Marshal(validatorIndexes)
|
|
if err != nil {
|
|
return nil, errors.Wrapf(err, "failed to marshal validator indexes")
|
|
}
|
|
|
|
if err = c.jsonRestHandler.Post(ctx, url, nil, bytes.NewBuffer(marshalledJsonValidatorIndexes), livenessResponseJson); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return livenessResponseJson, nil
|
|
}
|
|
|
|
func (c *beaconApiValidatorClient) syncing(ctx context.Context) (*structs.SyncStatusResponse, error) {
|
|
const endpoint = "/eth/v1/node/syncing"
|
|
|
|
syncingResponseJson := &structs.SyncStatusResponse{}
|
|
|
|
if err := c.jsonRestHandler.Get(ctx, endpoint, syncingResponseJson); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return syncingResponseJson, nil
|
|
}
|
|
|
|
func (c *beaconApiValidatorClient) isSyncing(ctx context.Context) (bool, error) {
|
|
response, err := c.syncing(ctx)
|
|
if err != nil || response == nil || response.Data == nil {
|
|
return true, errors.Wrapf(err, "failed to get syncing status")
|
|
}
|
|
|
|
return response.Data.IsSyncing, err
|
|
}
|
|
|
|
func (c *beaconApiValidatorClient) isOptimistic(ctx context.Context) (bool, error) {
|
|
response, err := c.syncing(ctx)
|
|
if err != nil || response == nil || response.Data == nil {
|
|
return true, errors.Wrapf(err, "failed to get syncing status")
|
|
}
|
|
|
|
return response.Data.IsOptimistic, err
|
|
}
|