CMakeLists.txt

cmake_minimum_required(VERSION 3.16)

project(qaultra-cpp VERSION 1.0.0 LANGUAGES CXX)

# 基本设置
set(CMAKE_CXX_STANDARD 17)
set(CMAKE_CXX_STANDARD_REQUIRED ON)

# 编译标志 - 优化但不过度
set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -O2 -Wall -Wextra")

# 选项 - 逐步启用
option(QAULTRA_BUILD_TESTS "Build tests" ON)
option(QAULTRA_BUILD_EXAMPLES "Build examples" OFF)
option(QAULTRA_BUILD_BENCHMARKS "Build benchmarks" OFF)
option(QAULTRA_BUILD_PYTHON "Build Python bindings" ON)
option(QAULTRA_USE_ARROW "Use Apache Arrow" OFF)
option(QAULTRA_USE_FULL_FEATURES "Use all features" OFF)
option(QAULTRA_USE_ICEORYX "Use IceOryx for zero-copy IPC" ON)
option(QAULTRA_USE_ICEORYX2 "Use iceoryx2 for zero-copy IPC" ON)

# 包含目录
include_directories(${CMAKE_CURRENT_SOURCE_DIR}/include)

# 查找基础依赖
find_package(Threads REQUIRED)
find_package(nlohmann_json QUIET)
if(NOT nlohmann_json_FOUND)
    # 尝试从系统包管理器安装的版本
    find_path(NLOHMANN_JSON_INCLUDE_DIR nlohmann/json.hpp)
    if(NLOHMANN_JSON_INCLUDE_DIR)
        set(nlohmann_json_FOUND TRUE)
    endif()
endif()

# MongoDB 依赖 (可选)
option(QAULTRA_USE_MONGODB "Use MongoDB connector" OFF)
if(QAULTRA_USE_MONGODB)
    find_package(mongocxx QUIET)
    find_package(bsoncxx QUIET)
    if(mongocxx_FOUND AND bsoncxx_FOUND)
        set(MONGODB_AVAILABLE TRUE)
        message(STATUS "MongoDB C++ driver found")
    else()
        message(WARNING "MongoDB C++ driver not found. Database features will be disabled.")
        set(MONGODB_AVAILABLE FALSE)
    endif()
endif()

# 可选依赖
if(QAULTRA_USE_ARROW)
    find_package(Arrow QUIET)
    if(Arrow_FOUND)
        set(ARROW_AVAILABLE TRUE)
    endif()
endif()

# IceOryx 依赖
if(QAULTRA_USE_ICEORYX)
    # 设置 IceOryx 路径
    set(iceoryx_posh_DIR "/home/quantaxis/iceoryx/build/install/lib/cmake/iceoryx_posh")
    set(iceoryx_hoofs_DIR "/home/quantaxis/iceoryx/build/install/lib/cmake/iceoryx_hoofs")
    set(iceoryx_platform_DIR "/home/quantaxis/iceoryx/build/install/lib/cmake/iceoryx_platform")

    # 添加 IceOryx 头文件路径
    include_directories("/home/quantaxis/iceoryx/build/install/include")

    find_package(iceoryx_posh QUIET)
    find_package(iceoryx_hoofs QUIET)
    find_package(iceoryx_platform QUIET)

    if(iceoryx_posh_FOUND AND iceoryx_hoofs_FOUND)
        set(ICEORYX_AVAILABLE TRUE)
        message(STATUS "IceOryx found: ${iceoryx_posh_DIR}")
    else()
        message(WARNING "IceOryx not found. Zero-copy IPC features will be disabled.")
        set(ICEORYX_AVAILABLE FALSE)
    endif()
endif()

# iceoryx2 依赖
if(QAULTRA_USE_ICEORYX2)
    # 添加 iceoryx2 头文件路径
    set(ICEORYX2_INCLUDE_DIR "/home/quantaxis/iceoryx2/iceoryx2-cxx/include")
    set(ICEORYX2_C_INCLUDE_DIR "/home/quantaxis/iceoryx2/build/rust/native/release/iceoryx2-ffi-c-cbindgen/include")
    set(ICEORYX2_LIB_DIR "/home/quantaxis/iceoryx2/build/iceoryx2-cxx")

    include_directories(${ICEORYX2_INCLUDE_DIR})
    include_directories(${ICEORYX2_C_INCLUDE_DIR})

    # 检查库文件是否存在
    if(EXISTS "${ICEORYX2_LIB_DIR}/libiceoryx2_cxx.a")
        set(ICEORYX2_AVAILABLE TRUE)
        message(STATUS "iceoryx2 found: ${ICEORYX2_LIB_DIR}/libiceoryx2_cxx.a")
    else()
        message(WARNING "iceoryx2 not found. iceoryx2 IPC features will be disabled.")
        set(ICEORYX2_AVAILABLE FALSE)
    endif()
endif()

# PyBind11 依赖 (Python bindings)
if(QAULTRA_BUILD_PYTHON)
    find_package(Python3 COMPONENTS Interpreter Development QUIET)

    if(Python3_FOUND)
        # Try to find pybind11 using python's pip installation
        execute_process(
            COMMAND ${Python3_EXECUTABLE} -c "import pybind11; print(pybind11.get_cmake_dir())"
            OUTPUT_VARIABLE PYBIND11_CMAKE_DIR
            OUTPUT_STRIP_TRAILING_WHITESPACE
            ERROR_QUIET
        )

        if(PYBIND11_CMAKE_DIR)
            set(pybind11_DIR ${PYBIND11_CMAKE_DIR})
            find_package(pybind11 CONFIG QUIET)
        endif()

        if(pybind11_FOUND)
            set(PYBIND11_AVAILABLE TRUE)
            message(STATUS "PyBind11 found: Python ${Python3_VERSION}")
            message(STATUS "Python include: ${Python3_INCLUDE_DIRS}")
            message(STATUS "PyBind11 include: ${pybind11_INCLUDE_DIR}")
        else()
            message(WARNING "PyBind11 not found via pip. Python bindings will be disabled.")
            message(WARNING "  Python3_FOUND: ${Python3_FOUND}")
            message(WARNING "  pybind11_FOUND: ${pybind11_FOUND}")
            set(PYBIND11_AVAILABLE FALSE)
        endif()
    else()
        message(WARNING "Python3 not found. Python bindings will be disabled.")
        set(PYBIND11_AVAILABLE FALSE)
    endif()
endif()

# 收集源文件 - 使用统一版本
set(UNIFIED_SOURCES
    # 统一数据类型系统
    "src/data/datatype.cpp"
    "src/data/kline.cpp"

    # 统一账户系统
    "src/account/qa_account.cpp"
    "src/account/marketpreset.cpp"
    "src/account/batch_operations.cpp"


    # 协议支持（只包含存在的文件）
    "src/protocol/mifi.cpp"
    "src/protocol/tifi.cpp"

    # 分析模块
    "src/analysis/performance_analyzer.cpp"

    # 连接器
    "src/connector/database_connector.cpp"
)

# MongoDB 连接器 (可选)
if(MONGODB_AVAILABLE)
    list(APPEND UNIFIED_SOURCES
        "src/connector/mongodb_connector.cpp"
    )
endif()

# IceOryx IPC 模块 (v1)
if(ICEORYX_AVAILABLE)
    list(APPEND UNIFIED_SOURCES
        "src/ipc/broadcast_hub_v1.cpp"
    )
endif()

# iceoryx2 IPC 模块 (v2)
if(ICEORYX2_AVAILABLE)
    list(APPEND UNIFIED_SOURCES
        "src/ipc/broadcast_hub_v2.cpp"
        "src/ipc/cross_lang_data.cpp"
    )
endif()

# 可选的完整功能源文件
if(QAULTRA_USE_FULL_FEATURES)
    list(APPEND UNIFIED_SOURCES
        # 市场模块（暂时禁用，API不匹配）
        # "src/market/market_system.cpp"
        # "src/market/simmarket.cpp"
        # "src/market/match_engine.cpp"

        # 账户扩展功能（暂时禁用，API不匹配）
        # "src/account/order.cpp"
        # "src/account/position.cpp"

        # 数据扩展功能（Arc优化 - 已修复API问题）
        "src/data/datatype.cpp"
        "src/data/kline.cpp"
        "src/data/marketcenter.cpp"      # Arc 零拷贝基础
        "src/data/tick_broadcaster.cpp"  # Arc 零拷贝广播器
    )
endif()

set(QAULTRA_SOURCES ${UNIFIED_SOURCES})

# 创建库
add_library(qaultra STATIC ${QAULTRA_SOURCES})

# 基础链接
target_link_libraries(qaultra PUBLIC Threads::Threads)

# nlohmann_json 链接
if(nlohmann_json_FOUND)
    if(TARGET nlohmann_json::nlohmann_json)
        target_link_libraries(qaultra PUBLIC nlohmann_json::nlohmann_json)
    else()
        target_include_directories(qaultra PUBLIC ${NLOHMANN_JSON_INCLUDE_DIR})
    endif()
    target_compile_definitions(qaultra PUBLIC QAULTRA_HAVE_JSON)
endif()

# 可选链接
if(ARROW_AVAILABLE)
    target_link_libraries(qaultra PUBLIC arrow_shared)
    target_compile_definitions(qaultra PUBLIC QAULTRA_HAVE_ARROW)
endif()

# IceOryx 链接
if(ICEORYX_AVAILABLE)
    target_link_libraries(qaultra PUBLIC
        iceoryx_posh::iceoryx_posh
        iceoryx_hoofs::iceoryx_hoofs
        iceoryx_platform::iceoryx_platform
    )
    target_compile_definitions(qaultra PUBLIC QAULTRA_HAVE_ICEORYX)
endif()

# MongoDB 链接
if(MONGODB_AVAILABLE)
    target_link_libraries(qaultra PUBLIC
        mongo::mongocxx_shared
        mongo::bsoncxx_shared
    )
    target_compile_definitions(qaultra PUBLIC QAULTRA_HAVE_MONGODB)
endif()

# iceoryx2 链接
if(ICEORYX2_AVAILABLE)
    set(ICEORYX2_DEPS_DIR "/home/quantaxis/iceoryx2/build/_deps/iceoryx-build")

    target_link_libraries(qaultra PUBLIC
        ${ICEORYX2_LIB_DIR}/libiceoryx2_cxx.a
        /home/quantaxis/iceoryx2/build/rust/native/release/libiceoryx2_ffi_c.a
        ${ICEORYX2_DEPS_DIR}/iceoryx_hoofs/libiceoryx_hoofs.so
        ${ICEORYX2_DEPS_DIR}/iceoryx_platform/libiceoryx_platform.so
        pthread
        dl
        m
        rt
    )
    target_compile_definitions(qaultra PUBLIC QAULTRA_HAVE_ICEORYX2)

    # 添加运行时库路径
    set_target_properties(qaultra PROPERTIES
        BUILD_RPATH "${ICEORYX2_DEPS_DIR}/iceoryx_hoofs:${ICEORYX2_DEPS_DIR}/iceoryx_platform"
        INSTALL_RPATH "${ICEORYX2_DEPS_DIR}/iceoryx_hoofs:${ICEORYX2_DEPS_DIR}/iceoryx_platform"
    )
endif()

# 设置属性
set_target_properties(qaultra PROPERTIES
    VERSION ${PROJECT_VERSION}
    POSITION_INDEPENDENT_CODE ON
)

# 测试
if(QAULTRA_BUILD_TESTS)
    # 查找Google Test框架
    find_package(GTest QUIET)
    find_package(benchmark QUIET)

    # 核心测试 - 所有测试已禁用，等待API修复后重新启用

    # 协议测试 (MIFI/TIFI/QIFI) - 已禁用
    # add_executable(protocol_test tests/test_protocol.cpp)
    # target_link_libraries(protocol_test qaultra)
    # message(STATUS "Protocol test enabled")

    # TODO: 以下测试需要API修复后才能启用
    #
    # 问题列表:
    # - test_account.cpp: QA_Account API不匹配 (buy方法签名,get_orders/get_trades不存在)
    # - test_unified_account.cpp: 需要验证API
    # - test_position.cpp: Position字段访问方式不对 (volume_long是方法不是字段)
    # - test_market_preset.cpp: marketpreset.hpp已修复include,需要验证
    # - test_batch_operations.cpp: Position字段名不匹配 (last_price应为lastest_price)
    # - test_portfolio_management.cpp: 未验证
    # - test_performance_metrics.cpp: 未验证
    # - test_thread_safety.cpp: 未验证
    # - test_broadcast_basic.cpp: 需要使用qaultra::ipc::v1命名空间
    # - test_broadcast_massive_scale.cpp: 需要使用qaultra::ipc::v1命名空间
    # - test_kline.cpp: 需要链接GTest
    # - test_qadata.cpp: 需要链接GTest
    # - test_database_connector.cpp: ConnectorFactory::DatabaseType不存在
    # - test_performance_analysis.cpp: 未验证

    # if(GTest_FOUND)
    #     add_executable(qaultra_tests
    #         tests/test_main.cpp
    #         tests/test_market_preset.cpp
    #     )
    #     target_link_libraries(qaultra_tests qaultra GTest::gtest GTest::gtest_main)
    #     include(GoogleTest)
    #     gtest_discover_tests(qaultra_tests)
    # endif()

    # Arc 零拷贝优化测试 (暂时禁用，需要修复Tick初始化)
    # 核心功能已通过独立demo验证
    # if(QAULTRA_USE_FULL_FEATURES)
    #     add_executable(test_tick_broadcaster tests/test_tick_broadcaster.cpp)
    #     target_link_libraries(test_tick_broadcaster qaultra)
    #     message(STATUS "TickBroadcaster test enabled")
    # endif()
endif()

# 示例
if(QAULTRA_BUILD_EXAMPLES)
    add_executable(simple_example simple_test.cpp)
    target_link_libraries(simple_example qaultra)

    # 跨语言IPC示例 (iceoryx2)
    if(ICEORYX2_AVAILABLE)
        add_executable(cross_lang_publisher examples/cross_lang_publisher.cpp)
        target_link_libraries(cross_lang_publisher qaultra)

        add_executable(cross_lang_arrow_publisher examples/cross_lang_arrow_publisher.cpp)
        target_link_libraries(cross_lang_arrow_publisher qaultra)

        # 标准 Apache Arrow IPC 示例
        find_package(Arrow QUIET)
        if(Arrow_FOUND)
            add_executable(arrow_ipc_publisher examples/arrow_ipc_publisher.cpp)
            target_link_libraries(arrow_ipc_publisher qaultra arrow_shared)
            message(STATUS "Apache Arrow IPC example enabled")
        endif()
    endif()
endif()

# 跨语言 qadataswap 示例 (独立于 QAULTRA_BUILD_EXAMPLES)
find_package(Arrow QUIET)
if(Arrow_FOUND)
    # qadataswap C++ 发布器
    add_executable(cross_lang_cpp_publisher examples/cross_lang_cpp_publisher.cpp)
    target_link_libraries(cross_lang_cpp_publisher
        ${CMAKE_SOURCE_DIR}/../libs/qadataswap/build/cpp/libqadataswap_core.so
        arrow_shared
    )
    target_include_directories(cross_lang_cpp_publisher PRIVATE
        ${CMAKE_SOURCE_DIR}/../libs/qadataswap/src/cpp/include
    )

    # qadataswap C++ 订阅器
    add_executable(cross_lang_cpp_subscriber examples/cross_lang_cpp_subscriber.cpp)
    target_link_libraries(cross_lang_cpp_subscriber
        ${CMAKE_SOURCE_DIR}/../libs/qadataswap/build/cpp/libqadataswap_core.so
        arrow_shared
    )
    target_include_directories(cross_lang_cpp_subscriber PRIVATE
        ${CMAKE_SOURCE_DIR}/../libs/qadataswap/src/cpp/include
    )

    message(STATUS "Cross-language qadataswap examples enabled")
endif()

# Python bindings
if(PYBIND11_AVAILABLE AND QAULTRA_USE_FULL_FEATURES)
    # Python module sources
    set(PYTHON_BINDING_SOURCES
        "python/qaultra_py.cpp"
        "python/py_marketcenter.cpp"
        "python/py_tick_broadcaster.cpp"
    )

    # Create Python module
    pybind11_add_module(qaultra_py ${PYTHON_BINDING_SOURCES})

    # Link against qaultra library and its dependencies
    target_link_libraries(qaultra_py PRIVATE qaultra)

    # If Arrow is available, also link Python module against Arrow
    if(ARROW_AVAILABLE)
        find_package(Parquet QUIET)
        target_link_libraries(qaultra_py PRIVATE arrow_shared parquet_shared)
    endif()

    # Set output directory
    set_target_properties(qaultra_py PROPERTIES
        LIBRARY_OUTPUT_DIRECTORY "${CMAKE_BINARY_DIR}/python"
    )

    message(STATUS "Python bindings enabled")
    message(STATUS "  Module: qaultra_py")
    message(STATUS "  Output: ${CMAKE_BINARY_DIR}/python/qaultra_py*.so")
endif()

# 打印配置信息
message(STATUS "")
message(STATUS "QAULTRA Progressive Build Configuration:")
message(STATUS "======================================")
message(STATUS "  Version: ${PROJECT_VERSION}")
message(STATUS "  C++ Standard: ${CMAKE_CXX_STANDARD}")
message(STATUS "  Build Tests: ${QAULTRA_BUILD_TESTS}")
message(STATUS "  Build Python: ${QAULTRA_BUILD_PYTHON}")
message(STATUS "  Use Arrow: ${QAULTRA_USE_ARROW}")
message(STATUS "  Use Full Features: ${QAULTRA_USE_FULL_FEATURES}")
message(STATUS "  Use IceOryx: ${QAULTRA_USE_ICEORYX}")
message(STATUS "  Use iceoryx2: ${QAULTRA_USE_ICEORYX2}")
message(STATUS "  Arrow Available: ${ARROW_AVAILABLE}")
message(STATUS "  IceOryx Available: ${ICEORYX_AVAILABLE}")
message(STATUS "  iceoryx2 Available: ${ICEORYX2_AVAILABLE}")
message(STATUS "  PyBind11 Available: ${PYBIND11_AVAILABLE}")
message(STATUS "")