tcp_server_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_server.h"
 
#include <memory>
#include <mutex>
#include <string>
#include <unordered_map>
 
namespace kcenon::network::core {
    class messaging_server;
}
 
namespace kcenon::network::session {
    class messaging_session;
}
 
namespace kcenon::network::internal::adapters {
 
class tcp_server_adapter : public interfaces::i_protocol_server {
public:
    explicit tcp_server_adapter(std::string_view server_id);
 
    ~tcp_server_adapter() override;
 
    // Non-copyable, non-movable
    tcp_server_adapter(const tcp_server_adapter&) = delete;
    tcp_server_adapter& operator=(const tcp_server_adapter&) = delete;
    tcp_server_adapter(tcp_server_adapter&&) = delete;
    tcp_server_adapter& operator=(tcp_server_adapter&&) = delete;
 
    // =========================================================================
    // i_network_component interface implementation
    // =========================================================================
 
    [[nodiscard]] auto is_running() const -> bool override;
    auto wait_for_stop() -> void override;
 
    // =========================================================================
    // i_protocol_server interface implementation
    // =========================================================================
 
    [[nodiscard]] auto start(uint16_t port) -> VoidResult override;
    [[nodiscard]] auto stop() -> VoidResult override;
    [[nodiscard]] auto connection_count() const -> size_t override;
 
    auto set_connection_callback(connection_callback_t callback) -> void override;
    auto set_disconnection_callback(disconnection_callback_t callback) -> void override;
    auto set_receive_callback(receive_callback_t callback) -> void override;
    auto set_error_callback(error_callback_t callback) -> void override;
 
private:
    auto setup_internal_callbacks() -> void;
 
    auto track_session(std::shared_ptr<session::messaging_session> session)
        -> std::shared_ptr<interfaces::i_session>;
 
    std::string server_id_;
    std::shared_ptr<core::messaging_server> server_;
 
    mutable std::mutex callbacks_mutex_;
    connection_callback_t connection_callback_;
    disconnection_callback_t disconnection_callback_;
    receive_callback_t receive_callback_;
    error_callback_t error_callback_;
 
    // Session tracking for lookup by ID
    mutable std::mutex sessions_mutex_;
    std::unordered_map<std::string, std::shared_ptr<session::messaging_session>> sessions_;
};
 
} // namespace kcenon::network::internal::adapters