interfaces

type Arbitrators interface {
	NewBlocksListener

	StartUp() error
	ForceChange() error

	GetArbitrators() [][]byte
	GetCandidates() [][]byte
	GetNextArbitrators() [][]byte
	GetNextCandidates() [][]byte

	GetArbitratorsProgramHashes() []*common.Uint168
	GetCandidatesProgramHashes() []*common.Uint168

	GetOnDutyArbitrator() []byte
	GetNextOnDutyArbitrator(offset uint32) []byte

	HasArbitersMajorityCount(num uint32) bool
	HasArbitersMinorityCount(num uint32) bool

	RegisterListener(listener ArbitratorsListener)
	UnregisterListener(listener ArbitratorsListener)
}

type ArbitratorsListener interface {
	OnNewElection(arbiters [][]byte)
}

type DBTable struct {
	// name of table
	Name string

	// primary key range from 1 to len(table.Fields)
	// if give other value, will use default rowID as primary key only
	PrimaryKey uint64

	// database index range from 1 to len(table.Fields)
	// if give values not in scope, the database index will not be effective
	Indexes []uint64

	// field name of table
	Fields []string
}

type DirectPeers struct {
	PublicKey []byte
	Address   string
	Sequence  uint32
}

type Field struct {
	Name  string
	Value interface{}
}

type HeightVersions interface {
	GetDefaultTxVersion(blockHeight uint32) byte
	GetDefaultBlockVersion(blockHeight uint32) uint32

	CheckOutputPayload(blockHeight uint32, tx *types.Transaction, output *types.Output) error
	CheckOutputProgramHash(blockHeight uint32, tx *types.Transaction, programHash common.Uint168) error
	CheckCoinbaseMinerReward(blockHeight uint32, tx *types.Transaction, totalReward common.Fixed64) error
	CheckCoinbaseArbitratorsReward(blockHeight uint32, coinbase *types.Transaction, rewardInCoinbase common.Fixed64) error
	CheckVoteProducerOutputs(blockHeight uint32, tx *types.Transaction, outputs []*types.Output,
		references map[*types.Input]*types.Output, producers [][]byte) error
	CheckTxHasNoPrograms(blockHeight uint32, tx *types.Transaction) error

	GetProducersDesc(block *types.Block) ([][]byte, error)
	AddBlock(block *types.Block) (bool, bool, error)
	AddDposBlock(block *types.DposBlock) (bool, bool, error)
	AssignCoinbaseTxRewards(block *types.Block, totalReward common.Fixed64) error
	CheckConfirmedBlockOnFork(block *types.Block) error
	GetNextOnDutyArbitrator(blockHeight, dutyChangedCount, offset uint32) []byte
}

type IArbitratorsRecord interface {
	GetArbitrators(a Arbitrators) error
	SaveDposDutyChangedCount(count uint32)
	SaveCurrentArbitrators(a Arbitrators)
	SaveNextArbitrators(a Arbitrators)

	GetDirectPeers() ([]*DirectPeers, error)
	SaveDirectPeers(peers []*DirectPeers)
}

type IDBBasic interface {
	InitConnection(connParams ...interface{}) error
	Disconnect() error
}

type IDBOperator interface {
	IDBBasic

	Create(table *DBTable) error
	Insert(table *DBTable, fields []*Field) (uint64, error)
	Select(table *DBTable, inputFields []*Field) ([][]*Field, error)
	Update(table *DBTable, inputFields []*Field, updateFields []*Field) ([]uint64, error)

	SelectID(table *DBTable, inputFields []*Field) ([]uint64, error)
}

type IDposStore interface {
	IDBOperator
	IEventRecord
	IArbitratorsRecord
}

type IEventRecord interface {
	AddProposalEvent(event interface{}) error
	UpdateProposalEvent(event interface{}) error
	AddVoteEvent(event interface{}) error
	AddViewEvent(event interface{}) error
	AddConsensusEvent(event interface{}) error
	UpdateConsensusEvent(event interface{}) error
}

type NewBlocksListener interface {
	OnBlockReceived(b *types.Block, confirmed bool)
	OnConfirmReceived(p *types.DPosProposalVoteSlot)
}