Update bot.py

bot.py

@@ -3,13 +3,12 @@ import os
 import logging
 import random
 import sys
-from telethon import TelegramClient
+from telethon import TelegramClient, functions
 from telethon.sessions import StringSession
 from telethon.tl.functions.channels import InviteToChannelRequest
-from telethon.tl.types import InputPeerUser
+from telethon.tl.types import InputPeerUser, UserStatusRecently, UserStatusOnline
 from telethon.errors import (
-    FloodWaitError, UserPrivacyRestrictedError, PeerFloodError,
-    UserChannelsTooMuchError, UserAlreadyParticipantError
+    FloodWaitError, UserPrivacyRestrictedError, PeerFloodError, UserAlreadyParticipantError
 )
 
 # إعداد اللوق
@@ -22,77 +21,66 @@ 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", "")
-LIMIT = int(os.getenv("LIMIT", "50")) 
-BASE_DELAY = int(os.getenv("DELAY_SECONDS", "300")) 
+LIMIT_PER_CYCLE = 2 # إضافة عضوين في كل دورة
 
 async def start_transfer():
-    logger.info("🚀 بدأت المحاولة باستخدام الكود المحدث (تخطي الحظر والانتظار الطويل)...")
-    
     client = TelegramClient(StringSession(SESSION_STRING.strip()), API_ID, API_HASH)
-    
     try:
         await client.connect()
         if not await client.is_user_authorized():
             logger.error("❌ الجلسة غير صالحة!")
             return
 
+        # ✅ إظهار الحساب "متصل الآن"
+        await client(functions.account.UpdateStatusRequest(offline=False))
+        logger.info("🟢 متصل الآن (Online)")
+
         source = await client.get_entity(SOURCE_CHANNEL)
         target = await client.get_entity(TARGET_CHANNEL)
         
-        # جلب الأعضاء
+        # جلب الأعضاء النشطين فقط لضمان جودة النقل
         participants = await client.get_participants(source, limit=500)
         random.shuffle(participants)
         
-        success, processed = 0, 0
-
+        success = 0
         for member in participants:
-            if processed >= LIMIT: break
+            if success >= LIMIT_PER_CYCLE: break
             if member.bot or member.deleted: continue
-
-            processed += 1
-            name = member.first_name or "User"
-            logger.info(f"[{processed}/{LIMIT}] محاولة إجبارية لإضافة: {name}")
+            
+            # تخطي غير النشطين لتقليل فرص الحظر
+            if not isinstance(member.status, (UserStatusOnline, UserStatusRecently)):
+                continue
 
             try:
                 # محاولة الإضافة
                 await client(InviteToChannelRequest(target, [InputPeerUser(member.id, member.access_hash or 0)]))
                 success += 1
-                logger.info(f"✅ نجحت إضافة {name}!")
-                await asyncio.sleep(BASE_DELAY)
-
-            except PeerFloodError:
-                logger.warning(f"🚨 تيليجرام رفض إضافة {name} (Flood). سأتخطاه وأجرب العضو التالي بعد 30 ثانية...")
-                await asyncio.sleep(30)
-                continue 
+                logger.info(f"✅ تمت إضافة {member.first_name}")
+                # انتظار قصير جداً بين العضوين داخل الدورة
+                await asyncio.sleep(random.randint(5, 10))
 
             except UserAlreadyParticipantError:
-                logger.info(f"⏭ {name} موجود بالفعل.")
-                
-            except FloodWaitError as e:
-                # 🛠 هنا التعديل السحري:
-                logger.warning(f"⏳ تيليجرام طلب انتظار {e.seconds} ثانية!")
-                if e.seconds > 120:
-                    logger.warning("⚠️ هذا وقت طويل جداً! سأتخطى هذا العضو وأنتظر 2 دقائق فقط (120 ثانية) وأكمل...")
-                    await asyncio.sleep(120)
-                else:
-                    await asyncio.sleep(e.seconds + 2)
-                    
-            except UserPrivacyRestrictedError:
-                logger.info(f"🔒 خصوصية {name} تمنع الإضافة.")
+                continue
+            except PeerFloodError:
+                logger.warning("🚨 تقييد PeerFlood! سنرتاح في الدورة القادمة.")
+                break
             except Exception as e:
-                logger.info(f"❌ فشل مع {name}: {type(e).__name__}")
+                logger.info(f"❌ فشل مع {member.first_name}: {type(e).__name__}")
+                continue
 
-        logger.info(f"🏁 انتهت الدورة. تم إضافة {success} أعضاء.")
+        logger.info(f"🏁 انتهت الدورة. تم إضافة {success} عضو.")
 
     except Exception as e:
         logger.error(f"❌ خطأ نظام: {e}")
     finally:
+        # ✅ الخروج لكي يظهر الح��اب أوف لاين أثناء فترة الراحة
         await client.disconnect()
 
 if __name__ == "__main__":
-    # تشغيل مستمر
     while True:
         asyncio.run(start_transfer())
-        logger.info("💤 انتظار 10 دقائق قبل دورة عشوائية جديدة...")
+        # ✅ الانتظار لمدة 5 دقائق (300 ثانية) كما طلبت
+        wait_time = 300 
+        logger.info(f"💤 تسجيل خروج والراحة لمدة {wait_time//60} دقائق...")
         import time
-        time.sleep(600)
+        time.sleep(wait_time)