Method getAsync

Source/Http/HttpServer.cpp:1347–1392

}

HttpClient::RequestId HttpClient::getAsync(String url, float timeout, 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;
	}
	SharedAsyncThread.run([request, timeout, urlStr = url.toString(), callback]() {
		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, {});
		auto status = DoraXrtHttpExecute(
			"GET",
			urlStr.c_str(),
			headerNamePtrs.data(),
			headerValuePtrs.data(),
			headerNamePtrs.size(),
			nullptr,
			0,
			to_timeout_ms(timeout),
			0,
			should_cancel_xrt_http,
			request.get(),
			&response);
		if (status != 0 || response.statusCode < 200 || response.statusCode >= 400) {
			Info("failed to do HTTP GET \"{}\"; network status: {}, HTTP status: {}", urlStr, DoraXrtHttpStatusName(status), response.statusCode);
			SharedApplication.invokeInLogic([callback]() {
				callback(std::nullopt);
			});
		} else {
			std::string body(response.body ? response.body : "", response.bodyLen);
			SharedApplication.invokeInLogic([callback, body = std::move(body)]() {
				callback(body);
			});
		}
		DoraXrtHttpResponseFree(&response);
		unregister_http_client_request(request);
	});
	return request->id;
}

HttpClient::RequestId HttpClient::downloadAsync(String url, String filePath, float timeout, const std::function<bool(bool interrupted, uint64_t current, uint64_t total)>& progress) {
	if (_stopped.load(std::memory_order_relaxed)) {