Update trade_manager.py

trade_manager.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🛡️ trade_manager.py (V36.0 - GEM-Architect: Full Production)
+# 🛡️ trade_manager.py (V37.0 - GEM-Architect: Governance Integrated)
 # ============================================================
 
 import asyncio
@@ -9,10 +9,11 @@ import traceback
 from datetime import datetime
 from typing import List, Dict, Any
 
-# استيراد إدارة المحفظة
+# استيراد المكونات الأساسية
 from smart_portfolio import SmartPortfolio
-# ✅ استيراد الحدود المركزية لقراءة الإعدادات الحية (للحراس)
 from ml_engine.processor import SystemLimits 
+# ✅ استيراد محرك الحوكمة الجديد (مجلس الشيوخ)
+from governance_engine import GovernanceEngine
 
 class TradeManager:
     def __init__(self, r2_service, data_manager, processor): 
@@ -23,12 +24,15 @@ class TradeManager:
         # ✅ سيتم حقنه من الخارج لربط حلقة التعلم
         self.learning_hub = None 
         
+        # تهيئة المحفظة والحوكمة
         self.smart_portfolio = SmartPortfolio(r2_service, data_manager)
+        self.governance = GovernanceEngine() # 🏛️ تفعيل مجلس الحوكمة
+        
         self.open_positions = {}
         self.watchlist = {}
         self.sentry_tasks = {}
         self.running = True
-        self.latest_guardian_log = "🛡️ Guardian & Portfolio Systems Online."
+        self.latest_guardian_log = "🛡️ Guardian & Governance Systems Online."
         self.FEE_RATE = 0.001 
         self.ORACLE_CHECK_INTERVAL = 900
         
@@ -41,7 +45,7 @@ class TradeManager:
         }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V36.0] Full System Online (Learning Loop Ready).")
+        print(f"🛡️ [TradeManager V37.0] Full System Online (Governance Layer Active).")
 
     async def initialize_sentry_exchanges(self):
         """تهيئة المحفظة واستعادة الحالة"""
@@ -140,10 +144,37 @@ class TradeManager:
             await self._execute_entry_from_signal(best_signal['symbol'], best_signal)
 
     async def _execute_entry_from_signal(self, symbol, signal_data):
-        """تنفيذ الدخول الفعلي مع إدارة المحفظة"""
+        """تنفيذ الدخول الفعلي مع فحص الحوكمة وإدارة المحفظة"""
         try:
-            # طلب الموافقة من المحفظة الذكية
+            # 🏛️ الخطوة 1: استشارة مجلس الحوكمة (Governance Layer)
+            # نحتاج إلى تجميع البيانات المطلوبة للحوكمة (خاصة فريم 15 دقيقة)
+            print(f"   🏛️ [Governance] Convening Senate for {symbol}...")
+            
+            t15_task = self.data_manager.get_latest_ohlcv(symbol, '15m', 200)
+            t1h_task = self.data_manager.get_latest_ohlcv(symbol, '1h', 200)
+            ob_task = self.data_manager.get_order_book_snapshot(symbol)
+            
+            t15, t1h, ob = await asyncio.gather(t15_task, t1h_task, ob_task)
+            
+            ohlcv_dict = {'15m': t15, '1h': t1h}
+            
+            # تقييم الحوكمة
+            gov_decision = await self.governance.evaluate_trade(symbol, ohlcv_dict, ob)
+            
+            if gov_decision['grade'] == 'REJECT':
+                print(f"⛔ [Governance VETO] {symbol} Rejected by Senate. Grade: REJECT | Score: {gov_decision['governance_score']:.1f}")
+                return # إيقاف التنفيذ فوراً
+
+            print(f"   ✅ [Governance PASS] Grade: {gov_decision['grade']} | Score: {gov_decision['governance_score']:.1f}")
+            
+            # دمج نتائج الحوكمة في بيانات الإشارة لتراها المحفظة
+            signal_data['governance_grade'] = gov_decision['grade']
+            signal_data['governance_score'] = gov_decision['governance_score']
+            signal_data['governance_details'] = gov_decision['components']
+
+            # 💰 الخطوة 2: طلب الموافقة من المحفظة الذكية (تستخدم الـ Grade لتحديد الحجم)
             is_approved, plan = await self.smart_portfolio.request_entry_approval(signal_data, len(self.open_positions))
+            
             if not is_approved:
                 print(f"⛔ [Portfolio Rejection] {symbol}: {plan.get('reason')}")
                 return
@@ -161,11 +192,13 @@ class TradeManager:
 
             # حفظ تفاصيل القرار كاملة من أجل التعلم
             decision_snapshot = {
-                'components': signal_data.get('components', {}), # Titan, Patterns, MC, Sniper Scores
+                'components': signal_data.get('components', {}),
                 'oracle_conf': signal_data.get('confidence', 0),
+                'governance_grade': gov_decision['grade'], # تسجيل الجودة
+                'governance_score': gov_decision['governance_score'],
                 'system_confidence': system_conf,
                 'market_mood': market_mood,
-                'regime_at_entry': getattr(SystemLimits, 'CURRENT_REGIME', 'UNKNOWN') # ✅ تسجيل حالة السوق عند الدخول
+                'regime_at_entry': getattr(SystemLimits, 'CURRENT_REGIME', 'UNKNOWN')
             }
 
             new_trade = {
@@ -179,7 +212,7 @@ class TradeManager:
                 'sl_price': float(signal_data.get('sl_price', current_price * 0.95)),
                 'last_update': datetime.now().isoformat(), 
                 'last_oracle_check': datetime.now().isoformat(),
-                'strategy': 'OracleV4_Hydra_Portfolio',
+                'strategy': 'OracleV4_Governance_Hydra',
                 'initial_oracle_strength': float(signal_data.get('strength', 0.5)),
                 'initial_oracle_class': signal_data.get('target_class', 'TP2'),
                 'oracle_tp_map': signal_data.get('tp_map', {}),
@@ -187,7 +220,7 @@ class TradeManager:
                 'entry_fee_usd': entry_fee_usd,
                 'l1_score': float(signal_data.get('enhanced_final_score', 0.0)),
                 'target_class_int': 3,
-                'decision_data': decision_snapshot, # 🔥 هنا يكمن سر التعلم
+                'decision_data': decision_snapshot, 
                 'highest_price': current_price
             }
             
@@ -209,7 +242,7 @@ class TradeManager:
             if symbol in self.sentry_tasks: self.sentry_tasks[symbol].cancel()
             self.sentry_tasks[symbol] = asyncio.create_task(self._guardian_loop(symbol))
             
-            print(f"✅ [ENTRY] {symbol} @ {current_price} | Size: ${approved_size_usd:.2f} | TP: {approved_tp} ({target_label}) | Conf: {system_conf:.0%} | Mood: {market_mood}")
+            print(f"✅ [ENTRY] {symbol} @ {current_price} | Grade: {gov_decision['grade']} | Size: ${approved_size_usd:.2f} | TP: {approved_tp} ({target_label}) | Mood: {market_mood}")
 
         except Exception as e:
             print(f"❌ [Entry Error] {symbol}: {e}")
@@ -360,8 +393,6 @@ class TradeManager:
             curr = await self.data_manager.get_latest_price_async(symbol)
             if curr == 0: return
             
-            # إذا بعنا، والسعر هبط -> خروج جيد (وفرنا خسارة أو حفظنا ربح)
-            # إذا بعنا، والسعر صعد -> خروج سيء (فوتنا ربح)
             change_pct = (curr - exit_price) / exit_price
             usd_impact = change_pct * position_size_usd
             is_good_exit = change_pct < 0 
@@ -374,8 +405,6 @@ class TradeManager:
             
             record = {"symbol": symbol, "exit_price": exit_price, "price_15m": curr, "usd_impact": usd_impact, "verdict": "SUCCESS" if is_good_exit else "MISS"}
             await self.r2.append_deep_steward_audit(record)
-            
-            # (يمكن إضافة هذا السجل للتعلم أيضاً، لكننا اعتمدنا على register_trade_outcome الفوري)
         except Exception: pass
 
     async def _execute_exit(self, symbol, price, reason, ai_scores=None):
@@ -425,10 +454,9 @@ class TradeManager:
             self._launch_post_exit_analysis(symbol, exit_price, trade.get('exit_time'), entry_capital, ai_scores, trade)
             
             # ==========================================================
-            # 🧠 THE TACTICAL LEARNING LINK (الحلقة القصيرة)
+            # 🧠 THE TACTICAL LEARNING LINK
             # ==========================================================
             if self.learning_hub:
-                # نرسل الصفقة للمركز التعليمي ليقوم بمكافأة/عقاب النماذج
                 print(f"🎓 [Learning] Reporting trade outcome to AdaptiveHub...")
                 asyncio.create_task(self.learning_hub.register_trade_outcome(trade))
             # ==========================================================
@@ -438,7 +466,6 @@ class TradeManager:
 
         except Exception as e:
             print(f"❌ [Exit Error] {e}"); traceback.print_exc()
-            # استعادة الصفقة في حالة الخطأ
             if symbol not in self.open_positions: self.open_positions[symbol] = trade 
 
     async def force_exit_by_manager(self, symbol, reason):