http_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 http_client;
}
 
namespace kcenon::network::internal::adapters {
 
class http_client_adapter : public interfaces::i_protocol_client {
public:
    explicit http_client_adapter(
        std::string_view client_id,
        std::chrono::milliseconds timeout = std::chrono::seconds(30));
 
    ~http_client_adapter() override;
 
    // Non-copyable, non-movable
    http_client_adapter(const http_client_adapter&) = delete;
    http_client_adapter& operator=(const http_client_adapter&) = delete;
    http_client_adapter(http_client_adapter&&) = delete;
    http_client_adapter& operator=(http_client_adapter&&) = delete;
 
    // =========================================================================
    // Path Configuration
    // =========================================================================
 
    auto set_path(std::string_view path) -> void;
 
    auto set_use_ssl(bool use_ssl) -> 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:
    [[nodiscard]] auto build_url() const -> std::string;
 
    auto notify_receive(const std::vector<uint8_t>& data) -> void;
 
    auto notify_error(std::error_code ec) -> void;
 
    std::string client_id_;
    std::chrono::milliseconds timeout_;
    std::shared_ptr<core::http_client> client_;
 
    // URL components
    std::string host_;
    uint16_t port_{0};
    std::string path_{"/"};
    bool use_ssl_{false};
 
    std::atomic<bool> is_running_{false};
 
    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