Update bot.py

bot.py

@@ -5,13 +5,13 @@ import aiosqlite
 import time
 import shutil
 import urllib.request
-import random # 👈 تم إضافة مكتبة العشوائية
+import random
 from threading import Thread
 from http.server import BaseHTTPRequestHandler, HTTPServer
 from pyrogram import Client, filters, idle
 from pyrogram.errors import FloodWait
 from pyrogram.types import InputMediaPhoto, InputMediaVideo, InputMediaDocument, InputMediaAudio
-from pyrogram.enums import ChatAction # 👈 تم إضافة مكتبة إشارات الدردشة
+from pyrogram.enums import ChatAction
 
 # --- 1. الإعدادات الأساسية ---
 DATA_DIR = "./data"
@@ -21,7 +21,7 @@ os.makedirs(DOWNLOAD_DIR, exist_ok=True)
 
 HEALTHCHECK_URL = os.environ.get("HEALTHCHECK_URL", "")
 MAX_FILE_SIZE = 2000 * 1024 * 1024 # 2GB
-BASE_UPLOAD_DELAY = 3 # الوقت الأساسي
+BASE_UPLOAD_DELAY = 4 # زيادة الأمان الافتراضي للرفع
 
 download_queue = asyncio.Queue()
 
@@ -30,12 +30,12 @@ class RequestHandler(BaseHTTPRequestHandler):
     def do_GET(self):
         self.send_response(200)
         self.end_headers()
-        self.wfile.write(b"Live Radar Archiver Engine Active!")
+        self.wfile.write(b"Ultimate Radar Archiver Engine Active!")
     def log_message(self, format, *args): pass
 
 Thread(target=lambda: HTTPServer(('0.0.0.0', 7860), RequestHandler).serve_forever(), daemon=True).start()
 
-# --- 3. إعدادات الحساب (تمويه متقدم جداً) ---
+# --- 3. إعدادات الحساب (أعلى مستوى تمويه هاتف ذكي وبصمة حقيقية) ---
 API_ID = int(os.environ.get("API_ID", 0))
 API_HASH = os.environ.get("API_HASH", "")
 SESSION_STRING = os.environ.get("SESSION_STRING", "")
@@ -47,10 +47,11 @@ app = Client(
     api_hash=API_HASH,
     session_string=SESSION_STRING,
     in_memory=True,
-    device_model="Samsung Galaxy S23 Ultra", # جهاز حقيقي
-    system_version="Android 14.0", # نظام حديث
-    app_version="10.14.1", # إصدار تليجرام
-    lang_code="ar" # 👈 بصمة اللغة العربية لإبعاد الشبهات
+    device_model="Samsung Galaxy S23 Ultra",
+    system_version="Android 14.0",
+    app_version="10.14.1",
+    lang_code="ar",
+    system_lang_code="ar-SA"
 )
 
 # --- 4. أدوات النظام وقاعدة البيانات ---
@@ -128,7 +129,7 @@ async def download_worker_task(worker_id):
                                 (message.chat.id, message.id, unique_id, group_id, m_type, final_caption, file_path, file_size, time.time())
                             )
                             await db.commit()
-                        print(f"⚡ [Worker-{worker_id}] تم تنزيل رسالة: {message.id}")
+                        print(f"⚡ [Worker-{worker_id}] تم تنزيل رسالة بنجاح: {message.id}")
                         break
                     else:
                         if file_path and os.path.exists(file_path): os.remove(file_path)
@@ -158,28 +159,28 @@ async def status_command(client, message):
     free_mb = round(free / (1024 * 1024), 2)
     
     report = (
-        f"👑 **حالة رادار الأرشفة:**\n\n"
-        f"📥 جاهز للرفع (بالترتيب): `{pending}`\n"
-        f"📤 تم رفعه: `{uploaded}`\n"
-        f"🔄 قيد التنزيل الآن: `{download_queue.qsize()}`\n"
+        f"👑 **حالة رادار الأرشفة المحترف:**\n\n"
+        f"📥 جاهز للرفع: `{pending}`\n"
+        f"📤 تم رفعه بأمان: `{uploaded}`\n"
+        f"🔄 قيد التنزيل: `{download_queue.qsize()}`\n"
         f"💾 المساحة المتاحة: `{free_mb} MB`"
     )
     await message.reply_text(report)
 
-# --- 8. محرك الرفع الذكي (مع إشارات التمويه البشري) ---
+# --- 8. محرك الرفع الذكي العالي الأمان ---
 async def upload_worker():
     global BASE_UPLOAD_DELAY
     while True:
         try:
             async with aiosqlite.connect(DB_PATH) as db:
-                async with db.execute("SELECT id, chat_id, msg_id, media_group_id, media_type, caption, file_path, timestamp FROM queue WHERE status='DOWNLOADED' ORDER BY id ASC LIMIT 1") as cursor:
+                async with db.execute("SELECT id, chat_id, msg_id, media_group_id, media_type, caption, file_path, file_size, timestamp FROM queue WHERE status='DOWNLOADED' ORDER BY id ASC LIMIT 1") as cursor:
                     row = await cursor.fetchone()
 
             if not row:
                 await asyncio.sleep(2)
                 continue
 
-            q_id, chat_id, msg_id, group_id, m_type, caption, file_path, ts = row
+            q_id, chat_id, msg_id, group_id, m_type, caption, file_path, file_size, ts = row
 
             if not os.path.exists(file_path):
                 async with aiosqlite.connect(DB_PATH) as db:
@@ -187,18 +188,18 @@ async def upload_worker():
                     await db.commit()
                 continue
 
-            # 👈 إرسال إشارة "جاري الرفع..." للسيرفر قبل الرفع الفعلي لتمويه الذكاء الاصطناعي
+            # محاكاة إرسال حالة الكتابة أو الرفع الحقيقية
             try:
                 if m_type == "photo": await app.send_chat_action(TARGET_CHAT, ChatAction.UPLOAD_PHOTO)
-                elif m_type == "video" or m_type == "animation": await app.send_chat_action(TARGET_CHAT, ChatAction.UPLOAD_VIDEO)
+                elif m_type in ["video", "animation"]: await app.send_chat_action(TARGET_CHAT, ChatAction.UPLOAD_VIDEO)
                 elif m_type == "doc": await app.send_chat_action(TARGET_CHAT, ChatAction.UPLOAD_DOCUMENT)
-                elif m_type == "audio" or m_type == "voice": await app.send_chat_action(TARGET_CHAT, ChatAction.UPLOAD_AUDIO)
-                await asyncio.sleep(random.uniform(0.5, 1.5)) # انتظار بسيط كأن التطبيق دا يحمل
-            except: pass # تجاهل الأخطاء هنا حتى ما يوقف الرفع الأساسي
+                elif m_type in ["audio", "voice"]: await app.send_chat_action(TARGET_CHAT, ChatAction.UPLOAD_AUDIO)
+                await asyncio.sleep(random.uniform(1.0, 2.0))
+            except: pass
 
             if group_id:
                 time_passed = time.time() - ts
-                if time_passed < 8: await asyncio.sleep(8 - time_passed)
+                if time_passed < 10: await asyncio.sleep(10 - time_passed)
 
                 async with aiosqlite.connect(DB_PATH) as db:
                     async with db.execute(
@@ -235,11 +236,10 @@ async def upload_worker():
                                 if os.path.exists(f_path): os.remove(f_path)
                             
                             gc.collect()
-                            # 👈 وقت انتظار عشوائي بين الألبومات (النبض البشري)
-                            human_delay = BASE_UPLOAD_DELAY + random.uniform(1.0, 3.5)
-                            await asyncio.sleep(human_delay)
+                            await asyncio.sleep(BASE_UPLOAD_DELAY + random.uniform(2.0, 4.0))
                     continue
 
+            # رفع الملف المفرد مع ضبط الحجم الذكي (الملفات الكبيرة تأخذ وقتاً أطول للراحة)
             if m_type == "photo": await app.send_photo(TARGET_CHAT, photo=file_path, caption=caption)
             elif m_type == "video": await app.send_video(TARGET_CHAT, video=file_path, caption=caption, supports_streaming=True)
             elif m_type == "doc": await app.send_document(TARGET_CHAT, document=file_path, caption=caption)
@@ -254,24 +254,24 @@ async def upload_worker():
 
             if os.path.exists(file_path): os.remove(file_path)
             
-            if BASE_UPLOAD_DELAY > 3: BASE_UPLOAD_DELAY -= 0.1
-            gc.collect()
+            # زيادة زمن الانتظار ديناميكياً إذا كان الملف كبيراً (أكثر من 50 ميجابايت) لحماية الحساب تماماً
+            size_factor = min(file_size / (10 * 1024 * 1024), 10) # حد أقصى للإضافات
+            safe_sleep = BASE_UPLOAD_DELAY + size_factor + random.uniform(1.0, 3.0)
             
-            # 👈 وقت انتظار عشوائي بين الملفات المفردة (النبض البشري)
-            human_delay = BASE_UPLOAD_DELAY + random.uniform(0.5, 2.5)
-            await asyncio.sleep(human_delay)
+            gc.collect()
+            await asyncio.sleep(safe_sleep)
 
         except FloodWait as e:
-            print(f"⚠️ تليجرام يطلب الانتظار {e.value} ثانية... (نظام الحماية يعمل)")
-            BASE_UPLOAD_DELAY += 2
-            await asyncio.sleep(e.value + random.uniform(2, 5)) # زيادة عشوائية خفيفة بعد الحظر
+            print(f"⚠️ تليجرام فرض حماية FloodWait لمدة {e.value} ثانية. جاري التهدئة...")
+            BASE_UPLOAD_DELAY += 5 # رفع معدل الأمان للأساس
+            await asyncio.sleep(e.value + random.uniform(10, 20))
         except Exception as e:
-            print(f"⚠️ خطأ أثناء الرفع، سيتم تخطي الملف: {e}")
+            print(f"⚠️ خطأ غير متوقع، تجاوز الملف: {e}")
             async with aiosqlite.connect(DB_PATH) as db:
                 await db.execute("UPDATE queue SET status='FAILED' WHERE id=?", (q_id,))
                 await db.commit()
             if os.path.exists(file_path): os.remove(file_path)
-            await asyncio.sleep(2)
+            await asyncio.sleep(5)
 
 async def healthcheck_ping():
     while True:
@@ -284,17 +284,18 @@ async def main():
     await init_db()
     await app.start()
     
-    print("🔄 جاري تنشيط ذاكرة المحادثات لتعريف السكربت بالقنوات...")
+    print("🔄 جاري مزامنة بصمة الهاتف مع مراكز بيانات تليجرام...")
     try:
-        async for _ in app.get_dialogs(limit=300):
+        me = await app.get_me()
+        print(f"✅ تم الاتصال بنجاح بالحساب: {me.first_name} (معرف الجلسة مستقر)")
+        async for _ in app.get_dialogs(limit=150):
             pass
-        print("✅ تم تنشيط الذاكرة بنجاح وتخزين المعرفات!")
     except Exception as e:
-        pass
+        print(f"⚠️ تحذير الاتصال: {e}")
 
-    print("🚀 تم تشغيل وضع الرادار الحي! (محاكاة هاتف حقيقي فعالة 100%)")
+    print("🚀 تم تشغيل الرادار الحي بنسخة الأمان القصوى والمحاكاة التامة!")
     
-    for i in range(3):
+    for i in range(2): # تقليل عدد العمال لضمان عدم حدوث زحمة طلبات (Rate Limit)
         asyncio.create_task(download_worker_task(i + 1))
         
     asyncio.create_task(upload_worker())
@@ -309,4 +310,4 @@ if __name__ == "__main__":
             app.run(main())
         except Exception as crash_error:
             print(f"⚠️ إعادة تشغيل ذكية: {crash_error}")
-            time.sleep(5)
+            time.sleep(10)