ups_watch_scu.h

Go to the documentation of this file.

 
#ifndef PACS_SERVICES_UPS_WATCH_SCU_HPP
#define PACS_SERVICES_UPS_WATCH_SCU_HPP
 
#include "ups_push_scu.h"
#include "ups_watch_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 <functional>
#include <memory>
#include <string>
 
namespace kcenon::pacs::services {
 
// =============================================================================
// UPS Watch SCU Data Structures
// =============================================================================
 
struct ups_subscribe_data {
    std::string workitem_uid;
 
    bool deletion_lock{false};
};
 
struct ups_unsubscribe_data {
    std::string workitem_uid;
};
 
struct ups_watch_event {
    uint16_t event_type_id{0};
 
    std::string workitem_uid;
 
    std::string procedure_step_state;
 
    std::string progress;
 
    std::string cancellation_reason;
 
    core::dicom_dataset event_info;
 
    std::chrono::system_clock::time_point timestamp;
};
 
struct ups_watch_scu_config {
    std::chrono::milliseconds timeout{30000};
};
 
// =============================================================================
// UPS Watch SCU Class
// =============================================================================
 
class ups_watch_scu {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit ups_watch_scu(std::shared_ptr<di::ILogger> logger = nullptr);
 
    explicit ups_watch_scu(const ups_watch_scu_config& config,
                           std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~ups_watch_scu() = default;
 
    // Non-copyable, non-movable (due to atomic members)
    ups_watch_scu(const ups_watch_scu&) = delete;
    ups_watch_scu& operator=(const ups_watch_scu&) = delete;
    ups_watch_scu(ups_watch_scu&&) = delete;
    ups_watch_scu& operator=(ups_watch_scu&&) = delete;
 
    // =========================================================================
    // Callback Configuration
    // =========================================================================
 
    using event_received_callback = std::function<void(
        const ups_watch_event& event)>;
 
    void set_event_received_callback(event_received_callback cb);
 
    // =========================================================================
    // N-ACTION Operations
    // =========================================================================
 
    [[nodiscard]] network::Result<ups_result> subscribe(
        network::association& assoc,
        const ups_subscribe_data& data);
 
    [[nodiscard]] network::Result<ups_result> unsubscribe(
        network::association& assoc,
        const ups_unsubscribe_data& data);
 
    [[nodiscard]] network::Result<ups_result> suspend_global(
        network::association& assoc);
 
    // =========================================================================
    // N-EVENT-REPORT Handler
    // =========================================================================
 
    [[nodiscard]] network::Result<ups_watch_event> handle_event_report(
        const network::dimse::dimse_message& event_rq);
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] size_t subscribes_performed() const noexcept;
    [[nodiscard]] size_t unsubscribes_performed() const noexcept;
    [[nodiscard]] size_t events_received() const noexcept;
 
    void reset_statistics() noexcept;
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    [[nodiscard]] network::Result<ups_result> send_watch_action(
        network::association& assoc,
        const std::string& sop_instance_uid,
        uint16_t action_type_id);
 
    [[nodiscard]] static ups_watch_event parse_event_dataset(
        uint16_t event_type_id,
        const std::string& workitem_uid,
        const core::dicom_dataset& dataset);
 
    [[nodiscard]] uint16_t next_message_id() noexcept;
 
    // =========================================================================
    // Private Members
    // =========================================================================
 
    std::shared_ptr<di::ILogger> logger_;
    ups_watch_scu_config config_;
    event_received_callback event_callback_;
    std::atomic<uint16_t> message_id_counter_{1};
    std::atomic<size_t> subscribes_performed_{0};
    std::atomic<size_t> unsubscribes_performed_{0};
    std::atomic<size_t> events_received_{0};
};
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_UPS_WATCH_SCU_HPP