|
@@ -11,7 +11,7 @@ from .pending_orders_manager import PendingOrdersManager
|
|
|
from .risk_manager import RiskManager
|
|
|
from .alarm_manager import AlarmManager
|
|
|
from .exchange_order_sync import ExchangeOrderSync
|
|
|
-from .copy_trading_monitor import CopyTradingMonitor
|
|
|
+# from .copy_trading_monitor import CopyTradingMonitor
|
|
|
# DrawdownMonitor and RsiMonitor will be lazy-loaded to avoid circular imports
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
@@ -33,7 +33,7 @@ class MonitoringCoordinator:
|
|
|
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)
|
|
|
- self.copy_trading_monitor = CopyTradingMonitor(hl_client, notification_manager)
|
|
|
+ # self.copy_trading_monitor = CopyTradingMonitor(hl_client, notification_manager)
|
|
|
|
|
|
# Exchange order synchronization (will be initialized with trading stats)
|
|
|
self.exchange_order_sync = None
|
|
@@ -60,9 +60,9 @@ class MonitoringCoordinator:
|
|
|
await self.risk_manager.start()
|
|
|
# AlarmManager doesn't have start() method - it's always ready
|
|
|
|
|
|
- # Start copy trading monitor if enabled
|
|
|
- if self.copy_trading_monitor.enabled:
|
|
|
- asyncio.create_task(self.copy_trading_monitor.start_monitoring())
|
|
|
+ # # Start copy trading monitor if enabled
|
|
|
+ # if self.copy_trading_monitor.enabled:
|
|
|
+ # asyncio.create_task(self.copy_trading_monitor.start_monitoring())
|
|
|
|
|
|
# Initialize exchange order sync with trading stats
|
|
|
self._init_exchange_order_sync()
|
|
@@ -100,9 +100,9 @@ class MonitoringCoordinator:
|
|
|
await self.risk_manager.stop()
|
|
|
# AlarmManager doesn't have stop() method - nothing to stop
|
|
|
|
|
|
- # Stop copy trading monitor
|
|
|
- if self.copy_trading_monitor:
|
|
|
- await self.copy_trading_monitor.stop_monitoring()
|
|
|
+ # # Stop copy trading monitor
|
|
|
+ # if self.copy_trading_monitor:
|
|
|
+ # await self.copy_trading_monitor.stop_monitoring()
|
|
|
|
|
|
# Stop optional monitors if they exist and have stop methods
|
|
|
if self.drawdown_monitor and hasattr(self.drawdown_monitor, 'stop'):
|
|
@@ -228,7 +228,7 @@ class MonitoringCoordinator:
|
|
|
'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,
|
|
|
+ # 'copy_trading_monitor': self.copy_trading_monitor.enabled,
|
|
|
'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
|
|
|
},
|