p2p

type CandidatePairInfo struct {
	LocalType  string `json:"local_type"`
	RemoteType string `json:"remote_type"`
	LocalAddr  string `json:"local_addr"`
	RemoteAddr string `json:"remote_addr"`
}

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	// STUNURLs STUN 服务器列表。
	STUNURLs []string `yaml:"stun_urls"`
	// TURN 配置（外部 coturn）。
	TURN TURNConfig `yaml:"turn"`
	// ICE 超时。
	ICETimeout time.Duration `yaml:"ice_timeout"`
	// SignalingAddr tunnel gateway 信令地址（P1 后接入 tunnel 控制流）。
	SignalingAddr string `yaml:"signaling_addr"`
	// AuthToken 注册/建连鉴权 token，对应 tunnel TokenAuthProvider。
	AuthToken string `yaml:"auth_token"`
	// Insecure 跳过 QUIC TLS 校验（仅开发）。
	Insecure bool `yaml:"insecure"`
	// TLS QUIC 证书（生产环境）；设置 cert/key 后自动启用 TLS。
	TLS TLSFileConfig `yaml:"tls"`
	// Reconnect 断线重连策略（Reconnect 使用；Dial 仍为单次尝试）。
	Reconnect ReconnectConfig `yaml:"reconnect"`
}

type ConnectionStats struct {
	RemotePeerID      string            `json:"remote_peer_id"`
	Pair              CandidatePairInfo `json:"pair"`
	ConnectedAt       time.Time         `json:"connected_at"`
	ConnectDurationMs int64             `json:"connect_duration_ms"`
	RTTMs             float64           `json:"rtt_ms,omitempty"`
	PairState         string            `json:"pair_state,omitempty"`
	Nominated         bool              `json:"nominated,omitempty"`
}

type Coordinator interface {
	Listen(ctx context.Context, selfID string) (Listener, error)
	Dial(ctx context.Context, peerID string) (PeerConn, error)
	// Reconnect 关闭与 peer 的现有连接并重新 ICE+QUIC 协商（带退避重试）。
	Reconnect(ctx context.Context, peerID string) (PeerConn, error)
	Close() error
	Stats() Stats
}

type Listener interface {
	Accept(ctx context.Context) (PeerConn, error)
	Close() error
}

type MetricsRecorder struct {
	// contains filtered or unexported fields
}

type PacketConn interface {
	net.PacketConn
	io.Closer
}

type PeerConn interface {
	tunnel.Session
	RemotePeerID() string
	LocalPeerID() string
	// SelectedPair 返回 ICE 选路摘要（host/srflx/relay + 地址），用于可观测。
	SelectedPair() CandidatePairInfo
}

type ReconnectConfig struct {
	// MaxAttempts 最大尝试次数（含首次），默认 3。
	MaxAttempts int `yaml:"max_attempts"`
	// Backoff 重试间隔，默认 1s。
	Backoff time.Duration `yaml:"backoff"`
}

type Role int

type Stats struct {
	SelfID            string            `json:"self_id"`
	Listening         bool              `json:"listening"`
	ActiveConnections int               `json:"active_connections"`
	RelayConnections  int               `json:"relay_connections"`
	Connections       []ConnectionStats `json:"connections"`
}

type TLSFileConfig struct {
	CertFile string `yaml:"cert_file"`
	KeyFile  string `yaml:"key_file"`
	CAFile   string `yaml:"ca_file"`
}

type TURNConfig struct {
	URL      string `yaml:"url"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
	Realm    string `yaml:"realm"`
	// AuthSecret 与 coturn static-auth-secret 一致时，按 TURN REST API 生成临时凭证。
	AuthSecret string        `yaml:"auth_secret"`
	CredTTL    time.Duration `yaml:"cred_ttl"`
	// Disabled 为 true 时不使用 TURN（即使 URL 有默认值）。
	Disabled bool `yaml:"disabled"`
}