ManualTrader/src/monitoring/monitoring_coordinator.py

import asyncio
import logging
from typing import Optional

from ..clients.hyperliquid_client import HyperliquidClient
from ..notifications.notification_manager import NotificationManager
from ..config.config import Config

from .position_tracker import PositionTracker
from .pending_orders_manager import PendingOrdersManager
from .risk_manager import RiskManager
from .alarm_manager import AlarmManager
from .exchange_order_sync import ExchangeOrderSync
# DrawdownMonitor and RsiMonitor will be lazy-loaded to avoid circular imports

logger = logging.getLogger(__name__)

try:
    from .copy_trading_monitor import CopyTradingMonitor
    COPY_TRADING_AVAILABLE = True
except ImportError as e:
    logger.warning(f"Copy trading monitor not available: {e}")
    COPY_TRADING_AVAILABLE = False

class MonitoringCoordinator:
    """
    Simplified monitoring coordinator that manages all monitoring components.
    Replaces the complex unified monitor with a clean, focused approach.
    """
    
    def __init__(self, hl_client: HyperliquidClient, notification_manager: NotificationManager, config: Config):
        self.hl_client = hl_client
        self.notification_manager = notification_manager
        self.config = config
        self.is_running = False
        
        # Initialize monitoring components
        self.position_tracker = PositionTracker(hl_client, notification_manager)
        self.pending_orders_manager = PendingOrdersManager(hl_client, notification_manager)
        self.risk_manager = RiskManager(hl_client, notification_manager, config)
        self.alarm_manager = AlarmManager()  # AlarmManager only needs alarms_file (defaults to data/price_alarms.json)
        
        # Initialize copy trading monitor (Step 2: Initialize but don't start)
        try:
            from src.monitoring.copy_trading_monitor import CopyTradingMonitor
            self.copy_trading_monitor = CopyTradingMonitor(
                self.hl_client,
                self.notification_manager
            )
            logger.info("✅ Copy trading monitor initialized (Step 2: not auto-starting)")
            self.copy_trading_available = True
        except ImportError as e:
            logger.warning(f"Copy trading monitor not available: {e}")
            self.copy_trading_monitor = None
            self.copy_trading_available = False
        except Exception as e:
            logger.error(f"Error initializing copy trading monitor: {e}")
            self.copy_trading_monitor = None
            self.copy_trading_available = False
        
        # Exchange order synchronization (will be initialized with trading stats)
        self.exchange_order_sync = None
        
        # DrawdownMonitor and RSIMonitor will be lazy-loaded to avoid circular imports
        self.drawdown_monitor = None
        self.rsi_monitor = None
        self._hl_client = hl_client
        self._notification_manager = notification_manager
        self._config = config
        
    async def start(self):
        """Start all monitoring components"""
        if self.is_running:
            return
            
        self.is_running = True
        logger.info("Starting simplified monitoring system")
        
        try:
            # Start all monitors
            await self.position_tracker.start()
            await self.pending_orders_manager.start()
            await self.risk_manager.start()
            # AlarmManager doesn't have start() method - it's always ready
            
            # Start copy trading monitor if enabled (with async fixes applied)
            if self.copy_trading_monitor and hasattr(self.copy_trading_monitor, 'enabled') and self.copy_trading_monitor.enabled:
                try:
                    asyncio.create_task(self.copy_trading_monitor.start_monitoring())
                    logger.info("🔄 Copy trading monitor started (with full async implementation)")
                except Exception as e:
                    logger.error(f"❌ Failed to start copy trading monitor: {e}")
            elif self.copy_trading_monitor:
                logger.info("✅ Copy trading monitor initialized (ready for manual start)")
            
            # Initialize exchange order sync with trading stats
            self._init_exchange_order_sync()
            
            # Lazy-load optional monitors to avoid circular imports
            self._init_optional_monitors()
            
            # Start optional monitors if they have async start methods
            if hasattr(self.drawdown_monitor, 'start'):
                await self.drawdown_monitor.start()
            if hasattr(self.rsi_monitor, 'start'):
                await self.rsi_monitor.start()
            
            # Start order synchronization loop
            asyncio.create_task(self._order_sync_loop())
            
            logger.info("All monitoring components started successfully")
            
        except Exception as e:
            logger.error(f"Error starting monitoring system: {e}")
            await self.stop()
            raise
            
    async def stop(self):
        """Stop all monitoring components"""
        if not self.is_running:
            return
            
        self.is_running = False
        logger.info("Stopping monitoring system")
        
        # Stop all monitors
        await self.position_tracker.stop()
        await self.pending_orders_manager.stop()
        await self.risk_manager.stop()
        # AlarmManager doesn't have stop() method - nothing to stop
        
        # Stop copy trading monitor
        if self.copy_trading_monitor and hasattr(self.copy_trading_monitor, 'stop_monitoring'):
            try:
                await self.copy_trading_monitor.stop_monitoring()
                logger.info("🛑 Copy trading monitor stopped")
            except Exception as e:
                logger.error(f"❌ Error stopping copy trading monitor: {e}")
        
        # Stop optional monitors if they exist and have stop methods
        if self.drawdown_monitor and hasattr(self.drawdown_monitor, 'stop'):
            await self.drawdown_monitor.stop()
        if self.rsi_monitor and hasattr(self.rsi_monitor, 'stop'):
            await self.rsi_monitor.stop()
        
        logger.info("Monitoring system stopped")
        
    def _init_exchange_order_sync(self):
        """Initialize exchange order synchronization"""
        try:
            # Try multiple sources for trading stats
            trading_stats = None
            
            # Method 1: Get from position tracker
            if hasattr(self.position_tracker, 'trading_stats') and self.position_tracker.trading_stats:
                trading_stats = self.position_tracker.trading_stats
                logger.debug("Found trading stats from position tracker")
            
            # Method 2: Get from trading engine (if we have access to it)
            elif hasattr(self, '_trading_engine') and self._trading_engine:
                trading_stats = self._trading_engine.get_stats()
                logger.debug("Found trading stats from trading engine")
            
            # Method 3: Try to initialize trading stats directly
            if not trading_stats:
                try:
                    from ..stats.trading_stats import TradingStats
                    trading_stats = TradingStats()
                    logger.debug("Initialized trading stats directly")
                except Exception as e:
                    logger.warning(f"Could not initialize trading stats directly: {e}")
            
            if trading_stats:
                self.exchange_order_sync = ExchangeOrderSync(
                    self.hl_client, 
                    trading_stats
                )
                logger.info("✅ Exchange order sync initialized")
            else:
                logger.warning("⚠️ Trading stats not available from any source, exchange order sync disabled")
                
        except Exception as e:
            logger.error(f"Error initializing exchange order sync: {e}", exc_info=True)
    
    async def _order_sync_loop(self):
        """Periodic order synchronization loop"""
        logger.info("🔄 Starting exchange order synchronization loop")
        sync_interval = 30  # Sync every 30 seconds
        loop_count = 0
        
        while self.is_running:
            try:
                loop_count += 1
                
                # Run sync every 30 seconds (6 cycles with 5s heartbeat)
                if loop_count % 6 == 0 and self.exchange_order_sync:
                    logger.debug(f"🔄 Running exchange order sync (loop #{loop_count})")
                    sync_results = self.exchange_order_sync.sync_exchange_orders_to_database()
                    
                    # Log results if there were changes
                    if sync_results.get('new_orders_added', 0) > 0 or sync_results.get('orders_updated', 0) > 0:
                        logger.info(f"📊 Order sync: +{sync_results.get('new_orders_added', 0)} new, "
                                  f"~{sync_results.get('orders_updated', 0)} updated, "
                                  f"-{sync_results.get('orphaned_orders_cancelled', 0)} cancelled")
                
                # Wait for next cycle
                await asyncio.sleep(Config.BOT_HEARTBEAT_SECONDS)
                
            except Exception as e:
                logger.error(f"Error in order sync loop: {e}")
                await asyncio.sleep(Config.BOT_HEARTBEAT_SECONDS)
        
        logger.info("🛑 Exchange order sync loop stopped")
    
    def _init_optional_monitors(self):
        """Initialize optional monitors with lazy loading to avoid circular imports"""
        try:
            if self.drawdown_monitor is None:
                # DrawdownMonitor needs a TradingStats instance
                from ..stats.trading_stats import TradingStats
                from .drawdown_monitor import DrawdownMonitor
                stats = TradingStats()
                self.drawdown_monitor = DrawdownMonitor(stats)
                
            if self.rsi_monitor is None:
                # RsiMonitor class from rsi_monitor module
                from .rsi_monitor import RsiMonitor
                self.rsi_monitor = RsiMonitor(self._hl_client, self._notification_manager)
                
        except Exception as e:
            logger.warning(f"Could not initialize optional monitors: {e}")
            # Set to dummy objects that won't break the system
            if self.drawdown_monitor is None:
                self.drawdown_monitor = type('DummyMonitor', (), {'start': lambda: None, 'stop': lambda: None, 'is_running': False})()
            if self.rsi_monitor is None:
                self.rsi_monitor = type('DummyMonitor', (), {'start': lambda: None, 'stop': lambda: None, 'is_running': False})()
        
    async def add_pending_stop_loss(self, symbol: str, stop_price: float, size: float, side: str, expires_hours: int = 24):
        """Add a pending stop loss order"""
        await self.pending_orders_manager.add_pending_stop_loss(symbol, stop_price, size, side, expires_hours)
        
    async def cancel_pending_order(self, symbol: str) -> bool:
        """Cancel pending order for symbol"""
        return await self.pending_orders_manager.cancel_pending_order(symbol)
        
    async def get_pending_orders(self) -> list:
        """Get all pending orders"""
        return await self.pending_orders_manager.get_pending_orders()
        
    async def get_risk_status(self) -> dict:
        """Get current risk status"""
        return await self.risk_manager.get_risk_status()
        
    async def get_monitoring_status(self) -> dict:
        """Get overall monitoring status"""
        try:
            return {
                'is_running': self.is_running,
                'components': {
                    'position_tracker': self.position_tracker.is_running,
                    'pending_orders_manager': self.pending_orders_manager.is_running,
                    'risk_manager': self.risk_manager.is_running,
                    'alarm_manager': self.alarm_manager.is_running if hasattr(self.alarm_manager, 'is_running') else True,
                    'copy_trading_monitor': self.copy_trading_monitor.enabled if self.copy_trading_monitor else False,
                    'drawdown_monitor': self.drawdown_monitor.is_running if hasattr(self.drawdown_monitor, 'is_running') else True,
                    'rsi_monitor': self.rsi_monitor.is_running if hasattr(self.rsi_monitor, 'is_running') else True
                },
                'pending_orders_count': len(await self.get_pending_orders()),
                'risk_status': await self.get_risk_status()
            }
        except Exception as e:
            logger.error(f"Error getting monitoring status: {e}")
            return {'error': str(e)}