Method writerRoundtrip

Tests/Libraries/Http/HttpWebSocketFrameTest.cpp:577–621

}

void SC::HttpWebSocketFrameTest::writerRoundtrip()
{
    HttpWebSocketFrameWriter writer;
    writer.reset(HttpWebSocketEndpointRole::Client);

    HttpWebSocketFrameHeaderView header;
    header.fin           = true;
    header.opcode        = HttpWebSocketOpcode::Binary;
    header.masked        = true;
    header.payloadLength = 6;
    header.maskKey[0]    = 0xAA;
    header.maskKey[1]    = 0xBB;
    header.maskKey[2]    = 0xCC;
    header.maskKey[3]    = 0xDD;

    char payload[]   = {char(0x00), char(0x11), char(0x22), char(0x33), char(0x44), char(0x55)};
    char encoded[32] = {0};

    Span<const char> encodedHeader;
    SC_TEST_EXPECT(writer.beginFrame(header, {encoded, sizeof(encoded)}, encodedHeader));

    Span<char> payloadOut = {encoded + encodedHeader.sizeInBytes(), sizeof(payload)};
    for (size_t idx = 0; idx < sizeof(payload); ++idx)
    {
        payloadOut[idx] = payload[idx];
    }

    SC_TEST_EXPECT(writer.writePayload({payloadOut.data(), 2}));
    SC_TEST_EXPECT(writer.writePayload({payloadOut.data() + 2, 4}));
    SC_TEST_EXPECT(writer.finishFrame());

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

    size_t consumed = 0;
    SC_TEST_EXPECT(reader.parse({encoded, encodedHeader.sizeInBytes() + sizeof(payload)}, consumed));
    SC_TEST_EXPECT(consumed == encodedHeader.sizeInBytes() + sizeof(payload));
    SC_TEST_EXPECT(collector.numHeaders == 1);
    SC_TEST_EXPECT(collector.headers[0].opcode == HttpWebSocketOpcode::Binary);
    SC_TEST_EXPECT(collector.headers[0].masked);
    SC_TEST_EXPECT(spansEqual(collector.payload.toSpanConst(), {payload, sizeof(payload)}));
}

void SC::runHttpWebSocketFrameTest(SC::TestReport& report) { HttpWebSocketFrameTest test(report); }