quic_client_adapter.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2024, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
 
#include "kcenon/network/interfaces/i_protocol_client.h"
 
#include <atomic>
#include <chrono>
#include <memory>
#include <mutex>
#include <optional>
#include <string>
#include <vector>
 
namespace kcenon::network::core {
    class messaging_quic_client;
}
 
namespace kcenon::network::internal::adapters {
 
class quic_client_adapter : public interfaces::i_protocol_client {
public:
    explicit quic_client_adapter(std::string_view client_id);
 
    ~quic_client_adapter() override;
 
    // Non-copyable, non-movable
    quic_client_adapter(const quic_client_adapter&) = delete;
    quic_client_adapter& operator=(const quic_client_adapter&) = delete;
    quic_client_adapter(quic_client_adapter&&) = delete;
    quic_client_adapter& operator=(quic_client_adapter&&) = delete;
 
    // =========================================================================
    // QUIC-specific Configuration
    // =========================================================================
 
    auto set_alpn_protocols(const std::vector<std::string>& protocols) -> void;
 
    auto set_ca_cert_path(std::string_view path) -> void;
 
    auto set_client_cert(std::string_view cert_path, std::string_view key_path) -> void;
 
    auto set_verify_server(bool verify) -> void;
 
    auto set_max_idle_timeout(uint64_t timeout_ms) -> void;
 
    // =========================================================================
    // i_network_component interface implementation
    // =========================================================================
 
    [[nodiscard]] auto is_running() const -> bool override;
    auto wait_for_stop() -> void override;
 
    // =========================================================================
    // i_protocol_client interface implementation
    // =========================================================================
 
    [[nodiscard]] auto start(std::string_view host, uint16_t port) -> VoidResult override;
    [[nodiscard]] auto stop() -> VoidResult override;
    [[nodiscard]] auto send(std::vector<uint8_t>&& data) -> VoidResult override;
    [[nodiscard]] auto is_connected() const -> bool override;
 
    auto set_observer(std::shared_ptr<interfaces::connection_observer> observer) -> void override;
 
    auto set_receive_callback(receive_callback_t callback) -> void override;
    auto set_connected_callback(connected_callback_t callback) -> void override;
    auto set_disconnected_callback(disconnected_callback_t callback) -> void override;
    auto set_error_callback(error_callback_t callback) -> void override;
 
private:
    auto setup_internal_callbacks() -> void;
 
    std::string client_id_;
    std::shared_ptr<core::messaging_quic_client> client_;
 
    // QUIC-specific configuration
    std::vector<std::string> alpn_protocols_;
    std::optional<std::string> ca_cert_path_;
    std::optional<std::string> client_cert_path_;
    std::optional<std::string> client_key_path_;
    bool verify_server_{true};
    uint64_t max_idle_timeout_ms_{30000};
 
    mutable std::mutex callbacks_mutex_;
    std::shared_ptr<interfaces::connection_observer> observer_;
    receive_callback_t receive_callback_;
    connected_callback_t connected_callback_;
    disconnected_callback_t disconnected_callback_;
    error_callback_t error_callback_;
};
 
} // namespace kcenon::network::internal::adapters