ws_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 <string>
 
namespace kcenon::network::core {
    class messaging_ws_client;
}
 
namespace kcenon::network::internal::adapters {
 
class ws_client_adapter : public interfaces::i_protocol_client {
public:
    explicit ws_client_adapter(
        std::string_view client_id,
        std::chrono::milliseconds ping_interval = std::chrono::seconds(30));
 
    ~ws_client_adapter() override;
 
    // Non-copyable, non-movable
    ws_client_adapter(const ws_client_adapter&) = delete;
    ws_client_adapter& operator=(const ws_client_adapter&) = delete;
    ws_client_adapter(ws_client_adapter&&) = delete;
    ws_client_adapter& operator=(ws_client_adapter&&) = delete;
 
    // =========================================================================
    // Path Configuration
    // =========================================================================
 
    auto set_path(std::string_view path) -> 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::string path_{"/"}; // Default WebSocket path
    std::chrono::milliseconds ping_interval_;
    std::shared_ptr<core::messaging_ws_client> client_;
 
    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