Update app.py

app.py

@@ -55,51 +55,71 @@ class MedicalLabBot:
         self.file_cache = {}
         self.application = None
         self.is_initialized = False
+        self.initialization_status = "pending" # تتبع حالة التهيئة
         self.load_all_materials()
     
     async def initialize_application(self):
-        """تهيئة تطبيق التليجرام بشكل غير متزامن مع محاولات إعادة"""
+        """تهيئة تطبيق التليجرام بشكل غير متزامن مع محاولات إعادة (للتشغيل في الخلفية)"""
         try:
-            if not self.application:
-                logger.info("🔄 جاري تهيئة تطبيق التليجرام...")
-                self.application = (
-                    Application.builder()
-                    .token(TELEGRAM_BOT_TOKEN)
-                    .build()
-                )
-                await self.setup_handlers()
-                
-                # ========== !! الحــل !! ==========
-                # إعادة تفعيل `initialize` مع إضافة محاولات إعادة للتعامل مع أخطاء الشبكة المؤقتة
-                
-                max_retries = 3
-                retry_delay = 5 # ثواني
-                
-                for attempt in range(max_retries):
-                    try:
-                        logger.info(f"🚀 محاولة تهيئة الاتصال بـ Telegram (محاولة {attempt + 1}/{max_retries})...")
-                        await self.application.initialize()
-                        self.is_initialized = True
-                        logger.info("✅ تم تهيئة تطبيق التليجرام بنجاح")
-                        return True # نجح، اخرج من الدالة
-                    except Exception as e:
-                        logger.warning(f"⚠️ فشلت محاولة التهيئة {attempt + 1}: {e}")
-                        if attempt < max_retries - 1:
-                            logger.info(f"⏳ الانتظار {retry_delay} ثواني قبل إعادة المحاولة...")
-                            await asyncio.sleep(retry_delay)
-                        else:
-                            logger.error(f"❌ فشل تهيئة التطبيق نهائياً بعد {max_retries} محاولات.")
-                            # لا تطلق الخطأ، فقط سجل الفشل وأكمل
-                            self.is_initialized = False
-                            return False
-                
-                # في حالة الفشل بعد كل المحاولات
-                self.is_initialized = False
-                return False
+            if self.is_initialized:
+                return True
+            
+            logger.info("🔄 جاري تهيئة تطبيق التليجرام...")
+            self.application = (
+                Application.builder()
+                .token(TELEGRAM_BOT_TOKEN)
+                .build()
+            )
+            await self.setup_handlers()
+            
+            # ========== !! الحــل !! ==========
+            # زيادة المحاولات والتأخير بشكل كبير للتعامل مع بطء شبكة HFS
+            max_retries = 5  # زيادة إلى 5 محاولات
+            retry_delay = 10 # زيادة إلى 10 ثواني
+            
+            for attempt in range(max_retries):
+                try:
+                    logger.info(f"🚀 محاولة تهيئة الاتصال بـ Telegram (محاولة {attempt + 1}/{max_retries})...")
+                    # 1. الاتصال بـ Telegram (getMe)
+                    await self.application.initialize() 
+                    logger.info("✅ تم تهيئة الاتصال بـ Telegram بنجاح.")
+                    
+                    # 2. ضبط الـ Webhook (فقط بعد نجاح الاتصال)
+                    if SPACE_URL:
+                        webhook_url = f"{SPACE_URL.rstrip('/')}/telegram"
+                        logger.info(f"ℹ️ جاري إعداد الويب هوك على: {webhook_url}")
+                        await self.application.bot.set_webhook(
+                            url=webhook_url,
+                            allowed_updates=Update.ALL_TYPES,
+                            drop_pending_updates=True
+                        )
+                        logger.info(f"✅ Webhook set to: {webhook_url}")
+                    else:
+                        logger.warning("⚠️ SPACE_URL not set. Webhook cannot be set.")
+                    
+                    # 3. ضبط الحالة على "ناجح"
+                    self.is_initialized = True
+                    self.initialization_status = "success"
+                    logger.info("✅✅✅ التطبيق جاهز لاستقبال الطلبات.")
+                    return True # نجح، اخرج من الدالة
+                    
+                except Exception as e:
+                    logger.warning(f"⚠️ فشلت ��حاولة التهيئة {attempt + 1}: {e}")
+                    if attempt < max_retries - 1:
+                        logger.info(f"⏳ الانتظار {retry_delay} ثواني قبل إعادة المحاولة...")
+                        await asyncio.sleep(retry_delay)
+                    else:
+                        logger.error(f"❌ فشل تهيئة التطبيق نهائياً بعد {max_retries} محاولات.")
+            
+            # فشل بعد كل المحاولات
+            self.is_initialized = False
+            self.initialization_status = "failed"
+            return False
 
         except Exception as e:
             logger.error(f"❌ خطأ فادح في تهيئة التطبيق: {e}")
             self.is_initialized = False
+            self.initialization_status = "failed"
             return False
     
     async def setup_handlers(self):
@@ -765,33 +785,11 @@ bot = MedicalLabBot()
 # ========== دوال FastAPI ==========
 @app.on_event("startup")
 async def on_startup():
-    """إعداد Webhook عند بدء التشغيل"""
-    try:
-        # تهيئة التطبيق أولاً (مع آلية إعادة المحاولة)
-        success = await bot.initialize_application()
-        
-        if not success:
-            logger.error("❌ فشل في تهيئة التطبيق الأساسي بعد عدة محاولات")
-            # التطبيق سيعمل، لكن is_initialized ستكون False
-            return
-            
-        if SPACE_URL:
-            webhook_url = f"{SPACE_URL.rstrip('/')}/telegram"
-            logger.info(f"ℹ️ جاري إعداد الويب هوك على: {webhook_url}")
-            await bot.application.bot.set_webhook(
-                url=webhook_url,
-                allowed_updates=Update.ALL_TYPES,
-                drop_pending_updates=True
-            )
-            logger.info(f"✅ Webhook set to: {webhook_url}")
-        else:
-            logger.warning("⚠️ SPACE_URL not set, using polling instead (if run locally)")
-            
-    except Exception as e:
-        logger.error(f"❌ Error during startup (likely setting webhook): {e}")
-        # إذا فشل الويب هوك، التطبيق لا يزال "مهيأ" من ناحية الكود
-        # لكنه لن يستقبل تحديثات
-        pass
+    """بدء تشغيل التطبيق وبدء تهيئة البوت في الخلفية"""
+    logger.info("🚀 بدء تشغيل FastAPI... بدء مهمة تهيئة البوت في الخلفية.")
+    # لا ننتظر (no await) - سيبدأ الخادم فوراً، وستعمل هذه المهمة في الخلفية
+    asyncio.create_task(bot.initialize_application())
+    logger.info("✅ خادم FastAPI يعمل. التهيئة (الاتصال بـ Telegram) جارية في الخلفية.")
 
 @app.get("/", response_class=HTMLResponse)
 async def root():
@@ -799,6 +797,16 @@ async def root():
     materials_count = len(bot.available_materials)
     total_files = sum(len(material['files']) for material in bot.available_materials.values())
     
+    # تحديد رسالة الحالة بناءً على حالة التهيئة
+    status_message = "⏳ جاري التهيئة (الاتصال بـ Telegram)..."
+    status_color = "#ffc107" # أصفر
+    if bot.initialization_status == "success":
+        status_message = "✅ نشط ومهيأ"
+        status_color = "#28a745" # أخضر
+    elif bot.initialization_status == "failed":
+        status_message = "❌ فشل التهيئة (خطأ في الاتصال بـ Telegram)"
+        status_color = "#dc3545" # أحمر
+    
     return f"""
     <html>
         <head>
@@ -806,7 +814,7 @@ async def root():
             <style>
                 body {{ font-family: Arial, sans-serif; margin: 40px; background: #f5f5f5; }}
                 .container {{ max-width: 800px; margin: 0 auto; background: white; padding: 30px; border-radius: 15px; box-shadow: 0 4px 6px rgba(0,0,0,0.1); }}
-                .status {{ padding: 20px; background: #f0f8ff; border-radius: 10px; border-left: 5px solid #007bff; }}
+                .status {{ padding: 20px; background: #f0f8ff; border-radius: 10px; border-left: 5px solid {status_color}; }}
                 h1 {{ color: #2c3e50; text-align: center; }}
                 ul {{ line-height: 1.8; }}
                 li {{ margin: 10px 0; }}
@@ -816,8 +824,7 @@ async def root():
             <div class="container">
                 <h1>🏥 بوت المختبرات الطبية الذكي</h1>
                 <div class="status">
-                    <h2>✅ البوت يعمل</h2>
-                    <p><strong>الحالة:</strong> {'✅ نشط ومهيأ' if bot.is_initialized else '❌ غير مهيأ (فشل الاتصال بـ Telegram)'}</p>
+                    <h2>حالة البوت: {status_message}</h2>
                     <p><strong>المواد المحملة:</strong> {materials_count} مادة</p>
                     <p><strong>إجمالي الملفات:</strong> {total_files} ملف</p>
                 </div>
@@ -843,8 +850,8 @@ async def handle_telegram_update(request: Request):
     try:
         # التحقق من أن التطبيق مهيأ
         if not bot.is_initialized or not bot.application:
-            logger.error("❌ التطبيق غير مهيأ، لا يمكن معالجة التحديث.")
-            raise HTTPException(status_code=503, detail="Application not initialized")
+            logger.error("❌ التطبيق غير مهيأ، لا يمكن معالجة التحديث (ربما لا يزال قيد التهيئة).")
+            raise HTTPException(status_code=503, detail="Application not initialized or still initializing")
         
         update_data = await request.json()
         update = Update.de_json(update_data, bot.application.bot)
@@ -863,10 +870,18 @@ async def health_check():
     materials_count = len(bot.available_materials)
     total_files = sum(len(material['files']) for material in bot.available_materials.values())
     
+    status = "unhealthy"
+    if bot.initialization_status == "pending":
+        status = "initializing"
+    elif bot.initialization_status == "success":
+        status = "healthy"
+    elif bot.initialization_status == "failed":
+        status = "unhealthy_failed_init"
+        
     return {
-        "status": "healthy" if bot.is_initialized else "unhealthy",
+        "status": status,
         "service": "medical-lab-bot",
-        "initialized": bot.is_initialized,
+        "initialization_status": bot.initialization_status,
         "materials_loaded": materials_count,
         "total_files": total_files,
         "timestamp": datetime.now().isoformat()