storage_commitment_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_STORAGE_COMMITMENT_SCP_HPP
#define PACS_SERVICES_STORAGE_COMMITMENT_SCP_HPP
 
#include "scp_service.h"
#include "storage_commitment_types.h"
 
#include <kcenon/pacs/storage/storage_interface.h>
 
#include <atomic>
#include <memory>
#include <string>
 
namespace kcenon::pacs::services {
 
class storage_commitment_scp final : public scp_service {
public:
    explicit storage_commitment_scp(
        std::shared_ptr<storage::storage_interface> storage,
        std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~storage_commitment_scp() override = default;
 
    // =========================================================================
    // scp_service Interface
    // =========================================================================
 
    [[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 actions_processed() const noexcept;
    [[nodiscard]] size_t instances_committed() const noexcept;
    [[nodiscard]] size_t instances_failed() const noexcept;
    void reset_statistics() noexcept;
 
private:
    // =========================================================================
    // N-ACTION Handler
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> handle_n_action(
        network::association& assoc,
        uint8_t context_id,
        const network::dimse::dimse_message& request);
 
    // =========================================================================
    // Instance Verification
    // =========================================================================
 
    [[nodiscard]] commitment_result verify_instances(
        const std::string& transaction_uid,
        const std::vector<sop_reference>& references);
 
    // =========================================================================
    // N-EVENT-REPORT Sender
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> send_event_report(
        network::association& assoc,
        uint8_t context_id,
        const commitment_result& result);
 
    // =========================================================================
    // Response Helpers
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> send_n_action_response(
        network::association& assoc,
        uint8_t context_id,
        uint16_t message_id,
        network::dimse::status_code status);
 
    // =========================================================================
    // Dataset Parsing Helpers
    // =========================================================================
 
    [[nodiscard]] static std::vector<sop_reference> parse_referenced_sop_sequence(
        const core::dicom_dataset& dataset);
 
    [[nodiscard]] static core::dicom_dataset build_event_report_dataset(
        const commitment_result& result);
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    std::shared_ptr<storage::storage_interface> storage_;
 
    std::atomic<size_t> actions_processed_{0};
    std::atomic<size_t> instances_committed_{0};
    std::atomic<size_t> instances_failed_{0};
};
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_STORAGE_COMMITMENT_SCP_HPP