Method _handle_connect

stream/proxy_server.py:130–232

Handle CONNECT method (for HTTPS connections)

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

            self._safe_close(writer)

    async def _handle_connect(
        self, reader: asyncio.StreamReader, writer: asyncio.StreamWriter, target: str
    ):
        """
        Handle CONNECT method (for HTTPS connections)
        """
        host, port_str = target.split(":")
        port = int(port_str)
        intercept = self.should_intercept(host)

        if intercept:
            self.cert_manager.get_domain_cert(host)

            writer.write(b"HTTP/1.1 200 Connection Established\r\n\r\n")
            await writer.drain()

            await reader.read(8192)

            loop = asyncio.get_running_loop()
            transport = writer.transport

            if transport is None:
                self.logger.warning(
                    f"Client writer transport is None for {host}:{port} before TLS upgrade. Closing."
                )
                return

            ssl_context = ssl.create_default_context(ssl.Purpose.CLIENT_AUTH)
            ssl_context.load_cert_chain(
                certfile=self.cert_manager.cert_dir / f"{host}.crt",
                keyfile=self.cert_manager.cert_dir / f"{host}.key",
            )

            client_protocol = transport.get_protocol()

            new_transport = await loop.start_tls(
                transport=transport,
                protocol=client_protocol,
                sslcontext=ssl_context,
                server_side=True,
            )

            if new_transport is None:
                self.logger.error(
                    f"loop.start_tls returned None for {host}:{port}, which is unexpected. Closing connection.",
                    exc_info=True,
                )
                writer.close()
                return

            client_writer = asyncio.StreamWriter(
                transport=new_transport,
                protocol=client_protocol,
                reader=reader,
                loop=loop,
            )

            try: