Method handle_buffer

src/dpp/http_server_request.cpp:109–206

}

bool http_server_request::handle_buffer(std::string &buffer)
{
	bool state_changed = false;
	do {
		state_changed = false;
		switch (state) {
			case HTTPS_HEADERS:
				if (buffer.length() > get_max_header_size()) {
					owner->log(ll_warning, "HTTTP request exceeds max header size, dropped");
					return false;
				} else if (buffer.find("\r\n\r\n") != std::string::npos) {

					/* Add 10 seconds to retrieve body */
					timeout += 10;

					/* Got all headers, proceed to new state */

					/* Get headers string */
					std::string headers = buffer.substr(0, buffer.find("\r\n\r\n"));

					/* Modify buffer, remove headers section */
					buffer.erase(0, buffer.find("\r\n\r\n") + 4);

					/* Process headers into map */
					std::vector<std::string> h = utility::tokenize(headers);

					if (h.empty()) {
						generate_error(400, "Malformed request");
						return true;
					}

					/* First line is special */
					std::vector<std::string> verb_path_protocol = utility::tokenize(h[0], " ");
					if (verb_path_protocol.size() < 3) {
						generate_error(400, "Malformed request");
						return true;
					}
					std::string req_verb = uppercase(verb_path_protocol[0]);
					request_type = req_verb;
					std::string req_path = verb_path_protocol[1];
					path = req_path;
					std::string protocol = uppercase(verb_path_protocol[2]);
					
					h.erase(h.begin());

					if (protocol.substr(0, 5) != "HTTP/") {
						generate_error(400, "Malformed request");
						return true;
					}

					if (std::find(verb.begin(), verb.end(), req_verb) == verb.end()) {
						generate_error(401, "Unsupported method");
						return true;
					}

					for(auto &hd : h) {
						std::string::size_type sep = hd.find(": ");
						if (sep != std::string::npos) {