storage_commitment_scu.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_STORAGE_COMMITMENT_SCU_HPP
#define PACS_SERVICES_STORAGE_COMMITMENT_SCU_HPP
 
#include "storage_commitment_types.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 <functional>
#include <memory>
#include <string>
 
namespace kcenon::pacs::services {
 
class storage_commitment_scu {
public:
    explicit storage_commitment_scu(
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~storage_commitment_scu() = default;
 
    // =========================================================================
    // Callback Configuration
    // =========================================================================
 
    using commitment_callback = std::function<void(
        const std::string& transaction_uid,
        const commitment_result& result)>;
 
    void set_commitment_callback(commitment_callback cb);
 
    // =========================================================================
    // N-ACTION Request
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> request_commitment(
        network::association& assoc,
        uint8_t context_id,
        const std::string& transaction_uid,
        const std::vector<sop_reference>& references);
 
    // =========================================================================
    // N-EVENT-REPORT Handler
    // =========================================================================
 
    [[nodiscard]] network::Result<commitment_result> handle_event_report(
        const network::dimse::dimse_message& event_rq);
 
    // =========================================================================
    // Statistics
    // =========================================================================
 
    [[nodiscard]] size_t requests_sent() const noexcept;
    [[nodiscard]] size_t event_reports_received() const noexcept;
    void reset_statistics() noexcept;
 
private:
    // =========================================================================
    // Dataset Builders
    // =========================================================================
 
    [[nodiscard]] static core::dicom_dataset build_action_dataset(
        const std::string& transaction_uid,
        const std::vector<sop_reference>& references);
 
    [[nodiscard]] static commitment_result parse_event_report_dataset(
        const core::dicom_dataset& dataset);
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    std::shared_ptr<di::ILogger> logger_;
    commitment_callback callback_;
 
    std::atomic<size_t> requests_sent_{0};
    std::atomic<size_t> event_reports_received_{0};
};
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_STORAGE_COMMITMENT_SCU_HPP