Update app.py

app.py

@@ -6,80 +6,63 @@ import re
 import struct
 import time
 import zipfile
-# این کد صحیح است
-import google.generativeai as genai
-from google.generativeai import types
+from google import genai
+from google.genai import types
 import threading
 import logging
-import uuid  # <<<< جدید: برای تولید شناسه‌های منحصر به فرد
-import tempfile # <<<< جدید: برای مدیریت فایل‌ها و دایرکتوری‌های موقت
-import glob # <<<< جدید: برای پیدا کردن و پاک کردن فایل‌های قدیمی
+import uuid # اضافه شد: برای تولید شناسه‌های یکتا
 
 try:
     from pydub import AudioSegment
     PYDUB_AVAILABLE = True
 except ImportError:
     PYDUB_AVAILABLE = False
+    logging.warning("⚠️ کتابخانه pydub یافت نشد. قابلیت ادغام فایل‌های صوتی غیرفعال است. برای فعال‌سازی آن را نصب کنید (pip install pydub).")
 
 # --- START: پیکربندی لاگینگ ---
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s', datefmt='%Y-%m-%d %H:%M:%S')
+# --- END: پیکربندی لاگینگ ---
 
-# --- START: منطق مدیریت API Key (بدون تغییر، عالی است) ---
+# --- START: منطق جدید مدیریت API Key (مشابه کد قبلی شما) ---
 ALL_API_KEYS: list[str] = []
 NEXT_KEY_INDEX: int = 0
-KEY_LOCK: threading.Lock = threading.Lock()
+KEY_LOCK: threading.Lock = threading.Lock() # برای اطمینان از ایمنی تردها هنگام به روز رسانی ایندکس
 
 def _init_api_keys():
+    """
+    کلیدهای API را از یک متغیر محیطی واحد شناسایی و مرتب می‌کند.
+    این تابع باید یک بار هنگام شروع برنامه اجرا شود.
+    """
     global ALL_API_KEYS
+    
     all_keys_string = os.environ.get("ALL_GEMINI_API_KEYS") 
+    
     if all_keys_string:
         ALL_API_KEYS = [key.strip() for key in all_keys_string.split(',') if key.strip()]
+        
     logging.info(f"✅ تعداد {len(ALL_API_KEYS)} کلید API جیمینای بارگذاری شد.")
     if not ALL_API_KEYS:
         logging.warning("⛔️ خطای حیاتی: هیچ Secret با نام ALL_GEMINI_API_KEYS یافت نشد!")
+        logging.warning("   لطفاً Secret را به عنوان یک رشته با کاما جدا شده (مثال: key1,key2,key3) در تنظیمات Space خود اضافه کنید.")
+
+# فراخوانی تابع شناسایی کلیدها در ابتدای برنامه
 _init_api_keys()
 
 def get_next_api_key():
+    """
+    کلید API بعدی را به صورت چرخشی برمی‌گرداند.
+    """
     global NEXT_KEY_INDEX, ALL_API_KEYS, KEY_LOCK
-    with KEY_LOCK:
-        if not ALL_API_KEYS: return None, None
+    
+    with KEY_LOCK: # اطمینان از اینکه تنها یک ترد در هر زمان به ایندکس دسترسی دارد
+        if not ALL_API_KEYS:
+            return None, None
+
         key_to_use = ALL_API_KEYS[NEXT_KEY_INDEX % len(ALL_API_KEYS)]
         key_display_index = (NEXT_KEY_INDEX % len(ALL_API_KEYS)) + 1
         NEXT_KEY_INDEX += 1
         return key_to_use, key_display_index
-# --- END: منطق مدیریت API Key ---
-
-# --- START: منطق پاک‌سازی خودکار فایل‌های خروجی قدیمی --- # <<<< بخش کاملاً جدید
-OUTPUT_DIR = "gradio_output" # یک پوشه برای نگهداری فایل‌های نهایی
-os.makedirs(OUTPUT_DIR, exist_ok=True)
-CLEANUP_INTERVAL_SECONDS = 60 * 10 # هر ۱۰ دقیقه یکبار
-FILE_LIFETIME_SECONDS = 60 * 15 # فایل‌ها پس از ۱۵ دقیقه حذف شوند
-
-def cleanup_old_files():
-    """یک ریسه پس‌زمینه که فایل‌های صوتی قدیمی را پاک می‌کند."""
-    while True:
-        try:
-            logging.info(f"🧹 اجرای پاک‌سازی فایل‌های قدیمی در پوشه {OUTPUT_DIR}...")
-            current_time = time.time()
-            # فقط فایل‌هایی با فرمت alpha_tts_final_... را بررسی می‌کنیم
-            files_to_check = glob.glob(os.path.join(OUTPUT_DIR, "alpha_tts_final_*.wav"))
-            files_to_check += glob.glob(os.path.join(OUTPUT_DIR, "alpha_tts_final_*.mp3")) # برای فرمت‌های دیگر
-            
-            for file_path in files_to_check:
-                try:
-                    if os.path.isfile(file_path):
-                        file_age = current_time - os.path.getmtime(file_path)
-                        if file_age > FILE_LIFETIME_SECONDS:
-                            os.remove(file_path)
-                            logging.info(f"🗑️ فایل قدیمی حذف شد: {os.path.basename(file_path)}")
-                except Exception as e:
-                    logging.warning(f"⚠️ خطا در هنگام حذف فایل {file_path}: {e}")
-        except Exception as e:
-            logging.error(f"❌ خطای جدی در ریسه پاک‌سازی: {e}")
-        
-        time.sleep(CLEANUP_INTERVAL_SECONDS)
-# --- END: منطق پاک‌سازی خودکار ---
-
+# --- END: منطق جدید مدیریت API Key ---
 
 SPEAKER_VOICES = [
     "Achird", "Zubenelgenubi", "Vindemiatrix", "Sadachbia", "Sadaltager",
@@ -91,9 +74,8 @@ SPEAKER_VOICES = [
 FIXED_MODEL_NAME = "gemini-2.5-flash-preview-tts"
 DEFAULT_MAX_CHUNK_SIZE = 3800
 DEFAULT_SLEEP_BETWEEN_REQUESTS = 8
+# نام پایه فایل دیگر ثابت نیست و به uuid هر درخواست بستگی دارد.
 
-# توابع کمکی (save_binary_file, convert_to_wav, parse_audio_mime_type, smart_text_split) بدون تغییر باقی می‌مانند
-# ... (کد این توابع را اینجا قرار دهید) ...
 def save_binary_file(file_name, data):
     try:
         with open(file_name, "wb") as f: f.write(data)
@@ -126,43 +108,82 @@ def parse_audio_mime_type(mime_type: str) -> dict[str, int]:
 def smart_text_split(text, max_size=3800):
     if len(text) <= max_size: return [text]
     chunks, current_chunk = [], ""
-    sentences = re.split(r'(?<=[.!?؟])\s+', text)
+    # اصلاح regex برای مدیریت بهتر کاراکترهای فارسی و فضای سفید
+    sentences = re.split(r'(?<=[.!?؟…])\s*|\n+', text) # اضافه شد: ... و newline
     for sentence in sentences:
-        if len(current_chunk) + len(sentence) + 1 > max_size:
-            if current_chunk: chunks.append(current_chunk.strip())
-            current_chunk = sentence
+        sentence = sentence.strip() # اطمینان از حذف فضای سفید اضافی در ابتدا/انتها
+        if not sentence: continue # رد کردن جملات خالی
+
+        # اگر اضافه کردن جمله جاری، اندازه قطعه را از حداکثر مجاز فراتر ببرد
+        # یا اگر جمله جاری به تنهایی از حداکثر مجاز بزرگتر باشد
+        if len(current_chunk) + len(sentence) + 1 > max_size or (not current_chunk and len(sentence) > max_size):
+            if current_chunk: # اگر قطعه جاری محتوایی دارد، آن را اضافه کن
+                chunks.append(current_chunk.strip())
+            current_chunk = sentence # شروع یک قطعه جدید با جمله جاری
+            
+            # اگر جمله جاری به تنهایی از max_size بزرگتر است، آن را هم خرد کن
             while len(current_chunk) > max_size:
+                # تلاش برای یافتن نقطه تقسیم در یک مرز منطقی (کاما، نقطه ویرگول، دو نقطه، فاصله)
                 split_idx = next((i for i in range(max_size - 1, max_size // 2, -1) if current_chunk[i] in ['،', ',', ';', ':', ' ']), -1)
-                part, current_chunk = (current_chunk[:split_idx+1], current_chunk[split_idx+1:]) if split_idx != -1 else (current_chunk[:max_size], current_chunk[max_size:])
+                
+                if split_idx != -1:
+                    part, current_chunk = current_chunk[:split_idx+1], current_chunk[split_idx+1:]
+                else: # اگر هیچ مرزی منطقی پیدا نشد، به زور از max_size برش بزن
+                    part, current_chunk = current_chunk[:max_size], current_chunk[max_size:]
+                
                 chunks.append(part.strip())
-        else: current_chunk += (" " if current_chunk else "") + sentence
-    if current_chunk: chunks.append(current_chunk.strip())
-    final_chunks = [c for c in chunks if c]
-    return final_chunks
+                current_chunk = current_chunk.strip() # فضای سفید اضافه را حذف کن
+
+        else: # در غیر این صورت، جمله جاری را به قطعه فعلی اضافه کن
+            current_chunk += (" " if current_chunk else "") + sentence
     
+    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
+    if not PYDUB_AVAILABLE: 
+        logging.warning("⚠️ pydub برای ادغام در دسترس نیست.")
+        return False
     try:
         combined = AudioSegment.empty()
         for i, fp in enumerate(file_paths):
-            if os.path.exists(fp): combined += AudioSegment.from_file(fp) + (AudioSegment.silent(duration=150) if i < len(file_paths) - 1 else AudioSegment.empty())
-            else: logging.warning(f"⚠️ فایل برای ادغام پیدا نشد: {fp}")
+            if os.path.exists(fp): 
+                combined += AudioSegment.from_file(fp) 
+                # اضافه کردن یک سکوت کوتاه بین قطعات، به جز آخرین قطعه
+                if i < len(file_paths) - 1:
+                    combined += AudioSegment.silent(duration=150) # 150 میلی‌ثانیه سکوت
+            else: 
+                logging.warning(f"⚠️ فایل برای ادغام پیدا نشد: {fp}")
         combined.export(output_path, format="wav")
         return True
-    except Exception as e: logging.error(f"❌ خطا در ادغام فایل‌های صوتی: {e}"); return False
+    except Exception as e: 
+        logging.error(f"❌ خطا در ادغام فایل‌های صوتی به {output_path}: {e}")
+        return False
 
-# تابع generate_audio_chunk_with_retry بدون تغییر باقی می‌ماند
-# ... (کد این تابع را اینجا قرار دهید) ...
-def generate_audio_chunk_with_retry(chunk_text, prompt_text, voice, temp):
+# --- START: منطق تولید صدا با قابلیت تلاش مجدد با کلیدهای چرخشی ---
+
+def generate_audio_chunk_with_retry(chunk_text, prompt_text, voice, temp, request_id):
+    """
+    یک قطعه صوتی را با قابلیت تلاش مجدد با کلیدهای مختلف API تولید می‌کند.
+    اگر یک کلید ناموفق بود، به طور خودکار کلید بعدی را امتحان می‌کند تا تمام کلیدها بررسی شوند.
+    """
     if not ALL_API_KEYS:
-        logging.error("❌ هیچ کلید API برای تولید صدا در دسترس نیست.")
+        logging.error(f"❌ (درخواست {request_id}) هیچ کلید API برای تولید صدا در دسترس نیست.")
         return None
+
     for _ in range(len(ALL_API_KEYS)): 
         selected_api_key, key_idx_display = get_next_api_key()
+        
         if not selected_api_key:
-            logging.warning("⚠️ get_next_api_key هیچ کلیدی برنگرداند. تلاش‌های باقیمانده نادیده گرفته می‌شوند.")
+            logging.warning(f"⚠️ (درخواست {request_id}) get_next_api_key هیچ کلیدی برنگرداند. تلاش‌های باقیمانده نادیده گرفته می‌شوند.")
             break 
-        logging.info(f"⚙️ تلاش برای تولید قطعه با کلید API شماره {key_idx_display} (...{selected_api_key[-4:]})")
+
+        logging.info(f"⚙️ (درخواست {request_id}) تلاش برای تولید قطعه با کلید API شماره {key_idx_display} (...{selected_api_key[-4:]})")
+
         try:
             client = genai.Client(api_key=selected_api_key)
             final_text = f'"{prompt_text}"\n{chunk_text}' if prompt_text and prompt_text.strip() else chunk_text
@@ -170,137 +191,184 @@ def generate_audio_chunk_with_retry(chunk_text, prompt_text, voice, temp):
             config = types.GenerateContentConfig(temperature=temp, response_modalities=["audio"],
                 speech_config=types.SpeechConfig(voice_config=types.VoiceConfig(
                     prebuilt_voice_config=types.PrebuiltVoiceConfig(voice_name=voice))))
+
             response = client.models.generate_content(model=FIXED_MODEL_NAME, contents=contents, config=config)
+
             if response.candidates and response.candidates[0].content and response.candidates[0].content.parts and response.candidates[0].content.parts[0].inline_data:
-                logging.info(f"✅ قطعه با موفقیت توسط کلید شماره {key_idx_display} تولید شد.")
+                logging.info(f"✅ (درخواست {request_id}) قطعه با موفقیت توسط کلید شماره {key_idx_display} تولید شد.")
                 return response.candidates[0].content.parts[0].inline_data
             else:
-                logging.warning(f"⚠️ پاسخ API برای قطعه با کلید شماره {key_idx_display} بدون داده صوتی بود. تلاش با کلید بعدی...")
+                logging.warning(f"⚠️ (درخواست {request_id}) پاسخ API برای قطعه با کلید شماره {key_idx_display} بدون داده صوتی بود. تلاش با کلید بعدی...")
+
         except Exception as e:
-            logging.error(f"❌ خطا در تولید قطعه با کلید شماره {key_idx_display}: {e}. تلاش با کلید بعدی...")
-    logging.error("❌ تمام کلیدهای API امتحان شدند اما هیچ‌کدام موفق به تولید قطعه نشدند.")
-    return None
+            logging.error(f"❌ (درخواست {request_id}) خطا در تولید قطعه با کلید شماره {key_idx_display}: {e}. تلاش با کلید بعدی...")
     
-# --- START: بازنویسی کامل core_generate_audio برای ایمنی در برابر همزمانی ---
+    logging.error(f"❌ (درخواست {request_id}) تمام کلیدهای API امتحان شدند اما هیچ‌کدام موفق به تولید قطعه نشدند.")
+    return None
+
 def core_generate_audio(text_input, prompt_input, selected_voice, temperature_val):
-    # <<<< تغییر کلیدی: استفاده از with tempfile.TemporaryDirectory()
-    # این دستور یک پوشه موقت و منحصر به فرد برای این درخواست ایجاد می‌کند
-    # و پس از اتمام کار، به طور خودکار آن را با تمام محتویاتش پاک می‌کند.
-    with tempfile.TemporaryDirectory() as temp_dir:
-        request_id = str(uuid.uuid4()) # <<<< جدید: یک شناسه یکتا برای این درخواست
-        logging.info(f"🚀 شروع فرآیند تولید صدا برای درخواست {request_id[:8]}...")
-        
-        max_chunk, sleep_time = DEFAULT_MAX_CHUNK_SIZE, DEFAULT_SLEEP_BETWEEN_REQUESTS
+    # برای هر درخواست یک شناسه یکتا تولید می‌شود تا نام فایل‌ها تداخل نداشته باشند
+    request_id = str(uuid.uuid4())
+    logging.info(f"🚀 (درخواست {request_id}) شروع فرآیند تولید صدا با قابلیت تعویض کلید خودکار...")
 
-        if not text_input or not text_input.strip():
-            logging.error(f"❌ متن ورودی برای درخواست {request_id[:8]} خالی است.")
-            return None
+    # نام پایه فایل اکنون شامل شناسه درخواست است
+    output_base_name = f"alpha_tts_audio_{request_id}"
+    max_chunk, sleep_time = DEFAULT_MAX_CHUNK_SIZE, DEFAULT_SLEEP_BETWEEN_REQUESTS
 
-        text_chunks = smart_text_split(text_input, max_chunk)
-        if not text_chunks:
-            logging.error(f"❌ متن برای درخواست {request_id[:8]} قابل پردازش به قطعات کوچکتر نیست.")
-            return None
+    if not text_input or not text_input.strip():
+        logging.error(f"❌ (درخواست {request_id}) متن ورودی خالی است.")
+        return None
 
-        generated_files_in_temp = []
-        for i, chunk in enumerate(text_chunks):
-            logging.info(f"🔊 [{request_id[:8]}] پردازش قطعه {i+1}/{len(text_chunks)}...")
+    text_chunks = smart_text_split(text_input, max_chunk)
+    if not text_chunks:
+        logging.error(f"❌ (درخواست {request_id}) متن قابل پردازش به قطعات کوچکتر نیست.")
+        return None
+
+    generated_files = []
+    for i, chunk in enumerate(text_chunks):
+        logging.info(f"🔊 (درخواست {request_id}) پردازش قطعه {i+1}/{len(text_chunks)}...")
+        
+        inline_data = generate_audio_chunk_with_retry(chunk, prompt_input, selected_voice, temperature_val, request_id)
+
+        if inline_data:
+            data_buffer = inline_data.data
+            ext = mimetypes.guess_extension(inline_data.mime_type) or ".wav"
+            if "audio/L" in inline_data.mime_type and ext == ".wav": 
+                data_buffer = convert_to_wav(data_buffer, inline_data.mime_type)
+            if not ext.startswith("."): ext = "." + ext
             
-            inline_data = generate_audio_chunk_with_retry(chunk, prompt_input, selected_voice, temperature_val)
-
-            if inline_data:
-                data_buffer = inline_data.data
-                ext = mimetypes.guess_extension(inline_data.mime_type) or ".wav"
-                if "audio/L" in inline_data.mime_type and ext == ".wav": 
-                    data_buffer = convert_to_wav(data_buffer, inline_data.mime_type)
-                if not ext.startswith("."): ext = "." + ext
-                
-                # <<<< تغییر کلیدی: فایل‌ها در پوشه موقت منحصر به فرد ذخیره می‌شوند
-                temp_fname_base = os.path.join(temp_dir, f"part{i+1:03d}")
-                temp_fpath = save_binary_file(f"{temp_fname_base}{ext}", data_buffer)
-
-                if temp_fpath: 
-                    generated_files_in_temp.append(temp_fpath)
-                else:
-                    logging.error(f"❌ [{request_id[:8]}] موفق به ذخیره فایل برای قطعه {i+1} نشدیم.")
-                    continue
+            # نام فایل قطعه با شناسه درخواست منحصر به فرد می‌شود
+            fname_base = f"{output_base_name}_part{i+1:03d}"
+            fpath = save_binary_file(f"{fname_base}{ext}", data_buffer)
+            if fpath: 
+                generated_files.append(fpath)
             else:
-                logging.error(f"🛑 [{request_id[:8]}] فرآیند متوقف شد زیرا تولید قطعه {i+1} ناموفق بود.")
-                break
+                 logging.error(f"❌ (درخواست {request_id}) موفق به ذخیره فایل برای قطعه {i+1} نشدیم. این قطعه نادیده گرفته می‌شود.")
+                 continue
+        else:
+            logging.error(f"🛑 (درخواست {request_id}) فرآیند متوقف شد زیرا تولید قطعه {i+1} با تمام کلیدهای موجود ناموفق بود.")
+            break 
 
-            if i < len(text_chunks) - 1 and len(text_chunks) > 1: 
-                time.sleep(sleep_time)
+        if i < len(text_chunks) - 1 and len(text_chunks) > 1: 
+            time.sleep(sleep_time)
 
-        if not generated_files_in_temp:
-            logging.error(f"❌ [{request_id[:8]}] هیچ فایل صوتی تولید نشد.")
-            return None
-        
-        # <<<< تغییر کلیدی: نام فایل نهایی نیز منحصر به فرد است
-        final_output_filename = f"alpha_tts_final_{request_id}.wav"
-        final_output_path = os.path.join(OUTPUT_DIR, final_output_filename)
-        
-        final_audio_to_return = None
-
-        if len(generated_files_in_temp) > 1:
-            if PYDUB_AVAILABLE:
-                # <<<< تغییر کلیدی: فایل ادغام شده موقت
-                temp_merged_path = os.path.join(temp_dir, "merged.wav")
-                if merge_audio_files_func(generated_files_in_temp, temp_merged_path):
-                    # انتقال فایل نهایی به پوشه خروجی اصلی
-                    os.rename(temp_merged_path, final_output_path)
-                    final_audio_to_return = final_output_path
-                else:
-                    logging.error(f"❌ [{request_id[:8]}] ادغام فایل‌ها ناموفق بود. اولین قطعه برگردانده می‌شود.")
-                    # اگر ادغام شکست خورد، فقط اولین قطعه را منتقل کن
-                    os.rename(generated_files_in_temp[0], final_output_path)
-                    final_audio_to_return = final_output_path
-            else: 
-                logging.warning(f"⚠️ [{request_id[:8]}] pydub در دسترس نیست. اولین قطعه ارائه می‌شود.")
-                os.rename(generated_files_in_temp[0], final_output_path)
-                final_audio_to_return = final_output_path
-        
-        elif len(generated_files_in_temp) == 1:
-            # فقط یک فایل وجود دارد، آن را به پوشه خروجی منتقل کن
-            os.rename(generated_files_in_temp[0], final_output_path)
-            final_audio_to_return = final_output_path
+    if not generated_files:
+        logging.error(f"❌ (درخواست {request_id}) هیچ فایل صوتی تولید نشد.")
+        return None
+    
+    final_audio_file = None
+    # نام فایل خروجی نهایی نیز باید شامل شناسه درخواست باشد
+    final_output_path_base = f"{output_base_name}_final"
+
+    if len(generated_files) > 1:
+        if PYDUB_AVAILABLE:
+            merged_fn = f"{final_output_path_base}.wav"
+            # نیازی به os.remove قبلی نیست چون نام فایل یونیک است
+            if merge_audio_files_func(generated_files, merged_fn):
+                final_audio_file = merged_fn
+            else:
+                logging.error(f"❌ (درخواست {request_id}) ادغام فایل‌ها ناموفق بود. بازگشت به اولین قطعه.")
+                # اگر ادغام ناموفق بود، اولین قطعه را به عنوان خروجی نهایی برمی‌گردانیم
+                if generated_files:
+                    try:
+                        target_ext = os.path.splitext(generated_files[0])[1]
+                        renamed_first_chunk = f"{final_output_path_base}_single{target_ext}" # نامی متفاوت برای جلوگیری از تداخل
+                        # نیازی به os.remove قبلی نیست
+                        os.rename(generated_files[0], renamed_first_chunk)
+                        final_audio_file = renamed_first_chunk
+                    except Exception as e_rename:
+                         logging.error(f"❌ (درخواست {request_id}) خطا در تغییر نام فایل اولین قطعه (پس از ادغام ناموفق): {e_rename}")
+                         final_audio_file = generated_files[0] # اگر تغییر نام هم نشد، همان فایل اصلی را برگردان
+        else: 
+            logging.warning(f"⚠️ (درخواست {request_id}) pydub در دسترس نیست. اولین قطعه صوتی ارائه می‌شود.")
+            if generated_files:
+                try:
+                    target_ext = os.path.splitext(generated_files[0])[1]
+                    renamed_first_chunk = f"{final_output_path_base}_single{target_ext}"
+                    # نیازی به os.remove قبلی نیست
+                    os.rename(generated_files[0], renamed_first_chunk)
+                    final_audio_file = renamed_first_chunk
+                    for i_gf in range(1, len(generated_files)): # حذف بقیه قطعات اضافی
+                        try: os.remove(generated_files[i_gf])
+                        except: pass
+                except Exception as e_rename_single:
+                    logging.error(f"❌ (درخواست {request_id}) خطا در تغییر نام فایل اولین قطعه (بدون pydub): {e_rename_single}")
+                    final_audio_file = generated_files[0] # اگر تغییر نام هم نشد، همان فایل اصلی را برگردان
+
+    elif len(generated_files) == 1: # فقط یک قطعه تولید شده است
+        try:
+            target_ext = os.path.splitext(generated_files[0])[1]
+            final_single_fn = f"{final_output_path_base}{target_ext}"
+            # نیازی به os.remove قبلی نیست
+            os.rename(generated_files[0], final_single_fn)
+            final_audio_file = final_single_fn
+        except Exception as e_rename_single_final:
+            logging.error(f"❌ (درخواست {request_id}) خطا در تغییر نام فایل تکی نهایی: {e_rename_single_final}")
+            final_audio_file = generated_files[0]
+    
+    # --- تمیز کردن فایل‌های میانی (اگر ادغام انجام شده باشد یا تنها یک فایل بوده باشد) ---
+    for fp_cleanup in generated_files:
+        # مطمئن می‌شویم که فایل نهایی را حذف نمی‌کنیم
+        if final_audio_file and os.path.abspath(fp_cleanup) == os.path.abspath(final_audio_file):
+            continue
+        try:
+            if os.path.exists(fp_cleanup):
+                os.remove(fp_cleanup)
+                logging.info(f"🗑️ (درخواست {request_id}) فایل میانی حذف شد: {os.path.basename(fp_cleanup)}")
+        except Exception as e_cleanup:
+            logging.warning(f"⚠️ (درخواست {request_id}) خطا در حذف فایل میانی {os.path.basename(fp_cleanup)}: {e_cleanup}")
+
+    if final_audio_file and os.path.exists(final_audio_file):
+        logging.info(f"✅ (درخواست {request_id}) فایل صوتی نهایی با موفقیت تولید شد: {os.path.basename(final_audio_file)}")
+    elif final_audio_file:
+        logging.warning(f"⚠️ (درخواست {request_id}) فایل نهایی '{final_audio_file}' پس از پردازش وجود ندارد!")
+        return None
+    else:
+        logging.error(f"❓ (درخواست {request_id}) وضعیت نامشخص برای فایل نهایی.")
+        return None
         
-        if final_audio_to_return and os.path.exists(final_audio_to_return):
-            logging.info(f"✅ [{request_id[:8]}] فایل صوتی نهایی با موفقیت تولید شد: {os.path.basename(final_audio_to_return)}")
-            return final_audio_to_return
-        else:
-            logging.error(f"❌ [{request_id[:8]}] تولید فایل نهایی با شکست مواجه شد.")
-            return None
-    # <<<< اینجا پوشه temp_dir و تمام محتویات آن به طور خودکار حذف می‌شود.
+    return final_audio_file
 
-# --- END: بازنویسی core_generate_audio ---
+# --- END: منطق جدید تولید صدا ---
 
-
-# تابع رابط کاربری Gradio (بدون تغییر)
 def gradio_tts_interface(use_file_input, uploaded_file, text_to_speak, speech_prompt, speaker_voice, temperature, progress=gr.Progress(track_tqdm=True)):
     actual_text = ""
     if use_file_input:
         if uploaded_file:
             try:
-                with open(uploaded_file.name, 'r', encoding='utf-8') as f: actual_text = f.read().strip()
-                if not actual_text: logging.error("❌ فایل آپلود شده خالی است یا خوانده نشد."); return None
-            except Exception as e: logging.error(f"❌ خطا در خواندن فایل آپلود شده: {e}"); return None
-        else: logging.warning("❌ گزینه استفاده از فایل انتخاب شده اما فایلی آپلود نشده."); return None
+                # اطمینان از اینکه فایل به درستی از مسیر temp خوانده می‌شود
+                with open(uploaded_file.name, 'r', encoding='utf-8') as f: 
+                    actual_text = f.read().strip()
+                if not actual_text: 
+                    logging.error("❌ فایل آپلود شده خالی است یا خوانده نشد.")
+                    return None
+            except Exception as e: 
+                logging.error(f"❌ خطا در خواندن فایل آپلود شده: {e}")
+                return None
+        else: 
+            logging.warning("❌ گزینه استفاده از فایل انتخاب شده اما فایلی آپلود نشده.")
+            return None
     else:
         actual_text = text_to_speak
-        if not actual_text or not actual_text.strip(): logging.warning("❌ متن ورودی برای تبدیل خالی است."); return None
+        if not actual_text or not actual_text.strip(): 
+            logging.warning("❌ متن ورودی برای تبدیل خالی است.")
+            return None
     
+    # Gradio به صورت خودکار فایل خروجی را پس از اتمام درخواست حذف می‌کند.
     final_path = core_generate_audio(actual_text, speech_prompt, speaker_voice, temperature)
     return final_path
 
-# تابع ریستارت خودکار (بدون تغییر)
+# --- تابع جدید برای ریست خودکار هر 24 ساعت ---
 def auto_restart_service():
     RESTART_INTERVAL_SECONDS = 24 * 60 * 60
     logging.info(f"سرویس برای ری‌استارت خودکار پس از {RESTART_INTERVAL_SECONDS / 3600:.0f} ساعت زمان‌بندی شده است.")
     time.sleep(RESTART_INTERVAL_SECONDS)
     logging.info(f"زمان ری‌استارت خودکار فرا رسیده است. برنامه برای ری‌استارت خارج می‌شود...")
     os._exit(1)
+# --- END: تابع ری‌استارت خودکار ---
+
 
-# CSS و HTML (بدون تغییر)
-# ... (کد CSS و HTML را اینجا قرار دهید) ...
+# --- CSS و Gradio UI (بدون تغییر) ---
 custom_css_inspired_by_image = f"""
 @import url('https://fonts.googleapis.com/css2?family=Vazirmatn:wght@300;400;500;700;800&display=swap');
 :root {{
@@ -353,37 +421,84 @@ alpha_header_html_v3 = """
 </div>
 """
 
+# --- رابط کاربری Gradio ---
 with gr.Blocks(theme=gr.themes.Base(font=[gr.themes.GoogleFont("Vazirmatn")]), css=custom_css_inspired_by_image, title="آلفا TTS") as demo:
     gr.HTML(alpha_header_html_v3)
 
     with gr.Column(elem_classes=["main-content-panel-alpha"]):
         use_file_input_cb = gr.Checkbox(label="📄 استفاده از فایل متنی (.txt)", value=False, elem_id="use_file_cb_alpha_v3")
-        uploaded_file_input = gr.File(label=" ", file_types=['.txt'], visible=False, elem_id="file_uploader_alpha_main_v3") 
-        text_to_speak_tb = gr.Textbox(label="متن فارسی برای تبدیل", placeholder="مثال: سلام، فردا هوا چطور است؟", lines=5, value="", visible=True, elem_id="text_input_main_alpha_v3")
-        use_file_input_cb.change(fn=lambda x: (gr.update(visible=x, label=" " if x else "متن فارسی برای تبدیل"), gr.update(visible=not x)), inputs=use_file_input_cb, outputs=[uploaded_file_input, text_to_speak_tb])
-        speech_prompt_tb = gr.Textbox(label="سبک گفتار (اختیاری)", placeholder="مثال: با لحنی شاد و پرانرژی", value="با لحنی دوستانه و رسا صحبت کن.", lines=2, elem_id="speech_prompt_alpha_v3")
-        speaker_voice_dd = gr.Dropdown(SPEAKER_VOICES, label="انتخاب گوینده و لهجه", value="Charon", elem_id="speaker_voice_alpha_v3")
-        temperature_slider = gr.Slider(minimum=0.1, maximum=1.5, step=0.05, value=0.9, label="میزان خلاقیت صدا", elem_id="temperature_slider_alpha_v3")
+        uploaded_file_input = gr.File(
+            label=" ", 
+            file_types=['.txt'], 
+            visible=False,
+            elem_id="file_uploader_alpha_main_v3"
+        ) 
+        text_to_speak_tb = gr.Textbox(
+            label="متن فارسی برای تبدیل", 
+            placeholder="مثال: سلام، فردا هوا چطور است؟",
+            lines=5,
+            value="", 
+            visible=True,
+            elem_id="text_input_main_alpha_v3"
+        )
+        use_file_input_cb.change(
+            fn=lambda x: (gr.update(visible=x, label=" " if x else "متن فارسی برای تبدیل"), gr.update(visible=not x)),
+            inputs=use_file_input_cb,
+            outputs=[uploaded_file_input, text_to_speak_tb]
+        )
+
+        speech_prompt_tb = gr.Textbox(
+            label="سبک گفتار (اختیاری)",
+            placeholder="مثال: با لحنی شاد و پرانرژی",
+            value="با لحنی دوستانه و رسا صحبت کن.",
+            lines=2, elem_id="speech_prompt_alpha_v3"
+        )
+        speaker_voice_dd = gr.Dropdown(
+            SPEAKER_VOICES, label="انتخاب گوینده و لهجه", value="Charon", elem_id="speaker_voice_alpha_v3"
+        )
+        temperature_slider = gr.Slider(
+            minimum=0.1, maximum=1.5, step=0.05, value=0.9, label="میزان خلاقیت صدا",
+            elem_id="temperature_slider_alpha_v3"
+        )
         gr.Markdown("<p class='temp_description_class_alpha_v3'>مقادیر بالاتر = تنوع بیشتر، مقادیر پایین‌تر = یکنواختی بیشتر.</p>")
+
         generate_button = gr.Button("🚀 تولید و پخش صدا", elem_classes=["generate-button-final"], elem_id="generate_button_alpha_v3")
+        
         output_audio = gr.Audio(label=" ", type="filepath", elem_id="output_audio_player_alpha_v3")
-        generate_button.click(fn=gradio_tts_interface, inputs=[ use_file_input_cb, uploaded_file_input, text_to_speak_tb, speech_prompt_tb, speaker_voice_dd, temperature_slider ], outputs=[output_audio])
+    
+        generate_button.click(
+            fn=gradio_tts_interface,
+            inputs=[ use_file_input_cb, uploaded_file_input, text_to_speak_tb, speech_prompt_tb, speaker_voice_dd, temperature_slider ],
+            outputs=[output_audio] 
+        )
+
         gr.Markdown("<h3 class='section-title-main-alpha' style='margin-top:2.5rem; text-align:center; border-bottom:none;'>نمونه‌های کاربردی</h3>", elem_id="examples_section_title_v3")
-        gr.Examples(examples=[[False, None, "سلام بر شما، امیدوارم روز خوبی داشته باشید.", "با لحنی گرم و صمیمی.", "Zephyr", 0.85], [False, None, "این یک آزمایش برای بررسی کیفیت صدای تولید شده توسط هوش مصنوعی آلفا است.", "با صدایی طبیعی و روان.", "Charon", 0.9]], inputs=[ use_file_input_cb, uploaded_file_input, text_to_speak_tb, speech_prompt_tb, speaker_voice_dd, temperature_slider ], outputs=[output_audio], fn=gradio_tts_interface, cache_examples=False)
+        gr.Examples(
+            examples=[
+                [False, None, "سلام بر شما، امیدوارم روز خوبی داشته باشید.", "با لحنی گرم و صمیمی.", "Zephyr", 0.85],
+                [False, None, "این یک آزمایش برای بررسی کیفیت صدای تولید شده توسط هوش مصنوعی آلفا است.", "با صدایی طبیعی و روان.", "Charon", 0.9],
+            ],
+            inputs=[ use_file_input_cb, uploaded_file_input, text_to_speak_tb, speech_prompt_tb, speaker_voice_dd, temperature_slider ],
+            outputs=[output_audio],
+            fn=gradio_tts_interface,
+            cache_examples=False 
+        )
     gr.Markdown("<p class='app-footer-final'>Alpha Language Learning © 2024</p>")
 
-
 if __name__ == "__main__":
-    # <<<< جدید: اجرای ریسه‌های پس‌زمینه در شروع برنامه
+    # اجرای تابع ری‌استارت خودکار در یک ترد جداگانه
     threading.Thread(target=auto_restart_service, daemon=True, name="AutoRestartThread").start()
-    threading.Thread(target=cleanup_old_files, daemon=True, name="FileCleanupThread").start()
-
+    
     if len(ALL_API_KEYS) > 0 :
-        # <<<< نکته مهم برای هاگینگ فیس: استفاده از .queue()
-        # این متد درخواست‌ها را در یک صف قرار می‌دهد و از کرش کردن برنامه به دلیل
-        # درخواست‌های همزمان زیاد (که منابع را تمام می‌کنند) جلوگیری می‌کند.
-        # concurrency_count مشخص می‌کند چند کاربر همزمان می‌توانند پردازش را اجرا کنند.
-        # برای پلن رایگان، 1 یا 2 مقدار معقولی است.
-        demo.queue().launch(server_name="0.0.0.0", server_port=int(os.getenv("PORT", 7860)))
+        # فعال‌سازی همزمانی برای Gradio:
+        # concurrency_count تعداد درخواست‌هایی است که Gradio می‌تواند به صورت همزمان پردازش کند.
+        # برای Spaces رایگان، 2 یا 3 (حداکثر 4) معمولاً نقطه شروع خوبی است تا منابع Space بیش از حد بارگذاری نشود.
+        # max_queue_size تعداد درخواست‌هایی است که در صف نگه داشته می‌شوند.
+        demo.launch(
+            server_name="0.0.0.0", 
+            server_port=int(os.getenv("PORT", 7860)),
+            concurrency_count=3, # تنظیم برای پردازش 3 درخواست همزمان
+            max_queue_size=10    # حداکثر 10 درخواست در صف نگهداری می‌شوند
+        )
     else:
         logging.critical("🔴 برنامه به دلیل عدم وجود کلید API جیمینای اجرا نشد. لطفاً Secrets را بررسی کنید.")