Update bot.py

bot.py

@@ -2,139 +2,107 @@ import asyncio
 import os
 import logging
 import random
-from telethon import TelegramClient
+import sys
+from threading import Thread
+from http.server import HTTPServer, SimpleHTTPRequestHandler
+from telethon import TelegramClient, functions
 from telethon.sessions import StringSession
 from telethon.tl.functions.channels import InviteToChannelRequest
 from telethon.tl.types import InputPeerUser, UserStatusRecently, UserStatusOnline
 from telethon.errors import (
-    FloodWaitError,
-    UserPrivacyRestrictedError,
-    ChatAdminRequiredError,
-    UserNotMutualContactError,
-    UserChannelsTooMuchError,
-    PeerFloodError
+    FloodWaitError, UserPrivacyRestrictedError, PeerFloodError,
+    UserChannelsTooMuchError, UserAlreadyParticipantError
 )
 
-# إعداد التسجيل
+# --- الجسر لإبقاء البوت حياً ---
+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
+
+Thread(target=lambda: HTTPServer(("0.0.0.0", 7860), HealthHandler).serve_forever(), daemon=True).start()
+
+# --- إعداد اللوق ---
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)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", "")
+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")) 
+BASE_DELAY = int(os.getenv("DELAY_SECONDS", "300"))
 
-if not API_ID or not API_HASH or not SESSION_STRING:
-    logger.error("❌ تأكد من إضافة API_ID و API_HASH و SESSION_STRING في الـ Secrets")
-    sys.exit()
+# رسالة الدعوة التي ستصل للأعضاء
+MESSAGE_TEXT = f"مرحباً بك! 👋\nلقد تمت دعوتك للانضمام إلى مجموعتنا المميزة. يشرفنا انضمامك عبر الرابط التالي:\n\n{INVITE_LINK}"
 
-# إنشاء العميل بـ SESSION_STRING نظيف بدون أي تلاعب بالبادينغ
-try:
+async def main():
     client = TelegramClient(StringSession(SESSION_STRING.strip()), API_ID, API_HASH)
-except Exception as e:
-    logger.error(f"🚨 خطأ فادح في إنشاء الجلسة: {e}")
-    sys.exit()
-
-def load_added_users():
-    if os.path.exists('added_users.txt'):
-        try:
-            with open('added_users.txt', 'r') as f:
-                return set(line.strip() for line in f)
-        except:
-            return set()
-    return set()
-
-def save_added_user(user_id):
     try:
-        with open('added_users.txt', 'a') as f:
-            f.write(f"{user_id}\n")
-    except:
-        pass
+        await client.connect()
+        if not await client.is_user_authorized():
+            logger.error("❌ الجلسة غير صالحة!")
+            return
 
-async def main():
-    logger.info("✅ جاري الاتصال بتيليجرام...")
-    added_users_memory = load_added_users()
-    logger.info(f"📂 يوجد {len(added_users_memory)} عضو في السجل (سيتم تخطيهم)")
-    
-    try:
         source = await client.get_entity(SOURCE_CHANNEL)
         target = await client.get_entity(TARGET_CHANNEL)
-    except Exception as e:
-        logger.error(f"❌ خطأ في الوصول للقنوات: {e}")
-        return
-
-    try:
-        members = await client.get_participants(source, limit=LIMIT * 3)
-    except Exception as e:
-        logger.error(f"❌ خطأ في جلب الأعضاء: {e}")
-        return
-
-    success, failed = 0, 0
-    actual_processed = 0
-
-    random.shuffle(members)
-
-    for member in members:
-        if actual_processed >= LIMIT:
-            break
-
-        str_id = str(member.id)
         
-        if member.bot or member.deleted or str_id in added_users_memory:
-            continue
-
-        is_active = isinstance(member.status, (UserStatusOnline, UserStatusRecently))
-        if not is_active:
-            continue
-
-        actual_processed += 1
-        name = member.first_name or "مستخدم"
-        logger.info(f"[{actual_processed}/{LIMIT}] 📩 محاولة إضافة: {name}")
+        participants = await client.get_participants(source, limit=LIMIT * 2)
+        random.shuffle(participants)
         
-        save_added_user(str_id)
-        added_users_memory.add(str_id)
+        success_add = 0
+        success_msg = 0
 
-        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]))
+        for member in participants:
+            if (success_add + success_msg) >= LIMIT: break
+            if member.bot or member.deleted: continue
+
+            name = member.first_name or "مستخدم"
             
-            success += 1
-            logger.info(f"✅ تمت إضافة {name} بنجاح!")
+            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__}")
             
-            smart_delay = BASE_DELAY + random.randint(10, 60)
-            logger.info(f"⏳ انتظار {smart_delay} ثانية للتمويه...")
-            await asyncio.sleep(smart_delay)
+            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__}")
 
-        except FloodWaitError as e:
-            logger.warning(f"⏳ حد الفلود - انتظار {e.seconds} ثانية...")
-            await asyncio.sleep(e.seconds + 5)
-        except PeerFloodError:
-            logger.error("🚨 تم حظرك مؤقتاً من الإضافة! توقف العمل.")
-            break
-        except UserPrivacyRestrictedError:
-            failed += 1
-            logger.info("🔒 خصوصية مقيدة للمستخدم")
-        except UserChannelsTooMuchError:
-            failed += 1
-            logger.info("📛 المستخدم في قنوات كثيرة")
-        except Exception as e:
-            failed += 1
-            logger.info(f"❌ خطأ بسيط: {type(e).__name__}")
+            # انتظار بين العمليات
+            wait = BASE_DELAY + random.randint(10, 30)
+            logger.info(f"⏳ انتظار {wait} ثانية...")
+            await asyncio.sleep(wait)
 
-    logger.info("=" * 40)
-    logger.info(f"✅ انتهى! (نجاح: {success} | فشل/خصوصية: {failed})")
+        logger.info(f"🏁 انتهى: مضافين ({success_add}) | مرسل لهم دعوات ({success_msg})")
 
-async def run():
-    async with client:
-        await main()
+    finally:
+        await client.disconnect()
 
 if __name__ == "__main__":
-    try:
-        import sys
-        asyncio.run(run())
-    except Exception as e:
-        logger.error(f"❌ خطأ في التشغيل: {e}")
+    while True:
+        asyncio.run(main())
+        logger.info("💤 استراحة 15 دقيقة...")
+        import time
+        time.sleep(900)