TestConsoleApp.hpp

Go to the documentation of this file.

#pragma once
 
#include <chrono>
#include <filesystem>
#include <fstream>
#include <memory>
#include <stdexcept>
#include <string>
#include <thread>
#include <tuple>
 
#include "AppContext.h"
#include "ConsoleApp.hpp"

namespace test_console_app_schema {
inline constexpr insitech::config::FieldSpec<const char*> K_APP_NAME{
    "app_name", "test app name", "test-console-app"};
inline constexpr insitech::config::FieldSpec<const char*> K_APP_DESCRIPTION{
    "app_description", "test app description", "test-console-app"};
inline constexpr insitech::config::FieldSpec<const char*> K_APP_DIR{
    "app_dir", "test app dir", "/tmp"};
inline constexpr insitech::config::FieldSpec<const char*> K_BUS_MULTICAST_GROUP{
    "bus_multicast_group", "test multicast group", "239.255.19.40"};
inline constexpr insitech::config::FieldSpec<int64_t> K_BUS_MULTICAST_PORT{
    "bus_multicast_port", "test multicast port", 47800};
inline constexpr insitech::config::FieldSpec<int64_t> K_SHARED_BUS_ADDRESS{
    "shared_bus_address", "test shared bus address", 100};
inline constexpr insitech::config::FieldSpec<const char*> K_LOG_DIR{
    "log_dir", "test log dir", "/tmp"};
inline constexpr insitech::config::FieldSpec<int64_t> K_LOG_MIN_LEVEL{
    "log_min_level", "test log min level", 1};
 
inline constexpr auto K_ALL_FIELDS = std::tie(
    K_APP_NAME, K_APP_DESCRIPTION, K_APP_DIR, K_BUS_MULTICAST_GROUP,
    K_BUS_MULTICAST_PORT, K_SHARED_BUS_ADDRESS, K_LOG_DIR, K_LOG_MIN_LEVEL);
}  // namespace test_console_app_schema
 
// Базовый UDP multicast-порт для собственной шины этого тестового набора —
// каждый выбранный вызывающей стороной port_offset (см.
// make_test_console_app_config() ниже) выбирает отдельный порт отсюда, так
// что несколько одновременно существующих тестовых экземпляров никогда не
// рискуют реальным конфликтом при bind.
inline constexpr int K_TEST_CONSOLE_APP_BASE_MULTICAST_PORT = 47800;
 
class TestConsoleApp : public insitech::ConsoleApp<TestConsoleApp> {
 public:
  using ConsoleApp::ConsoleApp;

  [[nodiscard]] auto run_impl() const -> int {
    if (const char* crash_mode = std::getenv("TEST_CONSOLE_APP_CRASH_MODE");
        crash_mode != nullptr) {
      const std::string mode(crash_mode);
      const char* marker_path = std::getenv("TEST_CONSOLE_APP_CRASH_MARKER");
      bool should_crash = true;
      if (mode != "always" && marker_path != nullptr) {
        if (std::filesystem::exists(marker_path)) {
          should_crash = false;
        } else {
          std::ofstream(marker_path) << "crashed";
        }
      }
      if (should_crash) {
        if (mode == "segv") {
          // `volatile` на самом указателе (а не только на том, на что он
          // указывает) заставляет выполнить реальную загрузку-затем-запись
          // по адресу 0 — без этого -O3 распознаёт запись по null как
          // неопределённое поведение и вправе заменить всё целиком на
          // trap/abort() вместо аппаратного SIGSEGV, который на самом деле
          // нужен этому тесту (воспроизведено вживую: после оптимизации
          // это падало с SIGABRT, а не с SIGSEGV).
          int* volatile bad = nullptr;
          *bad =
              1;  // NOLINT: намеренная, тестовая запись по нулевому указателю.
        } else if (mode == "throw") {
          std::thread([]() -> void {
            throw std::runtime_error(
                "TestConsoleApp: deliberate uncaught exception (crash test)");
          }).detach();
          // Даём отсоединённому потоку время реально бросить исключение (и
          // TerminateHandler() — время на ExecSelfRestart()/abort()),
          // прежде чем собственный цикл этого потока ниже иначе просто
          // проскочил бы мимо этого в режиме ожидания.
          constexpr auto throw_settle_time = std::chrono::seconds(5);
          std::this_thread::sleep_for(throw_settle_time);
        } else {
          // "abort" или "always".
          std::abort();
        }
      }
    }
    constexpr auto idle_poll_interval = std::chrono::milliseconds(20);
    while (m_running.load(std::memory_order_relaxed)) {
      std::this_thread::sleep_for(idle_poll_interval);
    }
    return 0;
  }
 
 protected:
  void user_signal_handler(int /*signum*/) override {}
};

// NOLINTBEGIN(bugprone-easily-swappable-parameters) - у app_name/log_dir
// ясные имена, они различимы в каждой реальной точке вызова.
inline auto make_test_console_app_config(const std::string& app_name,
                                         const std::string& log_dir,
                                         const int port_offset)
    -> std::unique_ptr<insitech::config::ConfigStore<>> {
  // NOLINTEND(bugprone-easily-swappable-parameters)
  static insitech::config::JsonConfigCodec codec;
  auto config = std::make_unique<insitech::config::ConfigStore<>>(
      test_console_app_schema::K_ALL_FIELDS, codec);
  config->set<std::string>(test_console_app_schema::K_APP_NAME.key, app_name);
  config->set<std::string>(test_console_app_schema::K_LOG_DIR.key, log_dir);
  // Собственная история сессий AppControl теперь хранится под app_dir
  // (см. конструктор ConsoleApp.hpp), а не под log_dir — тестовому набору
  // эта разница не важна, поэтому оба поля просто получают одну и ту же
  // выбранную вызывающей стороной директорию.
  config->set<std::string>(test_console_app_schema::K_APP_DIR.key, log_dir);
  config->set<std::string>(test_console_app_schema::K_BUS_MULTICAST_GROUP.key,
                           "239.255.19.40");
  config->set<int64_t>(test_console_app_schema::K_BUS_MULTICAST_PORT.key,
                       K_TEST_CONSOLE_APP_BASE_MULTICAST_PORT + port_offset);
  return config;
}