ups_push_scu.h

Go to the documentation of this file.

 
#ifndef PACS_SERVICES_UPS_PUSH_SCU_HPP
#define PACS_SERVICES_UPS_PUSH_SCU_HPP
 
#include "ups_push_scp.h"
 
#include "kcenon/pacs/core/dicom_dataset.h"
#include "kcenon/pacs/di/ilogger.h"
#include "kcenon/pacs/network/association.h"
#include "kcenon/pacs/network/dimse/dimse_message.h"
 
#include <atomic>
#include <chrono>
#include <memory>
#include <string>
#include <vector>
 
namespace kcenon::pacs::services {
 
// =============================================================================
// UPS SCU Data Structures
// =============================================================================
 
struct ups_create_data {
    std::string workitem_uid;
 
    std::string procedure_step_label;
 
    std::string worklist_label;
 
    std::string priority{"MEDIUM"};
 
    std::string scheduled_start_datetime;
 
    std::string expected_completion_datetime;
 
    std::string scheduled_station_name;
 
    std::string input_information;
};
 
struct ups_set_data {
    std::string workitem_uid;
 
    core::dicom_dataset modifications;
};
 
struct ups_get_data {
    std::string workitem_uid;
 
    std::vector<core::dicom_tag> attribute_tags;
};
 
struct ups_change_state_data {
    std::string workitem_uid;
 
    std::string requested_state;
 
    std::string transaction_uid;
};
 
struct ups_request_cancel_data {
    std::string workitem_uid;
 
    std::string reason;
};
 
struct ups_result {
    std::string workitem_uid;
 
    uint16_t status{0};
 
    std::string error_comment;
 
    core::dicom_dataset attributes;
 
    std::chrono::milliseconds elapsed{0};
 
    [[nodiscard]] bool is_success() const noexcept {
        return status == 0x0000;
    }
 
    [[nodiscard]] bool is_warning() const noexcept {
        return (status & 0xF000) == 0xB000;
    }
 
    [[nodiscard]] bool is_error() const noexcept {
        return !is_success() && !is_warning();
    }
};
 
struct ups_push_scu_config {
    std::chrono::milliseconds timeout{30000};
 
    bool auto_generate_uid{true};
};
 
// =============================================================================
// UPS Push SCU Class
// =============================================================================
 
class ups_push_scu {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit ups_push_scu(std::shared_ptr<di::ILogger> logger = nullptr);
 
    explicit ups_push_scu(const ups_push_scu_config& config,
                          std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~ups_push_scu() = default;
 
    // Non-copyable, non-movable (due to atomic members)
    ups_push_scu(const ups_push_scu&) = delete;
    ups_push_scu& operator=(const ups_push_scu&) = delete;
    ups_push_scu(ups_push_scu&&) = delete;
    ups_push_scu& operator=(ups_push_scu&&) = delete;
 
    // =========================================================================
    // N-CREATE Operation
    // =========================================================================
 
    [[nodiscard]] network::Result<ups_result> create(
        network::association& assoc,
        const ups_create_data& data);
 
    // =========================================================================
    // N-SET Operation
    // =========================================================================
 
    [[nodiscard]] network::Result<ups_result> set(
        network::association& assoc,
        const ups_set_data& data);
 
    // =========================================================================
    // N-GET Operation
    // =========================================================================
 
    [[nodiscard]] network::Result<ups_result> get(
        network::association& assoc,
        const ups_get_data& data);
 
    // =========================================================================
    // N-ACTION Operations
    // =========================================================================
 
    [[nodiscard]] network::Result<ups_result> change_state(
        network::association& assoc,
        const ups_change_state_data& data);
 
    [[nodiscard]] network::Result<ups_result> request_cancel(
        network::association& assoc,
        const ups_request_cancel_data& data);
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] size_t creates_performed() const noexcept;
    [[nodiscard]] size_t sets_performed() const noexcept;
    [[nodiscard]] size_t gets_performed() const noexcept;
    [[nodiscard]] size_t actions_performed() const noexcept;
 
    void reset_statistics() noexcept;
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    [[nodiscard]] core::dicom_dataset build_create_dataset(
        const ups_create_data& data) const;
 
    [[nodiscard]] core::dicom_dataset build_change_state_dataset(
        const ups_change_state_data& data) const;
 
    [[nodiscard]] core::dicom_dataset build_request_cancel_dataset(
        const ups_request_cancel_data& data) const;
 
    [[nodiscard]] std::string generate_workitem_uid() const;
 
    [[nodiscard]] uint16_t next_message_id() noexcept;
 
    // =========================================================================
    // Private Members
    // =========================================================================
 
    std::shared_ptr<di::ILogger> logger_;
    ups_push_scu_config config_;
    std::atomic<uint16_t> message_id_counter_{1};
    std::atomic<size_t> creates_performed_{0};
    std::atomic<size_t> sets_performed_{0};
    std::atomic<size_t> gets_performed_{0};
    std::atomic<size_t> actions_performed_{0};
};
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_UPS_PUSH_SCU_HPP