Method downloadAsync

Source/Http/HttpServer.cpp:1394–1486

}

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)) {
		progress(true, 0, 0);
		return 0;
	}
	if (!_downloadThread) {
		_downloadThread = SharedAsyncThread.newThread();
	}
	auto request = register_http_client_request();
	if (!request) {
		progress(true, 0, 0);
		return 0;
	}
	auto progressFunc = std::make_shared<std::function<bool(bool interrupted, uint64_t current, uint64_t total)>>(progress);
	_downloadThread->run([request, fileStr = filePath.toString(), urlStr = url.toString(), timeout, progressFunc]() -> Own<Values> {
		try {
			if (request->cancelling.load(std::memory_order_relaxed)) {
				SharedApplication.invokeInLogic([progressFunc]() {
					(*progressFunc)(true, 0, 0);
				});
				unregister_http_client_request(request);
				return nullptr;
			}
			std::vector<std::string> headerNames;
			std::vector<std::string> headerValues;
			std::vector<const char*> headerNamePtrs;
			std::vector<const char*> headerValuePtrs;
			prepare_xrt_http_headers(headerNames, headerValues, headerNamePtrs, headerValuePtrs, {});
			auto fullname = fileStr;
			SDL_RWops* out = SDL_RWFromFile(fullname.c_str(), "wb+");
			if (!out) {
				Error("invalid local file path \"{}\" to download to", fileStr);
				unregister_http_client_request(request);
				return nullptr;
			}
			auto stream = std::shared_ptr<SDL_RWops>{out, [](SDL_RWops* io) {
														 SDL_RWclose(io);
													 }};
			auto stopped = std::make_shared<std::atomic<bool>>(false);
			XrtDownloadStreamContext streamContext{request, progressFunc, stopped, out, urlStr};
			int statusCode = 0;
			auto status = DoraXrtHttpExecuteStream(
				"GET",
				urlStr.c_str(),
				headerNamePtrs.data(),
				headerValuePtrs.data(),
				headerNamePtrs.size(),
				nullptr,
				0,
				to_timeout_ms(timeout),
				0,
				should_cancel_xrt_http,
				request.get(),
				on_xrt_download_stream_chunk,
				&streamContext,
				&statusCode);
			if (status != 0 || statusCode < 200 || statusCode >= 400 || streamContext.writeFailed || stopped->load(std::memory_order_relaxed)) {
				Info("failed to download \"{}\"; network status: {}, HTTP status: {}", urlStr, DoraXrtHttpStatusName(status), statusCode);