Method start

src/proxy/proxy_server.py:345–399

(self)

        return self.fronter._is_static_asset_url(url)

    async def start(self):
        if self._warmup_before_listen:
            log.info(
                "Relay warmup in progress... waiting up to %.0fs before opening listeners",
                self._warmup_timeout,
            )
            ready = await self.fronter.wait_until_warm(timeout=self._warmup_timeout)
            if ready:
                log.info("Relay warmup complete — enabling HTTP/SOCKS listeners")
            else:
                log.warning(
                    "Relay warmup timed out after %.0fs — starting listeners anyway",
                    self._warmup_timeout,
                )

        http_srv = await asyncio.start_server(self._on_client, self.host, self.port)
        socks_srv = None

        if self.socks_enabled:
            try:
                socks_srv = await asyncio.start_server(
                    self._on_socks_client, self.socks_host, self.socks_port
                )
            except OSError as e:
                log.error("SOCKS5 listener failed on %s:%d: %s",
                          self.socks_host, self.socks_port, e)

        self._servers = [s for s in (http_srv, socks_srv) if s]

        log.info(
            "HTTP proxy listening on %s:%d",
            self.host, self.port,
        )
        if socks_srv:
            log.info(
                "SOCKS5 proxy listening on %s:%d",
                self.socks_host, self.socks_port,
            )

        # Kick off adblock refresh in the background — won't block startup.
        if self._adblock_urls:
            asyncio.create_task(self._refresh_adblock_lists())

        try:
            async with http_srv:
                if socks_srv:
                    async with socks_srv:
                        await asyncio.gather(
                            http_srv.serve_forever(),
                            socks_srv.serve_forever(),
                        )
                else:
                    await http_srv.serve_forever()
        except asyncio.CancelledError:
            raise

    async def stop(self):
        """Shut down all listeners and release relay resources."""