Method resolveRpc

src/fl/net/http/stream_transport.cpp.hpp:129–156

}

bool HttpStreamTransport::resolveRpc(const fl::json& msg, const fl::string& idKey) {
    auto it = mPendingCalls.find(idKey);
    if (it == mPendingCalls.end()) {
        return false;
    }
    PendingCall* pending = &it->second;

    // Check for error
    if (msg.contains("error")) {
        fl::task::Error err(msg["error"]["message"].as_string().value());
        pending->promise.complete_with_error(err);
        mPendingCalls.erase(idKey);
        return true;
    }

    // Check for ACK (ASYNC mode sends acknowledged first)
    if (msg.contains("result") && msg["result"].contains("acknowledged")) {
        if (msg["result"]["acknowledged"].as_bool() == true) {
            pending->ackReceived = true;
            return true;  // Stay pending, wait for final result
        }
    }

    // Final result
    pending->promise.complete_with_value(msg);
    mPendingCalls.erase(idKey);
    return true;
}

bool HttpStreamTransport::resolveRpcStream(const fl::json& msg, const fl::string& idKey) {
    auto it = mPendingStreams.find(idKey);