Update simulation_engine/sim_runner.py

simulation_engine/sim_runner.py

@@ -1,11 +1,10 @@
 # simulation_engine/sim_runner.py
-# (V1.3 - Streamlined Simulation Loop - NO DEADLOCKS)
+# (V1.4 - Streamlined Simulation Loop - FIXED TITAN DATA SCARCITY)
 
 import asyncio
 import os
 import pandas as pd
 import traceback
-# from tqdm.notebook import tqdm # (اختياري: يمكن استبداله بطباعة عادية إذا سبب مشاكل في البيئة الحالية)
 from tqdm import tqdm
 from datetime import datetime
 
@@ -23,8 +22,8 @@ except ImportError:
 # === إعدادات المحاكاة ===
 SIM_CONFIG = {
     "START_DATE": "2025-09-10",
-    "END_DATE": "2025-11-09", # شهرين للتعلم الجيد
-    "INITIAL_BALANCE": 10, # رصيد واقعي أكثر للبدء
+    "END_DATE": "2025-11-09", 
+    "INITIAL_BALANCE": 10.0, # تم التعديل بناء على طلب المستخدم
     "TEST_SYMBOLS": [
         "BTC/USDT", "ETH/USDT", "SOL/USDT", "BNB/USDT", "XRP/USDT",
         "DOGE/USDT", "ADA/USDT", "AVAX/USDT", "LINK/USDT"
@@ -40,6 +39,10 @@ SIM_STATUS = {
     "trades_count": 0
 }
 
+# 🔥 متغير ثابت للإصلاح 🔥
+REQUIRED_CANDLES = 200 # الحد الأدنى للشموع المطلوبة لحساب المؤشرات الكبيرة (مثل 200 EMA)
+FETCH_LIMIT = 500 # نطلب 500 شمعة لضمان توفر الـ 200
+
 async def run_realistic_simulation():
     global SIM_STATUS
     SIM_STATUS["running"] = True
@@ -54,16 +57,12 @@ async def run_realistic_simulation():
 
     print("🛠️ تجهيز البيئة...")
     mock_exchange = MockKuCoin(SIM_CONFIG["LOCAL_DATA_DIR"])
-    # تحميل البيانات للأطر الزمنية الأساسية التي يحتاجها المعالج
     await mock_exchange.load_data(SIM_CONFIG["TEST_SYMBOLS"], ['5m', '15m', '1h', '4h', '1d'])
     virtual_wallet = VirtualExchange(SIM_CONFIG["INITIAL_BALANCE"])
 
     print("🧠 تهيئة النظام الهجين مع التعلم النشط...")
     data_manager = DataManager(None, None, r2_service=r2_service, mock_exchange=mock_exchange)
-    # لا حاجة لتهيئة data_manager الكاملة هنا لأننا لن نستخدم stream_ohlcv_data المعقدة
-    # await data_manager.initialize() 
     
-    # 🔥 تفعيل مركز التعلم بالكامل 🔥
     learning_hub = LearningHubManager(r2_service, None, data_manager)
     await learning_hub.initialize()
 
@@ -74,17 +73,15 @@ async def run_realistic_simulation():
 
     start_ts = int(pd.Timestamp(SIM_CONFIG["START_DATE"]).timestamp() * 1000)
     end_ts = int(pd.Timestamp(SIM_CONFIG["END_DATE"]).timestamp() * 1000)
-    step_ms = 15 * 60 * 1000 # خطوة كل 15 دقيقة
+    step_ms = 15 * 60 * 1000 
     timeline = range(start_ts, end_ts, step_ms)
     total_steps = len(timeline)
     
-    # استخدام tqdm العادي للطرفية، أو استبدله بـ range عادي إذا كنت في بيئة لا تدعمه
     progress_bar = tqdm(timeline, desc="Simulating", unit="step")
     
     for i, current_ts in enumerate(progress_bar):
         mock_exchange.set_time(current_ts)
         
-        # تحديث الحالة العالمية كل 10 خطوات فقط لتخفيف الحمل
         if i % 10 == 0:
              SIM_STATUS["progress"] = (i / total_steps) * 100
              SIM_STATUS["current_balance"] = virtual_wallet.get_balance()
@@ -92,70 +89,67 @@ async def run_realistic_simulation():
 
         # --- أ. تحديث المحفظة + تعلم من الصفقات المغلقة ---
         current_prices = {}
-        # جلب سريع للأسعار الحالية لكل الرموز دفعة واحدة (تحسين)
         for sym in SIM_CONFIG["TEST_SYMBOLS"]:
             ticker = await mock_exchange.fetch_ticker(sym)
             current_prices[sym] = ticker['last']
             
         closed_trades = virtual_wallet.update_positions(current_prices, current_ts)
         for trade in closed_trades:
-            # print(f"🎓 Closed: {trade['symbol']} PnL: {trade['pnl_percent']:.2f}%") # اختياري للطباعة
             await learning_hub.analyze_trade_and_learn(trade, trade['close_reason'])
 
         # --- ب. دورة البحث عن فرص جديدة (مباشرة وبسيطة) ---
-        # ننفذ المسح فقط إذا كان لدينا رصيد كافٍ
-        if virtual_wallet.get_balance() > 1: 
+        # تم تعديل الشرط ليناسب الرصيد الصغير (أكبر من 5 دولارات كحد أدنى)
+        if virtual_wallet.get_balance() > 5: 
             for symbol in SIM_CONFIG["TEST_SYMBOLS"]:
                 try:
-                    # 1. بناء حزمة البيانات المطلوبة للمعالج يدوياً وبسرعة
                     ohlcv_packet = {}
                     REQUIRED_TFS = ['5m', '15m', '1h', '4h', '1d']
                     valid_packet = True
+                    
                     for tf in REQUIRED_TFS:
-                        # نطلب عدداً كافياً من الشموع للتحليل (مثلاً 100)
-                        candles = await mock_exchange.fetch_ohlcv(symbol, tf, limit=100)
-                        if not candles or len(candles) < 50: # تحقق بسيط من كفاية البيانات
+                        # 🔥 جلب 500 شمعة بدلاً من 100
+                        candles = await mock_exchange.fetch_ohlcv(symbol, tf, limit=FETCH_LIMIT)
+                        
+                        # 🔥 التحقق من الحد الأدنى للشموع المطلوبة
+                        if not candles or len(candles) < REQUIRED_CANDLES: 
                             valid_packet = False
                             break
+                            
                         ohlcv_packet[tf] = candles
                     
                     if not valid_packet: continue
-
+                    
                     raw_data = {
                         'symbol': symbol,
                         'ohlcv': ohlcv_packet,
                         'current_price': current_prices.get(symbol, 0.0)
                     }
 
-                    # 2. المعالجة الفورية
-                    # نستخدم المعالج الهجين مباشرة
                     res = await processor.process_and_score_symbol_enhanced(raw_data)
                     
-                    # 3. اتخاذ القرار
-                    # نستخدم عتبة من DataManager أو قيمة ثابتة آمنة
                     entry_threshold = getattr(data_manager, 'HYBRID_ENTRY_THRESHOLD', 0.75)
                     
                     if res and res['enhanced_final_score'] >= entry_threshold:
-                        # التحقق من عدم وجود صفقة مفتوحة لنفس الرمز
                         if symbol not in virtual_wallet.positions:
-                             # حجم صفقة ثابت نسبياً (10% من الرصيد الحالي)
-                             pos_size = virtual_wallet.get_balance() * 0.95
-                             # تنفيذ الشراء
+                             # 🔥 حجم الصفقة 100% من الرصيد المتاح (للاستثمار بالكامل)
+                             pos_size = virtual_wallet.get_balance()
+                             
                              virtual_wallet.execute_buy(
                                  symbol, 
                                  res['current_price'], 
                                  pos_size, 
                                  current_ts, 
-                                 res.get('components', {}) # نحفظ تفاصيل القرار للتعلم لاحقاً
+                                 res.get('components', {})
                              )
-                             # print(f"🛒 BUY {symbol} at {res['current_price']} (Score: {res['enhanced_final_score']:.2f})")
 
                 except Exception as e:
-                    # طباعة الخطأ مرة واحدة فقط لتجنب إغراق الشاشة
+                    # تتبع الأخطاء الصامتة فقط
+                    if not valid_packet: continue # نمرر الأخطاء المتعلقة بالبيانات غير الكافية في بداية المحاكاة
+                    # يمكنك إلغاء التعليق هنا إذا أردت رؤية الأخطاء الأخرى:
                     # print(f"⚠️ Error processing {symbol} at {current_ts}: {e}")
                     pass
 
-    # --- الختام ---
+    # الختام
     print("\n🏁 نهاية فترة المحاكاة. إغلاق الصفقات المتبقية...")
     final_ts = end_ts
     mock_exchange.set_time(final_ts)
@@ -168,17 +162,14 @@ async def run_realistic_simulation():
         trade = virtual_wallet.execute_sell(sym, final_prices.get(sym, 0), final_ts, "END_OF_SIM")
         if trade: await learning_hub.analyze_trade_and_learn(trade, "END_OF_SIM")
 
-    # حفظ النتائج النهائية
     print("💾 جاري حفظ النتائج إلى R2...")
     await r2_service.save_simulation_results(virtual_wallet.trade_history, virtual_wallet.metrics)
     
-    # حفظ ما تعلمناه (الأوزان الجديدة، إلخ)
     await learning_hub.shutdown()
     
     SIM_STATUS["running"] = False
     SIM_STATUS["progress"] = 100.0
     
-    # طباعة ملخص سريع
     print("\n🎉 === تقرير المحاكاة السريع ===")
     print(f"💰 الرصيد النهائي: ${virtual_wallet.get_balance():.2f} (من ${SIM_CONFIG['INITIAL_BALANCE']})")
     print(f"📈 إجمالي الربح/الخسارة: ${virtual_wallet.metrics['total_pnl_usd']:.2f}")