websocket.cpp

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.
 
#include "kcenon/network/detail/protocol/websocket.h"
#include "internal/unified/adapters/ws_connection_adapter.h"
#include "internal/unified/adapters/ws_listener_adapter.h"
 
#include <atomic>
#include <chrono>
#include <sstream>
 
namespace kcenon::network::protocol::websocket {
 
namespace {
 
auto generate_unique_id(std::string_view prefix) -> std::string
{
    static std::atomic<uint64_t> counter{0};
    auto now = std::chrono::steady_clock::now().time_since_epoch().count();
    auto count = counter.fetch_add(1);
 
    std::ostringstream oss;
    oss << prefix << "-" << now << "-" << count;
    return oss.str();
}
 
}  // namespace
 
auto create_connection(std::string_view id) -> std::unique_ptr<unified::i_connection>
{
    std::string connection_id = id.empty() ? generate_unique_id("ws-conn") : std::string(id);
    return std::make_unique<unified::adapters::ws_connection_adapter>(connection_id);
}
 
auto connect(std::string_view url, std::string_view id)
    -> std::unique_ptr<unified::i_connection>
{
    auto conn = create_connection(id);
    (void)conn->connect(url);
    return conn;
}
 
auto connect(const unified::endpoint_info& endpoint,
             std::string_view path,
             std::string_view id)
    -> std::unique_ptr<unified::i_connection>
{
    std::string connection_id = id.empty() ? generate_unique_id("ws-conn") : std::string(id);
    auto adapter = std::make_unique<unified::adapters::ws_connection_adapter>(connection_id);
    adapter->set_path(path);
    (void)adapter->connect(endpoint);
    return adapter;
}
 
auto create_listener(std::string_view id) -> std::unique_ptr<unified::i_listener>
{
    std::string listener_id = id.empty() ? generate_unique_id("ws-listener") : std::string(id);
    return std::make_unique<unified::adapters::ws_listener_adapter>(listener_id);
}
 
auto listen(const unified::endpoint_info& bind_address,
            std::string_view path,
            std::string_view id)
    -> std::unique_ptr<unified::i_listener>
{
    std::string listener_id = id.empty() ? generate_unique_id("ws-listener") : std::string(id);
    auto adapter = std::make_unique<unified::adapters::ws_listener_adapter>(listener_id);
    adapter->set_path(path);
    (void)adapter->start(bind_address);
    return adapter;
}
 
auto listen(uint16_t port, std::string_view path, std::string_view id)
    -> std::unique_ptr<unified::i_listener>
{
    return listen(unified::endpoint_info{"0.0.0.0", port}, path, id);
}
 
}  // namespace kcenon::network::protocol::websocket