Merge pull request 'clan-cli: improve runtime dependency management' (#1733) from DavHau/clan-core:DavHau-vars into main

pkgs/clan-cli/clan_cli/git.py

@@ -2,7 +2,7 @@ from pathlib import Path
 
 # from clan_cli.dirs import find_git_repo_root
 from clan_cli.errors import ClanError
-from clan_cli.nix import nix_shell
+from clan_cli.nix import run_cmd
 
 from .cmd import Log, run
 from .locked_open import locked_open
@@ -60,8 +60,8 @@ def _commit_file_to_git(
     """
     with locked_open(repo_dir / ".git" / "clan.lock", "w+"):
         for file_path in file_paths:
-            cmd = nix_shell(
+            cmd = run_cmd(
-                ["nixpkgs#git"],
+                ["git"],
                 ["git", "-C", str(repo_dir), "add", str(file_path)],
             )
             # add the file to the git index
@@ -73,8 +73,8 @@ def _commit_file_to_git(
             )
 
         # check if there is a diff
-        cmd = nix_shell(
+        cmd = run_cmd(
-            ["nixpkgs#git"],
+            ["git"],
             ["git", "-C", str(repo_dir), "diff", "--cached", "--exit-code"]
             + [str(file_path) for file_path in file_paths],
         )
@@ -84,8 +84,8 @@ def _commit_file_to_git(
             return
 
         # commit only that file
-        cmd = nix_shell(
+        cmd = run_cmd(
-            ["nixpkgs#git"],
+            ["git"],
             [
                 "git",
                 "-C",

pkgs/clan-cli/clan_cli/nix/__init__.py

@@ -4,8 +4,8 @@ import tempfile
 from pathlib import Path
 from typing import Any
 
-from .cmd import run, run_no_stdout
+from ..cmd import run, run_no_stdout
-from .dirs import nixpkgs_flake, nixpkgs_source
+from ..dirs import nixpkgs_flake, nixpkgs_source
 
 
 def nix_command(flags: list[str]) -> list[str]:
@@ -111,3 +111,49 @@ def nix_shell(packages: list[str], cmd: list[str]) -> list[str]:
         "-c",
         *cmd,
     ]
+
+
+# lazy loads list of allowed and static programs
+class Programs:
+    allowed_programs = None
+    static_programs = None
+
+    @classmethod
+    def is_allowed(cls: type["Programs"], program: str) -> bool:
+        if cls.allowed_programs is None:
+            with open(Path(__file__).parent / "allowed-programs.json") as f:
+                cls.allowed_programs = json.load(f)
+        return program in cls.allowed_programs
+
+    @classmethod
+    def is_static(cls: type["Programs"], program: str) -> bool:
+        """
+        Determines if a program is statically shipped with this clan distribution
+        """
+        if cls.static_programs is None:
+            cls.static_programs = os.environ.get("CLAN_STATIC_PROGRAMS", "").split(":")
+        return program in cls.static_programs
+
+
+# Alternative implementation of nix_shell() to replace nix_shell() at some point
+#   Features:
+#     - allow list for programs (need to be specified in allowed-programs.json)
+#     - be abe to compute a closure of all deps for testing
+#     - build clan distributions that ship some or all packages (eg. clan-cli-full)
+def run_cmd(programs: list[str], cmd: list[str]) -> list[str]:
+    for program in programs:
+        if not Programs.is_allowed(program):
+            raise ValueError(f"Program not allowed: {program}")
+    if os.environ.get("IN_NIX_SANDBOX"):
+        return cmd
+    missing_packages = [
+        f"nixpkgs#{program}" for program in programs if not Programs.is_static(program)
+    ]
+    if not missing_packages:
+        return cmd
+    return [
+        *nix_command(["shell", "--inputs-from", f"{nixpkgs_flake()!s}"]),
+        *missing_packages,
+        "-c",
+        *cmd,
+    ]

pkgs/clan-cli/clan_cli/nix/allowed-programs.json

@@ -0,0 +1,15 @@
+[
+  "age",
+  "bash",
+  "e2fsprogs",
+  "git",
+  "mypy",
+  "nix",
+  "openssh",
+  "qemu",
+  "rsync",
+  "sops",
+  "sshpass",
+  "tor",
+  "zbar"
+]

pkgs/clan-cli/default.nix

@@ -1,54 +1,40 @@
 {
-  age,
+  # callPackage args
-  lib,
   argcomplete,
+  gitMinimal,
+  gnupg,
   installShellFiles,
+  lib,
   nix,
-  openssh,
+  pkgs,
-  pytest,
   pytest-cov,
-  pytest-xdist,
   pytest-subprocess,
   pytest-timeout,
+  pytest-xdist,
+  pytest,
   python3,
   runCommand,
   setuptools,
-  sops,
   stdenv,
-  rsync,
+
-  bash,
+  # custom args
-  sshpass,
-  zbar,
-  tor,
-  git,
-  qemu,
-  gnupg,
-  e2fsprogs,
-  mypy,
-  nixpkgs,
   clan-core-path,
-  gitMinimal,
+  nixpkgs,
+  includedRuntimeDeps,
 }:
 let
   pythonDependencies = [
     argcomplete # Enables shell completions
   ];
 
-  runtimeDependencies = [
+  # load nixpkgs runtime dependencies from a json file
-    bash
+  # This file represents an allow list at the same time that is checked by the run_cmd
-    nix
+  #   implementation in nix.py
-    openssh
+  runtimeDependenciesAsSet = lib.genAttrs (lib.importJSON ./clan_cli/nix/allowed-programs.json) (
-    sshpass
+    name: pkgs.${name}
-    zbar
+  );
-    tor
+
-    age
+  runtimeDependencies = lib.attrValues runtimeDependenciesAsSet;
-    rsync
-    sops
-    git
-    mypy
-    qemu
-    e2fsprogs
-  ];
 
   testDependencies =
     runtimeDependencies
@@ -65,10 +51,6 @@ let
       pytest-timeout # Add timeouts to your tests
     ];
 
-  runtimeDependenciesAsSet = builtins.listToAttrs (
-    builtins.map (p: lib.nameValuePair (lib.getName p.name) p) runtimeDependencies
-  );
-
   # Setup Python environment with all dependencies for running tests
   pythonWithTestDeps = python3.withPackages (_ps: testDependencies);
 
@@ -106,13 +88,28 @@ python3.pkgs.buildPythonApplication {
   format = "pyproject";
 
   # Arguments for the wrapper to unset LD_LIBRARY_PATH to avoid glibc version issues
-  makeWrapperArgs = [
+  makeWrapperArgs =
-    "--unset LD_LIBRARY_PATH"
+    [
-    "--suffix"
+      "--unset LD_LIBRARY_PATH"
-    "PATH"
+
-    ":"
+      # TODO: remove gitMinimal here and use the one from runtimeDependencies
-    "${gitMinimal}/bin/git"
+      "--suffix"
-  ];
+      "PATH"
+      ":"
+      "${gitMinimal}/bin/git"
+    ]
+    # include selected runtime dependencies in the PATH
+    ++ lib.concatMap (p: [
+      "--prefix"
+      "PATH"
+      ":"
+      p
+    ]) includedRuntimeDeps
+    ++ [
+      "--set"
+      "CLAN_STATIC_PROGRAMS"
+      (lib.concatStringsSep ":" includedRuntimeDeps)
+    ];
 
   nativeBuildInputs = [
     setuptools
@@ -165,6 +162,7 @@ python3.pkgs.buildPythonApplication {
   passthru.testDependencies = testDependencies;
   passthru.pythonWithTestDeps = pythonWithTestDeps;
   passthru.runtimeDependencies = runtimeDependencies;
+  passthru.runtimeDependenciesAsSet = runtimeDependenciesAsSet;
 
   postInstall = ''
     cp -r ${nixpkgs'} $out/${python3.sitePackages}/clan_cli/nixpkgs

pkgs/clan-cli/flake-module.nix

@@ -40,13 +40,22 @@
     {
 
       devShells.clan-cli = pkgs.callPackage ./shell.nix {
-        inherit (self'.packages) clan-cli;
+        inherit (self'.packages) clan-cli clan-cli-full;
         inherit self';
       };
       packages = {
         clan-cli = pkgs.python3.pkgs.callPackage ./default.nix {
           inherit (inputs) nixpkgs;
           clan-core-path = clanCoreWithVendoredDeps;
+          includedRuntimeDeps = [
+            "age"
+            "git"
+          ];
+        };
+        clan-cli-full = pkgs.python3.pkgs.callPackage ./default.nix {
+          inherit (inputs) nixpkgs;
+          clan-core-path = clanCoreWithVendoredDeps;
+          includedRuntimeDeps = lib.importJSON ./clan_cli/nix/allowed-programs.json;
         };
         clan-cli-docs = pkgs.stdenv.mkDerivation {
           name = "clan-cli-docs";

pkgs/clan-cli/shell.nix

@@ -1,6 +1,8 @@
 {
+  lib,
   nix-unit,
   clan-cli,
+  clan-cli-full,
   mkShell,
   ruff,
   python3,
@@ -27,6 +29,10 @@ mkShell {
 
   PYTHONBREAKPOINT = "ipdb.set_trace";
 
+  CLAN_STATIC_PROGRAMS = lib.concatStringsSep ":" (
+    lib.attrNames clan-cli-full.passthru.runtimeDependenciesAsSet
+  );
+
   shellHook = ''
     export GIT_ROOT="$(git rev-parse --show-toplevel)"
     export PKG_ROOT="$GIT_ROOT/pkgs/clan-cli"

pkgs/clan-cli/tests/test_vars.py

@@ -40,9 +40,11 @@ def test_generate_public_var(
     )
     monkeypatch.chdir(flake.path)
     cli.run(["vars", "generate", "--flake", str(flake.path), "my_machine"])
-    assert (
+    secret_path = (
         flake.path / "machines" / "my_machine" / "vars" / "my_generator" / "my_secret"
-    ).is_file()
+    )
+    assert secret_path.is_file()
+    assert secret_path.read_text() == "hello\n"
 
 
 @pytest.mark.impure