Upload userbot_noura.py

userbot_noura.py

@@ -36,7 +36,7 @@ load_dotenv()
 API_ID = int(os.getenv("API_ID", 0))
 API_HASH = os.getenv("API_HASH", "")
 PHONE = os.getenv("PHONE", "")
-BOT_TOKEN = os.getenv("BOT_TOKEN", "")
+BOT_TOKEN = os.getenv("BOT_TOKEN", "7875784449:AAGlCPmjOmoQHRSku8HShc-cTfaXrkroYN0")
 
 # إعدادات نورا
 NOURA_API = (os.getenv("NOURA_API_BASE", "http://127.0.0.1:9531")).rstrip("/")
@@ -848,68 +848,148 @@ async def post_init(app):
         logging.info("Warm-up: تم.")
     except Exception as e:
         logging.warning("Warm-up فشل: %s", e)
+        import asyncio
+from telethon import TelegramClient, events
+from telegram.ext import ApplicationBuilder, CommandHandler, MessageHandler, filters
 
 # =========================
-# الدوال الرئيسية للتشغيل
+# الإعدادات الأساسية
+# =========================
+#API_ID = 'your_api_id'
+#API_HASH = 'your_api_hash'
+#PHONE = 'your_phone_number'
+#TELEGRAM_TOKEN = 'your_telegram_bot_token'
+
+# قوائم القنوات (سيتم ملؤها ديناميكياً)
+source_channels = []
+target_channels = []
+
+# تهيئة العميل
+client = TelegramClient('session_name', API_ID, API_HASH)
+
+# =========================
+# دوال المساعدة
+# =========================
+
+async def refresh_admin_channels():
+    """تحديث قائمة القنوات من قنوات الإدارة"""
+    global source_channels, target_channels
+    try:
+        # هنا يتم جلب القنوات من قنوات الإدارة
+        # هذا مثال - يجب تعديله حسب طريقة تخزينك للقنوات
+        source_channels = [123456, 789012]  # أمثلة على معرفات القنوات
+        target_channels = [345678, 901234]  # أمثلة على معرفات القنوات
+        
+        print(f"🔄 تم تحديث القنوات: {len(source_channels)} مصدر، {len(target_channels)} هدف")
+    except Exception as e:
+        print(f"❌ خطأ في تحديث القنوات: {e}")
+
+async def periodic_channel_refresh(interval_minutes=30):
+    """تحديث قائمة القنوات بشكل دوري"""
+    while True:
+        await asyncio.sleep(interval_minutes * 60)
+        await refresh_admin_channels()
+
+# =========================
+# معالجة رسائل القنوات (تليثون)
+# =========================
+
+@client.on(events.NewMessage(chats=source_channels))
+async def handle_channel_message(event):
+    """معالجة الرسائل من القنوات المصدر"""
+    try:
+        print(f"📥 رسالة جديدة من قناة مصدر: {event.chat_id}")
+        
+        # إعادة الإرسال لجميع القنوات الهدف
+        success_count = 0
+        for target_id in target_channels:
+            if target_id != event.chat_id:  # عدم الإرسال لنفس القناة
+                try:
+                    await client.forward_messages(target_id, event.message)
+                    print(f"✅ تم النشر إلى: {target_id}")
+                    success_count += 1
+                    await asyncio.sleep(1)  # تجنب FloodWait
+                except Exception as e:
+                    print(f"❌ فشل النشر إلى {target_id}: {e}")
+        
+        print(f"✅ تم النشر إلى {success_count} قناة")
+        
+    except Exception as e:
+        print(f"❌ خطأ في معالجة الرسالة: {e}")
+
+# =========================
+# معالجة أوامر البوت (تليجرام)
+# =========================
+
+async def start(update, context):
+    """معالجة أمر /start"""
+    await update.message.reply_text("مرحباً! أنا بوت يعمل.")
+
+async def handle_image_command(update, context):
+    """معالجة أمر /image"""
+    await update.message.reply_text("معالجة صورة...")
+
+async def handle_message(update, context):
+    """معالجة الرسائل النصية"""
+    await update.message.reply_text(f"تم استلام رسالتك: {update.message.text}")
+
+async def handle_images(update, context):
+    """معالجة الصور المرسلة"""
+    await update.message.reply_text("تم استلام الصورة!")
+
+# =========================
+# الدالة الرئيسية
 # =========================
-# استبدل دالة main() الحالية:
 
 async def main():
+    print("🚀 بدء التشغيل...")
+    
     # بدء تيليثون
     await client.start(phone=PHONE)
-    print("✅ تم تشغيل تيليثون بنجاح")
+    print("✅ تيليثون يعمل")
     
     # تحديث قائمة القنوات تلقائياً
     await refresh_admin_channels()
+    print("✅ تم تحديث القنوات")
     
-    # بدء تيليجرام بوت
-    app = ApplicationBuilder().token(TELEGRAM_TOKEN).post_init(post_init).build()
+    # بدء التحديث الدوري للقنوات في الخلفية
+    asyncio.create_task(periodic_channel_refresh(30))
+    print("✅ التحديث الدوري يعمل")
     
-    # إضافة الهاندلرات
+    # بدء بوت التليجرام في الخلفية
+    app = ApplicationBuilder().token(TELEGRAM_TOKEN).build()
     app.add_handler(CommandHandler("start", start))
     app.add_handler(CommandHandler("image", handle_image_command))
     app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message))
     app.add_handler(MessageHandler(filters.PHOTO | (filters.Document.IMAGE & filters.CAPTION), handle_images))
+    print("✅ تم إعداد بوت التليجرام")
     
-    # تشغيل البوتين معاً
-    await asyncio.gather(
-        client.run_until_disconnected(),
-        app.run_polling()
-    )
-
-# استبدل دالة main() الحالية بهذا الكود:
-
-async def main():
-    # بدء تيليثون
-    await client.start(phone=PHONE)
-    print("✅ تم تشغيل تيليثون بنجاح")
-    
-    # تحديث قائمة القنوات تلقائياً
-    await refresh_admin_channels()
-    
-    # بدء تيليجرام بوت في خيط منفصل
-    import threading
-    
-    def run_bot():
-        # إنشاء تطبيق جديد داخل الخيط
-        app = ApplicationBuilder().token(TELEGRAM_TOKEN).build()
-        
-        # إضافة الهاندلرات
-        app.add_handler(CommandHandler("start", start))
-        app.add_handler(CommandHandler("image", handle_image_command))
-        app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_message))
-        app.add_handler(MessageHandler(filters.PHOTO | (filters.Document.IMAGE & filters.CAPTION), handle_images))
-        
-        # تشغيل البوت
-        app.run_polling()
-    
-    # تشغيل البوت في خيط منفصل
-    bot_thread = threading.Thread(target=run_bot)
-    bot_thread.daemon = True
-    bot_thread.start()
+    # تشغيل البوت في الخلفية
+    await app.initialize()
+    await app.start()
+    if app.updater:
+        await app.updater.start_polling()
+    print("✅ بوت التليجرام يعمل")
     
-    # الاستمرار في تشغيل تيليثون في الخيط الرئيسي
+    # البقاء في الانتظار إلى الأبد
+    print("🔄 البوت يعمل الآن - استخدم Ctrl+C لإيقافه")
     await client.run_until_disconnected()
 
+# =========================
+# نقطة الدخول
+# =========================
+
 if __name__ == "__main__":
-    asyncio.run(main())
+    # تشغيل البوت بشكل دائم
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+    
+    try:
+        loop.run_until_complete(main())
+    except KeyboardInterrupt:
+        print("⏹️ تم إيقاف البوت")
+    except Exception as e:
+        print(f"❌ خطأ: {e}")
+    finally:
+        print("🔄 جاري الإغلاق...")
+        loop.close()