consensus_pbft

type Communicator interface {
	Broadcast(msg *message.Message, peerType pbftTypes.Peer_Type) error
	Unicast(msg *message.Message, receiverHandle *pbftTypes.PeerID) error
}

type Consenter interface {
	RecvMsg(msg *message.Message, senderHandle *pbftTypes.PeerID) error // Called serially with incoming messages from gRPC
	ExecutionConsumer
}

type ExecutionConsumer interface {
	Executed(tag interface{})                               // Called whenever Execute completes
	Committed(tag interface{}, state *message.StateInfo)    // Called whenever Commit completes
	RolledBack(tag interface{})                             // Called whenever a Rollback completes
	StateUpdated(tag interface{}, state *message.StateInfo) // Called when state transfer completes, if target is nil, this indicates a failure and a new target should be supplied
}

type Executor interface {
	Start()                                                                            // Bring up the resources needed to use this interface
	Halt()                                                                             // Tear down the resources needed to use this interface
	Execute(tag interface{}, txs []*message.Task)                                      // Executes a set of transactions, this may be called in succession
	Commit(tag interface{}, metadata []byte)                                           // Commits whatever transactions have been executed
	Rollback(tag interface{})                                                          // Rolls back whatever transactions have been executed
	UpdateState(tag interface{}, target *message.StateInfo, peers []*pbftTypes.PeerID) // Attempts to synchronize state to a particular target, implicitly calls rollback if needed
}

type Inquirer interface {
	GetNetworkNodes() (self pbftTypes.Peer, network []pbftTypes.Peer, err error)
	GetNetworkNodeIDs() (self *pbftTypes.PeerID, network []*pbftTypes.PeerID, err error)
}

type LedgerManager interface {
	InvalidateState() // Invalidate informs the ledger that it is out of date and should reject queries
	ValidateState()   // Validate informs the ledger that it is back up to date and should resume replying to queries
}

type NetworkStack interface {
	Communicator
	Inquirer
}

type ReadOnlyLedger interface {
	GetState(height uint64) (state *message.StateInfo, err error)
	//	GetBlockchainInfo() *pb.BlockchainInfo
	GetBlockchainInfoBlob() []byte
	GetBlockHeadMetadata() ([]byte, error)
}

type SecurityUtils interface {
	Sign(msg []byte) ([]byte, error)
	Verify(peerID pbftTypes.ReplicaID, signature []byte, message []byte) error
}

type Stack interface {
	NetworkStack                    // 网络消息发送和接收接口
	SecurityUtils                   // Sign和Verify接口
	Executor                        // 事件消息处理接口
	consensusInterface.NodeExecutor // 交易处理接口
	LedgerManager                   // 控制ledger的状态
	ReadOnlyLedger                  // 操作blockchain
	StatePersistor                  // 操作共识状态
}

type StatePersistor interface {
	StoreState(key string, value []byte) error
	ReadState(key string) ([]byte, error)
	ReadStateSet(prefix string) (map[string][]byte, error)
	DelState(key string)
}