Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (V25.2 - GEM-Architect: Full Spot Edition with Oracle V4)
+# trade_manager.py (V25.3 - GEM-Architect: Separation of Concerns Edition)
 
 import asyncio
 import uuid
@@ -32,7 +32,7 @@ class TradeManager:
         }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V25.2] Full Spot Commander Initialized.")
+        print(f"🛡️ [TradeManager V25.3] Full Spot Commander Initialized.")
 
     async def initialize_sentry_exchanges(self):
         print("🛡️ [TradeManager] Syncing state with R2...")
@@ -48,7 +48,7 @@ class TradeManager:
             self.open_positions = {} 
 
     # ==============================================================================
-    # 🎯 L4 Sniper Execution Logic (Oracle V4 Directed - Spot Only)
+    # 🎯 L4 Sniper Execution Logic (Authority Delegated to Engine)
     # ==============================================================================
     async def select_and_execute_best_signal(self, oracle_approved_signals: List[Dict[str, Any]]):
         if len(self.open_positions) > 0:
@@ -60,6 +60,8 @@ class TradeManager:
 
         sniper_candidates = []
         
+        print(f"\n🔎 [Sniper] Scanning {len(oracle_approved_signals)} candidates...")
+
         for signal in oracle_approved_signals:
             symbol = signal['symbol']
             
@@ -75,25 +77,40 @@ class TradeManager:
             ohlcv_1m, order_book = await asyncio.gather(ohlcv_task, ob_task)
             
             if not ohlcv_1m or len(ohlcv_1m) < 100:
-                print(f"   -> [Sniper Skip] {symbol} (Insufficient 1m data).")
+                print(f"   -> ⚠️ [Skip] {symbol}: Insufficient 1m data.")
                 continue
             
-            # 2. استشارة القناص
-            # نمرر له direction='LONG' دائماً لأننا في Spot
+            # 2. استشارة القناص (هو من يمتلك القرار والعتبة)
+            # نمرر له البيانات وننتظر الحكم (BUY/WAIT) + التفاصيل
             sniper_result = await self.processor.check_sniper_entry(ohlcv_1m, order_book)
             
             sniper_signal = sniper_result.get('signal', 'WAIT')
-            sniper_conf = sniper_result.get('confidence_prob', 0.0)
+            final_conf = sniper_result.get('confidence_prob', 0.0)
+            
+            # استخراج التفاصيل للسجلات (الشفافية الكاملة)
+            ml_score = sniper_result.get('ml_score', 0.0)
+            ob_score = sniper_result.get('ob_score', 0.0)
+            reason = sniper_result.get('reason', 'N/A')
             
-            # 3. التحقق من التوافق (Must be BUY/LONG)
-            if sniper_signal == 'BUY' and sniper_conf >= 0.60:
-                print(f"   -> 🎯 [Sniper Confirmed] {symbol} | Oracle:BUY + Sniper:BUY")
+            # طباعة السجل المفصل الذي طلبته
+            log_msg = (f"   -> 🔭 {symbol:<6} | Decision: {sniper_signal} | Score: {final_conf:.2f} "
+                       f"(ML:{ml_score:.2f} + OB:{ob_score:.2f})")
+            print(log_msg)
+
+            # 3. التحقق من التوافق (طاعة عمياء للمحرك)
+            # لم نعد نفحص أي أرقام هنا، المحرك قام بذلك بالفعل
+            if sniper_signal == 'BUY':
+                print(f"      ✅ [ACCEPTED] {symbol} approved by Sniper Engine.")
                 
                 signal['sniper_entry_price'] = sniper_result.get('entry_price', 0)
-                signal['sniper_score'] = sniper_conf
+                signal['sniper_score'] = final_conf
                 sniper_candidates.append(signal)
+            else:
+                # فقط نوضح سبب الرفض في حال أراد المستخدم المراجعة
+                pass # الرسالة السابقة تكفي (Decision: WAIT)
 
         if not sniper_candidates:
+            print("   -> 📉 No candidates passed the Sniper L4 check.")
             return
 
         # ترتيب حسب قوة Oracle + قوة القناص
@@ -106,6 +123,7 @@ class TradeManager:
         
         async with self.execution_lock:
             if len(self.open_positions) == 0:
+                print(f"🚀 [EXECUTING] Entering best candidate: {best_signal['symbol']}")
                 await self._execute_entry_from_signal(best_signal['symbol'], best_signal)
 
     # ==============================================================================