Update backtest_engine.py

backtest_engine.py

@@ -1,5 +1,5 @@
 # ============================================================
-# 🧪 backtest_engine.py (V85.0 - GEM-Architect: Full Audit)
+# 🧪 backtest_engine.py (V85.1 - GEM-Architect: Silent Fetcher)
 # ============================================================
 
 import asyncio
@@ -17,7 +17,6 @@ from typing import Dict, Any, List
 try:
     from ml_engine.processor import MLProcessor, SystemLimits 
     from ml_engine.data_manager import DataManager
-    # ✅ استيراد كامل للهب والاستراتيجية
     from learning_hub.adaptive_hub import StrategyDNA, AdaptiveHub
     from r2 import R2Service
 except ImportError:
@@ -36,7 +35,6 @@ class HeavyDutyBacktester:
         self.TRADING_FEES = 0.001 
         self.MAX_SLOTS = 4         
         
-        # القائمة الكاملة (50 عملة)
         self.TARGET_COINS = [ 
             'SOL/USDT', 'XRP/USDT', 'DOGE/USDT', 'ADA/USDT', 'AVAX/USDT', 
             'LINK/USDT', 'TON/USDT', 'INJ/USDT', 'APT/USDT', 'OP/USDT', 
@@ -54,7 +52,7 @@ class HeavyDutyBacktester:
         self.force_end_date = None   
         
         if not os.path.exists(CACHE_DIR): os.makedirs(CACHE_DIR)
-        print(f"🧪 [Backtest V85.0] Full Audit Mode (Detailed Stats).")
+        print(f"🧪 [Backtest V85.1] Silent Fetcher Mode (Clean Logs).")
 
     def set_date_range(self, start_str, end_str):
         self.force_start_date = start_str
@@ -65,7 +63,7 @@ class HeavyDutyBacktester:
         return df[['timestamp', 'open', 'high', 'low', 'close', 'volume']].values.tolist()
 
     # ==============================================================
-    # 🧱 Core Logic: Single Coin Processor (Safe Scope)
+    # 🧱 Core Logic: Single Coin Processor
     # ==============================================================
     async def _process_single_coin_task(self, sym, start_time_ms, end_time_ms):
         safe_sym = sym.replace('/', '_')
@@ -85,7 +83,6 @@ class HeavyDutyBacktester:
         
         try:
             current_since = start_time_ms
-            fetch_count = 0
             
             while current_since < end_time_ms:
                 try:
@@ -94,7 +91,7 @@ class HeavyDutyBacktester:
                         timeout=10.0
                     )
                 except:
-                    print(f"      ⚠️ [{sym}] Retry...", flush=True)
+                    # صامت عند إعادة المحاولة
                     await asyncio.sleep(1)
                     continue
 
@@ -105,10 +102,8 @@ class HeavyDutyBacktester:
                 
                 all_candles_1m.extend(batch)
                 current_since = last_ts + 1
-                fetch_count += 1
                 
-                if fetch_count % 5 == 0:
-                    print(f"      -> [{sym}] Fetched {len(all_candles_1m)} candles...", flush=True)
+                # 🔇 [Removed] Intermediate print logic here
                 
                 await asyncio.sleep(0.01)
                 if current_since >= end_time_ms: break
@@ -116,10 +111,11 @@ class HeavyDutyBacktester:
             all_candles_1m = [c for c in all_candles_1m if c[0] <= end_time_ms]
             
             if not all_candles_1m: 
-                print(f"   ❌ [{sym}] No data.")
+                print(f" ❌ No data.")
                 return False
 
-            print(f"   ✅ [{sym}] Downloaded {len(all_candles_1m)} candles. Processing...", flush=True)
+            # ✅ طباعة واحدة عند الانتهاء
+            print(f" ✅ Downloaded {len(all_candles_1m)} candles. Processing...", flush=True)
 
             df_1m = pd.DataFrame(all_candles_1m, columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
             cols = ['open', 'high', 'low', 'close', 'volume']
@@ -242,7 +238,7 @@ class HeavyDutyBacktester:
             await asyncio.sleep(1.0)
 
     # ==============================================================
-    # PHASE 2: Portfolio Digital Twin Engine (Full Audit Stats)
+    # PHASE 2: Portfolio Digital Twin Engine
     # ==============================================================
     @staticmethod
     def _worker_optimize(combinations_batch, scores_files, initial_capital, fees_pct, max_slots):
@@ -267,7 +263,7 @@ class HeavyDutyBacktester:
             w_struct = config['w_struct']
             entry_thresh = config['thresh']
             
-            # تتبع الـ Drawdown
+            # Tracking Drawdown
             peak_balance = initial_capital
             max_drawdown = 0.0
             
@@ -275,7 +271,7 @@ class HeavyDutyBacktester:
                 active_symbols = list(wallet["positions"].keys())
                 current_prices = {row['symbol']: row['close'] for _, row in group.iterrows()}
                 
-                # 1. Check Exits
+                # Check Exits
                 for sym in active_symbols:
                     if sym in current_prices:
                         curr_p = current_prices[sym]
@@ -292,15 +288,12 @@ class HeavyDutyBacktester:
                             del wallet["positions"][sym]
                             wallet["trades_history"].append({'pnl': net_pnl})
 
-                # تحديث قمة الرصيد وحساب Drawdown
-                current_total_equity = wallet["balance"] # نتجاهل العائم للسرعة، نحسب المحقق فقط
-                if current_total_equity > peak_balance:
-                    peak_balance = current_total_equity
-                
+                current_total_equity = wallet["balance"] 
+                if current_total_equity > peak_balance: peak_balance = current_total_equity
                 dd = (peak_balance - current_total_equity) / peak_balance
                 if dd > max_drawdown: max_drawdown = dd
 
-                # 2. Check Entries
+                # Check Entries
                 if len(wallet["positions"]) < max_slots:
                     free_capital = wallet["balance"] - wallet["allocated"]
                     slots_left = max_slots - len(wallet["positions"])
@@ -333,7 +326,6 @@ class HeavyDutyBacktester:
                 
                 if wallet["balance"] < 1.0 and len(wallet["positions"]) == 0: break
 
-            # 🔥🔥🔥 حساب الإحصائيات التفصيلية الكاملة 🔥🔥🔥
             trades = wallet["trades_history"]
             if trades:
                 net_profit = wallet["balance"] - initial_capital
@@ -341,26 +333,20 @@ class HeavyDutyBacktester:
                 wins = [p for p in pnls if p > 0]
                 losses = [p for p in pnls if p <= 0]
                 
+                win_count = len(wins); loss_count = len(losses)
                 total_trades = len(trades)
-                win_count = len(wins)
-                loss_count = len(losses)
                 win_rate = (win_count / total_trades) * 100 if total_trades > 0 else 0
-                
                 max_single_win = max(pnls) if pnls else 0.0
                 max_single_loss = min(pnls) if pnls else 0.0
                 
-                # حساب السلاسل المتتالية
                 current_win_streak = 0; max_win_streak = 0
                 current_loss_streak = 0; max_loss_streak = 0
-                
                 for p in pnls:
                     if p > 0:
-                        current_win_streak += 1
-                        current_loss_streak = 0
+                        current_win_streak += 1; current_loss_streak = 0
                         if current_win_streak > max_win_streak: max_win_streak = current_win_streak
                     else:
-                        current_loss_streak += 1
-                        current_win_streak = 0
+                        current_loss_streak += 1; current_win_streak = 0
                         if current_loss_streak > max_loss_streak: max_loss_streak = current_loss_streak
 
                 results.append({
@@ -368,14 +354,11 @@ class HeavyDutyBacktester:
                     'final_balance': wallet["balance"],
                     'net_profit': net_profit,
                     'total_trades': total_trades,
-                    'win_count': win_count,
-                    'loss_count': loss_count,
+                    'win_count': win_count, 'loss_count': loss_count,
                     'win_rate': win_rate,
-                    'max_single_win': max_single_win,
-                    'max_single_loss': max_single_loss,
-                    'max_win_streak': max_win_streak,
-                    'max_loss_streak': max_loss_streak,
-                    'max_drawdown': max_drawdown * 100 # كنسبة مئوية
+                    'max_single_win': max_single_win, 'max_single_loss': max_single_loss,
+                    'max_win_streak': max_win_streak, 'max_loss_streak': max_loss_streak,
+                    'max_drawdown': max_drawdown * 100
                 })
             else:
                  results.append({
@@ -431,7 +414,7 @@ class HeavyDutyBacktester:
             
         best = sorted(final_results, key=lambda x: x['final_balance'], reverse=True)[0]
         
-        # 🔥🔥🔥 The Full Audit Report 🔥🔥🔥
+        # 🔥🔥🔥 Full Report 🔥🔥🔥
         print("\n" + "="*60)
         print(f"🏆 CHAMPION REPORT [{target_regime}]:")
         print(f"   📅 Period: {self.force_start_date} -> {self.force_end_date}")