quic_connection_adapter.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2025, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "kcenon/network/detail/unified/i_connection.h"
#include "kcenon/network/detail/protocol/quic.h"
#include "internal/protocols/quic/connection.h"
#include "internal/protocols/quic/stream.h"
 
#include <atomic>
#include <condition_variable>
#include <deque>
#include <memory>
#include <mutex>
#include <string>
#include <thread>
 
namespace kcenon::network::unified::adapters {
 
class quic_connection_adapter : public i_connection {
public:
    quic_connection_adapter(const protocol::quic::quic_config& config,
                            std::string_view connection_id);
 
    ~quic_connection_adapter() override;
 
    // Non-copyable, non-movable (contains mutex and thread)
    quic_connection_adapter(const quic_connection_adapter&) = delete;
    quic_connection_adapter& operator=(const quic_connection_adapter&) = delete;
    quic_connection_adapter(quic_connection_adapter&&) = delete;
    quic_connection_adapter& operator=(quic_connection_adapter&&) = delete;
 
    // =========================================================================
    // i_transport interface implementation
    // =========================================================================
 
    [[nodiscard]] auto send(std::span<const std::byte> data) -> VoidResult override;
    [[nodiscard]] auto send(std::vector<uint8_t>&& data) -> VoidResult override;
    [[nodiscard]] auto is_connected() const noexcept -> bool override;
    [[nodiscard]] auto id() const noexcept -> std::string_view override;
    [[nodiscard]] auto remote_endpoint() const noexcept -> endpoint_info override;
    [[nodiscard]] auto local_endpoint() const noexcept -> endpoint_info override;
 
    // =========================================================================
    // i_connection interface implementation
    // =========================================================================
 
    [[nodiscard]] auto connect(const endpoint_info& endpoint) -> VoidResult override;
    [[nodiscard]] auto connect(std::string_view url) -> VoidResult override;
    auto close() noexcept -> void override;
    auto set_callbacks(connection_callbacks callbacks) -> void override;
    auto set_options(connection_options options) -> void override;
    auto set_timeout(std::chrono::milliseconds timeout) -> void override;
    [[nodiscard]] auto is_connecting() const noexcept -> bool override;
    auto wait_for_stop() -> void override;
 
private:
    auto io_thread_func() -> void;
 
    auto process_outgoing() -> void;
 
    auto process_incoming() -> void;
 
    auto handle_state_change() -> void;
 
    auto parse_url(std::string_view url) -> std::pair<std::string, uint16_t>;
 
    std::string connection_id_;
    protocol::quic::quic_config config_;
 
    // QUIC connection (owned)
    std::unique_ptr<protocols::quic::connection> quic_conn_;
 
    // UDP socket for QUIC transport
    int socket_fd_{-1};
 
    // I/O thread
    std::thread io_thread_;
    std::atomic<bool> running_{false};
    std::atomic<bool> stop_requested_{false};
 
    // Callbacks
    mutable std::mutex callbacks_mutex_;
    connection_callbacks callbacks_;
 
    // Endpoint information
    mutable std::mutex endpoint_mutex_;
    endpoint_info remote_endpoint_;
    endpoint_info local_endpoint_;
 
    // State
    std::atomic<bool> is_connecting_{false};
    std::atomic<bool> is_connected_{false};
    connection_options options_;
 
    // Stop synchronization
    mutable std::mutex stop_mutex_;
    std::condition_variable stop_cv_;
 
    // Send queue
    mutable std::mutex send_queue_mutex_;
    std::deque<std::vector<uint8_t>> send_queue_;
};
 
}  // namespace kcenon::network::unified::adapters