aboutsummaryrefslogtreecommitdiffstats
path: root/include/parser.h
diff options
context:
space:
mode:
authoripknHama <ipknhama@gmail.com>2016-09-21 23:11:06 +0900
committeripknHama <ipknhama@gmail.com>2016-09-21 23:11:06 +0900
commit3081e4e1a82a4efd8feff68850c4cc04af230cd7 (patch)
tree3ad16ef2e940abd2d47c4ac3ca224365387b7f37 /include/parser.h
parent8b04940d2f28290451db439ad29155a0b8771ba3 (diff)
downloadcrow-3081e4e1a82a4efd8feff68850c4cc04af230cd7.tar.gz
crow-3081e4e1a82a4efd8feff68850c4cc04af230cd7.zip
Cleanup include folder into crow subfolder
- only crow.h is exposed now
Diffstat (limited to 'include/parser.h')
-rw-r--r--include/parser.h168
1 files changed, 0 insertions, 168 deletions
diff --git a/include/parser.h b/include/parser.h
deleted file mode 100644
index b621850..0000000
--- a/include/parser.h
+++ /dev/null
@@ -1,168 +0,0 @@
-#pragma once
-
-#include <string>
-#include <unordered_map>
-#include <boost/algorithm/string.hpp>
-#include <boost/tokenizer.hpp>
-#include <algorithm>
-
-#include "http_parser_merged.h"
-#include "http_request.h"
-
-namespace crow
-{
- template <typename Handler>
- struct HTTPParser : public http_parser
- {
- static int on_message_begin(http_parser* self_)
- {
- HTTPParser* self = static_cast<HTTPParser*>(self_);
- self->clear();
- return 0;
- }
- static int on_url(http_parser* self_, const char* at, size_t length)
- {
- HTTPParser* self = static_cast<HTTPParser*>(self_);
- self->raw_url.insert(self->raw_url.end(), at, at+length);
- return 0;
- }
- static int on_header_field(http_parser* self_, const char* at, size_t length)
- {
- HTTPParser* self = static_cast<HTTPParser*>(self_);
- switch (self->header_building_state)
- {
- case 0:
- if (!self->header_value.empty())
- {
- self->headers.emplace(std::move(self->header_field), std::move(self->header_value));
- }
- self->header_field.assign(at, at+length);
- self->header_building_state = 1;
- break;
- case 1:
- self->header_field.insert(self->header_field.end(), at, at+length);
- break;
- }
- return 0;
- }
- static int on_header_value(http_parser* self_, const char* at, size_t length)
- {
- HTTPParser* self = static_cast<HTTPParser*>(self_);
- switch (self->header_building_state)
- {
- case 0:
- self->header_value.insert(self->header_value.end(), at, at+length);
- break;
- case 1:
- self->header_building_state = 0;
- self->header_value.assign(at, at+length);
- break;
- }
- return 0;
- }
- static int on_headers_complete(http_parser* self_)
- {
- HTTPParser* self = static_cast<HTTPParser*>(self_);
- if (!self->header_field.empty())
- {
- self->headers.emplace(std::move(self->header_field), std::move(self->header_value));
- }
- self->process_header();
- return 0;
- }
- static int on_body(http_parser* self_, const char* at, size_t length)
- {
- HTTPParser* self = static_cast<HTTPParser*>(self_);
- self->body.insert(self->body.end(), at, at+length);
- return 0;
- }
- static int on_message_complete(http_parser* self_)
- {
- HTTPParser* self = static_cast<HTTPParser*>(self_);
-
- // url params
- self->url = self->raw_url.substr(0, self->raw_url.find("?"));
- self->url_params = query_string(self->raw_url);
-
- self->process_message();
- return 0;
- }
- HTTPParser(Handler* handler) :
- handler_(handler)
- {
- http_parser_init(this, HTTP_REQUEST);
- }
-
- // return false on error
- bool feed(const char* buffer, int length)
- {
- const static http_parser_settings settings_{
- on_message_begin,
- on_url,
- nullptr,
- on_header_field,
- on_header_value,
- on_headers_complete,
- on_body,
- on_message_complete,
- };
-
- int nparsed = http_parser_execute(this, &settings_, buffer, length);
- return nparsed == length;
- }
-
- bool done()
- {
- return feed(nullptr, 0);
- }
-
- void clear()
- {
- url.clear();
- raw_url.clear();
- header_building_state = 0;
- header_field.clear();
- header_value.clear();
- headers.clear();
- url_params.clear();
- body.clear();
- }
-
- void process_header()
- {
- handler_->handle_header();
- }
-
- void process_message()
- {
- handler_->handle();
- }
-
- request to_request() const
- {
- return request{(HTTPMethod)method, std::move(raw_url), std::move(url), std::move(url_params), std::move(headers), std::move(body)};
- }
-
- bool is_upgrade() const
- {
- return upgrade;
- }
-
- bool check_version(int major, int minor) const
- {
- return http_major == major && http_minor == minor;
- }
-
- std::string raw_url;
- std::string url;
-
- int header_building_state = 0;
- std::string header_field;
- std::string header_value;
- ci_map headers;
- query_string url_params;
- std::string body;
-
- Handler* handler_;
- };
-}