Update bot.py

bot.py

@@ -1,108 +1,129 @@
 import asyncio
 import os
 import logging
-import random
-import sys
-from threading import Thread
-from http.server import HTTPServer, SimpleHTTPRequestHandler
-from telethon import TelegramClient, functions
+import gradio as gr
+from telethon import TelegramClient
 from telethon.sessions import StringSession
 from telethon.tl.functions.channels import InviteToChannelRequest
-from telethon.tl.types import InputPeerUser, UserStatusRecently, UserStatusOnline
+from telethon.tl.types import InputPeerUser
 from telethon.errors import (
-    FloodWaitError, UserPrivacyRestrictedError, PeerFloodError,
-    UserChannelsTooMuchError, UserAlreadyParticipantError
+    FloodWaitError,
+    UserPrivacyRestrictedError,
+    PeerFloodError,
+    UserAlreadyParticipantError,
+    UserChannelsTooMuchError
 )
 
-# --- الجسر لإبقاء البوت حياً ---
-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>".encode("utf-8"))
-    def log_message(self, format, *args): pass
+# إعداد اللوق
+logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(message)s')
+logger = logging.getLogger(__name__)
 
-Thread(target=lambda: HTTPServer(("0.0.0.0", 7860), HealthHandler).serve_forever(), daemon=True).start()
+log_history = []
 
-# --- إعداد اللوق ---
-logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
-logger = logging.getLogger(__name__)
+def ui_print(msg):
+    logger.info(msg)
+    log_history.append(msg)
+    if len(log_history) > 40:
+        log_history.pop(0)
 
-# --- المتغيرات ---
+# المتغيرات السريّة (Secrets)
 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 ""
+SESSION_STRING = os.getenv("SESSION_STRING", "")
 SOURCE_CHANNEL = os.getenv("SOURCE_CHANNEL", "")
 TARGET_CHANNEL = os.getenv("TARGET_CHANNEL", "")
-INVITE_LINK = os.getenv("INVITE_LINK", f"https://t.me/{TARGET_CHANNEL}") # رابط الدعوة
-LIMIT = int(os.getenv("LIMIT", "50"))
-BASE_DELAY = int(os.getenv("DELAY_SECONDS", "300"))
 
-# رسالة الدعوة التي ستصل للأعضاء
-MESSAGE_TEXT = f"مرحباً بك! 👋\nلقد تمت دعوتك للانضمام إلى مجموعتنا المميزة. يشرفنا انضمامك عبر الرابط التالي:\n\n{INVITE_LINK}"
+# 🚀 وضع الهجوم: سحب عدد ضخم والانتظار 5 ثواني فقط!
+LIMIT = 200 
+AGGRESSIVE_DELAY = 5  
 
-async def main():
-    client = TelegramClient(StringSession(SESSION_STRING.strip()), API_ID, API_HASH)
-    try:
-        await client.connect()
-        if not await client.is_user_authorized():
-            logger.error("❌ الجلسة غير صالحة!")
-            return
+client = TelegramClient(StringSession(SESSION_STRING.strip()), API_ID, API_HASH)
+
+async def aggressive_transfer():
+    log_history.clear()
+    ui_print("🔥 بدء وضع الرشق الهجومي (بدون فلترة، سرعة قصوى)...")
+    
+    await client.connect()
+    if not await client.is_user_authorized():
+        ui_print("❌ الجلسة غير صالحة!")
+        await client.disconnect()
+        return
 
+    try:
         source = await client.get_entity(SOURCE_CHANNEL)
         target = await client.get_entity(TARGET_CHANNEL)
-        
-        participants = await client.get_participants(source, limit=LIMIT * 2)
-        random.shuffle(participants)
-        
-        success_add = 0
-        success_msg = 0
-
-        for member in participants:
-            if (success_add + success_msg) >= LIMIT: break
-            if member.bot or member.deleted: continue
-
-            name = member.first_name or "مستخدم"
+    except Exception as e:
+        ui_print(f"❌ خطأ في القنوات: {e}")
+        await client.disconnect()
+        return
+
+    try:
+        ui_print("👥 جاري جلب كمية ضخمة من الأعضاء...")
+        # جلب عدد كبير جداً بدون الاهتمام لحالتهم
+        participants = await client.get_participants(source, limit=1000)
+    except Exception as e:
+        ui_print(f"❌ خطأ في جلب الأعضاء: {e}")
+        await client.disconnect()
+        return
+
+    success = 0
+    processed = 0
+
+    for member in participants:
+        if success >= LIMIT:
+            ui_print("🎯 وصلنا للحد المطلوب لهذه الدورة.")
+            break
             
-            try:
-                # 1. محاولة الإضافة المباشرة أولاً
-                logger.info(f"📩 محاولة إضافة: {name}...")
-                await client(InviteToChannelRequest(target, [InputPeerUser(member.id, member.access_hash or 0)]))
-                success_add += 1
-                logger.info(f"✅ تمت إضافة {name} مباشرة!")
-                
-            except (UserPrivacyRestrictedError, PeerFloodError, UserChannelsTooMuchError):
-                # 2. إذا فشلت الإضافة، نرسل رسالة خاصة (الدعوة)
-                try:
-                    logger.info(f"✉️ الإضافة مقيدة. إرسال دعوة خاصة لـ {name}...")
-                    await client.send_message(member.id, MESSAGE_TEXT)
-                    success_msg += 1
-                    logger.info(f"✅ تم إرسال الدعوة بنجاح لـ {name}")
-                except Exception as e:
-                    logger.info(f"❌ فشل إرسال الرسالة أيضاً: {type(e).__name__}")
+        if member.bot or member.deleted: 
+            continue
+
+        processed += 1
+        name = member.first_name or "مجهول"
+
+        try:
+            # إضافة سريعة مباشرة
+            user_to_add = InputPeerUser(user_id=member.id, access_hash=member.access_hash or 0)
+            await client(InviteToChannelRequest(channel=target, users=[user_to_add]))
             
-            except UserAlreadyParticipantError:
-                continue
-            except FloodWaitError as e:
-                logger.warning(f"⏳ فلود! انتظار {e.seconds} ثانية.")
-                await asyncio.sleep(e.seconds + 5)
-            except Exception as e:
-                logger.info(f"❌ خطأ غير متوقع مع {name}: {type(e).__name__}")
-
-            # انتظار بين العمليات
-            wait = BASE_DELAY + random.randint(10, 30)
-            logger.info(f"⏳ انتظار {wait} ثانية...")
-            await asyncio.sleep(wait)
-
-        logger.info(f"🏁 انتهى: مضافين ({success_add}) | مرسل لهم دعوات ({success_msg})")
-
-    finally:
-        await client.disconnect()
+            success += 1
+            ui_print(f"[{processed}] ✅ رشق ناجح: {name}")
+            
+            # انتظار قصير جداً (5 ثواني) لزيادة العدد بسرعة قبل الحظر
+            await asyncio.sleep(AGGRESSIVE_DELAY)
+
+        except PeerFloodError:
+            ui_print(f"🚨 فلود! تيليجرام يحاول إيقافنا. تخطي سريع لـ {name}...")
+            await asyncio.sleep(2) # لا ننتظر كثيراً، نهجم على اللي بعده
+            continue
+        except UserAlreadyParticipantError:
+            pass # تخطي صامت
+        except UserPrivacyRestrictedError:
+            pass # تخطي صامت لتسريع العملية
+        except FloodWaitError as e:
+            if e.seconds > 60:
+                ui_print(f"⚠️ فلود طويل ({e.seconds}ث). سنتخطاه فوراً!")
+                continue # تخطي فوري بدون انتظار
+            else:
+                await asyncio.sleep(e.seconds)
+        except Exception as e:
+            pass
+
+    ui_print(f"🏁 انتهى الهجوم! رشّقنا {success} عضو للجروب.")
+    await client.disconnect()
+
+def get_logs():
+    return "\n".join(log_history) if log_history else "في انتظار إطلاق الهجوم..."
+
+# =============== واجهة Gradio ===============
+with gr.Blocks(title="بوت الرشق السريع", theme=gr.themes.Monochrome()) as demo:
+    gr.Markdown("## 💣 بوت الرشق الهجومي (لزيادة العدد فقط - قد يعرض الحساب للحظر)")
+    start_btn = gr.Button("🔥 ابدأ الهجوم الآن")
+    log_box = gr.Textbox(label="مراقبة الرشق", lines=20, interactive=False)
+    
+    start_btn.click(fn=aggressive_transfer, outputs=None)
+    
+    timer = gr.Timer(1)
+    timer.tick(fn=get_logs, outputs=log_box)
 
 if __name__ == "__main__":
-    while True:
-        asyncio.run(main())
-        logger.info("💤 استراحة 15 دقيقة...")
-        import time
-        time.sleep(900)
+    demo.launch(server_name="0.0.0.0", server_port=7860)