unified_server_example.cpp File Reference

Example showing the new unified server (listener) interface usage. More...

#include <kcenon/network/protocol/protocol.h>
#include <kcenon/network/unified/unified.h>
#include <cstddef>
#include <iostream>
#include <map>
#include <memory>
#include <span>
#include <string>

Include dependency graph for unified_server_example.cpp:

Go to the source code of this file.

Classes
class	ConnectionManager
	Advanced example: Managing accepted connections. More...

Functions
void	setup_server (std::unique_ptr< unified::i_listener > listener)
	Protocol-agnostic server setup.
void	tcp_server_example ()
	TCP server example using unified API.
void	udp_server_example ()
	UDP server example using unified API.
void	websocket_server_example ()
	WebSocket server example using unified API.
std::unique_ptr< unified::i_listener >	create_listener (const std::string &protocol, uint16_t port)
	Example of protocol selection at runtime.
int	main ()

Detailed Description

Example showing the new unified server (listener) interface usage.

This file demonstrates the NEW, RECOMMENDED way of creating network servers using the unified interface API.

Benefits:

• Single interface (i_listener) for all protocols
• Protocol selection via factory functions
• Unified callback structure
• Accepted connections use same i_connection interface

Definition in file unified_server_example.cpp.

Function Documentation

create_listener()

std::unique_ptr< unified::i_listener > create_listener	(	const std::string &	protocol,
		uint16_t	port )

Example of protocol selection at runtime.

Definition at line 160 of file unified_server_example.cpp.

                   {
 
    if (protocol == "tcp") {
        return protocol::tcp::listen(port);
    } else if (protocol == "udp") {
        return protocol::udp::listen(port);
    } else if (protocol == "websocket") {
        return protocol::websocket::listen(port, "/");
    }
 
    throw std::invalid_argument("Unknown protocol: " + protocol);
}

References kcenon::network::protocol::tcp::listen(), kcenon::network::protocol::udp::listen(), and kcenon::network::protocol::websocket::listen().

Here is the call graph for this function:

main()

int main

(

)

Definition at line 175 of file unified_server_example.cpp.

           {
    std::cout << "=== Unified Server Example ===\n";
    std::cout << "This file demonstrates the NEW unified API for servers.\n\n";
 
    std::cout << "Benefits of unified server API:\n";
    std::cout << "  1. Single i_listener interface for all protocols\n";
    std::cout << "  2. Accepted connections are i_connection (same as clients)\n";
    std::cout << "  3. Protocol selection via factory functions\n";
    std::cout << "  4. Cleaner callback setup with aggregate initialization\n";
    std::cout << "  5. Easy connection management with ownership\n";
 
    std::cout << "\nCode patterns shown:\n";
    std::cout << "  - protocol::tcp::listen(port)\n";
    std::cout << "  - protocol::udp::listen(port)\n";
    std::cout << "  - protocol::websocket::listen(port, path)\n";
    std::cout << "  - listener->set_callbacks({...})\n";
    std::cout << "  - listener->set_accept_callback(callback)\n";
    std::cout << "  - listener->start(port)\n";
    std::cout << "  - listener->broadcast(data)\n";
 
    return 0;
}

setup_server()

void setup_server

(

std::unique_ptr< unified::i_listener >

listener

)

Protocol-agnostic server setup.

This function works with ANY protocol - TCP, UDP, WebSocket, QUIC. The unified interface enables truly protocol-agnostic server code.

Definition at line 40 of file unified_server_example.cpp.

                                                             {
    // NEW: Set all callbacks at once using aggregate initialization
    listener->set_callbacks({
        .on_accept = [](std::string_view conn_id) {
            std::cout << "[Server] New connection: " << conn_id << "\n";
        },
        .on_data = [](std::string_view conn_id, std::span<const std::byte> data) {
            std::cout << "[Server] Received " << data.size()
                      << " bytes from " << conn_id << "\n";
 
            // Process data...
        },
        .on_disconnect = [](std::string_view conn_id) {
            std::cout << "[Server] Disconnected: " << conn_id << "\n";
        },
        .on_error = [](std::string_view conn_id, std::error_code ec) {
            std::cerr << "[Server] Error on " << conn_id
                      << ": " << ec.message() << "\n";
        }
    });
 
    // NEW: Start listening
    if (auto result = listener->start(8080); !result) {
        std::cerr << "[Server] Failed to start\n";
        return;
    }
 
    std::cout << "[Server] Listening on port 8080\n";
}

Referenced by tcp_server_example(), udp_server_example(), and websocket_server_example().

Here is the caller graph for this function:

tcp_server_example()

void tcp_server_example

(

)

TCP server example using unified API.

Definition at line 73 of file unified_server_example.cpp.

                          {
    std::cout << "\n=== TCP Server (Unified API) ===\n";
 
    // NEW: Create listener via protocol factory
    auto listener = protocol::tcp::listen(8080);
    setup_server(std::move(listener));
}

References kcenon::network::protocol::tcp::listen(), and setup_server().

Here is the call graph for this function:

udp_server_example()

void udp_server_example

(

)

UDP server example using unified API.

Definition at line 84 of file unified_server_example.cpp.

                          {
    std::cout << "\n=== UDP Server (Unified API) ===\n";
 
    // Same interface, different protocol factory
    auto listener = protocol::udp::listen(5555);
    setup_server(std::move(listener));
}

References kcenon::network::protocol::udp::listen(), and setup_server().

Here is the call graph for this function:

websocket_server_example()

void websocket_server_example

(

)

WebSocket server example using unified API.

Definition at line 95 of file unified_server_example.cpp.

                                {
    std::cout << "\n=== WebSocket Server (Unified API) ===\n";
 
    // WebSocket listener
    auto listener = protocol::websocket::listen(8080, "/ws");
    setup_server(std::move(listener));
}

References kcenon::network::protocol::websocket::listen(), and setup_server().

Here is the call graph for this function: