n_get_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_N_GET_SCP_HPP
#define PACS_SERVICES_N_GET_SCP_HPP
 
#include "scp_service.h"
 
#include <atomic>
#include <functional>
#include <string>
#include <vector>
 
namespace kcenon::pacs::services {
 
// =============================================================================
// Handler Types
// =============================================================================
 
using n_get_handler = std::function<network::Result<core::dicom_dataset>(
    const std::string& sop_class_uid,
    const std::string& sop_instance_uid,
    const std::vector<core::dicom_tag>& attribute_tags)>;
 
// =============================================================================
// N-GET SCP Class
// =============================================================================
 
class n_get_scp final : public scp_service {
public:
    // =========================================================================
    // Construction
    // =========================================================================
 
    explicit n_get_scp(std::shared_ptr<di::ILogger> logger = nullptr);
 
    ~n_get_scp() override = default;
 
    // =========================================================================
    // Configuration
    // =========================================================================
 
    void set_handler(n_get_handler handler);
 
    void add_supported_sop_class(std::string sop_class_uid);
 
    // =========================================================================
    // 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 gets_processed() const noexcept;
 
    void reset_statistics() noexcept;
 
private:
    // =========================================================================
    // Private Implementation
    // =========================================================================
 
    [[nodiscard]] network::Result<std::monostate> send_n_get_response(
        network::association& assoc,
        uint8_t context_id,
        uint16_t message_id,
        const std::string& sop_class_uid,
        const std::string& sop_instance_uid,
        network::dimse::status_code status,
        core::dicom_dataset* dataset = nullptr);
 
    // =========================================================================
    // Member Variables
    // =========================================================================
 
    n_get_handler handler_;
    std::vector<std::string> supported_sop_classes_;
 
    std::atomic<size_t> gets_processed_{0};
};
 
}  // namespace kcenon::pacs::services
 
#endif  // PACS_SERVICES_N_GET_SCP_HPP