Update bot.py

bot.py

@@ -5,7 +5,7 @@ import shutil
 import time
 import threading
 import gradio as gr
-from pyrogram import Client, filters
+from pyrogram import Client, filters, idle
 from pyrogram.errors import FloodWait, RPCError
 from pyrogram.types import InputMediaPhoto, InputMediaVideo, InputMediaDocument, InputMediaAudio
 
@@ -144,7 +144,7 @@ async def flush_media_group(chat_id, mg_id):
             except:
                 pass
 
-# ============ المعالج الرئيسي — بدون filters.channel/group ============
+# ============ المعالج الرئيسي ============
 @app.on_message(filters.incoming & ~filters.me & filters.media)
 async def on_media(client, message):
     chat_id = message.chat.id
@@ -225,15 +225,12 @@ async def monitor_all(client, message):
     if message.chat.id == TARGET_CHAT:
         return
     chat_type = message.chat.type
-    logger.info(f"👁️ رسالة من {message.chat.id} | نوع: {chat_type} | عنوان: {message.chat.title or 'بدون اسم'} | نص: {message.text or '[ملف]'}")
+    logger.info(f"👁️ رسالة واردة من {message.chat.id} | نوع: {chat_type} | عنوان: {message.chat.title or 'بدون اسم'} | نص: {message.text or '[ملف]'}")
     if message.media:
         logger.info(f"   └─ تحتوي على media: {message.media}")
 
-# ============ تشغيل البوت ============
+# ============ تشغيل البوت بـ idle() ============
 def run_bot():
-    loop = asyncio.new_event_loop()
-    asyncio.set_event_loop(loop)
-    
     async def bot_main():
         await app.start()
         me = await app.get_me()
@@ -244,8 +241,13 @@ def run_bot():
         logger.info("📡 المصدر: جميع القنوات والمجموعات")
         logger.info("=" * 50)
         
-        while True:
-            await asyncio.sleep(3600)
+        # 🔑 المفتاح: idle() يحافظ على الاتصال ويستقبل التحديثات
+        await idle()
+        
+        await app.stop()
+    
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
     
     while True:
         try: