receive_network_io_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/core/result.h>
 
#include <cstdint>
#include <functional>
#include <string>
#include <vector>
 
namespace kcenon::pacs::network::pipeline {
 
class receive_network_io_job : public pipeline_job_base {
public:
    using data_callback = std::function<void(uint64_t session_id,
                                             std::vector<uint8_t> data)>;
 
    using error_callback = std::function<void(uint64_t session_id,
                                              const std::string& error)>;
 
    receive_network_io_job(uint64_t session_id,
                           std::vector<uint8_t> data,
                           data_callback on_data = nullptr,
                           error_callback on_error = nullptr);
 
    ~receive_network_io_job() override = default;
 
    // Non-copyable, movable
    receive_network_io_job(const receive_network_io_job&) = delete;
    receive_network_io_job& operator=(const receive_network_io_job&) = delete;
    receive_network_io_job(receive_network_io_job&&) = default;
    receive_network_io_job& operator=(receive_network_io_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_data() const noexcept -> const std::vector<uint8_t>&;
 
    [[nodiscard]] auto get_session_id() const noexcept -> uint64_t;
 
private:
    job_context context_;
    std::vector<uint8_t> data_;
    data_callback on_data_;
    error_callback on_error_;
};
 
}  // namespace kcenon::pacs::network::pipeline