mux

type AuthRequest struct {
	Rand           string
	User           string
	CipherCounter  uint64
	CipherMethod   string
	CompressMethod string

	P2PToken   string
	P2PConnID  string
	P2PPriAddr string
	P2PPubAddr string
}

type AuthResponse struct {
	Code        int
	PeerPriAddr string
	PeerPubAddr string
	PubAddr     string
}

type ConnAddr interface {
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
}

type ConnectRequest struct {
	//ProxySID uint32
	Network     string
	Addr        string
	DialTimeout int
	ReadTimeout int
	Hops        []string
}

type HTTP2MuxSession struct {
	net.Conn

	ServerHost string
	//Client     *http.Client
	//Client        *http2.Transport
	AcceptCh chan MuxStream
	// contains filtered or unexported fields
}

type MuxSession interface {
	OpenStream() (MuxStream, error)
	CloseStream(stream MuxStream) error
	AcceptStream() (MuxStream, error)
	Ping() (time.Duration, error)
	NumStreams() int
	Close() error
	RemoteAddr() net.Addr
	LocalAddr() net.Addr
}

type MuxStream interface {
	io.ReadWriteCloser
	Connect(network string, addr string, opt StreamOptions) error
	Auth(req *AuthRequest) *AuthResponse
	StreamID() uint32
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
	LatestIOTime() time.Time
}

type MuxStreamConn struct {
	MuxStream
}

type ProxyMuxSession struct {
	*pmux.Session
	NetConn ConnAddr
}

type ProxyMuxStream struct {
	TimeoutReadWriteCloser
	// contains filtered or unexported fields
}

type QUICMuxSession struct {
	quic.Connection
	// contains filtered or unexported fields
}

type StreamOptions struct {
	DialTimeout int
	ReadTimeout int
	Hops        []string
}

type SyncCloser interface {
	SyncClose() error
}

type TimeoutReadWriteCloser interface {
	io.ReadWriteCloser
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}

type WsConn struct {
	*websocket.Conn
	// contains filtered or unexported fields
}