pdu_decode_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/pdu_types.h>
#include <kcenon/pacs/core/result.h>
 
#include <cstdint>
#include <functional>
#include <string>
#include <vector>
 
namespace kcenon::pacs::network::pipeline {
 
struct decoded_pdu {
    kcenon::pacs::network::pdu_type type;
 
    uint64_t session_id;
 
    std::vector<uint8_t> data;
 
    uint8_t presentation_context_id{0};
 
    bool is_last_fragment{true};
};
 
class pdu_decode_job : public pipeline_job_base {
public:
    using decode_callback = std::function<void(const decoded_pdu& pdu)>;
 
    using error_callback = std::function<void(uint64_t session_id,
                                              const std::string& error)>;
 
    pdu_decode_job(uint64_t session_id,
                   std::vector<uint8_t> raw_data,
                   decode_callback on_decoded = nullptr,
                   error_callback on_error = nullptr);
 
    ~pdu_decode_job() override = default;
 
    // Non-copyable, movable
    pdu_decode_job(const pdu_decode_job&) = delete;
    pdu_decode_job& operator=(const pdu_decode_job&) = delete;
    pdu_decode_job(pdu_decode_job&&) = default;
    pdu_decode_job& operator=(pdu_decode_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_raw_data() const noexcept -> const std::vector<uint8_t>&;
 
private:
    job_context context_;
    std::vector<uint8_t> raw_data_;
    decode_callback on_decoded_;
    error_callback on_error_;
 
    [[nodiscard]] auto decode_pdu() -> Result<decoded_pdu>;
};
 
}  // namespace kcenon::pacs::network::pipeline