Update r2.py

r2.py

@@ -1,5 +1,5 @@
 # ==============================================================================
-# ☁️ r2.py (V37.1 - GEM-Architect: Governance Training Data Ready)
+# ☁️ r2.py (V38.0 - GEM-Architect: Diagnostic Matrix & Guardian Persistence)
 # ==============================================================================
 
 import os
@@ -45,6 +45,10 @@ DEEP_STEWARD_AUDIT_KEY = "DeepSteward_Audit_Log.json"
 # ✅ مفتاح جديد خاص ببيانات تدريب الحوكمة (156 مؤشر + النتيجة)
 GOVERNANCE_TRAINING_KEY = "datasets/governance_training_data.json"
 
+# 📊 مفاتيح التحليلات والتشخيص (جديد)
+DIAGNOSTIC_STATS_KEY = "analytics/model_diagnostic_matrix.json"
+GUARDIAN_STATS_KEY = "analytics/guardian_performance_stats.json"
+
 # 🧬 مفاتيح النظام السيبراني
 STRATEGIC_DNA_KEY = "learning/strategic_dna_v2.json"
 
@@ -65,6 +69,7 @@ class R2Service:
             )
             self.lock_acquired = False
             self.BUCKET_NAME = BUCKET_NAME
+            print(f"✅ [R2 V38.0] Service Loaded (Diagnostics Ready).")
             
         except Exception as e:
             raise RuntimeError(f"Failed to initialize S3 client: {e}")
@@ -122,6 +127,10 @@ class R2Service:
             
             await asyncio.to_thread(_reset_sync)
             
+            # تصفير المصفوفات أيضاً عند الطلب الشامل
+            await self.reset_diagnostic_stats_async()
+            await self.reset_guardian_stats_async()
+            
             print("✅ [R2 Reset] تم تصفير جميع البيانات والمحفظة بنجاح.")
             return True
             
@@ -172,6 +181,78 @@ class R2Service:
             print(f"❌ [R2] File upload failed for {key}: {e}")
             raise
 
+    # ==============================================================================
+    # 📊 Diagnostic & Guardian Stats (New Feature)
+    # ==============================================================================
+    async def get_diagnostic_stats_async(self) -> Dict[str, Any]:
+        """استرجاع مصفوفة التشخيص"""
+        try:
+            data = await self.get_file_async(DIAGNOSTIC_STATS_KEY)
+            defaults = {
+                "Titan": {"wins": 0, "losses": 0, "pnl": 0.0},
+                "Patterns": {"wins": 0, "losses": 0, "pnl": 0.0},
+                "Oracle": {"wins": 0, "losses": 0, "pnl": 0.0},
+                "Sniper": {"wins": 0, "losses": 0, "pnl": 0.0},
+                "MonteCarlo_L": {"wins": 0, "losses": 0, "pnl": 0.0},
+                "MonteCarlo_A": {"wins": 0, "losses": 0, "pnl": 0.0},
+                "Governance": {"wins": 0, "losses": 0, "pnl": 0.0}
+            }
+            loaded = json.loads(data) if data else {}
+            # دمج القيم الافتراضية لضمان وجود المفاتيح
+            for k, v in defaults.items():
+                if k not in loaded: loaded[k] = v
+            return loaded
+        except: return {}
+
+    async def update_diagnostic_stats_async(self, updates: Dict[str, Dict[str, float]]):
+        """تحديث إحصائيات النماذج بشكل آمن"""
+        try:
+            current = await self.get_diagnostic_stats_async()
+            for model, metrics in updates.items():
+                if model not in current: current[model] = {"wins": 0, "losses": 0, "pnl": 0.0}
+                current[model]['wins'] += metrics.get('wins', 0)
+                current[model]['losses'] += metrics.get('losses', 0)
+                current[model]['pnl'] += metrics.get('pnl', 0.0)
+            
+            await self.upload_json_async(current, DIAGNOSTIC_STATS_KEY)
+        except Exception as e:
+            print(f"❌ [R2] Failed to update diagnostics: {e}")
+
+    async def reset_diagnostic_stats_async(self):
+        """تصفير مصفوفة التشخيص"""
+        empty = {k: {"wins": 0, "losses": 0, "pnl": 0.0} for k in 
+                 ["Titan", "Patterns", "Oracle", "Sniper", "MonteCarlo_L", "MonteCarlo_A", "Governance"]}
+        await self.upload_json_async(empty, DIAGNOSTIC_STATS_KEY)
+        print("📊 [R2] Diagnostic Matrix Reset.")
+
+    # --- Guardian Stats ---
+    async def get_guardian_stats_async(self) -> Dict[str, Any]:
+        data = await self.get_file_async(GUARDIAN_STATS_KEY)
+        defaults = {
+            "hybrid": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
+            "crash":  {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
+            "giveback": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
+            "stagnation": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0}
+        }
+        loaded = json.loads(data) if data else {}
+        for k, v in defaults.items():
+            if k not in loaded: loaded[k] = v
+        return loaded
+
+    async def save_guardian_stats_async(self, stats: Dict[str, Any]):
+        await self.upload_json_async(stats, GUARDIAN_STATS_KEY)
+        
+    async def reset_guardian_stats_async(self):
+        """تصفير إحصائيات الحراس"""
+        defaults = {
+            "hybrid": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
+            "crash":  {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
+            "giveback": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0},
+            "stagnation": {"total": 0, "good": 0, "saved": 0.0, "missed": 0.0}
+        }
+        await self.upload_json_async(defaults, GUARDIAN_STATS_KEY)
+        print("🛡️ [R2] Guardian Stats Reset.")
+
     # ==============================================================================
     # 🏛️ بيانات تدريب الحوكمة (Governance Training Data)
     # ==============================================================================
@@ -350,6 +431,4 @@ class R2Service:
         
     async def load_whale_learning_config_async(self) -> Dict[str, Any]:
         data = await self.get_file_async(WHALE_LEARNING_CONFIG_KEY)
-        return json.loads(data) if data else {}
-
-print("✅ [R2 V37.1] Service Loaded (Governance Data Ready).")
+        return json.loads(data) if data else {}