Update main.py

main.py

@@ -21,7 +21,7 @@ app = Flask(__name__)
 
 @app.route('/')
 def home():
-    return "🚀 ربات انتقال به گیت‌هاب (پشتیبانی از وب، تلگرام و اینستاگرام) روشن است!"
+    return "🚀 ربات هوشمند انتقال فایل (YouTube, Instagram, Telegram, Web) روشن است!"
 
 def run_flask():
     app.run(host="0.0.0.0", port=7860, threaded=True)
@@ -37,7 +37,7 @@ TG_API_ID = 6
 TG_API_HASH = "eb06d4abfb49dc3eeb1aeb98ae0f581e"
 
 if bot_token == "توکن_روبیکا" or GITHUB_TOKEN == "توکن_گیت‌هاب":
-    print("❌ توکن روبیکا یا گیت‌هاب تنظیم نشده است! لطفاً تنظیمات بالای کد را بررسی کنید.")
+    print("❌ تنظیمات ناقص است! توکن روبیکا یا گیت‌هاب را وارد کنید.")
     exit()
 
 bot = BotClient(bot_token)
@@ -45,19 +45,13 @@ BOT_GUID = None
 git_lock = asyncio.Lock()
 
 # ==============================================================================
-# 🟢 تنظیمات کلاینت تلگرام (Pyrogram)
+# 🟢 کلاینت تلگرام
 # ==============================================================================
 tg_client = None
 is_tg_started = False
 
 if TG_BOT_TOKEN and TG_BOT_TOKEN != "توکن_تلگرام":
-    tg_client = Client(
-        "tg_bot_session", 
-        api_id=TG_API_ID, 
-        api_hash=TG_API_HASH, 
-        bot_token=TG_BOT_TOKEN, 
-        in_memory=True
-    )
+    tg_client = Client("tg_bot_session", api_id=TG_API_ID, api_hash=TG_API_HASH, bot_token=TG_BOT_TOKEN, in_memory=True)
 
 async def ensure_tg_started():
     global is_tg_started
@@ -66,34 +60,39 @@ async def ensure_tg_started():
         is_tg_started = True
 
 # ==============================================================================
-# 🟢 توابع دانلود (اینستاگرام، تلگرام و وب)
+# 🟢 توابع دانلود حرفه‌ای
 # ==============================================================================
 
-# 1. تابع دانلود از اینستاگرام (و سایت‌های مشابه) با yt-dlp
+# 1. دانلود از یوتیوب، اینستاگرام و سایر شبکه‌های اجتماعی
 def sync_download_ytdlp(url, temp_dir):
-    """این تابع همگام است و در یک ترد مجزا اجرا می‌شود"""
     ydl_opts = {
         'outtmpl': f'{temp_dir}/{uuid.uuid4().hex[:6]}_%(title)s.%(ext)s',
         'quiet': True,
         'no_warnings': True,
-        'format': 'best'
+        'format': 'bestvideo[ext=mp4]+bestaudio[ext=m4a]/best[ext=mp4]/best', # تلاش برای دریافت بهترین کیفیت MP4
+        'merge_output_format': 'mp4',
     }
     with yt_dlp.YoutubeDL(ydl_opts) as ydl:
         info = ydl.extract_info(url, download=True)
         file_path = ydl.prepare_filename(info)
+        # اگر فایل mkv بود یا فرمت دیگری، yt-dlp ممکن است پسوند را تغییر دهد
+        if not os.path.exists(file_path):
+            base_path = os.path.splitext(file_path)[0]
+            for ext in ['.mp4', '.mkv', '.webm', '.flv']:
+                if os.path.exists(base_path + ext):
+                    file_path = base_path + ext
+                    break
+        
         filename = os.path.basename(file_path)
-        # پاکسازی نام فایل از کاراکترهای عجیب برای گیت‌هاب
-        clean_filename = re.sub(r'[\\/*?:"<>|]', "", filename)
-        if clean_filename != filename:
-            clean_path = os.path.join(temp_dir, clean_filename)
-            os.rename(file_path, clean_path)
-            return clean_path, clean_filename
-        return file_path, filename
+        clean_filename = re.sub(r'[\\/*?:"<>|]', "", filename).replace(" ", "_")
+        clean_path = os.path.join(temp_dir, clean_filename)
+        os.rename(file_path, clean_path)
+        return clean_path, clean_filename
 
-async def download_from_instagram(url, chat_id, message_id, client):
+async def download_social_media(url, chat_id, message_id, client, platform_name):
     status_msg_id = None
     try:
-        status_msg = await client.send_message(chat_id, "⏳ در حال استخراج و دانلود رسانه از اینستاگرام...", reply_to_message_id=message_id)
+        status_msg = await client.send_message(chat_id, f"⏳ در حال پردازش لینک {platform_name} و دانلود با بالاترین کیفیت...", reply_to_message_id=message_id)
         status_msg_id = getattr(status_msg, 'message_id', None)
         if not status_msg_id and isinstance(status_msg, dict):
             status_msg_id = status_msg.get('message_update', {}).get('message_id') or status_msg.get('message_id')
@@ -102,286 +101,173 @@ async def download_from_instagram(url, chat_id, message_id, client):
     try:
         temp_dir = "/app/downloads"
         os.makedirs(temp_dir, exist_ok=True)
-        
-        # اجرای کتابخانه همگام در یک ترد مجزا برای جلوگیری از قفل شدن ربات
         file_path, filename = await asyncio.to_thread(sync_download_ytdlp, url, temp_dir)
         return file_path, filename, status_msg_id
     except Exception as e:
-        error_msg = f"❌ خطا در دانلود از اینستاگرام (احتمالاً پیج پرایوت است یا پست حذف شده):\n{str(e)[:150]}"
+        error_msg = f"❌ خطا در دانلود از {platform_name}:\nاحتمالاً محتوا حذف شده یا محدودیت جغرافیایی دارد."
         if status_msg_id:
             try: await client.edit_message_text(chat_id, status_msg_id, error_msg)
             except: pass
         return None, None, status_msg_id
 
-# 2. تابع دانلود از تلگرام
+# 2. دانلود از تلگرام (کانال‌های عمومی)
 async def download_from_telegram(url, chat_id, message_id, client):
     status_msg_id = None
     try:
-        status_msg = await client.send_message(chat_id, "⏳ در حال برقراری ارتباط با سرورهای تلگرام...", reply_to_message_id=message_id)
+        status_msg = await client.send_message(chat_id, "⏳ در حال اتصال به تلگرام...", reply_to_message_id=message_id)
         status_msg_id = getattr(status_msg, 'message_id', None)
-        if not status_msg_id and isinstance(status_msg, dict):
-            status_msg_id = status_msg.get('message_update', {}).get('message_id') or status_msg.get('message_id')
     except: pass
 
     try:
-        if not tg_client:
-            raise Exception("ربات تلگرام متصل نیست. لطفاً توکن تلگرام را در سورس کد قرار دهید.")
-
+        if not tg_client: raise Exception("توکن تلگرام تنظیم نشده است.")
         await ensure_tg_started()
-        
         match = re.search(r"t\.me/([^/]+)/(\d+)", url)
-        if not match:
-            raise Exception("لینک تلگرام نامعتبر است.")
-        
-        channel_username = match.group(1)
-        msg_id = int(match.group(2))
+        if not match: raise Exception("لینک نامعتبر.")
         
-        if status_msg_id:
-            try: await client.edit_message_text(chat_id, status_msg_id, "⏳ در حال دریافت اطلاعات فایل از کانال عمومی تلگرام...")
-            except: pass
-
-        msg = await tg_client.get_messages(channel_username, msg_id)
-        if not msg or not msg.media:
-            raise Exception("فایلی در این پیام یافت نشد یا پیام از کانال حذف شده است.")
+        channel, m_id = match.group(1), int(match.group(2))
+        msg = await tg_client.get_messages(channel, m_id)
         
-        filename = None
-        if getattr(msg, 'document', None): filename = msg.document.file_name
-        elif getattr(msg, 'video', None): filename = msg.video.file_name
-        elif getattr(msg, 'audio', None): filename = msg.audio.file_name
-        elif getattr(msg, 'photo', None): filename = f"tg_photo_{uuid.uuid4().hex[:6]}.jpg" # پشتیبانی از عکس تلگرام
+        if not msg or not msg.media: raise Exception("فایلی یافت نشد.")
         
-        if not filename: filename = f"tg_media_{uuid.uuid4().hex[:6]}.dat"
+        filename = (getattr(msg.document, 'file_name', None) or 
+                    getattr(msg.video, 'file_name', None) or 
+                    getattr(msg.audio, 'file_name', None) or 
+                    f"photo_{uuid.uuid4().hex[:5]}.jpg")
         
         temp_dir = "/app/downloads"
         os.makedirs(temp_dir, exist_ok=True)
         file_path = os.path.join(temp_dir, f"{uuid.uuid4().hex[:6]}_{filename}")
         
         if status_msg_id:
-            try: await client.edit_message_text(chat_id, status_msg_id, "📥 در حال دانلود فایل از تلگرام به سرور واسط...")
+            try: await client.edit_message_text(chat_id, status_msg_id, "📥 در حال دریافت فایل از تلگرام...")
             except: pass
-        
+            
         await tg_client.download_media(msg, file_name=file_path)
         return file_path, filename, status_msg_id
-
     except Exception as e:
-        error_msg = f"❌ خطای تلگرام:\n{str(e)[:150]}"
-        if status_msg_id:
-            try: await client.edit_message_text(chat_id, status_msg_id, error_msg)
-            except: pass
+        if status_msg_id: await client.edit_message_text(chat_id, status_msg_id, f"❌ خطا: {str(e)[:100]}")
         return None, None, status_msg_id
 
-# 3. تابع دانلود وب (لینک مستقیم)
+# 3. دانلود فایل وب (لینک مستقیم)
 async def download_large_file(url, chat_id, message_id, client):
-    if "dropbox.com" in url:
-        if "dl=0" in url: url = url.replace("dl=0", "dl=1")
-        elif "?dl=" not in url and "&dl=" not in url: url += "&dl=1" if "?" in url else "?dl=1"
-
     temp_dir = "/app/downloads"
     os.makedirs(temp_dir, exist_ok=True)
-    
-    parsed_url = urllib.parse.urlparse(url)
-    filename = os.path.basename(parsed_url.path)
-    if not filename or '.' not in filename: filename = f"file_{uuid.uuid4().hex[:8]}.dat"
-        
+    filename = os.path.basename(urllib.parse.urlparse(url).path) or f"file_{uuid.uuid4().hex[:6]}.dat"
     file_path = os.path.join(temp_dir, f"{uuid.uuid4().hex[:6]}_{filename}")
     status_msg_id = None
-    
     try:
-        status_msg = await client.send_message(chat_id, "⏳ در حال دانلود فایل وب در سرور واسط...", reply_to_message_id=message_id)
+        status_msg = await client.send_message(chat_id, "⏳ در حال دانلود فایل مستقیم...", reply_to_message_id=message_id)
         status_msg_id = getattr(status_msg, 'message_id', None)
-        if not status_msg_id and isinstance(status_msg, dict):
-            status_msg_id = status_msg.get('message_update', {}).get('message_id') or status_msg.get('message_id')
-    except Exception: pass
-
-    try:
-        headers = {"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64)"}
-        async with aiohttp.ClientSession(headers=headers) as session:
-            async with session.get(url, timeout=0) as response:
-                if response.status != 200:
-                    return None, None, status_msg_id
+        async with aiohttp.ClientSession() as session:
+            async with session.get(url, timeout=0) as resp:
+                if resp.status != 200: return None, None, status_msg_id
                 with open(file_path, 'wb') as f:
-                    async for chunk in response.content.iter_chunked(2 * 1024 * 1024):
-                        if chunk: f.write(chunk)
+                    async for chunk in resp.content.iter_chunked(2*1024*1024): f.write(chunk)
         return file_path, filename, status_msg_id
-    except Exception: return None, None, status_msg_id
+    except: return None, None, status_msg_id
 
 # ==============================================================================
-# 🟢 تابع خرد کردن فایل
+# 🟢 عملیات گیت‌هاب و پارت‌بندی
 # ==============================================================================
-def split_file_for_winrar(file_path, dest_dir, base_filename):
-    chunk_size = 95 * 1024 * 1024 
+def split_file(file_path, dest_dir, base_filename):
+    chunk_size = 94 * 1024 * 1024 
     part_num = 1
     os.makedirs(dest_dir, exist_ok=True)
     with open(file_path, 'rb') as f:
         while True:
             chunk = f.read(chunk_size)
             if not chunk: break
-            part_name = f"{base_filename}.{part_num:03d}"
-            part_path = os.path.join(dest_dir, part_name)
-            with open(part_path, 'wb') as p:
-                p.write(chunk)
+            with open(os.path.join(dest_dir, f"{base_filename}.{part_num:03d}"), 'wb') as p: p.write(chunk)
             part_num += 1
 
-# ==============================================================================
-# 🟢 پردازش و آپلود در گیت‌هاب
-# ==============================================================================
 async def process_and_commit_to_github(client, chat_id, message_id, url):
-    
-    url_lower = url.lower()
-    
-    # سیستم تشخیص هوشمند لینک
-    if "instagram.com/" in url_lower:
-        file_path, filename, status_msg_id = await download_from_instagram(url, chat_id, message_id, client)
-    elif "t.me/" in url_lower:
+    url_l = url.lower()
+    # تشخیص پلتفرم
+    if any(x in url_l for x in ["youtube.com", "youtu.be"]):
+        file_path, filename, status_msg_id = await download_social_media(url, chat_id, message_id, client, "یوتیوب")
+    elif "instagram.com" in url_l:
+        file_path, filename, status_msg_id = await download_social_media(url, chat_id, message_id, client, "اینستاگرام")
+    elif any(x in url_l for x in ["tiktok.com", "twitter.com", "x.com"]):
+        file_path, filename, status_msg_id = await download_social_media(url, chat_id, message_id, client, "شبکه‌های اجتماعی")
+    elif "t.me/" in url_l:
         file_path, filename, status_msg_id = await download_from_telegram(url, chat_id, message_id, client)
     else:
         file_path, filename, status_msg_id = await download_large_file(url, chat_id, message_id, client)
     
-    if not file_path or not os.path.exists(file_path):
-        if status_msg_id:
-            try: await client.edit_message_text(chat_id, status_msg_id, "❌ پردازش فایل ناموفق بود. لطفاً لینک را بررسی کنید.")
-            except: pass
-        return
+    if not file_path or not os.path.exists(file_path): return
 
     try:
-        if status_msg_id:
-            try: await client.edit_message_text(chat_id, status_msg_id, "✅ رسانه با موفقیت دریافت شد.\n✂️ در حال پارت‌بندی و انتقال به گیت‌هاب...")
-            except: pass
-
         async with git_lock:
-            current_timestamp = int(time.time())
-            branch_name = f"DL-{current_timestamp}-{uuid.uuid4().hex[:6]}"
+            ts = int(time.time())
+            branch = f"DL-{ts}-{uuid.uuid4().hex[:5]}"
             repo_url = f"https://oauth2:{GITHUB_TOKEN}@github.com/{GITHUB_REPO}.git"
             work_dir = "/app/git_workspace"
             
             if os.path.exists(work_dir): shutil.rmtree(work_dir)
-                
-            subprocess.run(["git", "clone", repo_url, work_dir], check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
-            subprocess.run(["git", "config", "user.email", "bot@aialpha.local"], cwd=work_dir)
-            subprocess.run(["git", "config", "user.name", "AI Alpha Bot"], cwd=work_dir)
-            subprocess.run(["git", "checkout", "--orphan", branch_name], cwd=work_dir, check=True)
-            subprocess.run(["git", "rm", "-rf", "."], cwd=work_dir, stderr=subprocess.DEVNULL)
+            subprocess.run(["git", "clone", repo_url, work_dir], check=True, capture_output=True)
+            subprocess.run(["git", "config", "user.email", "bot@ai.com"], cwd=work_dir)
+            subprocess.run(["git", "config", "user.name", "Bot"], cwd=work_dir)
+            subprocess.run(["git", "checkout", "--orphan", branch], cwd=work_dir, check=True)
+            subprocess.run(["git", "rm", "-rf", "."], cwd=work_dir, capture_output=True)
             
-            file_folder = os.path.join(work_dir, filename)
-            split_file_for_winrar(file_path, file_folder, filename)
+            split_file(file_path, os.path.join(work_dir, filename), filename)
             
             subprocess.run(["git", "add", "."], cwd=work_dir, check=True)
-            subprocess.run(["git", "commit", "-m", f"Add parts for {filename}"], cwd=work_dir, check=True)
-            subprocess.run(["git", "push", "origin", branch_name], cwd=work_dir, check=True)
-            
-            zip_download_link = f"https://github.com/{GITHUB_REPO}/archive/refs/heads/{branch_name}.zip"
+            subprocess.run(["git", "commit", "-m", "add file"], cwd=work_dir, check=True)
+            subprocess.run(["git", "push", "origin", branch], cwd=work_dir, check=True)
             
-            success_text = (
-                f"🎉 فایل شما با موفقیت آماده شد!\n\n"
-                f"📁 **نام فایل:** {filename}\n"
-                f"🔗 **لینک دانلود مستقیم (بدون مصرف ترافیک بین‌الملل):**\n{zip_download_link}\n\n"
-                f"💡 **راهنما:** فایل بالا را دانلود کرده و استخراج (Extract) کنید.\n\n"
-                f"⚠️ **توجه مهم:**\n"
-                f"جهت حفظ کیفیت خدمات و آزادسازی فضای سرور، این فایل **دقیقاً ۲ ساعت دیگر به صورت خودکار حذف خواهد شد.** ⏳"
-            )
-            
-            if status_msg_id:
-                try: await client.edit_message_text(chat_id, status_msg_id, success_text)
-                except: await client.send_message(chat_id, success_text)
-            else:
-                await client.send_message(chat_id, success_text)
-
+            link = f"https://github.com/{GITHUB_REPO}/archive/refs/heads/{branch}.zip"
+            msg = (f"🎉 **فایل شما آماده دانلود است!**\n\n📁 نام: {filename}\n🔗 لینک دانلود (اینترنت ملی):\n{link}\n\n"
+                   f"⏳ این لینک **۲ ساعت دیگر** به طور خودکار حذف می‌شود.")
+            await client.edit_message_text(chat_id, status_msg_id, msg)
     except Exception as e:
-        error_txt = f"❌ خطای گیت‌هاب:\n{str(e)[:150]}"
-        if status_msg_id:
-            try: await client.edit_message_text(chat_id, status_msg_id, error_txt)
-            except: await client.send_message(chat_id, error_txt)
+        if status_msg_id: await client.send_message(chat_id, f"❌ خطای گیت: {str(e)[:100]}")
     finally:
-        try: os.remove(file_path)
-        except: pass
-        if os.path.exists("/app/git_workspace"):
-            try: shutil.rmtree("/app/git_workspace")
-            except: pass
+        if file_path and os.path.exists(file_path): os.remove(file_path)
 
 # ==============================================================================
-# 🟢 سیستم هوشمند حذف خودکار فایل‌های منقضی شده
+# 🟢 سیستم حذف خودکار
 # ==============================================================================
-async def cleanup_expired_branches():
+async def cleanup_loop():
     while True:
         try:
             api_url = f"https://api.github.com/repos/{GITHUB_REPO}/git/refs/heads"
-            headers = {"Authorization": f"token {GITHUB_TOKEN}", "Accept": "application/vnd.github.v3+json"}
-            
-            async with aiohttp.ClientSession() as session:
-                async with session.get(api_url, headers=headers) as resp:
-                    if resp.status == 200:
-                        refs = await resp.json()
-                        current_time = int(time.time())
-                        
-                        for ref in refs:
-                            ref_name = ref.get("ref", "")
-                            if "refs/heads/DL-" in ref_name:
-                                branch_name = ref_name.split("/")[-1]
-                                parts = branch_name.split("-")
-                                
-                                if len(parts) >= 3 and parts[1].isdigit():
-                                    creation_time = int(parts[1])
-                                    if current_time - creation_time > 7200:
-                                        delete_url = f"https://api.github.com/repos/{GITHUB_REPO}/git/refs/heads/{branch_name}"
-                                        await session.delete(delete_url, headers=headers)
-                                        print(f"🗑 Branch {branch_name} automatically deleted (Expired).")
-        except Exception as e:
-            pass
+            headers = {"Authorization": f"token {GITHUB_TOKEN}"}
+            async with aiohttp.ClientSession() as sess:
+                async with sess.get(api_url, headers=headers) as r:
+                    if r.status == 200:
+                        for ref in await r.json():
+                            name = ref["ref"].split("/")[-1]
+                            if name.startswith("DL-"):
+                                try:
+                                    creation_ts = int(name.split("-")[1])
+                                    if int(time.time()) - creation_ts > 7200:
+                                        await sess.delete(f"{api_url}/{name}", headers=headers)
+                                        print(f"Deleted {name}")
+                                except: pass
+        except: pass
         await asyncio.sleep(1800)
 
-def run_cleanup_system():
-    loop = asyncio.new_event_loop()
-    asyncio.set_event_loop(loop)
-    loop.run_until_complete(cleanup_expired_branches())
-
 # ==============================================================================
-# 🟢 هندلر پیام‌های روبیکا
+# 🟢 شروع به کار
 # ==============================================================================
 @bot.on_update(filters.private)
-async def main_handler(client, update):
+async def handler(client, update):
     global BOT_GUID
-    try:
-        if not BOT_GUID:
-            me = await client.get_me()
-            if me and hasattr(me, 'user'): BOT_GUID = getattr(me.user, 'user_guid', None)
-
-        msg_obj = getattr(update, "message", None) or getattr(update, "new_message", None)
-        author_id = getattr(update, 'author_guid', None)
-        if not author_id and msg_obj: author_id = msg_obj.get('author_object_guid') if isinstance(msg_obj, dict) else getattr(msg_obj, 'author_object_guid', None)
-        if BOT_GUID and author_id == BOT_GUID: return
-        
-        chat_id = getattr(update, 'object_guid', None) or getattr(update, 'author_guid', None) or getattr(update, "chat_id", None)
-        if not chat_id: return
-        msg_id = getattr(update, "message_id", None)
-        
-        user_text = getattr(update, "text", "") or getattr(msg_obj, "text", "")
-        user_text_str = str(user_text).strip()
-        if not user_text_str: return
-
-        if user_text_str.lower() in ["/start", "سلام"]:
-            welcome_msg = (
-                "👋 سلام!\n\n"
-                "من یک ربات انتقال‌دهنده هوشمند هستم. لینک‌های زیر را پشتیبانی می‌کنم:\n\n"
-                "🌐 **لینک دانلود مستقیم** از سایت‌ها\n"
-                "✈️ **لینک پست یا عکس کانال تلگرام** (مثال: `t.me/channel/123`)\n"
-                "📸 **لینک ریلز یا پست اینستاگرام**\n\n"
-                "لینک خود را بفرستید تا با نهایت سرعت آن را روی سرور گیت‌هاب (با اینترنت ملی) برایتان آماده کنم.\n\n"
-                "⏳ **فایل‌ها جهت مدیریت سرور، دقیقاً دو ساعت بعد از ساخته‌شدن به صورت کاملاً خودکار پاک خواهند شد.**"
-            )
-            await client.send_message(chat_id, welcome_msg)
-            return
-
-        if user_text_str.lower().startswith("http"):
-            asyncio.create_task(process_and_commit_to_github(client, chat_id, msg_id, user_text_str))
-            
-    except Exception: traceback.print_exc()
+    if not BOT_GUID:
+        me = await client.get_me()
+        BOT_GUID = me.user.user_guid
+    
+    msg = getattr(update, "message", update)
+    if not msg or msg.get('author_object_guid') == BOT_GUID: return
+    
+    text = msg.get("text", "").strip()
+    if text.lower().startswith("http"):
+        asyncio.create_task(process_and_commit_to_github(client, msg.get("author_object_guid"), msg.get("message_id"), text))
+    elif text == "/start":
+        await client.send_message(msg.get("author_object_guid"), "🚀 لینک یوتیوب، اینستاگرام، تلگرام یا لینک مستقیم بفرست تا برات آماده کنم!")
 
 if __name__ == "__main__":
-    if not TG_BOT_TOKEN or TG_BOT_TOKEN == "توکن_تلگرام":
-        print("⚠️ هشدار: توکن ربات تلگرام تنظیم نشده است! دانلود از تلگرام کار نخواهد کرد.")
-        
     threading.Thread(target=run_flask, daemon=True).start()
-    threading.Thread(target=run_cleanup_system, daemon=True).start()
-    
-    print("🚀 ربات کلاستر گیت‌هاب (پشتیبانی اینستاگرام، تلگرام و وب) روشن شد...")
+    threading.Thread(target=lambda: asyncio.run(cleanup_loop()), daemon=True).start()
     bot.run()