Method get

Tests/Libraries/Http/HttpTestClient.cpp:8–68

#include <stdio.h> // snprintf

SC::Result SC::HttpTestClient::get(AsyncEventLoop& loop, StringSpan url, bool keepOpen)
{
    eventLoop          = &loop;
    keepConnectionOpen = keepOpen;

    // Parse URL
    HttpURLParser urlParser;
    SC_TRY(urlParser.parse(url));
    if (urlParser.protocol != "http")
        return Result::Error(HttpResultCategory, HttpError::UnsupportedProtocol);

    // Reset state for new request
    parser            = {};
    parser.type       = HttpParser::Type::Response;
    receivedBytes     = 0;
    parsedBytes       = 0;
    contentLen        = 0;
    headersReceived   = false;
    responseHasNoBody = false;

    {
        GrowableBuffer<decltype(content)> gb = {content};

        HttpStringAppend& sb = static_cast<HttpStringAppend&>(static_cast<IGrowableBuffer&>(gb));
        sb.clear();
        SC_TRY(sb.append("GET "));
        SC_TRY(sb.append(urlParser.path));
        SC_TRY(sb.append(" HTTP/1.1\r\n"));
        SC_TRY(sb.append("User-agent: SC\r\n"));
        SC_TRY(sb.append("Host: 127.0.0.1\r\n"));
        if (keepConnectionOpen)
        {
            SC_TRY(sb.append("Connection: keep-alive\r\n"));
        }
        SC_TRY(sb.append("\r\n"));
        headerBytes = content.size();
    }

    // If we don't have an active connection or we're not keeping connections open, create a new one
    if (not hasActiveConnection or not keepConnectionOpen)
    {
        uint16_t port;
        // TODO: Make DNS Resolution asynchronous
        char       buffer[256];
        Span<char> ipAddress = {buffer};
        SC_TRY(SocketDNS::resolveDNS(urlParser.hostname, ipAddress))
        port = urlParser.port;
        SocketIPAddress localHost;
        SC_TRY(localHost.fromAddressPort({ipAddress, true, StringEncoding::Ascii}, port));
        SC_TRY(eventLoop->createAsyncTCPSocket(localHost.getAddressFamily(), clientSocket));
        hasActiveConnection = true;

        connectAsync.callback.bind<HttpTestClient, &HttpTestClient::startSendingHeaders>(*this);
        return connectAsync.start(*eventLoop, clientSocket, localHost);
    }
    else
    {
        // Reuse existing connection - go directly to sending headers