Update r2.py

r2.py

@@ -1,4 +1,4 @@
-# r2.py (V11.0 - GEM-Architect: Full Stack Restoration & Accounting Fix)
+# r2.py (V12.1 - GEM-Architect: Full Code with Reset Function)
 import os
 import traceback
 import json
@@ -17,21 +17,18 @@ R2_ACCESS_KEY_ID = os.getenv("R2_ACCESS_KEY_ID")
 R2_SECRET_ACCESS_KEY = os.getenv("R2_SECRET_ACCESS_KEY")
 BUCKET_NAME = "trading"
 
-# الرصيد الافتراضي عند إنشاء محفظة جديدة (تم تحديثه ليكون منطقياً للمحاكاة)
-INITIAL_CAPITAL = 100.0 
+# 🔴 الرصيد الافتراضي (تم تعديله ليكون 10 دولار)
+INITIAL_CAPITAL = 10.0 
 
-# 📁 مفاتيح الملفات في R2 (File Keys)
-# 1. التعلم العميق للحيتان
+# 📁 مفاتيح الملفات في R2
 WHALE_LEARNING_PENDING_KEY = "learning_whale_pending_records.json"
 WHALE_LEARNING_COMPLETED_KEY = "learning_whale_completed_records.json"
 WHALE_LEARNING_CONFIG_KEY = "learning_whale_optimal_config.json"
 
-# 2. المحاسبة والتاريخ
 PORTFOLIO_STATE_KEY = "portfolio_state.json"
 OPEN_TRADES_KEY = "open_trades.json"
 CLOSED_TRADES_KEY = "closed_trades_history.json"
 
-# 3. النظام والمرشحين
 CANDIDATES_KEY = "Candidates.json"
 CONTRACTS_DB_KEY = "contracts.json"
 SYSTEM_LOGS_KEY = "system_logs.json"
@@ -53,7 +50,6 @@ class R2Service:
             self.lock_acquired = False
             self.BUCKET_NAME = BUCKET_NAME
             
-            # منع تكرار طباعة التحذيرات
             self._open_trades_warning_printed = False
             self._portfolio_warning_printed = False
             self._contracts_warning_printed = False
@@ -61,6 +57,49 @@ class R2Service:
         except Exception as e:
             raise RuntimeError(f"Failed to initialize S3 client: {e}")
 
+    # ==============================================================================
+    # 🔴 [هام جداً] دالة التصفير الشامل (هذه هي الدالة المفقودة)
+    # ==============================================================================
+    async def reset_all_stats_async(self):
+        """تصفير المحفظة والسجلات التاريخية والعودة لنقطة الصفر"""
+        try:
+            print("🔄 [R2 Reset] بدء عملية التصفير...")
+            
+            # 1. إعادة تعيين المحفظة للقيمة الأولية
+            initial_state = {
+                "current_capital_usd": INITIAL_CAPITAL,
+                "invested_capital_usd": 0.0,
+                "initial_capital_usd": INITIAL_CAPITAL, # تثبيت القيمة الأولية
+                "total_trades": 0,
+                "winning_trades": 0,
+                "losing_trades": 0,
+                "total_profit_usd": 0.0,
+                "total_loss_usd": 0.0,
+                "win_rate": 0.0,
+                "last_update": datetime.now().isoformat()
+            }
+            await self.save_portfolio_state_async(initial_state)
+            
+            # 2. مسح سجل الصفقات المغلقة (History)
+            empty_list_json = json.dumps([], indent=2).encode('utf-8')
+            self.s3_client.put_object(
+                Bucket=BUCKET_NAME, Key=CLOSED_TRADES_KEY, Body=empty_list_json, ContentType="application/json"
+            )
+            
+            # 3. مسح السجلات (Logs)
+            empty_logs_json = json.dumps({"logs": []}, indent=2).encode('utf-8')
+            self.s3_client.put_object(
+                Bucket=BUCKET_NAME, Key=SYSTEM_LOGS_KEY, Body=empty_logs_json, ContentType="application/json"
+            )
+            
+            print("✅ [R2 Reset] تم تصفير جميع البيانات والمحفظة بنجاح.")
+            return True
+            
+        except Exception as e:
+            print(f"❌ [R2 Reset Error] فشل التصفير: {e}")
+            traceback.print_exc()
+            return False
+
     # ==============================================================================
     # 🔒 إدارة القفل (Lock Mechanism)
     # ==============================================================================
@@ -83,7 +122,6 @@ class R2Service:
             except Exception as e:
                 print(f"❌ Failed to acquire lock: {e}")
                 time.sleep(1)
-        print(f"❌ Failed to acquire lock after {max_retries} attempts.")
         return False
 
     def release_lock(self):
@@ -100,7 +138,6 @@ class R2Service:
     # 📊 إدارة المرشحين (Candidates)
     # ==============================================================================
     async def save_candidates_async(self, candidates):
-        """حفظ بيانات المرشحين العشرة في ملف منفصل في R2"""
         try:
             data = {
                 "timestamp": datetime.now().isoformat(),
@@ -112,29 +149,16 @@ class R2Service:
                 Bucket=BUCKET_NAME, Key=CANDIDATES_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:
             response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=CANDIDATES_KEY)
             data = json.loads(response['Body'].read())
-            candidates = data.get('candidates', [])
-            print(f"✅ تم تحميل {len(candidates)} مرشح من R2")
-            return candidates
+            return data.get('candidates', [])
         except ClientError as e:
             if e.response['Error']['Code'] == 'NoSuchKey':
-                print("⚠️ لا يوجد ملف مرشحين سابق")
                 return []
             else:
                 raise
@@ -143,16 +167,12 @@ class R2Service:
     # 📝 السجلات والتعلم (Logs & Debugging)
     # ==============================================================================
     async def save_llm_prompts_async(self, symbol, prompt_type, prompt_content, analysis_data=None):
-        """حفظ الـ Prompts المرسلة إلى النموذج الضخم"""
         try:
             try:
                 response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=LLM_PROMPTS_KEY)
                 existing_data = json.loads(response['Body'].read())
-            except ClientError as e:
-                if e.response['Error']['Code'] == 'NoSuchKey':
-                    existing_data = {"prompts": []}
-                else:
-                    raise
+            except ClientError:
+                existing_data = {"prompts": []}
             
             new_prompt = {
                 "timestamp": datetime.now().isoformat(),
@@ -163,7 +183,6 @@ class R2Service:
             }
             
             existing_data["prompts"].append(new_prompt)
-            # الاحتفاظ بآخر 2000 سجل فقط
             if len(existing_data["prompts"]) > 2000:
                 existing_data["prompts"] = existing_data["prompts"][-2000:]
             
@@ -171,20 +190,16 @@ class R2Service:
             self.s3_client.put_object(
                 Bucket=BUCKET_NAME, Key=LLM_PROMPTS_KEY, Body=data_json, ContentType="application/json"
             )
-            print(f"✅ تم حفظ prompt لـ {symbol} ({prompt_type}) في R2")
-        except Exception as e:
-            print(f"❌ فشل حفظ prompt لـ {symbol}: {e}")
+        except Exception:
+            pass
 
     async def save_system_logs_async(self, log_data):
         try:
             try:
                 response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=SYSTEM_LOGS_KEY)
                 existing_logs = json.loads(response['Body'].read())
-            except ClientError as e:
-                if e.response['Error']['Code'] == 'NoSuchKey':
-                    existing_logs = {"logs": []}
-                else:
-                    raise
+            except ClientError:
+                existing_logs = {"logs": []}
             
             log_entry = {
                 "timestamp": datetime.now().isoformat(),
@@ -199,12 +214,11 @@ class R2Service:
             self.s3_client.put_object(
                 Bucket=BUCKET_NAME, Key=SYSTEM_LOGS_KEY, Body=data_json, ContentType="application/json"
             )
-            print(f"✅ System log saved: {log_data.get('cycle_started', log_data.get('cycle_completed', 'event'))}")
-        except Exception as e:
-            print(f"❌ Failed to save system logs: {e}")
+        except Exception:
+            pass
 
     # ==============================================================================
-    # 🧠 بيانات التعلم العام (General Learning Data)
+    # 🧠 بيانات التعلم العام
     # ==============================================================================
     async def save_learning_data_async(self, learning_data):
         try:
@@ -216,41 +230,39 @@ class R2Service:
             self.s3_client.put_object(
                 Bucket=BUCKET_NAME, Key=LEARNING_DATA_KEY, Body=data_json, ContentType="application/json"
             )
-            print("✅ Learning data saved to R2")
-        except Exception as e:
-            print(f"❌ Failed to save learning data: {e}")
+        except Exception:
+            pass
 
     async def load_learning_data_async(self):
         try:
             response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=LEARNING_DATA_KEY)
-            data = json.loads(response['Body'].read())
-            print("✅ Learning data loaded from R2")
-            return data
-        except ClientError as e:
-            if e.response['Error']['Code'] == 'NoSuchKey':
-                print("⚠️ No learning data found. Starting fresh.")
-                return {}
-            else:
-                raise
+            return json.loads(response['Body'].read())
+        except ClientError:
+            return {}
 
     # ==============================================================================
-    # 💰 إدارة المحفظة (Accounting & Portfolio) - [معدل للمحاسبة]
+    # 💰 إدارة المحفظة (Accounting & Portfolio)
     # ==============================================================================
     async def get_portfolio_state_async(self):
         try:
             response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=PORTFOLIO_STATE_KEY)
             state = json.loads(response['Body'].read())
+            
+            # إصلاح البيانات القديمة إن وجدت
+            if 'losing_trades' not in state: state['losing_trades'] = 0
+            if 'total_loss_usd' not in state: state['total_loss_usd'] = 0.0
+            if 'initial_capital_usd' not in state: state['initial_capital_usd'] = INITIAL_CAPITAL
+            
             if hasattr(self, '_portfolio_warning_printed'):
                 delattr(self, '_portfolio_warning_printed')
-            print(f"💰 Portfolio state loaded: Current Capital ${state.get('current_capital_usd', 0):.2f}")
+            print(f"💰 Portfolio loaded: Current Capital ${state.get('current_capital_usd', 0):.2f}")
             return state
         except ClientError as e:
             if e.response['Error']['Code'] == 'NoSuchKey':
                 if not hasattr(self, '_portfolio_warning_printed'):
-                    print(f"⚠️ No portfolio state file found. Initializing with ${INITIAL_CAPITAL:.2f}")
+                    print(f"⚠️ No portfolio state found. Initializing with ${INITIAL_CAPITAL}")
                     self._portfolio_warning_printed = True
                 
-                # تهيئة محفظة جديدة نظيفة
                 initial_state = {
                     "current_capital_usd": INITIAL_CAPITAL,
                     "invested_capital_usd": 0.0,
@@ -275,7 +287,7 @@ class R2Service:
             self.s3_client.put_object(
                 Bucket=BUCKET_NAME, Key=PORTFOLIO_STATE_KEY, Body=data_json, ContentType="application/json"
             )
-            print(f"💾 Portfolio state saved: Current Capital ${state.get('current_capital_usd', 0):.2f}")
+            print(f"💾 Portfolio saved: ${state.get('current_capital_usd', 0):.2f}")
         except Exception as e:
             print(f"❌ Failed to save portfolio state: {e}")
             raise
@@ -286,18 +298,9 @@ class R2Service:
     async def get_open_trades_async(self):
         try:
             response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=OPEN_TRADES_KEY)
-            trades = json.loads(response['Body'].read())
-            if hasattr(self, '_open_trades_warning_printed'):
-                delattr(self, '_open_trades_warning_printed')
-            return trades
-        except ClientError as e:
-            if e.response['Error']['Code'] == 'NoSuchKey':
-                if not hasattr(self, '_open_trades_warning_printed'):
-                    print("⚠️ No open trades file found. Starting with an empty list.")
-                    self._open_trades_warning_printed = True
-                return []
-            else:
-                raise
+            return json.loads(response['Body'].read())
+        except ClientError:
+            return []
     
     async def save_open_trades_async(self, trades):
         try:
@@ -305,29 +308,18 @@ class R2Service:
             self.s3_client.put_object(
                 Bucket=BUCKET_NAME, Key=OPEN_TRADES_KEY, Body=data_json, ContentType="application/json"
             )
-            print(f"✅ Open trades saved to R2. Total open trades: {len(trades)}")
         except Exception as e:
             print(f"❌ Failed to save open trades: {e}")
-            raise
 
-    # 🔴 [جديد] أرشفة الصفقات المغلقة 🔴
     async def append_to_closed_trades_history(self, trade_data: Dict[str, Any]):
-        """إضافة صفقة مغلقة إلى السجل التاريخي الدائم"""
         try:
-            # 1. تحميل السجل القديم
             try:
                 response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=CLOSED_TRADES_KEY)
                 history = json.loads(response['Body'].read())
-            except ClientError as e:
-                if e.response['Error']['Code'] == 'NoSuchKey':
-                    history = []
-                else:
-                    raise
+            except ClientError:
+                history = []
 
-            # 2. إضافة الصفقة الجديدة
             history.append(trade_data)
-            
-            # 3. حفظ السجل (نحتفظ بآخر 1000 صفقة فقط)
             if len(history) > 1000:
                 history = history[-1000:]
                 
@@ -335,13 +327,12 @@ class R2Service:
             self.s3_client.put_object(
                 Bucket=BUCKET_NAME, Key=CLOSED_TRADES_KEY, Body=data_json, ContentType="application/json"
             )
-            print(f"📜 [R2 History] تم أرشفة الصفقة {trade_data.get('symbol')} في السجل التاريخي.")
+            print(f"📜 History archived for {trade_data.get('symbol')}")
             
         except Exception as e:
-            print(f"❌ [R2 Error] فشل حفظ الصفقة في السجل التاريخي: {e}")
+            print(f"❌ Failed to archive trade: {e}")
 
     async def get_closed_trades_history(self):
-        """جلب سجل الصفقات التاريخية"""
         try:
             response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=CLOSED_TRADES_KEY)
             return json.loads(response['Body'].read())
@@ -349,24 +340,14 @@ class R2Service:
             return []
 
     # ==============================================================================
-    # 📜 قاعدة بيانات العقود (Contracts DB)
+    # 📜 قاعدة بيانات العقود
     # ==============================================================================
     async def load_contracts_db_async(self):
         try:
             response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=CONTRACTS_DB_KEY)
-            contracts_db = json.loads(response['Body'].read())
-            if hasattr(self, '_contracts_warning_printed'):
-                delattr(self, '_contracts_warning_printed')
-            print(f"💾 Contracts database loaded from R2. Total entries: {len(contracts_db)}")
-            return contracts_db
-        except ClientError as e:
-            if e.response['Error']['Code'] == 'NoSuchKey':
-                if not hasattr(self, '_contracts_warning_printed'):
-                    print("⚠️ No existing contracts database found. Initializing new one.")
-                    self._contracts_warning_printed = True
-                return {}
-            else:
-                raise
+            return json.loads(response['Body'].read())
+        except ClientError:
+            return {}
     
     async def save_contracts_db_async(self, data):
         try:
@@ -374,13 +355,11 @@ class R2Service:
             self.s3_client.put_object(
                 Bucket=BUCKET_NAME, Key=CONTRACTS_DB_KEY, Body=data_json, ContentType="application/json"
             )
-            print(f"✅ Contracts database saved to R2 successfully. Total entries: {len(data)}")
-        except Exception as e:
-            print(f"❌ Failed to save contracts database to R2: {e}")
-            raise
+        except Exception:
+            pass
 
     # ==============================================================================
-    # 🛠️ أدوات مساعدة (Utilities)
+    # 🛠️ أدوات مساعدة
     # ==============================================================================
     async def get_trade_by_symbol_async(self, symbol):
         try:
@@ -389,8 +368,7 @@ class R2Service:
                 if trade['symbol'] == symbol and trade['status'] == 'OPEN':
                     return trade
             return None
-        except Exception as e:
-            print(f"❌ Failed to get trade by symbol {symbol}: {e}")
+        except Exception:
             return None
 
     async def update_trade_monitoring_status_async(self, symbol, is_monitored):
@@ -404,149 +382,86 @@ class R2Service:
                     break
             if updated:
                 await self.save_open_trades_async(open_trades)
-                status = "ENABLED" if is_monitored else "DISABLED"
-                print(f"✅ Real-time monitoring {status} for {symbol}")
-            else:
-                print(f"⚠️ Trade {symbol} not found for monitoring status update")
-            return updated
-        except Exception as e:
-            print(f"❌ Failed to update monitoring status for {symbol}: {e}")
+                return True
+            return False
+        except Exception:
             return False
 
     async def get_monitored_trades_async(self):
         try:
             open_trades = await self.get_open_trades_async()
-            monitored_trades = [trade for trade in open_trades if trade.get('is_monitored', False)]
-            return monitored_trades
-        except Exception as e:
-            print(f"❌ Failed to get monitored trades: {e}")
+            return [trade for trade in open_trades if trade.get('is_monitored', False)]
+        except Exception:
             return []
     
     async def save_analysis_audit_log_async(self, audit_data):
-        """حفظ سجل تدقيق دورة التحليل (يحتفظ بآخر 50 دورة)"""
         try:
-            # 1. جلب السجل الحالي (إن وجد)
             try:
                 response = self.s3_client.get_object(Bucket=BUCKET_NAME, Key=ANALYSIS_AUDIT_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
+                history = json.loads(response['Body'].read())
+            except ClientError:
+                history = []
             
-            # 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=ANALYSIS_AUDIT_KEY, Body=data_json, ContentType="application/json"
             )
-            print(f"📊 تم حفظ سجل تدقيق التحليل بنجاح في R2 (إجمالي {len(history)} سجلات)")
-            
-        except Exception as e:
-            print(f"❌ فشل حفظ سجل تدقيق التحليل في R2: {e}")
+        except Exception:
+            pass
 
     # ==============================================================================
-    # 🐋 تعلم الحيتان (Whale Learning) - V10.2
+    # 🐋 تعلم الحيتان (Whale Learning)
     # ==============================================================================
-    
     async def _load_json_file_from_r2(self, key: str, default: Any = []) -> Any:
-        """دالة مساعدة لتحميل ملف JSON بأمان."""
         try:
             response = self.s3_client.get_object(Bucket=self.BUCKET_NAME, Key=key)
             return json.loads(response['Body'].read())
-        except ClientError as e:
-            if e.response['Error']['Code'] == 'NoSuchKey':
-                print(f"ℹ️ [R2Service] لم يتم العثور على ملف '{key}'. سيتم استخدام القيمة الافتراضية.")
-                return default
-            else:
-                print(f"❌ [R2Service] خطأ ClientError أثناء تحميل '{key}': {e}")
-                raise
-        except Exception as e:
-            print(f"❌ [R2Service] خطأ عام أثناء تحميل '{key}': {e}")
+        except Exception:
             return default
 
     async def _save_json_file_to_r2(self, key: str, data: Any):
-        """دالة مساعدة لحفظ ملف JSON بأمان."""
         try:
             data_json = json.dumps(data, indent=2, ensure_ascii=False).encode('utf-8')
-            self.s3_client.put_object(
-                Bucket=self.BUCKET_NAME, Key=key, Body=data_json, ContentType="application/json"
-            )
-        except Exception as e:
-            print(f"❌ [R2Service] فشل حفظ الملف '{key}' إلى R2: {e}")
-            traceback.print_exc()
+            self.s3_client.put_object(Bucket=self.BUCKET_NAME, Key=key, Body=data_json, ContentType="application/json")
+        except Exception:
+            pass
 
     async def save_whale_learning_record_async(self, record: Dict[str, Any]):
-        """يحفظ سجلاً 'معلقاً' جديداً في ملف PENDING."""
         try:
-            pending_records = await self._load_json_file_from_r2(WHALE_LEARNING_PENDING_KEY, default=[])
-            pending_records.append(record)
-            await self._save_json_file_to_r2(WHALE_LEARNING_PENDING_KEY, pending_records)
-            print(f"✅ [R2Service] تم حفظ سجل تعلم الحيتان (PENDING) لـ {record['symbol']}.")
-        except Exception as e:
-            print(f"❌ [R2Service] فشل في save_whale_learning_record_async: {e}")
+            pending = await self._load_json_file_from_r2(WHALE_LEARNING_PENDING_KEY, default=[])
+            pending.append(record)
+            await self._save_json_file_to_r2(WHALE_LEARNING_PENDING_KEY, pending)
+        except Exception: pass
 
     async def get_pending_whale_learning_records_async(self) -> List[Dict[str, Any]]:
-        """يجلب جميع السجلات 'المعلقة' من ملف PENDING."""
-        try:
-            return await self._load_json_file_from_r2(WHALE_LEARNING_PENDING_KEY, default=[])
-        except Exception as e:
-            print(f"❌ [R2Service] فشل في get_pending_whale_learning_records_async: {e}")
-            return []
+        return await self._load_json_file_from_r2(WHALE_LEARNING_PENDING_KEY, default=[])
 
     async def update_completed_whale_learning_record_async(self, completed_record: Dict[str, Any]):
-        """يحفظ السجل 'المكتمل' في ملف COMPLETED ويزيله من PENDING."""
         try:
             record_id = completed_record.get("record_id")
-            if not record_id:
-                print("❌ [R2Service] لا يمكن تحديث سجل مكتمل بدون record_id.")
-                return
-
-            # 1. الحفظ في ملف المكتمل (يحتفظ بآخر 5000 سجل مكتمل)
-            completed_records = await self._load_json_file_from_r2(WHALE_LEARNING_COMPLETED_KEY, default=[])
-            completed_records.append(completed_record)
-            if len(completed_records) > 5000:
-                completed_records = completed_records[-5000:]
-            await self._save_json_file_to_r2(WHALE_LEARNING_COMPLETED_KEY, completed_records)
-
-            # 2. الإزالة من ملف المعلق
-            pending_records = await self._load_json_file_from_r2(WHALE_LEARNING_PENDING_KEY, default=[])
-            updated_pending_records = [
-                rec for rec in pending_records if rec.get("record_id") != record_id
-            ]
-            await self._save_json_file_to_r2(WHALE_LEARNING_PENDING_KEY, updated_pending_records)
-            
-            print(f"✅ [R2Service] تم نقل سجل تعلم الحيتان (COMPLETED) لـ {completed_record['symbol']} (ID: {record_id}).")
+            if not record_id: return
+
+            completed = await self._load_json_file_from_r2(WHALE_LEARNING_COMPLETED_KEY, default=[])
+            completed.append(completed_record)
+            if len(completed) > 5000: completed = completed[-5000:]
+            await self._save_json_file_to_r2(WHALE_LEARNING_COMPLETED_KEY, completed)
+
+            pending = await self._load_json_file_from_r2(WHALE_LEARNING_PENDING_KEY, default=[])
+            updated_pending = [r for r in pending if r.get("record_id") != record_id]
+            await self._save_json_file_to_r2(WHALE_LEARNING_PENDING_KEY, updated_pending)
+        except Exception: pass
 
-        except Exception as e:
-            print(f"❌ [R2Service] فشل في update_completed_whale_learning_record_async: {e}")
-            
     async def get_all_completed_whale_records_async(self) -> List[Dict[str, Any]]:
-        """يجلب جميع السجلات المكتملة."""
-        try:
-            return await self._load_json_file_from_r2(WHALE_LEARNING_COMPLETED_KEY, default=[])
-        except Exception as e:
-            print(f"❌ [R2Service] فشل في get_all_completed_whale_records_async: {e}")
-            return []
+        return await self._load_json_file_from_r2(WHALE_LEARNING_COMPLETED_KEY, default=[])
             
     async def save_whale_learning_config_async(self, config: Dict[str, Any]):
-        """يحفظ ملف الإعدادات (الأوزان) الذي نتج عن التعلم."""
         await self._save_json_file_to_r2(WHALE_LEARNING_CONFIG_KEY, config)
-        print(f"✅ [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 Modules Ready")
+print("✅ Full R2 Service Loaded - Accounting, History & Reset Ready")