remote_node.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 <chrono>
#include <cstdint>
#include <functional>
#include <optional>
#include <string>
#include <string_view>
 
namespace kcenon::pacs::client {
 
// =============================================================================
// Node Status
// =============================================================================
 
enum class node_status {
    unknown,     
    online,      
    offline,     
    error,       
    verifying    
};
 
[[nodiscard]] constexpr const char* to_string(node_status status) noexcept {
    switch (status) {
        case node_status::unknown: return "unknown";
        case node_status::online: return "online";
        case node_status::offline: return "offline";
        case node_status::error: return "error";
        case node_status::verifying: return "verifying";
        default: return "unknown";
    }
}
 
[[nodiscard]] inline node_status node_status_from_string(std::string_view str) noexcept {
    if (str == "online") return node_status::online;
    if (str == "offline") return node_status::offline;
    if (str == "error") return node_status::error;
    if (str == "verifying") return node_status::verifying;
    return node_status::unknown;
}
 
// =============================================================================
// TLS Configuration
// =============================================================================
 
struct tls_config {
    std::string cert_path;     
    std::string key_path;      
    std::string ca_path;       
 
    [[nodiscard]] bool is_configured() const noexcept {
        return !cert_path.empty();
    }
};
 
// =============================================================================
// Remote Node
// =============================================================================
 
struct remote_node {
    // =========================================================================
    // Identification
    // =========================================================================
 
    std::string node_id;           
    std::string name;              
    std::string ae_title;          
    std::string host;              
    uint16_t port{104};            
 
    // =========================================================================
    // Supported Services
    // =========================================================================
 
    bool supports_find{true};      
    bool supports_move{true};      
    bool supports_get{false};      
    bool supports_store{true};     
    bool supports_worklist{false}; 
 
    // =========================================================================
    // Connection Settings
    // =========================================================================
 
    std::chrono::seconds connection_timeout{30};  
    std::chrono::seconds dimse_timeout{60};       
    size_t max_associations{4};                   
 
    // =========================================================================
    // TLS Settings (Optional)
    // =========================================================================
 
    std::optional<tls_config> tls;  
 
    // =========================================================================
    // Runtime Status
    // =========================================================================
 
    node_status status{node_status::unknown};     
    std::chrono::system_clock::time_point last_verified;   
    std::chrono::system_clock::time_point last_error;      
    std::string last_error_message;               
 
    // =========================================================================
    // Database Fields
    // =========================================================================
 
    int64_t pk{0};                 
    std::chrono::system_clock::time_point created_at;  
    std::chrono::system_clock::time_point updated_at;  
 
    // =========================================================================
    // Convenience Methods
    // =========================================================================
 
    [[nodiscard]] bool supports_query_retrieve() const noexcept {
        return supports_find && (supports_move || supports_get);
    }
 
    [[nodiscard]] bool is_online() const noexcept {
        return status == node_status::online;
    }
 
    [[nodiscard]] bool has_tls() const noexcept {
        return tls.has_value() && tls->is_configured();
    }
 
    [[nodiscard]] std::string address() const {
        return host + ":" + std::to_string(port);
    }
};
 
// =============================================================================
// Status Callback
// =============================================================================
 
using node_status_callback = std::function<void(std::string_view node_id, node_status status)>;
 
// =============================================================================
// Node Statistics
// =============================================================================
 
struct node_statistics {
    size_t total_connections{0};           
    size_t active_connections{0};          
    size_t successful_operations{0};       
    size_t failed_operations{0};           
    std::chrono::milliseconds avg_response_time{0};  
    std::chrono::milliseconds min_response_time{0};  
    std::chrono::milliseconds max_response_time{0};  
    std::chrono::system_clock::time_point last_activity;  
};
 
// =============================================================================
// Node Manager Configuration
// =============================================================================
 
struct node_manager_config {
    std::chrono::seconds health_check_interval{60};
 
    size_t max_pool_connections_per_node{4};
 
    std::chrono::seconds pool_connection_ttl{300};
 
    bool auto_start_health_check{true};
 
    std::string local_ae_title{"PACS_CLIENT"};
};
 
}  // namespace kcenon::pacs::client