libstore: remove FileTransferResult::data
return it as a separate item in a pair instead. this will let us remove
enqueueDownload() in favor of returning metadata from download() itself
Change-Id: I74fad2ca15f920da1eefabc950c2baa2c360f2ba
This commit is contained in:
parent
5cd7055044
commit
982d049d3b
|
@ -43,8 +43,9 @@ DownloadFileResult downloadFile(
|
||||||
if (cached)
|
if (cached)
|
||||||
headers.emplace_back("If-None-Match", getStrAttr(cached->infoAttrs, "etag"));
|
headers.emplace_back("If-None-Match", getStrAttr(cached->infoAttrs, "etag"));
|
||||||
FileTransferResult res;
|
FileTransferResult res;
|
||||||
|
std::string data;
|
||||||
try {
|
try {
|
||||||
res = getFileTransfer()->enqueueDownload(url, headers).get();
|
std::tie(res, data) = getFileTransfer()->enqueueDownload(url, headers).get();
|
||||||
} catch (FileTransferError & e) {
|
} catch (FileTransferError & e) {
|
||||||
if (cached) {
|
if (cached) {
|
||||||
warn("%s; using cached version", e.msg());
|
warn("%s; using cached version", e.msg());
|
||||||
|
@ -69,8 +70,8 @@ DownloadFileResult downloadFile(
|
||||||
storePath = std::move(cached->storePath);
|
storePath = std::move(cached->storePath);
|
||||||
} else {
|
} else {
|
||||||
StringSink sink;
|
StringSink sink;
|
||||||
sink << dumpString(res.data);
|
sink << dumpString(data);
|
||||||
auto hash = hashString(HashType::SHA256, res.data);
|
auto hash = hashString(HashType::SHA256, data);
|
||||||
ValidPathInfo info {
|
ValidPathInfo info {
|
||||||
*store,
|
*store,
|
||||||
name,
|
name,
|
||||||
|
|
|
@ -48,9 +48,12 @@ struct curlFileTransfer : public FileTransfer
|
||||||
FileTransferResult result;
|
FileTransferResult result;
|
||||||
Activity act;
|
Activity act;
|
||||||
std::optional<std::string> uploadData;
|
std::optional<std::string> uploadData;
|
||||||
|
std::string downloadData;
|
||||||
bool noBody = false; // \equiv HTTP HEAD, don't download data
|
bool noBody = false; // \equiv HTTP HEAD, don't download data
|
||||||
bool done = false; // whether either the success or failure function has been called
|
bool done = false; // whether either the success or failure function has been called
|
||||||
std::packaged_task<FileTransferResult(std::exception_ptr, FileTransferResult)> callback;
|
std::packaged_task<
|
||||||
|
std::pair<FileTransferResult, std::string>(std::exception_ptr, FileTransferResult)>
|
||||||
|
callback;
|
||||||
std::function<void(TransferItem &, std::string_view data)> dataCallback;
|
std::function<void(TransferItem &, std::string_view data)> dataCallback;
|
||||||
CURL * req = 0;
|
CURL * req = 0;
|
||||||
bool active = false; // whether the handle has been added to the multi object
|
bool active = false; // whether the handle has been added to the multi object
|
||||||
|
@ -105,9 +108,9 @@ struct curlFileTransfer : public FileTransfer
|
||||||
{uri}, parentAct)
|
{uri}, parentAct)
|
||||||
, uploadData(std::move(uploadData))
|
, uploadData(std::move(uploadData))
|
||||||
, noBody(noBody)
|
, noBody(noBody)
|
||||||
, callback([cb{std::move(callback)}] (std::exception_ptr ex, FileTransferResult r) {
|
, callback([this, cb{std::move(callback)}] (std::exception_ptr ex, FileTransferResult r) {
|
||||||
cb(ex);
|
cb(ex);
|
||||||
return r;
|
return std::pair{std::move(r), std::move(downloadData)};
|
||||||
})
|
})
|
||||||
, dataCallback(std::move(dataCallback))
|
, dataCallback(std::move(dataCallback))
|
||||||
{
|
{
|
||||||
|
@ -159,7 +162,7 @@ struct curlFileTransfer : public FileTransfer
|
||||||
writtenToSink += realSize;
|
writtenToSink += realSize;
|
||||||
dataCallback(*this, {static_cast<const char *>(contents), realSize});
|
dataCallback(*this, {static_cast<const char *>(contents), realSize});
|
||||||
} else {
|
} else {
|
||||||
this->result.data.append(static_cast<const char *>(contents), realSize);
|
this->downloadData.append(static_cast<const char *>(contents), realSize);
|
||||||
}
|
}
|
||||||
|
|
||||||
return realSize;
|
return realSize;
|
||||||
|
@ -183,7 +186,7 @@ struct curlFileTransfer : public FileTransfer
|
||||||
static std::regex statusLine("HTTP/[^ ]+ +[0-9]+(.*)", std::regex::extended | std::regex::icase);
|
static std::regex statusLine("HTTP/[^ ]+ +[0-9]+(.*)", std::regex::extended | std::regex::icase);
|
||||||
if (std::smatch match; std::regex_match(line, match, statusLine)) {
|
if (std::smatch match; std::regex_match(line, match, statusLine)) {
|
||||||
result.etag = "";
|
result.etag = "";
|
||||||
result.data.clear();
|
downloadData.clear();
|
||||||
bodySize = 0;
|
bodySize = 0;
|
||||||
statusMsg = trim(match.str(1));
|
statusMsg = trim(match.str(1));
|
||||||
acceptRanges = false;
|
acceptRanges = false;
|
||||||
|
@ -328,7 +331,7 @@ struct curlFileTransfer : public FileTransfer
|
||||||
if (writtenToSink)
|
if (writtenToSink)
|
||||||
curl_easy_setopt(req, CURLOPT_RESUME_FROM_LARGE, writtenToSink);
|
curl_easy_setopt(req, CURLOPT_RESUME_FROM_LARGE, writtenToSink);
|
||||||
|
|
||||||
result.data.clear();
|
downloadData.clear();
|
||||||
bodySize = 0;
|
bodySize = 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -348,8 +351,8 @@ struct curlFileTransfer : public FileTransfer
|
||||||
// wrapping user `callback`s instead is not possible because the
|
// wrapping user `callback`s instead is not possible because the
|
||||||
// Callback api expects std::functions, and copying Callbacks is
|
// Callback api expects std::functions, and copying Callbacks is
|
||||||
// not possible due the promises they hold.
|
// not possible due the promises they hold.
|
||||||
if (code == CURLE_OK && !dataCallback && result.data.length() > 0) {
|
if (code == CURLE_OK && !dataCallback && downloadData.length() > 0) {
|
||||||
result.data = decompress(encoding, result.data);
|
downloadData = decompress(encoding, downloadData);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (writeException)
|
if (writeException)
|
||||||
|
@ -417,7 +420,7 @@ struct curlFileTransfer : public FileTransfer
|
||||||
|
|
||||||
std::optional<std::string> response;
|
std::optional<std::string> response;
|
||||||
if (!successfulStatuses.count(httpStatus))
|
if (!successfulStatuses.count(httpStatus))
|
||||||
response = std::move(result.data);
|
response = std::move(downloadData);
|
||||||
auto exc =
|
auto exc =
|
||||||
code == CURLE_ABORTED_BY_CALLBACK && _isInterrupted
|
code == CURLE_ABORTED_BY_CALLBACK && _isInterrupted
|
||||||
? FileTransferError(Interrupted, std::move(response), "%s of '%s' was interrupted", verb(), uri)
|
? FileTransferError(Interrupted, std::move(response), "%s of '%s' was interrupted", verb(), uri)
|
||||||
|
@ -657,7 +660,7 @@ struct curlFileTransfer : public FileTransfer
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
std::future<FileTransferResult>
|
std::future<std::pair<FileTransferResult, std::string>>
|
||||||
enqueueDownload(const std::string & uri, const Headers & headers = {}) override
|
enqueueDownload(const std::string & uri, const Headers & headers = {}) override
|
||||||
{
|
{
|
||||||
return enqueueFileTransfer(uri, headers, std::nullopt, false);
|
return enqueueFileTransfer(uri, headers, std::nullopt, false);
|
||||||
|
@ -668,7 +671,7 @@ struct curlFileTransfer : public FileTransfer
|
||||||
enqueueFileTransfer(uri, headers, std::move(data), false).get();
|
enqueueFileTransfer(uri, headers, std::move(data), false).get();
|
||||||
}
|
}
|
||||||
|
|
||||||
std::future<FileTransferResult> enqueueFileTransfer(
|
std::future<std::pair<FileTransferResult, std::string>> enqueueFileTransfer(
|
||||||
const std::string & uri,
|
const std::string & uri,
|
||||||
const Headers & headers,
|
const Headers & headers,
|
||||||
std::optional<std::string> data,
|
std::optional<std::string> data,
|
||||||
|
@ -689,7 +692,7 @@ struct curlFileTransfer : public FileTransfer
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
std::future<FileTransferResult> enqueueFileTransfer(
|
std::future<std::pair<FileTransferResult, std::string>> enqueueFileTransfer(
|
||||||
const std::string & uri,
|
const std::string & uri,
|
||||||
const Headers & headers,
|
const Headers & headers,
|
||||||
std::invocable<std::exception_ptr> auto callback,
|
std::invocable<std::exception_ptr> auto callback,
|
||||||
|
@ -701,28 +704,32 @@ struct curlFileTransfer : public FileTransfer
|
||||||
/* Ugly hack to support s3:// URIs. */
|
/* Ugly hack to support s3:// URIs. */
|
||||||
if (uri.starts_with("s3://")) {
|
if (uri.starts_with("s3://")) {
|
||||||
// FIXME: do this on a worker thread
|
// FIXME: do this on a worker thread
|
||||||
return std::async(std::launch::deferred, [uri]() -> FileTransferResult {
|
return std::async(
|
||||||
|
std::launch::deferred,
|
||||||
|
[uri]() -> std::pair<FileTransferResult, std::string> {
|
||||||
#if ENABLE_S3
|
#if ENABLE_S3
|
||||||
auto [bucketName, key, params] = parseS3Uri(uri);
|
auto [bucketName, key, params] = parseS3Uri(uri);
|
||||||
|
|
||||||
std::string profile = getOr(params, "profile", "");
|
std::string profile = getOr(params, "profile", "");
|
||||||
std::string region = getOr(params, "region", Aws::Region::US_EAST_1);
|
std::string region = getOr(params, "region", Aws::Region::US_EAST_1);
|
||||||
std::string scheme = getOr(params, "scheme", "");
|
std::string scheme = getOr(params, "scheme", "");
|
||||||
std::string endpoint = getOr(params, "endpoint", "");
|
std::string endpoint = getOr(params, "endpoint", "");
|
||||||
|
|
||||||
S3Helper s3Helper(profile, region, scheme, endpoint);
|
S3Helper s3Helper(profile, region, scheme, endpoint);
|
||||||
|
|
||||||
// FIXME: implement ETag
|
// FIXME: implement ETag
|
||||||
auto s3Res = s3Helper.getObject(bucketName, key);
|
auto s3Res = s3Helper.getObject(bucketName, key);
|
||||||
FileTransferResult res;
|
FileTransferResult res;
|
||||||
if (!s3Res.data)
|
if (!s3Res.data)
|
||||||
throw FileTransferError(NotFound, "S3 object '%s' does not exist", uri);
|
throw FileTransferError(NotFound, "S3 object '%s' does not exist", uri);
|
||||||
res.data = std::move(*s3Res.data);
|
return {res, std::move(*s3Res.data)};
|
||||||
return res;
|
|
||||||
#else
|
#else
|
||||||
throw nix::Error("cannot download '%s' because Lix is not built with S3 support", uri);
|
throw nix::Error(
|
||||||
|
"cannot download '%s' because Lix is not built with S3 support", uri
|
||||||
|
);
|
||||||
#endif
|
#endif
|
||||||
});
|
}
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
return enqueueItem(std::make_shared<TransferItem>(
|
return enqueueItem(std::make_shared<TransferItem>(
|
||||||
|
|
|
@ -57,7 +57,6 @@ struct FileTransferResult
|
||||||
bool cached = false;
|
bool cached = false;
|
||||||
std::string etag;
|
std::string etag;
|
||||||
std::string effectiveUri;
|
std::string effectiveUri;
|
||||||
std::string data;
|
|
||||||
/* An "immutable" URL for this resource (i.e. one whose contents
|
/* An "immutable" URL for this resource (i.e. one whose contents
|
||||||
will never change), as returned by the `Link: <url>;
|
will never change), as returned by the `Link: <url>;
|
||||||
rel="immutable"` header. */
|
rel="immutable"` header. */
|
||||||
|
@ -74,7 +73,7 @@ struct FileTransfer
|
||||||
* Enqueues a download request, returning a future for the result of
|
* Enqueues a download request, returning a future for the result of
|
||||||
* the download. The future may throw a FileTransferError exception.
|
* the download. The future may throw a FileTransferError exception.
|
||||||
*/
|
*/
|
||||||
virtual std::future<FileTransferResult>
|
virtual std::future<std::pair<FileTransferResult, std::string>>
|
||||||
enqueueDownload(const std::string & uri, const Headers & headers = {}) = 0;
|
enqueueDownload(const std::string & uri, const Headers & headers = {}) = 0;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -161,7 +161,7 @@ protected:
|
||||||
checkEnabled();
|
checkEnabled();
|
||||||
|
|
||||||
try {
|
try {
|
||||||
return std::move(getFileTransfer()->enqueueDownload(makeURI(path)).get().data);
|
return std::move(getFileTransfer()->enqueueDownload(makeURI(path)).get().second);
|
||||||
} catch (FileTransferError & e) {
|
} catch (FileTransferError & e) {
|
||||||
if (e.error == FileTransfer::NotFound || e.error == FileTransfer::Forbidden)
|
if (e.error == FileTransfer::NotFound || e.error == FileTransfer::Forbidden)
|
||||||
return {};
|
return {};
|
||||||
|
|
|
@ -285,11 +285,11 @@ struct CmdUpgradeNix : MixDryRun, EvalCommand
|
||||||
Activity act(*logger, lvlInfo, actUnknown, "querying latest Nix version");
|
Activity act(*logger, lvlInfo, actUnknown, "querying latest Nix version");
|
||||||
|
|
||||||
// FIXME: use nixos.org?
|
// FIXME: use nixos.org?
|
||||||
auto res = getFileTransfer()->enqueueDownload(storePathsUrl).get();
|
auto [res, data] = getFileTransfer()->enqueueDownload(storePathsUrl).get();
|
||||||
|
|
||||||
auto state = std::make_unique<EvalState>(SearchPath{}, store);
|
auto state = std::make_unique<EvalState>(SearchPath{}, store);
|
||||||
auto v = state->allocValue();
|
auto v = state->allocValue();
|
||||||
state->eval(state->parseExprFromString(res.data, state->rootPath(CanonPath("/no-such-path"))), *v);
|
state->eval(state->parseExprFromString(data, state->rootPath(CanonPath("/no-such-path"))), *v);
|
||||||
Bindings & bindings(*state->allocBindings(0));
|
Bindings & bindings(*state->allocBindings(0));
|
||||||
auto v2 = findAlongAttrPath(*state, settings.thisSystem, bindings, *v).first;
|
auto v2 = findAlongAttrPath(*state, settings.thisSystem, bindings, *v).first;
|
||||||
|
|
||||||
|
|
|
@ -215,7 +215,7 @@ TEST(FileTransfer, usesIntermediateLinkHeaders)
|
||||||
{"200 ok", "content-length: 1\r\n", [] { return "a"; }},
|
{"200 ok", "content-length: 1\r\n", [] { return "a"; }},
|
||||||
});
|
});
|
||||||
auto ft = makeFileTransfer(0);
|
auto ft = makeFileTransfer(0);
|
||||||
auto result = ft->enqueueDownload(fmt("http://[::1]:%d/first", port)).get();
|
auto [result, _data] = ft->enqueueDownload(fmt("http://[::1]:%d/first", port)).get();
|
||||||
ASSERT_EQ(result.immutableUrl, "http://foo");
|
ASSERT_EQ(result.immutableUrl, "http://foo");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue