ws_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 "internal/http/websocket_client.h"
 
#include <atomic>
#include <memory>
#include <mutex>
#include <string>
 
namespace kcenon::network::unified::adapters {
 
class ws_connection_adapter : public i_connection {
public:
    explicit ws_connection_adapter(std::string_view connection_id);
 
    ~ws_connection_adapter() override;
 
    // Non-copyable, non-movable (contains mutex)
    ws_connection_adapter(const ws_connection_adapter&) = delete;
    ws_connection_adapter& operator=(const ws_connection_adapter&) = delete;
    ws_connection_adapter(ws_connection_adapter&&) = delete;
    ws_connection_adapter& operator=(ws_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;
 
    // =========================================================================
    // WebSocket-specific configuration
    // =========================================================================
 
    auto set_path(std::string_view path) -> void;
 
private:
    auto setup_internal_callbacks() -> void;
 
    static auto parse_websocket_url(std::string_view url,
                                    std::string& host,
                                    uint16_t& port,
                                    std::string& path,
                                    bool& secure) -> bool;
 
    std::string connection_id_;
    std::shared_ptr<core::messaging_ws_client> client_;
    std::string ws_path_ = "/";
 
    mutable std::mutex callbacks_mutex_;
    connection_callbacks callbacks_;
 
    mutable std::mutex endpoint_mutex_;
    endpoint_info remote_endpoint_;
    endpoint_info local_endpoint_;
 
    std::atomic<bool> is_connecting_{false};
    connection_options options_;
};
 
}  // namespace kcenon::network::unified::adapters