Method Serve

socks/connection_handler.go:31–57

Serve process new connection created after calling `Accept()` in the standard library

(c io.ReadWriter)

// Serve process new connection created after calling `Accept()` in the standard library
func (h *StandardConnectionHandler) Serve(c io.ReadWriter) error {
	bufConn := bufio.NewReader(c)

	// read the version byte
	version := []byte{0}
	if _, err := bufConn.Read(version); err != nil {
		return err
	}

	// ensure compatibility
	if version[0] != socks5Version {
		return fmt.Errorf("Unsupported SOCKS version: %v", version)
	}

	// handle auth
	if err := h.authHandler.Handle(bufConn, c); err != nil {
		return err
	}

	// process command/request
	req, err := NewRequest(bufConn)
	if err != nil {
		return err
	}

	return h.requestHandler.Handle(req, c)
}