From 015f8f1c13066125ad3d98b837b4545df10af741 Mon Sep 17 00:00:00 2001 From: Eelco Dolstra Date: Fri, 27 Mar 2020 21:08:41 +0100 Subject: Improve lock file generation This is now done in a single pass. Also fixes some issues when updating flakes with circular dependencies. Finally, when using '--recreate-lock-file --commit-lock-file', the commit message now correctly shows the differences. --- src/libexpr/flake/flake.cc | 364 ++++++++++++++++++++++----------------------- 1 file changed, 181 insertions(+), 183 deletions(-) (limited to 'src/libexpr') diff --git a/src/libexpr/flake/flake.cc b/src/libexpr/flake/flake.cc index f79abb4ee..18b776727 100644 --- a/src/libexpr/flake/flake.cc +++ b/src/libexpr/flake/flake.cc @@ -306,216 +306,214 @@ LockedFlake lockFlake( auto flake = getFlake(state, topRef, {}, lockFlags.useRegistries, flakeCache); - LockFile oldLockFile; - - if (!lockFlags.recreateLockFile) { - // FIXME: symlink attack - oldLockFile = LockFile::read( - flake.sourceInfo->actualPath + "/" + flake.lockedRef.subdir + "/flake.lock"); - } + // FIXME: symlink attack + auto oldLockFile = LockFile::read( + flake.sourceInfo->actualPath + "/" + flake.lockedRef.subdir + "/flake.lock"); debug("old lock file: %s", oldLockFile); - LockFile newLockFile, prevLockFile; - std::vector prevUnresolved; - // FIXME: check whether all overrides are used. std::map overrides; for (auto & i : lockFlags.inputOverrides) overrides.insert_or_assign(i.first, FlakeInput { .ref = i.second }); - /* Compute the new lock file. This is dones as a fixpoint - iteration: we repeat until the new lock file no longer changes - and there are no unresolved "follows" inputs. */ - while (true) { - std::vector unresolved; - - /* Recurse into the flake inputs. */ - std::function oldLocks, - std::shared_ptr newLocks, - const InputPath & inputPathPrefix)> - updateLocks; - - std::vector parents; - - updateLocks = [&]( - const FlakeInputs & flakeInputs, - std::shared_ptr oldLocks, - std::shared_ptr newLocks, - const InputPath & inputPathPrefix) - { - /* Get the overrides (i.e. attributes of the form - 'inputs.nixops.inputs.nixpkgs.url = ...'). */ - for (auto & [id, input] : flake.inputs) { - for (auto & [idOverride, inputOverride] : input.overrides) { - auto inputPath(inputPathPrefix); - inputPath.push_back(id); - inputPath.push_back(idOverride); - overrides.insert_or_assign(inputPath, inputOverride); - } - } - - /* Go over the flake inputs, resolve/fetch them if - necessary (i.e. if they're new or the flakeref changed - from what's in the lock file). */ - for (auto & [id, input2] : flakeInputs) { + LockFile newLockFile; + + std::vector parents; + std::map follows; + + std::function node, + const InputPath & inputPathPrefix, + std::shared_ptr oldNode)> + computeLocks; + + computeLocks = [&]( + const FlakeInputs & flakeInputs, + std::shared_ptr node, + const InputPath & inputPathPrefix, + std::shared_ptr oldNode) + { + debug("computing lock file node '%s'", concatStringsSep("/", inputPathPrefix)); + + /* Get the overrides (i.e. attributes of the form + 'inputs.nixops.inputs.nixpkgs.url = ...'). */ + // FIXME: check this + for (auto & [id, input] : flake.inputs) { + for (auto & [idOverride, inputOverride] : input.overrides) { auto inputPath(inputPathPrefix); inputPath.push_back(id); - auto inputPathS = concatStringsSep("/", inputPath); - - /* Do we have an override for this input from one of - the ancestors? */ - auto i = overrides.find(inputPath); - bool hasOverride = i != overrides.end(); - auto & input = hasOverride ? i->second : input2; - - if (input.follows) { - /* This is a "follows" input - (i.e. 'inputs.nixpkgs.follows = - "dwarffs/nixpkgs"). Resolve the source and copy - its inputs. Note that the source is normally - relative to the current node of the lock file - (e.g. "dwarffs/nixpkgs" refers to the nixpkgs - input of the dwarffs input of the root flake), - but if it's from an override, it's relative to - the *root* of the lock file. */ - auto follows = (hasOverride ? newLockFile.root : newLocks)->findInput(*input.follows); - if (follows) - newLocks->inputs.insert_or_assign(id, follows); - else - /* We haven't processed the source of the - "follows" yet (e.g. "dwarffs/nixpkgs"). So - we'll need another round of the fixpoint - iteration. */ - // FIXME: now that LockFile is a graph, we - // could pre-create the missing node. - unresolved.push_back(inputPath); - continue; + inputPath.push_back(idOverride); + overrides.insert_or_assign(inputPath, inputOverride); + } + } + + /* Go over the flake inputs, resolve/fetch them if + necessary (i.e. if they're new or the flakeref changed + from what's in the lock file). */ + for (auto & [id, input2] : flakeInputs) { + auto inputPath(inputPathPrefix); + inputPath.push_back(id); + auto inputPathS = concatStringsSep("/", inputPath); + debug("computing input '%s'", concatStringsSep("/", inputPath)); + + /* Do we have an override for this input from one of the + ancestors? */ + auto i = overrides.find(inputPath); + bool hasOverride = i != overrides.end(); + auto & input = hasOverride ? i->second : input2; + + /* Resolve 'follows' later (since it may refer to an input + path we haven't processed yet. */ + if (input.follows) { + if (hasOverride) + /* 'follows' from an override is relative to the + root of the graph. */ + follows.insert_or_assign(inputPath, *input.follows); + else { + /* Otherwise, it's relative to the current flake. */ + InputPath path(inputPathPrefix); + for (auto & i : *input.follows) path.push_back(i); + follows.insert_or_assign(inputPath, path); } + continue; + } - /* Do we have an entry in the existing lock file? And - we don't have a --update-input flag for this - input? */ - auto oldLockIt = - lockFlags.inputUpdates.count(inputPath) - ? oldLocks->inputs.end() - : oldLocks->inputs.find(id); + /* Do we have an entry in the existing lock file? And we + don't have a --update-input flag for this input? */ + std::shared_ptr oldLock; - std::shared_ptr oldLock; - if (oldLockIt != oldLocks->inputs.end()) { + if (oldNode && !lockFlags.inputUpdates.count(inputPath)) { + auto oldLockIt = oldNode->inputs.find(id); + if (oldLockIt != oldNode->inputs.end()) oldLock = std::dynamic_pointer_cast(oldLockIt->second); - assert(oldLock); - } + } - if (oldLock - && oldLock->originalRef == input.ref - && !hasOverride) - { - /* Copy the input from the old lock file if its - flakeref didn't change and there is no override - from a higher level flake. */ - newLocks->inputs.insert_or_assign(id, std::make_shared(*oldLock)); - - /* If we have an --update-input flag for an input - of this input, then we must fetch the flake to - to update it. */ - auto lb = lockFlags.inputUpdates.lower_bound(inputPath); - - auto hasChildUpdate = - lb != lockFlags.inputUpdates.end() - && lb->size() > inputPath.size() - && std::equal(inputPath.begin(), inputPath.end(), lb->begin()); - - if (hasChildUpdate) { - auto inputFlake = getFlake( - state, oldLock->lockedRef, oldLock->info, false, flakeCache); - - updateLocks(inputFlake.inputs, - oldLock, - newLocks->inputs.find(id)->second, - inputPath); - - } else { - /* No need to fetch this flake, we can be - lazy. However there may be new overrides on - the inputs of this flake, so we need to - check those. */ - FlakeInputs fakeInputs; - - for (auto & i : oldLock->inputs) + if (oldLock + && oldLock->originalRef == input.ref + && !hasOverride) + { + debug("keeping existing input '%s'", inputPathS); + + /* Copy the input from the old lock since its flakeref + didn't change and there is no override from a + higher level flake. */ + auto childNode = std::make_shared( + oldLock->lockedRef, oldLock->originalRef, oldLock->info, oldLock->isFlake); + + node->inputs.insert_or_assign(id, childNode); + + /* If we have an --update-input flag for an input + of this input, then we must fetch the flake to + to update it. */ + auto lb = lockFlags.inputUpdates.lower_bound(inputPath); + + auto hasChildUpdate = + lb != lockFlags.inputUpdates.end() + && lb->size() > inputPath.size() + && std::equal(inputPath.begin(), inputPath.end(), lb->begin()); + + if (hasChildUpdate) { + auto inputFlake = getFlake( + state, oldLock->lockedRef, oldLock->info, false, flakeCache); + computeLocks(inputFlake.inputs, childNode, inputPath, oldLock); + } else { + /* No need to fetch this flake, we can be + lazy. However there may be new overrides on the + inputs of this flake, so we need to check + those. */ + FlakeInputs fakeInputs; + + for (auto & i : oldLock->inputs) { + auto lockedNode = std::dynamic_pointer_cast(i.second); + // Note: this node is not locked in case + // of a circular reference back to the root. + if (lockedNode) fakeInputs.emplace(i.first, FlakeInput { - .ref = std::dynamic_pointer_cast(i.second)->originalRef + .ref = lockedNode->originalRef }); - - updateLocks(fakeInputs, - oldLock, - newLocks->inputs.find(id)->second, - inputPath); + else { + InputPath path(inputPath); + path.push_back(i.first); + follows.insert_or_assign(path, InputPath()); + } } - } else { - /* We need to update/create a new lock file - entry. So fetch the flake/non-flake. */ - - if (!lockFlags.allowMutable && !input.ref.input->isImmutable()) - throw Error("cannot update flake input '%s' in pure mode", inputPathS); - - if (input.isFlake) { - auto inputFlake = getFlake(state, input.ref, {}, lockFlags.useRegistries, flakeCache); - - newLocks->inputs.insert_or_assign(id, - std::make_shared(inputFlake.lockedRef, inputFlake.originalRef, inputFlake.sourceInfo->info)); - - /* Recursively process the inputs of this - flake. Also, unless we already have this - flake in the top-level lock file, use this - flake's own lock file. */ - - /* Guard against circular flake imports. */ - for (auto & parent : parents) - if (parent == input.ref) - throw Error("found circular import of flake '%s'", parent); - parents.push_back(input.ref); - Finally cleanup([&]() { parents.pop_back(); }); - - updateLocks(inputFlake.inputs, - oldLock - ? std::dynamic_pointer_cast(oldLock) - : LockFile::read( - inputFlake.sourceInfo->actualPath + "/" + inputFlake.lockedRef.subdir + "/flake.lock").root, - newLocks->inputs.find(id)->second, - inputPath); - } + computeLocks(fakeInputs, childNode, inputPath, oldLock); + } - else { - auto [sourceInfo, lockedRef] = fetchOrSubstituteTree( - state, input.ref, {}, lockFlags.useRegistries, flakeCache); - newLocks->inputs.insert_or_assign(id, - std::make_shared(lockedRef, input.ref, sourceInfo.info, false)); - } + } else { + /* We need to create a new lock file entry. So fetch + this input. */ + + if (!lockFlags.allowMutable && !input.ref.input->isImmutable()) + throw Error("cannot update flake input '%s' in pure mode", inputPathS); + + if (input.isFlake) { + auto inputFlake = getFlake(state, input.ref, {}, lockFlags.useRegistries, flakeCache); + + auto childNode = std::make_shared( + inputFlake.lockedRef, inputFlake.originalRef, inputFlake.sourceInfo->info); + + node->inputs.insert_or_assign(id, childNode); + + /* Guard against circular flake imports. */ + for (auto & parent : parents) + if (parent == input.ref) + throw Error("found circular import of flake '%s'", parent); + parents.push_back(input.ref); + Finally cleanup([&]() { parents.pop_back(); }); + + /* Recursively process the inputs of this + flake. Also, unless we already have this flake + in the top-level lock file, use this flake's + own lock file. */ + computeLocks( + inputFlake.inputs, childNode, inputPath, + oldLock + ? std::dynamic_pointer_cast(oldLock) + : LockFile::read( + inputFlake.sourceInfo->actualPath + "/" + inputFlake.lockedRef.subdir + "/flake.lock").root); + } + + else { + auto [sourceInfo, lockedRef] = fetchOrSubstituteTree( + state, input.ref, {}, lockFlags.useRegistries, flakeCache); + node->inputs.insert_or_assign(id, + std::make_shared(lockedRef, input.ref, sourceInfo.info, false)); } } - }; + } + }; - updateLocks(flake.inputs, oldLockFile.root, newLockFile.root, {}); + computeLocks( + flake.inputs, newLockFile.root, {}, + lockFlags.recreateLockFile ? nullptr : oldLockFile.root); - /* Check if there is a cycle in the "follows" inputs. */ - if (!unresolved.empty() && unresolved == prevUnresolved) { - std::vector ss; - for (auto & i : unresolved) - ss.push_back(concatStringsSep("/", i)); - throw Error("cycle or missing input detected in flake inputs: %s", concatStringsSep(", ", ss)); - } + /* Insert edges for 'follows' overrides. */ + for (auto & [from, to] : follows) { + debug("adding 'follows' node from '%s' to '%s'", + concatStringsSep("/", from), + concatStringsSep("/", to)); - std::swap(unresolved, prevUnresolved); + assert(!from.empty()); - /* Done with the fixpoint iteration? */ - if (newLockFile == prevLockFile) break; - prevLockFile = newLockFile; - }; + InputPath fromParent(from); + fromParent.pop_back(); + + auto fromParentNode = newLockFile.root->findInput(fromParent); + assert(fromParentNode); + + auto toNode = newLockFile.root->findInput(to); + if (!toNode) + throw Error("flake input '%s' follows non-existent flake input '%s'", + concatStringsSep("/", from), + concatStringsSep("/", to)); + + fromParentNode->inputs.insert_or_assign(from.back(), toNode); + } debug("new lock file: %s", newLockFile); -- cgit v1.2.3