y

data/Dockerfile

@@ -2,7 +2,7 @@ FROM python:3.10-slim
 
 # إضافة حزم أساسية فقط
 RUN apt-get update && apt-get install -y \
-    build-essential pkg-config \
+    build-essential pkg-config curl \
     && rm -rf /var/lib/apt/lists/*
 
 # إضافة مستخدم غير root
@@ -25,4 +25,4 @@ RUN pip install --no-cache-dir -r requirements.txt
 
 USER user
 
-CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860"]
+CMD ["uvicorn", "app:app", "--host", "0.0.0.0", "--port", "7860", "--log-config", "logging.conf"]

data/app.py

@@ -1,7 +1,18 @@
+# إعداد السجل العام للتطبيق
+import logging
+logging.basicConfig(
+    level=logging.DEBUG,
+    format="🪵 [%(asctime)s] [%(levelname)s] %(message)s",
+    handlers=[
+        logging.StreamHandler(),
+        logging.FileHandler("app.log")
+    ]
+)
+logger = logging.getLogger(__name__)
+
 from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
 from llama_cpp import Llama
-import logging
 import os
 import threading
 from fastapi.middleware.cors import CORSMiddleware
@@ -9,13 +20,6 @@ from monitor import get_current_metrics, start_monitoring_thread
 from huggingface_hub import hf_hub_download
 from memory import get_history, save_history
 
-# إعداد السجل العام للتطبيق
-logging.basicConfig(
-    level=logging.DEBUG,
-    format="🪵 [%(asctime)s] [%(levelname)s] %(message)s",
-)
-logger = logging.getLogger(__name__)
-
 # إعدادات النموذج
 MODEL_REPO = "Qwen/Qwen2-1.5B-Instruct-GGUF"
 MODEL_FILE = "qwen2-1_5b-instruct-q6_k.gguf"
@@ -30,6 +34,31 @@ Follow these rules:
 3. Keep responses concise but complete
 4. For complex requests, ask clarifying questions<|im_end|>"""
 
+# تنسيق prompt الدردشة
+def format_chat(history, new_message):
+    messages = [("system", SYSTEM_PROMPT)]
+
+    for item in history[-8:]:
+        if isinstance(item, list) and len(item) == 2:
+            user_msg, bot_msg = item
+            messages.append(("user", user_msg))
+            messages.append(("assistant", bot_msg))
+        else:
+            logger.warning(f"⚠️ عنصر غير متوافق في التاريخ: {item}")
+
+    messages.append(("user", new_message))
+
+    formatted = []
+    for role, content in messages:
+        if role == "system":
+            formatted.append(f"<|im_start|>system\n{content}<|im_end|>")
+        elif role == "user":
+            formatted.append(f"<|im_start|>user\n{content}<|im_end|>")
+        else:
+            formatted.append(f"<|im_start|>assistant\n{content}<|im_end|>")
+    formatted.append("<|im_start|>assistant\n")
+    return "\n".join(formatted)
+
 # تحميل النموذج إذا لم يكن موجوداً
 def load_model():
     if not os.path.exists(MODEL_PATH):
@@ -60,9 +89,6 @@ def load_model():
         verbose=False
     )
 
-# بدء مراقبة الموارد
-start_monitoring_thread()
-
 # إنشاء تطبيق FastAPI
 app = FastAPI()
 
@@ -97,6 +123,9 @@ async def startup_event():
     logger.info("🚀 بدء تحميل النموذج في الخلفية...")
     model_loading_thread = threading.Thread(target=load_model_in_background, daemon=True)
     model_loading_thread.start()
+    
+    # بدء مراقبة الموارد بعد إنشاء التطبيق
+    start_monitoring_thread()
 
 # نموذج الطلب والرد
 class ChatRequest(BaseModel):
@@ -107,31 +136,6 @@ class ChatResponse(BaseModel):
     response: str
     updated_history: list[list[str]]
 
-# تنسيق prompt الدردشة
-def format_chat(history, new_message):
-    messages = [("system", SYSTEM_PROMPT)]
-
-    for item in history[-8:]:
-        if isinstance(item, list) and len(item) == 2:
-            user_msg, bot_msg = item
-            messages.append(("user", user_msg))
-            messages.append(("assistant", bot_msg))
-        else:
-            logger.warning(f"⚠️ عنصر غير متوافق في التاريخ: {item}")
-
-    messages.append(("user", new_message))
-
-    formatted = []
-    for role, content in messages:
-        if role == "system":
-            formatted.append(f"<|im_start|>system\n{content}<|im_end|>")
-        elif role == "user":
-            formatted.append(f"<|im_start|>user\n{content}<|im_end|>")
-        else:
-            formatted.append(f"<|im_start|>assistant\n{content}<|im_end|>")
-    formatted.append("<|im_start|>assistant\n")
-    return "\n".join(formatted)
-
 # التحقق من حالة النموذج
 @app.get("/model-status")
 def model_status():
@@ -157,7 +161,7 @@ def chat(req: ChatRequest):
     logger.info(f"📩 طلب جديد من جلسة {req.session_id}: {req.message}")
     try:
         history = get_history(req.session_id)
-        logger.info(f"📜 التاريخ الحالي:\n{history}")
+        logger.info(f"📜 التاريخ الحالي: {len(history)} رسائل")
         prompt = format_chat(history, req.message)
 
         output = llm(
@@ -187,16 +191,27 @@ def chat(req: ChatRequest):
 def root():
     return {"message": "الخادم يعمل", "status": "ok"}
 
-# ✅ endpoint جديد: قراءة سجل مراقبة الموارد
+# endpoint قراءة سجل مراقبة الموارد
 @app.get("/monitor-log")
 def read_monitor_log():
-    log_path = "data/monitor.log"
+    import os
+    # استخدام المسار المطلق للتأكد من العثور على الملف
+    base_dir = os.path.dirname(os.path.abspath(__file__))
+    log_path = os.path.join(base_dir, "data", "monitor.log")
+    
     if not os.path.exists(log_path):
-        raise HTTPException(status_code=404, detail="لم يتم العثور على ملف السجل")
+        raise HTTPException(
+            status_code=404,
+            detail=f"لم يتم العثور على ملف السجل في المسار: {log_path}"
+        )
+    
     try:
-        with open(log_path, encoding="utf-8") as f:
+        with open(log_path, "r", encoding="utf-8") as f:
             content = f.read()
         return {"log": content}
     except Exception as e:
         logger.error(f"❌ فشل قراءة سجل المراقبة: {str(e)}")
-        raise HTTPException(status_code=500, detail="حدث خطأ أثناء قراءة السجل")
+        raise HTTPException(
+            status_code=500,
+            detail=f"حدث خطأ أثناء قراءة السجل: {str(e)}"
+        )

data/main.py

@@ -1,9 +1,26 @@
 import logging
+import os
+
+# إعداد السجل قبل الاستيرادات الأخرى
+logging.basicConfig(
+    level=logging.DEBUG,
+    format="🪵 [%(asctime)s] [%(levelname)s] %(message)s",
+    handlers=[
+        logging.StreamHandler(),
+        logging.FileHandler("app.log")
+    ]
+)
 logger = logging.getLogger(__name__)
 
 try:
     from app import app
     logger.info("✅ استيراد app من app.py ناجح")
+    
+    # التأكد من وجود مجلد البيانات
+    data_dir = os.path.join(os.path.dirname(os.path.abspath(__file__)), "data")
+    os.makedirs(data_dir, exist_ok=True)
+    logger.info(f"📁 مجلد البيانات جاهز: {data_dir}")
+    
 except ImportError as e:
     logger.error(f"❌ فشل استيراد app من app.py: {str(e)}")
     raise

data/memory.py

@@ -5,7 +5,8 @@ import logging
 
 logger = logging.getLogger(__name__)
 
-DB_DIR = os.path.join(os.path.dirname(os.path.abspath(__file__)), "data")
+base_dir = os.path.dirname(os.path.abspath(__file__))
+DB_DIR = os.path.join(base_dir, "data")
 DB_PATH = os.path.join(DB_DIR, "chat_memory.db")
 
 os.makedirs(DB_DIR, exist_ok=True)
@@ -21,6 +22,7 @@ try:
     ''')
     conn.commit()
     conn.close()
+    logger.info(f"✅ تم إنشاء/فتح قاعدة البيانات في: {DB_PATH}")
 except sqlite3.Error as e:
     logger.error(f"❌ خطأ في إنشاء قاعدة البيانات: {str(e)}")
 
@@ -39,7 +41,7 @@ def get_history(session_id: str):
         if isinstance(data, list) and all(isinstance(pair, list) and len(pair) == 2 for pair in data):
             return data
         else:
-            logger.warning(f"⚠️ تم تجاهل تاريخ غير متوافق: {data}")
+            logger.warning(f"⚠️ تم تجاهل تاريخ غير متوافق: {type(data)}")
             return []
     except Exception as e:
         logger.error(f"❌ خطأ أثناء استرجاع التاريخ: {str(e)}")
@@ -52,8 +54,8 @@ def save_history(session_id: str, history: list):
         c.execute(
             "REPLACE INTO memory (session_id, history) VALUES (?, ?)",
             (session_id, json.dumps(history))
-        )
         conn.commit()
         conn.close()
+        logger.debug(f"💾 تم حفظ التاريخ للجلسة: {session_id}")
     except Exception as e:
-        logger.error(f"❌ خطأ أثناء حفظ التاريخ: {str(e)}")
+        logger.error(f"❌ خطأ أثناء حفظ التاريخ: {str(e)}")

data/monitor.py

@@ -1,71 +1,83 @@
-import threading
-import time
-import psutil
-import logging
-from collections import deque
-import os
-import tracemalloc
-
-logger = logging.getLogger("monitor")
-
-# إعداد ملف السجل
-log_path = "data/monitor.log"
-os.makedirs("data", exist_ok=True)
-file_handler = logging.FileHandler(log_path)
-file_handler.setLevel(logging.DEBUG)
-formatter = logging.Formatter("📁 [%(asctime)s] [%(levelname)s] %(message)s")
-file_handler.setFormatter(formatter)
-logger.addHandler(file_handler)
-
-# تفعيل تتبع الذاكرة
-tracemalloc.start()
-
-# تخزين آخر 10 قياسات
-cpu_history = deque(maxlen=10)
-mem_history = deque(maxlen=10)
-current_metrics = {'cpu': 0, 'memory': 0}
-
-def monitor_resources():
-    counter = 0
-    logger.info("🔁 بدأ تشغيل monitor_resources()")
-    while True:
-        try:
-            process = psutil.Process(os.getpid())
-            mem_info = process.memory_info()
-            cpu_percent = psutil.cpu_percent(interval=None)
-            mem_percent = psutil.virtual_memory().percent
-
-            current_metrics['cpu'] = cpu_percent
-            current_metrics['memory'] = mem_percent
-            cpu_history.append(cpu_percent)
-            mem_history.append(mem_percent)
-
-            logger.info(f"🧠 RSS: {mem_info.rss / 1024**2:.2f} MB | VMS: {mem_info.vms / 1024**2:.2f} MB")
-            current, peak = tracemalloc.get_traced_memory()
-            logger.info(f"📊 tracemalloc: Current = {current / 1024**2:.2f} MB | Peak = {peak / 1024**2:.2f} MB")
-
-            counter += 1
-            if counter % 12 == 0:
-                snapshot = tracemalloc.take_snapshot()
-                top_stats = snapshot.statistics('lineno')
-                logger.info("📌 أعلى 5 أسطر استهلاكًا للذاكرة:")
-                for stat in top_stats[:5]:
-                    logger.info(stat)
-
-        except Exception as e:
-            logger.exception(f"❌ استثناء في مراقبة الموارد: {str(e)}")
-
-        time.sleep(5)
-
-def get_current_metrics():
-    return {
-        'cpu': current_metrics['cpu'],
-        'memory': current_metrics['memory'],
-        'cpu_history': list(cpu_history),
-        'mem_history': list(mem_history)
-    }
-
-def start_monitoring_thread():
-    thread = threading.Thread(target=monitor_resources, daemon=True)
-    thread.start()
-    logger.info("✅ تم بدء مراقبة الموارد في خيط منفصل")
+import threading
+import time
+import psutil
+import logging
+from collections import deque
+import os
+import tracemalloc
+
+# إنشاء logger خاص لهذه الوحدة
+logger = logging.getLogger("monitor")
+logger.setLevel(logging.DEBUG)
+
+# إعداد ملف السجل
+base_dir = os.path.dirname(os.path.abspath(__file__))
+log_dir = os.path.join(base_dir, "data")
+os.makedirs(log_dir, exist_ok=True)
+log_path = os.path.join(log_dir, "monitor.log")
+
+# إعداد handler لملف السجل
+file_handler = logging.FileHandler(log_path)
+file_handler.setLevel(logging.DEBUG)
+formatter = logging.Formatter("📁 [%(asctime)s] [%(levelname)s] %(message)s")
+file_handler.setFormatter(formatter)
+logger.addHandler(file_handler)
+
+# إعداد handler للوحدة الأساسية (اختياري)
+stream_handler = logging.StreamHandler()
+stream_handler.setFormatter(logging.Formatter("🪵 [%(asctime)s] [%(levelname)s] %(message)s"))
+logger.addHandler(stream_handler)
+
+# تفعيل تتبع الذاكرة
+tracemalloc.start()
+logger.info("🔍 بدأ تتبع الذاكرة")
+
+# تخزين آخر 10 قياسات
+cpu_history = deque(maxlen=10)
+mem_history = deque(maxlen=10)
+current_metrics = {'cpu': 0, 'memory': 0}
+
+def monitor_resources():
+    counter = 0
+    logger.info("🔁 بدأ تشغيل مراقبة الموارد")
+    while True:
+        try:
+            process = psutil.Process(os.getpid())
+            mem_info = process.memory_info()
+            cpu_percent = psutil.cpu_percent(interval=0.5)
+            mem_percent = psutil.virtual_memory().percent
+
+            current_metrics['cpu'] = cpu_percent
+            current_metrics['memory'] = mem_percent
+            cpu_history.append(cpu_percent)
+            mem_history.append(mem_percent)
+
+            logger.info(f"🧠 الذاكرة - RSS: {mem_info.rss / 1024**2:.2f} MB | VMS: {mem_info.vms / 1024**2:.2f} MB")
+            current, peak = tracemalloc.get_traced_memory()
+            logger.info(f"📊 tracemalloc - الحالي: {current / 1024**2:.2f} MB | الأعلى: {peak / 1024**2:.2f} MB")
+
+            counter += 1
+            if counter % 12 == 0:
+                snapshot = tracemalloc.take_snapshot()
+                top_stats = snapshot.statistics('lineno')
+                logger.info("📌 أعلى 5 أسطر استهلاكًا للذاكرة:")
+                for stat in top_stats[:5]:
+                    logger.info(f"   {stat}")
+
+        except Exception as e:
+            logger.exception(f"❌ استثناء في مراقبة الموارد: {str(e)}")
+
+        time.sleep(5)
+
+def get_current_metrics():
+    return {
+        'cpu': current_metrics['cpu'],
+        'memory': current_metrics['memory'],
+        'cpu_history': list(cpu_history),
+        'mem_history': list(mem_history)
+    }
+
+def start_monitoring_thread():
+    thread = threading.Thread(target=monitor_resources, daemon=True)
+    thread.start()
+    logger.info("✅ تم بدء مراقبة الموارد في خيط منفصل")