Method handleSOCKS5Connection

internal/socks5/proxy.go:51–182

handleSOCKS5Connection handles a single SOCKS5 connection

(clientConn net.Conn, quicConn quic.Connection)

// handleSOCKS5Connection handles a single SOCKS5 connection
func (p *DefaultProxy) handleSOCKS5Connection(clientConn net.Conn, quicConn quic.Connection) {
	// Generate unique connection ID for tracking
	connID := generateConnectionID()
	
	defer func() {
		clientConn.Close()
		metrics.DecrementActiveSOCKS5Connections()
		// Clean up connection tracking
		dashboard.GlobalConnectionTracker.RemoveConnection(connID)
	}()

	// Record new connection
	metrics.RecordSOCKS5Connection()
	metrics.IncrementActiveSOCKS5Connections()
	connStart := time.Now()

	log.Printf("📞 New SOCKS5 connection from %s", clientConn.RemoteAddr())

	// Handle SOCKS5 handshake (use optimized buffer size)
	buf := make([]byte, shared.OptimizedBufferSize)
	_, err := clientConn.Read(buf)
	if err != nil {
		log.Printf("Failed to read SOCKS5 handshake: %v", err)
		metrics.RecordSOCKS5FailedConnection()
		return
	}

	// Respond to SOCKS5 handshake (no auth)
	if buf[0] == shared.SOCKS5Version {
		clientConn.Write(shared.SOCKS5AuthResponse)
	} else {
		log.Printf("Not a SOCKS5 connection")
		return
	}

	// Read SOCKS5 request
	_, err = clientConn.Read(buf)
	if err != nil {
		log.Printf("Failed to read SOCKS5 request: %v", err)
		return
	}

	if buf[0] != shared.SOCKS5Version || buf[1] != shared.SOCKS5Connect {
		log.Printf("Only SOCKS5 CONNECT supported")
		return
	}

	// Parse target address
	var targetAddr string
	var targetPort uint16

	switch buf[3] { // Address type
	case shared.SOCKS5IPv4:
		targetAddr = fmt.Sprintf("%d.%d.%d.%d", buf[4], buf[5], buf[6], buf[7])
		targetPort = binary.BigEndian.Uint16(buf[8:10])
	case shared.SOCKS5DomainName:
		domainLen := buf[4]
		targetAddr = string(buf[5 : 5+domainLen])