WebSocketReader.h

#pragma once
#include "WebSocketCommon.h"
#include "ByteBuffer.h"
#include "WebSocketFrame.h"
namespace NPL
{
    namespace WebSocket
    {
        class WebSocketReader
        {
        public:
            WebSocketReader();
            ~WebSocketReader();
            bool parse(ByteBuffer& buffer);
            bool parseFrame(ByteBuffer& buffer);

            // append buffer to frame
            bool append(ByteBuffer& buffer);

            bool isRsv1InUse() { return (flagsInUse & 0x40) != 0; };
            bool isRsv2InUse() { return (flagsInUse & 0x20) != 0; };
            bool isRsv3InUse() { return (flagsInUse & 0x10) != 0; };

            static ByteBuffer load(Buffer_Type* buffer, int bytes_transferred);


            WebSocketFrame* getFrame();
            ComingMsgState getState() {
                return frameState;
            };
            void reset();
        private:
            void assertSanePayloadLength(int length);
        private:
            ByteBuffer payload;
            int payloadLength;
            int cursor;
            State state;

            byte flagsInUse;
            WebSocketFrame* frame;

            ComingMsgState frameState;
        };
    }
}