controller

type Controller struct {
	Ctx context.Context

	Logger                 *zap.Logger
	InstanceStorage        qbftstorage.InstanceStore
	ChangeRoundStorage     qbftstorage.ChangeRoundStore
	Network                p2pprotocol.Network
	InstanceConfig         *qbft.InstanceConfig
	ValidatorShare         *beaconprotocol.Share
	Identifier             []byte
	Fork                   forks.Fork
	Beacon                 beaconprotocol.Beacon
	KeyManager             spectypes.KeyManager
	HigherReceivedMessages map[spectypes.OperatorID]specqbft.Height

	// lockers
	CurrentInstanceLock *sync.RWMutex // not locker interface in order to avoid casting to RWMutex
	ForkLock            sync.Locker

	// signature
	SignatureState SignatureState

	// config
	SyncRateLimit time.Duration
	MinPeers      int

	// state
	State uint32

	// flags
	ReadMode bool

	Q msgqueue.MsgQueue

	DecidedFactory  *factory.Factory
	DecidedStrategy strategy.Decided
	// contains filtered or unexported fields
}

type Controllers map[spectypes.BeaconRole]IController

type IController interface {
	// Init should be called after creating an IController instance to init the instance, sync it, etc.
	Init() error

	// StartInstance starts a new instance by the given options
	StartInstance(opts instance.ControllerStartInstanceOptions, getInstance func(instance instance.Instancer)) (*instance.Result, error)

	// NextHeightNumber returns the previous decided instance seq number + 1
	// In case it's the first instance it returns 0
	NextHeightNumber() (specqbft.Height, error)

	// GetIBFTCommittee returns a map of the iBFT committee where the key is the member's id.
	GetIBFTCommittee() map[spectypes.OperatorID]*beaconprotocol.Node

	// GetIdentifier returns ibft identifier made of public key and role (type)
	GetIdentifier() []byte

	ProcessMsg(msg *spectypes.SSVMessage) error

	// ProcessPostConsensusMessage aggregates partial signature messages and broadcasting when quorum achieved
	ProcessPostConsensusMessage(msg *specssv.SignedPartialSignatureMessage) error

	// PostConsensusDutyExecution signs the eth2 duty after iBFT came to consensus and start signature state
	PostConsensusDutyExecution(logger *zap.Logger, decidedValue []byte, signaturesCount int, duty spectypes.BeaconRole) error

	// OnFork called when fork occur.
	OnFork(forkVersion forksprotocol.ForkVersion) error

	// GetCurrentInstance returns current instance if exist. if not, returns nil TODO for mapping, need to remove once duty runner implemented
	GetCurrentInstance() instance.Instancer
}

type MessageHandler func(msg *spectypes.SSVMessage) error

type NewDecidedHandler func(msg *specqbft.SignedMessage)

type Options struct {
	Context           context.Context
	Role              spectypes.BeaconRole
	Identifier        []byte
	Logger            *zap.Logger
	Storage           qbftstorage.QBFTStore
	Network           p2pprotocol.Network
	InstanceConfig    *qbft.InstanceConfig
	ValidatorShare    *beaconprotocol.Share
	Version           forksprotocol.ForkVersion
	Beacon            beaconprotocol.Beacon
	KeyManager        spectypes.KeyManager
	SyncRateLimit     time.Duration
	SigTimeout        time.Duration
	MinPeers          int
	ReadMode          bool
	FullNode          bool
	NewDecidedHandler NewDecidedHandler
}

type SignatureState struct {
	SignatureCollectionTimeout time.Duration
	// contains filtered or unexported fields
}

type TimerState int