Feature/SE integration (#26)

* SE inited

---------

Author: iceseer

.gitignore

@@ -35,9 +35,11 @@
 .idea
 
 /build
+/build-ex
 /cmake-build-*
 
 /.build
 /.venv
 /.vcpkg
 /.build*
+/vcpkg_installed

CMakeLists.txt

@@ -15,6 +15,7 @@ set(CMAKE_CXX_STANDARD 20)
 set(CMAKE_CXX_STANDARD_REQUIRED ON)
 set(CMAKE_CXX_EXTENSIONS OFF)
 set(CMAKE_POSITION_INDEPENDENT_CODE ON)
+set(CMAKE_EXPERIMENTAL_CXX_MODULE_CMAKE_API ON)
 
 project(cpp-jam
     VERSION 0.0.1
@@ -75,6 +76,12 @@ find_package(Boost.DI CONFIG REQUIRED)
 find_package(qtils CONFIG REQUIRED)
 find_package(prometheus-cpp CONFIG REQUIRED)
 
+if(CMAKE_CXX_COMPILER_ID STREQUAL "GNU")
+  add_compile_options(-fmodules-ts)
+elseif(CMAKE_CXX_COMPILER_ID MATCHES "Clang|AppleClang")
+  add_compile_options(-fmodules)
+endif()
+
 add_library(headers INTERFACE)
 target_include_directories(headers INTERFACE
     $<BUILD_INTERFACE:${PROJECT_SOURCE_DIR}/src_>

src/CMakeLists.txt

@@ -24,3 +24,8 @@ add_subdirectory(metrics)
 # Clocks and time subsystem
 add_subdirectory(clock)
 
+# Subscription Engine subsystem
+add_subdirectory(se)
+
+# Modules subsystem
+add_subdirectory(modules)

src/app/CMakeLists.txt

@@ -28,7 +28,9 @@ add_library(build_version
 
 add_library(app_configuration SHARED configuration.cpp)
 target_link_libraries(app_configuration
-    Boost::boost)
+    Boost::boost
+    fmt::fmt
+)
 
 add_library(app_configurator SHARED configurator.cpp)
 target_link_libraries(app_configurator

src/app/configuration.hpp

@@ -5,6 +5,7 @@
 
 #pragma once
 
+#include <filesystem>
 #include <string>
 
 #include <boost/asio/ip/tcp.hpp>
@@ -22,6 +23,7 @@ namespace jam::app {
 
     [[nodiscard]] std::string nodeVersion() const;
     [[nodiscard]] std::string nodeName() const;
+
     [[nodiscard]] std::optional<Endpoint> metricsEndpoint() const;
 
    private:

src/app/configurator.cpp

@@ -3,20 +3,19 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-#include "app/configuration.hpp"
+#include "app/configurator.hpp"
 
 #include <filesystem>
 #include <iostream>
 
 #include <boost/asio/ip/tcp.hpp>
+#include <boost/beast/core/error.hpp>
 #include <boost/program_options.hpp>
 #include <boost/program_options/value_semantic.hpp>
 #include <qtils/outcome.hpp>
 
 #include "app/build_version.hpp"
-#include "app/configurator.hpp"
-
-#include <boost/beast/core/error.hpp>
+#include "app/configuration.hpp"
 
 using Endpoint = boost::asio::ip::tcp::endpoint;
 
@@ -110,7 +109,7 @@ namespace jam::app {
         .add(metrics_options);
   }
 
-  outcome::result<bool> Configurator::step1() {
+  outcome::result<bool> Configurator::step1() {  // read min cli-args and config
     namespace po = boost::program_options;
     namespace fs = std::filesystem;
 
@@ -120,7 +119,7 @@ namespace jam::app {
 
     po::variables_map vm;
 
-    // first-run parse to read only general options and to lookup for "help",
+    // first-run parse to read-only general options and to lookup for "help",
     // "config" and "version". all the rest options are ignored
     try {
       po::parsed_options parsed = po::command_line_parser(argc_, argv_)
@@ -200,6 +199,7 @@ namespace jam::app {
   }
 
   outcome::result<void> Configurator::initGeneralConfig() {
+    // Init by config-file
     if (config_file_.has_value()) {
       auto section = (*config_file_)["general"];
       if (section.IsDefined()) {

src/app/configurator.hpp

@@ -5,6 +5,8 @@
 
 #pragma once
 
+#include <optional>
+
 #include <boost/program_options.hpp>
 #include <qtils/enum_error_code.hpp>
 #include <qtils/outcome.hpp>

src/app/impl/application_impl.cpp

@@ -16,16 +16,24 @@
 #include "log/logger.hpp"
 #include "metrics/histogram_timer.hpp"
 #include "metrics/metrics.hpp"
+#include "se/impl/subscription_manager.hpp"
 
 namespace jam::app {
 
+  SeHolder::SeHolder(SePtr se) : se_(std::move(se)) {}
+
+  SeHolder::~SeHolder() {
+    se_->dispose();
+  }
+
   ApplicationImpl::ApplicationImpl(
       std::shared_ptr<log::LoggingSystem> logsys,
       std::shared_ptr<Configuration> config,
       std::shared_ptr<StateManager> state_manager,
       std::shared_ptr<Watchdog> watchdog,
       std::shared_ptr<metrics::Exposer> metrics_exposer,
-      std::shared_ptr<clock::SystemClock> system_clock)
+      std::shared_ptr<clock::SystemClock> system_clock,
+      std::shared_ptr<SeHolder>)
       : logger_(logsys->getLogger("Application", "application")),
         app_config_(std::move(config)),
         state_manager_(std::move(state_manager)),

src/app/impl/application_impl.hpp

@@ -6,12 +6,13 @@
 
 #pragma once
 
-#include "app/application.hpp"
-
 #include <memory>
 
 #include <metrics/registry.hpp>
 
+#include "app/application.hpp"
+#include "se/subscription_fwd.hpp"
+
 namespace jam {
   class Watchdog;
 }  // namespace jam
@@ -41,14 +42,46 @@ namespace jam::metrics {
 
 namespace jam::app {
 
+  /**
+   * @brief RAII holder for subscription engine management
+   *
+   * SeHolder is responsible for managing the lifetime of subscription engine
+   * components. It ensures proper initialization and cleanup of the
+   * subscription system during application lifecycle.
+   */
+  struct SeHolder final {
+    using SePtr = std::shared_ptr<Subscription>;
+    SePtr se_;
+
+    // Disable copying - subscription engine should not be copied
+    SeHolder(const SeHolder &) = delete;
+    SeHolder &operator=(const SeHolder &) = delete;
+
+    // Disable moving - subscription engine should not be moved
+    SeHolder(SeHolder &&) = delete;
+    SeHolder &operator=(SeHolder &&) = delete;
+
+    /**
+     * @brief Constructs SeHolder with subscription engine instance
+     * @param se Shared pointer to subscription engine
+     */
+    SeHolder(SePtr se);
+
+    /**
+     * @brief Destructor ensures proper cleanup of subscription engine
+     */
+    ~SeHolder();
+  };
+
   class ApplicationImpl final : public Application {
    public:
     ApplicationImpl(std::shared_ptr<log::LoggingSystem> logsys,
                     std::shared_ptr<Configuration> config,
                     std::shared_ptr<StateManager> state_manager,
                     std::shared_ptr<Watchdog> watchdog,
                     std::shared_ptr<metrics::Exposer> metrics_exposer,
-                    std::shared_ptr<clock::SystemClock> system_clock);
+                    std::shared_ptr<clock::SystemClock> system_clock,
+                    std::shared_ptr<SeHolder>);
 
     void run() override;
 

src/app/impl/state_manager_impl.hpp

@@ -6,13 +6,12 @@
 
 #pragma once
 
-#include "app/state_manager.hpp"
-
 #include <condition_variable>
 #include <csignal>
 #include <mutex>
 #include <queue>
 
+#include "app/state_manager.hpp"
 #include "utils/ctor_limiters.hpp"
 
 namespace soralog {