Update bot.py

bot.py

@@ -3,8 +3,6 @@ import os
 import logging
 import random
 import sys
-from threading import Thread
-from http.server import HTTPServer, SimpleHTTPRequestHandler
 from telethon import TelegramClient
 from telethon.sessions import StringSession
 from telethon.tl.functions.channels import InviteToChannelRequest
@@ -14,26 +12,11 @@ from telethon.errors import (
     UserChannelsTooMuchError, UserAlreadyParticipantError
 )
 
-# 1. سيرفر ويب بسيط جداً لإبقاء Hugging Face يعمل
-class HealthHandler(SimpleHTTPRequestHandler):
-    def do_GET(self):
-        self.send_response(200)
-        self.send_header("Content-type", "text/html; charset=utf-8")
-        self.end_headers()
-        self.wfile.write("<h1>✅ البوت يعمل الآن في الخلفية...</h1><p>راجع سجلات الـ Logs لمتابعة التفاصيل.</p>".encode("utf-8"))
-    def log_message(self, format, *args): pass
-
-def run_health_server():
-    server = HTTPServer(("0.0.0.0", 7860), HealthHandler)
-    server.serve_forever()
-
-# تشغيل السيرفر في الخلفية
-Thread(target=run_health_server, daemon=True).start()
-
-# 2. إعدادات البوت واللوق
+# إعداد اللوق
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
 logger = logging.getLogger(__name__)
 
+# المتغيرات
 API_ID = int(os.getenv("API_ID", "0"))
 API_HASH = os.getenv("API_HASH", "")
 SESSION_STRING = os.getenv("SESSION_STRING") or os.getenv("STRING_SESSION") or ""
@@ -42,89 +25,68 @@ TARGET_CHANNEL = os.getenv("TARGET_CHANNEL", "")
 LIMIT = int(os.getenv("LIMIT", "50")) 
 BASE_DELAY = int(os.getenv("DELAY_SECONDS", "300")) 
 
-async def get_current_members(client, target_channel):
-    logger.info("🔍 جاري فحص أعضاء جروبك الحاليين...")
-    current_members = set()
-    try:
-        target = await client.get_entity(target_channel)
-        async for member in client.iter_participants(target):
-            current_members.add(member.id)
-        logger.info(f"✅ تم العثور على {len(current_members)} عضو في جروبك.")
-    except Exception as e:
-        logger.warning(f"⚠️ فشل فحص الأعضاء الحاليين: {e}")
-    return current_members
-
 async def start_transfer():
-    logger.info("🚀 بدء عملية النقل التلقائي...")
+    logger.info("🚀 بدأت المحاولة باستخدام الكود المحدث (تخطي الحظر)...")
     
-    if not SESSION_STRING:
-        logger.error("❌ خطأ: SESSION_STRING غير موجودة في الـ Secrets!")
-        return
-
     client = TelegramClient(StringSession(SESSION_STRING.strip()), API_ID, API_HASH)
     
     try:
         await client.connect()
         if not await client.is_user_authorized():
-            logger.error("❌ خطأ: الجلسة غير صالحة!")
+            logger.error("❌ الجلسة غير صالحة!")
             return
 
         source = await client.get_entity(SOURCE_CHANNEL)
         target = await client.get_entity(TARGET_CHANNEL)
         
-        # ميزة الفحص الذكي للأعضاء الموجودين
-        already_in = await get_current_members(client, TARGET_CHANNEL)
-        
-        # جلب الأعضاء للفلترة
-        participants = await client.get_participants(source, limit=LIMIT * 5)
+        # جلب الأعضاء
+        participants = await client.get_participants(source, limit=500)
         random.shuffle(participants)
         
         success, processed = 0, 0
+
         for member in participants:
             if processed >= LIMIT: break
-            
-            # فلترة: بوتات، محذوفين، أو موجودين أصلاً
-            if member.bot or member.deleted or member.id in already_in:
-                continue
-
-            # فلترة النشطين فقط
-            if not isinstance(member.status, (UserStatusOnline, UserStatusRecently)):
-                continue
+            if member.bot or member.deleted: continue
 
             processed += 1
             name = member.first_name or "User"
-            logger.info(f"[{processed}/{LIMIT}] محاولة إضافة: {name}")
+            logger.info(f"[{processed}/{LIMIT}] محاولة إجبارية لإضافة: {name}")
 
             try:
+                # محاولة الإضافة
                 await client(InviteToChannelRequest(target, [InputPeerUser(member.id, member.access_hash or 0)]))
                 success += 1
-                logger.info(f"✅ تمت إضافة {name} بنجاح.")
-                
-                delay = BASE_DELAY + random.randint(10, 60)
-                logger.info(f"⏳ انتظار {delay} ثانية...")
-                await asyncio.sleep(delay)
+                logger.info(f"✅ نجحت إضافة {name}!")
+                await asyncio.sleep(BASE_DELAY)
 
-            except FloodWaitError as e:
-                logger.warning(f"⏳ فلود من تيليجرام! انتظار {e.seconds} ثانية.")
-                await asyncio.sleep(e.seconds + 5)
             except PeerFloodError:
-                logger.error("🚨 حظر مؤقت من الإضافة. سيتوقف البوت لحماية الحساب.")
-                break
+                # 🛠 هنا التعديل: بدلاً من التوقف (Break)، سنقوم بالانتظار والتخطي (Continue)
+                logger.warning(f"🚨 تيليجرام رفض إضافة {name} (Flood). سأتخطاه وأجرب العضو التالي بعد 30 ثانية...")
+                await asyncio.sleep(30)
+                continue 
+
+            except UserAlreadyParticipantError:
+                logger.info(f"⏭ {name} موجود بالفعل.")
+            except FloodWaitError as e:
+                logger.warning(f"⏳ انتظار إجباري {e.seconds} ثانية.")
+                await asyncio.sleep(e.seconds + 2)
             except UserPrivacyRestrictedError:
-                logger.info(f"🔒 خصوصية العضو {name} تمنع إضافته.")
+                logger.info(f"🔒 خصوصية {name} تمنع الإضافة.")
             except Exception as e:
-                logger.info(f"❌ خطأ مع {name}: {type(e).__name__}")
+                logger.info(f"❌ فشل مع {name}: {type(e).__name__}")
 
-        logger.info(f"🏁 انتهى العمل. تم إضافة {success} أعضاء جدد.")
+        logger.info(f"🏁 انتهت الدورة. تم إضافة {success} أعضاء.")
 
     except Exception as e:
-        logger.error(f"❌ خطأ في النظام: {e}")
+        logger.error(f"❌ خطأ نظام: {e}")
     finally:
         await client.disconnect()
 
 if __name__ == "__main__":
-    # تشغيل البوت مباشرة
-    try:
+    # تشغيل مستمر
+    while True:
         asyncio.run(start_transfer())
-    except KeyboardInterrupt:
-        pass
+        logger.info("💤 انتظار 10 دقائق قبل دورة عشوائية جديدة...")
+        import time
+        time.sleep(600)