Update app.py

app.py

@@ -1,4 +1,4 @@
-# app.py (Updated to V8.5 - Vader Injection Fix)
+# app.py (Updated to V8.6 - Vader + ndarray Fix)
 import os
 import traceback
 import signal
@@ -549,7 +549,7 @@ async def run_3_layer_analysis_explorer() -> List[Dict[str, Any]]:
 
 
 async def re_analyze_open_trade_async(trade_data):
-    """(V8.3) إضافة جلب حجم التداول لـ Reflector"""
+    """(V8.6) إضافة إصلاح ndarray"""
     symbol = trade_data.get('symbol')
     try:
         async with state_manager.trade_analysis_lock:
@@ -576,7 +576,6 @@ async def re_analyze_open_trade_async(trade_data):
             if not ohlcv_data_list: print(f"⚠️ Failed to get re-analysis data for {symbol}"); return None
             ohlcv_data = ohlcv_data_list[0]
 
-            # (جلب حجم التداول اليومي الحالي لإعادة التحليل)
             print(f"   🔄 [Re-Analyze] Fetching current daily volume for {symbol}...")
             symbol_daily_volume = await data_manager_global.get_symbol_daily_volume(symbol)
             
@@ -603,7 +602,6 @@ async def re_analyze_open_trade_async(trade_data):
             processed_data['ohlcv'] = processed_data['raw_ohlcv']
             processed_data['sentiment_data'] = market_context
             
-            # (جلب الأخبار ودرجة VADER الخام لتمريرها إلى Reflector لاحقاً)
             if news_fetcher_global and VADER_ANALYZER:
                 try:
                     news_text = await news_fetcher_global.get_news_for_symbol(symbol)
@@ -618,8 +616,14 @@ async def re_analyze_open_trade_async(trade_data):
             else:
                 processed_data['news_text'] = "News analysis disabled."
                 processed_data['news_score'] = 0.0
-
-            re_analysis_decision = await llm_service_global.re_analyze_trade_async(trade_data, processed_data)
+            
+            # 🔴 --- START OF CHANGE (V8.6 - ndarray Fix) --- 🔴
+            # (يجب تنقية البيانات قبل إرسالها إلى LLMService لتجنب خطأ ndarray)
+            print(f"   🔄 [Re-Analyze] Sanitizing data for {symbol} before LLM log...")
+            sanitized_processed_data = _sanitize_results_for_json(processed_data)
+            
+            re_analysis_decision = await llm_service_global.re_analyze_trade_async(trade_data, sanitized_processed_data)
+            # 🔴 --- END OF CHANGE --- 🔴
 
             if re_analysis_decision:
                 await r2_service_global.save_system_logs_async({ "trade_reanalyzed": True, "symbol": symbol, "action": re_analysis_decision.get('action'), 'strategy': re_analysis_decision.get('strategy', 'GENERIC') })
@@ -721,7 +725,7 @@ async def run_bot_cycle_async():
 
 @asynccontextmanager
 async def lifespan(application: FastAPI):
-    # 🔴 --- START OF CHANGE (V8.4 - Whale Learning Loop) --- 🔴
+    # (V8.4 - Whale Learning Loop)
     """Application lifecycle management"""
     print("🚀 Starting application initialization (Explorer/Sentry/Executor)...")
     try:
@@ -753,7 +757,6 @@ async def lifespan(application: FastAPI):
         raise
     finally:
         await cleanup_on_shutdown()
-    # 🔴 --- END OF CHANGE --- 🔴
 
 
 application = FastAPI(lifespan=lifespan, title="AI Trading Bot", description="Explorer-Sentry-Executor Architecture (V5.9)", version="5.9.0")