System.hpp

#pragma once
 
#include <vector>
#include <memory>
#include <atomic>
#include <thread>
#include <chrono>
#include "message/MessageProcessor.hpp"
#include "control/IMessageHandler.hpp"
#include "control/HandlerDispatcher.hpp"
#include "algorithm/AlgorithmScanner.hpp"
#include "algorithm/AlgorithmRunner.hpp"
 
class System {
private:
    MessageProcessor messageProcessor;
    HandlerDispatcher dispatcher;
    AlgorithmScanner algorithmScanner;
    AlgorithmRunner algorithmRunner;
    
    std::vector<std::unique_ptr<IMessageHandler>> handlers;
    std::atomic<bool> running;
    
public:
    System(int port);
    ~System();
    
    void start();
    
    bool acceptConnection();
    
    void stop();
    
    void registerHandler(std::unique_ptr<IMessageHandler> handler);
    
    bool sendMessage(const std::string& payload, MessageType type);
    
    bool sendMessage(const std::string& messageId, const std::string& payload, MessageType type);
    
    bool isRunning() const;
    
    bool isClientConnected() const;
    
    void printStats() const;
    
    void handleCompleteMessage(const std::string& messageId, const std::string& payload, MessageType type);
    
    // Component access methods
    AlgorithmScanner& getAlgorithmScanner();
    
    AlgorithmRunner& getAlgorithmRunner();
};