base

type Dispatcher interface {
	Register(sub Subscriber) error
	UnRegister(sub Subscriber) error
	Dispatch(*protos.CoreMessage, Stream) error
}

type FilterStrategy string

type NetConf struct {
	// Module is the name of p2p module plugin
	Module string `yaml:"module,omitempty"`
	// Port the p2p network listened for p2p
	Port int32 `yaml:"port,omitempty"`
	// Address multiaddr string, /ip4/127.0.0.1/tcp/8080
	Address string `yaml:"address,omitempty"`
	// keyPath is the node private key path
	KeyPath string `yaml:"keyPath,omitempty"`
	// isNat envconfig whether the node use NAT manager
	IsNat bool `yaml:"isNat,omitempty"`
	// isHidden envconfig whether the node can be found
	IsHidden bool `yaml:"isHidden,omitempty"`
	// bootNodes envconfig the bootNodes the node to connect
	BootNodes []string `yaml:"bootNodes,omitempty"`
	// staticNodes envconfig the nodes which you trust
	StaticNodes map[string][]string `yaml:"staticNodes,omitempty"`
	// isBroadCast envconfig whether broadcast to all StaticNodes
	IsBroadCast bool `yaml:"isBroadCast,omitempty"`
	// maxStreamLimits envconfig the max stream num
	MaxStreamLimits int32 `yaml:"maxStreamLimits,omitempty"`
	// maxMessageSize envconfig the max message size
	MaxMessageSize int64 `yaml:"maxMessageSize,omitempty"`
	// timeout envconfig the timeout of Request with response
	Timeout int64 `yaml:"timeout,omitempty"`
	// StreamIPLimitSize set the limitation size for same ip
	StreamIPLimitSize int64 `yaml:"streamIPLimitSize,omitempty"`
	// MaxBroadcastPeers limit the number of common peers in a broadcast,
	// this number do not include MaxBroadcastCorePeers.
	MaxBroadcastPeers int `yaml:"maxBroadcastPeers,omitempty"`
	// isTls envconfig the node use tls secure transparent
	IsTls bool `yaml:"isTls,omitempty"`
	// ServiceName
	ServiceName string `yaml:"serviceName,omitempty"`
}

type NetCtx struct {
	// 基础上下文
	xctx.BaseCtx
	// 运行环境配置
	EnvCfg *xconf.EnvConf
	// 网络组件配置
	P2PConf *NetConf
}

type Network interface {
	Init(*NetCtx) error
	Start()
	Stop()

	NewSubscriber(protos.CoreMessage_MessageType, interface{}, ...SubscriberOption) Subscriber
	Register(Subscriber) error
	UnRegister(Subscriber) error

	SendMessage(xctx.Context, *protos.CoreMessage, ...OptionFunc) error
	SendMessageWithResponse(xctx.Context, *protos.CoreMessage, ...OptionFunc) ([]*protos.CoreMessage, error)

	Context() *NetCtx
	PeerInfo() protos.PeerInfo
}

type Option struct {
	Filters   []FilterStrategy
	Addresses []string
	PeerIDs   []string
	Accounts  []string

	WhiteList map[string]bool

	Percent float32 // percent wait for return

	Factor float64
}

type OptionFunc func(*Option)

type Stream interface {
	Send(*protos.CoreMessage) error
}

type Subscriber interface {
	GetMessageType() protos.CoreMessage_MessageType
	Match(*protos.CoreMessage) bool
	HandleMessage(xctx.Context, *protos.CoreMessage, Stream) error
}

type SubscriberOption func(Subscriber)