Update smart_portfolio.py

smart_portfolio.py

@@ -1,11 +1,10 @@
 # ==============================================================================
-# 💼 smart_portfolio.py (V1.2 - GEM-Architect: True Risk & Market Mood)
+# 💼 smart_portfolio.py (V36.0 - GEM-Architect: Regime-Aligned Risk)
 # ==============================================================================
-# التحديثات الجذرية:
-# 1. إدارة صارمة لرأس المال (Allocated vs Free).
-# 2. دمج مؤشر الخوف والجشع (Fear & Greed Index) في حساب الثقة.
-# 3. فرض حقيقي لعدد الخانات (Slots Enforcement).
-# 4. معالجة الرسوم بشكل منفصل ودقيق.
+# التحديثات:
+# 1. إلغاء تحديد الاتجاه المستقل. الاعتماد الكلي على SystemLimits.CURRENT_REGIME.
+# 2. إدارة الخانات الديناميكية (Dynamic Slots) بناءً على حالة السوق.
+# 3. تعديل مضاعفات المخاطرة (Risk Multipliers) لتتوافق مع الـ DNA الحالي.
 # ==============================================================================
 
 import asyncio
@@ -17,38 +16,43 @@ import pandas_ta as ta
 from datetime import datetime, timedelta
 from typing import Dict, Any, Tuple, Optional
 
+# استيراد الدستور المركزي لقراءة حالة السوق
+try:
+    from ml_engine.processor import SystemLimits
+except ImportError:
+    # Fallback في حال التشغيل المنفصل
+    class SystemLimits:
+        CURRENT_REGIME = "RANGE"
+
 class SmartPortfolio:
     def __init__(self, r2_service, data_manager):
         self.r2 = r2_service
         self.data_manager = data_manager
         
-        # ⚙️ إعدادات المحفظة (الدستور المالي)
+        # ⚙️ إعدادات المحفظة الأساسية
         self.MIN_CAPITAL_FOR_SPLIT = 20.0
-        self.MAX_SLOTS_BELOW_THRESHOLD = 1
-        self.MAX_SLOTS_ABOVE_THRESHOLD = 5
-        
         self.DAILY_LOSS_LIMIT_PCT = 0.20
         
-        # 📊 أوزان الثقة المركبة (تم التحديث لإضافة Market Mood)
+        # 📊 أوزان الثقة المركبة
         self.WEIGHTS = {
             "L2_TECHNICAL": 0.25, 
             "L3_ORACLE": 0.35,     
             "L4_SNIPER": 0.20,     
-            "CONTEXT": 0.10,       # حيتان وأخبار
-            "MARKET_MOOD": 0.10    # Fear & Greed + BTC Trend
+            "CONTEXT": 0.10,       
+            "MARKET_MOOD": 0.10    
         }
         
-        # حالة السوق والمزاج العام
-        self.market_trend = "NEUTRAL"
-        self.fear_greed_index = 50  # 0-100 (50 = Neutral)
+        # حالة السوق (تقرأ الآن من SystemLimits)
+        self.market_trend = "NEUTRAL" # للعرض فقط
+        self.fear_greed_index = 50
         self.fear_greed_label = "Neutral"
         
         self.capital_lock = asyncio.Lock()
         
-        # 📂 حالة المحفظة (تمت إضافة allocated_capital_usd)
+        # 📂 حالة المحفظة
         self.state = {
-            "current_capital": 10.0,        # إجمالي حقوق الملكية (Equity)
-            "allocated_capital_usd": 0.0,   # الأموال المحجوزة في صفقات نشطة
+            "current_capital": 10.0,        
+            "allocated_capital_usd": 0.0,   
             "session_start_balance": 10.0,
             "last_session_reset": datetime.now().isoformat(),
             "daily_net_pnl": 0.0,
@@ -56,45 +60,36 @@ class SmartPortfolio:
             "halt_reason": None
         }
         
-        print("💼 [SmartPortfolio V1.2] True Risk & Market Mood Initialized.")
+        print("💼 [SmartPortfolio V36.0] Regime-Aligned Risk System Initialized.")
 
     async def initialize(self):
         await self._sync_state_from_r2()
         await self._check_daily_reset()
-        # تشغيل المراقبين
+        # تشغيل مراقب الخوف والجشع فقط (أما الاتجاه فيأتي من العقل المركزي)
         asyncio.create_task(self._market_monitor_loop())
 
     # ==============================================================================
-    # 🦅 Market Monitor: BTC Trend + Fear & Greed
+    # 🦅 Market Monitor: Fear & Greed Only (Trend from Central)
     # ==============================================================================
     async def _market_monitor_loop(self):
-        """مراقبة خلفية لاتجاه البيتكوين ومؤشر الخوف والجشع"""
-        print("🦅 [SmartPortfolio] Market Sentinel Started.")
+        """مراقبة مؤشر الخوف والجشع فقط"""
+        print("🦅 [SmartPortfolio] Sentiment Sentinel Started.")
         async with httpx.AsyncClient() as client:
             while True:
                 try:
-                    # 1. تحليل ترند BTC
-                    ohlcv = await self.data_manager.get_latest_ohlcv("BTC/USDT", "4h", limit=50)
-                    if ohlcv:
-                        df = pd.DataFrame(ohlcv, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
-                        ema20 = df['close'].ewm(span=20).mean().iloc[-1]
-                        ema50 = df['close'].ewm(span=50).mean().iloc[-1]
-                        close = df['close'].iloc[-1]
-                        
-                        if close > ema20 and ema20 > ema50: self.market_trend = "BULLISH"
-                        elif close < ema20 and ema20 < ema50: self.market_trend = "BEARISH"
-                        else: self.market_trend = "NEUTRAL"
+                    # تحديث العرض بناءً على النظام المركزي
+                    regime = getattr(SystemLimits, 'CURRENT_REGIME', 'RANGE')
+                    self.market_trend = regime # تحديث المتغير للعرض في الواجهة
 
-                    # 2. جلب مؤشر الخوف والجشع (Fear & Greed API)
-                    # نجلبه بمعدل أقل لتجنب الحظر، لكن هنا في نفس الحلقة للتبسيط
+                    # جلب مؤشر الخوف والجشع
                     try:
-                        resp = await client.get("https://api.alternative.me/fng/?limit=1", timeout=5)
+                        resp = await client.get("https://api.alternative.me/fng/?limit=1", timeout=10)
                         data = resp.json()
                         if data['data']:
                             self.fear_greed_index = int(data['data'][0]['value'])
                             self.fear_greed_label = data['data'][0]['value_classification']
                     except Exception: 
-                        pass # الحفاظ على القيمة السابقة عند الفشل
+                        pass 
 
                     await asyncio.sleep(300) # كل 5 دقائق
                 except Exception as e:
@@ -102,7 +97,7 @@ class SmartPortfolio:
                     await asyncio.sleep(60)
 
     # ==============================================================================
-    # 🧮 The Consensus Engine (Updated with Mood)
+    # 🧮 The Consensus Engine
     # ==============================================================================
     def _calculate_composite_confidence(self, signal_data: Dict[str, Any]) -> float:
         try:
@@ -110,24 +105,22 @@ class SmartPortfolio:
             oracle_conf = float(signal_data.get('confidence', 0.5))
             sniper_score = float(signal_data.get('sniper_score', 0.5))
             
-            # تطبيع سياق الحيتان والأخبار (0.0 - 1.0)
             whale_impact = float(signal_data.get('whale_score', 0.0))
             news_impact = float(signal_data.get('news_score', 0.0))
             context_val = max(0.0, min(1.0, 0.5 + whale_impact + news_impact))
             
-            # حساب سكور "مزاج السوق" (Market Mood Score)
-            # الخوف الشديد (أقل من 20) قد يكون فرصة شراء ممتازة (Contrarian)
-            # الجشع الشديد (فوق 80) قد يكون خطر تصحيح
+            # حساب سكور المزاج بناءً على Regime المركزي
+            regime = getattr(SystemLimits, 'CURRENT_REGIME', 'RANGE')
             mood_score = 0.5
-            if self.market_trend == "BULLISH":
-                mood_score += 0.2
-            elif self.market_trend == "BEARISH":
-                mood_score -= 0.2
+            
+            if regime == "BULL": mood_score += 0.2
+            elif regime == "BEAR": mood_score -= 0.2
+            elif regime == "DEAD": mood_score -= 0.1
                 
-            # دمج F&G: إذا السوق صاعد وجشع معتدل = جيد. جشع مفرط = سيء.
+            # دمج F&G (Contrarian Logic)
             fg = self.fear_greed_index
-            if fg < 20: mood_score += 0.1  # خوف شديد = فرصة ارتداد محتملة
-            elif fg > 80: mood_score -= 0.1 # جشع شديد = خطر القمة
+            if fg < 20: mood_score += 0.1  # خوف شديد = شراء
+            elif fg > 80: mood_score -= 0.1 # جشع شديد = حذر
             
             mood_score = max(0.0, min(1.0, mood_score))
 
@@ -144,18 +137,18 @@ class SmartPortfolio:
             return float(signal_data.get('confidence', 0.5))
 
     # ==============================================================================
-    # 🧠 Core Logic: Entry Approval (True Risk)
+    # 🧠 Core Logic: Entry Approval (Regime-Adaptive Risk)
     # ==============================================================================
     async def request_entry_approval(self, signal_data: Dict[str, Any], open_positions_count: int) -> Tuple[bool, Dict[str, Any]]:
         """
-        تطلب الموافقة مع مراعاة رأس المال الحر (Free Capital) وعدد الخانات المشغولة.
+        تطلب الموافقة مع مراعاة حالة السوق المركزية (Regime).
         """
         async with self.capital_lock:
-            # 1. Circuit Breaker Check
+            # 1. Circuit Breaker
             if self.state["is_trading_halted"]:
                 return False, {"reason": f"Halted: {self.state['halt_reason']}"}
 
-            # 2. Daily Loss Limit Check
+            # 2. Daily Loss Limit
             current_cap = float(self.state["current_capital"])
             start_cap = float(self.state["session_start_balance"])
             
@@ -166,11 +159,30 @@ class SmartPortfolio:
                 await self._save_state_to_r2()
                 return False, {"reason": "Daily Limit Hit"}
 
-            # 3. Slot Availability Check (Hard Limit)
-            max_slots = self.MAX_SLOTS_ABOVE_THRESHOLD if current_cap >= self.MIN_CAPITAL_FOR_SPLIT else self.MAX_SLOTS_BELOW_THRESHOLD
+            # 3. Regime-Based Slots & Risk
+            # قراءة الحالة من النظام المركزي
+            regime = getattr(SystemLimits, 'CURRENT_REGIME', 'RANGE')
             
+            # تحديد الحد الأقصى للصفقات بناءً على الحالة
+            if regime == "BULL":
+                max_slots = 6  # هجومي
+                risk_factor_base = 1.2
+            elif regime == "BEAR":
+                max_slots = 3  # دفاعي جداً
+                risk_factor_base = 0.5
+            elif regime == "DEAD":
+                max_slots = 2  # حذر جداً
+                risk_factor_base = 0.4
+            else: # RANGE
+                max_slots = 4  # متوازن
+                risk_factor_base = 0.8
+            
+            # تعديل للخزين الصغير
+            if current_cap < self.MIN_CAPITAL_FOR_SPLIT:
+                max_slots = min(max_slots, 2) # لا نفتح الكثير إذا الرصيد قليل
+
             if open_positions_count >= max_slots:
-                return False, {"reason": f"Max slots reached ({open_positions_count}/{max_slots})"}
+                return False, {"reason": f"Max slots reached for {regime} ({open_positions_count}/{max_slots})"}
 
             # 4. Free Capital Check
             allocated = float(self.state.get("allocated_capital_usd", 0.0))
@@ -179,33 +191,29 @@ class SmartPortfolio:
             if free_capital < 5.0:
                 return False, {"reason": f"Insufficient Free Capital (${free_capital:.2f})"}
 
-            # 5. Position Sizing (Island Logic)
-            # نقسم رأس المال الحر على عدد الخانات المتبقية لضمان التوزيع العادل
+            # 5. Position Sizing
             remaining_slots = max_slots - open_positions_count
             base_allocation = 0.0
             
             if current_cap >= self.MIN_CAPITAL_FOR_SPLIT:
-                # توزيع ذكي: رأس المال الكلي / عدد الخانات الكلي (للحفاظ على حجم ثابت)
-                # لكن بشرط ألا يتجاوز رأس المال الحر
-                target_size = current_cap / self.MAX_SLOTS_ABOVE_THRESHOLD
+                # تقسيم ذكي: نحاول الحفاظ على توازن، لكن نأخذ حصة أكبر في الـ Bull
+                target_size = current_cap / max_slots
                 base_allocation = min(target_size, free_capital)
             else:
-                # حساب النمو (All-in Safe)
-                base_allocation = free_capital * 0.95
+                base_allocation = free_capital * 0.95 # All-in تقريباً للحسابات الصغيرة
 
             # 6. Consensus & Risk Multiplier
             system_confidence = self._calculate_composite_confidence(signal_data)
+            
+            # تعديل المخاطرة بناءً على الثقة + الحالة
             risk_multiplier = 1.0
+            if system_confidence >= 0.80: risk_multiplier = 1.2
+            elif system_confidence < 0.60: risk_multiplier = 0.7
             
-            if system_confidence >= 0.80: risk_multiplier = 1.35
-            elif system_confidence >= 0.70: risk_multiplier = 1.0
-            elif system_confidence >= 0.60: risk_multiplier = 0.80
-            else: risk_multiplier = 0.50
-
-            if self.market_trend == "BEARISH": risk_multiplier *= 0.5
+            # دمج عامل الحالة (Regime Factor)
+            final_risk_mult = risk_multiplier * risk_factor_base
             
-            # الحجم النهائي (لا يتجاوز Free Capital ولا 98% من الإجمالي)
-            final_size_usd = base_allocation * risk_multiplier
+            final_size_usd = base_allocation * final_risk_mult
             final_size_usd = min(final_size_usd, free_capital, current_cap * 0.98)
 
             if final_size_usd < 5.0:
@@ -215,20 +223,16 @@ class SmartPortfolio:
             entry_price = float(signal_data.get('sniper_entry_price') or signal_data.get('current_price'))
             tp_map = signal_data.get('tp_map', {})
             
-            # منطق الأهداف مع F&G
-            # إذا كان الخوف شديد (القاع) + إشارة قوية -> استهدف القمر (TP4)
-            if system_confidence >= 0.85 and (self.market_trend == "BULLISH" or self.fear_greed_index < 20):
-                selected_tp = tp_map.get('TP4') or tp_map.get('TP3')
-                target_label = "TP4 (Moonbag)"
-            elif system_confidence >= 0.75:
-                selected_tp = tp_map.get('TP3')
-                target_label = "TP3"
-            elif system_confidence >= 0.65:
+            # أهداف طموحة في Bull، ومحافظة في Bear
+            if regime == "BULL" and system_confidence >= 0.75:
+                selected_tp = tp_map.get('TP3') or tp_map.get('TP4')
+                target_label = "TP3/4 (Bull Run)"
+            elif regime == "BEAR":
+                selected_tp = tp_map.get('TP1') # خروج سريع في الهبوط
+                target_label = "TP1 (Scalp)"
+            else:
                 selected_tp = tp_map.get('TP2')
                 target_label = "TP2"
-            else:
-                selected_tp = tp_map.get('TP1')
-                target_label = "TP1"
                 
             if not selected_tp or selected_tp <= entry_price: selected_tp = entry_price * 1.02
 
@@ -237,35 +241,30 @@ class SmartPortfolio:
                 "approved_tp": float(selected_tp),
                 "target_label": target_label,
                 "system_confidence": system_confidence,
-                "risk_multiplier": risk_multiplier,
-                "market_mood": f"{self.market_trend} | FG:{self.fear_greed_index}"
+                "risk_multiplier": final_risk_mult,
+                "market_mood": f"{regime} | FG:{self.fear_greed_index}"
             }
 
     # ==============================================================================
-    # 🔒 Capital Tracking (Atomic Operations)
+    # 🔒 Capital Tracking
     # ==============================================================================
     async def register_new_position(self, size_usd: float):
-        """يتم استدعاؤها عند فتح الصفقة لحجز رأس المال"""
         async with self.capital_lock:
             self.state["allocated_capital_usd"] = float(self.state.get("allocated_capital_usd", 0.0)) + float(size_usd)
-            # حماية من الأخطاء الحسابية (لا يتجاوز الإجمالي)
             if self.state["allocated_capital_usd"] > self.state["current_capital"]:
                 self.state["allocated_capital_usd"] = self.state["current_capital"]
             await self._save_state_to_r2()
 
     async def register_closed_position(self, released_capital_usd: float, net_pnl: float, fees: float):
-        """يتم استدعاؤها عند الإغلاق لتحرير رأس المال وتحديث الربح"""
         async with self.capital_lock:
-            # 1. تحرير رأس المال المحجوز
             current_allocated = float(self.state.get("allocated_capital_usd", 0.0))
             self.state["allocated_capital_usd"] = max(0.0, current_allocated - released_capital_usd)
             
-            # 2. تحديث الرصيد الإجمالي (الصافي بعد الرسوم)
-            net_impact = net_pnl - fees # نخصم الرسوم هنا لضمان الدقة
+            net_impact = net_pnl - fees
             self.state["current_capital"] += net_impact
             self.state["daily_net_pnl"] += net_impact
             
-            # 3. فحص الخسارة اليومية
+            # Check Daily Limit after trade
             start = self.state["session_start_balance"]
             dd = (start - self.state["current_capital"]) / start if start > 0 else 0
             if dd >= self.DAILY_LOSS_LIMIT_PCT:
@@ -273,7 +272,6 @@ class SmartPortfolio:
                 self.state["halt_reason"] = "Daily Limit Hit After Exit"
             
             await self._save_state_to_r2()
-            print(f"💰 [Portfolio] Capital Released: ${released_capital_usd:.2f} | Net Change: ${net_impact:+.2f}")
 
     # ==============================================================================
     # 💾 Utilities
@@ -293,8 +291,6 @@ class SmartPortfolio:
             if data: 
                 loaded = json.loads(data)
                 self.state.update(loaded)
-                # ضمان وجود المفاتيح الجديدة في حال الترقية من نسخة قديمة
-                if "allocated_capital_usd" not in self.state: self.state["allocated_capital_usd"] = 0.0
             else:
                 old = await self.r2.get_portfolio_state_async()
                 if old: 
@@ -305,8 +301,4 @@ class SmartPortfolio:
     async def _save_state_to_r2(self):
         try:
             await self.r2.upload_json_async(self.state, "smart_portfolio_state.json")
-            # تحديث الملف القديم للتوافق
-            existing = await self.r2.get_portfolio_state_async()
-            existing["current_capital_usd"] = self.state["current_capital"]
-            await self.r2.save_portfolio_state_async(existing)
         except: pass