ups_push_scp.h

Go to the documentation of this file.

 
#ifndef PACS_SERVICES_UPS_PUSH_SCP_HPP
#define PACS_SERVICES_UPS_PUSH_SCP_HPP
 
#include "../scp_service.h"
 
#include <atomic>
#include <functional>
#include <optional>
#include <string>
#include <variant>
 
#include "kcenon/pacs/storage/ups_workitem.h"
 
namespace kcenon::pacs::services {
 
// =============================================================================
// SOP Class UID
// =============================================================================
 
inline constexpr std::string_view ups_push_sop_class_uid =
    "1.2.840.10008.5.1.4.34.6.1";
 
// =============================================================================
// N-ACTION Type Constants
// =============================================================================
 
inline constexpr uint16_t ups_action_change_state = 1;
 
inline constexpr uint16_t ups_action_request_cancel = 3;
 
// =============================================================================
// Handler Types
// =============================================================================
 
using ups_create_handler = std::function<network::Result<std::monostate>(
    const storage::ups_workitem& workitem)>;
 
using ups_set_handler = std::function<network::Result<std::monostate>(
    const std::string& workitem_uid,
    const core::dicom_dataset& modifications)>;
 
using ups_get_handler = std::function<network::Result<storage::ups_workitem>(
    const std::string& workitem_uid)>;
 
using ups_change_state_handler = std::function<network::Result<std::monostate>(
    const std::string& workitem_uid,
    const std::string& new_state,
    const std::string& transaction_uid)>;
 
using ups_request_cancel_handler = std::function<network::Result<std::monostate>(
    const std::string& workitem_uid,
    const std::string& reason)>;
 
// =============================================================================
// UPS Push SCP Class
// =============================================================================
 
class ups_push_scp final : public scp_service {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit ups_push_scp(std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~ups_push_scp() override = default;
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    void set_create_handler(ups_create_handler handler);
    void set_set_handler(ups_set_handler handler);
    void set_get_handler(ups_get_handler handler);
    void set_change_state_handler(ups_change_state_handler handler);
    void set_request_cancel_handler(ups_request_cancel_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 gets_processed() const noexcept;
    [[nodiscard]] size_t actions_processed() const noexcept;
    [[nodiscard]] size_t state_changes() const noexcept;
    [[nodiscard]] size_t cancel_requests() 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> handle_n_get(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    [[nodiscard]] network::Result<std::monostate> handle_n_action(
        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);
 
    [[nodiscard]] network::Result<std::monostate> send_n_get_response(
        network::association& assoc,
        uint8_t context_id,
        uint16_t message_id,
        const std::string& sop_instance_uid,
        network::dimse::status_code status,
        core::dicom_dataset* dataset = nullptr);
 
    [[nodiscard]] network::Result<std::monostate> send_n_action_response(
        network::association& assoc,
        uint8_t context_id,
        uint16_t message_id,
        const std::string& sop_instance_uid,
        uint16_t action_type_id,
        network::dimse::status_code status);
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    ups_create_handler create_handler_;
    ups_set_handler set_handler_;
    ups_get_handler get_handler_;
    ups_change_state_handler change_state_handler_;
    ups_request_cancel_handler request_cancel_handler_;
 
    std::atomic<size_t> creates_processed_{0};
    std::atomic<size_t> sets_processed_{0};
    std::atomic<size_t> gets_processed_{0};
    std::atomic<size_t> actions_processed_{0};
    std::atomic<size_t> state_changes_{0};
    std::atomic<size_t> cancel_requests_{0};
};
 
// =============================================================================
// UPS DICOM Tags
// =============================================================================
 
namespace ups_tags {
 
inline constexpr core::dicom_tag procedure_step_state{0x0074, 0x1000};
 
inline constexpr core::dicom_tag procedure_step_progress{0x0074, 0x1004};
 
inline constexpr core::dicom_tag scheduled_procedure_step_priority{0x0074, 0x1200};
 
inline constexpr core::dicom_tag worklist_label{0x0074, 0x1202};
 
inline constexpr core::dicom_tag procedure_step_label{0x0074, 0x1204};
 
inline constexpr core::dicom_tag transaction_uid{0x0008, 0x1195};
 
inline constexpr core::dicom_tag input_information_sequence{0x0040, 0x4021};
 
inline constexpr core::dicom_tag reason_for_cancellation{0x0074, 0x1238};
 
}  // namespace ups_tags
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_UPS_PUSH_SCP_HPP