peer_mgr

type BasicPeerManager interface {
	// Start
	Start() error

	// Stop
	Stop() error

	// AsyncSend sends message to peer with peer info.
	AsyncSend(KeyType, *pb.Message) error

	// Send sends message waiting response
	Send(KeyType, *pb.Message) (*pb.Message, error)

	// CountConnectedPeers counts connected peer numbers
	CountConnectedPeers() uint64

	// Peers return all peers including local peer.
	Peers() map[string]*peer.AddrInfo
}

type KeyType interface{}

type OrderMessageEvent struct {
	Data []byte
}

type OrderPeerManager interface {
	BasicPeerManager

	// SubscribeOrderMessage
	SubscribeOrderMessage(ch chan<- OrderMessageEvent) event.Subscription

	// AddNode adds a vp peer.
	AddNode(newNodeID uint64, vpInfo *pb.VpInfo)

	// DelNode deletes a vp peer.
	DelNode(delID uint64)

	// UpdateRouter update the local router to quorum router.
	UpdateRouter(vpInfos map[uint64]*pb.VpInfo, isNew bool) bool

	// OtherPeers return peers except local peer.
	OtherPeers() map[uint64]*peer.AddrInfo

	// Broadcast message to all node
	Broadcast(*pb.Message) error

	// Disconnect disconnect with all vp peers.
	Disconnect(vpInfos map[uint64]*pb.VpInfo)

	// OrderPeers return all OrderPeers include account and id.
	OrderPeers() map[uint64]*pb.VpInfo
}

type TssPeerManager interface {
	// SubscribeTssMessage subscribes to the message of the tss module
	SubscribeTssMessage(ch chan<- *pb.Message) event.Subscription

	// SubscribeTssSignRes subscribes to the sign result
	SubscribeTssSignRes(ch chan<- *pb.Message) event.Subscription

	// SubscribeTssMessage subscribes to the message of the tss module
	SubscribeTssCulprits(ch chan<- *pb.Message) event.Subscription

	SubscribeTssKeygenReq(ch chan<- *pb.Message) event.Subscription
}