Update r2.py

r2.py

@@ -1,4 +1,4 @@
-# r2.py (V12.1 - GEM-Architect: Full Code with Reset Function)
+# r2.py (V13.0 - GEM-Architect: Full Code with DeepSteward Audit)
 import os
 import traceback
 import json
@@ -17,7 +17,7 @@ R2_ACCESS_KEY_ID = os.getenv("R2_ACCESS_KEY_ID")
 R2_SECRET_ACCESS_KEY = os.getenv("R2_SECRET_ACCESS_KEY")
 BUCKET_NAME = "trading"
 
-# 🔴 الرصيد الافتراضي (تم تعديله ليكون 10 دولار)
+# 🔴 الرصيد الافتراضي
 INITIAL_CAPITAL = 10.0 
 
 # 📁 مفاتيح الملفات في R2
@@ -58,7 +58,7 @@ class R2Service:
             raise RuntimeError(f"Failed to initialize S3 client: {e}")
 
     # ==============================================================================
-    # 🔴 [هام جداً] دالة التصفير الشامل (هذه هي الدالة المفقودة)
+    # 🔴 [هام جداً] دالة التصفير الشامل
     # ==============================================================================
     async def reset_all_stats_async(self):
         """تصفير المحفظة والسجلات التاريخية والعودة لنقطة الصفر"""
@@ -69,7 +69,7 @@ class R2Service:
             initial_state = {
                 "current_capital_usd": INITIAL_CAPITAL,
                 "invested_capital_usd": 0.0,
-                "initial_capital_usd": INITIAL_CAPITAL, # تثبيت القيمة الأولية
+                "initial_capital_usd": INITIAL_CAPITAL,
                 "total_trades": 0,
                 "winning_trades": 0,
                 "losing_trades": 0,
@@ -216,6 +216,35 @@ class R2Service:
             )
         except Exception:
             pass
+    
+    # ==============================================================================
+    # 🧠 سجلات DeepSteward (Post-Exit Analysis) - [NEW]
+    # ==============================================================================
+    async def append_deep_steward_audit(self, audit_record: Dict[str, Any]):
+        """
+        حفظ تحليل ما بعد الخروج في ملف خاص بالنموذج.
+        """
+        try:
+            # اسم الملف يعتمد على اسم النموذج لضمان التنظيم
+            file_key = "DeepSteward_Audit_Log.json" 
+            
+            try:
+                response = self.s3_client.get_object(Bucket=self.BUCKET_NAME, Key=file_key)
+                history = json.loads(response['Body'].read())
+            except ClientError:
+                history = []
+            
+            history.append(audit_record)
+            # نحتفظ بآخر 1000 سجل فقط لعدم تضخم الملف
+            if len(history) > 1000: history = history[-1000:]
+            
+            data_json = json.dumps(history, indent=2, ensure_ascii=False).encode('utf-8')
+            self.s3_client.put_object(
+                Bucket=self.BUCKET_NAME, Key=file_key, Body=data_json, ContentType="application/json"
+            )
+            print(f"📝 [R2 Audit] تم تسجيل نتيجة قرار DeepSteward لـ {audit_record.get('symbol')}")
+        except Exception as e:
+            print(f"❌ [R2 Error] فشل حفظ سجل التدقيق: {e}")
 
     # ==============================================================================
     # 🧠 بيانات التعلم العام
@@ -464,4 +493,4 @@ class R2Service:
     async def load_whale_learning_config_async(self) -> Dict[str, Any]:
         return await self._load_json_file_from_r2(WHALE_LEARNING_CONFIG_KEY, default={})
 
-print("✅ Full R2 Service Loaded - Accounting, History & Reset Ready")
+print("✅ Full R2 Service Loaded - Accounting, History, Reset & Audit Ready")