Method handle_client

stream/proxy_server.py:95–128

Handle a client connection

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

        return False

    async def handle_client(
        self, reader: asyncio.StreamReader, writer: asyncio.StreamWriter
    ):
        """
        Handle a client connection
        """
        current_task = asyncio.current_task()
        if current_task:
            self.background_tasks.add(current_task)
            current_task.add_done_callback(self.background_tasks.discard)

        try:
            request_line = await reader.readline()
            request_line = request_line.decode("utf-8").strip()

            if not request_line:
                self._safe_close(writer)
                return

            parts = request_line.split(" ")
            if len(parts) < 2:
                self._safe_close(writer)
                return
            method, target = parts[0], parts[1]

            if method == "CONNECT":
                await self._handle_connect(reader, writer, target)

        except asyncio.CancelledError:
            raise
        except Exception as e:
            self.logger.error(f"Error handling client: {e}", exc_info=True)
        finally:
            self._safe_close(writer)

    async def _handle_connect(
        self, reader: asyncio.StreamReader, writer: asyncio.StreamWriter, target: str