Create sim_runner.py

simulation_engine/sim_runner.py

@@ -0,0 +1,157 @@
+# simulation_engine/sim_runner.py
+# (V1.1 - Full Hybrid System Simulation with Local Data)
+
+import asyncio
+import os
+import pandas as pd
+import json
+import traceback
+from tqdm.notebook import tqdm
+from datetime import datetime
+
+# استيراد مكونات النظام الحقيقية (العقل الهجين)
+from r2 import R2Service
+from ml_engine.data_manager import DataManager
+from ml_engine.processor import MLProcessor
+from learning_hub.hub_manager import LearningHubManager
+
+# استيراد المكونات الوهمية
+try:
+    from .mock_kucoin import MockKuCoin
+    from .virtual_exchange import VirtualExchange
+except ImportError:
+    print("❌ [SimRunner] تأكد من وجود mock_kucoin.py و virtual_exchange.py")
+
+# === إعدادات المحاكاة ===
+SIM_CONFIG = {
+    # 1. تواريخ الاختبار (يجب أن تطابق البيانات التي جلبتها)
+    "START_DATE": "2024-05-01",
+    "END_DATE": "2024-05-15",
+    "INITIAL_BALANCE": 1000.0,
+    
+    # 2. العملات المستهدفة
+    "TEST_SYMBOLS": [
+        "BTC/USDT", "ETH/USDT", "SOL/USDT", "BNB/USDT", "XRP/USDT",
+        "DOGE/USDT", "ADA/USDT", "AVAX/USDT", "LINK/USDT"
+    ],
+    
+    # 3. مسار البيانات المحلي (داخل مجلد المشروع)
+    "LOCAL_DATA_DIR": "./simulation_data" 
+}
+
+async def run_realistic_simulation():
+    print(f"🚀 بدء المحاكاة الهجينة الشاملة (Titan+Patterns+MC)...")
+    print(f"📅 الفترة: {SIM_CONFIG['START_DATE']} -> {SIM_CONFIG['END_DATE']}")
+
+    # 1. تهيئة الخدمات
+    r2_service = R2Service()
+    
+    # 2. تجهيز البيئة الوهمية
+    if not os.path.exists(SIM_CONFIG["LOCAL_DATA_DIR"]):
+        print(f"❌ خطأ فادح: مجلد البيانات غير موجود: {SIM_CONFIG['LOCAL_DATA_DIR']}")
+        print("ℹ️ يرجى إنشاء المجلد ووضع ملفات .parquet فيه قبل التشغيل.")
+        return
+
+    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"])
+
+    # 3. تهيئة النظام الهجين الحقيقي
+    print("🧠 تهيئة العقل الهجين (Hybrid Core)...")
+    # حقن المنصة الوهمية في مدير البيانات
+    data_manager = DataManager(None, None, r2_service=r2_service, mock_exchange=mock_exchange)
+    await data_manager.initialize()
+    
+    learning_hub = LearningHubManager(r2_service, None, data_manager)
+    # (يمكننا تخطي تهيئة learning_hub الكاملة إذا لم نرد التعلم أثناء المحاكاة)
+    
+    # المعالج هو الأهم: هو من يحتوي على منطق (تيتان + الأنماط + مونت كارلو)
+    processor = MLProcessor(None, data_manager, learning_hub)
+    await processor.initialize()
+    
+    if not processor.pattern_engine or not processor.pattern_engine.initialized:
+        print("⚠️ تحذير: محرك الأنماط لم يتهيأ بالكامل. تأكد من وجود ملفات النماذج.")
+    
+    print(f"✅ النظام جاهز. العتبة الهجينة الحالية: {data_manager.HYBRID_ENTRY_THRESHOLD}")
+
+    # 4. حلقة الزمن
+    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 دقيقة
+    
+    timeline = range(start_ts, end_ts, step_ms)
+    
+    for current_ts in tqdm(timeline, desc="Simulating Market"):
+        mock_exchange.set_time(current_ts)
+        
+        # أ. تحديث المحفظة
+        current_prices = {}
+        for sym in SIM_CONFIG["TEST_SYMBOLS"]:
+            t = await mock_exchange.fetch_ticker(sym)
+            current_prices[sym] = t['last']
+        virtual_wallet.update_positions(current_prices, current_ts)
+
+        # ب. دورة التحليل الهجين
+        # نستخدم فقط العملات التي لدينا كاش لها
+        if virtual_wallet.get_balance() > 100: 
+            candidates = [{'symbol': s} for s in SIM_CONFIG["TEST_SYMBOLS"]]
+            data_queue = asyncio.Queue()
+            # DataManager سيجلب البيانات "التاريخية" من MockKuCoin
+            producer = asyncio.create_task(data_manager.stream_ohlcv_data(candidates, data_queue))
+            
+            while True:
+                batch = await data_queue.get()
+                if batch is None:
+                    data_queue.task_done()
+                    break
+                
+                for raw_data in batch:
+                    # 🔥 استدعاء العقل الهجين الكامل (Titan + Patterns + MC) 🔥
+                    try:
+                        res = await processor.process_and_score_symbol_enhanced(raw_data)
+                        
+                        if res:
+                            score = res['enhanced_final_score']
+                            sym = res['symbol']
+                            price = res['current_price']
+                            
+                            # قرار الدخول بالعتبة الهجينة
+                            if score >= data_manager.HYBRID_ENTRY_THRESHOLD:
+                                if sym not in virtual_wallet.positions:
+                                     # حجم الصفقة: 10% من الرصيد الحالي
+                                     pos_size = virtual_wallet.get_balance() * 0.10
+                                     virtual_wallet.execute_buy(sym, price, pos_size, current_ts, res.get('components', {}))
+                    except Exception as e:
+                        # print(f"❌ Error processing {raw_data.get('symbol')}: {e}")
+                        pass
+
+                data_queue.task_done()
+            await producer
+
+    # 5. الختام
+    print("\n🏁 نهاية المحاكاة.")
+    # إغلاق إجباري للمراكز المتبقية بسعر النهاية
+    final_prices_map = {}
+    for sym in SIM_CONFIG["TEST_SYMBOLS"]:
+         t = await mock_exchange.fetch_ticker(sym)
+         final_prices_map[sym] = t['last']
+    for sym in list(virtual_wallet.positions.keys()):
+        virtual_wallet.execute_sell(sym, final_prices_map.get(sym, 0), end_ts, "END_OF_SIM")
+
+    # التقرير
+    wins = virtual_wallet.metrics['wins']
+    losses = virtual_wallet.metrics['losses']
+    total = wins + losses
+    win_rate = (wins/total*100) if total > 0 else 0
+    
+    print(f"\n📊 === تقرير الأداء الهجين ===")
+    print(f"💰 الرصيد النهائي: ${virtual_wallet.get_balance():.2f} (من ${SIM_CONFIG['INITIAL_BALANCE']})")
+    print(f"📈 العائد الإجمالي: {((virtual_wallet.get_balance()/SIM_CONFIG['INITIAL_BALANCE'])-1)*100:.2f}%")
+    print(f"🎯 دقة الإشارات: {win_rate:.1f}% ({wins} رابحة / {total} كلية)")
+    print(f"📉 أقصى تراجع: {virtual_wallet.metrics['max_drawdown']*100:.2f}%")
+
+    # حفظ النتائج
+    await r2_service.save_simulation_results(virtual_wallet.trade_history, virtual_wallet.metrics)