Function FL_TEST_FILE

tests/fl/remote/loopback.cpp:21–132

#include "fl/stl/mutex.h"

FL_TEST_FILE(FL_FILEPATH) {

using namespace fl;
using namespace fl::net::http;

FL_TEST_CASE("Loopback: connect and sync RPC round-trip") {
    // Use port 0 to let the OS assign an available ephemeral port.
    // This eliminates port collisions entirely.
    auto server_transport = fl::make_shared<HttpStreamServer>(0);
    FL_REQUIRE(server_transport->connect());
    uint16_t PORT = server_transport->port();
    FL_REQUIRE(PORT != 0);

    fl::Remote server_remote(
        [&server_transport]() { return server_transport->readRequest(); },
        [&server_transport](const fl::json& r) { server_transport->writeResponse(r); }
    );
    server_remote.bind("add", [](int a, int b) -> int { return a + b; });

    // Background thread: handles acceptClients + server transport update + RPC.
    // This is the standard net-thread pattern — the server side runs entirely
    // in a dedicated thread, and results (the RPC response) flow back through
    // the TCP connection to the client on the main thread.
    fl::atomic<bool> server_running{true};
    fl::thread server_thread([&]() {
        while (server_running.load()) {
            uint32_t now = fl::millis();
            server_transport->acceptClients();
            server_transport->update(now);
            server_remote.update(now);
            fl::this_thread::sleep_for(fl::chrono::milliseconds(1));  // ok sleep for - inside thread
        }
    });

    // Client — connect() blocks until the server accepts, but the server
    // thread is already running acceptClients() so this won't deadlock.
    // Use 127.0.0.1 directly instead of "localhost" to avoid DNS resolution
    // overhead and IPv6 ambiguity on Windows (server binds to INADDR_LOOPBACK).
    auto client_transport = fl::make_shared<HttpStreamClient>("127.0.0.1", PORT);

    {
        bool connected = false;
        uint32_t connect_start = fl::millis();
        while (fl::millis() - connect_start < 10000) {
            if (client_transport->connect()) {
                connected = true;
                break;
            }
            fl::delay(10);
        }
        FL_REQUIRE(connected);
    }

    FL_REQUIRE(client_transport->isConnected());

    // Send request
    json params = json::array();
    params.push_back(json(5));