fix: update i18n/rate limit

Author: Mag1cFall

src/api/request_processor.py

@@ -632,8 +632,10 @@ async def _process_request_refactored(req_id: str, request: ChatCompletionReques
         system_prompt, prepared_prompt, image_list = await prep_task
 
         await _handle_parameter_cache(req_id, context)
-        await page_controller.adjust_parameters(request.model_dump(exclude_none=True), context['page_params_cache'], context['params_cache_lock'], context['model_id_to_use'], context['parsed_model_list'], check_client_disconnected)
-        await page_controller.set_system_instructions(system_prompt, check_client_disconnected)
+        await asyncio.gather(
+            page_controller.adjust_parameters(request.model_dump(exclude_none=True), context['page_params_cache'], context['params_cache_lock'], context['model_id_to_use'], context['parsed_model_list'], check_client_disconnected),
+            page_controller.set_system_instructions(system_prompt, check_client_disconnected)
+        )
         check_client_disconnected('提交提示前最终检查')
         await page_controller.submit_prompt(prepared_prompt, image_list, check_client_disconnected)
         response_result = await _handle_response_processing(req_id, request, page, context, result_future, submit_button_locator, check_client_disconnected, disconnect_check_task)

src/manager.py

@@ -41,6 +41,7 @@ def __init__(self):
         self.worker_processes: List[subprocess.Popen] = []
         self.output_threads: List[threading.Thread] = []
         self.is_worker_mode = False
+        self._log_enabled = True
 
     def load_config(self):
         if os.path.exists(CONFIG_FILE_PATH):
@@ -60,7 +61,8 @@ def load_config(self):
             'helper_endpoint': '',
             'launch_mode': 'headless',
             'script_injection_enabled': False,
-            'worker_mode_enabled': False
+            'worker_mode_enabled': False,
+            'log_enabled': True
         }
 
     def save_config(self, config):
@@ -73,16 +75,15 @@ def save_config(self, config):
             return False
 
     async def broadcast_log(self, message: str, level: str = "INFO"):
+        if not self.active_connections or not self._log_enabled:
+            return
         timestamp = time.strftime("%H:%M:%S")
         log_entry = json.dumps({
             "type": "log",
             "time": timestamp,
             "level": level,
             "message": message
         })
-        
-        if not self.active_connections:
-            return
 
         to_remove = []
 
@@ -460,6 +461,8 @@ def kill_process(self, pid: int) -> tuple[bool, str]:
 async def lifespan(app: FastAPI):
     global loop
     loop = asyncio.get_running_loop()
+    config = manager.load_config()
+    manager._log_enabled = config.get('log_enabled', True)
     if WORKER_POOL_AVAILABLE:
         worker_pool.init_from_config()
     yield
@@ -490,6 +493,7 @@ async def get_config():
 
 @app.post("/api/config")
 async def save_config(config: Dict[str, Any] = Body(...)):
+    manager._log_enabled = config.get('log_enabled', True)
     if manager.save_config(config):
         return {"success": True}
     raise HTTPException(status_code=500, detail="保存失败")