Update app.py

app.py

@@ -7,13 +7,14 @@ import time
 from datetime import datetime
 import logging
 import re
+import os
 
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
 app = FastAPI(title="Windows AI Controller - الخادم المركزي الحقيقي")
 
-# تمكين CORS للسماح بالاتصال من تطبيقات Windows
+# تمكين CORS للسماح بالاتصال من تطبيبات Windows
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
@@ -22,11 +23,18 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
-# تخزين البيانات
+# تخزين البيانات - نظام الذاكرة الكامل
 pending_commands = {}
 client_results = {}
 connected_clients = {}
 
+# نظام الذاكرة الجديد
+client_memories = {}  # ذاكرة المحادثات لكل عميل
+game_analysis_memory = {}  # ذاكرة تحليل الألعاب
+system_info_memory = {}  # ذاكرة معلومات النظام
+installed_programs_memory = {}  # ذاكرة البرامج المثبتة
+action_history_memory = {}  # سجل الإجراءات
+
 class WindowsCommand(BaseModel):
     command_type: str
     target_game: Optional[str] = None
@@ -60,6 +68,12 @@ class ClientRegistration(BaseModel):
     timestamp: str
     agent_type: str
 
+class MemoryEntry(BaseModel):
+    timestamp: str
+    type: str  # conversation, game_analysis, system_info, action_result, installed_programs
+    data: Dict[str, Any]
+    client_id: str
+
 def update_client_activity(client_id: str, activity: str = "chat"):
     """تحديث نشاط العميل"""
     connected_clients[client_id] = {
@@ -70,15 +84,157 @@ def update_client_activity(client_id: str, activity: str = "chat"):
     }
     logger.info(f"📊 تم تحديث نشاط العميل {client_id}: {activity}")
 
+def save_to_memory(client_id: str, memory_type: str, data: Dict[str, Any]):
+    """حفظ البيانات في الذاكرة"""
+    if client_id not in client_memories:
+        client_memories[client_id] = []
+    
+    memory_entry = {
+        "timestamp": datetime.now().isoformat(),
+        "type": memory_type,
+        "data": data,
+        "client_id": client_id
+    }
+    
+    client_memories[client_id].append(memory_entry)
+    
+    # حفظ فقط آخر 1000 إدخال لكل عميل لمنع استهلاك الذاكرة
+    if len(client_memories[client_id]) > 1000:
+        client_memories[client_id] = client_memories[client_id][-1000:]
+    
+    logger.info(f"💾 تم حفظ بيانات في الذاكرة للعميل {client_id}: {memory_type}")
+
+def get_client_memory(client_id: str, memory_type: str = None, limit: int = 10):
+    """استرجاع الذاكرة للعميل"""
+    if client_id not in client_memories:
+        return []
+    
+    memories = client_memories[client_id]
+    
+    if memory_type:
+        memories = [m for m in memories if m["type"] == memory_type]
+    
+    return memories[-limit:]
+
+def save_game_analysis(client_id: str, game_name: str, analysis_data: Dict[str, Any]):
+    """حفظ تحليل اللعبة في الذاكرة"""
+    if client_id not in game_analysis_memory:
+        game_analysis_memory[client_id] = {}
+    
+    if game_name not in game_analysis_memory[client_id]:
+        game_analysis_memory[client_id][game_name] = []
+    
+    analysis_entry = {
+        "timestamp": datetime.now().isoformat(),
+        "analysis_data": analysis_data,
+        "client_id": client_id
+    }
+    
+    game_analysis_memory[client_id][game_name].append(analysis_entry)
+    
+    # أيضا حفظ في الذاكرة العامة
+    save_to_memory(client_id, "game_analysis", {
+        "game_name": game_name,
+        "analysis_data": analysis_data
+    })
+    
+    logger.info(f"🎮 تم حفظ تحليل اللعبة {game_name} للعميل {client_id}")
+
+def get_game_analysis(client_id: str, game_name: str = None):
+    """استرجاع تحليل الألعاب"""
+    if client_id not in game_analysis_memory:
+        return {}
+    
+    if game_name:
+        return game_analysis_memory[client_id].get(game_name, [])
+    else:
+        return game_analysis_memory[client_id]
+
+def save_system_info(client_id: str, system_info: Dict[str, Any]):
+    """حفظ معلومات النظام"""
+    system_info_memory[client_id] = {
+        "timestamp": datetime.now().isoformat(),
+        "system_info": system_info
+    }
+    
+    # أيضا حفظ في الذاكرة العامة
+    save_to_memory(client_id, "system_info", system_info)
+    
+    logger.info(f"💻 تم حفظ معلومات النظام للعميل {client_id}")
+
+def get_system_info(client_id: str):
+    """استرجاع معلومات النظام"""
+    return system_info_memory.get(client_id, {})
+
+def save_installed_programs(client_id: str, programs_data: Dict[str, Any]):
+    """حفظ البرامج المثبتة"""
+    installed_programs_memory[client_id] = {
+        "timestamp": datetime.now().isoformat(),
+        "programs": programs_data
+    }
+    
+    # أيضا حفظ في الذاكرة العامة
+    save_to_memory(client_id, "installed_programs", programs_data)
+    
+    logger.info(f"📦 تم حفظ بيانات البرامج المثبتة للعميل {client_id}")
+
+def get_installed_programs(client_id: str):
+    """استرجاع البرامج المثبتة"""
+    return installed_programs_memory.get(client_id, {})
+
+def save_action_history(client_id: str, action_data: Dict[str, Any]):
+    """حفظ سجل الإجراءات"""
+    if client_id not in action_history_memory:
+        action_history_memory[client_id] = []
+    
+    action_entry = {
+        "timestamp": datetime.now().isoformat(),
+        "action_data": action_data
+    }
+    
+    action_history_memory[client_id].append(action_entry)
+    
+    # أيضا حفظ في الذاكرة العامة
+    save_to_memory(client_id, "action_history", action_data)
+    
+    logger.info(f"📝 تم حفظ إجراء في السجل للعميل {client_id}: {action_data.get('action_type', 'unknown')}")
+
+def get_action_history(client_id: str, limit: int = 20):
+    """استرجاع سجل الإجراءات"""
+    if client_id not in action_history_memory:
+        return []
+    
+    return action_history_memory[client_id][-limit:]
+
+def extract_file_name(file_path: str) -> str:
+    """استخراج اسم الملف من المسار - الإصلاح هنا"""
+    try:
+        if '/' in file_path:
+            return file_path.split('/')[-1]
+        elif '\\' in file_path:
+            return file_path.split('\\')[-1]
+        else:
+            return file_path
+    except Exception:
+        return file_path
+
 @app.get("/")
 async def root():
+    total_memories = sum(len(memories) for memories in client_memories.values())
     return {
         "status": "running",
-        "service": "Windows AI Controller Server - النسخة الحقيقية",
+        "service": "Windows AI Controller Server - النسخة الحقيقية مع الذاكرة",
         "timestamp": datetime.now().isoformat(),
         "connected_clients": len(connected_clients),
         "pending_commands": len(pending_commands),
-        "active_clients": list(connected_clients.keys())
+        "active_clients": list(connected_clients.keys()),
+        "total_memories": total_memories,
+        "memory_stats": {
+            "conversations": total_memories,
+            "game_analyses": sum(len(analyses) for analyses in game_analysis_memory.values()),
+            "system_info": len(system_info_memory),
+            "installed_programs": len(installed_programs_memory)
+        }
     }
 
 @app.post("/api/chat")
@@ -88,6 +244,13 @@ async def chat_with_ai(request: ChatRequest):
         logger.info(f"💬 طلب محادثة من العميل {request.client_id}: {request.message}")
         update_client_activity(request.client_id, "chat")
         
+        # حفظ المحادثة في الذاكرة
+        save_to_memory(request.client_id, "conversation", {
+            "user_message": request.message,
+            "timestamp": request.timestamp,
+            "direction": "incoming"
+        })
+        
         user_message = request.message.lower()
         
         # تحليل الطلب وتحديد الإجراءات الحقيقية
@@ -107,6 +270,8 @@ async def chat_with_ai(request: ChatRequest):
             return await handle_tool_installation(request)
         elif "مرحبا" in user_message or "اهلا" in user_message or "hello" in user_message:
             return await handle_welcome(request)
+        elif "الذاكرة" in user_message or "memory" in user_message:
+            return await handle_memory_query(request)
         else:
             return await handle_general_request(request)
             
@@ -120,14 +285,15 @@ async def handle_scan_programs(request: ChatRequest):
     
     response = ChatResponse(
         thinking_process=thinking,
-        message="🔍 **جاري مسح البرامج المثبتة على جهازك...**\n\nسيقوم الوكيل التنفيذي بمسح شامل لجميع البرامج المثبتة وعرضها لك.",
+        message="🔍 **جاري مسح البرامج المثبتة على جهازك...**\n\nسيقوم الوكيل التنفيذي بمسح شامل لجميع البرامج المثبتة وحفظها في الذاكرة الدائمة.",
         actions=[
             {
                 "type": "scan_installed_programs",
                 "description": "مسح شامل للبرامج المثبتة على النظام",
                 "parameters": {
                     "scan_type": "comprehensive",
-                    "include_versions": True
+                    "include_versions": True,
+                    "save_to_memory": True
                 }
             }
         ]
@@ -140,14 +306,15 @@ async def handle_scan_processes(request: ChatRequest):
     
     response = ChatResponse(
         thinking_process=thinking,
-        message="⚡ **جاري مسح العمليات الن��طة على جهازك...**\n\nعرض جميع العمليات الجارية حالياً مع التركيز على عمليات الألعاب.",
+        message="⚡ **جاري مسح العمليات النشطة على جهازك...**\n\nعرض جميع العمليات الجارية حالياً مع التركيز على عمليات الألعاب وحفظها في الذاكرة.",
         actions=[
             {
                 "type": "scan_running_processes",
                 "description": "مسح العمليات النشطة على النظام",
                 "parameters": {
                     "include_memory_usage": True,
-                    "detect_games": True
+                    "detect_games": True,
+                    "save_to_memory": True
                 }
             }
         ]
@@ -174,25 +341,30 @@ async def handle_reverse_engineering(request: ChatRequest):
             ]
         )
     else:
+        # استخراج اسم الملف فقط للعرض - الإصلاح هنا
+        file_name = extract_file_name(file_path)
+        
         response = ChatResponse(
             thinking_process=thinking + f" تم تحديد المسار: {file_path}. جاري إعداد أدوات الهندسة العكسية.",
-            message=f"🔬 **جاري تحضير الهندسة العكسية لـ**: `{file_path}`\n\nسيقوم النظام بتحليل الملف بشكل كامل واستخراج جميع المعلومات الممكنة.",
+            message=f"🔬 **جاري تحضير الهندسة العكسية لـ**: `{file_path}`\n\nسيقوم النظام بتحليل الملف بشكل كامل واستخراج جميع المعلومات الممكنة وحفظها في الذاكرة.",
             actions=[
                 {
                     "type": "reverse_engineer",
-                    "description": f"هندسة عكسية متقدمة للملف {file_path.split('/')[-1] if '/' in file_path else file_path.split('\\\\')[-1]}",
+                    "description": f"هندسة عكسية متقدمة للملف {file_name}",
                     "parameters": {
                         "file_path": file_path,
                         "analysis_depth": "deep",
                         "extract_resources": True,
-                        "analyze_imports": True
+                        "analyze_imports": True,
+                        "save_to_memory": True
                     }
                 },
                 {
                     "type": "analyze_game_file",
                     "description": f"تحليل بنية ملف اللعبة",
                     "parameters": {
-                        "file_path": file_path
+                        "file_path": file_path,
+                        "save_to_memory": True
                     }
                 }
             ]
@@ -221,8 +393,8 @@ async def handle_bot_development(request: ChatRequest):
         )
     else:
         response = ChatResponse(
-            thinking_process=thinking + f" تطوير بوت {bot_type} للعبة {game_name}.",
-            message=f"🚀 **بدء تطوير بوت {bot_type} للعبة {game_name}**\n\nجاري:\n• تصميم هيكل البوت\n• إعداد مكتبات الأتمتة\n• تطوير الخوارزميات الأساسية\n• إنشاء كود البوت الكامل",
+            thinking_process=thinking + f" تطوير بوت {bot_type} للعبة {game_name}. سيتم حفظ تفاصيل البوت في الذاكرة.",
+            message=f"🚀 **بدء تطوير بوت {bot_type} للعبة {game_name}**\n\nجاري:\n• تصميم هيكل البوت\n• إعداد مكتبات الأتمتة\n• تطوير الخوارزميات الأساسية\n• إنشاء كود البوت الكامل\n• حفظ التفاصيل في الذاكرة الدائمة",
             actions=[
                 {
                     "type": "develop_bot",
@@ -230,14 +402,16 @@ async def handle_bot_development(request: ChatRequest):
                     "parameters": {
                         "game_name": game_name,
                         "bot_type": bot_type,
-                        "features": ["auto_detection", "memory_control", "image_recognition", "screen_capture"]
+                        "features": ["auto_detection", "memory_control", "image_recognition", "screen_capture"],
+                        "save_to_memory": True
                     }
                 },
                 {
                     "type": "install_tool",
                     "description": "تثبيت أدوات تطوير البوت",
                     "parameters": {
-                        "tool_name": "python"
+                        "tool_name": "python",
+                        "save_to_memory": True
                     }
                 }
             ]
@@ -247,17 +421,18 @@ async def handle_bot_development(request: ChatRequest):
 
 async def handle_screenshot(request: ChatRequest):
     """معالجة طلب تصوير الشاشة"""
-    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يطلب تصوير شاشة جهازه. إعداد أمر التقاط الصورة."
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يطلب تصوير شاشة جهازه. إعداد أمر التقاط الصورة وحفظها في الذاكرة."
     
     response = ChatResponse(
         thinking_process=thinking,
-        message="📸 **جاري التقاط صورة لشاشة جهازك...**\n\nسيتم حفظ الصورة في مجلد البوتات.",
+        message="📸 **جاري التقاط صورة لشاشة جهازك...**\n\nسيتم حفظ الصورة في مجلد البوتات وتخزين معلوماتها في الذاكرة.",
         actions=[
             {
                 "type": "take_screenshot",
                 "description": "التقاط صورة للشاشة الحالية",
                 "parameters": {
-                    "save_path": f"screenshots/screen_{datetime.now().strftime('%Y%m%d_%H%M%S')}.png"
+                    "save_path": f"screenshots/screen_{datetime.now().strftime('%Y%m%d_%H%M%S')}.png",
+                    "save_to_memory": True
                 }
             }
         ]
@@ -278,15 +453,16 @@ async def handle_memory_scan(request: ChatRequest):
         )
     else:
         response = ChatResponse(
-            thinking_process=thinking + f" مسح ذاكرة العملية: {process_name}",
-            message=f"🔍 **جاري مسح ذاكرة اللعبة**: {process_name}\n\nالبحث عن القيم القابلة للتعديل مثل المال، الصحة، الذخيرة...",
+            thinking_process=thinking + f" مسح ذاكرة العملية: {process_name}. سيتم حفظ النتائج في الذاكرة.",
+            message=f"🔍 **جاري مسح ذاكرة اللعبة**: {process_name}\n\nالبحث عن القيم القابلة للتعديل مثل المال، الصحة، الذخيرة... وحفظ النتائج في الذاكرة الدائمة.",
             actions=[
                 {
                     "type": "scan_game_memory",
                     "description": f"مسح ذاكرة العملية {process_name}",
                     "parameters": {
                         "process_name": process_name,
-                        "scan_for": ["money", "health", "ammo", "experience"]
+                        "scan_for": ["money", "health", "ammo", "experience"],
+                        "save_to_memory": True
                     }
                 }
             ]
@@ -308,14 +484,15 @@ async def handle_tool_installation(request: ChatRequest):
         )
     else:
         response = ChatResponse(
-            thinking_process=thinking + f" تثبيت الأداة: {tool_name}",
-            message=f"📥 **جاري تثبيت الأداة**: {tool_name}\n\nسيتم تحضير البيئة اللازمة للعمل.",
+            thinking_process=thinking + f" تثبيت الأداة: {tool_name}. سيتم حفظ حالة التثبيت في الذاكرة.",
+            message=f"📥 **جاري تثبيت الأداة**: {tool_name}\n\nسيتم تحضير البيئة اللازمة للعمل وحفظ حالة التثبيت في الذاكرة.",
             actions=[
                 {
                     "type": "install_tool",
                     "description": f"تثبيت أداة {tool_name}",
                     "parameters": {
-                        "tool_name": tool_name
+                        "tool_name": tool_name,
+                        "save_to_memory": True
                     }
                 }
             ]
@@ -325,11 +502,27 @@ async def handle_tool_installation(request: ChatRequest):
 
 async def handle_welcome(request: ChatRequest):
     """معالجة رسالة الترحيب"""
-    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يرسل تحية. الترحيب به وعرض الميزات الحقيقية."
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يرسل تحية. الترحيب به وعرض الميزات الحقيقية ونظام الذاكرة."
+    
+    # استرجاع إحصائيات الذاكرة للعميل
+    memory_stats = await get_memory_stats_for_client(request.client_id)
     
     response = ChatResponse(
         thinking_process=thinking,
-        message="🧠 **مرحباً بك في النظام الحقيقي المتكامل!**\n\n🚀 **الميزات الحقيقية الجاهزة للتنفيذ على جهازك:**\n\n• 🔍 **مسح شامل** للبرامج والعمليات\n• 🎮 **تحليل الذاكرة** للألعاب والتعديل\n• 🤖 **تطوير بوتات** كاملة وتجربتها\n• 🔬 **هندسة عكسية** متقدمة للملفات\n• 📸 **تصوير الشاشة** والتسجيل\n• ⚡ **تثبيت أدوات** متخصصة\n\n💡 **ما المهمة التي تريد ال��دء بها؟**",
+        message=f"🧠 **مرحباً بك في النظام الحقيقي المتكامل مع الذاكرة الدائمة!**\n\n"
+               f"💾 **حالة ذاكرتك الحالية:**\n"
+               f"• المحادثات: {memory_stats['conversations']}\n"
+               f"• تحليلات الألعاب: {memory_stats['game_analyses']}\n"
+               f"• الإجراءات: {memory_stats['actions']}\n\n"
+               f"🚀 **الميزات الحقيقية الجاهزة للتنفيذ على جهازك:**\n\n"
+               f"• 🔍 **مسح شامل** للبرامج والعمليات\n"
+               f"• 🎮 **تحليل الذاكرة** للألعاب والتعديل\n"
+               f"• 🤖 **تطوير بوتات** كاملة وتجربتها\n"
+               f"• 🔬 **هندسة عكسية** متقدمة للملفات\n"
+               f"• 📸 **تصوير الشاشة** والتسجيل\n"
+               f"• ⚡ **تثبيت أدوات** متخصصة\n\n"
+               f"💡 **كل شيء يتم حفظه تلقائياً في الذاكرة الدائمة!**\n\n"
+               f"ما المهمة التي تريد البدء بها؟",
         actions=[
             {
                 "type": "welcome",
@@ -340,26 +533,74 @@ async def handle_welcome(request: ChatRequest):
     )
     return response
 
+async def handle_memory_query(request: ChatRequest):
+    """معالجة استعلامات الذاكرة"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يطلب معلومات عن الذاكرة. تجهيز إحصائيات الذاكرة."
+    
+    memory_stats = await get_memory_stats_for_client(request.client_id)
+    
+    response = ChatResponse(
+        thinking_process=thinking,
+        message=f"💾 **نظام الذاكرة الدائمة - إحصائياتك:**\n\n"
+               f"📊 **التفاصيل:**\n"
+               f"• المحادثات المحفوظة: {memory_stats['conversations']}\n"
+               f"• تحليلات الألعاب: {memory_stats['game_analyses']}\n"
+               f"• معلومات النظام: {memory_stats['system_info']}\n"
+               f"• البرامج المثبتة: {memory_stats['installed_programs']}\n"
+               f"• سجل الإجراءات: {memory_stats['actions']}\n\n"
+               f"🔍 **آخر 5 محادثات:**\n{memory_stats['recent_conversations']}\n\n"
+               f"🎮 **الألعاب التي تم تحليلها:** {memory_stats['games_analyzed']}",
+        actions=[]
+    )
+    return response
+
 async def handle_general_request(request: ChatRequest):
     """معالجة الطلبات العامة"""
-    thinking = "🤔 **التفكير الاستراتيجي**: تحليل الطلب العام للمستخدم وتحديد أفضل الإجراءات المناسبة."
+    thinking = "🤔 **التفكير الاستراتيجي**: تحليل الطلب العام للمستخدم وتحديد أفضل الإجراءات المناسبة مع حفظ النتائج في الذاكرة."
     
     response = ChatResponse(
         thinking_process=thinking,
-        message="🧠 **فهمت طلبك!**\n\nسأقوم بمساعدتك في هذه المهمة باستخدام النظام الحقيقي المتكامل.\n\n💡 **جاري تحليل متطلباتك وإعداد الحل المناسب...**",
+        message="🧠 **فهمت طلبك!**\n\nسأقوم بمساعدتك في هذه المهمة باستخدام النظام الحقيقي المتكامل مع الذاكرة الدائمة.\n\n💡 **جاري تحليل متطلباتك وإعداد الحل المناسب مع حفظ كل التفاصيل في الذاكرة...**",
         actions=[
             {
                 "type": "general_analysis",
                 "description": "تحليل المهمة العامة وتحديد المتطلبات",
                 "parameters": {
                     "user_message": request.message,
-                    "analysis_type": "comprehensive"
+                    "analysis_type": "comprehensive",
+                    "save_to_memory": True
                 }
             }
         ]
     )
     return response
 
+async def get_memory_stats_for_client(client_id: str):
+    """الحصول على إحصائيات الذاكرة للعميل"""
+    conversations = len(get_client_memory(client_id, "conversation"))
+    game_analyses = len(get_client_memory(client_id, "game_analysis"))
+    system_info = 1 if client_id in system_info_memory else 0
+    installed_programs = 1 if client_id in installed_programs_memory else 0
+    actions = len(get_action_history(client_id))
+    
+    # آخر 5 محادثات
+    recent_convos = get_client_memory(client_id, "conversation", 5)
+    recent_text = "\n".join([f"• {conv['data'].get('user_message', '')[:50]}..." for conv in recent_convos])
+    
+    # الألعاب التي تم تحليلها
+    games_analyzed = list(get_game_analysis(client_id).keys())
+    games_text = ", ".join(games_analyzed) if games_analyzed else "لا توجد"
+    
+    return {
+        "conversations": conversations,
+        "game_analyses": game_analyses,
+        "system_info": system_info,
+        "installed_programs": installed_programs,
+        "actions": actions,
+        "recent_conversations": recent_text,
+        "games_analyzed": games_text
+    }
+
 def extract_file_path(message: str) -> str:
     """استخراج مسار الملف من الرسالة"""
     # البحث عن أنماط المسارات في النص
@@ -446,6 +687,154 @@ def extract_tool_name(message: str) -> str:
     
     return ""
 
+# نقاط النهاية الجديدة للذاكرة
+@app.get("/api/memory/{client_id}")
+async def get_client_memory_endpoint(client_id: str, memory_type: str = None, limit: int = 10):
+    """الحصول على ذاكرة العميل"""
+    try:
+        memories = get_client_memory(client_id, memory_type, limit)
+        return {
+            "success": True,
+            "client_id": client_id,
+            "memories": memories,
+            "total": len(memories)
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في استرجاع الذاكرة: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.get("/api/game-analysis/{client_id}")
+async def get_game_analysis_endpoint(client_id: str, game_name: str = None):
+    """الحصول على تحليل الألعاب"""
+    try:
+        analysis = get_game_analysis(client_id, game_name)
+        return {
+            "success": True,
+            "client_id": client_id,
+            "game_analysis": analysis
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في استرجاع تحليل الألعاب: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.post("/api/save-system-info/{client_id}")
+async def save_system_info_endpoint(client_id: str, system_info: Dict[str, Any]):
+    """حفظ معلومات النظام"""
+    try:
+        save_system_info(client_id, system_info)
+        return {
+            "success": True,
+            "message": "تم حفظ معلومات النظام بنجاح"
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في حفظ معلومات النظام: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.get("/api/system-info/{client_id}")
+async def get_system_info_endpoint(client_id: str):
+    """الحصول على معلومات النظام"""
+    try:
+        system_info = get_system_info(client_id)
+        return {
+            "success": True,
+            "client_id": client_id,
+            "system_info": system_info
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في استرجاع معلومات النظام: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.post("/api/save-installed-programs/{client_id}")
+async def save_installed_programs_endpoint(client_id: str, programs_data: Dict[str, Any]):
+    """حفظ البرامج المثبتة"""
+    try:
+        save_installed_programs(client_id, programs_data)
+        return {
+            "success": True,
+            "message": "تم حفظ بيانات البرامج المثبتة بنجاح"
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في حفظ البرامج المثبتة: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.get("/api/installed-programs/{client_id}")
+async def get_installed_programs_endpoint(client_id: str):
+    """الحصول على البرامج المثبتة"""
+    try:
+        programs = get_installed_programs(client_id)
+        return {
+            "success": True,
+            "client_id": client_id,
+            "installed_programs": programs
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في استرجاع البرامج المثبتة: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.post("/api/save-action-result/{client_id}")
+async def save_action_result_endpoint(client_id: str, action_result: Dict[str, Any]):
+    """حفظ نتيجة الإجراء في الذاكرة"""
+    try:
+        save_action_history(client_id, action_result)
+        return {
+            "success": True,
+            "message": "تم حفظ نتيجة الإجراء بنجاح"
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في حفظ نتيجة الإجراء: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.get("/api/action-history/{client_id}")
+async def get_action_history_endpoint(client_id: str, limit: int = 20):
+    """الحصول على سجل الإجراءات"""
+    try:
+        history = get_action_history(client_id, limit)
+        return {
+            "success": True,
+            "client_id": client_id,
+            "action_history": history,
+            "total": len(history)
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في استرجاع سجل الإجراءات: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+@app.get("/api/memory-stats")
+async def get_memory_stats_endpoint():
+    """إحصائيات الذاكرة"""
+    total_memories = sum(len(memories) for memories in client_memories.values())
+    total_clients = len(client_memories)
+    total_game_analyses = sum(len(analyses) for analyses in game_analysis_memory.values())
+    total_system_info = len(system_info_memory)
+    total_installed_programs = len(installed_programs_memory)
+    
+    return {
+        "success": True,
+        "total_memories": total_memories,
+        "total_clients": total_clients,
+        "total_game_analyses": total_game_analyses,
+        "total_system_info": total_system_info,
+        "total_installed_programs": total_installed_programs,
+        "clients_with_memory": list(client_memories.keys()),
+        "timestamp": datetime.now().isoformat()
+    }
+
+@app.get("/api/client-memory-stats/{client_id}")
+async def get_client_memory_stats_endpoint(client_id: str):
+    """إحصائيات ذاكرة عميل محدد"""
+    try:
+        stats = await get_memory_stats_for_client(client_id)
+        return {
+            "success": True,
+            "client_id": client_id,
+            "memory_stats": stats,
+            "timestamp": datetime.now().isoformat()
+        }
+    except Exception as e:
+        logger.error(f"❌ خطأ في إحصائيات الذاكرة: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+# نقاط النهاية القديمة (محفوظة للتوافق)
 @app.post("/api/register-client")
 async def register_client(registration: ClientRegistration):
     """تسجيل عميل جديد"""
@@ -460,6 +849,14 @@ async def register_client(registration: ClientRegistration):
             "message_count": 0
         }
         
+        # حفظ معلومات النظام الأولية في الذاكرة
+        save_system_info(registration.client_id, {
+            "machine_name": registration.machine_name,
+            "os_version": registration.os_version,
+            "agent_type": registration.agent_type,
+            "first_seen": registration.timestamp
+        })
+        
         logger.info(f"🆕 عميل جديد مسجل: {registration.client_id} - {registration.machine_name}")
         
         return {
@@ -533,6 +930,14 @@ async def submit_result(result: ClientResult):
         
         update_client_activity(result.client_id, "result")
         
+        # حفظ نتيجة الإجراء في الذاكرة
+        save_action_history(result.client_id, {
+            "command_id": result.command_id,
+            "result": result.result,
+            "status": result.status,
+            "type": "action_result"
+        })
+        
         logger.info(f"📊 تم استلام نتيجة من العميل {result.client_id}")
         
         return {"success": True, "message": "تم استلام النتيجة بنجاح"}
@@ -544,12 +949,15 @@ async def submit_result(result: ClientResult):
 async def client_status(client_id: str):
     """الحصول على حالة العميل"""
     client_data = connected_clients.get(client_id, {})
+    memory_stats = await get_memory_stats_for_client(client_id)
+    
     return {
         "success": True,
         "client_id": client_id,
         "status": client_data.get("status", "offline"),
         "last_seen": client_data.get("last_seen"),
         "message_count": client_data.get("message_count", 0),
+        "memory_stats": memory_stats,
         "timestamp": datetime.now().isoformat()
     }
 
@@ -573,6 +981,8 @@ async def system_status():
         "active_clients": active_clients,
         "pending_commands": len(pending_commands),
         "total_results": len(client_results),
+        "total_memories": sum(len(memories) for memories in client_memories.values()),
+        "memory_system": "active",
         "server_time": datetime.now().isoformat()
     }
 
@@ -581,6 +991,10 @@ async def debug_clients():
     """تصحيح الأخطاء - عرض جميع العملاء"""
     return {
         "connected_clients": connected_clients,
+        "client_memories": {client_id: len(memories) for client_id, memories in client_memories.items()},
+        "game_analysis_memory": {client_id: len(analyses) for client_id, analyses in game_analysis_memory.items()},
+        "system_info_memory": list(system_info_memory.keys()),
+        "installed_programs_memory": list(installed_programs_memory.keys()),
         "total": len(connected_clients)
     }