Update r2.py

r2.py

@@ -63,6 +63,48 @@ class R2Service:
             except Exception as e:
                 print(f"❌ Failed to release lock: {e}")
 
+    async def save_candidates_async(self, candidates):
+        """حفظ بيانات المرشحين العشرة في ملف منفصل في R2"""
+        try:
+            key = "Candidates.json"
+            data = {
+                "timestamp": datetime.now().isoformat(),
+                "total_candidates": len(candidates),
+                "candidates": candidates
+            }
+            data_json = json.dumps(data, 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"✅ تم حفظ {len(candidates)} مرشح في ملف Candidates في R2")
+            
+            # عرض معلومات المرشحين المحفوظين
+            print("📊 المرشحون المحفوظون:")
+            for i, candidate in enumerate(candidates):
+                symbol = candidate.get('symbol', 'Unknown')
+                score = candidate.get('enhanced_final_score', 0)
+                strategy = candidate.get('target_strategy', 'GENERIC')
+                print(f"   {i+1}. {symbol}: {score:.3f} - {strategy}")
+                
+        except Exception as e:
+            print(f"❌ فشل حفظ المرشحين في R2: {e}")
+
+    async def load_candidates_async(self):
+        """تحميل بيانات المرشحين من R2"""
+        try:
+            key = "Candidates.json"
+            response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=key)
+            data = json.loads(response['Body'].read())
+            candidates = data.get('candidates', [])
+            print(f"✅ تم تحميل {len(candidates)} مرشح من R2")
+            return candidates
+        except ClientError as e:
+            if e.response['Error']['Code'] == 'NoSuchKey':
+                print("⚠️ لا يوجد ملف مرشحين سابق")
+                return []
+            else:
+                raise
+
     async def save_llm_prompts_async(self, symbol, prompt_type, prompt_content, analysis_data=None):
         """حفظ الـ Prompts المرسلة إلى النموذج الضخم"""
         try:
@@ -292,4 +334,4 @@ class R2Service:
             print(f"❌ Failed to get monitored trades: {e}")
             return []
 
-print("✅ Enhanced R2 Service Loaded - Comprehensive Logging System")
+print("✅ Enhanced R2 Service Loaded - Comprehensive Logging System with Candidates Support")