LIVE Real-Time Trading Systems

import time
import logging

logger = logging.getLogger('v7_live')

class LiveTradingLoop:
    """Main live trading loop with error handling."""
    
    def __init__(self, engine, connector, bar_interval_sec=900):
        self.engine = engine
        self.connector = connector
        self.interval = bar_interval_sec
        self.running = False
    
    def start(self):
        self.running = True
        logger.info("V7 Live Trading STARTED")
        
        while self.running:
            try:
                cycle_start = time.time()
                
                # 1. Check connection
                if not self.connector.is_connected():
                    logger.warning("Connection lost, reconnecting...")
                    self.connector.connect()
                    continue
                
                # 2. Process signals
                signals = self.engine.scan_all_symbols()
                
                for signal in signals:
                    # 3. Risk check
                    if not self.engine.risk_check(signal):
                        logger.info(f"SKIP {signal['symbol']}: risk limit")
                        continue
                    
                    # 4. Execute
                    result = self.connector.place_order(
                        symbol=signal['symbol'],
                        direction=signal['direction'],
                        volume=signal['volume'],
                        sl=signal['sl'],
                        tp=signal['tp'],
                    )
                    logger.info(f"ORDER: {result}")
                
                # 5. Update existing positions
                self.engine.update_exits()
                
                # 6. Log state
                self.engine.log_state()
                
                # 7. Sleep until next bar
                elapsed = time.time() - cycle_start
                sleep_time = max(0, self.interval - elapsed)
                time.sleep(sleep_time)
                
            except KeyboardInterrupt:
                self.running = False
                logger.info("Manual stop requested")
            except Exception as e:
                logger.error(f"Error in trading loop: {e}", exc_info=True)
                time.sleep(60)  # wait before retrying