response_encode_job.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.
 
#pragma once
 
#include <kcenon/pacs/network/pipeline/pipeline_coordinator.h>
#include <kcenon/pacs/network/pipeline/pipeline_job_types.h>
#include <kcenon/pacs/network/pipeline/jobs/storage_query_exec_job.h>
#include <kcenon/pacs/core/result.h>
 
#include <cstdint>
#include <functional>
#include <vector>
 
namespace kcenon::pacs::network::pipeline {
 
struct encoded_response {
    uint64_t session_id;
 
    std::vector<uint8_t> pdu_data;
 
    bool is_final{true};
 
    uint16_t message_id;
};
 
class response_encode_job : public pipeline_job_base {
public:
    using encode_callback = std::function<void(const encoded_response& response)>;
 
    using error_callback = std::function<void(uint64_t session_id,
                                              const std::string& error)>;
 
    response_encode_job(service_result result,
                        uint32_t max_pdu_size = 16384,
                        encode_callback on_encoded = nullptr,
                        error_callback on_error = nullptr);
 
    ~response_encode_job() override = default;
 
    // Non-copyable, movable
    response_encode_job(const response_encode_job&) = delete;
    response_encode_job& operator=(const response_encode_job&) = delete;
    response_encode_job(response_encode_job&&) = default;
    response_encode_job& operator=(response_encode_job&&) = default;
 
    [[nodiscard]] auto execute(pipeline_coordinator& coordinator) -> VoidResult override;
 
    [[nodiscard]] auto get_context() const noexcept -> const job_context& override;
    [[nodiscard]] auto get_context() noexcept -> job_context& override;
 
    [[nodiscard]] auto get_name() const -> std::string override;
 
    [[nodiscard]] auto get_result() const noexcept -> const service_result&;
 
private:
    job_context context_;
    service_result result_;
    uint32_t max_pdu_size_;
    encode_callback on_encoded_;
    error_callback on_error_;
 
    [[nodiscard]] auto encode_response() -> Result<std::vector<encoded_response>>;
 
    [[nodiscard]] auto encode_dimse_command() -> Result<std::vector<uint8_t>>;
 
    [[nodiscard]] auto fragment_data(const std::vector<uint8_t>& data)
        -> std::vector<std::vector<uint8_t>>;
};
 
}  // namespace kcenon::pacs::network::pipeline