Method Start

plugins/http/http-server.cpp:149–201

}

void HttpServer::Start()
{
	std::lock_guard<std::mutex> lock(_impl->mutex);

	if (_impl->server) {
		_impl->server->stop();
	}
	if (_impl->thread.joinable()) {
		_impl->thread.join();
	}

	_impl->server = std::make_unique<httplib::Server>();
	_impl->listening.store(false);

	auto handleRequest = [this](const httplib::Request &req,
				    httplib::Response &res) {
		HttpRequest request;
		request.method = req.method;
		request.path = req.path;
		request.body = req.body;
		for (const auto &[name, value] : req.headers) {
			request.headers.emplace(name, value);
		}
		_impl->dispatcher.DispatchMessage(request);
		res.status = 200;
	};

	_impl->server->Get(".*", handleRequest);
	_impl->server->Post(".*", handleRequest);
	_impl->server->Put(".*", handleRequest);
	_impl->server->Patch(".*", handleRequest);
	_impl->server->Delete(".*", handleRequest);

	const int port = _port;
	const std::string name = _name;
	auto serverPtr = _impl->server.get();
	auto listeningFlag = &_impl->listening;

	_impl->thread = std::thread([serverPtr, listeningFlag, port, name]() {
		if (!serverPtr->bind_to_port("0.0.0.0", port)) {
			blog(LOG_WARNING,
			     "HTTP server \"%s\" failed to bind to port %d",
			     name.c_str(), port);
			return;
		}
		listeningFlag->store(true);
		blog(LOG_INFO, "HTTP server \"%s\" listening on port %d",
		     name.c_str(), port);
		serverPtr->listen_after_bind();
		listeningFlag->store(false);
		blog(LOG_INFO, "HTTP server \"%s\" stopped", name.c_str());
	});
}

void HttpServer::Stop()
{