Update main.py

main.py

@@ -16,6 +16,16 @@ from huggingface_hub import AsyncInferenceClient
 from PIL import Image
 from pydub import AudioSegment
 
+# --- تابع تبدیل اعداد فارسی/عربی به انگلیسی ---
+def to_english_digits(text):
+    if not text:
+        return text
+    persian_digits = '۰۱۲۳۴۵۶۷۸۹'
+    arabic_digits = '٠١٢٣٤٥٦٧٨٩'
+    english_digits = '0123456789'
+    translation_table = str.maketrans(persian_digits + arabic_digits, english_digits * 2)
+    return str(text).translate(translation_table)
+
 # --- تنظیمات وب سرور ---
 app = Flask(__name__)
 
@@ -27,7 +37,7 @@ def run_flask():
     app.run(host="0.0.0.0", port=7860)
 
 
-# --- ساختار کیبورد آپدیت شده (دقیقاً طبق چیدمان درخواستی شما) ---
+# --- ساختار کیبورد آپدیت شده (دقیقاً طبق چیدمان درخواستی شما در ۵ ردیف) ---
 MAIN_KEYPAD_DICT = {
     "rows": [
         # ردیف اول
@@ -247,59 +257,7 @@ processed_message_ids = set()
 user_last_request_time = {}
 
 
-# --- بخش پردازش ویرایش عکس با FLUX.2-dev ---
-async def process_image_edit(client, chat_id, image_bytes, prompt):
-    if not HF_TOKENS:
-        await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
-        return
-
-    proc_msg = await send_with_keyboard(client, chat_id, "🪄 در حال پردازش و اعمال جادوی FLUX.2 روی عکس شما...\n(این فرآیند ممکن است کمی طول بکشد)", False)
-    
-    keys_to_try = HF_TOKENS.copy()
-    random.shuffle(keys_to_try)
-    generated_image = None
-    last_error_log = "سرور پاسخ نداد."
-    
-    for token in keys_to_try:
-        try:
-            hf_client = AsyncInferenceClient(provider="fal-ai", api_key=token)
-            # استفاده از متد image_to_image با ارسال دیتای بایت عکس و پرامپت متنی کاربر
-            generated_image = await hf_client.image_to_image(
-                image_bytes,
-                prompt=prompt,
-                model="black-forest-labs/FLUX.2-dev"
-            )
-            break 
-        except Exception as e:
-            last_error_log = str(e)
-            continue
-            
-    try:
-        if proc_msg:
-            msg_id = getattr(proc_msg, 'message_id', None)
-            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
-            if msg_id: await client.delete_messages(chat_id, [msg_id])
-    except Exception: pass
-
-    if not generated_image:
-        await send_with_keyboard(client, chat_id, f"❌ متأسفانه ویرایش عکس انجام نشد.\n\n⚠️ علت:\n{last_error_log[:200]}", True)
-        return
-
-    try:
-        file_name = f"edited_flux_{random.randint(1000, 999999)}.jpg"
-        rgb_im = generated_image.convert('RGB')
-        rgb_im.save(file_name, format="JPEG", quality=100)
-        await asyncio.sleep(1)
-        caption_text = f"🪄 ویرایش عکس با هوش مصنوعی Flux.2 انجام شد!\n\n✨ تغییرات خواسته شده: {prompt}"
-        upload_result = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
-        if upload_result is not True:
-            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما خطا در ارسال به روبیکا رخ داد:\n`{str(upload_result)[:800]}`", True)
-        if os.path.exists(file_name): os.remove(file_name)
-    except Exception as e:
-        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس ویرایش شده:\n{str(e)[:150]}", True)
-
-
-# --- پردازش‌های قبلی ---
+# --- ۱. پردازش چت متنی و چندرسانه‌ای ---
 async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=None):
     if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلیدهای API جیمینای تنظیم نشده‌اند.", False)
     proc_msg = await send_with_keyboard(client, chat_id, "🧠 در حال پردازش...", False)
@@ -312,7 +270,15 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
     if file_bytes and file_name:
         base64_data = base64.b64encode(file_bytes).decode('utf-8')
         mime_type, _ = mimetypes.guess_type(file_name)
-        if not mime_type: mime_type = "image/jpeg"
+        if not mime_type:
+            if file_name.endswith(('.jpg', '.jpeg')): mime_type = "image/jpeg"
+            elif file_name.endswith('.png'): mime_type = "image/png"
+            elif file_name.endswith('.pdf'): mime_type = "application/pdf"
+            elif file_name.endswith('.mp4'): mime_type = "video/mp4"
+            elif file_name.endswith('.mp3'): mime_type = "audio/mp3"
+            elif file_name.endswith(('.ogg', '.oga')): mime_type = "audio/ogg"
+            elif file_name.endswith('.wav'): mime_type = "audio/wav"
+            else: mime_type = "image/jpeg"
         new_parts.append({"inlineData": {"mimeType": mime_type, "data": base64_data}})
 
     if history and history[-1]["role"] == "user": history[-1]["parts"].extend(new_parts)
@@ -349,7 +315,7 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
 
     if not final_answer:
         if history and history[-1]["role"] == "user": history.pop()
-        await send_with_keyboard(client, chat_id, "❌ متأسفانه پاسخی دریافت نشد.", False)
+        await send_with_keyboard(client, chat_id, "❌ متأسفانه پاسخی دریافت نشد. (شاید سایز فایل بیش از حد مجاز بوده است)", False)
         return
 
     history.append({"role": "model", "parts": [{"text": final_answer}]})
@@ -377,14 +343,15 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
     except Exception:
         await send_with_keyboard(client, chat_id, "❌ خطایی در ارسال پیام رخ داد.", False)
 
+# --- ۲. پردازش ساخت عکس ---
 async def process_image(client, chat_id, prompt):
-    if not HF_TOKENS: return await send_with_keyboard(client, chat_id, "❌ توکن‌ها تنظیم نشده‌اند.", False)
+    if not HF_TOKENS: return await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
     proc_msg = await send_with_keyboard(client, chat_id, "✨ در حال ترجمه و بهینه‌سازی پرامپت شما توسط جیمینای...\n(تبدیل به پرامپت حرفه‌ای)", False)
     enhanced_prompt = prompt 
     if GEMINI_KEYS:
         keys_to_try_gemini = GEMINI_KEYS.copy()
         random.shuffle(keys_to_try_gemini)
-        gemini_sys_prompt = f"You are an expert AI image generation prompt engineer. Translate the following user input to English, and enhance it with high-quality, highly detailed, 4k resolution, cinematic lighting keywords. Return ONLY the final English prompt string.\nUser input: {prompt}"
+        gemini_sys_prompt = f"You are an expert AI image generation prompt engineer. Translate the following user input to English, and enhance it with high-quality, highly detailed, 4k resolution, cinematic lighting, and visually striking descriptive keywords. Return ONLY the final English prompt string.\nUser input: {prompt}"
         async with aiohttp.ClientSession() as session:
             for key in keys_to_try_gemini:
                 url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key={key}"
@@ -437,10 +404,63 @@ async def process_image(client, chat_id, prompt):
         await asyncio.sleep(1)
         caption_text = f"🎨 تصویر شما با پرامپت هوشمند آماده شد!\n\n✨ ایده اولیه: {prompt}"
         upload_result = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
-        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ خطا در آپلود:\n`{str(upload_result)[:800]}`", True)
+        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ خطا در آپلود روبیکا:\n`{str(upload_result)[:800]}`", True)
         if os.path.exists(file_name): os.remove(file_name)
     except Exception as e: await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس:\n{str(e)[:150]}", True)
 
+# --- ۲.۵. پردازش ویرایش عکس با FLUX.2-dev ---
+async def process_image_edit(client, chat_id, image_bytes, prompt):
+    if not HF_TOKENS:
+        await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
+        return
+
+    proc_msg = await send_with_keyboard(client, chat_id, "🪄 در حال پردازش و اعمال جادوی FLUX.2 روی عکس شما...\n(این فرآیند ممکن است کمی طول بکشد)", False)
+    
+    keys_to_try = HF_TOKENS.copy()
+    random.shuffle(keys_to_try)
+    generated_image = None
+    last_error_log = "سرور پاسخ نداد."
+    
+    for token in keys_to_try:
+        try:
+            hf_client = AsyncInferenceClient(provider="fal-ai", api_key=token)
+            # استفاده از متد image_to_image با ارسال دیتای بایت عکس و پرامپت متنی کاربر
+            generated_image = await hf_client.image_to_image(
+                image_bytes,
+                prompt=prompt,
+                model="black-forest-labs/FLUX.2-dev"
+            )
+            break 
+        except Exception as e:
+            last_error_log = str(e)
+            continue
+            
+    try:
+        if proc_msg:
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
+    except Exception: pass
+
+    if not generated_image:
+        await send_with_keyboard(client, chat_id, f"❌ متأسفانه ویرایش عکس انجام نشد.\n\n⚠️ علت:\n{last_error_log[:200]}", True)
+        return
+
+    try:
+        file_name = f"edited_flux_{random.randint(1000, 999999)}.jpg"
+        rgb_im = generated_image.convert('RGB')
+        rgb_im.save(file_name, format="JPEG", quality=100)
+        await asyncio.sleep(1)
+        caption_text = f"🪄 ویرایش عکس با هوش مصنوعی Flux.2 انجام شد!\n\n✨ تغییرات خواسته شده: {prompt}"
+        upload_result = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
+        if upload_result is not True:
+            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما خطا در ارسال به روبیکا رخ داد:\n`{str(upload_result)[:800]}`", True)
+        if os.path.exists(file_name): os.remove(file_name)
+    except Exception as e:
+        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس ویرایش شده:\n{str(e)[:150]}", True)
+
+
+# --- ۳. پردازش ساخت صدا ---
 async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
     try:
         proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال ساخت صدا با «{speaker_name}»...\n(لطفاً صبور باشید)", False)
@@ -481,8 +501,9 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
         else: await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
     except Exception: traceback.print_exc()
 
+# --- ۳.۵. پردازش پادکست ---
 async def process_podcast(client, chat_id, prompt):
-    proc_msg = await send_with_keyboard(client, chat_id, "📻 در حال بررسی موضوع و نگارش سناریوی پادکست...\n(لطفاً صبور باشید)", False)
+    proc_msg = await send_with_keyboard(client, chat_id, "📻 در حال بررسی موضوع و نگارش سناریوی پادکست توسط هوش مصنوعی...\n(لطفاً صبور باشید)", False)
     available_speakers = []
     for num_key, (spk_name, spk_id) in SPEAKERS.items():
         gender = "male" if "مرد" in spk_name else "female"
@@ -494,9 +515,9 @@ async def process_podcast(client, chat_id, prompt):
     async with aiohttp.ClientSession() as session:
         try:
             async with session.post(url_create, json=payload_create, timeout=60) as resp:
-                if resp.status != 202: return await send_with_keyboard(client, chat_id, f"❌ خطا: وضعیت {resp.status}", True)
+                if resp.status != 202: return await send_with_keyboard(client, chat_id, f"❌ خطا در سرور پادکست: وضعیت {resp.status}", True)
                 task_id = (await resp.json()).get("task_id")
-        except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا اتصال:\n{str(e)}", True)
+        except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور پادکست:\n{str(e)}", True)
 
         url_status = f"https://ezmarynoori-podgen.hf.space/api/podcast-status/{task_id}"
         script_data = None
@@ -510,10 +531,10 @@ async def process_podcast(client, chat_id, prompt):
                             script_data = status_data.get("data", {}).get("script", [])
                             break
                         elif status_data.get("status") == "failed":
-                            return await send_with_keyboard(client, chat_id, "❌ هوش مصنوعی نتوانست سناریو بنویسد.", True)
+                            return await send_with_keyboard(client, chat_id, "❌ متأسفانه هوش مصنوعی نتوانست برای این موضوع سناریو بنویسد.", True)
             except Exception: pass
             
-        if not script_data: return await send_with_keyboard(client, chat_id, "❌ پایان زمان انتظار برای نوشتن سناریو.", True)
+        if not script_data: return await send_with_keyboard(client, chat_id, "❌ زمان انتظار برای نوشتن سناریو به پایان رسید.", True)
 
         try:
             if proc_msg:
@@ -522,7 +543,7 @@ async def process_podcast(client, chat_id, prompt):
                 if msg_id: await client.delete_messages(chat_id, [msg_id])
         except: pass
         
-        proc_msg = await send_with_keyboard(client, chat_id, f"🎙 سناریو نوشته شد! در حال میکس (شامل {len(script_data)} نوبت صحبت)...\nزمان‌بر است...", False)
+        proc_msg = await send_with_keyboard(client, chat_id, f"🎙 سناریو نوشته شد! در حال ریکورد و میکس دیالوگ‌های گویندگان (شامل {len(script_data)} نوبت صحبت)...\nاین مرحله زمان‌بر است...", False)
 
         combined_audio = AudioSegment.empty()
         url_generate = "https://ezmarynoori-podgen.hf.space/api/generate"
@@ -538,12 +559,12 @@ async def process_podcast(client, chat_id, prompt):
                             break
                 except Exception: await asyncio.sleep(2)
             
-            if not chunk_audio_bytes: return await send_with_keyboard(client, chat_id, f"❌ خطا در بخش {index+1}", True)
+            if not chunk_audio_bytes: return await send_with_keyboard(client, chat_id, f"❌ خطا در تولید صدای بخش {index+1} از سرور. عملیات متوقف شد.", True)
                 
             try:
                 audio_segment = AudioSegment.from_file(io.BytesIO(chunk_audio_bytes))
                 combined_audio += audio_segment
-            except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا میکس:\n{str(e)}", True)
+            except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا در پردازش صدا (آیا pydub و ffmpeg نصب است؟):\n{str(e)}", True)
 
         file_name = f"final_podcast_{random.randint(1000, 999999)}.mp3"
         combined_audio.export(file_name, format="mp3")
@@ -555,14 +576,15 @@ async def process_podcast(client, chat_id, prompt):
                 if msg_id: await client.delete_messages(chat_id, [msg_id])
         except: pass
 
-        caption = f"🎧 پادکست شما میکس شد!\n\n💡 موضوع: {prompt}"
+        caption = f"🎧 پادکست شما با موفقیت میکس و ساخته شد!\n\n💡 موضوع شما: {prompt}"
         upload_result = await helper_upload_file(client, chat_id, file_name, "Voice", caption)
-        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ خطای آپلود روبیکا.\n\n`{str(upload_result)[:800]}`", True)
+        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ پادکست با موفقیت ساخته شد اما روبیکا خطای آپلود داد.\n\n`{str(upload_result)[:800]}`", True)
         if os.path.exists(file_name): os.remove(file_name)
 
+# --- ۴. پردازش تبدیل فایل صوتی/تصویری به متن ---
 async def process_stt(client, chat_id, audio_bytes, file_name):
-    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید تنظیم نشده", False)
-    proc_msg = await send_with_keyboard(client, chat_id, "📝 در حال پیاده‌سازی متن...", False)
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلیدهای جیمینای تنظیم نشده‌اند.", False)
+    proc_msg = await send_with_keyboard(client, chat_id, "📝 در حال گوش دادن و پیاده‌سازی متن...", False)
     base64_data = base64.b64encode(audio_bytes).decode('utf-8')
     mime_type, _ = mimetypes.guess_type(file_name)
     if not mime_type: mime_type = "audio/ogg" 
@@ -570,7 +592,7 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
     keys_to_try = GEMINI_KEYS.copy()
     random.shuffle(keys_to_try)
     transcribed_text = None
-    prompt = "این فایل صوتی/تصویری را دقیق گوش بده و صحبت‌ها را کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
+    prompt = "لطفاً این فایل صوتی/تصویری را با دقت کامل گوش بده و صحبت‌های داخل آن را کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
     
     async with aiohttp.ClientSession() as session:
         for key in keys_to_try:
@@ -591,11 +613,12 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
             if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
-    if transcribed_text: await send_with_keyboard(client, chat_id, f"📝 **متن:**\n\n{transcribed_text}", True)
-    else: await send_with_keyboard(client, chat_id, f"❌ تبدیل ناموفق", True)
+    if transcribed_text: await send_with_keyboard(client, chat_id, f"📝 **متن استخراج شده:**\n\n{transcribed_text}", True)
+    else: await send_with_keyboard(client, chat_id, f"❌ تبدیل فایل به متن ناموفق بود.", True)
 
+# --- ۵. پردازش تحلیل فایل مستقل ---
 async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
-    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید تنظیم نیست.", False)
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید جیمینای تنظیم نیست.", False)
     proc_msg = await send_with_keyboard(client, chat_id, "👁️ در حال تحلیل فایل...", False)
     base64_data = base64.b64encode(file_bytes).decode('utf-8')
     mime_type, _ = mimetypes.guess_type(file_name)
@@ -624,7 +647,7 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
             if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
-    if final_answer: await send_with_keyboard(client, chat_id, f"💡 **تحلیل:**\n\n{final_answer}", True)
+    if final_answer: await send_with_keyboard(client, chat_id, f"💡 **نتیجه تحلیل:**\n\n{final_answer}", True)
     else: await send_with_keyboard(client, chat_id, "❌ پاسخی دریافت نشد.", True)
 
 
@@ -699,10 +722,10 @@ else:
 
             if user_text_str in ["/start", "سلام", "لغو", "/cancel", "❌ لغو", "برگشت♻️"]:
                 user_states[chat_id] = {"mode": None, "text": "", "history": [], "file_bytes": None, "file_name": None}
-                await send_with_keyboard(client, chat_id, "سلام کاربر عزیز! به ربات هوشمند آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، یکی از بخش‌های زیر را انتخاب کنید:", True)
+                await send_with_keyboard(client, chat_id, "سلام! به ربات هوشمند آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True)
                 return
 
-            # --- شخصی‌سازی حساب کاربری با شناسه چت (داینامیک) ---
+            # --- حساب کاربری ---
             if user_text_str in ["/account", "حساب کاربری 👤"]:
                 account_profile = f"""👤 **اطلاعات حساب کاربری شما**
 
@@ -722,44 +745,44 @@ else:
 
             if user_text_str in ["/chat", "💬 چت", "چت با هوش مصنوعی 🤖"]:
                 user_states[chat_id] = {"mode": "chat", "text": "", "history": []}
-                await send_with_keyboard(client, chat_id, "💬 وارد بخش **چت هوشمند** شدید.\nسوالی بپرسید تا جواب بدهم:", True)
+                await send_with_keyboard(client, chat_id, "💬 شما وارد بخش **چت با هوش مصنوعی** شدید.\n\nهر سوالی دارید بفرستید تا جواب بدم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             if user_text_str in ["/image", "🎨 عکس", "ساخت تصاویر🎨"]:
                 user_states[chat_id] = {"mode": "image_waiting_for_text", "text": "", "history": []}
-                await send_with_keyboard(client, chat_id, "🎨 وارد بخش **ساخت عکس** شدید.\nمتن خود را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "🎨 شما وارد بخش **ساخت عکس پیشرفته** شدید.\n\nمتن خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             if user_text_str in ["/edit_image", "ویرایش تصاویر 🪄"]:
                 user_states[chat_id] = {"mode": "image_edit_waiting_for_image", "text": "", "history": [], "file_bytes": None, "file_name": None}
-                await send_with_keyboard(client, chat_id, "🪄 به بخش **ویرایش عکس (Flux.2)** خوش آمدید.\n\nلطفاً ابتدا عکسی که می‌خواهید ویرایش کنید را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "🪄 به بخش **ویرایش عکس (Flux.2)** خوش آمدید.\n\nلطفاً ابتدا عکسی که می‌خواهید ویرایش کنید را بفرستید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             if user_text_str in ["/tts", "🎙️ صدا", "تبدیل متن به صدا🗣️"]:
                 user_states[chat_id] = {"mode": "tts_waiting_for_text", "text": "", "history": []}
-                await send_with_keyboard(client, chat_id, "🎙️ وارد بخش **تبدیل متن به صدا** شدید.\nمتن خود را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "🎙️ شما وارد بخش **تبدیل متن به صدا** شدید.\n\nلطفاً متنی که می‌خواهید به صدا تبدیل شود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
             
             if user_text_str in ["/podcast", "📻 پادکست", "ساخت پادکست 🎙️"]:
                 user_states[chat_id] = {"mode": "podcast_waiting_for_topic", "text": "", "history": []}
-                await send_with_keyboard(client, chat_id, "📻 وارد بخش **ساخت پادکست** شدید.\nموضوع پادکست را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "📻 شما وارد بخش **ساخت پادکست** شدید.\n\nلطفاً موضوع پادکست خود را بفرستید.\nمثال: درباره تاریخچه پیدایش قهوه با ۳ گوینده یک پادکست جذاب بساز\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             if user_text_str in ["/file", "تحلیل فایل ��"]:
                 user_states[chat_id] = {"mode": "file_waiting_for_file", "text": "", "history": [], "file_bytes": None, "file_name": None}
-                await send_with_keyboard(client, chat_id, "📁 وارد بخش **تحلیل فایل** شدید.\nفایل خود را ارسال کنید:", True)
+                await send_with_keyboard(client, chat_id, "📁 شما وارد بخش **تحلیل فایل اختصاصی** شدید.\n\nلطفاً فایل خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             if user_text_str in ["/stt", "فایل صوتی به متن 📝"]:
                 user_states[chat_id] = {"mode": "stt_waiting_for_audio", "text": "", "history": []}
-                await send_with_keyboard(client, chat_id, "📝 وارد بخش **تبدیل صدا به متن** شدید.\nفایل خود را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "📝 شما وارد بخش **تبدیل صدا به متن** شدید.\n\nلطفاً فایل خود (ویس، آهنگ، ویدیو و...) را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             current_mode = user_states[chat_id].get("mode")
 
             if current_mode is None:
                 if is_file: pass 
-                elif user_text_str: await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا یک بخش را از کیبورد پایین انتخاب کنید:", True)
+                elif user_text_str: await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا از کیبورد پایین، بخش مورد نظرتان را انتخاب کنید:", True)
                 return
 
             elif current_mode == "chat":
@@ -768,7 +791,7 @@ else:
                     try:
                         file_bytes = await helper_download_file(client, msg_obj)
                         asyncio.create_task(process_gemini(client, chat_id, user_text_str, file_bytes=file_bytes, file_name=file_name))
-                    except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا!\n{str(dl_err)}", False)
+                    except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
                 elif user_text_str: asyncio.create_task(process_gemini(client, chat_id, user_text_str))
                 return
 
@@ -784,7 +807,7 @@ else:
                     user_states[chat_id]["file_bytes"] = file_bytes
                     user_states[chat_id]["mode"] = "image_edit_waiting_for_prompt"
                     await send_with_keyboard(client, chat_id, "✅ عکس با موفقیت دریافت شد.\n\nحالا دستور خود را به صورت متنی تایپ کنید.\nمثال: یک کلاه قرمز روی سر این گربه بگذار.", False)
-                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت عکس!\n{str(dl_err)}", False)
                 return
 
             elif current_mode == "image_edit_waiting_for_prompt":
@@ -798,45 +821,63 @@ else:
 
             elif current_mode == "tts_waiting_for_text":
                 if user_text_str:
-                    if len(user_text_str) > 2500: return await send_with_keyboard(client, chat_id, "⚠️ متن خیلی طولانی است.", False)
+                    if len(user_text_str) > 2500: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً متنی کوتاه‌تر از 2500 کاراکتر بفرستید.", False)
                     user_states[chat_id]["text"] = user_text_str
                     user_states[chat_id]["mode"] = "tts_waiting_for_speaker"
-                    await send_with_keyboard(client, chat_id, "✅ متن ذخیره شد.\nلطفاً **شماره** گوینده (بین 1 تا 30) را بفرستید:", False)
+                    
+                    # بازگرداندن متن کامل لیست گویندگان
+                    speakers_menu = """✅ متن شما ذخیره شد.
+لطفاً **شماره** گوینده مورد نظر خود را بفرستید:
+1. شهاب | 2. آوا | 3. نوید
+4. آرمان | 5. مهسا | 6. دانا
+7. سامان | 8. آرش | 9. شبنم
+10. سحر | 11. مریم | 12. بهرام
+13. نیکان| 14. فرناز | 15. سارا
+16. مانی | 17. آرتین | 18. دلنواز
+19. روژان | 20. امید | 21. بردیا
+22. ترانه | 23. نیکو | 24. هستی
+25. کامیار| 26. کیانوش| 27. پویا
+28. مهتاب | 29. سام | 30. لیدا"""
+                    await send_with_keyboard(client, chat_id, speakers_menu, False)
                 return
 
             elif current_mode == "tts_waiting_for_speaker":
-                if user_text_str.isdigit() and user_text_str in SPEAKERS:
-                    spk_name, spk_id = SPEAKERS[user_text_str]
+                # تبدیل اعداد فارسی/عربی احتمالی به انگلیسی
+                normalized_text = to_english_digits(user_text_str)
+                
+                if normalized_text.isdigit() and normalized_text in SPEAKERS:
+                    spk_name, spk_id = SPEAKERS[normalized_text]
                     txt = user_states[chat_id]["text"]
                     user_states[chat_id]["mode"] = "tts_waiting_for_text"
                     asyncio.create_task(process_tts(client, chat_id, txt, spk_id, spk_name))
-                else: await send_with_keyboard(client, chat_id, "❌ شماره نامعتبر!", False)
+                else: 
+                    await send_with_keyboard(client, chat_id, "❌ شماره نامعتبر است! لطفاً فقط یک عدد بین 1 تا 30 بفرستید.", False)
                 return
 
             elif current_mode == "podcast_waiting_for_topic":
                 if user_text_str: asyncio.create_task(process_podcast(client, chat_id, user_text_str))
-                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً موضوع را متنی بفرستید.", False)
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً موضوع پادکست خود را به صورت متنی بفرستید.", False)
                 return
 
             elif current_mode == "stt_waiting_for_audio":
-                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً فایل بفرستید.", False)
-                await send_with_keyboard(client, chat_id, "📥 در حال دانلود...", False)
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً یک فایل ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل...", False)
                 try:
                     audio_bytes = await helper_download_file(client, msg_obj)
                     asyncio.create_task(process_stt(client, chat_id, audio_bytes, file_name))
-                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا!\n{str(dl_err)}", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دانلود فایل!\n{str(dl_err)}", False)
                 return
 
             elif current_mode == "file_waiting_for_file":
-                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ فایل بفرستید.", False)
-                await send_with_keyboard(client, chat_id, "📥 دریافت فایل...", False)
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا یک فایل ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دریافت فایل...", False)
                 try:
                     file_bytes = await helper_download_file(client, msg_obj)
                     user_states[chat_id]["file_bytes"] = file_bytes
                     user_states[chat_id]["file_name"] = file_name 
                     user_states[chat_id]["mode"] = "file_waiting_for_prompt"
-                    await send_with_keyboard(client, chat_id, "✅ دریافت شد.\nچگونه تحلیل شود؟", False)
-                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا!\n{str(dl_err)}", False)
+                    await send_with_keyboard(client, chat_id, "✅ فایل با موفقیت دریافت شد.\n\nحالا لطفاً متنی بگویید **چگونه تحلیل شود؟**", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
                 return
 
             elif current_mode == "file_waiting_for_prompt":
@@ -845,7 +886,7 @@ else:
                     saved_name = user_states[chat_id].get("file_name", "file.jpeg")
                     user_states[chat_id]["mode"] = "file_waiting_for_file" 
                     asyncio.create_task(process_file_analysis(client, chat_id, saved_bytes, saved_name, user_text_str))
-                else: await send_with_keyboard(client, chat_id, "⚠️ متن بفرستید.", False)
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
                 return
 
         except Exception: traceback.print_exc()