Update app.py

app.py

@@ -15,7 +15,7 @@ from PIL import Image
 import io
 import requests
 from fastapi import FastAPI, Request, HTTPException
-from fastapi.responses import HTMLResponse
+from fastapi.responses import HTMLResponse, JSONResponse # استيراد JSONResponse
 import uvicorn
 import random
 import docx  # لإضافة دعم .docx
@@ -25,7 +25,7 @@ import httpx
 import dns.asyncresolver
 from httpx import AsyncClient, AsyncHTTPTransport, Request, Response
 import contextlib # <-- إضافة المكتبة الصحيحة
-from typing import Dict # <-- إضافة Dict لتحديد نوع الاستجابة
+from typing import Dict, Any # <-- إضافة Dict و Any
 # ==========================================================
 
 # ========== تكوين السجلات ==========
@@ -192,7 +192,7 @@ class MedicalLabBot:
             return False
 
         except Exception as e:
-            logger.error(f"❌ خطأ فادح في تهيئة التطبيق: {e}")
+            logger.error(f"❌ خطأ فادح في تهيئة التطبيق: {e}", exc_info=True) # إضافة exc_info=True
             self.is_initialized = False
             self.initialization_status = "failed"
             return False
@@ -361,6 +361,7 @@ class MedicalLabBot:
     async def _call_nvidia_api(self, messages, max_tokens=1500):
         """دالة مساعدة لاستدعاء NVIDIA API"""
         try:
+            # استخدام asyncio.to_thread لتشغيل الكود المتزامن في thread
             completion = await asyncio.to_thread(
                 nvidia_client.chat.completions.create,
                 model="meta/llama3-70b-instruct", # استخدام موديل قوي
@@ -371,7 +372,7 @@ class MedicalLabBot:
             )
             return completion.choices[0].message.content
         except Exception as e:
-            logger.error(f"❌ Error calling NVIDIA API: {e}")
+            logger.error(f"❌ Error calling NVIDIA API: {e}", exc_info=True)
             return f"❌ حدث خطأ أثناء التواصل مع الذكاء الاصطناعي: {e}"
 
     def _find_file_by_query(self, query, subject):
@@ -452,16 +453,16 @@ class MedicalLabBot:
             if local_path.lower().endswith('.pdf'):
                 # استخدام PyMuPDF (fitz) لاستخراج أدق
                  with fitz.open(local_path) as doc:
-                      for page in doc:
+                      for page_num, page in enumerate(doc):
                            text_content += page.get_text("text", sort=True) # محاولة فرز النص
-                           text_content += "\n\n--- Page Break ---\n\n" # إضافة فاصل صفحات
+                           # text_content += f"\n\n--- Page {page_num + 1} ---\n\n" # إضافة فاصل صفحات (اختياري)
 
             elif local_path.lower().endswith('.txt'):
                 with open(local_path, 'r', encoding='utf-8', errors='ignore') as f: # تجاهل أخطاء الترميز
                     text_content = f.read()
 
             elif local_path.lower().endswith('.docx'):
-                 doc_obj = docx.Document(local_path)
+                 doc_obj = await asyncio.to_thread(docx.Document, local_path) # تشغيل في thread
                  full_text = []
                  for para in doc_obj.paragraphs:
                      full_text.append(para.text)
@@ -1083,7 +1084,7 @@ async def root():
     </html>
     """
 
-# ========== !! الحل البديل: تحديد نوع الاستجابة صراحة !! ==========
+# ========== !! الحل البديل المضمون: تحديد نوع الاستجابة صراحة !! ==========
 @app.post("/telegram", response_model=Dict[str, str])
 async def handle_telegram_update(request: Request):
     """معالجة تحديثات Telegram"""
@@ -1116,7 +1117,8 @@ async def handle_telegram_update(request: Request):
         raise HTTPException(status_code=500, detail="Internal server error while processing update")
 
 
-@app.get("/health")
+# ========== تعديل احترازي: تحديد نوع الاستجابة لمسار health أيضاً ==========
+@app.get("/health", response_model=Dict[str, Any])
 async def health_check():
     """فحص صحة الخدمة"""
     materials_count = len(bot.available_materials)
@@ -1146,7 +1148,6 @@ async def health_check():
     }
 
     # استخدام JSONResponse لتحديد status_code بشكل صحيح
-    from fastapi.responses import JSONResponse
     return JSONResponse(content=response_payload, status_code=status_code)
 
 # ========== التشغيل الرئيسي ==========