fix: downgrade model TargetClosedError to debug, retry stream proxy on port failure

- model_management: TargetClosedError in set_model_from_display -> debug
- app.py: retry stream proxy up to 3 times with port increment on failure
- server.py: add STREAM_PORT_ACTUAL global

Author: maebahesioru

src/api/app.py

@@ -88,18 +88,23 @@ async def _start_stream_proxy():
         port = int(STREAM_PORT or 3120)
         STREAM_PROXY_SERVER_ENV = os.environ.get('UNIFIED_PROXY_CONFIG') or os.environ.get('HTTPS_PROXY') or os.environ.get('HTTP_PROXY')
         server.logger.info(f'Starting STREAM proxy on port {port} with upstream proxy: {STREAM_PROXY_SERVER_ENV}')
-        server.STREAM_QUEUE = multiprocessing.Queue()
-        server.STREAM_PROCESS = multiprocessing.Process(target=proxy.start, args=(server.STREAM_QUEUE, port, STREAM_PROXY_SERVER_ENV))
-        server.STREAM_PROCESS.start()
-        server.logger.info('STREAM proxy process started. Waiting for port readiness...')
-        if await _wait_for_port(port, timeout=30.0):
-            server.logger.info(f'STREAM proxy port {port} is ready.')
-        else:
-            server.logger.error(f'STREAM proxy port {port} not ready after timeout. Browser may fail to connect.')
-            if server.STREAM_PROCESS and server.STREAM_PROCESS.is_alive():
-                server.logger.warning('STREAM proxy process is alive but port not listening.')
+        for attempt in range(3):
+            current_port = port + attempt
+            server.STREAM_QUEUE = multiprocessing.Queue()
+            server.STREAM_PROCESS = multiprocessing.Process(target=proxy.start, args=(server.STREAM_QUEUE, current_port, STREAM_PROXY_SERVER_ENV))
+            server.STREAM_PROCESS.start()
+            server.logger.info(f'STREAM proxy process started on port {current_port}. Waiting for port readiness...')
+            if await _wait_for_port(current_port, timeout=30.0):
+                server.STREAM_PORT_ACTUAL = current_port
+                server.logger.info(f'STREAM proxy port {current_port} is ready.')
+                if current_port != port:
+                    server.logger.warning(f'STREAM proxy using fallback port {current_port} (requested {port}).')
+                return
             else:
-                server.logger.error(f'STREAM proxy process died. Exit code: {server.STREAM_PROCESS.exitcode}')
+                server.logger.warning(f'STREAM proxy port {current_port} not ready, killing process...')
+                server.STREAM_PROCESS.terminate()
+                server.STREAM_PROCESS.join(timeout=3)
+        server.logger.error(f'STREAM proxy failed to start after 3 attempts.')
 
 async def _initialize_browser_and_page():
     import server

src/browser/model_management.py

@@ -484,4 +484,8 @@ async def _set_model_from_page_display(page: AsyncPage, set_storage: bool=False)
             await page.evaluate("(prefsStr) => localStorage.setItem('aiStudioUserPreference', prefsStr)", json.dumps(prefs_to_set))
             logger.info(f"   ✅ localStorage.aiStudioUserPreference 已更新。isAdvancedOpen: {prefs_to_set.get('isAdvancedOpen')}, areToolsOpen: {prefs_to_set.get('areToolsOpen')} (期望: True), promptModel: '{prefs_to_set.get('promptModel', '未设置/保留原样')}'。")
     except Exception as e_set_disp:
-        logger.error(f'   尝试从页面显示设置模型时出错: {e_set_disp}', exc_info=True)
+        from playwright._impl._errors import TargetClosedError
+        if isinstance(e_set_disp, TargetClosedError):
+            logger.debug(f'   尝试从页面显示设置模型时出错 (browser closed): {e_set_disp}')
+        else:
+            logger.error(f'   尝试从页面显示设置模型时出错: {e_set_disp}', exc_info=True)

src/server.py

@@ -35,6 +35,7 @@
 from api import generate_sse_chunk, generate_sse_stop_chunk, generate_sse_error_chunk, use_helper_get_response, use_stream_response, clear_stream_queue, prepare_combined_prompt, validate_chat_request, _process_request_refactored, create_app, queue_worker
 STREAM_QUEUE: Optional[multiprocessing.Queue] = None
 STREAM_PROCESS = None
+STREAM_PORT_ACTUAL: Optional[int] = None
 playwright_manager: Optional[AsyncPlaywright] = None
 browser_instance: Optional[AsyncBrowser] = None
 page_instance: Optional[AsyncPage] = None