Add v2ray QUIC transport

inbound/default.go

@@ -129,6 +129,18 @@ func (a *myInboundAdapter) ListenTCP() (*net.TCPListener, error) {
 	return tcpListener, err
 }
 
+func (a *myInboundAdapter) ListenUDP() (*net.UDPConn, error) {
+	bindAddr := M.SocksaddrFrom(netip.Addr(a.listenOptions.Listen), a.listenOptions.ListenPort)
+	udpConn, err := net.ListenUDP(M.NetworkFromNetAddr(N.NetworkUDP, bindAddr.Addr), bindAddr.UDPAddr())
+	if err != nil {
+		return nil, err
+	}
+	a.udpConn = udpConn
+	a.udpAddr = bindAddr
+	a.logger.Info("udp server started at ", udpConn.LocalAddr())
+	return udpConn, err
+}
+
 func (a *myInboundAdapter) Close() error {
 	var err error
 	if a.clearSystemProxy != nil {

inbound/hysteria_stub.go

@@ -6,11 +6,11 @@ import (
 	"context"
 
 	"github.com/sagernet/sing-box/adapter"
+	C "github.com/sagernet/sing-box/constant"
 	"github.com/sagernet/sing-box/log"
 	"github.com/sagernet/sing-box/option"
-	E "github.com/sagernet/sing/common/exceptions"
 )
 
 func NewHysteria(ctx context.Context, router adapter.Router, logger log.ContextLogger, tag string, options option.HysteriaInboundOptions) (adapter.Inbound, error) {
-	return nil, E.New(`QUIC is not included in this build, rebuild with -tags with_quic`)
+	return nil, C.ErrQUICNotIncluded
 }

inbound/naive_quic_stub.go

@@ -2,8 +2,10 @@
 
 package inbound
 
-import E "github.com/sagernet/sing/common/exceptions"
+import (
+	C "github.com/sagernet/sing-box/constant"
+)
 
 func (n *Naive) configureHTTP3Listener(listenAddr string) error {
-	return E.New("QUIC is not included in this build, rebuild with -tags with_quic")
+	return C.ErrQUICNotIncluded
 }

inbound/vmess.go

@@ -83,16 +83,30 @@ func (h *VMess) Start() error {
 	if h.transport == nil {
 		return h.myInboundAdapter.Start()
 	}
-	tcpListener, err := h.myInboundAdapter.ListenTCP()
-	if err != nil {
-		return err
-	}
-	go func() {
-		sErr := h.transport.Serve(tcpListener)
-		if sErr != nil && !E.IsClosed(sErr) {
-			h.logger.Error("transport serve error: ", sErr)
+	if common.Contains(h.transport.Network(), N.NetworkTCP) {
+		tcpListener, err := h.myInboundAdapter.ListenTCP()
+		if err != nil {
+			return err
 		}
-	}()
+		go func() {
+			sErr := h.transport.Serve(tcpListener)
+			if sErr != nil && !E.IsClosed(sErr) {
+				h.logger.Error("transport serve error: ", sErr)
+			}
+		}()
+	}
+	if common.Contains(h.transport.Network(), N.NetworkUDP) {
+		udpConn, err := h.myInboundAdapter.ListenUDP()
+		if err != nil {
+			return err
+		}
+		go func() {
+			sErr := h.transport.ServePacket(udpConn)
+			if sErr != nil && !E.IsClosed(sErr) {
+				h.logger.Error("transport serve error: ", sErr)
+			}
+		}()
+	}
 	return nil
 }