iframe-proxy | Sunbelt Computer Software

120 lines (85 loc) · 2.68 KB

#include "ServerHttp2Stream.h"
#include "extensions/Sendfile.h"
namespace HttpServer
	ServerHttp2Stream::ServerHttp2Stream(
		Socket::Adapter &sock,
		const ServerSettings &settings,
		ServerControls &controls,
		Http2::IncStream *stream
	) noexcept
		: ServerHttp2Protocol(sock, settings, controls, stream)
	void ServerHttp2Stream::close() {
		this->stream->close();
	ServerProtocol *ServerHttp2Stream::process()
		struct Request req;
		req.timeout = std::chrono::milliseconds(5000);
		req.protocol_variant = Transfer::ProtocolVariant::HTTP_2;
		req.incoming_headers = std::move(this->stream->incoming_headers);
		req.incoming_data = std::move(this->stream->incoming_data);
		req.incoming_files = std::move(this->stream->incoming_files);
		auto const &headers = req.incoming_headers;
		auto const it_scheme = headers.find(":scheme");
		if (headers.cend() == it_scheme) {
			return this;
		const std::string &scheme = it_scheme->second;
		const int default_port = (scheme == "https")
			: (scheme == "http")
				? 80 : 0;
		auto const it_host = headers.find(":authority");
		if (headers.cend() == it_host) {
			return this;
		const std::string &host_header = it_host->second;
		// Поиск разделителя, за которым помещается номер порта, если указан
		const size_t delimiter = host_header.find(':');
		// Получить имя (или адрес)
		req.host = host_header.substr(0, delimiter);
		// Получить номер порта
		const int port = std::string::npos != delimiter
			? std::atoi(host_header.substr(delimiter + 1).c_str())
			: default_port;
		const ServerApplicationSettings *app_sets = this->settings.apps_tree.find(req.host);
		// Если приложение найдено
		if (nullptr == app_sets || (
				app_sets->ports.cend() == app_sets->ports.find(port) &&
				app_sets->tls_ports.cend() == app_sets->tls_ports.find(port)
			return this;
		auto const it_method = headers.find(":method");
		if (headers.cend() == it_method) {
			return this;
		req.method = it_method->second;
		auto const it_path = headers.find(":path");
		if (headers.cend() == it_path) {
			return this;
		req.path = it_path->second;
		req.app_exit_code = EXIT_FAILURE;
		this->runApplication(req, *app_sets);
		for (auto const &it : req.incoming_files) {
			std::remove(it.second.getTmpName().c_str() );
		if (EXIT_SUCCESS == req.app_exit_code) {
		//	Http2::OutStream out(*stream);
		//	auto tmp = req.protocol_data;
		//	req.protocol_data = &out;
			Sendfile::xSendfile(
				std::ref(*this),
				this->settings.mimes_types
		//	req.protocol_data = tmp;
		return this;

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Sunbelt Computer Software

PL/B Language Development and Support

FilesExpand file tree

ServerHttp2Stream.cpp

Latest commit

History

ServerHttp2Stream.cpp

File metadata and controls