Update app.py

app.py

@@ -1,4 +1,4 @@
-# app.py - نسخه کامل و بهینه‌سازی شده برای پایداری بالا (با اصلاح نهایی)
+# app.py - نسخه نهایی با اجرای همزمان واقعی برای حداکثر پایداری
 
 import os
 import sys
@@ -42,13 +42,7 @@ def _init_api_keys():
         logging.warning("⛔️ هشدار: هیچ Secret با نام ALL_GEMINI_API_KEYS یافت نشد!")
 
 def get_next_api_key_and_client():
-    """
-    تغییر اصلی: این تابع هم کلید و هم یک client کش‌شده یا جدید را برمی‌گرداند.
-    """
-    # --- START: خط اصلاح شده اینجاست ---
-    global NEXT_KEY_INDEX 
-    # --- END: خط اصلاح شده ---
-
+    global NEXT_KEY_INDEX
     with KEY_LOCK:
         if not ALL_API_KEYS:
             return None, None, -1
@@ -68,7 +62,6 @@ def get_next_api_key_and_client():
             
     return key_to_use, client, key_display_index
 
-# --- ثابت‌ها ---
 FIXED_MODEL_NAME = "gemini-2.5-flash-preview-tts"
 DEFAULT_MAX_CHUNK_SIZE = 3800
 DEFAULT_SLEEP_BETWEEN_REQUESTS = 8
@@ -80,6 +73,7 @@ def save_binary_file(file_name, data):
     except Exception as e:
         logging.error(f"❌ خطا در ذخیره فایل {file_name}: {e}")
         return None
+
 def convert_to_wav(audio_data: bytes, mime_type: str) -> bytes:
     parameters = parse_audio_mime_type(mime_type)
     bits_per_sample, rate = parameters["bits_per_sample"], parameters["rate"]
@@ -88,6 +82,7 @@ def convert_to_wav(audio_data: bytes, mime_type: str) -> bytes:
     byte_rate, chunk_size = rate * block_align, 36 + data_size
     header = struct.pack("<4sI4s4sIHHIIHH4sI", b"RIFF", chunk_size, b"WAVE", b"fmt ", 16, 1, num_channels, rate, byte_rate, block_align, bits_per_sample, b"data", data_size)
     return header + audio_data
+
 def parse_audio_mime_type(mime_type: str) -> dict[str, int]:
     bits, rate = 16, 24000
     for param in mime_type.split(";"):
@@ -99,6 +94,7 @@ def parse_audio_mime_type(mime_type: str) -> dict[str, int]:
             try: bits = int(param.split("L", 1)[1])
             except: pass
     return {"bits_per_sample": bits, "rate": rate}
+
 def smart_text_split(text, max_size=3800):
     if len(text) <= max_size: return [text]
     chunks, current_chunk = [], ""
@@ -115,6 +111,7 @@ def smart_text_split(text, max_size=3800):
     if current_chunk: chunks.append(current_chunk.strip())
     final_chunks = [c for c in chunks if c]
     return final_chunks
+
 def merge_audio_files_func(file_paths, output_path):
     if not PYDUB_AVAILABLE: logging.warning("⚠️ pydub برای ادغام در دسترس نیست."); return False
     try:
@@ -206,8 +203,12 @@ class TTSRequest(BaseModel):
     speaker: str
     temperature: float
 
+# --- START: تغییر اصلی برای اجرای همزمان واقعی ---
+# کلمه کلیدی async از تعریف تابع حذف شده است.
+# این به FastAPI می‌گوید که این تابع سنگین را در یک thread جداگانه اجرا کند.
 @app.post("/generate")
-async def generate_audio_endpoint(request: TTSRequest):
+def generate_audio_endpoint(request: TTSRequest):
+# --- END: تغییر اصلی ---
     session_id = str(uuid.uuid4())[:8]
     logging.info(f"[{session_id}] 🏁 درخواست جدید API در این Worker دریافت شد.")
     try: