Update app.py

app.py

@@ -10,9 +10,9 @@ import time
 from contextlib import asynccontextmanager
 from fastapi import FastAPI, HTTPException
 from datetime import datetime
-# 🔴 --- START OF CHANGE --- 🔴
+# 🔴 --- (لا تغيير هنا) --- 🔴
 from typing import List, Dict, Any # (إضافة الاستيراد الناقص)
-# 🔴 --- END OF CHANGE --- 🔴
+# 🔴 --- (لا تغيير هنا) --- 🔴
 
 # استيراد الخدمات (بما في ذلك TradeManager المحدث)
 try:
@@ -85,7 +85,11 @@ async def initialize_services():
 
         print("   🔄 تهيئة مراقب الحيتان (Layer 1 Data)...");
         try:
-            from whale_news_data import EnhancedWhaleMonitor
+            # 🔴 --- START OF CHANGE --- 🔴
+            # (تم تغيير هذا السطر ليشير إلى المسار الجديد)
+            from whale_monitor.core import EnhancedWhaleMonitor
+            # 🔴 --- END OF CHANGE --- 🔴
+            
             symbol_whale_monitor_global = EnhancedWhaleMonitor(contracts_database, r2_service_global)
             state_manager.set_service_initialized('symbol_whale_monitor'); print("   ✅ مراقب الحيتان مهيأ")
         except Exception as e: print(f"   ⚠️ فشل تهيئة مراقب الحيتان: {e}"); symbol_whale_monitor_global = None
@@ -212,7 +216,7 @@ async def process_batch_parallel(batch, ml_processor, batch_num, total_batches,
 
 async def run_3_layer_analysis_explorer() -> List[Dict[str, Any]]:
     """
-    (معدل) - هذا هو "المستكشف" (Layer 1).
+    (لا تغيير) - هذا هو "المستكشف" (Layer 1).
     ينشئ "قائمة مراقبة" (Watchlist) للحارس (Sentry).
     """
 
@@ -441,7 +445,7 @@ async def re_analyze_open_trade_async(trade_data):
 
 async def run_bot_cycle_async():
     """
-    (معدل) - دورة البوت الرئيسية (المستكشف)
+    (لا تغيير) - دورة البوت الرئيسية (المستكشف)
     """
     try:
         if not await state_manager.wait_for_initialization():