Update LLM.py

LLM.py

@@ -1,4 +1,4 @@
-# LLM.py (V19.2 - NVIDIA Engine + System Trigger Fix)
+# LLM.py (V19.3 - NVIDIA Engine + Vader Fix)
 import os, traceback, json, time, re
 import httpx
 from datetime import datetime
@@ -21,6 +21,15 @@ try:
 except ImportError:
     NewsFetcher = None
 
+# 🔴 --- START OF CHANGE (V19.3) --- 🔴
+# (استيراد VADER هنا أيضاً للـ type hinting)
+try:
+    from vaderSentiment.vaderSentiment import SentimentIntensityAnalyzer
+except ImportError:
+    SentimentIntensityAnalyzer = None
+# 🔴 --- END OF CHANGE --- 🔴
+
+
 # (تحديث الإعدادات الافتراضية لتطابق NVIDIA)
 LLM_API_URL = os.getenv("LLM_API_URL", "https://integrate.api.nvidia.com/v1")
 LLM_API_KEY = os.getenv("LLM_API_KEY") # (هذا هو المفتاح الذي سيتم استخدامه)
@@ -47,10 +56,10 @@ class LLMService:
                 api_key=LLM_API_KEY,
                 timeout=CLIENT_TIMEOUT
             )
-            print(f"✅ [LLMService V19.2] مهيأ. النموذج: {LLM_MODEL}")
+            print(f"✅ [LLMService V19.3] مهيأ. النموذج: {LLM_MODEL}")
             print(f"   -> Endpoint: {LLM_API_URL}")
         except Exception as e:
-            print(f"❌ [LLMService V19.2] فشل تهيئة AsyncOpenAI: {e}")
+            print(f"❌ [LLMService V19.3] فشل تهيئة AsyncOpenAI: {e}")
             traceback.print_exc()
             raise
         
@@ -58,6 +67,11 @@ class LLMService:
         self.r2_service: Optional[R2Service] = None
         self.learning_hub: Optional[LearningHubManager] = None
         self.news_fetcher: Optional[NewsFetcher] = None
+        
+        # 🔴 --- START OF CHANGE (V19.3) --- 🔴
+        # (إضافة متغير VADER)
+        self.vader_analyzer: Optional[SentimentIntensityAnalyzer] = None
+        # 🔴 --- END OF CHANGE --- 🔴
 
     async def _call_llm(self, prompt: str) -> Optional[str]:
         """
@@ -65,11 +79,7 @@ class LLMService:
         إجراء استدعاء API للنموذج الضخم (يستخدم الآن "detailed thinking on" كـ system prompt).
         """
         
-        # 🔴 --- START OF CHANGE (V19.2) --- 🔴
-        # (استخدام "detailed thinking on" كـ system prompt كما طلبت)
         system_prompt = "detailed thinking on"
-        # (تم نقل جميع التعليمات الأخرى إلى الـ User Prompt)
-        # 🔴 --- END OF CHANGE --- 🔴
 
         payload = {
             "model": LLM_MODEL,
@@ -216,7 +226,7 @@ class LLMService:
 
     async def re_analyze_trade_async(self, trade_data: Dict[str, Any], current_data: Dict[str, Any]) -> Optional[Dict[str, Any]]:
         """
-        (محدث V8.1)
+        (محدث V19.3)
         يستدعي النموذج الضخم لإعادة تحليل صفقة مفتوحة (Reflector Brain).
         """
         symbol = trade_data.get('symbol', 'UNKNOWN')
@@ -232,11 +242,15 @@ class LLMService:
             # 2. (V8.1) جلب أحدث الأخبار (باستخدام NewsFetcher المخصص)
             latest_news_text = "News data unavailable for re-analysis."
             latest_news_score = 0.0
+            
+            # 🔴 --- START OF CHANGE (V19.3) --- 🔴
+            # (استخدام self.vader_analyzer الذي تم حقنه)
             if self.news_fetcher:
                 latest_news_text = await self.news_fetcher.get_news_for_symbol(symbol)
-                if self.news_fetcher.vader_analyzer and latest_news_text:
-                     vader_scores = self.news_fetcher.vader_analyzer.polarity_scores(latest_news_text)
+                if self.vader_analyzer and latest_news_text: # (التحقق من المحلل المُمرر)
+                     vader_scores = self.vader_analyzer.polarity_scores(latest_news_text)
                      latest_news_score = vader_scores.get('compound', 0.0)
+            # 🔴 --- END OF CHANGE --- 🔴
             
             current_data['latest_news_text'] = latest_news_text
             current_data['latest_news_score'] = latest_news_score
@@ -344,7 +358,6 @@ class LLMService:
     * Relative 24h Net Flow (vs Daily Volume): {relative_net_flow_24h_percent:+.2f}%
 """
         
-        # 🔴 --- START OF CHANGE (V19.2) --- 🔴
         # (تم دمج جميع التعليمات هنا في رسالة الـ user)
         task_prompt = f"""
 CONTEXT:
@@ -376,7 +389,6 @@ OUTPUT (JSON Object ONLY):
   "exit_profile": "Aggressive" or "Standard" or "Patient"
 }}
 """
-        # 🔴 --- END OF CHANGE --- 🔴
         
         # (نرسل فقط task_prompt لأنه يحتوي الآن على كل شيء)
         return task_prompt
@@ -442,7 +454,6 @@ OUTPUT (JSON Object ONLY):
     * Latest News (VADER: {latest_news_score:.3f}): {latest_news_text[:300]}...
 """
         
-        # 🔴 --- START OF CHANGE (V19.2) --- 🔴
         # (دمج جميع التعليمات في رسالة الـ user)
         task_prompt = f"""
 CONTEXT:
@@ -473,6 +484,5 @@ OUTPUT (JSON Object ONLY):
   "new_take_profit": (float or null, required if action is 'UPDATE_TRADE')
 }}
 """
-        # 🔴 --- END OF CHANGE --- 🔴
         
         return task_prompt