Update whale_monitor/rpc_manager.py

whale_monitor/rpc_manager.py

@@ -18,10 +18,8 @@ RPC_HEALTH_CHECK_WINDOW = 10  # تتبع آخر 10 طلبات
 RPC_ERROR_THRESHOLD = 3       # عدد الأخطاء المتتالية لإيقاف مؤقت
 RPC_CIRCUIT_BREAKER_DURATION = 300 # 5 دقائق إيقاف مؤقت
 
-# 🔴 --- START OF CHANGE --- 🔴
 # (إضافة ثابت لفرض تأخير بين طلبات CoinGecko)
 COINGECKO_REQUEST_DELAY = 2.0  # 2.0 ثانية (يساوي 30 طلب/دقيقة كحد أقصى)
-# 🔴 --- END OF CHANGE --- 🔴
 
 class AdaptiveRpcManager:
     """
@@ -36,10 +34,8 @@ class AdaptiveRpcManager:
         self.rpc_semaphore = asyncio.Semaphore(5)  # حد عام لـ RPC
         self.coingecko_semaphore = asyncio.Semaphore(1) # حد خاص لـ CoinGecko
         
-        # 🔴 --- START OF CHANGE --- 🔴
         # (متغير لتتبع وقت آخر طلب لـ CoinGecko)
         self.last_coingecko_call = 0.0
-        # 🔴 --- END OF CHANGE --- 🔴
         
         # تهيئة إعدادات الشبكة ونقاط RPC
         self.network_configs = self._initialize_network_configs(DEFAULT_NETWORK_CONFIGS)
@@ -160,7 +156,11 @@ class AdaptiveRpcManager:
             health['consecutive_errors'] += 1
             health['total_errors'] += 1
             health['last_error_time'] = time.time()
-            if health['consecutive_errors'] >= RPC_CIRCUIT_BREAKER_THRESHOLD:
+            
+            # 🔴 --- START OF CHANGE --- 🔴
+            # (تصحيح الخطأ الطباعي: استخدام RPC_ERROR_THRESHOLD)
+            if health['consecutive_errors'] >= RPC_ERROR_THRESHOLD:
+            # 🔴 --- END OF CHANGE --- 🔴
                 health['circuit_open'] = True
                 print(f"🚨 [RPC Manager] قاطع الدائرة مفعل! إيقاف مؤقت لـ: {endpoint.split('//')[-1]}")
 
@@ -214,7 +214,6 @@ class AdaptiveRpcManager:
         try:
             async with semaphore:
                 
-                # 🔴 --- START OF CHANGE --- 🔴
                 # (تطبيق "الخنق" لـ CoinGecko)
                 if use_coingecko_semaphore:
                     current_time = time.time()
@@ -227,12 +226,10 @@ class AdaptiveRpcManager:
                     
                     # (تحديث وقت آخر استدعاء *قبل* الطلب)
                     self.last_coingecko_call = time.time()
-                # 🔴 --- END OF CHANGE --- 🔴
 
                 response = await self.http_client.get(base_url, params=params, headers=headers, timeout=timeout)
                 
                 if response.status_code == 429: # Too Many Requests
-                    # 🔴 --- START OF CHANGE --- 🔴
                     # (زيادة وقت الانتظار)
                     wait_duration = 15.0
                     print(f"⚠️ [GET] خطأ 429 (Rate Limit) من {base_url}. الانتظار {wait_duration} ثوان...")
@@ -241,7 +238,6 @@ class AdaptiveRpcManager:
                     # (تحديث وقت آخر استدعاء مرة أخرى بعد الانتظار)
                     if use_coingecko_semaphore:
                         self.last_coingecko_call = time.time()
-                    # 🔴 --- END OF CHANGE --- 🔴
 
                     # إعادة المحاولة مرة واحدة
                     response = await self.http_client.get(base_url, params=params, headers=headers, timeout=timeout)