Update bot.py

bot.py

@@ -5,170 +5,120 @@ import random
 import json
 from threading import Thread
 from http.server import HTTPServer, SimpleHTTPRequestHandler
-from telethon import TelegramClient
+from telethon import TelegramClient, functions, types
 from telethon.sessions import StringSession
 from telethon.tl.functions.channels import InviteToChannelRequest
-from telethon.tl.functions.messages import ExportChatInviteRequest
-from telethon.tl.functions.account import UpdateStatusRequest
-from telethon.tl.types import InputPeerUser
+from telethon.tl.functions.messages import ExportChatInviteRequest, SendScreenshotNotificationRequest
+from telethon.tl.types import InputPeerUser, UserStatusOnline
 from telethon.errors import *
 
+# إعداد اللوق
 logging.basicConfig(level=logging.INFO, format='%(asctime)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 ""
 SOURCE_CHANNEL = os.getenv("SOURCE_CHANNEL", "")
 TARGET_CHANNEL = os.getenv("TARGET_CHANNEL", "")
 
-def run_server():
-    HTTPServer(("0.0.0.0", 7860), SimpleHTTPRequestHandler).serve_forever()
-Thread(target=run_server, daemon=True).start()
+# جسر الحماية
+Thread(target=lambda: HTTPServer(("0.0.0.0", 7860), SimpleHTTPRequestHandler).serve_forever(), daemon=True).start()
 
-# 🧠 الذاكرة والمخزن
 def load_blacklist():
-    if os.path.exists('blacklist.txt'):
-        with open('blacklist.txt', 'r') as f:
-            return set(line.strip() for line in f if line.strip())
+    if os.path.exists('blacklist.json'):
+        try:
+            with open('blacklist.json', 'r') as f: return set(json.load(f))
+        except: return set()
     return set()
 
-def save_to_blacklist(user_id):
-    with open('blacklist.txt', 'a') as f:
-        f.write(f"{user_id}\n")
+def save_to_blacklist(blacklist):
+    with open('blacklist.json', 'w') as f: json.dump(list(blacklist), f)
 
-# 🗣️ Spintax بشري جداً
-def get_random_message(name, invite_link):
-    greetings = ["هلا", "مرحبا", "أهلين", "يا هلا", "عساك بخير"]
-    intros = [
-        f"{name} شفتك مهتم بنفس مجالنا",
-        f"شفت تفاعلك قلت أكيد بيهمك هالجروب يا {name}",
-        "جروبنا بيفيدك جداً",
-        f"يا {name} أتمنى تنورنا بوجودك"
+def get_smart_message(name, link):
+    templates = [
+        f"أهلاً {name} ✨\nوجدت اهتمامك المشترك بمجالنا، يسعدنا انضمامك لأسرتنا هنا: {link}",
+        f"السلام عليكم يا {name} 👋\nندعوك لتكون جزءاً من مجتمعنا المتفاعل والمفيد: {link}",
+        f"يا هلا {name}.. شفتك متواجد بجروبات مشابهة، حياك الله معنا: {link}",
+        f"نتشرف بوجودك {name} في مجموعتنا الرسمية، انضم الآن: {link}"
     ]
-    
-    # 20% احتمال يرسل رسالة "بشرية" عشوائية فيها خطأ مطبعي متعمد لتجاوز السبام
-    if random.random() < 0.2:
-        return f"{random.choice(greetings)} {name}.. \nرابط الجروب اهوا:\n{invite_link}"
-        
-    return f"{random.choice(greetings)}\n{random.choice(intros)}\nتفضل الرابط:\n{invite_link}"
-
-async def simulate_human_activity(client):
-    """حركة ذكية لتمويه تيليجرام بأن المستخدم يقرأ ويتصفح التطبيق"""
-    try:
-        # إرسال حالة "أونلاين"
-        await client(UpdateStatusRequest(offline=False))
-        # انتظار كأن الشخص يقرأ الشاشة
-        await asyncio.sleep(random.randint(1, 3))
-    except:
-        pass
+    return random.choice(templates)
 
-async def brute_force():
-    logger.info("😈 بدء النسخة الإمبراطورية v3 (محاكاة بشرية، تخزين ذكي)...")
+async def cyclone_attack():
     client = TelegramClient(StringSession(SESSION_STRING.strip()), API_ID, API_HASH)
-    
     try:
         await client.connect()
-        if not await client.is_user_authorized():
-            logger.error("❌ الجلسة ماتت!")
-            return
+        if not await client.is_user_authorized(): return
 
-        source = await client.get_entity(SOURCE_CHANNEL)
-        target = await client.get_entity(TARGET_CHANNEL)
-        
+        # 1. تجهيز الرابط والهدف
+        target_entity = await client.get_entity(TARGET_CHANNEL)
         try:
-            invite = await client(ExportChatInviteRequest(peer=target))
+            invite = await client(ExportChatInviteRequest(peer=target_entity))
             invite_link = invite.link
-        except Exception:
-            invite_link = f"https://t.me/{TARGET_CHANNEL}"
-        
+        except: invite_link = f"https://t.me/{TARGET_CHANNEL}"
+
         blacklist = load_blacklist()
+        source = await client.get_entity(SOURCE_CHANNEL)
         
-        # 🛡️ نظام حفظ الضحايا في ملف JSON لعدم سحبهم كل مرة من تيليجرام
-        victims_file = "victims.json"
-        valid_members = []
-        
-        if os.path.exists(victims_file):
-            with open(victims_file, 'r') as f:
-                saved_data = json.load(f)
-                # استخراج فقط من ليس في البلاك لست
-                valid_members = [m for m in saved_data if str(m['id']) not in blacklist]
-            logger.info(f"📂 تم تحميل {len(valid_members)} ضحية من المخزن المحلي (بدون استهلاك API تيليجرام!)")
-        
-        if not valid_members:
-            logger.info("📡 جاري سحب القائمة الكاملة لأول مرة...")
-            members = await client.get_participants(source, limit=10000)
-            valid_members = [{'id': m.id, 'access_hash': getattr(m, 'access_hash', 0), 'first_name': m.first_name} 
-                             for m in members if not m.bot and not m.deleted and str(m.id) not in blacklist]
-            
-            with open(victims_file, 'w') as f:
-                json.dump(valid_members, f)
-            logger.info(f"✅ تم حفظ {len(valid_members)} ضحية في المخزن المحلي. لن نطلبهم من تيليجرام مجدداً!")
-        
+        # 2. سحب قائمة ضخمة
+        logger.info(f"📡 جاري سحب وتصفية الأعضاء من {SOURCE_CHANNEL}...")
+        participants = await client.get_participants(source, limit=5000)
+        valid_members = [m for m in participants if not m.bot and not m.deleted and str(m.id) not in blacklist]
         random.shuffle(valid_members)
-        success_add, success_msg = 0, 0
-        
-        for m_data in valid_members:
-            name = m_data['first_name'] or "صديقي"
-            str_id = str(m_data['id'])
-            
-            # محاكاة السلوك البشري قبل أي حركة!
-            await simulate_human_activity(client)
 
+        logger.info(f"🌪️ تم تجهيز إعصار لـ {len(valid_members)} عضو.")
+
+        added, messaged = 0, 0
+        for member in valid_members:
+            if added + messaged >= 500: break # حد الدورة الواحدة
+            
+            name = member.first_name or "صديقي"
+            str_id = str(member.id)
+            
             try:
-                # 1. الحشر (الإضافة)
-                peer = InputPeerUser(user_id=m_data['id'], access_hash=m_data['access_hash'])
-                await client(InviteToChannelRequest(target, [peer]))
-                success_add += 1
-                logger.info(f"✅ تم الحشر: {name}")
-                save_to_blacklist(str_id)
-                await asyncio.sleep(random.randint(18, 30))
+                # 🟡 حركة ذكية 1: إظهار أنك "أونلاين"
+                await client(functions.account.UpdateStatusRequest(offline=False))
 
-            except UserAlreadyParticipantError:
-                save_to_blacklist(str_id)
-                continue
+                # محاولة الإضافة
+                await client(InviteToChannelRequest(target_entity, [InputPeerUser(member.id, member.access_hash)]))
+                added += 1
+                logger.info(f"✅ حشر مباشر: {name}")
+                blacklist.add(str_id)
+                await asyncio.sleep(random.randint(15, 25))
 
-            except (PeerFloodError, UserPrivacyRestrictedError, FloodWaitError) as e:
-                if isinstance(e, FloodWaitError) and e.seconds > 60:
-                    logger.warning(f"⏳ حظر إضافة. تحويل {name} للخاص...")
-                else:
-                    logger.warning(f"🛡️ حماية أو خصوصية. تحويل {name} للخاص...")
-                
+            except (PeerFloodError, UserPrivacyRestrictedError, FloodWaitError):
+                # 🔵 الخطة البديلة: المراسلة الاحترافية
                 try:
-                    # 2. القصف (المراسلة)
-                    msg_text = get_random_message(name, invite_link)
+                    # 🟢 حركة ذكية 2: إظهار أنك "تكتب الآن"
+                    async with client.action(member.id, 'typing'):
+                        await asyncio.sleep(3) # محاكاة وقت الكتابة
                     
-                    # محاكاة "Typing..." قبل الإرسال! خدعة روسية قوية جداً
-                    async with client.action(m_data['id'], 'typing'):
-                        await asyncio.sleep(random.randint(2, 4))
+                    # 🟣 حركة ذكية 3: قراءة محادثة العضو (Seen)
+                    await client(functions.messages.ReadHistoryRequest(peer=member.id, max_id=0))
                     
-                    await client.send_message(m_data['id'], msg_text)
-                    success_msg += 1
-                    logger.info(f"📨 تم قصف {name} بالخاص!")
-                    save_to_blacklist(str_id)
-                    await asyncio.sleep(random.randint(18, 30))
-                    
-                except FloodWaitError as e_msg:
-                    if e_msg.seconds > 60:
-                        logger.warning("⚠️ حظر رسائل. تخطي!")
-                        await asyncio.sleep(3)
-                        continue
-                    await asyncio.sleep(e_msg.seconds + 1)
-                except Exception:
-                    continue
-            except Exception:
-                continue
-
-            total_processed = success_add + success_msg
-            if total_processed > 0 and total_processed % 30 == 0:
-                logger.info("🔄 تمت معالجة 30 شخص. أخذ استراحة لتمويه خوارزمية تيليجرام (3 دقائق)...")
-                await asyncio.sleep(180)
+                    msg = get_smart_message(name, invite_link)
+                    await client.send_message(member.id, msg)
+                    messaged += 1
+                    logger.info(f"📨 قصف ذكي (بعد الكتابة والسين): {name}")
+                    blacklist.add(str_id)
+                    await asyncio.sleep(random.randint(20, 40))
+                except: continue
+            
+            except Exception: continue
+            
+            # حفظ الذاكرة دورياً
+            if (added + messaged) % 10 == 0: save_to_blacklist(blacklist)
 
-    except Exception as e:
-        logger.error(f"❌ خطأ: {e}")
     finally:
-        logger.info(f"📊 الخلاصة: إضافة {success_add} | مراسلة {success_msg}")
+        save_to_blacklist(blacklist)
         await client.disconnect()
 
 if __name__ == "__main__":
-    asyncio.run(brute_force())
+    while True:
+        try:
+            asyncio.run(cyclone_attack())
+            logger.info("😴 استراحة إعصارية لمدة 10 دقائق...")
+            import time
+            time.sleep(600)
+        except Exception: import time; time.sleep(30)