17c081a40c
* add support for hysteria udp port hopping * add ports field for hysteria * change method for udp connection Co-authored-by: geoleonsh <geoleonsh@live.com>
104 lines
2.7 KiB
Go
104 lines
2.7 KiB
Go
package transport
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"fmt"
|
|
"net"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/metacubex/quic-go"
|
|
|
|
"github.com/Dreamacro/clash/transport/hysteria/conns/faketcp"
|
|
"github.com/Dreamacro/clash/transport/hysteria/conns/udp"
|
|
"github.com/Dreamacro/clash/transport/hysteria/conns/wechat"
|
|
obfsPkg "github.com/Dreamacro/clash/transport/hysteria/obfs"
|
|
"github.com/Dreamacro/clash/transport/hysteria/utils"
|
|
)
|
|
|
|
type ClientTransport struct {
|
|
Dialer *net.Dialer
|
|
}
|
|
|
|
func (ct *ClientTransport) quicPacketConn(proto string, server string, obfs obfsPkg.Obfuscator, hopInterval time.Duration, dialer utils.PacketDialer) (net.PacketConn, error) {
|
|
if len(proto) == 0 || proto == "udp" {
|
|
conn, err := dialer.ListenPacket()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if obfs != nil {
|
|
if isMultiPortAddr(server) {
|
|
return udp.NewObfsUDPHopClientPacketConn(server, hopInterval, obfs, dialer)
|
|
}
|
|
oc := udp.NewObfsUDPConn(conn, obfs)
|
|
return oc, nil
|
|
} else {
|
|
if isMultiPortAddr(server) {
|
|
return udp.NewObfsUDPHopClientPacketConn(server, hopInterval, nil, dialer)
|
|
}
|
|
return conn, nil
|
|
}
|
|
} else if proto == "wechat-video" {
|
|
conn, err := dialer.ListenPacket()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if obfs == nil {
|
|
obfs = obfsPkg.NewDummyObfuscator()
|
|
}
|
|
return wechat.NewObfsWeChatUDPConn(conn, obfs), nil
|
|
} else if proto == "faketcp" {
|
|
var conn *faketcp.TCPConn
|
|
conn, err := faketcp.Dial("tcp", server)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if obfs != nil {
|
|
oc := faketcp.NewObfsFakeTCPConn(conn, obfs)
|
|
return oc, nil
|
|
} else {
|
|
return conn, nil
|
|
}
|
|
} else {
|
|
return nil, fmt.Errorf("unsupported protocol: %s", proto)
|
|
}
|
|
}
|
|
|
|
func (ct *ClientTransport) QUICDial(proto string, server string, tlsConfig *tls.Config, quicConfig *quic.Config, obfs obfsPkg.Obfuscator, hopInterval time.Duration, dialer utils.PacketDialer) (quic.Connection, error) {
|
|
serverUDPAddr, err := dialer.RemoteAddr(server)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
pktConn, err := ct.quicPacketConn(proto, serverUDPAddr.String(), obfs, hopInterval, dialer)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
qs, err := quic.DialContext(dialer.Context(), pktConn, serverUDPAddr, server, tlsConfig, quicConfig)
|
|
if err != nil {
|
|
_ = pktConn.Close()
|
|
return nil, err
|
|
}
|
|
return qs, nil
|
|
}
|
|
|
|
func (ct *ClientTransport) DialTCP(raddr *net.TCPAddr) (*net.TCPConn, error) {
|
|
conn, err := ct.Dialer.Dial("tcp", raddr.String())
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return conn.(*net.TCPConn), nil
|
|
}
|
|
|
|
func (ct *ClientTransport) ListenUDP() (*net.UDPConn, error) {
|
|
return net.ListenUDP("udp", nil)
|
|
}
|
|
|
|
func isMultiPortAddr(addr string) bool {
|
|
_, portStr, err := net.SplitHostPort(addr)
|
|
if err == nil && (strings.Contains(portStr, ",") || strings.Contains(portStr, "-")) {
|
|
return true
|
|
}
|
|
return false
|
|
}
|