Method parse

Libraries/Http/HttpWebSocket.cpp:653–764

}

Result HttpWebSocketFrameReader::parse(Span<char> data, size_t& consumedBytes)
{
    consumedBytes = 0;
    while (consumedBytes < data.sizeInBytes())
    {
        const uint8_t current = static_cast<uint8_t>(data[consumedBytes]);
        switch (state)
        {
        case State::HeaderByte0:
            headerByte0 = current;
            consumedBytes++;
            state = State::HeaderByte1;
            break;

        case State::HeaderByte1: {
            const uint8_t opcodeValue = headerByte0 & 0x0F;
            SC_TRY_MSG((headerByte0 & 0x70) == 0, "HttpWebSocketFrameReader RSV bits are not supported");
            currentFrame        = {};
            currentFrame.fin    = (headerByte0 & 0x80) != 0;
            currentFrame.opcode = static_cast<HttpWebSocketOpcode>(opcodeValue);
            SC_TRY_MSG(scHttpWebSocketIsSupportedOpcode(currentFrame.opcode),
                       "HttpWebSocketFrameReader unsupported opcode");

            currentFrame.masked              = (current & 0x80) != 0;
            const uint8_t payloadLengthField = current & 0x7F;

            extendedLengthAccumulator = 0;
            extendedLengthBytesRead   = 0;
            maskBytesRead             = 0;

            consumedBytes++;

            if (payloadLengthField < 126)
            {
                currentFrame.payloadLength = payloadLengthField;
                if (currentFrame.masked)
                {
                    state = State::MaskKey;
                }
                else
                {
                    SC_TRY(onHeaderReady());
                }
            }
            else
            {
                extendedLengthBytesExpected = payloadLengthField == 126 ? 2 : 8;
                state                       = State::ExtendedLength;
            }
            break;
        }

        case State::ExtendedLength:
            SC_TRY_MSG(not(extendedLengthBytesExpected == 8 and extendedLengthBytesRead == 0 and (current & 0x80) != 0),
                       "HttpWebSocketFrameReader invalid 64-bit payload length");
            extendedLengthAccumulator = (extendedLengthAccumulator << 8) | current;
            extendedLengthBytesRead++;
            consumedBytes++;