storage

type FilteredSharesFunc = func(logger *zap.Logger, f func(share *types.SSVShare) bool) ([]*types.SSVShare, error)

type GetOperatorData = func(index uint64) (*OperatorData, bool, error)

type OperatorData struct {
	ID           spectypes.OperatorID `json:"id"`
	PublicKey    []byte               `json:"publicKey"`
	OwnerAddress common.Address       `json:"ownerAddress"`
}

type Operators interface {
	GetOperatorDataByPubKey(logger *zap.Logger, operatorPubKey []byte) (*OperatorData, bool, error)
	GetOperatorData(id spectypes.OperatorID) (*OperatorData, bool, error)
	SaveOperatorData(logger *zap.Logger, operatorData *OperatorData) (bool, error)
	DeleteOperatorData(id spectypes.OperatorID) error
	ListOperators(logger *zap.Logger, from uint64, to uint64) ([]OperatorData, error)
	GetOperatorsPrefix() []byte
}

type RecipientData struct {
	Owner        common.Address             `json:"ownerAddress"`
	FeeRecipient bellatrix.ExecutionAddress `json:"feeRecipientAddress"`
}

type Recipients interface {
	GetRecipientData(owner common.Address) (*RecipientData, bool, error)
	GetRecipientDataMany(logger *zap.Logger, owners []common.Address) (map[common.Address]bellatrix.ExecutionAddress, error)
	SaveRecipientData(recipientData *RecipientData) (*RecipientData, error)
	DeleteRecipientData(owner common.Address) error
	GetRecipientsPrefix() []byte
}

type Shares interface {
	eth1.RegistryStore

	SaveShare(logger *zap.Logger, share *types.SSVShare) error
	SaveShareMany(logger *zap.Logger, shares []*types.SSVShare) error
	GetShare(key []byte) (*types.SSVShare, bool, error)
	GetAllShares(logger *zap.Logger) ([]*types.SSVShare, error)
	GetFilteredShares(logger *zap.Logger, f func(share *types.SSVShare) bool) ([]*types.SSVShare, error)
	DeleteShare(key []byte) error
}