node

type Config struct {
	// ExchangeKey 是用于密封消息的对称密钥
	ExchangeKey string

	// RoomName 是所有对等节点订阅的OTP令牌八卦房间
	RoomName string

	// ListenAddresses 是发现对等节点的初始引导地址
	ListenAddresses []discovery.AddrList

	// Insecure 禁用安全的P2P端到端加密通信
	Insecure bool

	// Handlers 是订阅VPN接口接收消息的处理器列表
	Handlers, GenericChannelHandler []Handler

	MaxMessageSize  int // 最大消息大小
	SealKeyInterval int // 密封密钥间隔

	ServiceDiscovery []ServiceDiscovery // 服务发现列表
	NetworkServices  []NetworkService   // 网络服务列表
	Logger           log.StandardLogger // 日志记录器

	SealKeyLength    int    // 密封密钥长度
	InterfaceAddress string // 接口地址

	Store blockchain.Store // 存储器

	// Handle 是被HumanInterfaces消耗的句柄，用于处理接收的消息
	Handle                     func(bool, *hub.Message)
	StreamHandlers             map[protocol.Protocol]StreamHandler // 流处理器映射
	AdditionalOptions, Options []libp2p.Option                     // libp2p选项

	DiscoveryInterval, LedgerSyncronizationTime, LedgerAnnounceTime time.Duration      // 各种时间间隔
	DiscoveryBootstrapPeers                                         discovery.AddrList // 发现引导节点

	Whitelist, Blacklist []string // 白名单和黑名单

	// GenericHub 启用通用中心
	GenericHub bool

	PrivateKey []byte             // 私钥
	PeerTable  map[string]peer.ID // 对等节点表

	Sealer    Sealer // 密封器
	PeerGater Gater  // 对等节点门控器
}

type Gater interface {
	Gate(*Node, peer.ID) bool // 门控检查
	Enable()                  // 启用
	Disable()                 // 禁用
	Enabled() bool            // 是否启用
}

type Handler func(*blockchain.Ledger, *hub.Message, chan *hub.Message) error

type NetworkService func(context.Context, Config, *Node, *blockchain.Ledger) error

type Node struct {
	MessageHub *hub.MessageHub // 消息中心

	sync.Mutex
	// contains filtered or unexported fields
}

type OTP struct {
	DHT    OTPConfig `yaml:"dht"`    // DHT配置
	Crypto OTPConfig `yaml:"crypto"` // 加密配置
}

type OTPConfig struct {
	Interval int    `yaml:"interval"` // 间隔
	Key      string `yaml:"key"`      // 密钥
	Length   int    `yaml:"length"`   // 长度
}

type Option func(cfg *Config) error

type Sealer interface {
	Seal(string, string) (string, error)   // 密封
	Unseal(string, string) (string, error) // 解封
}

type ServiceDiscovery interface {
	Run(log.StandardLogger, context.Context, host.Host) error // 运行服务发现
	Option(context.Context) func(c *libp2p.Config) error      // 返回libp2p选项
}

type StreamHandler func(*Node, *blockchain.Ledger) func(stream network.Stream)

type YAMLConnectionConfig struct {
	OTP OTP `yaml:"otp"`

	RoomName       string `yaml:"room"`             // 房间名称
	Rendezvous     string `yaml:"rendezvous"`       // 会合点
	MDNS           string `yaml:"mdns"`             // mDNS
	MaxMessageSize int    `yaml:"max_message_size"` // 最大消息大小
}