Update bot.py

bot.py

@@ -1,12 +1,14 @@
 import os
 import asyncio
 import sqlite3
+from threading import Thread
+from http.server import BaseHTTPRequestHandler, HTTPServer
 from pyrogram import Client, filters, idle
 from pyrogram.errors import FloodWait
 from pyrogram.enums import ChatType
 
-# --- 1. إعداد مساحات التخزين وقاعدة البيانات ---
-DATA_DIR = "/data"
+# --- 1. إعداد مساحات التخزين (متوافق مع Hugging Face) ---
+DATA_DIR = "./data" # استخدام مسار محلي داخل الـ Space
 DOWNLOAD_DIR = os.path.join(DATA_DIR, "downloads")
 DB_PATH = os.path.join(DATA_DIR, 'bot_memory.db')
 os.makedirs(DOWNLOAD_DIR, exist_ok=True)
@@ -24,30 +26,40 @@ def mark_processed(chat_id, msg_id):
     cursor.execute("INSERT OR IGNORE INTO processed VALUES (?, ?)", (chat_id, msg_id))
     conn.commit()
 
-# --- 2. إعدادات الحساب ---
+# --- 2. سيرفر الويب الوهمي (لمنع Hugging Face من إغلاق البوت) ---
+class RequestHandler(BaseHTTPRequestHandler):
+    def do_GET(self):
+        self.send_response(200)
+        self.end_headers()
+        self.wfile.write(b"Hugging Face Bot is Running Perfectly!")
+    def log_message(self, format, *args): pass
+
+# تشغيل السيرفر على المنفذ 7860 المطلوب من HF
+Thread(target=lambda: HTTPServer(('0.0.0.0', 7860), RequestHandler).serve_forever(), daemon=True).start()
+
+# --- 3. إعدادات الحساب ---
 API_ID = int(os.environ.get("API_ID", 0))
 API_HASH = os.environ.get("API_HASH", "")
 SESSION_STRING = os.environ.get("SESSION_STRING", "")
 TARGET_CHAT = int(os.environ.get("TARGET_CHAT", 0))
 
-# تقليل العمال لتجنب استفزاز رادار تيليجرام
 app = Client(
     "restricted_bypass_bot", 
     api_id=API_ID, 
     api_hash=API_HASH, 
     session_string=SESSION_STRING,
-    max_concurrent_transmissions=2 
+    max_concurrent_transmissions=1 # تقليل الضغط على سيرفرات تيليجرام
 )
 
 process_queue = asyncio.Queue()
 
-# --- 3. صائد الرسائل الجديدة ---
+# --- 4. صائد الرسائل الجديدة ---
 @app.on_message(filters.incoming & ~filters.me & (filters.channel | filters.group) & filters.media)
 async def catch_new_messages(client, message):
     if not is_processed(message.chat.id, message.id):
         await process_queue.put(message)
 
-# --- 4. حاصد الأرشيف القديم (لكل القنوات المشترك بها) ---
+# --- 5. حاصد الأرشيف القديم (مبطأ لتجنب FloodWait) ---
 async def scan_old_history():
     print("🔎 [جيمي] بدء مسح أرشيف القنوات والمجموعات...")
     try:
@@ -58,20 +70,19 @@ async def scan_old_history():
                     async for message in app.get_chat_history(dialog.chat.id):
                         if message.media and not is_processed(message.chat.id, message.id):
                             await process_queue.put(message)
-                except Exception as e:
-                    print(f"⚠️ تجاوز {dialog.chat.title} بسبب خطأ: {e}")
+                except Exception:
+                    pass
                 
-                await asyncio.sleep(3) # فاصل بين فحص كل قناة وأخرى
+                # زيادة الفاصل الزمني إلى 7 ثوانٍ لمنع GetHistory FloodWait
+                await asyncio.sleep(7) 
         print("✅ اكتمل سحب كافة الرسائل المفقودة إلى الطابور!")
     except Exception as e:
         print(f"❌ خطأ عام بالمسح: {e}")
 
-# --- 5. محرك الكسر والرفع (العملية المتسلسلة) ---
+# --- 6. محرك الكسر والرفع (للقنوات المقفلة) ---
 async def restricted_bypass_worker():
     while True:
         message = await process_queue.get()
-        
-        # تجنب معالجة ما تم إنجازه
         if is_processed(message.chat.id, message.id):
             process_queue.task_done()
             continue
@@ -79,18 +90,14 @@ async def restricted_bypass_worker():
         file_path = None
         try:
             print(f"⬇️ جاري سحب الملف (ID: {message.id}) من قناة مقفلة...")
-            
-            # خطوة 1: التحميل الفعلي
             file_path = await message.download(file_name=f"{DOWNLOAD_DIR}/")
             
             if not file_path:
-                print("⚠️ فشل التحميل، سيتم التخطي.")
                 continue
 
             print(f"⬆️ جاري الرفع إلى قناتك...")
-            
-            # خطوة 2: الرفع الفعلي
             caption = message.caption or ""
+            
             if message.photo:
                 await app.send_photo(TARGET_CHAT, photo=file_path, caption=caption)
             elif message.video:
@@ -98,26 +105,21 @@ async def restricted_bypass_worker():
             elif message.document:
                 await app.send_document(TARGET_CHAT, document=file_path, caption=caption)
             else:
-                await app.send_audio(TARGET_CHAT, audio=file_path, caption=caption) # للأنواع الأخرى
+                await app.send_audio(TARGET_CHAT, audio=file_path, caption=caption)
                 
-            # خطوة 3: التوثيق في قاعدة البيانات
             mark_processed(message.chat.id, message.id)
             print(f"✅ تم النقل بنجاح!")
-            
-            # خطوة 4: الفاصل الزمني الإجباري (لا تقم بتعديله، فهو درع الحماية من الحظر)
-            print("⏳ استراحة أمنية لمدة 12 ثانية...")
-            await asyncio.sleep(12) 
+            await asyncio.sleep(15) # استراحة إجبارية
 
         except FloodWait as e:
-            print(f"🛑 [تحذير الحظر] تيليجرام يطلب التوقف لمدة {e.value} ثانية! سنطيع الأمر.")
+            print(f"🛑 تيليجرام يطلب التوقف لمدة {e.value} ثانية! سنطيع الأمر.")
             await asyncio.sleep(e.value + 5)
-            await process_queue.put(message) # إعادة إدراج الرسالة كي لا تضيع
+            await process_queue.put(message)
             
         except Exception as e:
             print(f"❌ خطأ أثناء معالجة الملف: {e}")
             
         finally:
-            # خطوة 5: حذف الملف فوراً لتجنب امتلاء السيرفر
             if file_path and os.path.exists(file_path):
                 try:
                     os.remove(file_path)
@@ -125,15 +127,12 @@ async def restricted_bypass_worker():
                     pass
             process_queue.task_done()
 
-# --- 6. التشغيل ---
+# --- 7. التشغيل ---
 async def main():
     await app.start()
-    print("🚀 محرك اختراق القنوات المقفلة يعمل الآن بثبات!")
+    print("🚀 البوت يعمل الآن بكفاءة على Hugging Face!")
     
-    # عامل رفع واحد فقط لضمان الترتيب وعدم الضغط على سيرفر تيليجرام
     asyncio.create_task(restricted_bypass_worker())
-    
-    # تشغيل ماسح الأرشيف لجلب الفيديوهات القديمة
     asyncio.create_task(scan_old_history())
     
     await idle()