Function FL_TEST_FILE

tests/fl/stl/asio/http/http_promise.cpp:14–315

#include "fl/stl/asio/http/test_utils/mock_http_client.h"

FL_TEST_FILE(FL_FILEPATH) {

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

//=============================================================================
// TEST CASE: SYNC rpc() resolves with result
//=============================================================================

FL_TEST_CASE("Promise - SYNC rpc() resolves") {
    MockHttpServer server(48001);
    server.connect();

    Remote remoteServer(
        [&server]() { return server.readRequest(); },
        [&server](const json& r) { server.writeResponse(r); }
    );

    remoteServer.bind("add", [](int a, int b) -> int {
        return a + b;
    });

    MockHttpClient client(server);
    client.connect();

    // Use rpc() API
    json params = json::array();
    params.push_back(json(5));
    params.push_back(json(7));
    fl::task::Promise<json> p = client.rpc("add", params);

    FL_CHECK(p.valid());
    FL_CHECK(!p.is_completed());

    // Pump: server reads from client, processes, sends response back
    server.update(0);
    remoteServer.update(0);

    // Client update drains chunks and resolves promise
    client.update(0);

    FL_REQUIRE(p.is_resolved());
    const json& response = p.value();
    FL_CHECK(response.contains("result"));
    FL_CHECK_EQ(response["result"].as_int().value(), 12);
}

//=============================================================================
// TEST CASE: ASYNC rpc() skips ACK, resolves with final result
//=============================================================================

FL_TEST_CASE("Promise - ASYNC rpc() skips ACK") {
    MockHttpServer server(48002);
    server.connect();
    server.update(0);

    Remote remoteServer(
        [&server]() { return server.readRequest(); },