beacon

type AttestationInfo struct {
	AggregationBits bitfield.Bitlist
	SlotIndex       uint64
	// Committees represented by AggregationBits
	Committees bitfield.Bitvector64
}

type BeaconBlock struct {
	Slot                 uint64
	ProposerIndex        string
	HasExecutionPayload  bool
	Attestations         []AttestationInfo
	FeeRecipient         common.Address
	ExecutionBlockNumber uint64
	ExecutionBlockHash   common.Hash
	Withdrawals          []WithdrawalInfo
}

type BeaconBlockHeader struct {
	Slot          uint64
	ProposerIndex string
}

type BeaconBlockSSZ struct {
	Data io.ReadCloser
	Size int64
	Fork string
}

type BeaconClientType int

type BeaconHead struct {
	Epoch                  uint64
	FinalizedEpoch         uint64
	JustifiedEpoch         uint64
	PreviousJustifiedEpoch uint64
}

type BeaconStateSSZ struct {
	Data io.ReadCloser
	Size int64
	Fork string
}

type Client interface {
	GetClientType() (BeaconClientType, error)
	GetSyncStatus() (SyncStatus, error)
	GetEth2Config() (Eth2Config, error)
	GetEth2DepositContract() (Eth2DepositContract, error)
	GetAttestations(blockId string) ([]AttestationInfo, bool, error)
	GetBeaconBlock(blockId string) (BeaconBlock, bool, error)
	GetBeaconBlockHeader(blockId string) (BeaconBlockHeader, bool, error)
	GetBeaconHead() (BeaconHead, error)
	GetValidatorStatusByIndex(index string, opts *ValidatorStatusOptions) (ValidatorStatus, error)
	GetValidatorStatus(pubkey types.ValidatorPubkey, opts *ValidatorStatusOptions) (ValidatorStatus, error)
	GetAllValidators() ([]ValidatorStatus, error)
	GetValidatorStatuses(pubkeys []types.ValidatorPubkey, opts *ValidatorStatusOptions) (map[types.ValidatorPubkey]ValidatorStatus, error)
	GetValidatorIndex(pubkey types.ValidatorPubkey) (string, error)
	GetValidatorSyncDuties(indices []string, epoch uint64) (map[string]bool, error)
	GetValidatorProposerDuties(indices []string, epoch uint64) (map[string]uint64, error)
	GetValidatorBalances(indices []string, opts *ValidatorStatusOptions) (map[string]*big.Int, error)
	GetValidatorBalancesSafe(indices []string, opts *ValidatorStatusOptions) (map[string]*big.Int, error)
	GetDomainData(domainType []byte, epoch uint64, useGenesisFork bool) ([]byte, error)
	ExitValidator(validatorIndex string, epoch uint64, signature types.ValidatorSignature) error
	Close() error
	GetEth1DataForEth2Block(blockId string) (Eth1Data, bool, error)
	GetCommitteesForEpoch(epoch *uint64) (Committees, error)
	ChangeWithdrawalCredentials(validatorIndex string, fromBlsPubkey types.ValidatorPubkey, toExecutionAddress common.Address, signature types.ValidatorSignature) error

	GetBeaconStateSSZ(slot uint64) (*BeaconStateSSZ, error)
	GetBeaconBlockSSZ(slot uint64) (*BeaconBlockSSZ, bool, error)
}

type Committees interface {
	// Index returns the index of the committee at the provided offset
	Index(int) uint64
	// Slot returns the slot of the committee at the provided offset
	Slot(int) uint64
	// Validators returns the list of validators of the committee at
	// the provided offset
	Validators(int) []string
	// ValidatorCount returns the number of validators in the committee at
	// the provided offset
	ValidatorCount(int) int
	// Count returns the number of committees in the response
	Count() int
	// Release returns the reused validators slice buffer to the pool for
	// further reuse, and must be called when the user is done with this
	// committees instance
	Release()
}

type Eth1Data struct {
	DepositRoot  common.Hash
	DepositCount uint64
	BlockHash    common.Hash
}

type Eth2Config struct {
	GenesisForkVersion           []byte `json:"genesis_fork_version"`
	GenesisValidatorsRoot        []byte `json:"genesis_validators_root"`
	GenesisEpoch                 uint64 `json:"genesis_epoch"`
	GenesisTime                  uint64 `json:"genesis_time"`
	SecondsPerSlot               uint64 `json:"seconds_per_slot"`
	SlotsPerEpoch                uint64 `json:"slots_per_epoch"`
	SecondsPerEpoch              uint64 `json:"seconds_per_epoch"`
	EpochsPerSyncCommitteePeriod uint64 `json:"epochs_per_sync_committee_period"`
	ShardCommitteePeriod         uint64 `json:"shard_committee_period"`
}

type Eth2DepositContract struct {
	ChainID uint64
	Address common.Address
}

type ExecutionHeaderSource interface {
	// HeaderByHash returns the block header with the given hash.
	HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)
}

type SyncStatus struct {
	Syncing  bool
	Progress float64
}

type ValidatorState string

type ValidatorStatus struct {
	Pubkey                     types.ValidatorPubkey `json:"pubkey"`
	Index                      string                `json:"index"`
	WithdrawalCredentials      common.Hash           `json:"withdrawal_credentials"`
	Balance                    uint64                `json:"balance"`
	Status                     ValidatorState        `json:"status"`
	EffectiveBalance           uint64                `json:"effective_balance"`
	Slashed                    bool                  `json:"slashed"`
	ActivationEligibilityEpoch uint64                `json:"activation_eligibility_epoch"`
	ActivationEpoch            uint64                `json:"activation_epoch"`
	ExitEpoch                  uint64                `json:"exit_epoch"`
	WithdrawableEpoch          uint64                `json:"withdrawable_epoch"`
	Exists                     bool                  `json:"exists"`
}

type ValidatorStatusOptions struct {
	Epoch *uint64
	Slot  *uint64
}

type WithdrawalInfo struct {
	ValidatorIndex string
	Address        common.Address
	Amount         *big.Int
}