ExchangeManager.h

Go to the documentation of this file.

#pragma once
 
#include <exchange_app/TradingCore.h>
#include <fix/FixServer.h>
#include <data/SequenceRepository.h>
#include <asio.hpp>
 
#include <memory>
#include <atomic>
 
namespace admin {
 
class ExchangeManager {
public:
    explicit ExchangeManager(asio::io_context& ioCtx);
    ~ExchangeManager();
 
    bool start(short port = 8088);
 
    void stop();
 
    bool isRunning() const { return mIsRunning; }
    
    trading_core::TradingCore* getCore() { return mTradingCore.get(); }
    fix::FixServer* getServer() { return mFixServer.get(); }
 
private:
    asio::io_context& mIoCtx;
    std::unique_ptr<trading_core::TradingCore> mTradingCore;
    std::unique_ptr<fix::FixServer> mFixServer;
    std::unique_ptr<data::SequenceRepository> mSeqRepo;
    std::atomic<bool> mIsRunning{false};
 
};
 
} // namespace admin