application.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <string>
#include <functional>
#include "fix/fix_codec.hpp"
 
namespace fix40 {
 
// 前置声明
class Session;
class IStore;
 
struct SessionID {
    std::string senderCompID;  
    std::string targetCompID;  
 
    SessionID() = default;
 
    SessionID(const std::string& sender, const std::string& target)
        : senderCompID(sender), targetCompID(target) {}
 
    std::string to_string() const {
        return senderCompID + "->" + targetCompID;
    }
 
    bool operator==(const SessionID& other) const {
        return senderCompID == other.senderCompID && 
               targetCompID == other.targetCompID;
    }
 
    bool operator!=(const SessionID& other) const {
        return !(*this == other);
    }
};
 
class Application {
public:
    virtual ~Application() = default;
 
    // =========================================================================
    // 生命周期回调
    // =========================================================================
 
    virtual void onLogon(const SessionID& sessionID) = 0;
 
    virtual void onLogout(const SessionID& sessionID) = 0;
 
    // =========================================================================
    // 业务消息回调
    // =========================================================================
 
    virtual void fromApp(const FixMessage& msg, const SessionID& sessionID) = 0;
 
    virtual void toApp(FixMessage& msg, const SessionID& sessionID) {
        (void)msg;
        (void)sessionID;
    }
 
    // =========================================================================
    // 管理消息回调（可选）
    // =========================================================================
 
    virtual void fromAdmin(const FixMessage& msg, const SessionID& sessionID) {
        (void)msg;
        (void)sessionID;
    }
 
    virtual void toAdmin(FixMessage& msg, const SessionID& sessionID) {
        (void)msg;
        (void)sessionID;
    }
 
    // =========================================================================
    // 可选：持久化能力探测
    // =========================================================================
 
    virtual IStore* getStore() const { return nullptr; }
};
 
} // namespace fix40