Update main.py

main.py

@@ -17,7 +17,7 @@ from flask import Flask
 # کتابخانه‌های ربات تلگرام/بله
 import telebot
 from telebot.async_telebot import AsyncTeleBot
-from telebot import asyncio_helper  # تغییر نام به ماژول صحیح
+from telebot import asyncio_helper  # ماژول صحیح برای اتصال به بله در حالت غیرهمزمان
 from telebot.types import ReplyKeyboardMarkup, KeyboardButton
 
 # ایمپورت‌های هوش مصنوعی، کار با فایل صوتی و دیتابیس هاگینگ فیس
@@ -35,28 +35,6 @@ ADMIN_CODE = "3011"
 # متغیر سراسری برای ذخیره آیدی خود ربات (جلوگیری از جواب دادن ربات به خودش)
 BOT_GUID = None
 
-# =======================================================
-# 🔥 سیستم کنترل سرعت و ضد رگبار (Burst Controller) 🔥
-# =======================================================
-global_burst_count = 0
-global_burst_time = time.time()
-burst_lock = threading.Lock()
-
-def is_backlog_burst():
-    """اگر بیشتر از 5 پیام در 1 ثانیه بیاید، یعنی رگبار از سمت سرور است و رد می‌شود"""
-    global global_burst_count, global_burst_time
-    with burst_lock:
-        now = time.time()
-        if now - global_burst_time > 1.0:
-            global_burst_time = now
-            global_burst_count = 1
-            return False
-        else:
-            global_burst_count += 1
-            if global_burst_count > 5:
-                return True
-            return False
-
 # --- سیستم دیتابیس حساب کاربری متصل به دیتاست هاگینگ فیس ---
 DB_FILE = "users_db.json"
 DATASET_REPO = "Opera8/Karbaran-rayegan-tedad"
@@ -96,7 +74,7 @@ def load_db():
                 print("✅ دیتابیس با موفقیت از دیتاست هاگینگ فیس لود شد.")
                 return json.load(f)
         except Exception as e:
-            print("⚠️ فایل دیتابیس در هاگینگ فیس یافت نشد یا خطایی رخ داد (ساخت دیتابیس جدید). جزئیات:", str(e)[:100])
+            print("⚠️ فایل دیتابیس در هاگینگ فیس یافت نشد (ساخت دیتابیس جدید).")
     
     if os.path.exists(DB_FILE):
         try:
@@ -191,7 +169,7 @@ app = Flask(__name__)
 
 @app.route('/')
 def home():
-    return "ربات یکپارچه آلفا (متصل به بله + دیتاست + سیستم ضد باگ) روشن است! 🚀"
+    return "ربات یکپارچه آلفا (متصل به بله + دیتاست + بدون قفلی) روشن است! 🚀"
 
 def run_flask():
     app.run(host="0.0.0.0", port=7860)
@@ -215,19 +193,6 @@ def get_join_keyboard():
     markup.row(KeyboardButton("✅ عضو شدم"))
     return markup
 
-# --- ⛔️ سیستم بررسی عضویت اجباری کانال (Force Join) ⛔️ ---
-CHANNEL_USERNAME = "aialpha"
-
-async def check_channel_membership(client, user_id):
-    global BOT_GUID
-    if str(user_id) == str(BOT_GUID): return True
-    try:
-        member = await client.get_chat_member(f"@{CHANNEL_USERNAME}", user_id)
-        if member.status in ['member', 'administrator', 'creator']:
-            return True
-        return False
-    except Exception:
-        return False
 
 # --- تابع ارسال منحصراً برای کیبورد پایین صفحه ---
 async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
@@ -274,8 +239,6 @@ if GEMINI_KEYS_STR2:
     _raw_keys.extend(GEMINI_KEYS_STR2.split(","))
 
 GEMINI_KEYS = list(set([k.strip() for k in _raw_keys if k.strip()]))
-print(f"✅ تعداد {len(GEMINI_KEYS)} کلید جیمینای با موفقیت شناسایی شد.")
-
 current_gemini_key_index = 0
 gemini_key_lock = threading.Lock()
 
@@ -310,7 +273,7 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
             markup = get_main_keyboard()
             if file_type in["photo", "Image", "image"]:
                 await client.send_photo(chat_id, photo=f, caption=caption, reply_markup=markup)
-            elif file_type in ["voice", "Voice", "audio"]:
+            elif file_type in["voice", "Voice", "audio"]:
                 if abs_path.lower().endswith('.ogg'):
                     await client.send_voice(chat_id, voice=f, caption=caption, reply_markup=markup)
                 else:
@@ -342,13 +305,11 @@ SPEAKERS = {
 }
 
 user_states = {}
-processed_message_ids = set()
-user_last_request_time = {}
 
 
 # --- ۱. پردازش چت متنی و چندرسانه‌ای ---
 async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=None):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     if creds["chat"] <= 0:
         return await send_with_keyboard(client, chat_id, "❌ اعتبار پیام‌های چت شما تمام شده است. لطفاً از منوی اصلی وار�� بخش «خرید اشتراک 💎» شوید.", False)
@@ -482,7 +443,7 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
 
 # --- ۲. پردازش ساخت عکس ---
 async def process_image(client, chat_id, prompt):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     if creds["image"] <= 0:
         return await send_with_keyboard(client, chat_id, "❌ اعتبار ساخت عکس شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
@@ -608,7 +569,7 @@ async def translate_text_aloha(prompt_text):
 
 # --- ۲.۵. پردازش ویرایش عکس ---
 async def process_image_edit(client, chat_id, image_bytes, prompt):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     if creds["edit_image"] <= 0:
         return await send_with_keyboard(client, chat_id, "❌ اعتبار ویرایش عکس شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
@@ -668,7 +629,7 @@ async def process_image_edit(client, chat_id, image_bytes, prompt):
 
 # --- ۳. پردازش ساخت صدا ---
 async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     if creds["tts"] <= 0:
         return await send_with_keyboard(client, chat_id, "❌ اعتبار تبدیل متن به صدای شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
@@ -724,7 +685,7 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
 
 # --- ۳.۵. پردازش پادکست ---
 async def process_podcast(client, chat_id, prompt):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     if creds["podcast"] <= 0:
         return await send_with_keyboard(client, chat_id, "❌ اعتبار ساخت پادکست شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
@@ -816,7 +777,7 @@ async def process_podcast(client, chat_id, prompt):
 
 # --- ۴. پردازش تبدیل فایل صوتی/تصویری به متن ---
 async def process_stt(client, chat_id, audio_bytes, file_name):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     if creds["stt"] <= 0:
         return await send_with_keyboard(client, chat_id, "❌ اعتبار تبدیل صدا به متن شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
@@ -861,7 +822,7 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
 
 # --- ۵. پردازش تحلیل فایل مستقل ---
 async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     if creds["file"] <= 0:
         return await send_with_keyboard(client, chat_id, "❌ اعتبار تحلیل فایل شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
@@ -905,7 +866,7 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
 
 # --- ۵.۵. پردازش ساخت مقاله و تبدیل به فایل ---
 async def process_create_file(client, chat_id, topic):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+    str_chat_id = str(chat_id)
     creds = get_user_credits(str_chat_id)
     
     if creds["chat"] <= 0:
@@ -1031,17 +992,12 @@ bot = AsyncTeleBot(bot_token) if bot_token else None
 if bot:
     @bot.message_handler(func=lambda message: True, content_types=['text', 'photo', 'document', 'voice', 'audio', 'video'])
     async def main_handler(message):
-        global BOT_GUID
-        
-        if is_backlog_burst():
-            return
-            
         try:
+            global BOT_GUID
             if not BOT_GUID:
                 try:
                     me_info = await bot.get_me()
-                    if me_info:
-                        BOT_GUID = me_info.id
+                    if me_info: BOT_GUID = me_info.id
                 except Exception:
                     pass
 
@@ -1050,19 +1006,6 @@ if bot:
                 return
             
             chat_id = message.chat.id
-            msg_id = message.message_id
-            
-            unique_msg_key = f"{chat_id}_{msg_id}" if msg_id else None
-            if unique_msg_key:
-                if unique_msg_key in processed_message_ids: return
-                processed_message_ids.add(unique_msg_key)
-                if len(processed_message_ids) > 5000: processed_message_ids.clear()
-            
-            current_time = time.time()
-            last_req_time = user_last_request_time.get(chat_id, 0)
-            if current_time - last_req_time < 1.0:
-                return
-            user_last_request_time[chat_id] = current_time
 
             user_text = message.text or message.caption or ""
             user_text_str = str(user_text).strip() if user_text else ""
@@ -1078,24 +1021,10 @@ if bot:
                     target_id = parts[1].replace("`", "").replace("'", "").replace('"', "").strip()
                     if target_id:
                         if target_id not in user_credits_db:
-                            user_credits_db[target_id] = {
-                                "is_premium": False,
-                                "expire_date": None,
-                                "last_reset": "",
-                                "chat": 10,
-                                "image": 5,
-                                "edit_image": 1,
-                                "podcast": 2,
-                                "tts": 5,
-                                "file": 1,
-                                "stt": 5,
-                                "has_joined": True
-                            }
-                        
+                            user_credits_db[target_id] = {"is_premium": False, "expire_date": None, "last_reset": "", "chat": 10, "image": 5, "edit_image": 1, "podcast": 2, "tts": 5, "file": 1, "stt": 5, "has_joined": True}
                         user_credits_db[target_id]["is_premium"] = True
                         expire_time = datetime.datetime.now() + datetime.timedelta(days=30)
                         user_credits_db[target_id]["expire_date"] = expire_time.isoformat()
-                        
                         user_credits_db[target_id]["chat"] = 999999
                         user_credits_db[target_id]["image"] = 20
                         user_credits_db[target_id]["edit_image"] = 10
@@ -1103,7 +1032,6 @@ if bot:
                         user_credits_db[target_id]["tts"] = 999999
                         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:
@@ -1135,7 +1063,6 @@ if bot:
                         if target_id in user_credits_db:
                             t_creds = user_credits_db[target_id]
                             is_prem = t_creds.get("is_premium", False)
-                            
                             if is_prem:
                                 expire_txt = "نامشخص"
                                 days_left = 0
@@ -1144,33 +1071,13 @@ if bot:
                                     now = datetime.datetime.now()
                                     diff = exp_d - now
                                     days_left = diff.days if diff.days >= 0 else 0
-                                    
                                     jy, jm, jd = gregorian_to_jalali(exp_d.year, exp_d.month, exp_d.day)
                                     expire_txt = f"{jy:04d}/{jm:02d}/{jd:02d}"
                                 status_text = f"🌟 نسخه پرو (ویژه)\n📅 انقضا: {expire_txt}\n⏳ باقیمانده: {days_left} روز"
                             else:
                                 status_text = "🥉 نسخه رایگان (آزمایشی)\n⏳ سهمیه روزانه"
 
-                            chat_rem = "نامحدود ∞" if is_prem else t_creds.get('chat', 0)
-                            podcast_rem = "نامحدود ∞" if is_prem else t_creds.get('podcast', 0)
-                            tts_rem = "نامحدود ∞" if is_prem else t_creds.get('tts', 0)
-                            file_rem = "نامحدود ∞" if is_prem else t_creds.get('file', 0)
-                            stt_rem = "نامحدود ∞" if is_prem else t_creds.get('stt', 0)
-                            image_rem = t_creds.get('image', 0)
-                            edit_image_rem = t_creds.get('edit_image', 0)
-
-                            info_msg = f"""🔍 **اطلاعات کاربر `{target_id}`:**
-
-🔹 **وضعیت:** {status_text}
-
-📊 **سهمیه:**
-- چت: {chat_rem}
-- تولید عکس: {image_rem}
-- ویرایش عکس: {edit_image_rem}
-- پادکست: {podcast_rem}
-- متن به صدا: {tts_rem}
-- تحلیل فایل: {file_rem}
-- صدا به متن: {stt_rem}"""
+                            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)
                         else:
                             await send_with_keyboard(bot, chat_id, f"❌ کاربری با شناسه `{target_id}` در دیتابیس یافت نشد.", False)
@@ -1195,7 +1102,7 @@ if bot:
                 is_file = True
                 file_name = getattr(message.video, 'file_name', f"video_{uuid.uuid4().hex[:6]}.mp4")
 
-            str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+            str_chat_id = str(chat_id)
             creds = get_user_credits(str_chat_id)
 
             if user_text_str == "✅ عضو شدم":
@@ -1220,10 +1127,9 @@ if bot:
                 return
 
             # --- حساب کاربری ---
-            if user_text_str in ["/account", "حساب کاربری 👤"]:
+            if user_text_str in["/account", "حساب کاربری 👤"]:
                 creds = get_user_credits(chat_id)
                 is_prem = creds.get("is_premium", False)
-                
                 if is_prem:
                     expire_txt = "نامشخص"
                     days_left = 0
@@ -1232,10 +1138,8 @@ if bot:
                         now = datetime.datetime.now()
                         diff = exp_d - now
                         days_left = diff.days if diff.days >= 0 else 0
-                        
                         jy, jm, jd = gregorian_to_jalali(exp_d.year, exp_d.month, exp_d.day)
                         expire_txt = f"{jy:04d}/{jm:02d}/{jd:02d} (ساعت {exp_d.hour:02d}:{exp_d.minute:02d})"
-                        
                     status_text = "🌟 نسخه پرو (ویژه)"
                     expire_info = f"\n📅 **تاریخ انقضا:** {expire_txt}\n⏳ **زمان باقیمانده:** {days_left} روز"
                     daily_note = "*نکته: سهمیه پردازشی شما مختص همین دوره یک‌ماهه می‌باشد.*"
@@ -1339,10 +1243,10 @@ if bot:
             
             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)
+                await 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)
@@ -1355,7 +1259,7 @@ if bot:
 
             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هوش مصنوعی یک مقاله کامل و طولانی نوشته و در نهایت فایل PDF و Word آن را به شما تحویل می‌دهد.\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                await send_with_keyboard(bot, chat_id, "📄 شما وارد بخش **ساخت فایل** شدید.\n\nلطفاً موضوع مقاله‌ای که می‌خواهید را کامل بفرستید.\nمثال: نحوه مدیریت زمان\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             current_mode = user_states[chat_id].get("mode")
@@ -1370,13 +1274,13 @@ if bot:
                     await send_with_keyboard(bot, chat_id, "📥 در حال دانلود فایل...", False)
                     try:
                         file_bytes = await helper_download_file(bot, message)
-                        asyncio.create_task(process_gemini(bot, chat_id, user_text_str, file_bytes=file_bytes, file_name=file_name))
+                        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: asyncio.create_task(process_gemini(bot, chat_id, user_text_str))
+                elif user_text_str: await process_gemini(bot, chat_id, user_text_str)
                 return
 
             elif current_mode == "image_waiting_for_text":
-                if user_text_str: asyncio.create_task(process_image(bot, chat_id, user_text_str))
+                if user_text_str: await process_image(bot, chat_id, user_text_str)
                 return
 
             elif current_mode == "image_edit_waiting_for_image":
@@ -1395,7 +1299,7 @@ if bot:
                     saved_bytes = user_states[chat_id].get("file_bytes")
                     user_states[chat_id]["mode"] = None 
                     user_states[chat_id]["file_bytes"] = None
-                    asyncio.create_task(process_image_edit(bot, chat_id, saved_bytes, user_text_str))
+                    await process_image_edit(bot, chat_id, saved_bytes, user_text_str)
                 else: await send_with_keyboard(bot, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
                 return
 
@@ -1427,13 +1331,13 @@ if bot:
                     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(bot, chat_id, txt, spk_id, spk_name))
+                    await process_tts(bot, chat_id, txt, spk_id, spk_name)
                 else: 
                     await send_with_keyboard(bot, chat_id, "❌ شماره نامعتبر است! لطفاً فقط یک عدد بین 1 تا 30 بفرستید.", False)
                 return
 
             elif current_mode == "podcast_waiting_for_topic":
-                if user_text_str: asyncio.create_task(process_podcast(bot, chat_id, user_text_str))
+                if user_text_str: await process_podcast(bot, chat_id, user_text_str)
                 else: await send_with_keyboard(bot, chat_id, "⚠️ لطفاً موضوع پادکست خود را به صورت متنی بفرستید.", False)
                 return
 
@@ -1442,7 +1346,7 @@ if bot:
                 await send_with_keyboard(bot, chat_id, "📥 در حال دانلود فایل...", False)
                 try:
                     audio_bytes = await helper_download_file(bot, message)
-                    asyncio.create_task(process_stt(bot, chat_id, audio_bytes, file_name))
+                    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)
                 return
 
@@ -1463,18 +1367,20 @@ 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" 
-                    asyncio.create_task(process_file_analysis(bot, chat_id, saved_bytes, saved_name, user_text_str))
+                    await process_file_analysis(bot, chat_id, saved_bytes, saved_name, user_text_str)
                 else: await send_with_keyboard(bot, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
                 return
 
             elif current_mode == "create_file_waiting_for_topic":
                 if user_text_str:
-                    asyncio.create_task(process_create_file(bot, chat_id, user_text_str))
+                    await process_create_file(bot, chat_id, user_text_str)
                 else: 
                     await send_with_keyboard(bot, chat_id, "⚠️ لطفاً موضوع مقاله خود را به صورت متنی بفرستید.", False)
                 return
 
-        except Exception: traceback.print_exc()
+        except Exception as e: 
+            print("خطا در پردازش:", e)
+            traceback.print_exc()
 
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()
@@ -1482,4 +1388,5 @@ if __name__ == "__main__":
         print("خطا: توکن ربات بله وارد نشده است! لطفا متغیر BALE_TOKEN را تنظیم کنید.")
     else:
         print("ربات آلفا پرو با سیستم اشتراک نامحدود + سپر امنیتی متصل به پیامرسان «بله» روشن شد... 🚀")
-        asyncio.run(bot.polling(non_stop=True, request_timeout=90))
+        # تنظیم زمان تایم‌اوت معقول برای جلوگیری از بسته شدن کانکشن بله
+        asyncio.run(bot.polling(non_stop=True, timeout=20, request_timeout=30))