Update app.py

app.py

@@ -6,11 +6,12 @@ import json
 import time
 from datetime import datetime
 import logging
+import re
 
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)
 
-app = FastAPI(title="Windows AI Controller - الخادم المركزي")
+app = FastAPI(title="Windows AI Controller - الخادم المركزي الحقيقي")
 
 # تمكين CORS للسماح بالاتصال من تطبيقات Windows
 app.add_middleware(
@@ -73,7 +74,7 @@ def update_client_activity(client_id: str, activity: str = "chat"):
 async def root():
     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),
@@ -82,65 +83,368 @@ async def root():
 
 @app.post("/api/chat")
 async def chat_with_ai(request: ChatRequest):
-    """نقطة النهاية للمحادثة مع الذكاء الاصطناعي"""
+    """نقطة النهاية للمحادثة مع الذكاء الاصطناعي - النسخة الحقيقية"""
     try:
         logger.info(f"💬 طلب محادثة من العميل {request.client_id}: {request.message}")
-        
-        # تحديث نشاط العميل فوراً
         update_client_activity(request.client_id, "chat")
         
-        # محاكاة استجابة من نموذج الذكاء الاصطناعي الحقيقي
-        thinking = f"🤔 **التفكير الاستراتيجي**: تحليل متعمق لطلب المستخدم '{request.message}'. تحديد الإجراءات المطلوبة بناءً على نوع الطلب والمتطلبات."
+        user_message = request.message.lower()
         
-        if "لعبة" in request.message or "game" in request.message:
-            response_msg = "🎮 **الوكيل الاستراتيجي يحلل طلب الألعاب**\n\nتم استلام طلبك المتعلق بالألعاب بنجاح! 🚀\n\nجاري:\n• إعداد أدوات الهندسة العكسية المتقدمة\n• تحضير محلل الذاكرة والعمليات\n• تجهيز مكتبات تعديل القيم\n\n🔍 **أخبرني باسم اللعبة المحددة والميزة التي تريد تعديلها**"
-            actions = [
+        # تحليل الطلب وتحديد الإجراءات الحقيقية
+        if "مسح" in user_message and "برامج" in user_message:
+            return await handle_scan_programs(request)
+        elif "مسح" in user_message and "عمليات" in user_message:
+            return await handle_scan_processes(request)
+        elif "هندسة عكسية" in user_message or "reverse engineer" in user_message:
+            return await handle_reverse_engineering(request)
+        elif "بوت" in user_message or "bot" in user_message:
+            return await handle_bot_development(request)
+        elif "شاشة" in user_message or "screenshot" in user_message:
+            return await handle_screenshot(request)
+        elif "ذاكرة" in user_message or "memory" in user_message:
+            return await handle_memory_scan(request)
+        elif "تثبيت" in user_message or "install" in user_message:
+            return await handle_tool_installation(request)
+        elif "مرحبا" in user_message or "اهلا" in user_message or "hello" in user_message:
+            return await handle_welcome(request)
+        else:
+            return await handle_general_request(request)
+            
+    except Exception as e:
+        logger.error(f"❌ خطأ في معالجة المحادثة: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+async def handle_scan_programs(request: ChatRequest):
+    """معالجة طلب مسح البرامج"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يطلب مسح البرامج المثبتة على جهازه. جاري إعداد أمر المسح الشامل..."
+    
+    response = ChatResponse(
+        thinking_process=thinking,
+        message="🔍 **جاري مسح البرامج المثبتة على جهازك...**\n\nسيقوم الوكيل التنفيذي بمسح شامل لجميع البرامج المثبتة وعرضها لك.",
+        actions=[
+            {
+                "type": "scan_installed_programs",
+                "description": "مسح شامل للبرامج المثبتة على النظام",
+                "parameters": {
+                    "scan_type": "comprehensive",
+                    "include_versions": True
+                }
+            }
+        ]
+    )
+    return response
+
+async def handle_scan_processes(request: ChatRequest):
+    """معالجة طلب مسح العمليات"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يريد مسح العمليات النشطة على جهازه. تحديد العمليات الجارية والألعاب النشطة."
+    
+    response = ChatResponse(
+        thinking_process=thinking,
+        message="⚡ **جاري مسح العمليات النشطة على جهازك...**\n\nعرض جميع العمليات الجارية حالياً مع التركيز على عمليات الألعاب.",
+        actions=[
+            {
+                "type": "scan_running_processes",
+                "description": "مسح العمليات النشطة على النظام",
+                "parameters": {
+                    "include_memory_usage": True,
+                    "detect_games": True
+                }
+            }
+        ]
+    )
+    return response
+
+async def handle_reverse_engineering(request: ChatRequest):
+    """معالجة طلب الهندسة العكسية"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يطلب هندسة عكسية لملف. تحديد المسار وتحليل المتطلبات..."
+    
+    # استخراج مسار الملف من الرسالة
+    file_path = extract_file_path(request.message)
+    
+    if not file_path:
+        response = ChatResponse(
+            thinking_process=thinking + " لم يتم تحديد مسار الملف. طلب التوضيح من المستخدم.",
+            message="🔧 **الهندسة العكسية**\n\nيبدو أنك تريد عمل هندسة عكسية لملف. الرجاء تحديد المسار الكامل للملف:\n\nمثال: `F:\\Coven Kal\\engine.exe`",
+            actions=[
                 {
-                    "type": "game_analysis", 
-                    "description": "تحليل هياكل اللعبة والذاكرة باستخدام الذكاء الاستراتيجي",
-                    "parameters": {"game_detected": True, "analysis_level": "advanced"}
+                    "type": "prepare_reverse_engineering",
+                    "description": "تحضير بيئة الهندسة العكسية",
+                    "parameters": {}
                 }
             ]
-        elif "بوت" in request.message or "bot" in request.message:
-            response_msg = "🤖 **تطوير البوتات - تحليل استراتيجي**\n\nممتاز! جاري:\n• تحضير بيئة التطوير المتقدمة\n• إعداد مكتبات الأتمتة\n• تحليل متطلبات الأداء\n\n💡 **ما نوع البوت الذي تريد تطويره وأي لعبة يستهدفها؟**"
-            actions = [
+        )
+    else:
+        response = ChatResponse(
+            thinking_process=thinking + f" تم تحديد المسار: {file_path}. جاري إعداد أدوات الهندسة العكسية.",
+            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]}",
+                    "parameters": {
+                        "file_path": file_path,
+                        "analysis_depth": "deep",
+                        "extract_resources": True,
+                        "analyze_imports": True
+                    }
+                },
                 {
-                    "type": "bot_development", 
-                    "description": "إعداد بيئة تطوير البوت باستراتيجيات متقدمة",
-                    "parameters": {"development_phase": "requirements_analysis"}
+                    "type": "analyze_game_file",
+                    "description": f"تحليل بنية ملف اللعبة",
+                    "parameters": {
+                        "file_path": file_path
+                    }
                 }
             ]
-        elif "مرحبا" in request.message or "اهلا" in request.message or "hello" in request.message:
-            response_msg = "🧠 **الوكيل الاستراتيجي يرحب بك!**\n\n✅ **تم الاتصال بنجاح بالخادم المركزي**\n\n🔧 **الميزات المتاحة عبر الوكيل الاستراتيجي:**\n• تحليل ذاكرة متقدم للألعاب\n• هندسة عكسية باستخدام الذكاء الاصطناعي\n• تطوير برامج وبوتات مخصصة\n• حل مشاكل تقنية معقدة\n• بحث واستخراج معلومات متقدم\n\n🚀 **ما المهمة التي تريدني مساعدتك فيها؟**"
-            actions = [
+        )
+    
+    return response
+
+async def handle_bot_development(request: ChatRequest):
+    """معالجة طلب تطوير البوت"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يطلب تطوير بوت. تحديد نوع البوت واللعبة المستهدفة..."
+    
+    game_name = extract_game_name(request.message)
+    bot_type = extract_bot_type(request.message)
+    
+    if not game_name:
+        response = ChatResponse(
+            thinking_process=thinking + " لم يتم تحديد اسم اللعبة. طلب التوضيح.",
+            message="🤖 **تطوير البوتات**\n\nلنبدأ في تطوير البوت! أخبرني:\n• اسم اللعبة المستهدفة\n• نوع البوت المطلوب (مزرعة، قتال، تجارة، إلخ)\n• الميزات الخاصة التي تريدها",
+            actions=[
                 {
-                    "type": "strategic_welcome", 
-                    "description": "تهيئة البيئة الاستراتيجية للعميل",
-                    "parameters": {"welcome_complete": True, "client_registered": True}
+                    "type": "prepare_bot_development",
+                    "description": "تحضير بيئة تطوير البوتات",
+                    "parameters": {}
                 }
             ]
-        else:
-            response_msg = f"🧠 **الوكيل الاستراتيجي يحلل طلبك**: '{request.message}'\n\n✅ **تم استلام طلبك بنجاح عبر الخادم المركزي**\n\n🔧 **جاري المعالجة باستخدام الذكاء الاصطناعي المتقدم...**\n\n💡 **الميزات المتاحة:**\n• تحليل متقدم للذاكرة والعمليات\n• هندسة عكسية متطورة للألعاب\n• تطوير برامج وبوتات مخصصة\n• حل مشاكل تقنية معقدة\n• بحث واستخراج معلومات متقدم"
-            actions = [
+        )
+    else:
+        response = ChatResponse(
+            thinking_process=thinking + f" تطوير بوت {bot_type} للعبة {game_name}.",
+            message=f"🚀 **بدء تطوير بوت {bot_type} للعبة {game_name}**\n\nجاري:\n• تصميم هيكل البوت\n• إعداد مكتبات الأتمتة\n• تطوير الخوارزميات الأساسية\n• إنشاء كود البوت الكامل",
+            actions=[
                 {
-                    "type": "strategic_analysis", 
-                    "description": "تحليل استراتيجي متقدم للمهمة المطلوبة",
-                    "parameters": {"analysis_type": "general", "complexity": "high"}
+                    "type": "develop_bot",
+                    "description": f"تطوير بوت {bot_type} للعبة {game_name}",
+                    "parameters": {
+                        "game_name": game_name,
+                        "bot_type": bot_type,
+                        "features": ["auto_detection", "memory_control", "image_recognition", "screen_capture"]
+                    }
+                },
+                {
+                    "type": "install_tool",
+                    "description": "تثبيت أدوات تطوير البوت",
+                    "parameters": {
+                        "tool_name": "python"
+                    }
                 }
             ]
-        
+        )
+    
+    return response
+
+async def handle_screenshot(request: ChatRequest):
+    """معالجة طلب تصوير الشاشة"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يطلب تصوير شاشة جهازه. إعداد أمر التقاط الصورة."
+    
+    response = ChatResponse(
+        thinking_process=thinking,
+        message="📸 **جاري التقاط صورة لشاشة جهازك...**\n\nسيتم حفظ الصورة في مجلد البوتات.",
+        actions=[
+            {
+                "type": "take_screenshot",
+                "description": "التقاط صورة للشاشة الحالية",
+                "parameters": {
+                    "save_path": f"screenshots/screen_{datetime.now().strftime('%Y%m%d_%H%M%S')}.png"
+                }
+            }
+        ]
+    )
+    return response
+
+async def handle_memory_scan(request: ChatRequest):
+    """معالجة طلب مسح الذاكرة"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يريد مسح ذاكرة لعبة. تحديد اسم العملية المستهدفة."
+    
+    process_name = extract_process_name(request.message)
+    
+    if not process_name:
         response = ChatResponse(
-            thinking_process=thinking,
-            message=response_msg,
-            actions=actions
+            thinking_process=thinking + " لم يتم تحديد اسم العملية. طلب التوضيح.",
+            message="🎮 **مسح ذاكرة اللعبة**\n\nأخبرني اسم العملية أو اللعبة التي تريد مسح ذاكرتها:\n\nمثال: `GenshinImpact.exe` أو `Minecraft`",
+            actions=[]
         )
-        
-        logger.info(f"✅ تم إرسال رد استراتيجي للع��يل {request.client_id} - الإجراءات: {len(actions)}")
-        return response
-        
-    except Exception as e:
-        logger.error(f"❌ خطأ في معالجة المحادثة: {e}")
-        raise HTTPException(status_code=500, detail=str(e))
+    else:
+        response = ChatResponse(
+            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"]
+                    }
+                }
+            ]
+        )
+    
+    return response
+
+async def handle_tool_installation(request: ChatRequest):
+    """معالجة طلب تثبيت الأدوات"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يريد تثبيت أداة. تحديد الأداة المطلوبة."
+    
+    tool_name = extract_tool_name(request.message)
+    
+    if not tool_name:
+        response = ChatResponse(
+            thinking_process=thinking + " لم يتم تحديد الأداة. عرض القائمة.",
+            message="🔧 **تثبيت الأدوات**\n\nالأدوات المتاحة:\n• cheatengine - أداة تعديل الذاكرة\n• python - لغة برمجة البوتات\n• ida - محلل التجميع\n• x64dbg - مصحح الأخطاء\n\nما الأداة التي تريد تثبيتها؟",
+            actions=[]
+        )
+    else:
+        response = ChatResponse(
+            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
+                    }
+                }
+            ]
+        )
+    
+    return response
+
+async def handle_welcome(request: ChatRequest):
+    """معالجة رسالة الترحيب"""
+    thinking = "🤔 **التفكير الاستراتيجي**: المستخدم يرسل تحية. الترحيب به وعرض الميزات الحقيقية."
+    
+    response = ChatResponse(
+        thinking_process=thinking,
+        message="🧠 **مرحباً بك في النظام الحقيقي المتكامل!**\n\n🚀 **الميزات الحقيقية الجاهزة للتنفيذ على جهازك:**\n\n• 🔍 **مسح شامل** للبرامج والعمليات\n• 🎮 **تحليل الذاكرة** للألعاب والتعديل\n• 🤖 **تطوير بوتات** كاملة وتجربتها\n• 🔬 **هندسة عكسية** متقدمة للملفات\n• 📸 **تصوير الشاشة** والتسجيل\n• ⚡ **تثبيت أدوات** متخصصة\n\n💡 **ما المهمة التي تريد البدء بها؟**",
+        actions=[
+            {
+                "type": "welcome",
+                "description": "ترحيب بالمستخدم وتحضير البيئة الحقيقية",
+                "parameters": {}
+            }
+        ]
+    )
+    return response
+
+async def handle_general_request(request: ChatRequest):
+    """معالجة الطلبات العامة"""
+    thinking = "🤔 **التفكير الاستراتيجي**: تحليل الطلب العام للمستخدم وتحديد أفضل الإجراءات المناسبة."
+    
+    response = ChatResponse(
+        thinking_process=thinking,
+        message="🧠 **فهمت طلبك!**\n\nسأقوم بمساعدتك في هذه المهمة باستخدام النظام الحقيقي المتكامل.\n\n💡 **جاري تحليل متطلباتك وإعداد الحل المناسب...**",
+        actions=[
+            {
+                "type": "general_analysis",
+                "description": "تحليل المهمة العامة وتحديد المتطلبات",
+                "parameters": {
+                    "user_message": request.message,
+                    "analysis_type": "comprehensive"
+                }
+            }
+        ]
+    )
+    return response
+
+def extract_file_path(message: str) -> str:
+    """استخراج مسار الملف من الرسالة"""
+    # البحث عن أنماط المسارات في النص
+    patterns = [
+        r'[A-Z]:\\[^\s]+',
+        r'/[^\s]+',
+        r'~[^\s]+'
+    ]
+    
+    for pattern in patterns:
+        matches = re.findall(pattern, message)
+        if matches:
+            return matches[0]
+    
+    return ""
+
+def extract_game_name(message: str) -> str:
+    """استخراج اسم اللعبة من الرسالة"""
+    games = ["Genshin Impact", "Minecraft", "Among Us", "VALORANT", "Overwatch", "Coven Kal", "Fortnite", "Cyberpunk", "Witcher"]
+    
+    for game in games:
+        if game.lower() in message.lower():
+            return game
+    
+    return ""
+
+def extract_bot_type(message: str) -> str:
+    """استخراج نوع البوت من الرسالة"""
+    bot_types = {
+        "مزرعة": "farming",
+        "زراعة": "farming", 
+        "قتال": "combat",
+        "قتل": "combat",
+        "تجارة": "trading",
+        "تلقائي": "auto",
+        "حماية": "defense"
+    }
+    
+    for arabic_type, english_type in bot_types.items():
+        if arabic_type in message:
+            return english_type
+    
+    if "farm" in message.lower():
+        return "farming"
+    elif "combat" in message.lower():
+        return "combat"
+    elif "trade" in message.lower():
+        return "trading"
+    
+    return "auto"
+
+def extract_process_name(message: str) -> str:
+    """استخراج اسم العملية من الرسالة"""
+    # البحث عن أسماء العمليات الشائعة
+    common_processes = ["GenshinImpact", "Minecraft", "AmongUs", "VALORANT", "Overwatch", "Fortnite"]
+    
+    for process in common_processes:
+        if process.lower() in message.lower():
+            return process + ".exe"
+    
+    # البحث عن نمط .exe في النص
+    exe_pattern = r'(\w+\.exe)'
+    matches = re.findall(exe_pattern, message, re.IGNORECASE)
+    if matches:
+        return matches[0]
+    
+    return ""
+
+def extract_tool_name(message: str) -> str:
+    """استخراج اسم الأداة من الرسالة"""
+    tools = {
+        "cheat engine": "cheatengine",
+        "cheatengine": "cheatengine",
+        "python": "python",
+        "ida": "ida",
+        "x64dbg": "x64dbg",
+        "process hacker": "processhacker",
+        "processhacker": "processhacker"
+    }
+    
+    for tool_name, tool_id in tools.items():
+        if tool_name.lower() in message.lower():
+            return tool_id
+    
+    return ""
 
 @app.post("/api/register-client")
 async def register_client(registration: ClientRegistration):