main.cpp

#include <iostream>
#include <crow.h>

void onOpen(crow::websocket::connection &conn) {
    std::cout << "onOpen" << std::endl;
}

void onClose(crow::websocket::connection &conn, const std::string &reason, uint16_t code) {
    std::cout << "onClose: " << reason << std::endl;
}

void onMessage(crow::websocket::connection &conn, const std::string &data, bool is_binary) {
    std::cout << "onMessage: " << data << std::endl;
    for (int i = 0; i < 2; i++) {
        conn.send_text(std::format("response {}", i));
    }
}

int main() {
    auto app = crow::Crow();

    CROW_WEBSOCKET_ROUTE(app, "/")
            .onopen(onOpen)
            .onclose(onClose)
            .onmessage(onMessage);

    const std::future<void> serverShutdownFeature = app.bindaddr("127.0.0.1").port(1337).run_async();

    app.wait_for_server_start();

    std::cout << "Server started on port: " << app.port() << std::endl;

    while (true) {
        if (getchar() == 'q') {
            break;
        }
    }

    app.stop();
    serverShutdownFeature.wait();

    return 0;
}