remote_node_manager.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2021-2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "kcenon/pacs/client/remote_node.h"
#include "kcenon/pacs/core/result.h"
#include "kcenon/pacs/di/ilogger.h"
 
#include <chrono>
#include <future>
#include <memory>
#include <mutex>
#include <span>
#include <string>
#include <string_view>
#include <vector>
 
// Forward declarations
namespace kcenon::pacs::storage {
class node_repository;
}
 
namespace kcenon::pacs::network {
class association;
}
 
namespace kcenon::pacs::client {
 
// =============================================================================
// Remote Node Manager
// =============================================================================
 
class remote_node_manager {
public:
    // =========================================================================
    // Construction / Destruction
    // =========================================================================
 
    explicit remote_node_manager(
        std::shared_ptr<storage::node_repository> repo,
        node_manager_config config = {},
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~remote_node_manager();
 
    // Non-copyable, non-movable (due to internal threading)
    remote_node_manager(const remote_node_manager&) = delete;
    auto operator=(const remote_node_manager&) -> remote_node_manager& = delete;
    remote_node_manager(remote_node_manager&&) = delete;
    auto operator=(remote_node_manager&&) -> remote_node_manager& = delete;
 
    // =========================================================================
    // Node CRUD Operations
    // =========================================================================
 
    [[nodiscard]] auto add_node(const remote_node& node) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto update_node(const remote_node& node) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto remove_node(std::string_view node_id) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto get_node(std::string_view node_id) const
        -> std::optional<remote_node>;
 
    [[nodiscard]] auto list_nodes() const -> std::vector<remote_node>;
 
    [[nodiscard]] auto list_nodes_by_status(node_status status) const
        -> std::vector<remote_node>;
 
    // =========================================================================
    // Connection Verification (C-ECHO)
    // =========================================================================
 
    [[nodiscard]] auto verify_node(std::string_view node_id) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto verify_node_async(std::string_view node_id)
        -> std::future<kcenon::pacs::VoidResult>;
 
    void verify_all_nodes_async();
 
    // =========================================================================
    // Association Pool Management
    // =========================================================================
 
    [[nodiscard]] auto acquire_association(
        std::string_view node_id,
        std::span<const std::string> sop_classes)
        -> kcenon::pacs::Result<std::unique_ptr<network::association>>;
 
    void release_association(
        std::string_view node_id,
        std::unique_ptr<network::association> assoc);
 
    // =========================================================================
    // Health Check Scheduler
    // =========================================================================
 
    void start_health_check();
 
    void stop_health_check();
 
    [[nodiscard]] auto is_health_check_running() const noexcept -> bool;
 
    // =========================================================================
    // Status Monitoring
    // =========================================================================
 
    [[nodiscard]] auto get_status(std::string_view node_id) const -> node_status;
 
    void set_status_callback(node_status_callback callback);
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] auto get_statistics(std::string_view node_id) const
        -> node_statistics;
 
    void reset_statistics(std::string_view node_id = "");
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    [[nodiscard]] auto config() const noexcept -> const node_manager_config&;
 
    void set_config(node_manager_config new_config);
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    struct impl;
    std::unique_ptr<impl> impl_;
};
 
}  // namespace kcenon::pacs::client