api

type AccountAPI interface {
	GetAccount(addr *types.Address) ledger.IAccount
}

type AuditAPI interface {
	HandleAuditNodeSubscription(dataCh chan<- *pb.AuditTxInfo, auditNodeID string, blockStart uint64) error
	SubscribeAuditEvent(chan<- *pb.AuditTxInfo) event.Subscription
}

type BrokerAPI interface {
	HandleTransaction(tx pb.Transaction) error
	HandleView(tx pb.Transaction) (*pb.Receipt, error)
	GetTransaction(*types.Hash) (pb.Transaction, error)
	GetTransactionMeta(*types.Hash) (*pb.TransactionMeta, error)
	GetReceipt(*types.Hash) (*pb.Receipt, error)
	GetBlock(mode string, key string) (*pb.Block, error)
	GetBlocks(start uint64, end uint64) ([]*pb.Block, error)
	GetPendingNonceByAccount(account string) uint64
	GetPendingTransactions(max int) []pb.Transaction
	GetPoolTransaction(hash *types.Hash) pb.Transaction
	GetStateLedger() ledger.StateLedger

	// AddPier
	AddPier(pierID string) (chan *pb.InterchainTxWrappers, error)

	// RemovePier
	RemovePier(pierID string)

	GetBlockHeader(begin, end uint64, ch chan<- *pb.BlockHeader) error

	GetInterchainTxWrappers(did string, begin, end uint64, ch chan<- *pb.InterchainTxWrappers) error

	// OrderReady
	OrderReady() error

	FetchSignsFromOtherPeers(req *pb.GetSignsRequest) map[string][]byte
	GetSign(req *pb.GetSignsRequest, signers []string) (string, []byte, []string, error)
	GetBlockHeaders(start uint64, end uint64) ([]*pb.BlockHeader, error)
	GetQuorum() uint64
	GetTssPubkey() (string, *ecdsa.PublicKey, error)
	GetTssKeyGenPartiesPkMap() (map[string][]byte, error)
}

type ChainAPI interface {
	Status() string
	Meta() (*pb.ChainMeta, error)
	TPS(begin, end uint64) (uint64, error)
}

type CoreAPI interface {
	Broker() BrokerAPI
	Network() NetworkAPI
	Chain() ChainAPI
	Feed() FeedAPI
	Account() AccountAPI
	Audit() AuditAPI
}

type FeedAPI interface {
	SubscribeLogsEvent(chan<- []*pb.EvmLog) event.Subscription
	SubscribeNewTxEvent(chan<- pb.Transactions) event.Subscription
	SubscribeNewBlockEvent(chan<- events.ExecutedEvent) event.Subscription
	SubscribeTssSignRes(ch chan<- *pb.Message) event.Subscription
	BloomStatus() (uint64, uint64)
}

type NetworkAPI interface {
	PeerInfo() ([]byte, error)
	PierManager() peermgr.PierManager
	OtherPeers() map[uint64]*peer.AddrInfo
}