Function FL_TEST_FILE

tests/fl/stl/asio/http/native_client.cpp:13–426

#include "fl/system/delay.h"

FL_TEST_FILE(FL_FILEPATH) {

using namespace fl;

// Use port 0 so the OS assigns a free port — avoids hardcoded port conflicts
// with Windows Hyper-V/NAT reserved ranges and TIME_WAIT races.
static const uint16_t kAnyPort = 0;

// RAII wrapper for NativeHttpServer. Uses port 0 (OS-assigned).
// NativeHttpServer has no move/copy, so we must heap-allocate.
struct ServerGuard {
    fl::unique_ptr<NativeHttpServer> ptr;
    uint16_t port = 0;
    ServerGuard() = default;
    ServerGuard(ServerGuard&& o) : ptr(fl::move(o.ptr)), port(o.port) { o.port = 0; }
    ServerGuard& operator=(ServerGuard&& o) { ptr = fl::move(o.ptr); port = o.port; o.port = 0; return *this; }
    ~ServerGuard() { if (ptr) { ptr->stop(); } }
    NativeHttpServer* operator->() { return ptr.get(); }
    NativeHttpServer& operator*() { return *ptr; }
    explicit operator bool() const { return ptr != nullptr; }
};

static ServerGuard makeServer(const ConnectionConfig& config = ConnectionConfig()) {
    ServerGuard g;
    g.ptr = fl::make_unique<NativeHttpServer>(kAnyPort, config);
    if (g.ptr->start()) {
        g.port = g.ptr->port();
        return g;
    }
    g.ptr.reset();
    return g;
}

// Server thread: runs accept + update in background, posts results via atomics/mutex.
// This is the standard net-thread-to-main pattern: a dedicated networking thread
// handles blocking/polling work and the main thread reads results.
struct NetThread {
    NativeHttpServer& server;
    fl::atomic<bool> running{true};
    fl::mutex mtx;
    // Accumulated recv data per client (simplified: single client)
    fl::vector<uint8_t> recvBuf;
    fl::atomic<int> recvReady{0};
    fl::thread thread;

    explicit NetThread(NativeHttpServer& s) : server(s) {
        thread = fl::thread([this]() { run(); });
    }

    ~NetThread() {
        running.store(false);
        if (thread.joinable()) thread.join();
    }

    void run() {
        while (running.load()) {
            server.acceptClients();
            fl::this_thread::sleep_for(fl::chrono::milliseconds(1));  // ok sleep for