Method ReadResponse

src/bitcoin-cli.cpp:937–1119

}

HTTPResponse HTTPClient::ReadResponse()
{
    HTTPResponse response;
    std::string buffer;
    const auto deadline{std::chrono::steady_clock::now() + m_timeout};

    // Read data until we have complete headers
    size_t headers_end = 0;

    while (headers_end == 0) {
        if (auto result{Recv(deadline)}) {
            buffer.append(*result);
        } else {
            std::this_thread::yield();
            continue;
        }

        // Check for header terminator
        size_t pos = buffer.find("\r\n\r\n");
        if (pos != std::string::npos) {
            headers_end = pos + 4;
        }
    }

    // Parse http status
    util::LineReader reader(std::string_view{buffer.data(), headers_end}, headers_end);
    auto status_line = reader.ReadLine();
    if (!status_line) {
        throw HTTPError{"Failed to read status line"};
    }

    const std::string_view status_str = *status_line;
    // Minimum status line is "HTTP/X.Y NNN" (e.g. "HTTP/1.1 200"), 12 characters.
    if (status_str.size() < 12 || !status_str.starts_with("HTTP/")) {
        throw HTTPError{"Invalid status line"};
    }

    size_t space1 = status_str.find(' ');
    if (space1 == std::string::npos || space1 + 4 > status_str.size()) {
        throw HTTPError{"Invalid status line format"};
    }

    const std::string_view status_code_str = status_str.substr(space1 + 1, 3);
    auto status_code = ToIntegral<int>(status_code_str);
    if (!status_code) {
        throw HTTPError{"Invalid status code"};
    }
    response.status = *status_code;

    HTTPResponseHeaders headers;
    headers.Read(reader);

    // Determine body length
    size_t content_length = 0;
    bool chunked = false;

    // RFC 9112 §6.3 says responses with both Transfer-Encoding and Content-Length
    // must be rejected. We are more lenient: Transfer-Encoding takes precedence