routing_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/routing_types.h"
#include "kcenon/pacs/core/result.h"
#include "kcenon/pacs/di/ilogger.h"
 
#include <atomic>
#include <memory>
#include <shared_mutex>
#include <string>
#include <string_view>
#include <vector>
 
// Forward declarations
namespace kcenon::pacs::core {
class dicom_dataset;
}
 
namespace kcenon::pacs::storage {
class routing_repository;
}
 
namespace kcenon::pacs::services {
class storage_scp;
}
 
namespace kcenon::pacs::client {
 
// Forward declaration
class job_manager;
 
// =============================================================================
// Routing Manager
// =============================================================================
 
class routing_manager {
public:
    // =========================================================================
    // Construction / Destruction
    // =========================================================================
 
    explicit routing_manager(
        std::shared_ptr<storage::routing_repository> repo,
        std::shared_ptr<job_manager> job_manager,
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    explicit routing_manager(
        const routing_manager_config& config,
        std::shared_ptr<storage::routing_repository> repo,
        std::shared_ptr<job_manager> job_manager,
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~routing_manager();
 
    // Non-copyable, non-movable
    routing_manager(const routing_manager&) = delete;
    auto operator=(const routing_manager&) -> routing_manager& = delete;
    routing_manager(routing_manager&&) = delete;
    auto operator=(routing_manager&&) -> routing_manager& = delete;
 
    // =========================================================================
    // Rule CRUD
    // =========================================================================
 
    [[nodiscard]] auto add_rule(const routing_rule& rule) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto update_rule(const routing_rule& rule) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto remove_rule(std::string_view rule_id) -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto get_rule(std::string_view rule_id) const
        -> std::optional<routing_rule>;
 
    [[nodiscard]] auto list_rules() const -> std::vector<routing_rule>;
 
    [[nodiscard]] auto list_enabled_rules() const -> std::vector<routing_rule>;
 
    // =========================================================================
    // Rule Ordering
    // =========================================================================
 
    [[nodiscard]] auto set_rule_priority(std::string_view rule_id, int priority)
        -> kcenon::pacs::VoidResult;
 
    [[nodiscard]] auto reorder_rules(const std::vector<std::string>& rule_ids)
        -> kcenon::pacs::VoidResult;
 
    // =========================================================================
    // Rule Evaluation
    // =========================================================================
 
    [[nodiscard]] auto evaluate(const core::dicom_dataset& dataset)
        -> std::vector<routing_action>;
 
    [[nodiscard]] auto evaluate_with_rule_ids(const core::dicom_dataset& dataset)
        -> std::vector<std::pair<std::string, std::vector<routing_action>>>;
 
    // =========================================================================
    // Routing Execution
    // =========================================================================
 
    void route(const core::dicom_dataset& dataset);
 
    void route(std::string_view sop_instance_uid);
 
    // =========================================================================
    // Enable/Disable
    // =========================================================================
 
    void enable();
 
    void disable();
 
    [[nodiscard]] auto is_enabled() const noexcept -> bool;
 
    // =========================================================================
    // Storage SCP Integration
    // =========================================================================
 
    void attach_to_storage_scp(services::storage_scp& scp);
 
    void detach_from_storage_scp();
 
    // =========================================================================
    // Event Callbacks
    // =========================================================================
 
    void set_routing_callback(routing_event_callback callback);
 
    // =========================================================================
    // Testing (Dry Run)
    // =========================================================================
 
    [[nodiscard]] auto test_rules(const core::dicom_dataset& dataset) const
        -> routing_test_result;
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] auto get_statistics() const -> routing_statistics;
 
    [[nodiscard]] auto get_rule_statistics(std::string_view rule_id) const
        -> routing_statistics;
 
    void reset_statistics();
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    [[nodiscard]] auto config() const noexcept -> const routing_manager_config&;
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    [[nodiscard]] auto match_condition(const routing_condition& condition,
                                       const core::dicom_dataset& dataset) const
        -> bool;
 
    [[nodiscard]] auto match_pattern(std::string_view pattern,
                                     std::string_view value,
                                     bool case_sensitive) const -> bool;
 
    [[nodiscard]] auto get_field_value(routing_field field,
                                       const core::dicom_dataset& dataset) const
        -> std::string;
 
    void execute_actions(const std::string& sop_instance_uid,
                        const std::vector<routing_action>& actions);
 
    void load_rules();
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    routing_manager_config config_;
    std::shared_ptr<storage::routing_repository> repo_;
    std::shared_ptr<job_manager> job_manager_;
    std::shared_ptr<di::ILogger> logger_;
 
    std::vector<routing_rule> rules_;
    mutable std::shared_mutex rules_mutex_;
 
    std::atomic<bool> enabled_{true};
    routing_event_callback routing_callback_;
 
    // Statistics
    std::atomic<size_t> total_evaluated_{0};
    std::atomic<size_t> total_matched_{0};
    std::atomic<size_t> total_forwarded_{0};
    std::atomic<size_t> total_failed_{0};
 
    // Storage SCP attachment state
    services::storage_scp* attached_scp_{nullptr};
};
 
}  // namespace kcenon::pacs::client