Function _start_stream_proxy

api_utils/app.py:99–133

()

async def _start_stream_proxy():
    stream_port_env = get_environment_variable("STREAM_PORT")
    if stream_port_env != "0":
        port = int(stream_port_env or 3120)
        stream_proxy_server_env = (
            get_environment_variable("UNIFIED_PROXY_CONFIG")
            or get_environment_variable("HTTPS_PROXY")
            or get_environment_variable("HTTP_PROXY")
        )
        state.logger.info(
            f"Starting STREAM proxy on port {port} with upstream proxy: {stream_proxy_server_env}"
        )
        state.STREAM_QUEUE = multiprocessing.Queue()
        state.STREAM_PROCESS = multiprocessing.Process(
            target=stream.start,
            args=(state.STREAM_QUEUE, port, stream_proxy_server_env),
        )
        state.STREAM_PROCESS.start()
        state.logger.info("STREAM proxy process started. Waiting for 'READY' signal...")

        try:
            ready_signal = await asyncio.to_thread(state.STREAM_QUEUE.get, timeout=15)
            if ready_signal == "READY":
                state.logger.info(
                    "[SUCCESS] Received 'READY' signal from STREAM proxy."
                )
            else:
                state.logger.warning(
                    f"Received unexpected signal from proxy: {ready_signal}"
                )
        except queue.Empty:
            state.logger.error(
                "[ERROR] Timed out waiting for STREAM proxy to become ready. Startup will likely fail."
            )
            raise RuntimeError("STREAM proxy failed to start in time.")


async def _initialize_browser_and_page():