Update app.py

app.py

@@ -3,27 +3,42 @@ import edge_tts
 import tempfile
 import asyncio
 import traceback
-import threading # دیگر برای _get_or_create_event_loop استفاده نمی‌شود، اما ممکن است کتابخانه‌های دیگر از آن استفاده کنند
 import os
 import google.generativeai as genai
 import logging
 
+# --- START: پیکربندی لاگینگ ---
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(threadName)s - %(message)s')
-
-GOOGLE_API_KEY = os.environ.get('GOOGLE_API_KEY')
-model = None
-if GOOGLE_API_KEY:
-    try:
-        genai.configure(api_key=GOOGLE_API_KEY)
-        model = genai.GenerativeModel('gemini-1.5-flash-latest')
-        logging.info("سرویس Gemini با موفقیت پیکربندی شد.")
-    except Exception as e:
-        logging.error(f"خطا در پیکربندی Gemini: {e}. قابلیت ترجمه غیرفعال خواهد بود.")
-        model = None
+# --- END: پیکربندی لاگینگ ---
+
+# --- START: منطق چرخش API Key برای Gemini ---
+API_KEYS_GEMINI = []
+i = 1
+while True:
+    # خواندن کلیدها با فرمت GEMINI_API_KEY_1, GEMINI_API_KEY_2, ...
+    key = os.environ.get(f'GEMINI_API_KEY_{i}')
+    if key:
+        API_KEYS_GEMINI.append(key)
+        i += 1
+    else:
+        break
+
+NUM_GEMINI_KEYS = len(API_KEYS_GEMINI)
+current_gemini_key_index = 0
+# قفل برای همگام‌سازی دسترسی به current_gemini_key_index و پیکربندی genai
+gemini_operations_lock = asyncio.Lock()
+
+if NUM_GEMINI_KEYS == 0:
+    logging.error(
+        'خطای حیاتی: هیچ Secret با نام GEMINI_API_KEY_n (مثلاً GEMINI_API_KEY_1) یافت نشد! ' +
+        'قابلیت ترجمه غیرفعال خواهد بود. لطفاً Secret ها را در تنظیمات Space خود اضافه کنید.'
+    )
 else:
-    logging.warning("هشدار: کلید API گوگل (GOOGLE_API_KEY) تنظیم نشده است. قابلیت ترجمه غیرفعال خواهد بود.")
+    logging.info(f"تعداد {NUM_GEMINI_KEYS} کلید API جیمینای بارگذاری شد.")
+# --- END: منطق چرخش API Key برای Gemini ---
+
 
-# --- دیکشنری صداهای انگلیسی با حذف موارد مشخص شده ---
+# --- دیکشنری صداهای انگلیسی (بدون تغییر) ---
 language_dict_persian_keys = {
     'انگلیسی (آمریکا) - جنی (زن)': 'en-US-JennyNeural',
     'انگلیسی (آمریکا) - گای (مرد)': 'en-US-GuyNeural',
@@ -65,19 +80,48 @@ language_dict_persian_keys = {
 }
 
 async def translate_text_gemini(text, target_language="English"):
-    if not model: return "خطا: سرویس ترجمه در دسترس نیست (کلید API یا مدل مشکل دارد).", None
-    if not text or not text.strip(): return "خطا: متنی برای ترجمه وارد نشده است.", None
-    try:
-        prompt = f"Translate the following Persian text to {target_language}. Provide only the translated English text, naturally and fluently, without any extra phrases, explanations, or markdown formatting. Be concise and accurate.\n\nPersian: \"{text}\"\n{target_language}:"
-        # این تابع باید در یک event loop که توسط Gradio مدیریت می‌شود اجرا شود
-        response = await model.generate_content_async(prompt)
-        translated_text = response.text.strip()
-        if translated_text.lower().startswith(f"{target_language.lower()}:"):
-            translated_text = translated_text[len(target_language)+1:].strip()
-        return "ترجمه موفق", translated_text
-    except Exception as e:
-        logging.error(f"خطای Gemini: {e}\n{traceback.format_exc()}")
-        return f"خطای ترجمه: {type(e).__name__}", None
+    if NUM_GEMINI_KEYS == 0:
+        return "خطا: سرویس ترجمه پیکربندی نشده (هیچ کلید API جیمینای معتبری یافت نشد).", None
+    if not text or not text.strip():
+        return "خطا: متنی برای ترجمه وارد نشده است.", None
+
+    selected_api_key = None
+    model_to_use = 'gemini-1.5-flash-latest' # یا هر مدلی که نیاز دارید
+
+    async with gemini_operations_lock:
+        global current_gemini_key_index # برای تغییر ایندکس سراسری
+
+        # انتخاب کلید بعدی به صورت چرخشی
+        key_index_to_use = current_gemini_key_index
+        selected_api_key = API_KEYS_GEMINI[key_index_to_use]
+        current_gemini_key_index = (current_gemini_key_index + 1) % NUM_GEMINI_KEYS
+        
+        logging.info(f"قفل Gemini گرفته شد. استفاده از کلید API با اندیس: {key_index_to_use} (...{selected_api_key[-4:]}) برای مدل {model_to_use}")
+
+        try:
+            # پیکربندی Gemini با کلید انتخاب شده برای این درخواست
+            genai.configure(api_key=selected_api_key)
+            # ایجاد نمونه مدل با پیکربندی فعلی
+            model_instance = genai.GenerativeModel(model_to_use)
+            
+            logging.info(f"پیکربندی Gemini با کلید ...{selected_api_key[-4:]} برای مدل {model_to_use} انجام شد.")
+
+            prompt = f"Translate the following Persian text to {target_language}. Provide only the translated English text, naturally and fluently, without any extra phrases, explanations, or markdown formatting. Be concise and accurate.\n\nPersian: \"{text}\"\n{target_language}:"
+            
+            response = await model_instance.generate_content_async(prompt)
+            translated_text = response.text.strip()
+            
+            if translated_text.lower().startswith(f"{target_language.lower()}:"):
+                translated_text = translated_text[len(target_language)+1:].strip()
+            
+            logging.info(f"ترجمه با کلید ...{selected_api_key[-4:]} موفق. قفل Gemini آزاد می‌شود.")
+            return "ترجمه موفق", translated_text
+            
+        except Exception as e:
+            key_info = f"...{selected_api_key[-4:]}" if selected_api_key else "N/A"
+            logging.error(f"خطای Gemini با کلید {key_info} (مدل {model_to_use}): {e}\n{traceback.format_exc()}")
+            logging.info(f"قفل Gemini برای کلید {key_info} (پس از خطا) آزاد می‌شود.") # async with خودش مدیریت می‌کند
+            return f"خطای ترجمه ({type(e).__name__}) با کلید جاری.", None
 
 MAX_TTS_RETRIES = 1
 TTS_RETRY_DELAY = 0.5
@@ -119,21 +163,24 @@ async def text_to_speech_edge_async(text_to_speak, tts_voice_key, rate, volume,
 
     return "خطای TTS: تلاش‌ها برای تولید صدا ناموفق بود.", None
 
-# تابع _get_or_create_event_loop و _event_loops_by_thread حذف شد.
 
-async def translate_and_speak_async_wrapper(persian_text, english_tts_voice_key, rate, volume, pitch): # تابع async شد
+async def translate_and_speak_async_wrapper(persian_text, english_tts_voice_key, rate, volume, pitch):
     error_message_for_ui = ""
 
-    if not GOOGLE_API_KEY or not model:
-        error_message_for_ui = "خطا: سرویس ترجمه پیکربندی نشده است. لطفاً از تنظیم صحیح GOOGLE_API_KEY در Secrets اطمینان حاصل کنید."
-        return error_message_for_ui, None
+    if NUM_GEMINI_KEYS == 0: # بررسی اولیه وجود کلیدهای Gemini
+        error_message_for_ui = (
+            "خطا: سرویس ترجمه پیکربندی نشده است. "
+            "هیچ کلید API جیمینای (GEMINI_API_KEY_n) در بخش Secrets این Space یافت نشد. "
+            "لطفاً حداقل یک کلید با نام GEMINI_API_KEY_1 تنظیم کنید."
+        )
+        return error_message_for_ui, None # برگرداندن None برای صوت
+
     if not persian_text or not persian_text.strip():
         error_message_for_ui = "لطفاً متن فارسی را برای ترجمه وارد کنید."
         return error_message_for_ui, None
 
-    # فراخوانی مستقیم با await
     translation_status_msg, translated_text = await translate_text_gemini(persian_text, target_language="English")
-    translated_text_output = translated_text if translated_text else "ترجمه ناموفق بود."
+    translated_text_output = translated_text if translated_text else "ترجمه ناموفق بود یا خطایی رخ داد."
 
     if "خطا" in translation_status_msg or not translated_text:
         error_message_for_ui = f"{translated_text_output}\n({translation_status_msg})"
@@ -148,7 +195,6 @@ async def translate_and_speak_async_wrapper(persian_text, english_tts_voice_key,
             error_message_for_ui = f"{translated_text_output}\n\n(خطای TTS: هیچ صدایی برای انتخاب موجود نیست.)"
             return error_message_for_ui, None
 
-    # فراخوانی مستقیم با await
     tts_status_msg, audio_path = await text_to_speech_edge_async(translated_text, english_tts_voice_key, rate, volume, pitch)
 
     if "خطا" in tts_status_msg or not audio_path:
@@ -157,17 +203,14 @@ async def translate_and_speak_async_wrapper(persian_text, english_tts_voice_key,
 
     return translated_text_output, audio_path
 
+# --- بخش UI و Gradio (بدون تغییر عمده به جز پیام هشدار کلید) ---
 FLY_PRIMARY_COLOR_HEX = "#4F46E5"
 FLY_SECONDARY_COLOR_HEX = "#10B981"
-FLY_ACCENT_COLOR_HEX = "#D97706"
-FLY_TEXT_COLOR_HEX = "#1F2937"
-FLY_SUBTLE_TEXT_HEX = "#6B7280"
-FLY_LIGHT_BACKGROUND_HEX = "#F9FAFB"
-FLY_WHITE_HEX = "#FFFFFF"
-FLY_BORDER_COLOR_HEX = "#D1D5DB"
+# ... (بقیه متغیرهای CSS شما بدون تغییر) ...
 FLY_INPUT_BG_HEX_SIMPLE = "#F3F4F6"
 FLY_PANEL_BG_SIMPLE = "#E0F2FE"
 
+
 app_theme_outer = gr.themes.Base(
     font=[gr.themes.GoogleFont("Inter"), "system-ui", "sans-serif"],
 ).set(
@@ -241,10 +284,14 @@ with gr.Blocks(theme=app_theme_outer, css=custom_css, title="آموزش زبان
 
     with gr.Column(elem_classes=["main-content-area"]):
         with gr.Group(elem_classes=["content-panel-simple"]):
-            if not GOOGLE_API_KEY or not model:
-                missing_key_msg = "⚠️ هشدار: قابلیت ترجمه غیرفعال است. "
-                if not GOOGLE_API_KEY: missing_key_msg += "لطفاً کلید GOOGLE_API_KEY را در بخش Secrets این Space تنظیم کنید."
-                elif not model: missing_key_msg += "خطا در بارگذاری مدل Gemini. لطفاً لاگ‌ها یا صحت کلید API را بررسی کنید."
+            # نمایش هشدار اگر هیچ کلید API جیمینای تنظیم نشده باشد
+            if NUM_GEMINI_KEYS == 0:
+                missing_key_msg = (
+                    "⚠️ هشدار: قابلیت ترجمه غیرفعال است. "
+                    "هیچ کلید API جیمینای (با فرمت GEMINI_API_KEY_1, GEMINI_API_KEY_2, ...) "
+                    "در بخش Secrets این Space یافت نشد. "
+                    "لطفاً حداقل یک کلید با نام GEMINI_API_KEY_1 تنظیم کنید."
+                )
                 gr.Markdown(f"<div class='api-warning-message'>{missing_key_msg}</div>")
 
             with gr.Row(elem_classes=["main-content-row"]):
@@ -288,31 +335,34 @@ with gr.Blocks(theme=app_theme_outer, css=custom_css, title="آموزش زبان
                         label="🎧 فایل صوتی",
                         format="mp3",
                         interactive=False,
-                        autoplay=True
+                        autoplay=True # در برخی مرورگرها ممکن است کار نکند
                     )
 
             if language_dict_persian_keys and default_english_tts_voice and default_english_tts_voice != "لیست صداها خالی است":
                 gr.HTML("<hr class='custom-hr'>")
                 num_voices = len(language_dict_persian_keys)
                 voice_keys = list(language_dict_persian_keys.keys())
+                # انتخاب صداهای نمونه به شکلی که از ایندکس خارج نشود
                 voice1_idx = 0
-                voice2_idx = min(1, num_voices - 1) if num_voices > 1 else 0
-                voice3_idx = min(2, num_voices - 1) if num_voices > 2 else 0
-
+                voice2_idx = min(1, num_voices - 1) if num_voices > 0 else 0
+                voice3_idx = min(2, num_voices - 1) if num_voices > 0 else 0
+                
                 example_list = [
-                        ["قیمت این لباس چقدر است؟", voice_keys[voice1_idx], 0, 0, 0],
-                        ["می‌توانید آدرس را روی نقشه به من نشان دهید؟", voice_keys[voice2_idx], 0, 0, 0],
-                        ["ببخشید، متوجه نشدم. امکان دارد تکرار کنید؟", voice_keys[voice3_idx], -10, 0, 0],
+                        ["قیمت این لباس چقدر است؟", voice_keys[voice1_idx] if num_voices > 0 else current_default_voice, 0, 0, 0],
+                        ["می‌توانید آدرس را روی نقشه به من نشان دهید؟", voice_keys[voice2_idx] if num_voices > 0 else current_default_voice, 0, 0, 0],
+                        ["ببخشید، متوجه نشدم. امکان دارد تکرار کنید؟", voice_keys[voice3_idx] if num_voices > 0 else current_default_voice, -10, 0, 0],
                     ]
-
-                gr.Examples(
-                    examples=example_list,
-                    inputs=[input_text_persian, language_dropdown_tts_english, rate_slider, volume_slider, pitch_slider],
-                    outputs=[output_text_translated, output_audio],
-                    fn=translate_and_speak_async_wrapper, # استفاده از تابع async wrapper
-                    cache_examples=os.getenv("GRADIO_CACHE_EXAMPLES", "False").lower() == "true",
-                    label="💡 نمونه‌های کاربردی"
-                )
+                if num_voices == 0: example_list = [] # اگر صدایی نیست، مثال خالی باشد
+
+                if example_list:
+                    gr.Examples(
+                        examples=example_list,
+                        inputs=[input_text_persian, language_dropdown_tts_english, rate_slider, volume_slider, pitch_slider],
+                        outputs=[output_text_translated, output_audio],
+                        fn=translate_and_speak_async_wrapper,
+                        cache_examples=os.getenv("GRADIO_CACHE_EXAMPLES", "False").lower() == "true",
+                        label="💡 نمونه‌های کاربردی"
+                    )
             else:
                 gr.Markdown("<p style='text-align:center; color:var(--fly-text-secondary); margin-top:1rem;'>نمونه‌ای برای نمایش موجود نیست (لیست صداها خالی است یا صدای پیش‌فرض معتبر نیست).</p>")
 
@@ -320,23 +370,20 @@ with gr.Blocks(theme=app_theme_outer, css=custom_css, title="آموزش زبان
 
     if 'submit_button' in locals() and submit_button is not None:
         submit_button.click(
-            fn=translate_and_speak_async_wrapper, # استفاده از تابع async wrapper
+            fn=translate_and_speak_async_wrapper,
             inputs=[input_text_persian, language_dropdown_tts_english, rate_slider, volume_slider, pitch_slider],
             outputs=[output_text_translated, output_audio]
         )
     else:
-        logging.error("Submit button was not initialized correctly or is None.")
+        logging.error("دکمه ارسال (Submit button) به درستی مقداردهی اولیه نشده است.")
 
 if __name__ == "__main__":
     if not language_dict_persian_keys:
         logging.critical("خطای بحرانی: language_dict_persian_keys خالی است!")
 
-    # اگر از داخل یک environment مثل Hugging Face Spaces اجرا می‌کنید که خودش event loop را مدیریت می‌کند،
-    # نیازی به asyncio.run(demo.launch(...)) نیست. demo.launch() به تنها کافی است.
-    # Gradio خودش با توابع async به درستی کار می‌کند.
     demo.launch(
         server_name="0.0.0.0",
-        server_port=7860,
+        server_port=int(os.getenv("PORT", 7860)), # استفاده از متغیر PORT اگر تنظیم شده باشد
         debug=os.environ.get("GRADIO_DEBUG", "False").lower() == "true",
         show_error=True
-        )
+    )