Method postAsync

Source/Http/HttpServer.cpp:1235–1321

}

HttpClient::RequestId HttpClient::postAsync(String url, std::span<Slice> headers, String json, float timeout, const ContentPartHandler& partCallback, const ContentHandler& callback) {
	if (_stopped.load(std::memory_order_relaxed)) {
		callback(std::nullopt);
		return 0;
	}
	auto request = register_http_client_request();
	if (!request) {
		callback(std::nullopt);
		return 0;
	}
	std::vector<std::pair<std::string, std::string>> postHeaders;
	for (const auto& header : headers) {
		auto parts = header.split(":"sv);
		if (parts.size() == 2) {
			postHeaders.emplace_back(parts.front().toString(), parts.back().toString());
		}
	}
	postHeaders.emplace_back("Content-Type"s, "application/json"s);
	auto callbackFunc = std::make_shared<ContentHandler>(callback);
	auto partCallbackFunc = std::make_shared<ContentPartHandler>(partCallback);
	SharedAsyncThread.run([request, json = json.toString(), timeout, urlStr = url.toString(), partCallbackFunc, callbackFunc, headers = std::move(postHeaders)]() {
		std::vector<std::string> headerNames;
		std::vector<std::string> headerValues;
		std::vector<const char*> headerNamePtrs;
		std::vector<const char*> headerValuePtrs;
		DoraXrtHttpResponse response;
		prepare_xrt_http_headers(headerNames, headerValues, headerNamePtrs, headerValuePtrs, headers);
		if (*partCallbackFunc) {
			auto stopped = std::make_shared<std::atomic<bool>>(false);
			auto completion = std::make_shared<XrtPostStreamCompletion>();
			completion->callback = callbackFunc;
			XrtPostStreamContext streamContext{request, partCallbackFunc, stopped, completion};
			int statusCode = 0;
			auto status = DoraXrtHttpExecuteStream(
				"POST",
				urlStr.c_str(),
				headerNamePtrs.data(),
				headerValuePtrs.data(),
				headerNamePtrs.size(),
				json.data(),
				json.size(),
				to_timeout_ms(timeout),
				0,
				should_cancel_xrt_http,
				request.get(),
				on_xrt_post_stream_chunk,
				&streamContext,
				&statusCode);
			if (status != 0 || statusCode < 200 || statusCode >= 400 || stopped->load(std::memory_order_relaxed)) {
				request_finish_xrt_post_stream_in_logic(completion, false);
			} else {
				request_finish_xrt_post_stream_in_logic(completion, true);
			}
		} else {
			auto status = DoraXrtHttpExecute(
				"POST",
				urlStr.c_str(),
				headerNamePtrs.data(),