Update trade_manager.py

trade_manager.py

@@ -1,10 +1,5 @@
 # ============================================================
-# 🛡️ trade_manager.py (V35.0 - GEM-Architect: Portfolio-Driven)
-# ============================================================
-# التغييرات الجوهرية:
-# 1. تم دمج SmartPortfolio كمدير حصري للمخاطر ورأس المال.
-# 2. إزالة القيود اليدوية لعدد الصفقات والاعتماد على منطق المحفظة.
-# 3. استخدام الثقة المركبة (Consensus) والمزاج العام في اتخاذ القرار.
+# 🛡️ trade_manager.py (V35.1 - GEM-Architect: Portfolio-Driven & Muzzled Guardians)
 # ============================================================
 
 import asyncio
@@ -50,7 +45,7 @@ class TradeManager:
         }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V35.0] Portfolio-Driven Engine Online.")
+        print(f"🛡️ [TradeManager V35.1] Portfolio-Driven Engine Online.")
 
     async def initialize_sentry_exchanges(self):
         print("🛡️ [TradeManager] Syncing state & Initializing Portfolio...")
@@ -65,9 +60,7 @@ class TradeManager:
             print(f"   -> [Sync] Recovered {len(self.open_positions)} active trades.")
             
             # 🔄 مزامنة رأس المال المحجوز مع المحفظة بناءً على الصفقات المستعادة
-            # (خطوة احترازية لضمان دقة allocated_capital في حالة إعادة التشغيل)
             total_allocated = sum(float(t.get('entry_capital', 0.0)) for t in self.open_positions.values())
-            # نحدث الحالة المحلية للمحفظة فقط (دون حفظ لتجنب الكتابة فوق القيمة الدقيقة إذا كانت موجودة)
             self.smart_portfolio.state["allocated_capital_usd"] = total_allocated
             
         except Exception as e:
@@ -108,9 +101,6 @@ class TradeManager:
     # 🎯 L4 Sniper Execution Logic
     # ==============================================================================
     async def select_and_execute_best_signal(self, oracle_approved_signals: List[Dict[str, Any]]):
-        # ❌ حذفنا القيد اليدوي (if len > 0)
-        # ✅ الاعتماد الآن كلياً على smart_portfolio.request_entry_approval
-        
         if not self.processor.initialized:
             await self.processor.initialize()
 
@@ -168,7 +158,6 @@ class TradeManager:
         best_signal = sniper_candidates[0]
         
         async with self.execution_lock:
-            # لم نعد نتحقق من عدد الصفقات هنا، نترك الأمر للمحفظة عند التنفيذ
             print(f"🚀 [EXECUTING] Attempting entry for best candidate: {best_signal['symbol']}")
             await self._execute_entry_from_signal(best_signal['symbol'], best_signal)
 
@@ -178,7 +167,6 @@ class TradeManager:
     async def _execute_entry_from_signal(self, symbol, signal_data):
         try:
             # 1. 💼 طلب الموافقة من المحفظة الذكية
-            # نمرر عدد الصفقات المفتوحة حالياً لتطبيق قيود الـ Slots
             is_approved, plan = await self.smart_portfolio.request_entry_approval(
                 signal_data, 
                 open_positions_count=len(self.open_positions)
@@ -220,7 +208,7 @@ class TradeManager:
                 'direction': 'LONG',
                 'entry_time': datetime.now().isoformat(),
                 'status': 'OPEN',
-                'tp_price': approved_tp,         # ✅ استخدام الهدف المعتمد من المحفظة
+                'tp_price': approved_tp,
                 'sl_price': sl_price,
                 'last_update': datetime.now().isoformat(),
                 'last_oracle_check': datetime.now().isoformat(),
@@ -230,15 +218,15 @@ class TradeManager:
                 'initial_oracle_class': oracle_class,
                 'oracle_tp_map': signal_data.get('tp_map', {}),
                 
-                'entry_capital': approved_size_usd, # ✅ استخدام الحجم المعتمد من المحفظة
+                'entry_capital': approved_size_usd,
                 'entry_fee_usd': entry_fee_usd,
                 'l1_score': float(signal_data.get('enhanced_final_score', 0.0)),
                 'target_class_int': target_class_int,
                 'decision_data': {
                     'components': signal_data.get('components', {}),
                     'oracle_conf': signal_data.get('confidence', 0),
-                    'system_confidence': system_conf, # ✅ تسجيل الثقة المركبة
-                    'market_mood': market_mood        # ✅ تسجيل حالة السوق
+                    'system_confidence': system_conf,
+                    'market_mood': market_mood
                 },
                 'highest_price': current_price
             }
@@ -249,7 +237,6 @@ class TradeManager:
             # 3. 📝 تسجيل الصفقة ف�� المحفظة (حجز رأس المال)
             await self.smart_portfolio.register_new_position(approved_size_usd)
             
-            # تحديث timestamp لأول صفقة إذا لزم الأمر
             portfolio_state = await self.r2.get_portfolio_state_async()
             if portfolio_state.get('first_trade_timestamp') is None:
                 portfolio_state['first_trade_timestamp'] = new_trade['entry_time']
@@ -311,12 +298,14 @@ class TradeManager:
                     t5 = self.data_manager.get_latest_ohlcv(symbol, '5m', 300)
                     t15 = self.data_manager.get_latest_ohlcv(symbol, '15m', 200)
                     
+                    # ✅ GEM-Architect Update: Fetch Order Book for Validation
+                    tob = self.data_manager.get_order_book_snapshot(symbol)
+                    
                     try:
-                        d1, d5, d15 = await asyncio.gather(t1, t5, t15)
+                        d1, d5, d15, d_ob = await asyncio.gather(t1, t5, t15, tob)
                     except:
                         continue 
                     
-                    # التحقق من كفاية البيانات
                     if d1 and d5 and d15 and len(d1) >= 200:
                         context_data = {
                             'entry_price': trade['entry_price'],
@@ -324,15 +313,15 @@ class TradeManager:
                             'sl_price': trade['sl_price'],
                             'entry_time': trade['entry_time'],
                             'oracle_conf': trade.get('decision_data', {}).get('oracle_conf', 0.8),
-                            'system_conf': trade.get('decision_data', {}).get('system_confidence', 0.8), # ✅ تمرير الثقة المركبة
+                            'system_conf': trade.get('decision_data', {}).get('system_confidence', 0.8),
                             'l2_score': trade.get('l1_score', 0.7),
                             'target_class_int': trade.get('target_class_int', 3),
                             'highest_price': float(trade['highest_price']),
                             'time_in_trade_mins': (datetime.now() - datetime.fromisoformat(trade['entry_time'])).total_seconds() / 60
                         }
 
-                        # استشارة الحارس المزدوج
-                        decision = self.processor.consult_dual_guardians(symbol, d1, d5, d15, context_data)
+                        # ✅ Pass order book (d_ob) to Processor
+                        decision = self.processor.consult_dual_guardians(symbol, d1, d5, d15, context_data, order_book_snapshot=d_ob)
                         
                         action = decision.get('action', 'HOLD')
                         reason = decision.get('reason', '')
@@ -386,7 +375,6 @@ class TradeManager:
                 await asyncio.sleep(5)
 
     async def _consult_oracle_strategy_update(self, symbol, trade):
-        """Oracle V4 Strategy Update"""
         try:
             tasks = [self.data_manager.get_latest_ohlcv(symbol, tf, limit=100) for tf in ["15m", "1h", "4h"]]
             results = await asyncio.gather(*tasks)
@@ -489,7 +477,6 @@ class TradeManager:
             total_fees = entry_fee_usd + exit_fee_usd
             
             # 1. 💼 إبلاغ المحفظة الذكية لتحرير رأس المال وتحديث الرصيد
-            # (تمرير PnL الصافي والرسوم للمحفظة لتدقيق الحسابات)
             await self.smart_portfolio.register_closed_position(entry_capital, net_pnl_usd, total_fees)
 
             trade.update({
@@ -502,11 +489,7 @@ class TradeManager:
             })
 
             # 2. 📊 تحديث الإحصائيات (Counters Only) في TradeManager
-            # ملاحظة: نحدث العدادات فقط، ونترك للمحفظة إدارة current_capital_usd في R2
-            # لتجنب تضارب الكتابة، نقرأ أحدث حالة (التي حدثتها المحفظة للتو)
             portfolio = await self.r2.get_portfolio_state_async()
-            
-            # نحدث العدادات فقط
             portfolio['total_trades'] = portfolio.get('total_trades', 0) + 1
             if net_pnl_usd >= 0:
                 portfolio['winning_trades'] = portfolio.get('winning_trades', 0) + 1
@@ -517,7 +500,6 @@ class TradeManager:
                 portfolio['total_loss_usd'] = portfolio.get('total_loss_usd', 0) + abs(net_pnl_usd)
                 trade['result'] = 'LOSS'
 
-            # نحفظ الحالة المحدثة (التي تحتوي على الرصيد الجديد من المحفظة + العدادات الجديدة منا)
             await self.r2.save_portfolio_state_async(portfolio)
             await self.r2.save_open_trades_async(list(self.open_positions.values()))
             await self.r2.append_to_closed_trades_history(trade)