Method closeEcho

Tests/Libraries/Http/HttpWebSocketLifecycleTest.cpp:301–335

}

void SC::HttpWebSocketLifecycleTest::closeEcho()
{
    const uint8_t maskKey[4] = {9, 8, 7, 6};

    HttpWebSocketEndpoint client;
    client.reset(HttpWebSocketEndpointRole::Client);
    char             closeStorage[64] = {0};
    Span<const char> closeFrame;
    SC_TEST_EXPECT(client.sendClose(1000, "bye"_a8.toCharSpan(), maskKey, closeStorage, closeFrame));

    HttpWebSocketEndpoint server;
    server.reset(HttpWebSocketEndpointRole::Server);

    size_t consumed = 0;
    SC_TEST_EXPECT(server.receive({closeStorage, closeFrame.sizeInBytes()}, consumed));
    SC_TEST_EXPECT(server.hasCloseBeenReceived());
    SC_TEST_EXPECT(server.hasCloseBeenSent());

    Span<const char> echoFrame;
    SC_TEST_EXPECT(server.getPendingControlFrame(echoFrame));

    FrameCollector           collector;
    HttpWebSocketFrameReader reader;
    reader.reset(HttpWebSocketEndpointRole::Client);
    reader.onFrameHeader.bind<FrameCollector, &FrameCollector::onHeader>(collector);
    reader.onFramePayload.bind<FrameCollector, &FrameCollector::onPayload>(collector);

    size_t echoConsumed = 0;
    SC_TEST_EXPECT(reader.parse({const_cast<char*>(echoFrame.data()), echoFrame.sizeInBytes()}, echoConsumed));
    SC_TEST_EXPECT(collector.header.opcode == HttpWebSocketOpcode::Close);
    SC_TEST_EXPECT(collector.payloadSize == 5);
    SC_TEST_EXPECT(static_cast<uint8_t>(collector.payload[0]) == 0x03);
    SC_TEST_EXPECT(static_cast<uint8_t>(collector.payload[1]) == 0xE8);
    SC_TEST_EXPECT(bytesEqual({collector.payload + 2, collector.payloadSize - 2}, "bye"));
}

void SC::HttpWebSocketLifecycleTest::pendingControlBackpressure()
{