Update app.py

app.py

@@ -1,108 +1,132 @@
+import discord
 import asyncio
 import random
-import sys
-import subprocess
-import os
-
-# تثبيت المكتبات المطلوبة لضمان التشغيل
-try:
-    import discord
-    from discord.ext import commands
-    from aiohttp import web
-except ImportError:
-    subprocess.check_call([sys.executable, "-m", "pip", "install", "discord.py==2.3.2", "aiohttp", "PyNaCl==1.5.0"])
-    import discord
-    from discord.ext import commands
-    from aiohttp import web
-
-TOKENS = [
-    "MTUxMjU2NjMyNTQxMzgxMDI2MA.GFBEul.UKnVbr_OJAJlmpePUoO2V4NrJ_LpTTNKFsnUxQ",
-    "MTQ3Njg3NjgyNDkyMjU1ODYzOA.GWCkDG.kfTkrRo6E0XqRIPD_B80ieUwDqGyVq_KAoUJOk",
-    "MTUxMjEwNDE3MjM1MzM195Mw.GB7ANm.jPqZM5Mv_JNU2RA9Occpo1LTgXCm3YL6y8Vcdo",
-    "MTUxMjU2Mzg4MzcwNzk5NDE3Nw.GWKofh.R-1sNFRwGqsunxKWi1sE97LyVaunnV1MNRk2Nk",
-    "MTUxNDczMTU2NjE1NTQzMjA3OQ.GMqqGa.rYmt2Gglbgd4QRxXL7Hr21oMnadLbQ8Wa7p7ck",
-    "MTUxMzY0OTcyMjQxNjY5NzM1NQ.G1h9FV.G4L3yDC1zgcaEIZwasPUYoZCbr_1lF7zFdcIsI",
-    "MTQ4NjA5Nzg0NDM4ODQ5NTQ1Mw.G6gyXL.nxOQaSyLNNQzntpVsbHJcaH3THdnu-H3qHQqBs",
-    "MTUyMjMwOTYwNDExMjA3MjcxNA.GEmVmu.qLozNgXe8m9QLyCweOC0OvjAgMKtOKiBjO9kkA",
-    "MTUyMjMxMzE5Mzg0ODgzMjEwMQ.GE4CZs.ZFk8mJgPhfgOt4xh6N9QGnX_7InaxtgufWsT0g"
-]
+import threading
+import time
+from colorama import Fore, Style, init
 
-VOICE_CHANNELS = [
-    1466546948554096773, 1466546948554096773, 
-    1512162433626542181, 1512162433626542181, 
-    1390374668183277718, 1390374668183277718, 1390374668183277718, 
-    1522318302712692886, 1522318302712692886  
-]
+init(autoreset=True)
+
+# ================ كونفيج ================
+GUILD_ID = 1383484429837533318
 
-STREAMER_TOKEN = random.choice([
-    "MTUxNDczMTU2NjE1NTQzMjA3OQ.GMqqGa.rYmt2Gglbgd4QRxXL7Hr21oMnadLbQ8Wa7p7ck",
-    "MTUxMzY0OTcyMjQxNjY5NzM1NQ.G1h9FV.G4L3yDC1zgcaEIZwasPUYoZCbr_1lF7zFdcIsI",
-    "MTQ4NjA5Nzg0NDM4ODQ5NTQ1Mw.G6gyXL.nxOQaSyLNNQzntpVsbHJcaH3THdnu-H3qHQqBs"
-])
-
-async def start_bot(token, channel_id):
-    clean_token = token.strip()
-    intents = discord.Intents.default()
-    intents.message_content = True
-    intents.voice_states = True
+TOKENS_CONFIG = [
+    # (token, channel_id)
+    # الروم الأول - 2 توكين
+    ("MTUxMjU2Mzg4MzcwNzk5NDE3Nw.GWKofh.R-1sNFRwGqsunxKWi1sE97LyVaunnV1MNRk2Nk", 1466546948554096773),
+    ("MTUxMjEwNDE3MjM1MzM1OTk1Mw.GB7ANm.jPqZM5Mv_JNU2RA9Occpo1LTgXCm3YL6y8Vcdo", 1466546948554096773),
     
-    bot = commands.Bot(command_prefix="!", self_bot=True, intents=intents)
+    # الروم التاني - 2 توكين
+    ("MTQ3Njg3NjgyNDkyMjU1ODYzOA.Gn8u5W.jCb7hMTS2Eo-xoUua5JYBmJ-cwClHgshGM6aJM", 1512162433626542181),
+    ("MTUxMjU2NjMyNTQxMzgxMDI2MA.GFBEul.UKnVbr_OJAJlmpePUoO2V4NrJ_LpTTNKFsnUxQ", 1512162433626542181),
     
-    # ⚡ الحل السحري: تخطي حجب Hugging Face عبر تحويل الـ API والـ Gateway لـ Proxy مجاني مستقر لدخول ديسكورد
-    discord.http.Route.BASE = "https://discord.com/api/v9"
+    # الروم التالت - 3 توكين
+    ("MTQ4NjA5Nzg0NDM4ODQ5NTQ1Mw.G6gyXL.nxOQaSyLNNQzntpVsbHJcaH3THdnu-H3qHQqBs", 1390374668183277718),
+    ("MTUxMzY0OTcyMjQxNjY5NzM1NQ.G1h9FV.G4L3yDC1zgcaEIZwasPUYoZCbr_1lF7zFdcIsI", 1390374668183277718),
+    ("MTUxNDczMTU2NjE1NTQzMjA3OQ.GsqZ3V.UtmGBdhv-Ojjt6PtT5ny8w2kLv7SQJ7HpNzRio", 1390374668183277718),
     
-    bot.is_reconnecting = False
-
-    @bot.event
-    async def on_ready():
-        print(f'👤 {bot.user.name} نجح في تخطي الحجب وسجل دخول!')
-        await asyncio.sleep(2)
-        channel = bot.get_channel(channel_id)
-        if channel:
-            try:
-                await channel.connect()
-                print(f'✅ {bot.user.name} دخل الروم بنجاح الآن.')
-                
-                # تشغيل البث التلقائي إذا كان الحساب المختار
-                if token.strip() == STREAMER_TOKEN:
-                    await asyncio.sleep(5)
-                    await bot.ws.send_as_json({
-                        "op": 4,
-                        "d": {
-                            "guild_id": str(channel.guild.id),
-                            "channel_id": str(channel_id),
-                            "self_mute": False,
-                            "self_deaf": False,
-                            "self_video": True
-                        }
-                    })
-                    print(f'📺 [بث] {bot.user.name} بدأ البث بنجاح.')
-            except Exception as e:
-                print(f'❌ فشل دخول الروم للحساب {bot.user.name}: {e}')
+    # الروم الرابع - 2 توكين زيادة
+    ("MTUyMjMwOTYwNDExMjA3MjcxNA.GEmVmu.qLozNgXe8m9QLyCweOC0OvjAgMKtOKiBjO9kkA", 1522318302712692886),
+    ("MTUyMjMxMzE5Mzg0ODgzMjEwMQ.GE4CZs.ZFk8mJgPhfgOt4xh6N9QGnX_7InaxtgufWsT0g", 1522318302712692886),
+]
 
-    try:
-        await bot.start(clean_token)
-    except Exception as e:
-        print(f'❌ خطأ في التوكن [{clean_token[:15]}...]: {e}')
-
-# سيرفر الويب الوهمي لضمان عمل السبيس 24 ساعة
-async def keep_alive():
-    app = web.Application()
-    app.router.add_route('GET', '/', lambda r: web.Response(text="Bot is Running 24/7"))
-    runner = web.AppRunner(app)
-    await runner.setup()
-    site = web.TCPSite(runner, '0.0.0.0', 7860)
-    await site.start()
-
-async def main():
-    await keep_alive()
-    tasks = []
-    for i in range(len(TOKENS)):
-        tasks.append(asyncio.create_task(start_bot(TOKENS[i], VOICE_CHANNELS[i])))
-        if i < len(TOKENS) - 1:
-            await asyncio.sleep(random.uniform(5.0, 12.0)) # وقت عشوائي آمن بين دخول الحسابات
+
+class VCAccount:
+    def __init__(self, token, channel_id):
+        self.token = token
+        self.channel_id = channel_id
+        self.client = discord.Client()
+        self.voice_connected = False
+        self._setup_events()
+
+    def _setup_events(self):
+        @self.client.event
+        async def on_ready():
+            print(f"{Fore.GREEN}[+] {self.client.user.name} متصل ✅")
+            await self._join_vc()
+
+        @self.client.event
+        async def on_voice_state_update(member, before, after):
+            if member.id != self.client.user.id:
+                return
+
+            if before.channel is not None and after.channel is None:
+                print(f"{Fore.YELLOW}[!] {self.client.user.name} انفصل - برجع تاني 🔄")
+                self.voice_connected = False
+                await asyncio.sleep(1)
+                await self._join_vc()
+
+            elif after.self_mute or after.self_deaf or after.mute or after.deaf:
+                print(f"{Fore.YELLOW}[!] {self.client.user.name} ات mute/deaf - هرجع بعد 10 ثواني 🔇")
+                self.voice_connected = False
+                await asyncio.sleep(10)
+                await self._join_vc()
+            
+            elif after.channel is not None and before.channel is None:
+                self.voice_connected = True
+                print(f"{Fore.CYAN}[✓] {self.client.user.name} داخل فويس ✅")
+
+        @self.client.event
+        async def on_message(message):
+            if message.guild is None or message.guild.id != GUILD_ID:
+                return
+            if message.mention_everyone:
+                delay = random.uniform(1, 7)
+                await asyncio.sleep(delay)
+                try:
+                    await message.add_reaction("❤️")
+                    print(f"{Fore.MAGENTA}[❤️] {self.client.user.name} رياكشن ❤️")
+                except:
+                    pass
+
+    async def _join_vc(self):
+        try:
+            guild = self.client.get_guild(GUILD_ID)
+            if not guild:
+                print(f"{Fore.RED}[✗] {self.client.user.name} مش لاقي السيرفر")
+                return
+            
+            channel = guild.get_channel(self.channel_id)
+            if not channel:
+                print(f"{Fore.RED}[✗] {self.client.user.name} مش لاقي الروم")
+                return
             
-    await asyncio.gather(*tasks)
+            await guild.change_voice_state(channel=channel, self_mute=False, self_deaf=False)
+            print(f"{Fore.CYAN}[→] {self.client.user.name} جاي يدخل فويس {channel.name} ...")
+            
+        except Exception as e:
+            print(f"{Fore.RED}[✗] {self.client.user.name} فشل دخول الفويس: {e}")
+            await asyncio.sleep(3)
+            asyncio.create_task(self._join_vc())
+
+    def run(self):
+        try:
+            self.client.run(self.token)
+        except Exception as e:
+            print(f"{Fore.RED}[✗] فشل تشغيل {self.token[:20]}...: {e}")
+
+
+def run_accounts():
+    """تشغيل كل حساب بفارق 5 ثواني"""
+    delay = 0
+    for token, ch_id in TOKENS_CONFIG:
+        time.sleep(delay)
+        acc = VCAccount(token, ch_id)
+        t = threading.Thread(target=acc.run, daemon=True)
+        t.start()
+        delay = 5
+        print(f"{Fore.WHITE}[*] التوكين الجاي بعد {delay} ثواني...")
+
 
 if __name__ == "__main__":
-    asyncio.run(main())
+    print(f"{Fore.WHITE}{'='*50}")
+    print(f"{Fore.WHITE}     🎯 VC ARMY - 9 Accounts")
+    print(f"{Fore.WHITE}{'='*50}")
+    
+    run_accounts()
+    
+    try:
+        while True:
+            time.sleep(60)
+    except KeyboardInterrupt:
+        print(f"{Fore.RED}بي باي!")