Update trade_manager.py

trade_manager.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🛡️ trade_manager.py (V38.0 - GEM-Architect: Diagnostics Logic)
+# 🛡️ trade_manager.py (V61.1 - GEM-Architect: Full Integrity)
 # ============================================================
 
 import asyncio
@@ -43,9 +43,16 @@ class TradeManager:
             "giveback": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
             "stagnation": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0}
         }
+
+        # 📊 [NEW] إحصائيات أنواع العملات (الجديدة)
+        # الهيكل: الاسم، الفوز، الخسارة، الربح (USD)، الخسارة (USD)
+        self.type_stats = {
+            "SAFE_BOTTOM": {"wins": 0, "losses": 0, "profit_usd": 0.0, "loss_usd": 0.0},
+            "MOMENTUM_LAUNCH": {"wins": 0, "losses": 0, "profit_usd": 0.0, "loss_usd": 0.0}
+        }
         
         self.execution_lock = asyncio.Lock()
-        print(f"🛡️ [TradeManager V38.0] Full System Online (Diagnostics Ready).")
+        print(f"🛡️ [TradeManager V61.1] Full System Online (Diagnostics + Type Stats).")
 
     async def initialize_sentry_exchanges(self):
         """تهيئة المحفظة واستعادة الحالة"""
@@ -60,6 +67,29 @@ class TradeManager:
             print("   -> [Stats] Guardian metrics loaded from R2.")
         except Exception: pass
 
+        # ✅ تحميل إحصائيات الأنواع (Persistent Type Stats)
+        await self._load_type_stats_from_r2()
+
+    async def _load_type_stats_from_r2(self):
+        """تحميل إحصائيات أنواع العملات من R2"""
+        try:
+            # ملف منفصل لضمان عدم تصفيره مع السجلات الأخرى بالخطأ
+            saved_stats = await self.r2.get_file_json_async("stats/coin_type_performance_v1.json")
+            if saved_stats:
+                self.type_stats = saved_stats
+                print("   📊 [Stats] Coin Type performance loaded from R2.")
+            else:
+                print("   ℹ️ [Stats] No existing type stats found. Starting fresh.")
+        except Exception:
+            print("   ⚠️ [Stats] Error loading type stats.")
+
+    async def _save_type_stats_to_r2(self):
+        """حفظ إحصائيات الأنواع إلى R2"""
+        try:
+            await self.r2.upload_json_async(self.type_stats, "stats/coin_type_performance_v1.json")
+        except Exception as e:
+            print(f"❌ Failed to save type stats: {e}")
+
     async def sync_internal_state_with_r2(self):
         """استرجاع الصفقات المفتوحة من R2"""
         try:
@@ -125,7 +155,7 @@ class TradeManager:
             sniper_signal = sniper_result.get('signal', 'WAIT')
             final_conf = sniper_result.get('confidence_prob', 0.0)
             
-            log_msg = (f"   -> 🔭 {symbol:<6} | Decision: {sniper_signal} | Score: {final_conf:.2f} | 📝 {sniper_result.get('reason','N/A')}")
+            log_msg = (f"   -> 🔭 {symbol:<6} | Decision: {sniper_signal} | Score: {final_conf:.2f} | Type: {signal.get('strategy_type', 'N/A')}")
             print(log_msg)
 
             if sniper_signal == 'BUY':
@@ -262,8 +292,11 @@ class TradeManager:
             
             ohlcv_dict = {'15m': t15, '1h': t1h}
             
-            # تقييم الحوكمة
-            gov_decision = await self.governance.evaluate_trade(symbol, ohlcv_dict, ob)
+            # ✅ تمرير نوع الاستراتيجية للحوكمة (لتعديل الأوزان داخلياً إن لزم الأمر)
+            strategy_type = signal_data.get('strategy_type', 'NORMAL')
+
+            # تقييم الحوكمة مع تمرير نوع الاستراتيجية
+            gov_decision = await self.governance.evaluate_trade(symbol, ohlcv_dict, ob, strategy_type=strategy_type)
             
             if gov_decision['grade'] == 'REJECT':
                 print(f"⛔ [Governance VETO] {symbol} Rejected by Senate. Grade: REJECT | Score: {gov_decision['governance_score']:.1f}")
@@ -324,7 +357,9 @@ class TradeManager:
                 'entry_capital': approved_size_usd, 
                 'entry_fee_usd': entry_fee_usd,
                 'decision_data': decision_snapshot, 
-                'highest_price': current_price
+                'highest_price': current_price,
+                # ✅ حفظ نوع الاستراتيجية في الصفقة
+                'strategy_type': strategy_type
             }
             
             self.open_positions[symbol] = new_trade
@@ -354,7 +389,7 @@ class TradeManager:
                 model_votes
             ))
             
-            print(f"✅ [ENTRY] {symbol} @ {current_price} | Grade: {gov_decision['grade']} | Size: ${approved_size_usd:.2f} | TP: {approved_tp} ({target_label}) | Mood: {market_mood}")
+            print(f"✅ [ENTRY] {symbol} @ {current_price} | Type: {strategy_type} | Grade: {gov_decision['grade']} | Size: ${approved_size_usd:.2f}")
 
         except Exception as e:
             print(f"❌ [Entry Error] {symbol}: {e}")
@@ -564,11 +599,24 @@ class TradeManager:
                 portfolio['total_loss_usd'] = portfolio.get('total_loss_usd', 0) + abs(true_net_pnl_usd)
                 trade['result'] = 'LOSS'
 
+            # ✅ 2. تحديث إحصائيات الأنواع (Persistent Type Stats)
+            strat_type = trade.get('strategy_type', 'UNKNOWN')
+            if strat_type in self.type_stats:
+                if true_net_pnl_usd >= 0:
+                    self.type_stats[strat_type]['wins'] += 1
+                    self.type_stats[strat_type]['profit_usd'] += true_net_pnl_usd
+                else:
+                    self.type_stats[strat_type]['losses'] += 1
+                    self.type_stats[strat_type]['loss_usd'] += true_net_pnl_usd 
+                
+                # حفظ فوري لضمان عدم الضياع
+                asyncio.create_task(self._save_type_stats_to_r2())
+
             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)
             
-            print(f"✅ [EXIT] {symbol} | Net PnL: {true_net_pct:.2f}% (${true_net_pnl_usd:.2f}) | {reason}")
+            print(f"✅ [EXIT] {symbol} | Type: {strat_type} | PnL: {true_net_pct:.2f}% (${true_net_pnl_usd:.2f}) | {reason}")
             
             # ==========================================================
             # 🏛️ إرسال البيانات لملف تدريب الحوكمة (Governance Training Data)
@@ -586,7 +634,8 @@ class TradeManager:
                         "entry_price": trade['entry_price'],
                         "exit_price": trade['exit_price'],
                         "profit_pct": true_net_pct,
-                        "result": trade['result']
+                        "result": trade['result'],
+                        "strategy_type": strat_type # Added for context
                     }
                     # إرسال إلى R2 في الخلفية
                     asyncio.create_task(self.r2.append_governance_training_data(training_record))