Update app.py

app.py

@@ -20,6 +20,11 @@ import uvicorn
 import random
 import docx  # لإضافة دعم .docx
 
+# ========== (الحل) إضافة المكتبات اللازمة لحل مشكلة DNS ==========
+import httpx
+import httpx_dnspython
+# ==========================================================
+
 # ========== تكوين السجلات ==========
 logging.basicConfig(
     format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
@@ -45,7 +50,18 @@ REPO_ID = "Riy777/Study"
 SELECTING_SUBJECT, SELECTING_ACTION, WAITING_FOR_QUESTION = range(3)
 
 # ========== تطبيق FastAPI ==========
-app = FastAPI(title="Medical Lab Bot", version="1.0.0")
+# تعديل: استخدام lifespan بدلاً من on_event
+@asyncio.contextmanager
+async def lifespan(app: FastAPI):
+    # الكود الذي كان في on_startup
+    logger.info("🚀 بدء تشغيل FastAPI... بدء مهمة تهيئة البوت في الخلفية.")
+    asyncio.create_task(bot.initialize_application())
+    logger.info("✅ خادم FastAPI يعمل. التهيئة (الاتصال بـ Telegram) جارية في الخلفية.")
+    yield
+    # كود إيقاف التشغيل (on_shutdown) (إن وجد)
+    logger.info("🛑 إيقاف تشغيل خادم FastAPI.")
+
+app = FastAPI(title="Medical Lab Bot", version="1.0.0", lifespan=lifespan)
 
 # ========== فئة البوت الرئيسية ==========
 class MedicalLabBot:
@@ -59,23 +75,32 @@ class MedicalLabBot:
         self.load_all_materials()
     
     async def initialize_application(self):
-        """تهيئة تطبيق التليجرام بشكل غير متزامن مع محاولات إعادة (للتشغيل في الخلفية)"""
+        """تهيئة تطبيق التليجرام بشكل غير متزامن مع حل DNS المخصص"""
         try:
             if self.is_initialized:
                 return True
             
             logger.info("🔄 جاري تهيئة تطبيق التليجرام...")
+            
+            # ========== !! الحل الجذري (DNS) !! ==========
+            logger.info("🔧 إعداد عميل HTTP مخصص مع DNS (1.1.1.1)...")
+            transport = httpx_dnspython.AsyncDNSTransport(
+                resolver=httpx_dnspython.SyncResolver(nameservers=["1.1.1.1", "8.8.8.8"])
+            )
+            # نستخدم httpx.AsyncClient مع الناقل المخصص
+            custom_client = httpx.AsyncClient(transport=transport)
+            # ============================================
+
             self.application = (
                 Application.builder()
                 .token(TELEGRAM_BOT_TOKEN)
+                .http_client(custom_client)  # <-- تمرير العميل المخصص هنا
                 .build()
             )
             await self.setup_handlers()
             
-            # ========== !! الحــل !! ==========
-            # زيادة المحاولات والتأخير بشكل كبير للتعامل مع بطء شبكة HFS
-            max_retries = 5  # زيادة إلى 5 محاولات
-            retry_delay = 10 # زيادة إلى 10 ثواني
+            max_retries = 3 # تقليل المحاولات لأن المشكلة يفترض أن تُحل
+            retry_delay = 5 # تقليل التأخير
             
             for attempt in range(max_retries):
                 try:
@@ -109,7 +134,7 @@ class MedicalLabBot:
                         logger.info(f"⏳ الانتظار {retry_delay} ثواني قبل إعادة المحاولة...")
                         await asyncio.sleep(retry_delay)
                     else:
-                        logger.error(f"❌ فشل تهيئة التطبيق نهائياً بعد {max_retries} محاولات.")
+                        logger.error(f"❌ فشل تهيئة التطبيق نهائياً بعد {max_retries} محاولات (حتى مع DNS المخصص).")
             
             # فشل بعد كل المحاولات
             self.is_initialized = False
@@ -520,7 +545,7 @@ class MedicalLabBot:
             keyboard.append([InlineKeyboardButton(display_name, callback_data=f"subject_{subject}")])
         
         keyboard.append([InlineKeyboardButton("🔄 تحديث قائمة المواد", callback_data="refresh_materials")])
-        keyboard.append([InlineKeyboardButton("❓ مساعدة", callback_data="general_help")])
+        keyboard.append([InlineKeyboardButton("❓ مساعدة", callback_Ddata="general_help")])
         return keyboard
     
     async def handle_subject_selection(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
@@ -783,13 +808,15 @@ class MedicalLabBot:
 bot = MedicalLabBot()
 
 # ========== دوال FastAPI ==========
-@app.on_event("startup")
-async def on_startup():
-    """بدء تشغيل التطبيق وبدء تهيئة البوت في الخلفية"""
-    logger.info("🚀 بدء تشغيل FastAPI... بدء مهمة تهيئة البوت في الخلفية.")
-    # لا ننتظر (no await) - سيبدأ الخادم فوراً، ��ستعمل هذه المهمة في الخلفية
-    asyncio.create_task(bot.initialize_application())
-    logger.info("✅ خادم FastAPI يعمل. التهيئة (الاتصال بـ Telegram) جارية في الخلفية.")
+
+# تم نقل @app.on_event("startup") إلى تعريف "lifespan"
+# @app.on_event("startup")
+# async def on_startup():
+#     """بدء تشغيل التطبيق وبدء تهيئة البوت في الخلفية"""
+#     logger.info("🚀 بدء تشغيل FastAPI... بدء مهمة تهيئة البوت في الخلفية.")
+#     # لا ننتظر (no await) - سيبدأ الخادم فوراً، وستعمل هذه المهمة في الخلفية
+#     asyncio.create_task(bot.initialize_application())
+#     logger.info("✅ خادم FastAPI يعمل. التهيئة (الاتصال بـ Telegram) جارية في الخلفية.")
 
 @app.get("/", response_class=HTMLResponse)
 async def root():