Author SHA1 Message Date
Autumn Liu 5ef48168f4 fix bug
diff-pr / dix (pull_request) Canceled after 0s
flake-check / flake-check (pull_request) Canceled after 0s
lint / lint (pull_request) Canceled after 0s
2026-09-11 15:59:27 -05:00
Autumn Liu fa39169fee update 2026-09-11 15:59:27 -05:00
23 changed files with 221 additions and 582 deletions
+9 -12
View File
@@ -13,29 +13,26 @@ concurrency:
jobs: jobs:
dix: dix:
runs-on: nix runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v4 - uses: actions/checkout@v4
with: with:
ref: ${{ github.event.pull_request.head.sha }}
fetch-depth: 0 fetch-depth: 0
- name: merge base branch - uses: cachix/install-nix-action@v31
run: | with:
git config user.email "ci@localhost" extra_nix_config: |
git config user.name "CI" experimental-features = nix-command flakes
git fetch origin ${{ github.event.pull_request.base.ref }}
git merge --no-edit origin/${{ github.event.pull_request.base.ref }}
- name: worktree base for diff - name: worktree base for diff
run: git worktree add "$RUNNER_TEMP/base" "origin/${{ github.event.pull_request.base.ref }}" run: git worktree add "$RUNNER_TEMP/base" "${{ github.event.pull_request.base.sha }}"
- name: build closures and render diff - name: build closures and render diff
run: | run: |
nix run -L .#ci -- diff "$RUNNER_TEMP/base" . \ nix run .#ci -- diff "$RUNNER_TEMP/base" . \
"### System closure diff vs \`${{ github.event.pull_request.base.ref }}\`" \ "### System closure diff vs \`${{ github.event.pull_request.base.ref }}\`" \
> "$RUNNER_TEMP/comment.md" > "$RUNNER_TEMP/comment.md"
nix run -L .#ci -- inspect-diff "$RUNNER_TEMP/base" . \ nix run .#ci -- inspect-diff "$RUNNER_TEMP/base" . \
"### Inspection diff vs \`${{ github.event.pull_request.base.ref }}\`" \ "### Inspection diff vs \`${{ github.event.pull_request.base.ref }}\`" \
>> "$RUNNER_TEMP/comment.md" >> "$RUNNER_TEMP/comment.md"
@@ -45,4 +42,4 @@ jobs:
API: ${{ github.api_url }} API: ${{ github.api_url }}
REPO: ${{ github.repository }} REPO: ${{ github.repository }}
PR: ${{ github.event.pull_request.number }} PR: ${{ github.event.pull_request.number }}
run: nix run -L .#ci -- post-comment "<!-- dix-diff -->" "$RUNNER_TEMP/comment.md" run: nix run .#ci -- post-comment "<!-- dix-diff -->" "$RUNNER_TEMP/comment.md"
+8 -3
View File
@@ -9,12 +9,17 @@ permissions:
jobs: jobs:
dix: dix:
runs-on: nix runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v4 - uses: actions/checkout@v4
with: with:
fetch-depth: 0 fetch-depth: 0
- uses: cachix/install-nix-action@v31
with:
extra_nix_config: |
experimental-features = nix-command flakes
- name: diff latest tag against HEAD - name: diff latest tag against HEAD
run: | run: |
tag=$(git tag --sort=-creatordate | head -n1) tag=$(git tag --sort=-creatordate | head -n1)
@@ -25,8 +30,8 @@ jobs:
git worktree add "$RUNNER_TEMP/old" "$tag" git worktree add "$RUNNER_TEMP/old" "$tag"
head=$(git rev-parse --short HEAD) head=$(git rev-parse --short HEAD)
{ {
nix run -L .#ci -- diff "$RUNNER_TEMP/old" . \ nix run .#ci -- diff "$RUNNER_TEMP/old" . \
"# System closure diff: \`$tag\` -> \`$head\`" "# System closure diff: \`$tag\` -> \`$head\`"
nix run -L .#ci -- inspect-diff "$RUNNER_TEMP/old" . \ nix run .#ci -- inspect-diff "$RUNNER_TEMP/old" . \
"# Inspection diff: \`$tag\` -> \`$head\`" "# Inspection diff: \`$tag\` -> \`$head\`"
} | tee -a "$GITHUB_STEP_SUMMARY" } | tee -a "$GITHUB_STEP_SUMMARY"
+6 -1
View File
@@ -14,8 +14,13 @@ concurrency:
jobs: jobs:
flake-check: flake-check:
runs-on: nix runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v4 - uses: actions/checkout@v4
- uses: cachix/install-nix-action@v31
with:
extra_nix_config: |
experimental-features = nix-command flakes
- run: nix flake check -L - run: nix flake check -L
+13 -6
View File
@@ -5,22 +5,29 @@ on:
- cron: "17 4 * * *" - cron: "17 4 * * *"
workflow_dispatch: workflow_dispatch:
permissions:
contents: write
pull-requests: write
jobs: jobs:
update: update:
runs-on: nix runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v4 - uses: actions/checkout@v4
with:
persist-credentials: false
- run: nix flake update -L - uses: cachix/install-nix-action@v31
with:
extra_nix_config: |
experimental-features = nix-command flakes
- run: nix flake update
- name: open/update PR - name: open/update PR
env: env:
GH_TOKEN: ${{ secrets.BOT_TOKEN }} GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
API: ${{ github.api_url }} API: ${{ github.api_url }}
REPO: ${{ github.repository }} REPO: ${{ github.repository }}
run: | run: |
printf 'Automated `nix flake update`.\n' > "$RUNNER_TEMP/body.md" printf 'Automated `nix flake update`.\n' > "$RUNNER_TEMP/body.md"
nix run -L .#ci -- open-pr \ nix run .#ci -- open-pr \
flake-update "$GITHUB_REF_NAME" "flake.lock: update inputs" "$RUNNER_TEMP/body.md" automated flake-update "$GITHUB_REF_NAME" "flake.lock: update inputs" "$RUNNER_TEMP/body.md" automated
+16 -11
View File
@@ -15,22 +15,27 @@ concurrency:
jobs: jobs:
lint: lint:
runs-on: nix runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v4 - uses: actions/checkout@v4
- name: run linters - uses: cachix/install-nix-action@v31
run: nix run -L .#ci -- lint . "$RUNNER_TEMP/findings" with:
extra_nix_config: |
experimental-features = nix-command flakes
- name: report findings - name: pick reporter
if: always()
env:
REVIEWDOG_GITEA_API_TOKEN: ${{ secrets.GITEA_TOKEN }}
GITEA_ADDRESS: ${{ github.server_url }}
run: | run: |
if [ "${{ github.event_name }}" = pull_request ]; then if [ "${{ github.event_name }}" = pull_request ]; then
nix run -L .#ci -- lint-report gitea-pr-review "$RUNNER_TEMP/findings" echo "REPORTER=github-pr-review" >> "$GITHUB_ENV"
else else
nix run -L .#ci -- lint-summary "$RUNNER_TEMP/findings" \ echo "REPORTER=local" >> "$GITHUB_ENV"
| tee -a "$GITHUB_STEP_SUMMARY"
fi fi
- name: run linters
run: nix run .#ci -- lint . "$RUNNER_TEMP/findings"
- name: report findings
env:
REVIEWDOG_GITHUB_API_TOKEN: ${{ secrets.GITHUB_TOKEN }}
run: nix run .#ci -- lint-report "$REPORTER" "$RUNNER_TEMP/findings"
+13 -4
View File
@@ -5,15 +5,24 @@ on:
- cron: "0 6 * * 1" - cron: "0 6 * * 1"
workflow_dispatch: workflow_dispatch:
permissions:
contents: read
issues: write
jobs: jobs:
scan: scan:
runs-on: nix runs-on: ubuntu-latest
steps: steps:
- uses: actions/checkout@v4 - uses: actions/checkout@v4
- uses: cachix/install-nix-action@v31
with:
extra_nix_config: |
experimental-features = nix-command flakes
- name: scan host closures - name: scan host closures
id: scan id: scan
run: echo "count=$(nix run -L .#ci -- vulnix . "$RUNNER_TEMP/issue.md")" >> "$GITHUB_OUTPUT" run: echo "count=$(nix run .#ci -- vulnix . "$RUNNER_TEMP/issue.md")" >> "$GITHUB_OUTPUT"
- name: file/update issue - name: file/update issue
if: steps.scan.outputs.count != '0' if: steps.scan.outputs.count != '0'
@@ -21,7 +30,7 @@ jobs:
GH_TOKEN: ${{ secrets.GITHUB_TOKEN }} GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
API: ${{ github.api_url }} API: ${{ github.api_url }}
REPO: ${{ github.repository }} REPO: ${{ github.repository }}
run: 'nix run -L .#ci -- upsert-issue vulnix "vulnix: known vulnerabilities in system closure" "$RUNNER_TEMP/issue.md"' run: nix run .#ci -- upsert-issue vulnix "vulnix: known vulnerabilities in system closure" "$RUNNER_TEMP/issue.md"
- name: close resolved issue - name: close resolved issue
if: steps.scan.outputs.count == '0' if: steps.scan.outputs.count == '0'
@@ -29,4 +38,4 @@ jobs:
GH_TOKEN: ${{ secrets.GITHUB_TOKEN }} GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
API: ${{ github.api_url }} API: ${{ github.api_url }}
REPO: ${{ github.repository }} REPO: ${{ github.repository }}
run: nix run -L .#ci -- close-issue vulnix run: nix run .#ci -- close-issue vulnix
-8
View File
@@ -1,17 +1,9 @@
{ lib, pkgs }: { lib, pkgs }:
let
# vulnix's bundled nix-2.34 broke its own --experimental-features detection
nixConf = pkgs.writeText "ci-nix.conf" "experimental-features = nix-command flakes";
in
# tools must track ci.py's subprocess calls; nix stays ambient (uses the # tools must track ci.py's subprocess calls; nix stays ambient (uses the
# runner's own nix, not a pinned one). # runner's own nix, not a pinned one).
pkgs.writers.writePython3Bin "ci" { pkgs.writers.writePython3Bin "ci" {
flakeIgnore = [ "E501" ]; flakeIgnore = [ "E501" ];
libraries = [ pkgs.python3Packages.subprocess-tee ];
makeWrapperArgs = [ makeWrapperArgs = [
"--set-default"
"NIX_USER_CONF_FILES"
(toString nixConf)
"--prefix" "--prefix"
"PATH" "PATH"
":" ":"
+13 -89
View File
@@ -6,9 +6,7 @@ import json
import os import os
import re import re
import subprocess import subprocess
import subprocess_tee
import sys import sys
import urllib.error
import urllib.request import urllib.request
from collections import Counter from collections import Counter
from pathlib import Path from pathlib import Path
@@ -19,18 +17,13 @@ def run(*args, **kw):
def nix(*args): def nix(*args):
# tee to stderr - stdout leaks into GITHUB_OUTPUT $() captures return run("nix", "--extra-experimental-features", "nix-command flakes", *args, check=True, capture_output=True).stdout
return subprocess_tee.run(("nix", "--extra-experimental-features", "nix-command flakes", "-L", *args), check=True, text=True, stdout=sys.stderr).stdout
def git(*args, check=True): def git(*args, check=True):
return run("git", *args, check=check, capture_output=True) return run("git", *args, check=check, capture_output=True)
class GiteaError(Exception):
pass
def gitea(method, path, body=None): def gitea(method, path, body=None):
url = f'{os.environ["API"]}/repos/{os.environ["REPO"]}{path}' url = f'{os.environ["API"]}/repos/{os.environ["REPO"]}{path}'
data = json.dumps(body).encode() if body is not None else None data = json.dumps(body).encode() if body is not None else None
@@ -38,20 +31,13 @@ def gitea(method, path, body=None):
req.add_header("Authorization", f'token {os.environ["GH_TOKEN"]}') req.add_header("Authorization", f'token {os.environ["GH_TOKEN"]}')
if data is not None: if data is not None:
req.add_header("Content-Type", "application/json") req.add_header("Content-Type", "application/json")
try: with urllib.request.urlopen(req) as resp:
with urllib.request.urlopen(req) as resp: raw = resp.read()
raw = resp.read()
except urllib.error.HTTPError as e:
try:
detail = json.loads(e.read()).get("message", e.reason)
except (json.JSONDecodeError, UnicodeDecodeError):
detail = e.reason
raise GiteaError(f"{method} {path}: {e.code} {detail}") from None
return json.loads(raw) if raw else None return json.loads(raw) if raw else None
def find_open_issue(label): def find_open_issue(label):
issues = gitea("GET", f"/issues?state=open&type=issues&labels={label}") issues = gitea("GET", f"/issues?state=open&labels={label}")
return issues[0] if issues else None return issues[0] if issues else None
@@ -248,7 +234,7 @@ def format_vulnix(vulns):
for v in vulns: for v in vulns:
for cve in v["affected_by"]: for cve in v["affected_by"]:
score = v.get("cvssv3_basescore", {}).get(cve) score = v.get("cvssv3_basescore", {}).get(cve)
desc = v.get("description", {}).get(cve, "").replace("\n", " ").replace("|", "∣") desc = v.get("description", {}).get(cve, "")
if len(desc) > 120: if len(desc) > 120:
desc = desc[:117] + "..." desc = desc[:117] + "..."
rows.append((v["pname"], v["version"], cve, score, desc)) rows.append((v["pname"], v["version"], cve, score, desc))
@@ -376,63 +362,10 @@ def lint_report(args):
codes = [reviewdog(f"{args.dir}/{name}", flags) codes = [reviewdog(f"{args.dir}/{name}", flags)
for name, flags in LINTERS for name, flags in LINTERS
if os.path.isfile(f"{args.dir}/{name}") and os.path.getsize(f"{args.dir}/{name}") > 0] if os.path.getsize(f"{args.dir}/{name}") > 0]
sys.exit(1 if any(codes) else 0) sys.exit(1 if any(codes) else 0)
def has_findings(path):
return os.path.isfile(path) and os.path.getsize(path) > 0
def fmt_rdjsonl(path):
lines = []
with open(path) as f:
for raw in f:
rec = json.loads(raw)
loc = rec["location"]
r = loc.get("range", {}).get("start")
pos = f"{loc['path']}:{r['line']}:{r['column']}" if r else loc["path"]
lines.append(f"- `{pos}`: {rec['message']}")
return "\n".join(lines)
def fmt_errfmt(path):
lines = []
with open(path) as f:
for raw in f:
parts = raw.strip().split(">", 1)
if len(parts) == 2:
lines.append(f"- `{parts[0]}:{parts[1].split(':', 3)[-1].strip()}`" if ":" in parts[1] else f"- `{raw.strip()}`")
elif raw.strip():
lines.append(f"- `{raw.strip()}`")
return "\n".join(lines)
def lint_summary(args):
sections = []
d = args.dir
if has_findings(f"{d}/nixfmt.diff"):
with open(f"{d}/nixfmt.diff") as f:
sections.append(f"## nixfmt\n\n```diff\n{f.read().rstrip()}\n```")
if has_findings(f"{d}/statix.errfmt"):
sections.append(f"## statix\n\n{fmt_errfmt(f'{d}/statix.errfmt')}")
if has_findings(f"{d}/deadnix.rdjsonl"):
sections.append(f"## deadnix\n\n{fmt_rdjsonl(f'{d}/deadnix.rdjsonl')}")
if has_findings(f"{d}/cycles.rdjsonl"):
sections.append(f"## systemd ordering cycles\n\n{fmt_rdjsonl(f'{d}/cycles.rdjsonl')}")
if sections:
print("\n\n".join(["# Lint findings"] + sections))
sys.exit(1)
else:
print("No lint findings.")
sys.exit(0)
def post_comment(args): def post_comment(args):
body = args.marker + "\n" + Path(args.body_file).read_text() body = args.marker + "\n" + Path(args.body_file).read_text()
pr = os.environ["PR"] pr = os.environ["PR"]
@@ -475,24 +408,16 @@ def open_pr(args):
host = os.environ["API"].removesuffix("/api/v1") host = os.environ["API"].removesuffix("/api/v1")
auth = base64.b64encode(f'token:{os.environ["GH_TOKEN"]}'.encode()).decode() auth = base64.b64encode(f'token:{os.environ["GH_TOKEN"]}'.encode()).decode()
push = git("-c", f"http.extraHeader=Authorization: Basic {auth}", git("-c", f"http.extraHeader=Authorization: Basic {auth}",
"push", "-f", f'{host}/{os.environ["REPO"]}.git', f"HEAD:{args.branch}", "push", "-f", f'{host}/{os.environ["REPO"]}.git', f"HEAD:{args.branch}")
check=False)
if push.returncode != 0:
raise RuntimeError(f"git push failed:\n{push.stderr}")
pulls = gitea("GET", f"/pulls?state=open&base_branch={args.base}") owner = os.environ["REPO"].split("/")[0]
existing = next((pr for pr in pulls if pr["head"]["ref"] == args.branch), None) if gitea("GET", f"/pulls?state=open&head={owner}:{args.branch}"):
if existing:
print(f"PR #{existing['number']} already open, pushed update")
return return
labels = [label_id(args.label)] if args.label else [] labels = [label_id(args.label)] if args.label else []
pr = gitea("POST", "/pulls", gitea("POST", "/pulls",
{"title": args.title, "head": args.branch, "base": args.base, {"title": args.title, "head": args.branch, "base": args.base,
"body": Path(args.body_file).read_text(), "labels": labels}) "body": Path(args.body_file).read_text(), "labels": labels})
if not pr or "number" not in pr:
raise GiteaError(f"POST /pulls: unexpected response: {json.dumps(pr)}")
print(f"opened PR #{pr['number']}")
def main(): def main():
@@ -513,7 +438,6 @@ def main():
command("vulnix", vulnix, "ref", "body_out") command("vulnix", vulnix, "ref", "body_out")
command("lint", lint, "target", "out") command("lint", lint, "target", "out")
command("lint-report", lint_report, "reporter", "dir") command("lint-report", lint_report, "reporter", "dir")
command("lint-summary", lint_summary, "dir")
command("post-comment", post_comment, "marker", "body_file") command("post-comment", post_comment, "marker", "body_file")
command("upsert-issue", upsert_issue, "label", "title", "body_file") command("upsert-issue", upsert_issue, "label", "title", "body_file")
command("close-issue", close_issue, "label") command("close-issue", close_issue, "label")
-17
View File
@@ -4,28 +4,12 @@
lib, lib,
hostInfo, hostInfo,
customPkgs, customPkgs,
flakeRev,
deployLabel,
... ...
}: }:
let let
inherit (hostInfo) paths; inherit (hostInfo) paths;
in in
{ {
imports = [ ./modules/autodeploy.nix ];
services.server-autodeploy = {
enable = true;
giteaUrl = "https://git.floweytf.com/";
giteaRepo = "server/server-config";
tokenFile = "${hostInfo.paths.secrets}/gitea-autodeploy-token";
allowedSigners = [
"flowey@arch namespaces=\"git\" ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAIPaGpTX3EzfezVc2nl3MgsKVamYYP2h2VJaRny8pZkvi"
];
stateDir = hostInfo.paths.config;
repoOwner = "server";
};
assertions = assertions =
let let
isMounted = isMounted =
@@ -63,7 +47,6 @@ in
time.timeZone = "UTC"; time.timeZone = "UTC";
system.stateVersion = "26.05"; system.stateVersion = "26.05";
system.nixos.label = if deployLabel != null then deployLabel else flakeRev;
nix = { nix = {
settings = { settings = {
+1 -1
View File
@@ -381,6 +381,6 @@ let
}; };
}; };
}; };
inherit (c) hostAddr; hostAddr = c.hostAddr;
in in
c c
+111 -166
View File
@@ -8,9 +8,6 @@ let
inherit (dsl) mkContainer mkVm; inherit (dsl) mkContainer mkVm;
inherit (hostInfo.paths) data secrets; inherit (hostInfo.paths) data secrets;
pubSshPort = 23;
intSshPort = 23 + 8000;
ciRunnerData = "${data}/web/git-ci-runner"; ciRunnerData = "${data}/web/git-ci-runner";
ciRunnerSecrets = "${secrets}/ci-runner"; ciRunnerSecrets = "${secrets}/ci-runner";
in in
@@ -20,8 +17,8 @@ in
net.access = [ { to = "@internet"; } ]; net.access = [ { to = "@internet"; } ];
net.forward.tcp = [ net.forward.tcp = [
{ {
host = pubSshPort; host = 23;
container = intSshPort; container = 8023;
} }
]; ];
svc.autoStart = true; svc.autoStart = true;
@@ -41,8 +38,7 @@ in
ROOT_URL = "https://git.floweytf.com/"; ROOT_URL = "https://git.floweytf.com/";
START_SSH_SERVER = true; START_SSH_SERVER = true;
BUILTIN_SSH_SERVER_USER = "git"; BUILTIN_SSH_SERVER_USER = "git";
SSH_PORT = pubSshPort; SSH_PORT = 8023;
SSH_LISTEN_PORT = intSshPort;
}; };
service.DISABLE_REGISTRATION = true; service.DISABLE_REGISTRATION = true;
}; };
@@ -55,179 +51,128 @@ in
net.expose.tcp = [ 3000 ]; net.expose.tcp = [ 3000 ];
}; };
ci-runner = ci-runner = mkVm {
mkVm { name = "ci-runner";
name = "ci-runner"; net.access = [
includedInTests = false; {
net.access = [ to = "git";
{ tcp = [ 3000 ];
to = "git"; }
tcp = [ 3000 ]; { to = "@internet"; }
} ];
{ to = "@internet"; } svc.autoStart = true;
]; resources.cpu = 4;
svc.autoStart = true; resources.mem = "8G";
resources.cpu = 4; resources.fs = [
resources.mem = "32G"; {
resources.fs = [ proto = "virtiofs";
{ tag = "nix-rw-store";
proto = "virtiofs"; source = "${ciRunnerData}/nix-rw-store";
tag = "nix-rw-store"; mountPoint = "/nix/.rw-store";
source = "${ciRunnerData}/nix-rw-store"; }
mountPoint = "/nix/.rw-store"; {
} proto = "virtiofs";
{ tag = "docker-data";
proto = "virtiofs"; source = "${ciRunnerData}/docker";
tag = "nix-db"; mountPoint = "/var/lib/docker";
source = "${ciRunnerData}/nix-db"; }
mountPoint = "/nix/var/nix/db"; {
} proto = "virtiofs";
{ tag = "runner-state";
proto = "virtiofs"; source = "${ciRunnerData}/runner-state";
tag = "docker-data"; mountPoint = "/var/lib/gitea-runner";
source = "${ciRunnerData}/docker"; }
mountPoint = "/var/lib/docker"; {
} proto = "virtiofs";
{ tag = "runner-token";
proto = "virtiofs"; source = ciRunnerSecrets;
tag = "runner-state"; mountPoint = "/run/ci-runner-secrets";
source = "${ciRunnerData}/runner-state"; readOnly = true;
mountPoint = "/var/lib/private/gitea-runner"; }
} ];
{ guestConfig =
proto = "virtiofs"; {
tag = "runner-token"; pkgs,
source = ciRunnerSecrets; utils,
mountPoint = "/run/ci-runner-secrets"; lib,
readOnly = true; ...
} }:
{ let
proto = "virtiofs"; runnerInstanceName = "ci-runner";
tag = "tmp";
source = "/tmp";
mountPoint = "/tmp";
}
];
guestConfig =
{
pkgs,
utils,
lib,
...
}:
let
runnerInstanceName = "ci-runner";
ciJobContents = with pkgs; [ ciJobImage = pkgs.dockerTools.buildLayeredImage {
name = "ci-job-image";
tag = "latest";
contents = with pkgs; [
bashInteractive bashInteractive
coreutils coreutils
gitMinimal gitMinimal
nixVersions.latest nixVersions.latest
nodejs nodejs
cacert cacert
(writeTextDir "etc/nix/nix.conf" "experimental-features = nix-command flakes\n")
]; ];
config = {
Cmd = [ "/bin/sh" ];
Env = [
"SSL_CERT_FILE=${pkgs.cacert}/etc/ssl/certs/ca-bundle.crt"
"NIX_SSL_CERT_FILE=${pkgs.cacert}/etc/ssl/certs/ca-bundle.crt"
"NIX_REMOTE=daemon"
];
};
};
in
{
boot.kernelModules = [ "kvm-intel" ];
boot.extraModprobeConfig = "options kvm_intel nested=1";
microvm.writableStoreOverlay = "/nix/.rw-store";
nix.settings = {
experimental-features = [
"nix-command"
"flakes"
];
max-jobs = "auto";
};
ciJobImage = pkgs.dockerTools.buildLayeredImage { nix.gc = {
name = "ci-job-image"; automatic = true;
tag = "latest"; dates = "daily";
contents = ciJobContents; options = "--delete-older-than 14d";
config = { };
Cmd = [ "/bin/sh" ]; # nix.optimise.automatic = true; - doesn't work with microvm.writableStoreOverlay
Env = [
"PATH=${lib.makeBinPath ciJobContents}"
"SSL_CERT_FILE=${pkgs.cacert}/etc/ssl/certs/ca-bundle.crt"
"NIX_SSL_CERT_FILE=${pkgs.cacert}/etc/ssl/certs/ca-bundle.crt"
"NIX_REMOTE=daemon"
];
};
};
in
{
boot.kernelModules = [ "kvm-intel" ];
boot.extraModprobeConfig = "options kvm_intel nested=1";
# volume-mounted into CI containers; must be in VM's store so virtualisation.docker.enable = true;
# image symlinks (/bin/node etc.) resolve through the mount
system.extraDependencies = ciJobContents;
microvm.writableStoreOverlay = "/nix/.rw-store"; systemd.services.load-ci-job-image = {
description = "Load the CI job Docker image";
wantedBy = [ "multi-user.target" ];
after = [ "docker.service" ];
requires = [ "docker.service" ];
before = [ "gitea-runner-${utils.escapeSystemdPath runnerInstanceName}.service" ];
serviceConfig = {
Type = "oneshot";
RemainAfterExit = true;
ExecStart = "${lib.getExe' pkgs.docker "docker"} load -i ${ciJobImage}";
};
};
nix.settings = { services.gitea-actions-runner.instances.${runnerInstanceName} = {
experimental-features = [ enable = true;
"nix-command" name = runnerInstanceName;
"flakes" url = "http://git:3000/";
tokenFile = "/run/ci-runner-secrets/token";
labels = [
"nix:docker://ci-job-image:latest"
];
settings.container = {
options = "--device=/dev/kvm --volume=/nix/store:/nix/store:ro --volume=/nix/var/nix/daemon-socket:/nix/var/nix/daemon-socket";
valid_volumes = [
"/nix/store"
"/nix/var/nix/daemon-socket"
]; ];
max-jobs = "auto";
substituters = [ "https://microvm.cachix.org" ];
trusted-public-keys = [ "microvm.cachix.org-1:oXnBc6hRE3eX5rSYdRyMYXnfzcCxC7yKPTbZXALsqys=" ];
};
nix.settings = {
min-free = 5 * 1024 * 1024 * 1024;
max-free = 10 * 1024 * 1024 * 1024;
};
# nix.optimise.automatic = true; - doesn't work with microvm.writableStoreOverlay
services.openssh = {
enable = true;
settings = {
PermitRootLogin = "yes";
PermitEmptyPasswords = "yes";
};
};
users.users.root.initialHashedPassword = "";
services.journald.extraConfig = "ForwardToConsole=yes";
virtualisation.containerd.enable = true;
virtualisation.containerd.settings.plugins."io.containerd.snapshotter.v1.overlayfs".mount_options =
[ "userxattr" ];
virtualisation.docker.enable = true;
virtualisation.docker.extraOptions = "--containerd /run/containerd/containerd.sock";
virtualisation.docker.daemon.settings.exec-opts = [ "native.cgroupdriver=cgroupfs" ];
systemd.services.docker.wants = [ "containerd.service" ];
systemd.services.docker.after = [ "containerd.service" ];
systemd.services.load-ci-job-image = {
description = "Load the CI job Docker image";
wantedBy = [ "multi-user.target" ];
after = [ "docker.service" ];
requires = [ "docker.service" ];
before = [ "gitea-runner-${utils.escapeSystemdPath runnerInstanceName}.service" ];
serviceConfig = {
Type = "oneshot";
RemainAfterExit = true;
ExecStart = "${lib.getExe' pkgs.docker "docker"} load -i ${ciJobImage}";
};
};
services.gitea-actions-runner.instances.${runnerInstanceName} = {
enable = true;
name = runnerInstanceName;
url = "http://git:3000/";
tokenFile = "/run/ci-runner-secrets/token";
labels = [
"nix:docker://ci-job-image:latest"
];
settings.container = {
options = "--device=/dev/kvm --volume=/nix/store:/nix/store:ro --volume=/nix/var/nix/daemon-socket:/nix/var/nix/daemon-socket";
valid_volumes = [
"/nix/store"
"/nix/var/nix/daemon-socket"
];
};
}; };
}; };
}
// {
hostConfig = {
systemd.tmpfiles.rules = [
"d ${ciRunnerData}/nix-rw-store 0755 server server -"
"d ${ciRunnerData}/nix-db 0755 server server -"
"d ${ciRunnerData}/docker 0755 server server -"
"d ${ciRunnerData}/runner-state 0755 server server -"
];
}; };
}; };
} }
-2
View File
@@ -146,8 +146,6 @@ let
in in
mkContainer { mkContainer {
inherit name; inherit name;
includedInTests = false; # TODO: fixme, clearly mail is flakey
net.access = [ { to = "@internet"; } ]; net.access = [ { to = "@internet"; } ];
svc.autoStart = true; svc.autoStart = true;
net.forward.tcp = [ net.forward.tcp = [
+1 -1
View File
@@ -210,6 +210,6 @@ let
}; };
inherit (setup) containerConfig; inherit (setup) containerConfig;
}; };
inherit (c) hostAddr; hostAddr = c.hostAddr;
in in
c c
+1 -5
View File
@@ -61,16 +61,12 @@ let
net ? { }, net ? { },
resources ? { }, resources ? { },
traits ? [ ], traits ? [ ],
isolation ? { },
}: }:
mkContainer { mkContainer {
inherit name; inherit name;
inherit net resources; inherit net resources;
svc.autoStart = true; svc.autoStart = true;
isolation = { isolation.nixDaemon = nixDaemon;
inherit nixDaemon;
}
// isolation;
traits = [ sshTrait ] ++ traits; traits = [ sshTrait ] ++ traits;
packages = with pkgs; [ tmux ] ++ packages; packages = with pkgs; [ tmux ] ++ packages;
miscProperties = self._sshpiperRegister routingInfo; miscProperties = self._sshpiperRegister routingInfo;
+9 -20
View File
@@ -222,15 +222,13 @@ rec {
: Bind mounts, keyed by mount point. : Bind mounts, keyed by mount point.
`resources.devices` `resources.devices`
: Host device nodes to expose, as paths. Bound into the container at the : Host device nodes to expose, as paths, added to the unit's
same path and added to the unit's `DeviceAllow=` - the cgroup `DeviceAllow=`. nspawn populates a handful of privileged devices
permission alone doesn't get you a working node (nothing can `mknod` a (`/dev/kvm`, `/dev/net/tun`, ...) into the container's own `/dev` once
device inside a user namespace), and the bind alone leaves the cgroup the cgroup allows it, and silently skips ones the host doesn't have -
denying `open()`, so both are needed. The bind is unconditional, so no `resources.fs` bind mount needed. Nodes keep their host ownership,
the device must actually exist on whatever host runs the container. so a consumer inside needs `isolation.privateUsers = "identity"` for
Nodes keep their host ownership, so a consumer inside needs the owning gid to mean anything.
`isolation.privateUsers = "identity"` for the owning gid to mean
anything.
`isolation.nixDaemon` `isolation.nixDaemon`
: Whether the Nix daemon and CLI are available inside the container. : Whether the Nix daemon and CLI are available inside the container.
@@ -289,7 +287,7 @@ rec {
allBindMounts = builtins.foldl' (acc: t: acc // (t.resources.fs or { })) { } traits // bindMounts; allBindMounts = builtins.foldl' (acc: t: acc // (t.resources.fs or { })) { } traits // bindMounts;
userModules = map mkUser (lib.concatMap (t: t.users or [ ]) traits ++ users); userModules = map mkUser (lib.concatMap (t: t.users or [ ]) traits ++ users);
allPorts = ports ++ map (p: (normalizePort p).container) hostPorts; allPorts = ports ++ map (p: (normalizePort p).container) hostPorts;
useIdmap = privateUsers == "pick" || (builtins.isInt privateUsers && privateUsers > 0); useIdmap = privateUsers != "no";
bindMountExtraFlags = lib.mapAttrsToList ( bindMountExtraFlags = lib.mapAttrsToList (
mountPoint: bm: mountPoint: bm:
(if bm.isReadOnly then "--bind-ro=" else "--bind=") (if bm.isReadOnly then "--bind-ro=" else "--bind=")
@@ -297,10 +295,6 @@ rec {
+ lib.optionalString useIdmap ":idmap" + lib.optionalString useIdmap ":idmap"
) allBindMounts; ) allBindMounts;
bindMountHostPaths = map (bm: bm.hostPath) (lib.attrValues allBindMounts); bindMountHostPaths = map (bm: bm.hostPath) (lib.attrValues allBindMounts);
# DeviceAllow= alone only grants cgroup permission - nspawn can't
# mknod a device node inside a user namespace, so the node still
# needs an explicit bind from the host.
deviceFlags = map (d: "--bind=${d}") devices;
inherit (deriveIdentity ifPrefix.nspawn name) inherit (deriveIdentity ifPrefix.nspawn name)
iface iface
mac mac
@@ -387,7 +381,7 @@ rec {
nixosContainer = { nixosContainer = {
inherit autoStart privateUsers; inherit autoStart privateUsers;
bindMounts = { }; bindMounts = { };
extraFlags = bindMountExtraFlags ++ deviceFlags; extraFlags = bindMountExtraFlags;
privateNetwork = true; privateNetwork = true;
extraVeths = linkVeths; extraVeths = linkVeths;
config = config =
@@ -571,11 +565,6 @@ rec {
Destination = "0.0.0.0/0"; Destination = "0.0.0.0/0";
Gateway = hostAddr; Gateway = hostAddr;
}; };
networkConfig.DNS = [ hostAddr ];
networkConfig.Domains = [
"~."
"containers"
];
linkConfig.RequiredForOnline = if allowInternet then "routable" else "degraded"; linkConfig.RequiredForOnline = if allowInternet then "routable" else "degraded";
}; };
networking.enableIPv6 = false; networking.enableIPv6 = false;
Generated
-13
View File
@@ -1,17 +1,5 @@
{ {
"nodes": { "nodes": {
"deploy-label": {
"flake": false,
"locked": {
"path": "./misc/deploy-label",
"type": "path"
},
"original": {
"path": "./misc/deploy-label",
"type": "path"
},
"parent": []
},
"flake-utils": { "flake-utils": {
"inputs": { "inputs": {
"systems": "systems" "systems": "systems"
@@ -91,7 +79,6 @@
}, },
"root": { "root": {
"inputs": { "inputs": {
"deploy-label": "deploy-label",
"microvm": "microvm", "microvm": "microvm",
"mtce": "mtce", "mtce": "mtce",
"nixpkgs": "nixpkgs" "nixpkgs": "nixpkgs"
+6 -20
View File
@@ -7,17 +7,13 @@
mtce.inputs.nixpkgs.follows = "nixpkgs"; mtce.inputs.nixpkgs.follows = "nixpkgs";
microvm.url = "github:microvm-nix/microvm.nix"; microvm.url = "github:microvm-nix/microvm.nix";
microvm.inputs.nixpkgs.follows = "nixpkgs"; microvm.inputs.nixpkgs.follows = "nixpkgs";
deploy-label.url = "path:./misc/deploy-label";
deploy-label.flake = false;
}; };
outputs = outputs =
{ {
self,
nixpkgs, nixpkgs,
mtce, mtce,
microvm, microvm,
deploy-label,
... ...
}: }:
let let
@@ -25,14 +21,6 @@
inherit (nixpkgs) lib; inherit (nixpkgs) lib;
pkgs = import nixpkgs { inherit system; }; pkgs = import nixpkgs { inherit system; };
flakeRev = self.shortRev or self.dirtyShortRev or "unknown";
deployLabel =
let
labelFile = "${deploy-label}/label";
raw = lib.removeSuffix "\n" (builtins.readFile labelFile);
in
if raw != "" then raw else null;
customPkgs = { customPkgs = {
hopper-rs = pkgs.callPackage ./packages/hopper-rs.nix { }; hopper-rs = pkgs.callPackage ./packages/hopper-rs.nix { };
sshpiper = pkgs.callPackage ./packages/sshpiper.nix { }; sshpiper = pkgs.callPackage ./packages/sshpiper.nix { };
@@ -41,7 +29,6 @@
server-rebuild = pkgs.callPackage ./packages/server-rebuild.nix { }; server-rebuild = pkgs.callPackage ./packages/server-rebuild.nix { };
server-status = pkgs.callPackage ./packages/server-status.nix { }; server-status = pkgs.callPackage ./packages/server-status.nix { };
server-kexec = pkgs.callPackage ./packages/server-kexec.nix { }; server-kexec = pkgs.callPackage ./packages/server-kexec.nix { };
server-autodeploy = pkgs.callPackage ./packages/server-autodeploy.nix { };
}; };
ci = import ./ci.nix { inherit lib pkgs; }; ci = import ./ci.nix { inherit lib pkgs; };
@@ -59,13 +46,12 @@
server = "/persist/@containers"; server = "/persist/@containers";
data = "/persist/@containers/data"; data = "/persist/@containers/data";
secrets = "/persist/@secrets/"; secrets = "/persist/@secrets/";
config = "/persist/@config/";
}; };
}; };
specialArgsFor = hostName: { specialArgsFor = hostName: {
hostInfo = hostInfoFor hostName; hostInfo = hostInfoFor hostName;
inherit inputs customPkgs flakeRev deployLabel; inherit inputs customPkgs;
}; };
hostDefFor = hostDefFor =
@@ -143,10 +129,11 @@
{ {
nixosConfigurations = lib.mapAttrs (_: host: host.hostCfg) allHosts; nixosConfigurations = lib.mapAttrs (_: host: host.hostCfg) allHosts;
inspect = lib.mapAttrs ( inspect = lib.mapAttrs
name: host: (name: host:
pkgs.writeText "inspect-${name}.json" (builtins.toJSON (introspect.hostReport { inherit host; })) pkgs.writeText "inspect-${name}.json"
) allHosts; (builtins.toJSON (introspect.hostReport { inherit host; })))
allHosts;
packages.${system} = customPkgs // { packages.${system} = customPkgs // {
inherit ci; inherit ci;
@@ -161,7 +148,6 @@
server-rebuild server-rebuild
server-status server-status
server-kexec server-kexec
server-autodeploy
; ;
}; };
}; };
+1 -1
View File
@@ -1,7 +1,7 @@
_: { _: {
# New host: copy this file to hosts/<name>.nix. Replace fileSystems/boot # New host: copy this file to hosts/<name>.nix. Replace fileSystems/boot
# below with the real hardware (see hosts/server-n0.nix for a bigger # below with the real hardware (see hosts/server-n0.nix for a bigger
# example). Add a containers/<name>/ directory for its containers. # example). Add a containers/<name>/ directory for its containers.
module = module =
{ lib, hostInfo, ... }: { lib, hostInfo, ... }:
View File
-96
View File
@@ -1,96 +0,0 @@
{
config,
lib,
pkgs,
customPkgs,
...
}:
let
cfg = config.services.server-autodeploy;
in
{
options.services.server-autodeploy = {
enable = lib.mkEnableOption "automatic deployment from signed git tags";
interval = lib.mkOption {
type = lib.types.str;
default = "15min";
};
branch = lib.mkOption {
type = lib.types.str;
default = "master";
};
giteaUrl = lib.mkOption {
type = lib.types.str;
};
giteaRepo = lib.mkOption {
type = lib.types.str;
};
tokenFile = lib.mkOption {
type = lib.types.str;
};
allowedSigners = lib.mkOption {
type = lib.types.listOf lib.types.str;
default = [ ];
};
repoOwner = lib.mkOption {
type = lib.types.str;
description = "User that owns the configuration checkout";
};
stateDir = lib.mkOption {
type = lib.types.str;
};
hostname = lib.mkOption {
type = lib.types.str;
default = config.networking.hostName;
};
};
config = lib.mkIf cfg.enable {
systemd.services.server-autodeploy = {
description = "Deploy latest signed tag";
after = [ "network-online.target" ];
wants = [ "network-online.target" ];
environment = {
GITEA_URL = cfg.giteaUrl;
GITEA_REPO = cfg.giteaRepo;
TOKEN_FILE = cfg.tokenFile;
ALLOWED_SIGNERS = builtins.toFile "signers" (lib.join "\n" cfg.allowedSigners);
DEPLOY_BRANCH = cfg.branch;
STATE_DIR = cfg.stateDir;
REPO_DIR = "/persist/@configuration";
REPO_OWNER = cfg.repoOwner;
HOSTNAME = cfg.hostname;
};
serviceConfig = {
Type = "oneshot";
ExecStart = lib.getExe customPkgs.server-autodeploy;
TimeoutStartSec = "30min";
};
path = [
config.nix.package
pkgs.nixos-rebuild
];
};
systemd.timers.server-autodeploy = {
wantedBy = [ "timers.target" ];
timerConfig = {
OnBootSec = "2min";
OnUnitActiveSec = cfg.interval;
RandomizedDelaySec = "2min";
};
};
};
}
-18
View File
@@ -1,18 +0,0 @@
{
writeShellApplication,
git,
curl,
jq,
util-linux,
openssh,
}:
import ./mk-script.nix { inherit writeShellApplication; } {
name = "server-autodeploy";
runtimeInputs = [
git
curl
jq
util-linux
openssh
];
}
-64
View File
@@ -1,64 +0,0 @@
REPO_DIR="${REPO_DIR:-/persist/@configuration}"
STATE_DIR="${STATE_DIR:-/persist/@autodeploy}"
BRANCH="origin/${DEPLOY_BRANCH:-master}"
mkdir -p "$STATE_DIR"
exec 9>"$STATE_DIR/lock"
flock -n 9 || { echo "another deploy running"; exit 0; }
runas() { runuser -u "$REPO_OWNER" -- "$@"; }
report_status() {
echo "updating status to: $1 - $2"
[[ -f "$TOKEN_FILE" ]] || return 0
curl -sf -X POST \
-H "Authorization: token $(<"$TOKEN_FILE")" \
-H "Content-Type: application/json" \
-d "$(jq -n --arg s "$1" --arg d "$2" --arg c "deploy/$HOSTNAME" \
'{state:$s,description:$d,context:$c}')" \
"$GITEA_URL/api/v1/repos/$GITEA_REPO/statuses/$3" >/dev/null
}
cd "$REPO_DIR"
export GIT_CONFIG_COUNT=2
export GIT_CONFIG_KEY_0=gpg.format
export GIT_CONFIG_VALUE_0=ssh
export GIT_CONFIG_KEY_1=gpg.ssh.allowedSignersFile
export GIT_CONFIG_VALUE_1="$ALLOWED_SIGNERS"
runas git fetch origin --tags --prune-tags
latest=$(runas git describe --abbrev=0 "$BRANCH" 2>/dev/null) || {
echo "no tags on $BRANCH"
exit 0
}
current=$(cat "$STATE_DIR/tag" 2>/dev/null) || true
[[ "$latest" != "$current" ]] || { echo "already at $latest"; exit 0; }
echo "new tag: $latest (current: ${current:-none})"
runas git tag -v "$latest" || {
sha=$(runas git rev-list -1 "$latest")
report_status "failure" "tag signature verification failed" "$sha"
exit 1
}
sha=$(runas git rev-list -1 "$latest")
report_status "pending" "deploying $latest" "$sha"
label_dir=$(mktemp -d)
echo "$latest" > "$label_dir/label"
flake_url="git+${GITEA_URL}/${GITEA_REPO}?ref=refs/tags/${latest}&rev=${sha}#$HOSTNAME"
if nixos-rebuild switch --flake "$flake_url" --override-input deploy-label "path:$label_dir"; then
rm -rf "$label_dir"
echo "$latest" > "$STATE_DIR/tag"
report_status "success" "deployed $latest" "$sha"
echo "deployed $latest"
else
rm -rf "$label_dir"
report_status "failure" "nixos-rebuild failed" "$sha"
exit 1
fi
+13 -24
View File
@@ -153,8 +153,6 @@ with subtest("(functional): web services respond"):
for name, port in [("devenv", 8080), ("maven", 8080), ("git", 3000)]: for name, port in [("devenv", 8080), ("maven", 8080), ("git", 3000)]:
server.succeed(net_cmd(name, f"{CURL} -sf --max-time 5 -o /dev/null http://{ADDR[name]}:{port}/ >&2")) server.succeed(net_cmd(name, f"{CURL} -sf --max-time 5 -o /dev/null http://{ADDR[name]}:{port}/ >&2"))
# TODO: re-enable mail
"""
with subtest("(functional): mail accepts connections"): with subtest("(functional): mail accepts connections"):
smtp_probe = net_cmd("mail", f"{SH} -c 'exec 3<>/dev/tcp/{ADDR['mail']}/25 && head -1 <&3'") smtp_probe = net_cmd("mail", f"{SH} -c 'exec 3<>/dev/tcp/{ADDR['mail']}/25 && head -1 <&3'")
server.wait_until_succeeds(f"{smtp_probe} | grep -q '^220'", timeout=60) server.wait_until_succeeds(f"{smtp_probe} | grep -q '^220'", timeout=60)
@@ -169,7 +167,6 @@ with subtest("(functional): mail accepts connections"):
return greeting.strip().startswith("* OK") return greeting.strip().startswith("* OK")
retry(imap_ready, timeout_seconds=60) retry(imap_ready, timeout_seconds=60)
"""
with subtest("(functional): nginx proxies to backend containers"): with subtest("(functional): nginx proxies to backend containers"):
server.succeed( server.succeed(
@@ -200,7 +197,7 @@ with subtest("(isolation): undeclared container edges are refused"):
("devenv", "git", 3000), ("devenv", "git", 3000),
("git", "devenv", 8080), ("git", "devenv", 8080),
("maven", "git", 3000), ("maven", "git", 3000),
# ("nginx", "mail", 25), ("nginx", "mail", 25),
("ssh-botm", "ssh-admin", 22), ("ssh-botm", "ssh-admin", 22),
("overseer", "git", 3000), ("overseer", "git", 3000),
]: ]:
@@ -214,7 +211,12 @@ with subtest("(isolation): edges are one-way"):
server.fail(ct_connect("git", ADDR["nginx"], 443, timeout=2)) server.fail(ct_connect("git", ADDR["nginx"], 443, timeout=2))
with subtest("(isolation): host access allowlist"): with subtest("(isolation): host access allowlist"):
server.succeed(ct_connect("overseer", HOST_ADDR["overseer"], HOST_EXPORTER_PORT)) server.succeed(
net_cmd(
"overseer",
f"{CURL} -sf --max-time 5 http://{HOST_ADDR['overseer']}:{HOST_EXPORTER_PORT}/metrics >&2",
)
)
for port in (HOST_EXPORTER_PORT, HOST_CADVISOR_PORT): for port in (HOST_EXPORTER_PORT, HOST_CADVISOR_PORT):
server.fail(ct_connect("git", HOST_ADDR["git"], port, timeout=2)) server.fail(ct_connect("git", HOST_ADDR["git"], port, timeout=2))
server.fail(ct_connect("git", HOST_ADDR["overseer"], port, timeout=2)) server.fail(ct_connect("git", HOST_ADDR["overseer"], port, timeout=2))
@@ -253,7 +255,7 @@ with subtest("(isolation): renaming the interface changes nothing"):
rename(iface, "evil0") rename(iface, "evil0")
try: try:
server.succeed(ct_connect("nginx", ADDR["git"], 3000)) server.succeed(ct_connect("nginx", ADDR["git"], 3000))
# server.fail(ct_connect("nginx", ADDR["mail"], 25, timeout=2)) server.fail(ct_connect("nginx", ADDR["mail"], 25, timeout=2))
finally: finally:
rename("evil0", iface) rename("evil0", iface)
@@ -336,28 +338,15 @@ with subtest("(functional): published ports follow the container's lifetime"):
with subtest("(functional): declared devices are usable in-container"): with subtest("(functional): declared devices are usable in-container"):
for name, devices in DEVICES.items(): for name, devices in DEVICES.items():
for dev in devices: for dev in devices:
if server.execute(f"test -e {dev}")[0] != 0:
# host lacks the device (e.g. /dev/kvm without nested
# virtualization, as in this test's own VM) - nspawn skips
# populating it in-container, so there's nothing to check.
continue
# opened, not stat'd: without DeviceAllow= the node is still visible # opened, not stat'd: without DeviceAllow= the node is still visible
server.succeed(ct_cmd(name, f"exec 3<> {dev}")) server.succeed(ct_cmd(name, f"exec 3<> {dev}"))
with subtest("(functional): /dev/kvm actually initializes, not just opens"):
# a wrong-gid or unmapped node still opens but fails the ioctls qemu
# needs, so boot with no disk (never completes) and kill it - the
# failure mode this catches is qemu refusing to start at all.
for name, devices in DEVICES.items():
if "/dev/kvm" not in devices:
continue
out = server.succeed(
ct_cmd(
name,
f"{TIMEOUT} 3 qemu-system-x86_64 -enable-kvm -m 256 -nographic -no-reboot "
">/tmp/qemu.out 2>&1; cat /tmp/qemu.out",
)
)
assert "Permission denied" not in out, f"{name}: qemu couldn't use /dev/kvm:\n{out}"
assert "Could not access KVM" not in out, f"{name}: qemu couldn't use /dev/kvm:\n{out}"
with subtest("(isolation): devices reach only the container that declared them"): with subtest("(isolation): devices reach only the container that declared them"):
for name in enterable: for name in enterable:
for dev in {d for ds in DEVICES.values() for d in ds} - set(DEVICES.get(name, [])): for dev in {d for ds in DEVICES.values() for d in ds} - set(DEVICES.get(name, [])):