#pragma once
#include "Request.h"
#include "Response.h"
#include "compression/Compressor.h"
namespace panda { namespace protocol { namespace http {
constexpr const size_t SIZE_UNLIMITED = size_t(-1);
struct MessageParser {
    size_t max_headers_size = SIZE_UNLIMITED;
    size_t max_body_size    = SIZE_UNLIMITED;
    bool   uncompress_content = true;   // false have sense only for proxies
    virtual ~MessageParser();
protected:
    MessageSP       message;
    RequestSP       request;
    ResponseSP      response;
    State           state; // high-level state
    int             cs;    // ragel state
    bool            has_content_length;
    bool            proto_relative_uri;
    uint64_t        content_length;
    std::error_code error;
    MessageParser () {}
    MessageParser (const MessageParser&) = delete;
    MessageParser (MessageParser&&)      = default;
    inline void reset () {
        message            = nullptr;
        request            = nullptr;
        response           = nullptr;
        state              = State::headers;
        mark               = -1;
        marked             = false;
        headers_so_far     = 0;
        headers_finished   = false;
        has_content_length = false;
        proto_relative_uri = false;
        content_length     = 0;
        body_so_far        = 0;
        error.clear();
        if (compressor) {
            compressor->reset();
            compressor.reset();
        }
    }
    size_t _parse (const string& buffer);
    void set_error (const std::error_code& e) {
        error = e;
        state = State::error;
    }
    virtual bool on_headers    () = 0;
    virtual bool on_empty_body () = 0;
    compression::CompressorPtr compressor;
private:
    ptrdiff_t mark;
    bool      marked;
    string    acc;
    size_t    headers_so_far;
    bool      headers_finished;
    size_t    body_so_far;
    size_t    chunk_length;
    size_t    chunk_so_far;
    std::uint8_t compr = 0;
    size_t machine_exec (const string& buffer, size_t off);
};
}}}