mpps_scp.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_MPPS_SCP_HPP
#define PACS_SERVICES_MPPS_SCP_HPP
 
#include "scp_service.h"
 
#include <atomic>
#include <functional>
#include <optional>
#include <string>
 
namespace kcenon::pacs::services {
 
// =============================================================================
// SOP Class UID
// =============================================================================
 
inline constexpr std::string_view mpps_sop_class_uid = "1.2.840.10008.3.1.2.3.3";
 
// =============================================================================
// MPPS Types
// =============================================================================
 
enum class mpps_status {
    in_progress,   
    completed,     
    discontinued   
};
 
[[nodiscard]] inline auto to_string(mpps_status status) -> std::string_view {
    switch (status) {
        case mpps_status::in_progress:
            return "IN PROGRESS";
        case mpps_status::completed:
            return "COMPLETED";
        case mpps_status::discontinued:
            return "DISCONTINUED";
        default:
            return "IN PROGRESS";
    }
}
 
[[nodiscard]] inline auto parse_mpps_status(std::string_view str)
    -> std::optional<mpps_status> {
    if (str == "IN PROGRESS") {
        return mpps_status::in_progress;
    }
    if (str == "COMPLETED") {
        return mpps_status::completed;
    }
    if (str == "DISCONTINUED") {
        return mpps_status::discontinued;
    }
    return std::nullopt;
}
 
struct mpps_instance {
    std::string sop_instance_uid;
 
    mpps_status status{mpps_status::in_progress};
 
    std::string station_ae;
 
    core::dicom_dataset data;
};
 
// =============================================================================
// Handler Types
// =============================================================================
 
using mpps_create_handler = std::function<network::Result<std::monostate>(
    const mpps_instance& instance)>;
 
using mpps_set_handler = std::function<network::Result<std::monostate>(
    const std::string& sop_instance_uid,
    const core::dicom_dataset& modifications,
    mpps_status new_status)>;
 
// =============================================================================
// MPPS SCP Class
// =============================================================================
 
class mpps_scp final : public scp_service {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit mpps_scp(std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~mpps_scp() override = default;
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    void set_create_handler(mpps_create_handler handler);
 
    void set_set_handler(mpps_set_handler handler);
 
    // =========================================================================
    // scp_service Interface Implementation
    // =========================================================================
 
    [[nodiscard]] std::vector<std::string> supported_sop_classes() const override;
 
    [[nodiscard]] network::Result<std::monostate> handle_message(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request) override;
 
    [[nodiscard]] std::string_view service_name() const noexcept override;
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] size_t creates_processed() const noexcept;
 
    [[nodiscard]] size_t sets_processed() const noexcept;
 
    [[nodiscard]] size_t mpps_completed() const noexcept;
 
    [[nodiscard]] size_t mpps_discontinued() const noexcept;
 
    void reset_statistics() noexcept;
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> handle_n_create(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> handle_n_set(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> send_n_create_response(
        network::association& assoc,
        uint8_t context_id,
        uint16_t message_id,
        const std::string& sop_instance_uid,
        network::dimse::status_code status);
 
    [[nodiscard]] network::Result<std::monostate> send_n_set_response(
        network::association& assoc,
        uint8_t context_id,
        uint16_t message_id,
        const std::string& sop_instance_uid,
        network::dimse::status_code status);
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    mpps_create_handler create_handler_;
    mpps_set_handler set_handler_;
 
    std::atomic<size_t> creates_processed_{0};
    std::atomic<size_t> sets_processed_{0};
    std::atomic<size_t> mpps_completed_{0};
    std::atomic<size_t> mpps_discontinued_{0};
};
 
// =============================================================================
// MPPS DICOM Tags (Group 0x0040)
// =============================================================================
 
namespace mpps_tags {
 
inline constexpr core::dicom_tag performed_station_ae_title{0x0040, 0x0241};
 
inline constexpr core::dicom_tag performed_station_name{0x0040, 0x0242};
 
inline constexpr core::dicom_tag performed_location{0x0040, 0x0243};
 
inline constexpr core::dicom_tag performed_procedure_step_end_date{0x0040, 0x0250};
 
inline constexpr core::dicom_tag performed_procedure_step_end_time{0x0040, 0x0251};
 
inline constexpr core::dicom_tag performed_procedure_step_status{0x0040, 0x0252};
 
inline constexpr core::dicom_tag performed_procedure_step_id{0x0040, 0x0253};
 
inline constexpr core::dicom_tag performed_series_sequence{0x0040, 0x0340};
 
inline constexpr core::dicom_tag scheduled_step_attributes_sequence{0x0040, 0x0270};
 
inline constexpr core::dicom_tag referenced_study_sequence{0x0008, 0x1110};
 
}  // namespace mpps_tags
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_MPPS_SCP_HPP