production_pacs.h

Go to the documentation of this file.

 
#pragma once
 
#include "config_loader.h"
#include "../04_mini_pacs/mini_pacs.h"
 
#include <kcenon/pacs/security/access_control_manager.h>
#include <kcenon/pacs/security/anonymizer.h>
#include <kcenon/pacs/monitoring/health_checker.h>
#include <kcenon/pacs/monitoring/pacs_metrics.h>
#include <kcenon/pacs/web/rest_server.h>
 
#include <atomic>
#include <chrono>
#include <condition_variable>
#include <functional>
#include <memory>
#include <mutex>
#include <string>
#include <thread>
#include <vector>
 
namespace kcenon::pacs::samples {
 
// =============================================================================
// Event Types
// =============================================================================
 
namespace events {
 
struct image_received_event {
    std::string sop_instance_uid;
    std::string sop_class_uid;
    std::string patient_id;
    std::string study_instance_uid;
    std::string calling_ae;
    std::chrono::system_clock::time_point timestamp;
};
 
struct query_executed_event {
    std::string query_level;
    std::size_t result_count;
    std::string calling_ae;
    std::chrono::milliseconds duration;
    std::chrono::system_clock::time_point timestamp;
};
 
struct association_event {
    enum class type { opened, closed, rejected };
 
    type event_type;
    std::string calling_ae;
    std::string called_ae;
    std::string reason;
    std::chrono::system_clock::time_point timestamp;
};
 
struct access_denied_event {
    std::string calling_ae;
    std::string operation;
    std::string reason;
    std::chrono::system_clock::time_point timestamp;
};
 
}  // namespace events
 
// =============================================================================
// Production PACS Statistics
// =============================================================================
 
struct production_statistics {
    std::atomic<std::uint64_t> images_stored{0};
 
    std::atomic<std::uint64_t> images_anonymized{0};
 
    std::atomic<std::uint64_t> queries_executed{0};
 
    std::atomic<std::uint64_t> access_denied_count{0};
 
    std::atomic<std::uint64_t> rest_requests{0};
 
    std::atomic<std::uint32_t> active_associations{0};
 
    std::chrono::system_clock::time_point start_time;
 
    [[nodiscard]] auto uptime() const -> std::chrono::seconds {
        return std::chrono::duration_cast<std::chrono::seconds>(
            std::chrono::system_clock::now() - start_time);
    }
};
 
// =============================================================================
// Production PACS Class
// =============================================================================
 
class production_pacs {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit production_pacs(const production_config& config);
 
    ~production_pacs();
 
    // Non-copyable, non-movable
    production_pacs(const production_pacs&) = delete;
    production_pacs& operator=(const production_pacs&) = delete;
    production_pacs(production_pacs&&) = delete;
    production_pacs& operator=(production_pacs&&) = delete;
 
    // =========================================================================
    // Lifecycle
    // =========================================================================
 
    [[nodiscard]] bool start();
 
    void stop();
 
    void wait();
 
    [[nodiscard]] bool is_running() const noexcept;
 
    // =========================================================================
    // Event Handlers
    // =========================================================================
 
    void on_image_received(std::function<void(const events::image_received_event&)> handler);
 
    void on_query_executed(std::function<void(const events::query_executed_event&)> handler);
 
    void on_association_event(std::function<void(const events::association_event&)> handler);
 
    void on_access_denied(std::function<void(const events::access_denied_event&)> handler);
 
    // =========================================================================
    // Status and Statistics
    // =========================================================================
 
    void print_status() const;
 
    [[nodiscard]] const production_statistics& statistics() const noexcept;
 
    [[nodiscard]] monitoring::health_status get_health() const;
 
    void export_statistics(const std::filesystem::path& path) const;
 
    // =========================================================================
    // Configuration Access
    // =========================================================================
 
    [[nodiscard]] const production_config& config() const noexcept;
 
private:
    // =========================================================================
    // Initialization
    // =========================================================================
 
    void setup_mini_pacs();
    void setup_security();
    void setup_anonymization();
    void setup_rest_api();
    void setup_monitoring();
    void setup_event_handlers();
 
    // =========================================================================
    // Event Dispatch
    // =========================================================================
 
    void dispatch_image_received(const events::image_received_event& event);
    void dispatch_query_executed(const events::query_executed_event& event);
    void dispatch_association_event(const events::association_event& event);
    void dispatch_access_denied(const events::access_denied_event& event);
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    production_config config_;
    production_statistics stats_;
 
    // Core PACS (from Level 4)
    std::unique_ptr<mini_pacs> pacs_;
 
    // Security
    std::shared_ptr<security::access_control_manager> access_control_;
    std::unique_ptr<security::anonymizer> anonymizer_;
 
    // REST API
    std::unique_ptr<web::rest_server> rest_server_;
 
    // Monitoring
    std::shared_ptr<monitoring::health_checker> health_checker_;
    std::shared_ptr<monitoring::pacs_metrics> metrics_;
 
    // Event handlers
    std::vector<std::function<void(const events::image_received_event&)>> image_handlers_;
    std::vector<std::function<void(const events::query_executed_event&)>> query_handlers_;
    std::vector<std::function<void(const events::association_event&)>> association_handlers_;
    std::vector<std::function<void(const events::access_denied_event&)>> access_denied_handlers_;
 
    // Synchronization
    mutable std::mutex handlers_mutex_;
    std::mutex shutdown_mutex_;
    std::condition_variable shutdown_cv_;
    std::atomic<bool> running_{false};
};
 
}  // namespace kcenon::pacs::samples