imaging_document_consumer.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.
 
#ifndef PACS_SERVICES_XDS_IMAGING_DOCUMENT_CONSUMER_HPP
#define PACS_SERVICES_XDS_IMAGING_DOCUMENT_CONSUMER_HPP
 
#include "kcenon/pacs/core/dicom_dataset.h"
 
#include <cstdint>
#include <memory>
#include <optional>
#include <string>
#include <vector>
 
namespace kcenon::pacs::security { class atna_service_auditor; }
 
namespace kcenon::pacs::services::xds {
 
// =============================================================================
// Registry Query Types
// =============================================================================
 
struct registry_query_params {
    std::string patient_id;
 
    std::optional<std::string> class_code;
 
    std::optional<std::string> type_code;
 
    std::optional<std::string> practice_setting_code;
 
    std::optional<std::string> creation_time_from;
 
    std::optional<std::string> creation_time_to;
 
    std::string status{"Approved"};
 
    std::string query_id{"urn:uuid:14d4debf-8f97-4251-9a74-a90016b0af0d"};
};
 
struct document_reference {
    std::string unique_id;
 
    std::string repository_unique_id;
 
    std::string entry_uuid;
 
    std::string patient_id;
 
    std::string class_code;
 
    std::string type_code;
 
    std::string creation_time;
 
    std::string title;
 
    std::string mime_type;
 
    std::string status;
 
    size_t size{0};
};
 
struct registry_query_result {
    bool success{false};
 
    std::vector<document_reference> documents;
 
    std::string error_message;
 
    int http_status{0};
};
 
struct document_retrieval_result {
    bool success{false};
 
    std::optional<core::dicom_dataset> document;
 
    std::vector<std::string> referenced_study_uids;
    std::vector<std::string> referenced_series_uids;
    std::vector<std::string> referenced_instance_uids;
 
    std::string error_message;
 
    int http_status{0};
};
 
// =============================================================================
// Imaging Document Consumer Configuration
// =============================================================================
 
struct imaging_document_consumer_config {
    std::string registry_url;
 
    std::string repository_url;
 
    std::string wado_rs_url;
 
    uint32_t timeout_ms{30000};
 
    uint32_t max_results{100};
};
 
// =============================================================================
// Imaging Document Consumer
// =============================================================================
 
class imaging_document_consumer {
public:
    imaging_document_consumer() = default;
    explicit imaging_document_consumer(const imaging_document_consumer_config& config);
 
    [[nodiscard]] registry_query_result query_registry(
        const registry_query_params& params) const;
 
    [[nodiscard]] document_retrieval_result retrieve_document(
        const document_reference& doc_ref,
        bool is_imaging = true) const;
 
    void set_audit_handler(
        std::shared_ptr<kcenon::pacs::security::atna_service_auditor> auditor);
 
    [[nodiscard]] document_retrieval_result extract_references(
        const core::dicom_dataset& kos_dataset) const;
 
    [[nodiscard]] std::string build_wado_rs_url(
        const std::string& study_uid,
        const std::string& series_uid,
        const std::string& instance_uid) const;
 
    [[nodiscard]] const imaging_document_consumer_config& config() const noexcept;
 
    void set_config(const imaging_document_consumer_config& config);
 
private:
    imaging_document_consumer_config config_;
    std::shared_ptr<kcenon::pacs::security::atna_service_auditor> auditor_;
};
 
}  // namespace kcenon::pacs::services::xds
 
#endif  // PACS_SERVICES_XDS_IMAGING_DOCUMENT_CONSUMER_HPP