Update r2.py

r2.py

@@ -1,4 +1,4 @@
-# r2.py
+# r2.py (محدث)
 import os, traceback, json, time
 from datetime import datetime, timedelta
 import asyncio
@@ -333,5 +333,45 @@ class R2Service:
         except Exception as e:
             print(f"❌ Failed to get monitored trades: {e}")
             return []
+    
+    # 
+    # 🔴 دالة جديدة: لحفظ سجل تدقيق التحليل
+    #
+    async def save_analysis_audit_log_async(self, audit_data):
+        """حفظ سجل تدقيق دورة التحليل (يحتفظ بآخر 50 دورة)"""
+        try:
+            key = "analysis_audit_log.json"
+            
+            # 1. جلب السجل الحالي (إن وجد)
+            try:
+                response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=key)
+                existing_log_data = json.loads(response['Body'].read())
+                if isinstance(existing_log_data, list):
+                    history = existing_log_data
+                else:
+                    history = [] # بدء سجل جديد إذا كان التنسيق غير صالح
+            except ClientError as e:
+                if e.response['Error']['Code'] == 'NoSuchKey':
+                    history = [] # ملف جديد
+                else:
+                    raise
+            
+            # 2. إضافة الدورة الحالية
+            history.append(audit_data)
+            
+            # 3. الحفاظ على آخر 50 سجل فقط
+            if len(history) > 50:
+                history = history[-50:]
+            
+            # 4. حفظ الملف المحدث
+            data_json = json.dumps(history, indent=2, ensure_ascii=False).encode('utf-8')
+            self.s3_client.put_object(
+                Bucket=BUCKET_NAME, Key=key, Body=data_json, ContentType="application/json"
+            )
+            print(f"📊 تم حفظ سجل تدقيق التحليل بنجاح في R2 (إجمالي {len(history)} سجلات)")
+            
+        except Exception as e:
+            print(f"❌ فشل حفظ سجل تدقيق التحليل في R2: {e}")
+
 
 print("✅ Enhanced R2 Service Loaded - Comprehensive Logging System with Candidates Support")