Method _on_socks_client

src/proxy/proxy_server.py:515–540

(self, reader: asyncio.StreamReader,
                               writer: asyncio.StreamWriter)

                pass

    async def _on_socks_client(self, reader: asyncio.StreamReader,
                               writer: asyncio.StreamWriter):
        addr = writer.get_extra_info("peername")
        task = self._track_current_task()
        try:
            result = await negotiate_socks5(reader, writer)
            if result is None:
                return
            host, port = result
            log.info("SOCKS5 CONNECT → %s:%d", host, port)
            await self._handle_target_tunnel(host, port, reader, writer)
        except asyncio.IncompleteReadError:
            pass
        except asyncio.CancelledError:
            pass
        except asyncio.TimeoutError:
            log.debug("SOCKS5 timeout: %s", addr)
        except Exception as e:
            log.error("SOCKS5 error (%s): %s", addr, e)
        finally:
            self._untrack_task(task)
            try:
                writer.close()
                await writer.wait_closed()
            except Exception:
                pass

    # ── CONNECT (HTTPS tunnelling) ────────────────────────────────