Method onHeaderReady

Libraries/Http/HttpWebSocket.cpp:766–803

    SC_TRY(connection.response.startResponse(101));
    SC_TRY(connection.response.addHeader("Upgrade", "websocket"));
    SC_TRY(connection.response.addHeader("Connection", "Upgrade"));
    SC_TRY(connection.response.addHeader("Sec-WebSocket-Accept", accept));

    transport.readableStream = &connection.getReadableTransportStream();
    transport.writableStream = &connection.getWritableTransportStream();
    transport.buffersPool    = &connection.buffersPool;

    SC_TRY(connection.response.sendHeaders(
        {[&connection](AsyncBufferView::ID) { connection.getReadableTransportStream().resumeReading(); }}));
    connection.markWebSocketUpgraded();
    return Result(true);
}

Result HttpWebSocketHandshake::rejectServerConnection(HttpResponse&                       response,
                                                      const HttpWebSocketHandshakeResult& result)
{
    const int statusCode = result.httpStatusCode();
    if (statusCode == 101)
        return Result::Error(HttpResultCategory, HttpError::WebSocketRejectAcceptedRequest);
    SC_TRY(response.startResponse(statusCode));
    if (statusCode == 426)
    {
        SC_TRY(response.addHeader("Sec-WebSocket-Version", "13"));
    }
    SC_TRY(response.addContentLength(0));
    SC_TRY(response.addHeader("Connection", "close"));
    SC_TRY(response.sendHeaders());
    return response.end();
}

Result HttpWebSocketClientHandshake::connect(HttpAsyncClient& newClient, AsyncEventLoop& loop, StringSpan url,
                                             StringSpan newClientKey, HttpWebSocketTransportView& newTransport,
                                             HttpWebSocketSha1Mode newSha1Mode)
{
    SC_TRY(HttpWebSocketHandshake::validateClientKey(newClientKey));
    client    = &newClient;
    transport = &newTransport;
    clientKey = newClientKey;
    sha1Mode  = newSha1Mode;
    transport->reset();