types.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 <chrono>
#include <cstdint>
#include <functional>
#include <span>
#include <string>
#include <string_view>
#include <system_error>
#include <vector>
 
namespace kcenon::network::unified {
 
struct endpoint_info {
    std::string host;    
    uint16_t port = 0;   
 
    endpoint_info() = default;
 
    endpoint_info(const std::string& h, uint16_t p) : host(h), port(p) {}
 
    endpoint_info(const char* h, uint16_t p) : host(h), port(p) {}
 
    explicit endpoint_info(const std::string& url) : host(url), port(0) {}
 
    explicit endpoint_info(const char* url) : host(url), port(0) {}
 
    [[nodiscard]] auto is_valid() const noexcept -> bool { return !host.empty(); }
 
    [[nodiscard]] auto to_string() const -> std::string {
        if (port == 0) {
            return host;
        }
        return host + ":" + std::to_string(port);
    }
 
    [[nodiscard]] auto operator==(const endpoint_info& other) const noexcept -> bool {
        return host == other.host && port == other.port;
    }
 
    [[nodiscard]] auto operator!=(const endpoint_info& other) const noexcept -> bool {
        return !(*this == other);
    }
};
 
struct connection_callbacks {
    std::function<void()> on_connected;
 
    std::function<void(std::span<const std::byte>)> on_data;
 
    std::function<void()> on_disconnected;
 
    std::function<void(std::error_code)> on_error;
};
 
struct listener_callbacks {
    std::function<void(std::string_view)> on_accept;
 
    std::function<void(std::string_view, std::span<const std::byte>)> on_data;
 
    std::function<void(std::string_view)> on_disconnect;
 
    std::function<void(std::string_view, std::error_code)> on_error;
};
 
struct connection_options {
    std::chrono::milliseconds connect_timeout{0};
 
    std::chrono::milliseconds read_timeout{0};
 
    std::chrono::milliseconds write_timeout{0};
 
    bool keep_alive = false;
 
    bool no_delay = false;
};
 
}  // namespace kcenon::network::unified