tcp_facade.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 <chrono>
#include <cstdint>
#include <memory>
#include <optional>
#include <string>
 
#include "kcenon/network/interfaces/i_protocol_client.h"
#include "kcenon/network/interfaces/i_protocol_server.h"
#include "kcenon/network/types/result.h"
 
// Forward declarations
namespace kcenon::network::core
{
class connection_pool;
} // namespace kcenon::network::core
 
namespace kcenon::network::facade
{
 
class tcp_facade
{
public:
    struct client_config
    {
        std::string host;
 
        uint16_t port = 0;
 
        std::string client_id;
 
        std::chrono::milliseconds timeout = std::chrono::seconds(30);
 
        bool use_ssl = false;
 
        std::optional<std::string> ca_cert_path;
 
        bool verify_certificate = true;
    };
 
    struct server_config
    {
        uint16_t port = 0;
 
        std::string server_id;
 
        bool use_ssl = false;
 
        std::optional<std::string> cert_path;
 
        std::optional<std::string> key_path;
 
        std::optional<std::string> tls_version;
    };
 
    [[nodiscard]] auto create_client(const client_config& config) const
        -> Result<std::shared_ptr<interfaces::i_protocol_client>>;
 
    [[nodiscard]] auto create_server(const server_config& config) const
        -> Result<std::shared_ptr<interfaces::i_protocol_server>>;
 
    struct pool_config
    {
        std::string host;
 
        uint16_t port = 0;
 
        size_t pool_size = 10;
 
        std::chrono::seconds acquire_timeout = std::chrono::seconds(30);
    };
 
    [[nodiscard]] auto create_connection_pool(const pool_config& config) const
        -> Result<std::shared_ptr<core::connection_pool>>;
 
private:
    [[nodiscard]] static auto generate_client_id() -> std::string;
 
    [[nodiscard]] static auto generate_server_id() -> std::string;
 
    static auto validate_client_config(const client_config& config) -> VoidResult;
 
    static auto validate_server_config(const server_config& config) -> VoidResult;
};
 
} // namespace kcenon::network::facade