mock_md_adapter.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <thread>
#include <atomic>
#include <mutex>
#include <set>
#include <map>
#include <random>
#include <chrono>
#include "market/md_adapter.hpp"
 
namespace fix40 {
 
class MockMdAdapter : public MdAdapter {
public:
    explicit MockMdAdapter(moodycamel::BlockingConcurrentQueue<MarketData>& queue);
 
    ~MockMdAdapter() override;
 
    // 禁止拷贝
    MockMdAdapter(const MockMdAdapter&) = delete;
    MockMdAdapter& operator=(const MockMdAdapter&) = delete;
 
    // =========================================================================
    // MdAdapter 接口实现
    // =========================================================================
 
    bool start() override;
    void stop() override;
    bool isRunning() const override { return running_.load(); }
    MdAdapterState getState() const override { return state_.load(); }
 
    bool subscribe(const std::vector<std::string>& instruments) override;
    bool unsubscribe(const std::vector<std::string>& instruments) override;
 
    void setStateCallback(StateCallback callback) override;
 
    std::string getName() const override { return "Mock"; }
    std::string getTradingDay() const override;
 
    // =========================================================================
    // Mock 特有配置
    // =========================================================================
 
    void setTickInterval(std::chrono::milliseconds interval) {
        tickIntervalMs_.store(interval.count());
    }
 
    void setBasePrice(const std::string& instrument, double basePrice);
 
    void setVolatility(double volatility) {
        volatility_.store(volatility);
    }
 
private:
    void run();
 
    MarketData generateTick(const std::string& instrument);
 
    void notifyState(MdAdapterState state, const std::string& message);
 
    std::string getCurrentTime() const;
 
    std::atomic<bool> running_{false};
    std::atomic<MdAdapterState> state_{MdAdapterState::DISCONNECTED};
    std::thread workerThread_;
 
    mutable std::mutex mutex_;
    std::set<std::string> subscribedInstruments_;
    std::map<std::string, double> basePrices_;
    std::map<std::string, double> lastPrices_;
 
    StateCallback stateCallback_;
    std::atomic<int64_t> tickIntervalMs_{1000};  
    std::atomic<double> volatility_{0.005};      
 
    std::mt19937 rng_;                       
    const std::string tradingDay_;           
};
 
} // namespace fix40