blsbft

type Actor interface {
	// GetConsensusName - retrieve consensus name
	GetConsensusName() string
	GetChainKey() string
	GetChainID() int
	// GetUserPublicKey - get user public key of loaded mining key
	GetUserPublicKey() *incognitokey.CommitteePublicKey
	// Start - start consensus
	Start() error
	// Stop - stop consensus
	Stop() error
	Destroy()
	// IsOngoing - check whether consensus is currently voting on a block
	IsStarted() bool
	// ProcessBFTMsg - process incoming BFT message
	ProcessBFTMsg(msg *wire.MessageBFT)
	// LoadUserKey - load user mining key
	LoadUserKeys(miningKey []signatureschemes2.MiningKey)
	// ValidateData - validate data with this consensus signature scheme
	ValidateData(data []byte, sig string, publicKey string) error
	// SignData - sign data with this consensus signature scheme
	SignData(data []byte) (string, error)
	BlockVersion() int
	SetBlockVersion(version int)
}

type ActorV2RuleBuilder struct {
	// contains filtered or unexported fields
}

type ActorV2RuleDirector struct {
	// contains filtered or unexported fields
}

type BFTPropose struct {
	PeerID                 string
	Block                  json.RawMessage
	ReProposeHashSignature string
	FinalityProof          FinalityProof
	BestBlockConsensusData map[int]types.BlockConsensusData
	POLC                   POLC
}

type BFTRequestBlock struct {
	BlockHash string
	PeerID    string
}

type BFTVote struct {
	Phase              string
	RoundKey           string
	PrevBlockHash      string
	BlockHeight        uint64
	BlockHash          string //this is propose block hash
	Hash               string //this is block hash
	Validator          string
	BLS                []byte
	BRI                []byte
	Confirmation       []byte
	IsValid            int // 0 not process, 1 valid, -1 not valid
	ProduceTimeSlot    int64
	ProposeTimeSlot    int64
	CommitteeFromBlock common.Hash
	ChainID            int
	// Portal v4
	PortalSigs []*portalprocessv4.PortalSig
}

type BlockValidation interface {
	types.BlockInterface
	AddValidationField(validationData string)
}

type ByzantineDetector struct {
	// contains filtered or unexported fields
}

type Chain interface {
	BestViewCommitteeFromBlock() common.Hash
	GetMultiView() multiview.MultiView
	GetFinalView() multiview.View
	GetBestView() multiview.View
	GetEpoch() uint64
	GetChainName() string
	GetConsensusType() string
	GetBlockConsensusData() map[int]types.BlockConsensusData
	GetLastBlockTimeStamp() int64
	GetMinBlkInterval() time.Duration
	GetMaxBlkCreateTime() time.Duration
	IsReady() bool
	SetReady(bool)
	GetActiveShardNumber() int
	CurrentHeight() uint64
	GetCommitteeSize() int
	IsBeaconChain() bool
	GetCommittee() []incognitokey.CommitteePublicKey
	GetPendingCommittee() []incognitokey.CommitteePublicKey
	GetPubKeyCommitteeIndex(string) int
	GetLastProposerIndex() int
	UnmarshalBlock(blockString []byte) (types.BlockInterface, error)
	CreateNewBlock(
		version int,
		proposer string,
		round int,
		startTime int64,
		committees []incognitokey.CommitteePublicKey,
		hash common.Hash) (types.BlockInterface, error)
	CreateNewBlockFromOldBlock(oldBlock types.BlockInterface, proposer string, startTime int64, isValidRePropose bool) (types.BlockInterface, error)
	InsertBlock(block types.BlockInterface, shouldValidate bool) error
	InsertAndBroadcastBlock(block types.BlockInterface) error
	InsertWithPrevValidationData(types.BlockInterface, string) error
	InsertAndBroadcastBlockWithPrevValidationData(types.BlockInterface, string) error
	ValidatePreSignBlock(block types.BlockInterface, signingCommittees, committees []incognitokey.CommitteePublicKey) error
	GetShardID() int
	GetChainDatabase() incdb.Database
	//for new syncker
	GetBestViewHeight() uint64
	GetFinalViewHeight() uint64
	GetBestViewHash() string
	GetFinalViewHash() string
	GetViewByHash(hash common.Hash) multiview.View
	CommitteeEngineVersion() int
	GetProposerByTimeSlotFromCommitteeList(ts int64, committees []incognitokey.CommitteePublicKey) (incognitokey.CommitteePublicKey, int)
	ReplacePreviousValidationData(previousBlockHash common.Hash, previousProposeBlockHash common.Hash, previousCommittee []incognitokey.CommitteePublicKey, newValidationData string) error
	// GetSigningCommitteesFromBestView must be retrieve from a shard view, because it's based on the committee state version
	GetSigningCommittees(
		proposerIndex int,
		committees []incognitokey.CommitteePublicKey,
		blockVersion int,
	) []incognitokey.CommitteePublicKey
	GetPortalParamsV4(beaconHeight uint64) portalv4.PortalParams
	GetBlockByHash(hash common.Hash) (types.BlockInterface, error)
	CollectTxs(view multiview.View)
}

type CommitteeChainHandler interface {
	CommitteesFromViewHashForShard(committeeHash common.Hash, shardID byte) ([]incognitokey.CommitteePublicKey, error)
	FinalView() multiview.View
}

type ConsensusError struct {
	Code    int
	Message string
	// contains filtered or unexported fields
}

type ConsensusValidatorLemma1 struct {
	// contains filtered or unexported fields
}

type ConsensusValidatorLemma2 struct {
	// contains filtered or unexported fields
}

type ConsensusValidatorNoValidate struct {
}

type FinalityProof struct {
	ReProposeHashSignature []string
}

type HandleVoteMessage struct {
}

type IActorV2RuleBuilder interface {
	SetProposeMessageRule(IProposeMessageRule)
	SetVoteRule(IVoteRule)
	SetCreateRule(ICreateNewBlockRule)
	SetValidatorRule(IConsensusValidator)
	SetHandleVoteMessageRule(IHandleVoteMessageRule)
	SetInsertBlockRule(IInsertBlockRule)
	ProposeMessageRule() IProposeMessageRule
	VoteRule() IVoteRule
	CreateRule() ICreateNewBlockRule
	ValidatorRule() IConsensusValidator
	HandleVoteMessageRule() IHandleVoteMessageRule
	InsertBlockRule() IInsertBlockRule
}

type IConsensusValidator interface {
	FilterValidProposeBlockInfo(bestViewHash common.Hash, bestViewHeight uint64, finalViewHeight uint64, currentTimeSlot int64, proposeBlockInfos map[string]*ProposeBlockInfo) ([]*ProposeBlockInfo, []*ProposeBlockInfo, []string)
	ValidateBlock(lastVotedBlock types.BlockInterface, isVoteNextHeight bool, proposeBlockInfo *ProposeBlockInfo) (bool, error)
	ValidateConsensusRules(lastVotedBlock types.BlockInterface, isVoteNextHeight bool, proposeBlockInfo *ProposeBlockInfo) bool
}

type ICreateNewBlockRule interface {
	CreateBlock(
		b58Str string,
		block types.BlockInterface,
		committees []incognitokey.CommitteePublicKey,
		committeeViewHash common.Hash,
		isValidRePropose bool,
		consensusName string,
		blockVersion int,
		currentTime int64,
		isRePropose bool,
	) (types.BlockInterface, error)
}

type IHandleVoteMessageRule interface {
	IsHandle() bool
}

type IInsertBlockRule interface {
	InsertBlock(block types.BlockInterface) error
	InsertWithPrevValidationData(types.BlockInterface, string) error
}

type IProposeMessageRule interface {
	HandleBFTProposeMessage(env *ProposeMessageEnvironment, propose *BFTPropose) (*ProposeBlockInfo, error)
	CreateProposeBFTMessage(env *SendProposeBlockEnvironment, block types.BlockInterface) (*BFTPropose, error)
	GetValidFinalityProof(block types.BlockInterface, currentTimeSlot int64) (*FinalityProof, bool, string)
	HandleCleanMem(finalView uint64)
	FinalityProof() map[string]map[int64]string
}

type IVoteRule interface {
	ValidateVote(*ProposeBlockInfo) *ProposeBlockInfo
	CreateVote(Chain, *VoteMessageEnvironment, types.BlockInterface) (*BFTVote, error)
}

type InsertAndBroadcastRule struct {
	// contains filtered or unexported fields
}

type InsertOnlyRule struct {
	// contains filtered or unexported fields
}

type NoHandleProposeMessageRule struct {
	// contains filtered or unexported fields
}

type NoHandleVoteMessage struct {
}

type NoVoteRule struct {
	// contains filtered or unexported fields
}

type NodeInterface interface {
	PushMessageToChain(msg wire.Message, chain common.ChainInterface) error
	PushBlockToAll(block types.BlockInterface, previousValidationData string, isBeacon bool) error
	IsEnableMining() bool
	GetMiningKeys() string
	GetPrivateKey() string
	GetUserMiningState() (role string, chainID int)
	RequestMissingViewViaStream(peerID string, hashes [][]byte, fromCID int, chainName string) (err error)
	GetSelfPeerID() peer.ID
}

type NormalCreateBlockRule struct {
	// contains filtered or unexported fields
}

type OnlyCreateBlockRule struct {
	// contains filtered or unexported fields
}

type POLC struct {
	Idx              []int
	Sig              [][]byte
	BlockProposeHash string
	BlockHash        string
	Timeslot         int64
}

type ProposeBlockInfo struct {
	ReceiveTime             time.Time
	Committees              []incognitokey.CommitteePublicKey
	NumberOfFixNode         int
	SigningCommittees       []incognitokey.CommitteePublicKey
	UserKeySet              []signatureschemes2.MiningKey
	Votes                   map[string]*BFTVote //pk->BFTVote
	PreVotes                map[string]*BFTVote //pk->BFTVote
	IsValid                 bool
	HasNewPreVote           bool
	HasNewVote              bool
	IsVoted                 bool
	IsPreVoted              bool
	IsCommitted             bool
	ValidPreVotes           int
	ErrPreVotes             int
	ValidVotes              int
	ErrVotes                int
	ProposerSendPreVote     bool
	ProposerSendVote        bool
	ProposerMiningKeyBase58 string
	LastValidateTime        time.Time
	ReProposeHashSignature  string
	IsValidLemma2Proof      bool
	FinalityProof           FinalityProof
	ValidPOLC               bool
	// contains filtered or unexported fields
}

type ProposeMessageEnvironment struct {
	NumberOfFixedShardBlockValidator int
	// contains filtered or unexported fields
}

type ProposeRuleLemma1 struct {
	// contains filtered or unexported fields
}

type ProposeRuleLemma2 struct {
	// contains filtered or unexported fields
}

type ReProposeBlockInfo struct {
	PreviousBlockHash common.Hash
	Producer          string
	ProducerTimeSlot  int64
	Proposer          string
	ProposerTimeSlot  int64
	RootHash          common.Hash
}

type SendProposeBlockEnvironment struct {
	// contains filtered or unexported fields
}

type VoteMessageEnvironment struct {
	// contains filtered or unexported fields
}

type VoteMessageHandler func(bftVote *BFTVote) error

type VoteRule struct {
	// contains filtered or unexported fields
}