types

type Handler interface {
	// MessageType return the message type which the handler want to collect
	MessageType() MessageType
	// GetRequiredMessageCount gets required message count in this round
	GetRequiredMessageCount() uint32
	// IsHandled checks if the id's message is handled before
	IsHandled(logger log.Logger, id string) bool
	// HandleMessage handles the message
	HandleMessage(logger log.Logger, msg Message) error
	// Finalize finalizes the result based on the collected messages and return the next handler.
	// If next handler is nil, it means it's the end of the main process
	Finalize(logger log.Logger) (Handler, error)
}

type MainState uint32

type Message interface {
	// GetId returns the message id
	GetId() string
	// GetMessageType returns the message type
	GetMessageType() MessageType
	// IsValid checks if message is valid or not
	IsValid() bool
}

type MessageMain interface {
	AddMessage(senderId string, msg Message) error
	GetHandler() Handler
	GetState() MainState
	Start()
	Stop()
}

type MessageType int32

type PeerManager interface {
	NumPeers() uint32
	PeerIDs() []string
	SelfID() string
	MustSend(id string, msg interface{})
}

type StateChangedListener interface {
	OnStateChanged(oldState MainState, newState MainState)
}