| import asyncio |
| import os |
| import logging |
| import random |
| import sys |
| from threading import Thread |
| from http.server import HTTPServer, SimpleHTTPRequestHandler |
| from pyrogram import Client, errors, types, enums |
|
|
| |
| logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(message)s') |
| logger = logging.getLogger(__name__) |
|
|
| |
| API_ID = int(os.getenv("API_ID", "33236310")) |
| API_HASH = os.getenv("API_HASH", "d8b1097f2d17f2e30d7f82d538071726") |
| SESSION_STRING = os.getenv("SESSION_STRING") or os.getenv("STRING_SESSION") or "" |
| TARGET_CHANNEL = os.getenv("TARGET_CHANNEL", "") |
| KEYWORDS = ["دردشة", "شات", "قروب", "سوالف", "تعارف", "شباب", "بنات", "العاب", "تداول", "عملات", "بينانس", "ضحك"] |
|
|
| PROCESSED_USERS = set() |
| VISITED_GROUPS = set() |
|
|
| |
| Thread(target=lambda: HTTPServer(("0.0.0.0", 7860), SimpleHTTPRequestHandler).serve_forever(), daemon=True).start() |
|
|
| async def sync_contacts(app): |
| """مزامنة الأرقام من ملف contacts.txt""" |
| if os.path.exists("contacts.txt"): |
| try: |
| with open("contacts.txt", "r") as f: |
| phones = [line.strip() for line in f if line.strip()] |
| if phones: |
| sample = random.sample(phones, min(15, len(phones))) |
| logger.info(f"📡 مزامنة {len(sample)} رقم جديد من ملفك...") |
| contacts = [types.InputPhoneContact(phone=p, first_name=f"User_{random.randint(1,999)}") for p in sample] |
| await app.import_contacts(contacts) |
| except: pass |
|
|
| async def find_and_hunt(app): |
| """البحث عن جروبات عشوائية وصيد المتفاعلين""" |
| word = random.choice(KEYWORDS) |
| try: |
| |
| search_results = await app.get_inline_bot_results("google", word) |
| |
| async for dialog in app.get_chat_history("me", limit=1): |
| pass |
| |
| |
| target_hunt = f"@{word}" |
| chat = await app.join_chat(target_hunt) |
| VISITED_GROUPS.add(chat.id) |
| logger.info(f"✅ تم اقتحام جروب: {chat.title}") |
| |
| hunted = [] |
| async for message in app.get_chat_history(chat.id, limit=100): |
| if message.from_user and not message.from_user.is_bot: |
| if message.from_user.id not in PROCESSED_USERS: |
| hunted.append(message.from_user) |
| |
| await app.leave_chat(chat.id) |
| return hunted |
| except: return [] |
|
|
| async def start_attack(): |
| app = Client( |
| "beast_final", |
| api_id=API_ID, api_hash=API_HASH, |
| session_string=SESSION_STRING.strip(), |
| device_model="Samsung Galaxy S24 Ultra", |
| system_version="Android 14", |
| app_version="10.11.1", |
| in_memory=True |
| ) |
|
|
| try: |
| await app.start() |
| logger.info("💀 تم إطلاق الوحش بنظام Pyrogram وبصمة سامسونج!") |
|
|
| while True: |
| try: |
| await sync_contacts(app) |
| |
| |
| targets = [] |
| |
| contacts = await app.get_contacts() |
| targets.extend([c for c in contacts if c.id not in PROCESSED_USERS]) |
| |
| |
| hunted_users = await find_and_hunt(app) |
| targets.extend(hunted_users) |
|
|
| random.shuffle(targets) |
| logger.info(f"🎯 تم حشد {len(targets)} ضحية للهجوم...") |
|
|
| for user in targets: |
| if user.id in PROCESSED_USERS: continue |
| PROCESSED_USERS.add(user.id) |
| name = getattr(user, 'first_name', 'User') |
|
|
| try: |
| |
| await app.add_chat_members(TARGET_CHANNEL, user.id) |
| logger.info(f"✅ حشر مباشر: {name}") |
| await asyncio.sleep(random.randint(10, 20)) |
|
|
| except (errors.UserPrivacyRestricted, errors.PeerFlood, errors.FloodWait): |
| |
| try: |
| msg = f"أهلاً {name}! 👋\nندعوك للانضمام لأكبر تجمع متفاعل من هنا:\nhttps://t.me/{TARGET_CHANNEL}" |
| await app.send_message(user.id, msg) |
| logger.info(f"📨 قصف خاص لـ {name}") |
| await asyncio.sleep(random.randint(10, 20)) |
| except: continue |
| except: continue |
|
|
| logger.info("🔄 تبريد المحرك ...") |
| await asyncio.sleep(30) |
|
|
| except Exception as e: |
| logger.error(f"💥 خطأ دورة: {e}") |
| await asyncio.sleep(30) |
| finally: |
| await app.stop() |
|
|
| if __name__ == "__main__": |
| asyncio.run(start_attack()) |
