redis_ipc_configuration.hpp

// redis_ipc_configuration.hpp
// Created by Greg on 1/26/25.
// Copyright (C) 2025 Presage Security, Inc.
//
// SPDX-License-Identifier: LGPL-3.0-or-later
 
#pragma once
 
#include <string>
#include <chrono>
#include <optional>
#include <filesystem>
#include <nlohmann/json.hpp>
#include <absl/status/status.h>
#include <absl/status/statusor.h>
#include <glog/logging.h>
 
namespace presage::smartspectra::redis_ipc {

struct RedisIpcConfig {
    std::string host = "localhost";

    int port = 6379;

    std::optional<std::string> password;

    int database = 0;

    std::string key_prefix = "physiology";

    std::chrono::milliseconds connection_timeout{1500};

    std::chrono::milliseconds operation_timeout{1000};

    std::chrono::milliseconds reconnect_interval{5000};

    size_t max_reconnect_attempts = 10;

    struct Channels {
        std::string core_metrics = "core_metrics";
        std::string edge_metrics = "edge_metrics";
        std::string status = "status";
        std::string hud_frame = "hud_frame";
        std::string recording_commands = "recording_commands";
    } channels;

    struct Keys {
        std::string recording_state = "recording_state";
        std::string command_queue = "command_queue";
    } keys;

    size_t max_list_size = 10000;

    std::chrono::seconds frame_ttl{300};

    bool enable_pipelining = true;

    bool enable_debug_logging = false;

    bool use_streams = false;

    size_t stream_max_entries = 100000;

    size_t max_bulk_string_bytes = 134217728;

    size_t max_array_elements = 1000000;

    static absl::StatusOr<RedisIpcConfig> LoadFromJson(const std::filesystem::path& path);

    static absl::Status SaveToJson(const RedisIpcConfig& config, const std::filesystem::path& path);

    [[nodiscard]] nlohmann::json ToJson() const;

    static absl::StatusOr<RedisIpcConfig> FromJson(const nlohmann::json& j);
};

void to_json(nlohmann::json& j, const RedisIpcConfig& config);
void from_json(const nlohmann::json& j, RedisIpcConfig& config);

struct RedisIpcConfigurationTraits {
    using ConfigType = RedisIpcConfig;
    static constexpr const char* backend_name = "Redis IPC";
    static constexpr const char* config_filename = "redis_ipc_config.json";
    static constexpr const char* save_default_flag_name = "save_default_redis_ipc_config";
    static constexpr const char* config_path_flag_name = "redis_ipc_config_path";
 
    static void LogFinalConfig(const ConfigType& config) {
        LOG(INFO) << backend_name << " configuration prepared: host=" << config.host
                  << ", port=" << config.port
                  << ", key_prefix=" << config.key_prefix;
    }
};
 
} // namespace presage::smartspectra::redis_ipc