Update main.py

main.py

@@ -31,8 +31,6 @@ asyncio_helper.FILE_URL = "https://tapi.bale.ai/file/bot{0}/{1}"
 
 # --- کد مدیریت برای ارتقای کاربران بدون نیاز به لاگین ---
 ADMIN_CODE = "3011"
-
-# متغیر سراسری برای ذخیره آیدی خود ربات (جلوگیری از جواب دادن ربات به خودش)
 BOT_GUID = None
 
 # --- سیستم دیتابیس حساب کاربری متصل به دیتاست هاگینگ فیس ---
@@ -287,9 +285,7 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
         return f"Bale Send Error: {str(e)[:100]}"
 
 
-WORKER_URLS =[
-    "https://opera8-ttspro.hf.space/generate",
-]
+WORKER_URLS = ["https://opera8-ttspro.hf.space/generate"]
 
 SPEAKERS = {
     "1": ("شهاب (مرد)", "Charon"), "2": ("آوا (زن)", "Zephyr"), "3": ("نوید (مرد)", "Achird"), 
@@ -305,7 +301,7 @@ SPEAKERS = {
 }
 
 user_states = {}
-
+processed_message_ids = set()
 
 # --- ۱. پردازش چت متنی و چندرسانه‌ای ---
 async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=None):
@@ -327,14 +323,7 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
         base64_data = base64.b64encode(file_bytes).decode('utf-8')
         mime_type, _ = mimetypes.guess_type(file_name)
         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"
+            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)
@@ -361,7 +350,6 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
                         except (KeyError, IndexError): continue 
             except Exception: continue
 
-    # --- Fallback to Hugging Face Gemma 4 ---
     if not final_answer and HF_TOKENS:
         hf_messages =[]
         for msg in history:
@@ -386,11 +374,7 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
             for hf_key in keys_to_try_hf:
                 url = "https://router.huggingface.co/v1/chat/completions"
                 headers = {"Authorization": f"Bearer {hf_key}", "Content-Type": "application/json"}
-                payload = {
-                    "model": "google/gemma-4-31B-it:novita",
-                    "messages": hf_messages,
-                    "max_tokens": 4096
-                }
+                payload = {"model": "google/gemma-4-31B-it:novita", "messages": hf_messages, "max_tokens": 4096}
                 try:
                     async with session.post(url, headers=headers, json=payload, timeout=60) as response:
                         if response.status == 200:
@@ -475,11 +459,7 @@ async def process_image(client, chat_id, prompt):
             for hf_key in keys_to_try_hf:
                 url = "https://router.huggingface.co/v1/chat/completions"
                 headers = {"Authorization": f"Bearer {hf_key}", "Content-Type": "application/json"}
-                payload = {
-                    "model": "google/gemma-4-31B-it:novita",
-                    "messages":[{"role": "user", "content":[{"type": "text", "text": gemini_sys_prompt}]}],
-                    "max_tokens": 1024
-                }
+                payload = {"model": "google/gemma-4-31B-it:novita", "messages":[{"role": "user", "content":[{"type": "text", "text": gemini_sys_prompt}]}], "max_tokens": 1024}
                 try:
                     async with session.post(url, headers=headers, json=payload, timeout=20) as response:
                         if response.status == 200:
@@ -899,11 +879,7 @@ async def process_create_file(client, chat_id, topic):
             for hf_key in keys_to_try_hf:
                 url = "https://router.huggingface.co/v1/chat/completions"
                 headers = {"Authorization": f"Bearer {hf_key}", "Content-Type": "application/json"}
-                payload = {
-                    "model": "google/gemma-4-31B-it:novita",
-                    "messages":[{"role": "user", "content":[{"type": "text", "text": ai_prompt}]}],
-                    "max_tokens": 4096
-                }
+                payload = {"model": "google/gemma-4-31B-it:novita", "messages":[{"role": "user", "content":[{"type": "text", "text": ai_prompt}]}], "max_tokens": 4096}
                 try:
                     async with session.post(url, headers=headers, json=payload, timeout=60) as response:
                         if response.status == 200:
@@ -985,6 +961,39 @@ async def process_create_file(client, chat_id, topic):
     else:
         await send_with_keyboard(client, chat_id, "❌ فایل‌ها ساخته شدند اما بله در ارسال آن‌ها دچار مشکل شد.", True)
 
+# --- توابع واسط (Wrappers) برای جلوگیری از مسدود شدن سیستم ضد اسپم ---
+async def task_chat_file(client, chat_id, text, message, file_name):
+    try:
+        file_bytes = await helper_download_file(client, message)
+        await process_gemini(client, chat_id, text, file_bytes=file_bytes, file_name=file_name)
+    except Exception as e: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(e)}", False)
+
+async def task_image_edit(client, chat_id, message):
+    await send_with_keyboard(client, chat_id, "📥 در حال دانلود عکس...", False)
+    try:
+        file_bytes = await helper_download_file(client, message)
+        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 e: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت عکس!\n{str(e)}", False)
+
+async def task_stt(client, chat_id, message, file_name):
+    await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل...", False)
+    try:
+        audio_bytes = await helper_download_file(client, message)
+        await process_stt(client, chat_id, audio_bytes, file_name)
+    except Exception as e: await send_with_keyboard(client, chat_id, f"❌ خطا در دانلود فایل!\n{str(e)}", False)
+
+async def task_file_analysis(client, chat_id, message, file_name):
+    await send_with_keyboard(client, chat_id, "📥 در حال دریافت فایل...", False)
+    try:
+        file_bytes = await helper_download_file(client, message)
+        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\nحالا لطفاً متنی بگویید **چگونه تحلیل شود؟**", False)
+    except Exception as e: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(e)}", False)
+
 
 # --- راه‌اندازی و اتصال هندلرها به بله ---
 bot = AsyncTeleBot(bot_token) if bot_token else None
@@ -993,19 +1002,27 @@ if bot:
     @bot.message_handler(func=lambda message: True, content_types=['text', 'photo', 'document', 'voice', 'audio', 'video'])
     async def main_handler(message):
         try:
+            chat_id = message.chat.id
+            msg_id = message.message_id
+            
+            # سیستم ضد تکرار و اسپم 
+            unique_msg_key = f"{chat_id}_{msg_id}"
+            if unique_msg_key in processed_message_ids: 
+                return
+            processed_message_ids.add(unique_msg_key)
+            if len(processed_message_ids) > 10000: 
+                processed_message_ids.clear()
+            
             global BOT_GUID
             if not BOT_GUID:
                 try:
                     me_info = await bot.get_me()
                     if me_info: BOT_GUID = me_info.id
-                except Exception:
-                    pass
+                except Exception: pass
 
             author_id = message.from_user.id
             if BOT_GUID and author_id == BOT_GUID:
                 return
-            
-            chat_id = message.chat.id
 
             user_text = message.text or message.caption or ""
             user_text_str = str(user_text).strip() if user_text else ""
@@ -1033,10 +1050,7 @@ if bot:
                         user_credits_db[target_id]["file"] = 999999
                         user_credits_db[target_id]["stt"] = 999999
                         save_db(user_credits_db)
-                        await send_with_keyboard(bot, chat_id, f"✅ حساب کاربر `{target_id}` به مدت ۳۰ روز شارژ شد و به پرو ارتقا یافت.", False)
-                        try:
-                            await send_with_keyboard(bot, target_id, "🎉 **کاربر گرامی، تبریک!**\n\nحساب شما با موفقیت توسط پشتیبانی به **🌟 نسخه پرو (ویژه)** ارتقا یافت.\nهم‌اکنون بسته‌های نامحدود و طلایی یک‌ماهه شما فعال گردید.\n\nجهت مشاهده جزئیات روی دکمه «حساب کاربری 👤» کلیک کنید.", True)
-                        except Exception: pass
+                        asyncio.create_task(send_with_keyboard(bot, chat_id, f"✅ حساب کاربر `{target_id}` به مدت ۳۰ روز شارژ شد و به پرو ارتقا یافت.", False))
                 return
                 
             if user_text_lower.startswith(f"{ADMIN_CODE} free=") or user_text_lower.startswith(f"{ADMIN_CODE}free="):
@@ -1049,10 +1063,7 @@ if bot:
                             user_credits_db[target_id]["expire_date"] = None
                             user_credits_db[target_id]["last_reset"] = "" 
                             save_db(user_credits_db)
-                        await send_with_keyboard(bot, chat_id, f"✅ اشتراک کاربر `{target_id}` لغو شد و به رایگان تبدیل گشت.", False)
-                        try:
-                            await send_with_keyboard(bot, target_id, "⚠️ کاربر گرامی، اشتراک ویژه شما به پایان رسید و حساب شما به نسخه رایگان (آزمایشی) تغییر یافت.", True)
-                        except Exception: pass
+                        asyncio.create_task(send_with_keyboard(bot, chat_id, f"✅ اشتراک کاربر `{target_id}` لغو شد و به رایگان تبدیل گشت.", False))
                 return
 
             if user_text_lower.startswith(f"{ADMIN_CODE} =") or user_text_lower.startswith(f"{ADMIN_CODE}="):
@@ -1078,9 +1089,9 @@ if bot:
                                 status_text = "🥉 نسخه رایگان (آزمایشی)\n⏳ سهمیه روزانه"
 
                             info_msg = f"🔍 **اطلاعات کاربر `{target_id}`:**\n\n🔹 **وضعیت:** {status_text}\n\n📊 **سهمیه:**\n- چت: {t_creds.get('chat',0)}\n- تولید عکس: {t_creds.get('image',0)}\n- ویرایش عکس: {t_creds.get('edit_image',0)}\n- پادکست: {t_creds.get('podcast',0)}\n- متن به صدا: {t_creds.get('tts',0)}\n- تحلیل فایل: {t_creds.get('file',0)}\n- صدا به متن: {t_creds.get('stt',0)}"
-                            await send_with_keyboard(bot, chat_id, info_msg, False)
+                            asyncio.create_task(send_with_keyboard(bot, chat_id, info_msg, False))
                         else:
-                            await send_with_keyboard(bot, chat_id, f"❌ کاربری با شناسه `{target_id}` در دیتابیس یافت نشد.", False)
+                            asyncio.create_task(send_with_keyboard(bot, chat_id, f"❌ کاربری با شناسه `{target_id}` در دیتابیس یافت نشد.", False))
                 return
 
             is_file = False
@@ -1109,24 +1120,23 @@ if bot:
                 if not creds.get("has_joined", False):
                     user_credits_db[str_chat_id]["has_joined"] = True
                     save_db(user_credits_db)
-                    await send_with_keyboard(bot, chat_id, "🎉 **عضویت شما با موفقیت تایید شد! خیلی خوش آمدید.**\n\nحالا می‌توانید از تمامی امکانات ربات استفاده کنید.\nلطفاً یکی از گزینه‌های منو را انتخاب کنید:", True)
+                    asyncio.create_task(send_with_keyboard(bot, chat_id, "🎉 **عضویت شما با موفقیت تایید شد! خیلی خوش آمدید.**\n\nحالا می‌توانید از تمامی امکانات ربات استفاده کنید.\nلطفاً یکی از گزینه‌های منو را انتخاب کنید:", True))
                     return
                 else:
-                    await send_with_keyboard(bot, chat_id, "✅ شما قبلاً عضو شده‌اید! لطفا از منوی اصلی استفاده کنید.", True)
+                    asyncio.create_task(send_with_keyboard(bot, chat_id, "✅ شما قبلاً عضو شده‌اید! لطفا از منوی اصلی استفاده کنید.", True))
                     return
 
             if not creds.get("has_joined", False):
                 join_msg = "👋 **سلام کاربر گرامی!**\n\nجهت استفاده از خدمات ربات هوش مصنوعی آلفا و مطلع شدن از آخرین آپدیت‌ها، لطفا ابتدا در کانال رسمی ما عضو شوید:\n\n📢 **آیدی کانال:** @aialpha\n\n👇 پس از عضویت در کانال، بر روی دکمه **«✅ عضو شدم»** کلیک کنید تا ربات برای شما فعال شود."
-                await bot.send_message(chat_id, join_msg, reply_markup=get_join_keyboard())
+                asyncio.create_task(bot.send_message(chat_id, join_msg, reply_markup=get_join_keyboard()))
                 return
 
             if user_text_str in["/start", "سلام", "لغو", "/cancel", "❌ لغو", "برگشت♻️"]:
                 user_states[chat_id]["mode"] = None
                 user_states[chat_id]["file_bytes"] = None
-                await send_with_keyboard(bot, chat_id, "سلام! به ربات هوش مصنوعی آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "سلام! به ربات هوش مصنوعی آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True))
                 return
 
-            # --- حساب کاربری ---
             if user_text_str in["/account", "حساب کاربری 👤"]:
                 creds = get_user_credits(chat_id)
                 is_prem = creds.get("is_premium", False)
@@ -1156,142 +1166,84 @@ if bot:
                 image_rem = creds['image']
                 edit_image_rem = creds['edit_image']
 
-                account_profile = f"""👤 **اطلاعات حساب کاربری شما**
-
-🔹 **شناسه یکتا:** `{chat_id}`
-🔹 **وضعیت اشتراک:** {status_text}{expire_info}
-
-📊 **سهمیه باقی‌مانده شما:**
-- 💬 چت هوشمند: {chat_rem}
-- 🎨 تولید تصویر: {image_rem} عدد
-- 🪄 ویرایش تصویر: {edit_image_rem} عدد
-- 🎙 ساخت پادکست: {podcast_rem}
-- 🗣 تبدیل متن به صدا: {tts_rem}
-- 📁 تحلیل فایل و سند: {file_rem}
-- 📝 تبدیل صدا به متن: {stt_rem}
-
-{daily_note}"""
-                await send_with_keyboard(bot, chat_id, account_profile, True)
+                account_profile = f"👤 **اطلاعات حساب کاربری شما**\n\n🔹 **شناسه یکتا:** `{chat_id}`\n🔹 **وضعیت اشتراک:** {status_text}{expire_info}\n\n📊 **سهمیه باقی‌مانده شما:**\n- 💬 چت هوشمند: {chat_rem}\n- 🎨 تولید تصویر: {image_rem} عدد\n- 🪄 ویرایش تصویر: {edit_image_rem} عدد\n- 🎙 ساخت پادکست: {podcast_rem}\n- 🗣 تبدیل متن به صدا: {tts_rem}\n- 📁 تحلیل فایل و سند: {file_rem}\n- 📝 تبدیل صدا به متن: {stt_rem}\n\n{daily_note}"
+                asyncio.create_task(send_with_keyboard(bot, chat_id, account_profile, True))
                 return
 
             if user_text_str in["/buy", "خرید اشتراک 💎"]:
-                buy_text = f"""💎 **خرید اشتراک ویژه آلفا پرو (یک ماهه)**
-
-با تهیه اشتراک ویژه، محدودیت‌ها را کنار بزنید و از نهایت قدرت هوش مصنوعی لذت ببرید! 🚀
-
-🎁 **بسته طلایی یک‌ماهه شامل:**
-🤖 چت با هوش مصنوعی بصورت نامحدود
-🗣 تبدیل متن به صدا بصورت نامحدود با ۳۰ گوینده
-🎙 ساخت پادکست بصورت نامحدود 
-
-🪄 ۱۰ ویرایش تصویر
-🎨 ۲۰ تولید تصویر 
-📁 تحلیل نامحدود فایل و سند
-📝 تبدیل فایل صوتی به متن نامحدود
-
-💳 **هزینه اشتراک یک ماهه:** 250 هزار تومان
-
-💳 **شماره کارت جهت واریز:**
-`6219861411958035`
-👤 **به نام:** کوهی
-
-✅ **نحوه فعال‌سازی:**
-پس از واریز مبلغ، لطفاً رسید پرداختی را به همراه **شناسه یکتای خود** (که در پایین آمده) به آیدی پشتیبانی زیر ارسال کنید تا اشتراک شما فعال گردد:
-
-🔑 **شناسه یکتای شما:** `{chat_id}`
-
-👨‍💻 **ارتباط با پشتیبانی:**
-🆔 @H_a_m_e_d100"""
-                await send_with_keyboard(bot, chat_id, buy_text, True)
+                buy_text = f"💎 **خرید اشتراک ویژه آلفا پرو (یک ماهه)**\n\nبا تهیه اشتراک ویژه، محدودیت‌ها را کنار بزنید و از نهایت قدرت هوش مصنوعی لذت ببرید! 🚀\n\n🎁 **بسته طلایی یک‌ماهه شامل:**\n🤖 چت با هوش مصنوعی بصورت نامحدود\n🗣 تبدیل متن به صدا بصورت نامحدود با ۳۰ گوینده\n🎙 ساخت پادکست بصورت نامحدود \n\n🪄 ۱۰ ویرایش تصویر\n🎨 ۲۰ تولید تصویر \n📁 تحلیل نامحدود فایل و سند\n📝 تبدیل فایل صوتی به متن نامحدود\n\n💳 **هزینه اشتراک یک ماهه:** 250 هزار تومان\n\n💳 **شماره کارت جهت واریز:**\n`6219861411958035`\n👤 **به نام:** کوهی\n\n✅ **نحوه فعال‌سازی:**\nپس از واریز مبلغ، لطفاً رسید پرداختی را به همراه **شناسه یکتای خود** (که در پایین آمده) به آیدی پشتیبانی زیر ارسال کنید تا اشتراک شما فعال گردد:\n\n🔑 **شناسه یکتای شما:** `{chat_id}`\n\n👨‍💻 **ارتباط با پشتیبانی:**\n🆔 @H_a_m_e_d100"
+                asyncio.create_task(send_with_keyboard(bot, chat_id, buy_text, True))
                 return
 
             if user_text_str in["/transfer", "انتقال اکانت از برنامه به ربات"]:
-                transfer_text = f"""🔄 **انتقال اکانت از برنامه به ربات**
-
-کاربر گرامی، در صورتی که داخل برنامه «هوش مصنوعی آلفا» پیش‌تر اشتراک تهیه کرده‌اید، نیازی به خرید مجدد اشتراک داخل ربات نیست! 🎉
-
-کافیست **شناسه یکتای** ربات خود را کپی کرده و برای پشتیبانی ما ارسال کنید تا اکانت اشتراکی شما به سرعت انتقال داده شود.
-
-🔑 **شناسه یکتای ربات شما:** `{chat_id}`
-
-👨‍💻 **پشتیبانی:**
-🆔 @H_a_m_e_d100"""
-                await send_with_keyboard(bot, chat_id, transfer_text, True)
+                transfer_text = f"🔄 **انتقال اکانت از برنامه به ربات**\n\nکاربر گرامی، در صورتی که داخل برنامه «هوش مصنوعی آلفا» پیش‌تر اشتراک تهیه کرده‌اید، نیازی به خرید مجدد اشتراک داخل ربات نیست! 🎉\n\nکافیست **شناسه یکتای** ربات خود را کپی کرده و برای پشتیبانی ما ارسال کنید تا اکانت اشتراکی شما به سرعت انتقال داده شود.\n\n🔑 **شناسه یکتای ربات شما:** `{chat_id}`\n\n👨‍💻 **پشتیبانی:**\n🆔 @H_a_m_e_d100"
+                asyncio.create_task(send_with_keyboard(bot, chat_id, transfer_text, True))
                 return
 
             if user_text_str in["/chat", "💬 چت", "چت با هوش مصنوعی 🤖"]:
                 user_states[chat_id]["mode"] = "chat"
                 user_states[chat_id]["history"] =[]
-                await send_with_keyboard(bot, chat_id, "💬 شما وارد بخش **چت با هوش مصنوعی** شدید.\n\nهر سوالی دارید بفرستید تا جواب بدم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "💬 شما وارد بخش **چت با هوش مصنوعی** شدید.\n\nهر سوالی دارید بفرستید تا جواب بدم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True))
                 return
 
             if user_text_str in ["/image", "🎨 عکس", "ساخت تصاویر🎨"]:
                 user_states[chat_id]["mode"] = "image_waiting_for_text"
-                await send_with_keyboard(bot, chat_id, "🎨 شما وارد بخش **ساخت عکس پیشرفته** شدید.\n\nمتن خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "🎨 شما وارد بخش **ساخت عکس پیشرفته** شدید.\n\nمتن خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True))
                 return
 
             if user_text_str in["/edit_image", "ویرایش تصاویر 🪄"]:
                 user_states[chat_id]["mode"] = "image_edit_waiting_for_image"
                 user_states[chat_id]["file_bytes"] = None
-                await send_with_keyboard(bot, chat_id, "🪄 به بخش **ویرایش عکس (Flux.2)** خوش آمدید.\n\nلطفاً ابتدا عکسی که می‌خواهید ویرایش کنید را بفرستید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "🪄 به بخش **ویرایش عکس (Flux.2)** خوش آمدید.\n\nلطفاً ابتدا عکسی که می‌خواهید ویرایش کنید را بفرستید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True))
                 return
 
             if user_text_str in["/tts", "🎙️ صدا", "تبدیل متن به صدا🗣️"]:
                 user_states[chat_id]["mode"] = "tts_waiting_for_text"
-                await send_with_keyboard(bot, chat_id, "🎙️ شما وارد بخش **تبدیل متن به صدا** شدید.\n\nلطفاً متنی که می‌خواهید به صدا تبدیل شود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "🎙️ شما وارد بخش **تبدیل متن به صدا** شدید.\n\nلطفاً متنی که می‌خواهید به صدا تبدیل شود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True))
                 return
             
             if user_text_str in["/podcast", "📻 پادکست", "ساخت پادکست 🎙️"]:
                 user_states[chat_id]["mode"] = "podcast_waiting_for_topic"
-                await send_with_keyboard(bot, chat_id, "📻 شما وارد بخش **ساخت پادکست** شدید.\n\nلطفاً موضوع پادکست خود را بفرستید.\nمثال: درباره تاریخچه پیدایش قهوه با ۳ گویند�� یک پادکست جذاب بساز .\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "📻 شما وارد بخش **ساخت پادکست** شدید.\n\nلطفاً موضوع پادکست خود را بفرستید.\nمثال: درباره تاریخچه پیدایش قهوه با ۳ گوینده یک پادکست جذاب بساز .\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True))
                 return
 
-            if user_text_str in ["/file", "تحلیل فایل 📁"]:
+            if user_text_str in["/file", "تحلیل فایل 📁"]:
                 user_states[chat_id]["mode"] = "file_waiting_for_file"
                 user_states[chat_id]["file_bytes"] = None
-                await send_with_keyboard(bot, chat_id, "📁 شما وارد بخش **تحلیل فایل اختصاصی** شدید.\n\nلطفاً فایل خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "📁 شما وارد بخش **تحلیل فایل اختصاصی** شدید.\n\nلطفاً فایل خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True))
                 return
 
             if user_text_str in["/stt", "فایل صوتی به متن 📝"]:
                 user_states[chat_id]["mode"] = "stt_waiting_for_audio"
-                await send_with_keyboard(bot, chat_id, "📝 شما وارد بخش **تبدیل صدا به متن** شدید.\n\nلطفاً فایل خود (ویس، آهنگ، ویدیو و...) را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "📝 شما وارد بخش **تبدیل صدا به متن** شدید.\n\nلطفاً فایل خود (ویس، آهنگ، ویدیو و...) را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True))
                 return
 
             if user_text_str in["/create_file", "ساخت فایل 📄"]:
                 user_states[chat_id]["mode"] = "create_file_waiting_for_topic"
-                await send_with_keyboard(bot, chat_id, "📄 شما وارد بخش **ساخت فایل** شدید.\n\nلطفاً موضوع مقاله‌ای که می‌خواهید را کامل بفرستید.\nمثال: نحوه مدیریت زمان\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                asyncio.create_task(send_with_keyboard(bot, chat_id, "📄 شما وارد بخش **ساخت فایل** شدید.\n\nلطفاً موضوع مقاله‌ای که می‌خواهید را کامل بفرستید.\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(bot, chat_id, "⚠️ لطفاً ابتدا از کیبورد پایین، بخش مورد نظرتان را انتخاب کنید:", True)
+                elif user_text_str: asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً ابتدا از کیبورد پایین، بخش مورد نظرتان را انتخاب کنید:", True))
                 return
 
             elif current_mode == "chat":
-                if is_file:
-                    await send_with_keyboard(bot, chat_id, "📥 در حال دانلود فایل...", False)
-                    try:
-                        file_bytes = await helper_download_file(bot, message)
-                        await process_gemini(bot, chat_id, user_text_str, file_bytes=file_bytes, file_name=file_name)
-                    except Exception as dl_err: await send_with_keyboard(bot, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
-                elif user_text_str: await process_gemini(bot, chat_id, user_text_str)
+                if is_file: asyncio.create_task(task_chat_file(bot, chat_id, user_text_str, message, file_name))
+                elif user_text_str: asyncio.create_task(process_gemini(bot, chat_id, user_text_str))
                 return
 
             elif current_mode == "image_waiting_for_text":
-                if user_text_str: await process_image(bot, chat_id, user_text_str)
+                if user_text_str: asyncio.create_task(process_image(bot, chat_id, user_text_str))
                 return
 
             elif current_mode == "image_edit_waiting_for_image":
-                if not is_file: return await send_with_keyboard(bot, chat_id, "⚠️ لطفاً ابتدا یک عکس ارسال کنید.", False)
-                await send_with_keyboard(bot, chat_id, "📥 در حال دانلود عکس...", False)
-                try:
-                    file_bytes = await helper_download_file(bot, message)
-                    user_states[chat_id]["file_bytes"] = file_bytes
-                    user_states[chat_id]["mode"] = "image_edit_waiting_for_prompt"
-                    await send_with_keyboard(bot, chat_id, "✅ عکس با موفقیت دریافت شد.\n\nحالا دستور خود را به صورت متنی تایپ کنید.\nمثال: یک کلاه قرمز روی سر این گربه بگذار.", False)
-                except Exception as dl_err: await send_with_keyboard(bot, chat_id, f"❌ خطا در دریافت عکس!\n{str(dl_err)}", False)
+                if not is_file: 
+                    asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً ابتدا یک عکس ارسال کنید.", False))
+                    return
+                asyncio.create_task(task_image_edit(bot, chat_id, message))
                 return
 
             elif current_mode == "image_edit_waiting_for_prompt":
@@ -1299,67 +1251,49 @@ if bot:
                     saved_bytes = user_states[chat_id].get("file_bytes")
                     user_states[chat_id]["mode"] = None 
                     user_states[chat_id]["file_bytes"] = None
-                    await process_image_edit(bot, chat_id, saved_bytes, user_text_str)
-                else: await send_with_keyboard(bot, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
+                    asyncio.create_task(process_image_edit(bot, chat_id, saved_bytes, user_text_str))
+                else: asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False))
                 return
 
             elif current_mode == "tts_waiting_for_text":
                 if user_text_str:
-                    if len(user_text_str) > 2500: return await send_with_keyboard(bot, chat_id, "⚠️ لطفاً متنی کوتاه‌تر از 2500 کاراکتر بفرستید.", False)
+                    if len(user_text_str) > 2500: 
+                        asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً متنی کوتاه‌تر از 2500 کاراکتر بفرستید.", False))
+                        return
                     user_states[chat_id]["text"] = user_text_str
                     user_states[chat_id]["mode"] = "tts_waiting_for_speaker"
-                    
-                    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(bot, chat_id, speakers_menu, False)
+                    speakers_menu = "✅ متن شما ذخیره شد.\nلطفاً **شماره** گوینده مورد نظر خود را بفرستید:\n1. شهاب | 2. آوا | 3. نوید\n4. آرمان | 5. مهسا | 6. دانا\n7. سامان | 8. آرش | 9. شبنم\n10. سحر | 11. مریم | 12. بهرام\n13. نیکان| 14. فرناز | 15. سارا\n16. مانی | 17. آرتین | 18. دلنواز\n19. روژان | 20. امید | 21. بردیا\n22. ترانه | 23. نیکو | 24. هستی\n25. کامیار| 26. کیانوش| 27. پویا\n28. مهتاب | 29. سام | 30. لیدا"
+                    asyncio.create_task(send_with_keyboard(bot, chat_id, speakers_menu, False))
                 return
 
             elif current_mode == "tts_waiting_for_speaker":
                 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"
-                    await process_tts(bot, chat_id, txt, spk_id, spk_name)
+                    asyncio.create_task(process_tts(bot, chat_id, txt, spk_id, spk_name))
                 else: 
-                    await send_with_keyboard(bot, chat_id, "❌ شماره نامعتبر است! لطفاً فقط یک عدد بین 1 تا 30 بفرستید.", False)
+                    asyncio.create_task(send_with_keyboard(bot, chat_id, "❌ شماره نامعتبر است! لطفاً فقط یک عدد بین 1 تا 30 بفرستید.", False))
                 return
 
             elif current_mode == "podcast_waiting_for_topic":
-                if user_text_str: await process_podcast(bot, chat_id, user_text_str)
-                else: await send_with_keyboard(bot, chat_id, "⚠️ لطفاً موضوع پادکست خود را به صورت متنی بفرستید.", False)
+                if user_text_str: asyncio.create_task(process_podcast(bot, chat_id, user_text_str))
+                else: asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً موضوع پادکست خود را به صورت متنی بفرستید.", False))
                 return
 
             elif current_mode == "stt_waiting_for_audio":
-                if not is_file: return await send_with_keyboard(bot, chat_id, "⚠️ لطفاً یک فایل ارسال کنید.", False)
-                await send_with_keyboard(bot, chat_id, "📥 در حال دانلود فایل...", False)
-                try:
-                    audio_bytes = await helper_download_file(bot, message)
-                    await process_stt(bot, chat_id, audio_bytes, file_name)
-                except Exception as dl_err: await send_with_keyboard(bot, chat_id, f"❌ خطا در دانلود فایل!\n{str(dl_err)}", False)
+                if not is_file: 
+                    asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً یک فایل ارسال کنید.", False))
+                    return
+                asyncio.create_task(task_stt(bot, chat_id, message, file_name))
                 return
 
             elif current_mode == "file_waiting_for_file":
-                if not is_file: return await send_with_keyboard(bot, chat_id, "⚠️ لطفاً ابتدا یک فایل ارسال کنید.", False)
-                await send_with_keyboard(bot, chat_id, "📥 در حال دریافت فایل...", False)
-                try:
-                    file_bytes = await helper_download_file(bot, message)
-                    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(bot, chat_id, "✅ فایل با موفقیت دریافت شد.\n\nحالا لطفاً متنی بگویید **چگونه تحلیل شود؟**", False)
-                except Exception as dl_err: await send_with_keyboard(bot, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                if not is_file: 
+                    asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً ابتدا یک فایل ارسال کنید.", False))
+                    return
+                asyncio.create_task(task_file_analysis(bot, chat_id, message, file_name))
                 return
 
             elif current_mode == "file_waiting_for_prompt":
@@ -1367,19 +1301,16 @@ if bot:
                     saved_bytes = user_states[chat_id].get("file_bytes")
                     saved_name = user_states[chat_id].get("file_name", "file.jpeg")
                     user_states[chat_id]["mode"] = "file_waiting_for_file" 
-                    await process_file_analysis(bot, chat_id, saved_bytes, saved_name, user_text_str)
-                else: await send_with_keyboard(bot, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
+                    asyncio.create_task(process_file_analysis(bot, chat_id, saved_bytes, saved_name, user_text_str))
+                else: asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False))
                 return
 
             elif current_mode == "create_file_waiting_for_topic":
-                if user_text_str:
-                    await process_create_file(bot, chat_id, user_text_str)
-                else: 
-                    await send_with_keyboard(bot, chat_id, "⚠️ لطفاً موضوع مقاله خود را به صورت متنی بفرستید.", False)
+                if user_text_str: asyncio.create_task(process_create_file(bot, chat_id, user_text_str))
+                else: asyncio.create_task(send_with_keyboard(bot, chat_id, "⚠️ لطفاً موضوع مقاله خود را به صورت متنی بفرستید.", False))
                 return
 
         except Exception as e: 
-            print("خطا در پردازش:", e)
             traceback.print_exc()
 
 if __name__ == "__main__":
@@ -1388,5 +1319,5 @@ if __name__ == "__main__":
         print("خطا: توکن ربات بله وارد نشده است! لطفا متغیر BALE_TOKEN را تنظیم کنید.")
     else:
         print("ربات آلفا پرو با سیستم اشتراک نامحدود + سپر امنیتی متصل به پیامرسان «بله» روشن شد... 🚀")
-        # تنظیم زمان تایم‌اوت معقول برای جلوگیری از بسته شدن کانکشن بله
-        asyncio.run(bot.polling(non_stop=True, timeout=20, request_timeout=30))
+        # کلید حل مشکل اسپم: skip_pending=True
+        asyncio.run(bot.polling(non_stop=True, skip_pending=True, timeout=20, request_timeout=30))