p2p_base

type Message struct {
	MsgId         string  `json:"msg_id"`
	AckMsgId      string  `json:"ack_msg_id"`
	FromPeerId    peer.ID `json:"from_peer_id"`
	ToPeerId      peer.ID `json:"to_peer_id"`
	FromPeerName  string  `json:"from_peer_name"`
	ToPeerName    string  `json:"to_peer_name"`
	MsgType       MsgType `json:"msg_type"`
	MsgData       string  `json:"msg"`
	TimestampNano int64   `json:"timestamp_nano"` // 纳秒
	NeedsAck      bool    `json:"needs_ack"`
}

type MsgType string

type P2PBaseNode struct {
	Host              host.Host
	PeerName          string //名称
	ConnectionManager *P2pConnectionManager
	// contains filtered or unexported fields
}

type P2pConnection struct {
	PeerId        peer.ID
	PeerAddr      string
	Stream        network.Stream
	WaitAckMsgMap *myutils.MySyncMap[string, *chan bool] // 等待确认的消息通道 msgId -> 确认通道
	MainAckChan   *chan Message                          // 异步消息确认
}

type P2pConnectionManager struct {
	BaseNode          *P2PBaseNode
	TargetPeerAddrMap map[string]string         // name -> full addr
	ThisStreamMap     map[string]*P2pConnection // full addr -> stream
	RemoteStreamMap   map[string]*P2pConnection // remote peerId -> stream
}