Update app.py

app.py

@@ -1,4 +1,10 @@
-import os, traceback, signal, sys, uvicorn, asyncio, json
+import os
+import traceback
+import signal
+import sys
+import uvicorn
+import asyncio
+import json
 from contextlib import asynccontextmanager
 from fastapi import FastAPI, HTTPException
 from datetime import datetime
@@ -401,13 +407,22 @@ async def lifespan(application: FastAPI):
         r2_service_global = R2Service()
         llm_service_global = LLMService()
         contracts_database = await r2_service_global.load_contracts_db_async()
-        data_manager_global = DataManager(contracts_database)
+        
+        from whale_news_data import EnhancedWhaleMonitor
+        whale_monitor_global = EnhancedWhaleMonitor(contracts_database)
+        whale_monitor_global.data_manager = data_manager_global
+        
+        data_manager_global = DataManager(contracts_database, whale_monitor_global)
         await data_manager_global.initialize()
+        
         sentiment_analyzer_global = SentimentAnalyzer(data_manager_global)
         learning_engine_global = LearningEngine(r2_service_global, data_manager_global)
         await learning_engine_global.initialize_enhanced()
         await learning_engine_global.force_strategy_learning()
         trade_manager_global = TradeManager(r2_service_global, learning_engine_global, data_manager_global)
+        
+        whale_monitor_global.data_manager = data_manager_global
+        
         asyncio.create_task(monitor_market_async())
         asyncio.create_task(trade_manager_global.start_trade_monitoring())
         await r2_service_global.save_system_logs_async({"application_started": True})