Update bot.py

bot.py

@@ -9,6 +9,13 @@ from pyrogram import Client, filters
 from pyrogram.errors import FloodWait, RPCError
 from pyrogram.types import InputMediaPhoto, InputMediaVideo, InputMediaDocument, InputMediaAudio
 
+# ============ إصلاح MIN_CHANNEL_ID في Pyrogram ============
+# القنوات الجديدة لها معرفات < -1002147483647
+# المصدر: https://github.com/pyrogram/pyrogram/pull/1430
+import pyrogram
+pyrogram.utils.MIN_CHANNEL_ID = -1007852516352
+pyrogram.utils.MIN_CHAT_ID = -999999999999
+
 logging.basicConfig(
     level=logging.INFO,
     format='%(asctime)s - %(levelname)s - %(message)s'
@@ -38,26 +45,27 @@ app = Client(
     lang_code="ar"
 )
 
-# متغير عام للقناة الهدف الفعلية (قد تتغير بعد التحقق)
 TARGET_CHAT = None
 
-# ============ معرفة نوع الملف ============
+# ============ معرفة نوع الملف + الامتداد ============
 def get_media_info(message):
     if message.photo:
-        return "photo", message.photo.file_size or 0
+        return "photo", ".jpg"
     elif message.video:
-        return "video", message.video.file_size or 0
+        return "video", ".mp4"
     elif message.document:
-        return "doc", message.document.file_size or 0
+        ext = os.path.splitext(message.document.file_name or "")[1] or ""
+        return "doc", ext
     elif message.audio:
-        return "audio", message.audio.file_size or 0
+        ext = os.path.splitext(message.audio.file_name or "")[1] or ".mp3"
+        return "audio", ext
     elif message.voice:
-        return "voice", message.voice.file_size or 0
+        return "voice", ".ogg"
     elif message.video_note:
-        return "video_note", message.video_note.file_size or 0
+        return "video_note", ".mp4"
     elif message.animation:
-        return "animation", message.animation.file_size or 0
-    return None, 0
+        return "animation", ".mp4"
+    return None, ""
 
 # ============ اسم المصدر ============
 def get_source_name(message):
@@ -89,7 +97,7 @@ async def flush_media_group(chat_id, mg_id):
     
     downloaded = []
     for i, msg in enumerate(messages):
-        m_type, fsize = get_media_info(msg)
+        m_type, ext = get_media_info(msg)
         if not m_type:
             continue
         
@@ -98,10 +106,11 @@ async def flush_media_group(chat_id, mg_id):
         final_cap = f"{cap}\n\n📌 المصدر: {src_name}".strip() if cap else f"📌 المصدر: {src_name}"
         
         try:
-            file_path = await msg.download(file_name=f"{DOWNLOAD_DIR}/{chat_id}_{msg.id}_")
+            # 🔑 إضافة الامتداد لتجنب PHOTO_EXT_INVALID
+            file_path = await msg.download(file_name=f"{DOWNLOAD_DIR}/{chat_id}_{msg.id}{ext}")
             if file_path and os.path.exists(file_path) and os.path.getsize(file_path) > 0:
                 downloaded.append((m_type, file_path, final_cap))
-                logger.info(f"⬇️ تم التنزيل: {msg.id}")
+                logger.info(f"⬇️ تم التنزيل: {msg.id} -> {os.path.basename(file_path)}")
             else:
                 logger.warning(f"⚠️ فشل تنزيل: {msg.id}")
         except Exception as e:
@@ -174,16 +183,18 @@ async def on_media(client, message):
             media_groups[key].append(message)
         return
     
-    m_type, fsize = get_media_info(message)
+    m_type, ext = get_media_info(message)
     if not m_type:
         return
     
+    src_name = get_source_name(message)
     raw_cap = message.caption or ""
     final_cap = f"{raw_cap}\n\n📌 المصدر: {src_name}".strip() if raw_cap else f"📌 المصدر: {src_name}"
     
     file_path = None
     try:
-        file_path = await message.download(file_name=f"{DOWNLOAD_DIR}/{chat_id}_{message.id}_")
+        # 🔑 إضافة الامتداد لتجنب PHOTO_EXT_INVALID
+        file_path = await message.download(file_name=f"{DOWNLOAD_DIR}/{chat_id}_{message.id}{ext}")
         if not file_path or not os.path.exists(file_path) or os.path.getsize(file_path) == 0:
             logger.warning(f"⚠️ فشل تنزيل الرسالة {message.id}")
             return
@@ -239,7 +250,6 @@ async def resolve_target_chat():
         return
     
     try:
-        # جرب كـ integer أولاً
         chat_id_int = int(raw)
         chat = await app.get_chat(chat_id_int)
         TARGET_CHAT = chat_id_int
@@ -269,10 +279,7 @@ def run_gradio():
         | `API_ID` | رقم | `12345678` |
         | `API_HASH` | نص | `abc123...` |
         | `SESSION_STRING` | نص | `BQAD...` |
-        | `TARGET_CHAT` | معرف القناة الخاصة | `-1001234567890` |
-        
-        ### ⚠️ ملاحظة مهمة للقنوات الخاصة:
-        الحساب لازم يكون **عضو** في القناة الخاصة. إذا فشل التحقق، يرسل إلى Saved Messages.
+        | `TARGET_CHAT` | معرف القناة الخاصة | `-1004307601544` |
         """)
     
     demo.launch(server_name="0.0.0.0", server_port=7860)
@@ -282,7 +289,6 @@ async def main():
     await app.start()
     me = await app.get_me()
     
-    # 🔑 التحقق من القناة الهدف
     await resolve_target_chat()
     
     logger.info("=" * 50)