2022-03-21 10:31:01 +00:00
|
|
|
#include "primops.hh"
|
|
|
|
#include "store-api.hh"
|
2022-03-22 20:14:58 +00:00
|
|
|
#include "make-content-addressed.hh"
|
2022-03-22 21:47:33 +00:00
|
|
|
#include "url.hh"
|
2022-03-21 10:31:01 +00:00
|
|
|
|
|
|
|
namespace nix {
|
|
|
|
|
|
|
|
static void prim_fetchClosure(EvalState & state, const Pos & pos, Value * * args, Value & v)
|
|
|
|
{
|
|
|
|
state.forceAttrs(*args[0], pos);
|
|
|
|
|
2022-03-21 13:34:45 +00:00
|
|
|
std::optional<std::string> fromStoreUrl;
|
|
|
|
std::optional<StorePath> fromPath;
|
2022-03-22 20:14:58 +00:00
|
|
|
bool toCA = false;
|
|
|
|
std::optional<StorePath> toPath;
|
2022-03-21 10:31:01 +00:00
|
|
|
|
|
|
|
for (auto & attr : *args[0]->attrs) {
|
2022-03-21 13:34:45 +00:00
|
|
|
if (attr.name == "fromPath") {
|
2022-03-21 10:31:01 +00:00
|
|
|
PathSet context;
|
2022-03-21 13:34:45 +00:00
|
|
|
fromPath = state.coerceToStorePath(*attr.pos, *attr.value, context);
|
2022-03-21 10:31:01 +00:00
|
|
|
}
|
|
|
|
|
2022-03-22 20:14:58 +00:00
|
|
|
else if (attr.name == "toPath") {
|
|
|
|
state.forceValue(*attr.value, *attr.pos);
|
|
|
|
toCA = true;
|
|
|
|
if (attr.value->type() != nString || attr.value->string.s != std::string("")) {
|
|
|
|
PathSet context;
|
|
|
|
toPath = state.coerceToStorePath(*attr.pos, *attr.value, context);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2022-03-21 13:34:45 +00:00
|
|
|
else if (attr.name == "fromStore")
|
|
|
|
fromStoreUrl = state.forceStringNoCtx(*attr.value, *attr.pos);
|
2022-03-21 10:31:01 +00:00
|
|
|
|
|
|
|
else
|
|
|
|
throw Error({
|
|
|
|
.msg = hintfmt("attribute '%s' isn't supported in call to 'fetchClosure'", attr.name),
|
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
2022-03-21 13:34:45 +00:00
|
|
|
if (!fromPath)
|
2022-03-21 10:31:01 +00:00
|
|
|
throw Error({
|
2022-03-21 13:34:45 +00:00
|
|
|
.msg = hintfmt("attribute '%s' is missing in call to 'fetchClosure'", "fromPath"),
|
2022-03-21 10:31:01 +00:00
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
|
2022-03-21 13:34:45 +00:00
|
|
|
if (!fromStoreUrl)
|
2022-03-21 10:31:01 +00:00
|
|
|
throw Error({
|
2022-03-21 13:34:45 +00:00
|
|
|
.msg = hintfmt("attribute '%s' is missing in call to 'fetchClosure'", "fromStore"),
|
2022-03-21 10:31:01 +00:00
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
|
2022-03-22 21:47:33 +00:00
|
|
|
auto parsedURL = parseURL(*fromStoreUrl);
|
|
|
|
|
2022-03-22 22:19:21 +00:00
|
|
|
if (parsedURL.scheme != "http" &&
|
|
|
|
parsedURL.scheme != "https" &&
|
|
|
|
!(getEnv("_NIX_IN_TEST").has_value() && parsedURL.scheme == "file"))
|
2022-03-22 21:47:33 +00:00
|
|
|
throw Error({
|
|
|
|
.msg = hintfmt("'fetchClosure' only supports http:// and https:// stores"),
|
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
|
2022-04-06 09:52:51 +00:00
|
|
|
if (!parsedURL.query.empty())
|
|
|
|
throw Error({
|
|
|
|
.msg = hintfmt("'fetchClosure' does not support URL query parameters (in '%s')", *fromStoreUrl),
|
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
|
2022-03-22 21:47:33 +00:00
|
|
|
auto fromStore = openStore(parsedURL.to_string());
|
2022-03-21 10:31:01 +00:00
|
|
|
|
2022-03-22 20:14:58 +00:00
|
|
|
if (toCA) {
|
2022-03-22 21:01:20 +00:00
|
|
|
if (!toPath || !state.store->isValidPath(*toPath)) {
|
|
|
|
auto remappings = makeContentAddressed(*fromStore, *state.store, { *fromPath });
|
|
|
|
auto i = remappings.find(*fromPath);
|
|
|
|
assert(i != remappings.end());
|
|
|
|
if (toPath && *toPath != i->second)
|
|
|
|
throw Error({
|
|
|
|
.msg = hintfmt("rewriting '%s' to content-addressed form yielded '%s', while '%s' was expected",
|
|
|
|
state.store->printStorePath(*fromPath),
|
|
|
|
state.store->printStorePath(i->second),
|
|
|
|
state.store->printStorePath(*toPath)),
|
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
if (!toPath)
|
|
|
|
throw Error({
|
|
|
|
.msg = hintfmt(
|
|
|
|
"rewriting '%s' to content-addressed form yielded '%s'; "
|
|
|
|
"please set this in the 'toPath' attribute passed to 'fetchClosure'",
|
|
|
|
state.store->printStorePath(*fromPath),
|
|
|
|
state.store->printStorePath(i->second)),
|
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
}
|
2022-03-22 20:14:58 +00:00
|
|
|
} else {
|
2022-04-06 09:52:51 +00:00
|
|
|
if (!state.store->isValidPath(*fromPath))
|
|
|
|
copyClosure(*fromStore, *state.store, RealisedPath::Set { *fromPath });
|
2022-03-22 20:14:58 +00:00
|
|
|
toPath = fromPath;
|
|
|
|
}
|
2022-03-21 10:31:01 +00:00
|
|
|
|
2022-03-21 13:00:54 +00:00
|
|
|
/* In pure mode, require a CA path. */
|
|
|
|
if (evalSettings.pureEval) {
|
2022-03-22 20:14:58 +00:00
|
|
|
auto info = state.store->queryPathInfo(*toPath);
|
2022-03-21 13:00:54 +00:00
|
|
|
if (!info->isContentAddressed(*state.store))
|
|
|
|
throw Error({
|
|
|
|
.msg = hintfmt("in pure mode, 'fetchClosure' requires a content-addressed path, which '%s' isn't",
|
2022-03-22 20:14:58 +00:00
|
|
|
state.store->printStorePath(*toPath)),
|
2022-03-21 13:00:54 +00:00
|
|
|
.errPos = pos
|
|
|
|
});
|
|
|
|
}
|
2022-03-21 10:31:01 +00:00
|
|
|
|
2022-03-22 20:14:58 +00:00
|
|
|
auto toPathS = state.store->printStorePath(*toPath);
|
|
|
|
v.mkString(toPathS, {toPathS});
|
2022-03-21 10:31:01 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
static RegisterPrimOp primop_fetchClosure({
|
|
|
|
.name = "__fetchClosure",
|
|
|
|
.args = {"args"},
|
|
|
|
.doc = R"(
|
2022-03-22 22:31:48 +00:00
|
|
|
Fetch a Nix store closure from a binary cache, rewriting it into
|
|
|
|
content-addressed form. For example,
|
|
|
|
|
|
|
|
```nix
|
|
|
|
builtins.fetchClosure {
|
|
|
|
fromStore = "https://cache.nixos.org";
|
|
|
|
fromPath = /nix/store/r2jd6ygnmirm2g803mksqqjm4y39yi6i-git-2.33.1;
|
|
|
|
toPath = /nix/store/ldbhlwhh39wha58rm61bkiiwm6j7211j-git-2.33.1;
|
|
|
|
}
|
|
|
|
```
|
|
|
|
|
|
|
|
fetches `/nix/store/r2jd...` from the specified binary cache,
|
|
|
|
and rewrites it into the content-addressed store path
|
|
|
|
`/nix/store/ldbh...`.
|
|
|
|
|
|
|
|
If `fromPath` is already content-addressed, or if you are
|
|
|
|
allowing impure evaluation (`--impure`), then `toPath` may be
|
|
|
|
omitted.
|
|
|
|
|
|
|
|
To find out the correct value for `toPath` given a `fromPath`,
|
|
|
|
you can use `nix store make-content-addressed`:
|
|
|
|
|
|
|
|
```console
|
2022-03-22 22:40:04 +00:00
|
|
|
# nix store make-content-addressed --from https://cache.nixos.org /nix/store/r2jd6ygnmirm2g803mksqqjm4y39yi6i-git-2.33.1
|
2022-03-22 22:31:48 +00:00
|
|
|
rewrote '/nix/store/r2jd6ygnmirm2g803mksqqjm4y39yi6i-git-2.33.1' to '/nix/store/ldbhlwhh39wha58rm61bkiiwm6j7211j-git-2.33.1'
|
|
|
|
```
|
|
|
|
|
|
|
|
This function is similar to `builtins.storePath` in that it
|
|
|
|
allows you to use a previously built store path in a Nix
|
|
|
|
expression. However, it is more reproducible because it requires
|
|
|
|
specifying a binary cache from which the path can be fetched.
|
|
|
|
Also, requiring a content-addressed final store path avoids the
|
|
|
|
need for users to configure binary cache public keys.
|
2022-03-25 13:04:18 +00:00
|
|
|
|
|
|
|
This function is only available if you enable the experimental
|
|
|
|
feature `fetch-closure`.
|
2022-03-21 10:31:01 +00:00
|
|
|
)",
|
|
|
|
.fun = prim_fetchClosure,
|
2022-03-25 13:04:18 +00:00
|
|
|
.experimentalFeature = Xp::FetchClosure,
|
2022-03-21 10:31:01 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
}
|