Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
33ccab9ad4 |
@@ -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"
|
||||||
|
|||||||
@@ -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"
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
@@ -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
@@ -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"
|
||||||
|
|||||||
@@ -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
|
||||||
|
|||||||
@@ -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"
|
||||||
":"
|
":"
|
||||||
|
|||||||
@@ -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")
|
||||||
|
|||||||
@@ -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 = {
|
||||||
|
|||||||
@@ -381,6 +381,6 @@ let
|
|||||||
};
|
};
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
inherit (c) hostAddr;
|
hostAddr = c.hostAddr;
|
||||||
in
|
in
|
||||||
c
|
c
|
||||||
|
|||||||
@@ -0,0 +1,54 @@
|
|||||||
|
{
|
||||||
|
name,
|
||||||
|
hostInfo,
|
||||||
|
dsl,
|
||||||
|
...
|
||||||
|
}:
|
||||||
|
let
|
||||||
|
inherit (dsl) mkContainer mkService;
|
||||||
|
inherit (hostInfo.paths) data secrets;
|
||||||
|
in
|
||||||
|
mkContainer {
|
||||||
|
inherit name;
|
||||||
|
net.access = [ { to = "@internet"; } ];
|
||||||
|
svc.autoStart = true;
|
||||||
|
resources.fs = {
|
||||||
|
"/config" = {
|
||||||
|
hostPath = "${data}/web/devenv/config";
|
||||||
|
isReadOnly = false;
|
||||||
|
};
|
||||||
|
"/workspace" = {
|
||||||
|
hostPath = "${data}/web/devenv/workspace";
|
||||||
|
isReadOnly = false;
|
||||||
|
};
|
||||||
|
"/run/secrets/code-server-env" = {
|
||||||
|
hostPath = "${secrets}/code-server-env";
|
||||||
|
isReadOnly = true;
|
||||||
|
};
|
||||||
|
};
|
||||||
|
users = [
|
||||||
|
{
|
||||||
|
name = "coder";
|
||||||
|
uid = 1000;
|
||||||
|
home = "/config";
|
||||||
|
}
|
||||||
|
];
|
||||||
|
service =
|
||||||
|
{ pkgs, lib, ... }:
|
||||||
|
mkService {
|
||||||
|
description = "code-server";
|
||||||
|
execStart = "${lib.getExe' pkgs.code-server "code-server"} --bind-addr 0.0.0.0:8080 --user-data-dir /config/data --extensions-dir /config/extensions --auth password /workspace";
|
||||||
|
networkOnline = true;
|
||||||
|
serviceConfig = {
|
||||||
|
EnvironmentFile = "/run/secrets/code-server-env";
|
||||||
|
User = "coder";
|
||||||
|
ReadWritePaths = [
|
||||||
|
"/config"
|
||||||
|
"/workspace"
|
||||||
|
];
|
||||||
|
};
|
||||||
|
};
|
||||||
|
net.expose.tcp = [ 8080 ];
|
||||||
|
resources.mem = "4G";
|
||||||
|
resources.cpu = 2;
|
||||||
|
}
|
||||||
@@ -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;
|
||||||
};
|
};
|
||||||
@@ -53,16 +49,10 @@ in
|
|||||||
systemd.services.gitea.serviceConfig.FailureAction = "exit-force";
|
systemd.services.gitea.serviceConfig.FailureAction = "exit-force";
|
||||||
};
|
};
|
||||||
net.expose.tcp = [ 3000 ];
|
net.expose.tcp = [ 3000 ];
|
||||||
miscProperties.nginx = {
|
|
||||||
domain = "git.floweytf.com";
|
|
||||||
port = 3000;
|
|
||||||
};
|
|
||||||
};
|
};
|
||||||
|
|
||||||
ci-runner =
|
ci-runner = mkVm {
|
||||||
mkVm {
|
|
||||||
name = "ci-runner";
|
name = "ci-runner";
|
||||||
includedInTests = false;
|
|
||||||
net.access = [
|
net.access = [
|
||||||
{
|
{
|
||||||
to = "git";
|
to = "git";
|
||||||
@@ -72,7 +62,7 @@ in
|
|||||||
];
|
];
|
||||||
svc.autoStart = true;
|
svc.autoStart = true;
|
||||||
resources.cpu = 4;
|
resources.cpu = 4;
|
||||||
resources.mem = "32G";
|
resources.mem = "8G";
|
||||||
resources.fs = [
|
resources.fs = [
|
||||||
{
|
{
|
||||||
proto = "virtiofs";
|
proto = "virtiofs";
|
||||||
@@ -80,12 +70,6 @@ in
|
|||||||
source = "${ciRunnerData}/nix-rw-store";
|
source = "${ciRunnerData}/nix-rw-store";
|
||||||
mountPoint = "/nix/.rw-store";
|
mountPoint = "/nix/.rw-store";
|
||||||
}
|
}
|
||||||
{
|
|
||||||
proto = "virtiofs";
|
|
||||||
tag = "nix-db";
|
|
||||||
source = "${ciRunnerData}/nix-db";
|
|
||||||
mountPoint = "/nix/var/nix/db";
|
|
||||||
}
|
|
||||||
{
|
{
|
||||||
proto = "virtiofs";
|
proto = "virtiofs";
|
||||||
tag = "docker-data";
|
tag = "docker-data";
|
||||||
@@ -96,7 +80,7 @@ in
|
|||||||
proto = "virtiofs";
|
proto = "virtiofs";
|
||||||
tag = "runner-state";
|
tag = "runner-state";
|
||||||
source = "${ciRunnerData}/runner-state";
|
source = "${ciRunnerData}/runner-state";
|
||||||
mountPoint = "/var/lib/private/gitea-runner";
|
mountPoint = "/var/lib/gitea-runner";
|
||||||
}
|
}
|
||||||
{
|
{
|
||||||
proto = "virtiofs";
|
proto = "virtiofs";
|
||||||
@@ -105,12 +89,6 @@ in
|
|||||||
mountPoint = "/run/ci-runner-secrets";
|
mountPoint = "/run/ci-runner-secrets";
|
||||||
readOnly = true;
|
readOnly = true;
|
||||||
}
|
}
|
||||||
{
|
|
||||||
proto = "virtiofs";
|
|
||||||
tag = "tmp";
|
|
||||||
source = "/tmp";
|
|
||||||
mountPoint = "/tmp";
|
|
||||||
}
|
|
||||||
];
|
];
|
||||||
guestConfig =
|
guestConfig =
|
||||||
{
|
{
|
||||||
@@ -122,24 +100,20 @@ in
|
|||||||
let
|
let
|
||||||
runnerInstanceName = "ci-runner";
|
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")
|
|
||||||
];
|
];
|
||||||
|
|
||||||
ciJobImage = pkgs.dockerTools.buildLayeredImage {
|
|
||||||
name = "ci-job-image";
|
|
||||||
tag = "latest";
|
|
||||||
contents = ciJobContents;
|
|
||||||
config = {
|
config = {
|
||||||
Cmd = [ "/bin/sh" ];
|
Cmd = [ "/bin/sh" ];
|
||||||
Env = [
|
Env = [
|
||||||
"PATH=${lib.makeBinPath ciJobContents}"
|
|
||||||
"SSL_CERT_FILE=${pkgs.cacert}/etc/ssl/certs/ca-bundle.crt"
|
"SSL_CERT_FILE=${pkgs.cacert}/etc/ssl/certs/ca-bundle.crt"
|
||||||
"NIX_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"
|
"NIX_REMOTE=daemon"
|
||||||
@@ -151,10 +125,6 @@ in
|
|||||||
boot.kernelModules = [ "kvm-intel" ];
|
boot.kernelModules = [ "kvm-intel" ];
|
||||||
boot.extraModprobeConfig = "options kvm_intel nested=1";
|
boot.extraModprobeConfig = "options kvm_intel nested=1";
|
||||||
|
|
||||||
# volume-mounted into CI containers; must be in VM's store so
|
|
||||||
# image symlinks (/bin/node etc.) resolve through the mount
|
|
||||||
system.extraDependencies = ciJobContents;
|
|
||||||
|
|
||||||
microvm.writableStoreOverlay = "/nix/.rw-store";
|
microvm.writableStoreOverlay = "/nix/.rw-store";
|
||||||
|
|
||||||
nix.settings = {
|
nix.settings = {
|
||||||
@@ -163,36 +133,16 @@ in
|
|||||||
"flakes"
|
"flakes"
|
||||||
];
|
];
|
||||||
max-jobs = "auto";
|
max-jobs = "auto";
|
||||||
substituters = [ "https://microvm.cachix.org" ];
|
|
||||||
trusted-public-keys = [ "microvm.cachix.org-1:oXnBc6hRE3eX5rSYdRyMYXnfzcCxC7yKPTbZXALsqys=" ];
|
|
||||||
};
|
};
|
||||||
|
|
||||||
nix.settings = {
|
nix.gc = {
|
||||||
min-free = 5 * 1024 * 1024 * 1024;
|
automatic = true;
|
||||||
max-free = 10 * 1024 * 1024 * 1024;
|
dates = "daily";
|
||||||
|
options = "--delete-older-than 14d";
|
||||||
};
|
};
|
||||||
# nix.optimise.automatic = true; - doesn't work with microvm.writableStoreOverlay
|
# nix.optimise.automatic = true; - doesn't work with microvm.writableStoreOverlay
|
||||||
|
|
||||||
services.openssh = {
|
|
||||||
enable = true;
|
|
||||||
settings = {
|
|
||||||
PermitRootLogin = "yes";
|
|
||||||
PermitEmptyPasswords = "yes";
|
|
||||||
};
|
|
||||||
};
|
|
||||||
security.pam.services.sshd.allowNullPassword = true;
|
|
||||||
users.users.root.initialHashedPassword = "";
|
|
||||||
services.journald.settings.Journal.ForwardToConsole = "yes";
|
|
||||||
|
|
||||||
virtualisation.containerd.enable = true;
|
|
||||||
virtualisation.containerd.settings.plugins."io.containerd.snapshotter.v1.overlayfs".mount_options =
|
|
||||||
[ "userxattr" ];
|
|
||||||
|
|
||||||
virtualisation.docker.enable = true;
|
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 = {
|
systemd.services.load-ci-job-image = {
|
||||||
description = "Load the CI job Docker image";
|
description = "Load the CI job Docker image";
|
||||||
@@ -224,15 +174,5 @@ in
|
|||||||
};
|
};
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
}
|
|
||||||
// {
|
|
||||||
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 -"
|
|
||||||
];
|
|
||||||
};
|
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -146,13 +146,8 @@ 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;
|
||||||
miscProperties.nginx = {
|
|
||||||
domain = "mail.floweytf.com";
|
|
||||||
};
|
|
||||||
net.forward.tcp = [
|
net.forward.tcp = [
|
||||||
25
|
25
|
||||||
993
|
993
|
||||||
|
|||||||
@@ -38,8 +38,4 @@ mkContainer {
|
|||||||
environment.JAVA_OPTS = "-Xmx128M";
|
environment.JAVA_OPTS = "-Xmx128M";
|
||||||
};
|
};
|
||||||
net.expose.tcp = [ 8080 ];
|
net.expose.tcp = [ 8080 ];
|
||||||
miscProperties.nginx = {
|
|
||||||
domain = "maven.floweytf.com";
|
|
||||||
port = 8080;
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
...
|
...
|
||||||
}:
|
}:
|
||||||
let
|
let
|
||||||
inherit (dsl) mkContainer collectContainers;
|
inherit (dsl) mkContainer;
|
||||||
inherit (hostInfo.paths) data;
|
inherit (hostInfo.paths) data;
|
||||||
|
|
||||||
mkNginxConfig =
|
mkNginxConfig =
|
||||||
@@ -40,6 +40,9 @@ let
|
|||||||
defaultLoc = lib.optionalAttrs (upstream != null) {
|
defaultLoc = lib.optionalAttrs (upstream != null) {
|
||||||
"/" = {
|
"/" = {
|
||||||
proxyWebsockets = websockets;
|
proxyWebsockets = websockets;
|
||||||
|
# avoid startup error when containers aren't registered yet
|
||||||
|
# proxyPass is left unset for that reason, so recommendedProxySettings
|
||||||
|
# won't auto-include its headers here - set them manually to match
|
||||||
extraConfig = ''
|
extraConfig = ''
|
||||||
set $backend "${upstream.container.name}:${toString upstream.port}";
|
set $backend "${upstream.container.name}:${toString upstream.port}";
|
||||||
proxy_pass http://$backend;
|
proxy_pass http://$backend;
|
||||||
@@ -154,21 +157,24 @@ let
|
|||||||
|
|
||||||
up = container: port: { inherit container port; };
|
up = container: port: { inherit container port; };
|
||||||
|
|
||||||
discovered = collectContainers "nginx" containers;
|
nginxSetup =
|
||||||
|
hostAddr:
|
||||||
discoveredVhosts = map (
|
mkNginxConfig {
|
||||||
{ container, data }:
|
email = "floweydev@gmail.com";
|
||||||
|
resolver = hostAddr;
|
||||||
|
vhosts = [
|
||||||
{
|
{
|
||||||
inherit (data) domain;
|
domain = "devenv.floweytf.com";
|
||||||
|
upstream = up containers.devenv 8080;
|
||||||
|
}
|
||||||
|
{
|
||||||
|
domain = "maven.floweytf.com";
|
||||||
|
upstream = up containers.maven 8080;
|
||||||
|
}
|
||||||
|
{
|
||||||
|
domain = "git.floweytf.com";
|
||||||
|
upstream = up containers.git 3000;
|
||||||
}
|
}
|
||||||
// lib.optionalAttrs (data ? port) { upstream = up container data.port; }
|
|
||||||
// lib.optionalAttrs (data ? websockets) { inherit (data) websockets; }
|
|
||||||
// lib.optionalAttrs (data ? redirect) { inherit (data) redirect; }
|
|
||||||
// lib.optionalAttrs (data ? listenHttp) { inherit (data) listenHttp; }
|
|
||||||
// lib.optionalAttrs (data ? extraLocations) { inherit (data) extraLocations; }
|
|
||||||
) discovered;
|
|
||||||
|
|
||||||
extraVhosts = [
|
|
||||||
{
|
{
|
||||||
domain = "utils.floweytf.com";
|
domain = "utils.floweytf.com";
|
||||||
redirect = false;
|
redirect = false;
|
||||||
@@ -180,20 +186,20 @@ let
|
|||||||
};
|
};
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
{
|
||||||
|
# no upstream, vhost only exists for certs
|
||||||
|
domain = "mail.floweytf.com";
|
||||||
|
}
|
||||||
];
|
];
|
||||||
|
|
||||||
upstreamContainers = map (e: e.container) (lib.filter ({ data, ... }: data ? port) discovered);
|
|
||||||
|
|
||||||
setup = mkNginxConfig {
|
|
||||||
email = "floweydev@gmail.com";
|
|
||||||
resolver = hostAddr;
|
|
||||||
vhosts = discoveredVhosts ++ extraVhosts;
|
|
||||||
};
|
};
|
||||||
|
in
|
||||||
|
let
|
||||||
|
setup = nginxSetup hostAddr;
|
||||||
c = mkContainer {
|
c = mkContainer {
|
||||||
inherit name;
|
inherit name;
|
||||||
net.access = setup.access ++ [ { to = "@internet"; } ];
|
net.access = setup.access ++ [ { to = "@internet"; } ];
|
||||||
svc.autoStart = true;
|
svc.autoStart = true;
|
||||||
svc.depends = upstreamContainers;
|
svc.depends = lib.attrVals [ "devenv" "maven" "git" ] containers;
|
||||||
net.forward.tcp = [
|
net.forward.tcp = [
|
||||||
80
|
80
|
||||||
443
|
443
|
||||||
@@ -202,9 +208,8 @@ let
|
|||||||
hostPath = "${data}/core/nginx/acme";
|
hostPath = "${data}/core/nginx/acme";
|
||||||
isReadOnly = false;
|
isReadOnly = false;
|
||||||
};
|
};
|
||||||
miscProperties.acmeDomains = map (v: v.domain) (discoveredVhosts ++ extraVhosts);
|
|
||||||
inherit (setup) containerConfig;
|
inherit (setup) containerConfig;
|
||||||
};
|
};
|
||||||
inherit (c) hostAddr;
|
hostAddr = c.hostAddr;
|
||||||
in
|
in
|
||||||
c
|
c
|
||||||
|
|||||||
@@ -67,14 +67,21 @@ let
|
|||||||
inherit name;
|
inherit name;
|
||||||
inherit net resources;
|
inherit net resources;
|
||||||
svc.autoStart = true;
|
svc.autoStart = true;
|
||||||
isolation = {
|
isolation = { nixDaemon = nixDaemon; } // isolation;
|
||||||
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;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
kvmTrait = {
|
||||||
|
containerConfig =
|
||||||
|
{ pkgs, ... }:
|
||||||
|
{
|
||||||
|
users.users.runner.extraGroups = [ "wheel" ];
|
||||||
|
security.sudo.wheelNeedsPassword = false;
|
||||||
|
environment.systemPackages = [ pkgs.qemu_kvm ];
|
||||||
|
};
|
||||||
|
};
|
||||||
in
|
in
|
||||||
{
|
{
|
||||||
ssh-admin = mkSsh {
|
ssh-admin = mkSsh {
|
||||||
@@ -117,27 +124,32 @@ in
|
|||||||
ssh-generic = mkSsh {
|
ssh-generic = mkSsh {
|
||||||
name = "ssh-generic";
|
name = "ssh-generic";
|
||||||
net.access = [ { to = "@internet"; } ];
|
net.access = [ { to = "@internet"; } ];
|
||||||
# /dev/kvm keeps its host ownership, so the kvm gid must not be shifted.
|
|
||||||
isolation.privateUsers = "identity";
|
|
||||||
resources = {
|
resources = {
|
||||||
fs."/home/runner/data" = {
|
fs."/home/runner/data" = {
|
||||||
hostPath = "${data}/ssh/generic";
|
hostPath = "${data}/ssh/generic";
|
||||||
isReadOnly = false;
|
isReadOnly = false;
|
||||||
};
|
};
|
||||||
devices = [ "/dev/kvm" ];
|
|
||||||
mem = "16G";
|
mem = "16G";
|
||||||
cpu = 65;
|
cpu = 65;
|
||||||
};
|
};
|
||||||
packages = with pkgs; [ qemu_kvm ];
|
traits = [ kvmTrait ];
|
||||||
traits = [
|
isolation.allowedDevices = [
|
||||||
{
|
{
|
||||||
containerConfig =
|
node = "/dev/kvm";
|
||||||
{ config, ... }:
|
modifier = "rw";
|
||||||
{
|
|
||||||
users.groups.kvm.gid = config.ids.gids.kvm;
|
|
||||||
users.users.runner.extraGroups = [ "kvm" ];
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
|
{
|
||||||
|
node = "/dev/vhost-net";
|
||||||
|
modifier = "rw";
|
||||||
|
}
|
||||||
|
{
|
||||||
|
node = "/dev/net/tun";
|
||||||
|
modifier = "rwm";
|
||||||
|
}
|
||||||
|
];
|
||||||
|
isolation.additionalCapabilities = [
|
||||||
|
"CAP_NET_ADMIN"
|
||||||
|
"CAP_MKNOD"
|
||||||
];
|
];
|
||||||
routingInfo = [
|
routingInfo = [
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -221,17 +221,6 @@ rec {
|
|||||||
`resources.fs`
|
`resources.fs`
|
||||||
: Bind mounts, keyed by mount point.
|
: Bind mounts, keyed by mount point.
|
||||||
|
|
||||||
`resources.devices`
|
|
||||||
: Host device nodes to expose, as paths. Bound into the container at the
|
|
||||||
same path and added to the unit's `DeviceAllow=` - the cgroup
|
|
||||||
permission alone doesn't get you a working node (nothing can `mknod` a
|
|
||||||
device inside a user namespace), and the bind alone leaves the cgroup
|
|
||||||
denying `open()`, so both are needed. The bind is unconditional, so
|
|
||||||
the device must actually exist on whatever host runs the container.
|
|
||||||
Nodes keep their host ownership, so a consumer inside needs
|
|
||||||
`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.
|
||||||
|
|
||||||
@@ -239,6 +228,17 @@ rec {
|
|||||||
: systemd-nspawn user namespacing; see `--private-users=` in
|
: systemd-nspawn user namespacing; see `--private-users=` in
|
||||||
systemd-nspawn(1). Bind mounts always go through idmapped `--bind`.
|
systemd-nspawn(1). Bind mounts always go through idmapped `--bind`.
|
||||||
|
|
||||||
|
`isolation.allowedDevices`
|
||||||
|
: List of `{ node; modifier; }` host devices to grant the container's
|
||||||
|
cgroup access to; see `containers.<name>.allowedDevices` in the NixOS
|
||||||
|
manual. nspawn bind-mounts a handful of devices (`/dev/kvm`,
|
||||||
|
`/dev/net/tun`, ...) into the container itself once the cgroup allows it -
|
||||||
|
this doesn't need a matching `resources.fs` bind mount.
|
||||||
|
|
||||||
|
`isolation.additionalCapabilities`
|
||||||
|
: Extra Linux capabilities granted to the container; see
|
||||||
|
`containers.<name>.additionalCapabilities` in the NixOS manual.
|
||||||
|
|
||||||
`miscProperties`
|
`miscProperties`
|
||||||
: Arbitrary data attached to the result. Used for cross-container discovery
|
: Arbitrary data attached to the result. Used for cross-container discovery
|
||||||
via `collectContainers`.
|
via `collectContainers`.
|
||||||
@@ -281,15 +281,16 @@ rec {
|
|||||||
cpuQuota = "${toString (cpu * 100)}%";
|
cpuQuota = "${toString (cpu * 100)}%";
|
||||||
memoryMax = resources.mem or "512M";
|
memoryMax = resources.mem or "512M";
|
||||||
bindMounts = resources.fs or { };
|
bindMounts = resources.fs or { };
|
||||||
devices = resources.devices or [ ];
|
|
||||||
allowsNixDaemon = isolation.nixDaemon or false;
|
allowsNixDaemon = isolation.nixDaemon or false;
|
||||||
privateUsers = isolation.privateUsers or "pick";
|
privateUsers = isolation.privateUsers or "pick";
|
||||||
|
allowedDevices = isolation.allowedDevices or [ ];
|
||||||
|
additionalCapabilities = isolation.additionalCapabilities or [ ];
|
||||||
|
|
||||||
allowInternet = hasInternetAccess access;
|
allowInternet = hasInternetAccess access;
|
||||||
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 +298,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
|
||||||
@@ -379,15 +376,19 @@ rec {
|
|||||||
hostAddr
|
hostAddr
|
||||||
bindMountHostPaths
|
bindMountHostPaths
|
||||||
includedInTests
|
includedInTests
|
||||||
devices
|
|
||||||
;
|
;
|
||||||
bindMounts = allBindMounts;
|
bindMounts = allBindMounts;
|
||||||
kind = "nspawn";
|
kind = "nspawn";
|
||||||
miscProperties = flattenMiscProp self miscProperties;
|
miscProperties = flattenMiscProp self miscProperties;
|
||||||
nixosContainer = {
|
nixosContainer = {
|
||||||
inherit autoStart privateUsers;
|
inherit
|
||||||
|
autoStart
|
||||||
|
privateUsers
|
||||||
|
allowedDevices
|
||||||
|
additionalCapabilities
|
||||||
|
;
|
||||||
bindMounts = { };
|
bindMounts = { };
|
||||||
extraFlags = bindMountExtraFlags ++ deviceFlags;
|
extraFlags = bindMountExtraFlags;
|
||||||
privateNetwork = true;
|
privateNetwork = true;
|
||||||
extraVeths = linkVeths;
|
extraVeths = linkVeths;
|
||||||
config =
|
config =
|
||||||
@@ -520,7 +521,6 @@ rec {
|
|||||||
;
|
;
|
||||||
inherit needsGateway;
|
inherit needsGateway;
|
||||||
bindMountHostPaths = map (s: s.source) shares;
|
bindMountHostPaths = map (s: s.source) shares;
|
||||||
devices = [ ];
|
|
||||||
kind = "vm";
|
kind = "vm";
|
||||||
miscProperties = flattenMiscProp self miscProperties;
|
miscProperties = flattenMiscProp self miscProperties;
|
||||||
microvmConfig = {
|
microvmConfig = {
|
||||||
@@ -571,11 +571,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;
|
||||||
@@ -957,7 +952,6 @@ rec {
|
|||||||
startLimitBurst = 5;
|
startLimitBurst = 5;
|
||||||
startLimitIntervalSec = 120;
|
startLimitIntervalSec = 120;
|
||||||
unitConfig.RequiresMountsFor = c.bindMountHostPaths;
|
unitConfig.RequiresMountsFor = c.bindMountHostPaths;
|
||||||
serviceConfig.DeviceAllow = map (d: "${d} rw") c.devices;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
# the host end of a link, for both kinds. nixos-containers only configures
|
# the host end of a link, for both kinds. nixos-containers only configures
|
||||||
@@ -1223,43 +1217,6 @@ rec {
|
|||||||
) (lib.attrValues autoStartTestContainers)
|
) (lib.attrValues autoStartTestContainers)
|
||||||
);
|
);
|
||||||
|
|
||||||
exposedTcp = lib.mapAttrs (_: c: c.ports or [ ]) autoStartTestContainers;
|
|
||||||
|
|
||||||
hostAccessTcp = lib.filterAttrs (_: v: v != [ ]) (
|
|
||||||
lib.mapAttrs (
|
|
||||||
_: c: lib.concatMap (a: if a.to == "@host" then a.tcp or [ ] else [ ]) c.access
|
|
||||||
) autoStartTestContainers
|
|
||||||
);
|
|
||||||
|
|
||||||
pyForwardTcp = lib.concatStringsSep ", " (
|
|
||||||
lib.concatMap (
|
|
||||||
c:
|
|
||||||
map (
|
|
||||||
p:
|
|
||||||
let
|
|
||||||
np = normalizePort p;
|
|
||||||
in
|
|
||||||
"(${toString np.host}, \"${c.name}\", ${toString np.container})"
|
|
||||||
) c.hostPorts
|
|
||||||
) (lib.attrValues autoStartTestContainers)
|
|
||||||
);
|
|
||||||
|
|
||||||
nginxBackendPorts = lib.mapAttrs (_: c: c.miscProperties.nginx.port) (
|
|
||||||
lib.filterAttrs (
|
|
||||||
_: c: c.miscProperties ? nginx && c.miscProperties.nginx ? port
|
|
||||||
) autoStartTestContainers
|
|
||||||
);
|
|
||||||
|
|
||||||
nginxDomainMap = lib.listToAttrs (
|
|
||||||
lib.concatMap (
|
|
||||||
c:
|
|
||||||
lib.optional (c.miscProperties ? nginx && c.miscProperties.nginx ? domain) {
|
|
||||||
name = c.miscProperties.nginx.domain;
|
|
||||||
value = c.name;
|
|
||||||
}
|
|
||||||
) (lib.attrValues autoStartTestContainers)
|
|
||||||
);
|
|
||||||
|
|
||||||
bin = lib.getExe';
|
bin = lib.getExe';
|
||||||
|
|
||||||
testTools = [
|
testTools = [
|
||||||
@@ -1306,7 +1263,7 @@ rec {
|
|||||||
# containers don't forward journal to console by default
|
# containers don't forward journal to console by default
|
||||||
containers = lib.genAttrs nspawnNames (_: {
|
containers = lib.genAttrs nspawnNames (_: {
|
||||||
timeoutStartSec = "10min";
|
timeoutStartSec = "10min";
|
||||||
config.services.journald.settings.Journal.ForwardToConsole = "yes";
|
config.services.journald.extraConfig = "ForwardToConsole=yes";
|
||||||
});
|
});
|
||||||
|
|
||||||
# a test VM has neither the memory to hand out nor the cores to divide.
|
# a test VM has neither the memory to hand out nor the cores to divide.
|
||||||
@@ -1354,7 +1311,6 @@ rec {
|
|||||||
HOST_ADDR = ${pyDict pyStr (lib.mapAttrs (_: c: c.hostAddr) autoStartTestContainers)}
|
HOST_ADDR = ${pyDict pyStr (lib.mapAttrs (_: c: c.hostAddr) autoStartTestContainers)}
|
||||||
IFACE = ${pyDict pyStr (lib.mapAttrs (_: c: c.iface) autoStartTestContainers)}
|
IFACE = ${pyDict pyStr (lib.mapAttrs (_: c: c.iface) autoStartTestContainers)}
|
||||||
KIND = ${pyDict pyStr (lib.mapAttrs (_: c: c.kind) autoStartTestContainers)}
|
KIND = ${pyDict pyStr (lib.mapAttrs (_: c: c.kind) autoStartTestContainers)}
|
||||||
DEVICES = ${pyDict pyList (lib.mapAttrs (_: c: c.devices) autoStartTestContainers)}
|
|
||||||
# only nspawn guests can be entered with nsenter; a vm has no host-side
|
# only nspawn guests can be entered with nsenter; a vm has no host-side
|
||||||
# netns, so every probe that runs *inside* a guest is limited to these
|
# netns, so every probe that runs *inside* a guest is limited to these
|
||||||
enterable = [c for c in included if KIND[c] == "nspawn"]
|
enterable = [c for c in included if KIND[c] == "nspawn"]
|
||||||
@@ -1367,12 +1323,6 @@ rec {
|
|||||||
# (src, to, tcp ports, udp ports); `to` may be "@host" or "@internet"
|
# (src, to, tcp ports, udp ports); `to` may be "@host" or "@internet"
|
||||||
EDGES = [${pyEdges}]
|
EDGES = [${pyEdges}]
|
||||||
|
|
||||||
EXPOSED_TCP = ${pyDict pyInts exposedTcp}
|
|
||||||
HOST_ACCESS_TCP = ${pyDict pyInts hostAccessTcp}
|
|
||||||
FORWARD_TCP = [${pyForwardTcp}]
|
|
||||||
NGINX_BACKENDS = ${pyDict toString nginxBackendPorts}
|
|
||||||
NGINX_DOMAINS = ${pyDict pyStr nginxDomainMap}
|
|
||||||
|
|
||||||
NSENTER = "${bin pkgs.util-linux "nsenter"}"
|
NSENTER = "${bin pkgs.util-linux "nsenter"}"
|
||||||
CURL = "${bin pkgs.curl "curl"}"
|
CURL = "${bin pkgs.curl "curl"}"
|
||||||
IP = "${bin pkgs.iproute2 "ip"}"
|
IP = "${bin pkgs.iproute2 "ip"}"
|
||||||
|
|||||||
Generated
+13
-26
@@ -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"
|
||||||
@@ -38,11 +26,11 @@
|
|||||||
"spectrum": "spectrum"
|
"spectrum": "spectrum"
|
||||||
},
|
},
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1789506833,
|
"lastModified": 1786300091,
|
||||||
"narHash": "sha256-4L8SOCF84de1irB72Ka9VHcu9wrAJ9Amuey4lU9oh4Y=",
|
"narHash": "sha256-4UFJOVGpaYtHW5yasSv80MaJxTBYdk2zyf3jhKtt0wA=",
|
||||||
"owner": "microvm-nix",
|
"owner": "microvm-nix",
|
||||||
"repo": "microvm.nix",
|
"repo": "microvm.nix",
|
||||||
"rev": "187b0a390ee054028106a674e7b01b1cb940cbba",
|
"rev": "71beea0076cd46dafcee97a5a2e7d00cbba5bd2f",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
@@ -59,11 +47,11 @@
|
|||||||
]
|
]
|
||||||
},
|
},
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1790093442,
|
"lastModified": 1782711974,
|
||||||
"narHash": "sha256-n0t8bN5x0NU9Ugwa/Vr0bcnA4YKA3YmyVg+Vp7t70HU=",
|
"narHash": "sha256-ju0/qU6ZGqRxc5yDhuljrprG0BSPgguc8Kz3txktSjI=",
|
||||||
"owner": "Floweynt",
|
"owner": "Floweynt",
|
||||||
"repo": "monumenta-charm-eval",
|
"repo": "monumenta-charm-eval",
|
||||||
"rev": "0aaac697ff4d65e7af2fc9bebaf4f479d7c763b6",
|
"rev": "1aa8b532975679787f7c5bed180fd7fc0da6b905",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
@@ -75,11 +63,11 @@
|
|||||||
},
|
},
|
||||||
"nixpkgs": {
|
"nixpkgs": {
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1790046670,
|
"lastModified": 1786384358,
|
||||||
"narHash": "sha256-MYiI+CzL0tuWgRPjGsKCDHqYs2T3OzMlMQWOYWG0qso=",
|
"narHash": "sha256-RzPPiWeUtuvymnpuEWsdtzli5w4kjZs49FqEs3/1u+I=",
|
||||||
"owner": "NixOS",
|
"owner": "NixOS",
|
||||||
"repo": "nixpkgs",
|
"repo": "nixpkgs",
|
||||||
"rev": "6774f7bc253789b113a4f39285dc0fa100abeacc",
|
"rev": "2fcb964de67fcf60b43471c55d5d99e61a9ccb5a",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
@@ -91,7 +79,6 @@
|
|||||||
},
|
},
|
||||||
"root": {
|
"root": {
|
||||||
"inputs": {
|
"inputs": {
|
||||||
"deploy-label": "deploy-label",
|
|
||||||
"microvm": "microvm",
|
"microvm": "microvm",
|
||||||
"mtce": "mtce",
|
"mtce": "mtce",
|
||||||
"nixpkgs": "nixpkgs"
|
"nixpkgs": "nixpkgs"
|
||||||
@@ -100,11 +87,11 @@
|
|||||||
"spectrum": {
|
"spectrum": {
|
||||||
"flake": false,
|
"flake": false,
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1786032750,
|
"lastModified": 1785761586,
|
||||||
"narHash": "sha256-+Ba/kIn5BjvV7PN8bWOo7RoqgTY/Yv2M7qeMf3wS2Ag=",
|
"narHash": "sha256-MWOMVqJJERwjQGgRIv8d6rlEBqbLM3VZWxHkNKIIZNw=",
|
||||||
"ref": "refs/heads/main",
|
"ref": "refs/heads/main",
|
||||||
"rev": "77d2389874bb092b8dbf05ecc5b1030372e80e98",
|
"rev": "a7762d6f54b40560dd5255ce902e6e6a5d980fe9",
|
||||||
"revCount": 1417,
|
"revCount": 1416,
|
||||||
"type": "git",
|
"type": "git",
|
||||||
"url": "https://spectrum-os.org/git/spectrum"
|
"url": "https://spectrum-os.org/git/spectrum"
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -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,18 +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
|
inherit inputs customPkgs;
|
||||||
inputs
|
|
||||||
customPkgs
|
|
||||||
flakeRev
|
|
||||||
deployLabel
|
|
||||||
;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
hostDefFor =
|
hostDefFor =
|
||||||
@@ -148,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;
|
||||||
@@ -166,7 +148,6 @@
|
|||||||
server-rebuild
|
server-rebuild
|
||||||
server-status
|
server-status
|
||||||
server-kexec
|
server-kexec
|
||||||
server-autodeploy
|
|
||||||
;
|
;
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -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";
|
|
||||||
};
|
|
||||||
};
|
|
||||||
};
|
|
||||||
}
|
|
||||||
@@ -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
|
|
||||||
];
|
|
||||||
}
|
|
||||||
@@ -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
|
|
||||||
@@ -14,11 +14,13 @@ let
|
|||||||
|
|
||||||
it = dsl.mkIntegrationTest { inherit host testContainers pkgs; };
|
it = dsl.mkIntegrationTest { inherit host testContainers pkgs; };
|
||||||
|
|
||||||
nginxAcmeDomains =
|
nginxAcmeDomains = [
|
||||||
if testContainers ? nginx && testContainers.nginx.miscProperties ? acmeDomains then
|
"devenv.floweytf.com"
|
||||||
testContainers.nginx.miscProperties.acmeDomains
|
"maven.floweytf.com"
|
||||||
else
|
"git.floweytf.com"
|
||||||
[ ];
|
"utils.floweytf.com"
|
||||||
|
"mail.floweytf.com"
|
||||||
|
];
|
||||||
|
|
||||||
nginxAcmeDir = domain: "${serverDataDir}/core/nginx/acme/${domain}";
|
nginxAcmeDir = domain: "${serverDataDir}/core/nginx/acme/${domain}";
|
||||||
|
|
||||||
@@ -65,44 +67,9 @@ let
|
|||||||
'';
|
'';
|
||||||
sshpiperTestUser = "admin";
|
sshpiperTestUser = "admin";
|
||||||
|
|
||||||
|
hostExporterPort = 9100;
|
||||||
|
hostCadvisorPort = 9200;
|
||||||
hostSshdPort = 5952;
|
hostSshdPort = 5952;
|
||||||
|
|
||||||
# derive data directories from container bind mounts
|
|
||||||
allDataDirs = lib.unique (
|
|
||||||
lib.concatMap (c: lib.filter (p: lib.hasPrefix serverDataDir p) c.bindMountHostPaths) (
|
|
||||||
lib.attrValues testContainers
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
mkdirAllDataDirs = lib.concatMapStrings (p: ''mkdir -p "${p}"'' + "\n") allDataDirs;
|
|
||||||
|
|
||||||
# writable data dirs need ownership set to 1000:1000 (the standard
|
|
||||||
# container user uid). services that run as a different user (loki,
|
|
||||||
# prometheus, grafana) fix ownership via StateDirectory on startup.
|
|
||||||
writableDataDirs = lib.unique (
|
|
||||||
lib.concatMap (
|
|
||||||
c:
|
|
||||||
if c.kind == "nspawn" then
|
|
||||||
lib.filter (p: lib.hasPrefix serverDataDir p) (
|
|
||||||
map (bm: bm.hostPath) (lib.attrValues (lib.filterAttrs (_: bm: !bm.isReadOnly) c.bindMounts))
|
|
||||||
)
|
|
||||||
else
|
|
||||||
[ ]
|
|
||||||
) (lib.attrValues testContainers)
|
|
||||||
);
|
|
||||||
|
|
||||||
chownWritableDataDirs = lib.concatMapStrings (
|
|
||||||
p: ''chown -R 1000:1000 "${p}"'' + "\n"
|
|
||||||
) writableDataDirs;
|
|
||||||
|
|
||||||
# secret paths needed by test containers
|
|
||||||
secretPaths = lib.unique (
|
|
||||||
lib.concatMap (c: lib.filter (p: lib.hasPrefix serverSecretsDir p) c.bindMountHostPaths) (
|
|
||||||
lib.attrValues testContainers
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
mkdirSecretParents = lib.concatMapStrings (p: ''mkdir -p "$(dirname '${p}')"'' + "\n") secretPaths;
|
|
||||||
in
|
in
|
||||||
{
|
{
|
||||||
name = "integration-${host.hostName}";
|
name = "integration-${host.hostName}";
|
||||||
@@ -123,17 +90,54 @@ in
|
|||||||
it.serverModule
|
it.serverModule
|
||||||
];
|
];
|
||||||
|
|
||||||
|
containers.nginx.config = {
|
||||||
|
systemd.services = lib.genAttrs (map (d: "acme-order-renew-${d}") nginxAcmeDomains) (_: {
|
||||||
|
enable = lib.mkForce false;
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
system.activationScripts.test-secrets =
|
system.activationScripts.test-secrets =
|
||||||
# bash
|
# bash
|
||||||
''
|
''
|
||||||
mkdir -p /nix/var/nix/db /nix/var/nix/daemon-socket
|
mkdir -p /nix/var/nix/db /nix/var/nix/daemon-socket
|
||||||
mkdir -p /var/log/journal
|
|
||||||
mkdir -p "${serverSecretsDir}"
|
|
||||||
|
|
||||||
${mkdirAllDataDirs}
|
mkdir -p /var/log/journal
|
||||||
|
|
||||||
${mkdirAcmeDirs}
|
${mkdirAcmeDirs}
|
||||||
${mkdirSecretParents}
|
mkdir -p "${serverSecretsDir}" \
|
||||||
${chownWritableDataDirs}
|
"${serverDataDir}/core/sshpiper" \
|
||||||
|
"${serverDataDir}/core/mail" \
|
||||||
|
"${serverDataDir}/overseer/loki/data" \
|
||||||
|
"${serverDataDir}/overseer/prometheus/data" \
|
||||||
|
"${serverDataDir}/overseer/grafana" \
|
||||||
|
"${serverDataDir}/web/git" \
|
||||||
|
"${serverDataDir}/web/git-ci-runner/nix-rw-store" \
|
||||||
|
"${serverDataDir}/web/git-ci-runner/docker" \
|
||||||
|
"${serverDataDir}/web/git-ci-runner/runner-state" \
|
||||||
|
"${serverSecretsDir}/ci-runner" \
|
||||||
|
"${serverDataDir}/web/reposilite" \
|
||||||
|
"${serverDataDir}/web/devenv/config" \
|
||||||
|
"${serverDataDir}/web/devenv/workspace" \
|
||||||
|
"${serverDataDir}/ssh/generic" \
|
||||||
|
"${serverDataDir}/ssh/nyaa" \
|
||||||
|
"${serverDataDir}/mc/botm" \
|
||||||
|
"${serverDataDir}/mc/rogule-dev" \
|
||||||
|
"${serverDataDir}/mc/rogule-build" \
|
||||||
|
"${serverDataDir}/mc/starwalker" \
|
||||||
|
"${serverDataDir}/mc/tl"
|
||||||
|
|
||||||
|
chown -R 1000:1000 \
|
||||||
|
"${serverDataDir}/web/git" \
|
||||||
|
"${serverDataDir}/web/reposilite" \
|
||||||
|
"${serverDataDir}/web/devenv/config" \
|
||||||
|
"${serverDataDir}/web/devenv/workspace" \
|
||||||
|
"${serverDataDir}/core/mail" \
|
||||||
|
"${serverDataDir}/ssh/generic" \
|
||||||
|
"${serverDataDir}/mc/botm" \
|
||||||
|
"${serverDataDir}/mc/rogule-dev" \
|
||||||
|
"${serverDataDir}/mc/rogule-build" \
|
||||||
|
"${serverDataDir}/mc/starwalker" \
|
||||||
|
"${serverDataDir}/mc/tl"
|
||||||
|
|
||||||
for keytype in ed25519 rsa ecdsa; do
|
for keytype in ed25519 rsa ecdsa; do
|
||||||
keyfile="${serverSecretsDir}/ssh_host_''${keytype}_key"
|
keyfile="${serverSecretsDir}/ssh_host_''${keytype}_key"
|
||||||
@@ -142,14 +146,7 @@ in
|
|||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
|
|
||||||
${installFakeCerts}
|
# stalwart rejects weak/dictionary passwords
|
||||||
''
|
|
||||||
+ lib.optionalString (testContainers ? sshpiper) ''
|
|
||||||
mkdir -p "${serverDataDir}/core/sshpiper/user_${sshpiperTestUser}"
|
|
||||||
install -m 644 ${testSshKey}/key.pub \
|
|
||||||
"${serverDataDir}/core/sshpiper/user_${sshpiperTestUser}/authorized_keys"
|
|
||||||
''
|
|
||||||
+ lib.optionalString (testContainers ? mail) ''
|
|
||||||
for f in mail-admin-password mail-account-password; do
|
for f in mail-admin-password mail-account-password; do
|
||||||
target="${serverSecretsDir}/$f"
|
target="${serverSecretsDir}/$f"
|
||||||
if [[ ! -f "$target" ]]; then
|
if [[ ! -f "$target" ]]; then
|
||||||
@@ -157,14 +154,22 @@ in
|
|||||||
chmod 600 "$target"
|
chmod 600 "$target"
|
||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
|
|
||||||
|
if [[ ! -f "${serverSecretsDir}/ci-runner/token" ]]; then
|
||||||
|
echo "TOKEN=test-registration-token" > "${serverSecretsDir}/ci-runner/token"
|
||||||
|
chmod 600 "${serverSecretsDir}/ci-runner/token"
|
||||||
|
fi
|
||||||
|
|
||||||
|
if [[ ! -f "${serverSecretsDir}/code-server-env" ]]; then
|
||||||
|
echo "test-secret" > "${serverSecretsDir}/code-server-env"
|
||||||
|
chmod 600 "${serverSecretsDir}/code-server-env"
|
||||||
|
fi
|
||||||
|
|
||||||
|
${installFakeCerts}
|
||||||
|
mkdir -p "${serverDataDir}/core/sshpiper/user_${sshpiperTestUser}"
|
||||||
|
install -m 644 ${testSshKey}/key.pub \
|
||||||
|
"${serverDataDir}/core/sshpiper/user_${sshpiperTestUser}/authorized_keys"
|
||||||
'';
|
'';
|
||||||
}
|
|
||||||
// lib.optionalAttrs (testContainers ? nginx && nginxAcmeDomains != [ ]) {
|
|
||||||
containers.nginx.config = {
|
|
||||||
systemd.services = lib.genAttrs (map (d: "acme-order-renew-${d}") nginxAcmeDomains) (_: {
|
|
||||||
enable = lib.mkForce false;
|
|
||||||
});
|
|
||||||
};
|
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -177,6 +182,8 @@ in
|
|||||||
TEST_SSH_KEY_STORE = "${testSshKey}/key"
|
TEST_SSH_KEY_STORE = "${testSshKey}/key"
|
||||||
|
|
||||||
SSHPIPER_TEST_USER = "${sshpiperTestUser}"
|
SSHPIPER_TEST_USER = "${sshpiperTestUser}"
|
||||||
|
HOST_EXPORTER_PORT = ${toString hostExporterPort}
|
||||||
|
HOST_CADVISOR_PORT = ${toString hostCadvisorPort}
|
||||||
HOST_SSHD_PORT = ${toString hostSshdPort}
|
HOST_SSHD_PORT = ${toString hostSshdPort}
|
||||||
''
|
''
|
||||||
+ builtins.readFile ./integration.py;
|
+ builtins.readFile ./integration.py;
|
||||||
|
|||||||
+93
-173
@@ -27,17 +27,13 @@ if TYPE_CHECKING:
|
|||||||
HOST_ADDR: dict[str, str] = {}
|
HOST_ADDR: dict[str, str] = {}
|
||||||
IFACE: dict[str, str] = {}
|
IFACE: dict[str, str] = {}
|
||||||
KIND: dict[str, str] = {}
|
KIND: dict[str, str] = {}
|
||||||
DEVICES: dict[str, list[str]] = {}
|
|
||||||
EDGES: list[tuple[str, str, list[int], list[int]]] = []
|
EDGES: list[tuple[str, str, list[int], list[int]]] = []
|
||||||
EXPOSED_TCP: dict[str, list[int]] = {}
|
|
||||||
HOST_ACCESS_TCP: dict[str, list[int]] = {}
|
|
||||||
FORWARD_TCP: list[tuple[int, str, int]] = []
|
|
||||||
NGINX_BACKENDS: dict[str, int] = {}
|
|
||||||
NGINX_DOMAINS: dict[str, str] = {}
|
|
||||||
SSH_KEY: str = ""
|
SSH_KEY: str = ""
|
||||||
SSH_OPTS: str = ""
|
SSH_OPTS: str = ""
|
||||||
TEST_SSH_KEY_STORE: str = ""
|
TEST_SSH_KEY_STORE: str = ""
|
||||||
SSHPIPER_TEST_USER: str = ""
|
SSHPIPER_TEST_USER: str = ""
|
||||||
|
HOST_EXPORTER_PORT: int = 0
|
||||||
|
HOST_CADVISOR_PORT: int = 0
|
||||||
HOST_SSHD_PORT: int = 0
|
HOST_SSHD_PORT: int = 0
|
||||||
|
|
||||||
SW = "/run/current-system/sw/bin"
|
SW = "/run/current-system/sw/bin"
|
||||||
@@ -45,12 +41,6 @@ SH = f"{SW}/sh"
|
|||||||
|
|
||||||
PEER_EDGES = {(src, to) for src, to, _, _ in EDGES if to not in ("@host", "@internet")}
|
PEER_EDGES = {(src, to) for src, to, _, _ in EDGES if to not in ("@host", "@internet")}
|
||||||
|
|
||||||
# pre-compute the set of all host-access ports (union across containers)
|
|
||||||
ALL_HOST_ACCESS_PORTS = {p for ps in HOST_ACCESS_TCP.values() for p in ps}
|
|
||||||
|
|
||||||
# published host ports
|
|
||||||
FWD_HOST_PORTS = {hp for hp, _, _ in FORWARD_TCP}
|
|
||||||
|
|
||||||
|
|
||||||
def failed_units(node_arg=""):
|
def failed_units(node_arg=""):
|
||||||
out = server.succeed(f"systemctl {node_arg} list-units --state=failed --no-legend --plain || true")
|
out = server.succeed(f"systemctl {node_arg} list-units --state=failed --no-legend --plain || true")
|
||||||
@@ -65,11 +55,6 @@ def container_pid(name):
|
|||||||
return server.succeed(f"machinectl show {name} -p Leader --value").strip()
|
return server.succeed(f"machinectl show {name} -p Leader --value").strip()
|
||||||
|
|
||||||
|
|
||||||
def ct_cmd(name, cmd):
|
|
||||||
pid = container_pid(name)
|
|
||||||
return f"{NSENTER} --mount=/proc/{pid}/ns/mnt --root=/proc/{pid}/root -- {SH} -c '{cmd}'"
|
|
||||||
|
|
||||||
|
|
||||||
def net_cmd(name, cmd):
|
def net_cmd(name, cmd):
|
||||||
pid = container_pid(name)
|
pid = container_pid(name)
|
||||||
return f"{NSENTER} --net=/proc/{pid}/ns/net -- {cmd}"
|
return f"{NSENTER} --net=/proc/{pid}/ns/net -- {cmd}"
|
||||||
@@ -153,32 +138,40 @@ with subtest("(isolation): internet egress follows the access list"):
|
|||||||
server.fail(net_cmd(name, f"{IP} route show default | grep -q ."))
|
server.fail(net_cmd(name, f"{IP} route show default | grep -q ."))
|
||||||
|
|
||||||
with subtest("(functional): container DNS still resolves"):
|
with subtest("(functional): container DNS still resolves"):
|
||||||
src = enterable[0]
|
|
||||||
dst = next(c for c in included if c != src)
|
|
||||||
resolved = server.succeed(
|
resolved = server.succeed(
|
||||||
net_cmd(src, f"{DIG} +short +time=3 @{HOST_ADDR[src]} {dst}.containers")
|
net_cmd("git", f"{DIG} +short +time=3 @{HOST_ADDR['git']} nginx.containers")
|
||||||
).strip()
|
).strip()
|
||||||
assert resolved == ADDR[dst], f"{dst}.containers resolved to {resolved!r}, expected {ADDR[dst]}"
|
assert resolved == ADDR["nginx"], f"nginx.containers resolved to {resolved!r}, expected {ADDR['nginx']}"
|
||||||
|
|
||||||
with subtest("(functional): web services respond"):
|
with subtest("(functional): web services respond"):
|
||||||
for name, port in NGINX_BACKENDS.items():
|
for name, port in [("devenv", 8080), ("maven", 8080), ("git", 3000)]:
|
||||||
if name in enterable:
|
|
||||||
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"))
|
||||||
|
|
||||||
|
with subtest("(functional): mail accepts connections"):
|
||||||
|
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)
|
||||||
|
|
||||||
|
imap_probe = net_cmd(
|
||||||
|
"mail",
|
||||||
|
f"{TIMEOUT} 3 {OPENSSL} s_client -connect {ADDR['mail']}:993 -quiet -verify_quiet 2>/dev/null",
|
||||||
|
)
|
||||||
|
|
||||||
|
def imap_ready(_):
|
||||||
|
greeting = server.execute(f"echo | {imap_probe} | head -1")[1]
|
||||||
|
return greeting.strip().startswith("* OK")
|
||||||
|
|
||||||
|
retry(imap_ready, timeout_seconds=60)
|
||||||
|
|
||||||
with subtest("(functional): nginx proxies to backend containers"):
|
with subtest("(functional): nginx proxies to backend containers"):
|
||||||
if "nginx" in enterable:
|
|
||||||
for domain, backend in NGINX_DOMAINS.items():
|
|
||||||
if backend in included:
|
|
||||||
server.succeed(
|
server.succeed(
|
||||||
net_cmd(
|
net_cmd(
|
||||||
"nginx",
|
"nginx",
|
||||||
f"{CURL} -sfk --max-time 5 --resolve {domain}:443:{ADDR['nginx']} "
|
f"{CURL} -sfk --max-time 5 --resolve git.floweytf.com:443:{ADDR['nginx']} "
|
||||||
f"https://{domain}/ >&2",
|
"https://git.floweytf.com/ >&2",
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
with subtest("(functional): sshpiper authenticates/routes properly"):
|
with subtest("(functional): sshpiper authenticates/routes properly"):
|
||||||
if "sshpiper" in included:
|
|
||||||
whoami = server.succeed(f"{SSH} {SSH_OPTS} -p 2222 {SSHPIPER_TEST_USER}@{ADDR['sshpiper']} whoami").strip()
|
whoami = server.succeed(f"{SSH} {SSH_OPTS} -p 2222 {SSHPIPER_TEST_USER}@{ADDR['sshpiper']} whoami").strip()
|
||||||
assert whoami == "runner", f"expected to land as runner, got {whoami}"
|
assert whoami == "runner", f"expected to land as runner, got {whoami}"
|
||||||
hostname = server.succeed(
|
hostname = server.succeed(
|
||||||
@@ -194,136 +187,94 @@ with subtest("(isolation): every declared container edge connects"):
|
|||||||
server.succeed(ct_connect(src, ADDR[to], port))
|
server.succeed(ct_connect(src, ADDR[to], port))
|
||||||
|
|
||||||
with subtest("(isolation): undeclared container edges are refused"):
|
with subtest("(isolation): undeclared container edges are refused"):
|
||||||
tested = 0
|
for src, dst, port in [
|
||||||
for src in enterable:
|
("devenv", "git", 3000),
|
||||||
for dst in enterable:
|
("git", "devenv", 8080),
|
||||||
if src == dst or (src, dst) in PEER_EDGES:
|
("maven", "git", 3000),
|
||||||
continue
|
("nginx", "mail", 25),
|
||||||
ports = EXPOSED_TCP.get(dst, [])
|
("ssh-botm", "ssh-admin", 22),
|
||||||
if not ports:
|
("overseer", "git", 3000),
|
||||||
continue
|
]:
|
||||||
server.fail(ct_connect(src, ADDR[dst], ports[0], timeout=2))
|
assert (src, dst) not in PEER_EDGES, f"{src} -> {dst} is a declared edge, not a negative case"
|
||||||
tested += 1
|
server.fail(ct_connect(src, ADDR[dst], port, timeout=2))
|
||||||
assert tested > 0, "no negative edge cases to test"
|
|
||||||
|
|
||||||
with subtest("(isolation): edges are one-way"):
|
with subtest("(isolation): edges are one-way"):
|
||||||
tested = 0
|
assert ("nginx", "git") in PEER_EDGES
|
||||||
for src, dst, tcp_ports, _ in EDGES:
|
assert ("git", "nginx") not in PEER_EDGES
|
||||||
if dst in ("@host", "@internet") or src not in enterable or dst not in enterable:
|
server.succeed(ct_connect("nginx", ADDR["git"], 3000))
|
||||||
continue
|
server.fail(ct_connect("git", ADDR["nginx"], 443, timeout=2))
|
||||||
if (dst, src) in PEER_EDGES or not tcp_ports:
|
|
||||||
continue
|
|
||||||
server.succeed(ct_connect(src, ADDR[dst], tcp_ports[0]))
|
|
||||||
tested += 1
|
|
||||||
rev_ports = EXPOSED_TCP.get(src, [])
|
|
||||||
if rev_ports:
|
|
||||||
server.fail(ct_connect(dst, ADDR[src], rev_ports[0], timeout=2))
|
|
||||||
assert tested > 0, "no one-way edge cases to test"
|
|
||||||
|
|
||||||
with subtest("(isolation): host access allowlist"):
|
with subtest("(isolation): host access allowlist"):
|
||||||
for name, ports in HOST_ACCESS_TCP.items():
|
server.succeed(
|
||||||
if name in enterable:
|
net_cmd(
|
||||||
for port in ports:
|
"overseer",
|
||||||
server.succeed(ct_connect(name, HOST_ADDR[name], port))
|
f"{CURL} -sf --max-time 5 http://{HOST_ADDR['overseer']}:{HOST_EXPORTER_PORT}/metrics >&2",
|
||||||
no_access = [c for c in enterable if c not in HOST_ACCESS_TCP]
|
)
|
||||||
if no_access and ALL_HOST_ACCESS_PORTS:
|
)
|
||||||
ct = no_access[0]
|
for port in (HOST_EXPORTER_PORT, HOST_CADVISOR_PORT):
|
||||||
for port in ALL_HOST_ACCESS_PORTS:
|
server.fail(ct_connect("git", HOST_ADDR["git"], port, timeout=2))
|
||||||
server.fail(ct_connect(ct, HOST_ADDR[ct], port, timeout=2))
|
server.fail(ct_connect("git", HOST_ADDR["overseer"], port, timeout=2))
|
||||||
# reaching the port through a different container's host addr is also blocked
|
|
||||||
for other in HOST_ACCESS_TCP:
|
|
||||||
if other in included:
|
|
||||||
server.fail(ct_connect(ct, HOST_ADDR[other], port, timeout=2))
|
|
||||||
|
|
||||||
with subtest("(isolation): host services outside the access list"):
|
with subtest("(isolation): host services outside the access list"):
|
||||||
internet.succeed(connect(server_ip, HOST_SSHD_PORT))
|
internet.succeed(connect(server_ip, HOST_SSHD_PORT))
|
||||||
for name in enterable:
|
for name in ("git", "overseer"):
|
||||||
if HOST_SSHD_PORT not in HOST_ACCESS_TCP.get(name, []):
|
|
||||||
server.fail(ct_connect(name, HOST_ADDR[name], HOST_SSHD_PORT, timeout=2))
|
server.fail(ct_connect(name, HOST_ADDR[name], HOST_SSHD_PORT, timeout=2))
|
||||||
server.fail(ct_connect(name, server_ip, HOST_SSHD_PORT, timeout=2))
|
server.fail(ct_connect(name, server_ip, HOST_SSHD_PORT, timeout=2))
|
||||||
|
|
||||||
with subtest("(isolation): source address spoofing is dropped"):
|
with subtest("(isolation): source address spoofing is dropped"):
|
||||||
src = enterable[0]
|
|
||||||
other = enterable[1]
|
|
||||||
|
|
||||||
before = spoof_counter()
|
before = spoof_counter()
|
||||||
server.succeed(net_cmd(src, f"{PING} -c 1 -W 2 {HOST_ADDR[src]} >&2"))
|
server.succeed(net_cmd("git", f"{PING} -c 1 -W 2 {HOST_ADDR['git']} >&2"))
|
||||||
assert spoof_counter() == before, "an unspoofed packet hit the source guard"
|
assert spoof_counter() == before, "an unspoofed packet hit the source guard"
|
||||||
|
|
||||||
iface = IFACE[src]
|
iface = IFACE["git"]
|
||||||
server.succeed(net_cmd(src, f"{IP} addr add {ADDR[other]}/32 dev {iface}"))
|
server.succeed(net_cmd("git", f"{IP} addr add {ADDR['nginx']}/32 dev {iface}"))
|
||||||
try:
|
try:
|
||||||
server.execute(
|
server.execute(
|
||||||
net_cmd(src, f"{PING} -c 2 -W 2 -I {ADDR[other]} {HOST_ADDR[src]}")
|
net_cmd("git", f"{PING} -c 2 -W 2 -I {ADDR['nginx']} {HOST_ADDR['git']}")
|
||||||
)
|
)
|
||||||
assert spoof_counter() > before, "a forged source address was not dropped"
|
assert spoof_counter() > before, "a forged source address was not dropped"
|
||||||
finally:
|
finally:
|
||||||
server.succeed(net_cmd(src, f"{IP} addr del {ADDR[other]}/32 dev {iface}"))
|
server.succeed(net_cmd("git", f"{IP} addr del {ADDR['nginx']}/32 dev {iface}"))
|
||||||
|
|
||||||
with subtest("(isolation): renaming the interface changes nothing"):
|
with subtest("(isolation): renaming the interface changes nothing"):
|
||||||
# find a container with a declared peer edge
|
iface, host_addr = IFACE["nginx"], HOST_ADDR["nginx"]
|
||||||
rename_src = rename_dst = rename_port = None
|
|
||||||
for src, dst, tcp_ports, _ in EDGES:
|
|
||||||
if dst in ("@host", "@internet") or src not in enterable or dst not in included:
|
|
||||||
continue
|
|
||||||
if tcp_ports:
|
|
||||||
rename_src, rename_dst, rename_port = src, dst, tcp_ports[0]
|
|
||||||
break
|
|
||||||
|
|
||||||
assert rename_src is not None and rename_dst is not None and rename_port is not None, \
|
|
||||||
"no peer edge to test interface rename"
|
|
||||||
|
|
||||||
iface, host_addr = IFACE[rename_src], HOST_ADDR[rename_src]
|
|
||||||
|
|
||||||
def rename(frm, to):
|
def rename(frm, to):
|
||||||
server.succeed(net_cmd(rename_src, f"{IP} link set dev {frm} down"))
|
server.succeed(net_cmd("nginx", f"{IP} link set dev {frm} down"))
|
||||||
server.succeed(net_cmd(rename_src, f"{IP} link set dev {frm} name {to}"))
|
server.succeed(net_cmd("nginx", f"{IP} link set dev {frm} name {to}"))
|
||||||
server.succeed(net_cmd(rename_src, f"{IP} link set dev {to} up"))
|
server.succeed(net_cmd("nginx", f"{IP} link set dev {to} up"))
|
||||||
for route in (host_addr, f"10.0.0.0/8 via {host_addr}", f"default via {host_addr}"):
|
for route in (host_addr, f"10.0.0.0/8 via {host_addr}", f"default via {host_addr}"):
|
||||||
server.succeed(net_cmd(rename_src, f"{IP} route replace {route} dev {to}"))
|
server.succeed(net_cmd("nginx", f"{IP} route replace {route} dev {to}"))
|
||||||
|
|
||||||
rename(iface, "evil0")
|
rename(iface, "evil0")
|
||||||
try:
|
try:
|
||||||
server.succeed(ct_connect(rename_src, ADDR[rename_dst], rename_port))
|
server.succeed(ct_connect("nginx", ADDR["git"], 3000))
|
||||||
|
server.fail(ct_connect("nginx", ADDR["mail"], 25, timeout=2))
|
||||||
finally:
|
finally:
|
||||||
rename("evil0", iface)
|
rename("evil0", iface)
|
||||||
|
|
||||||
with subtest("(isolation): the veth cannot be moved out of the namespace"):
|
with subtest("(isolation): the veth cannot be moved out of the namespace"):
|
||||||
ct = enterable[0]
|
server.fail(net_cmd("git", f"{IP} link set dev {IFACE['git']} netns 1"))
|
||||||
server.fail(net_cmd(ct, f"{IP} link set dev {IFACE[ct]} netns 1"))
|
|
||||||
|
|
||||||
with subtest("(isolation): route bypass"):
|
with subtest("(isolation): route bypass"):
|
||||||
bypass_ct = next((c for c in enterable if c in no_gateway), None)
|
iface = IFACE["hopper"]
|
||||||
if bypass_ct is None:
|
|
||||||
bypass_ct = next((c for c in enterable if c not in allow_internet), None)
|
|
||||||
assert bypass_ct is not None, "no container without internet to test route bypass"
|
|
||||||
|
|
||||||
iface = IFACE[bypass_ct]
|
|
||||||
server.succeed(
|
server.succeed(
|
||||||
net_cmd(bypass_ct, f"{IP} route replace default via {HOST_ADDR[bypass_ct]} dev {iface} onlink")
|
net_cmd("hopper", f"{IP} route replace default via {HOST_ADDR['hopper']} dev {iface} onlink")
|
||||||
)
|
)
|
||||||
server.fail(net_cmd(bypass_ct, f"{CURL} -sf --max-time 5 http://{internet_ip}/ >&2"))
|
server.fail(net_cmd("hopper", f"{CURL} -sf --max-time 5 http://{internet_ip}/ >&2"))
|
||||||
unreachable = next(
|
server.fail(ct_connect("hopper", ADDR["git"], 3000, timeout=2))
|
||||||
(c for c in included if c != bypass_ct and (bypass_ct, c) not in PEER_EDGES and EXPOSED_TCP.get(c, [])),
|
|
||||||
None,
|
|
||||||
)
|
|
||||||
if unreachable:
|
|
||||||
server.fail(ct_connect(bypass_ct, ADDR[unreachable], EXPOSED_TCP[unreachable][0], timeout=2))
|
|
||||||
|
|
||||||
with subtest("(isolation): no IPv6 link-local addresses"):
|
with subtest("(isolation): no IPv6 link-local addresses"):
|
||||||
for name in enterable:
|
for name in ["git", "overseer"]:
|
||||||
assert not has_ipv6_link_local(name), f"{name} still has an IPv6 link-local address"
|
assert not has_ipv6_link_local(name), f"{name} still has an IPv6 link-local address"
|
||||||
|
|
||||||
with subtest("(isolation): published ports grant no reach between containers"):
|
with subtest("(isolation): published ports grant no reach between containers"):
|
||||||
if FWD_HOST_PORTS:
|
for port in (80, 443, 25565, 22, 25):
|
||||||
ct = next((c for c in enterable if c not in HOST_ACCESS_TCP), enterable[0])
|
server.fail(ct_connect("overseer", HOST_ADDR["overseer"], port, timeout=2))
|
||||||
for port in FWD_HOST_PORTS:
|
server.fail(ct_connect("git", server_ip, port, timeout=2))
|
||||||
server.fail(ct_connect(ct, HOST_ADDR[ct], port, timeout=2))
|
|
||||||
server.fail(ct_connect(ct, server_ip, next(iter(FWD_HOST_PORTS)), timeout=2))
|
|
||||||
|
|
||||||
with subtest("(isolation): privilege escalation / container escape"):
|
with subtest("(isolation): privilege escalation / container escape"):
|
||||||
ct = enterable[0]
|
leader = container_pid("git")
|
||||||
leader = container_pid(ct)
|
|
||||||
|
|
||||||
host_uid = server.succeed(f"awk '/^Uid:/{{print $2}}' /proc/{leader}/status").strip()
|
host_uid = server.succeed(f"awk '/^Uid:/{{print $2}}' /proc/{leader}/status").strip()
|
||||||
assert host_uid != "0", "container's PID 1 is not idmapped away from host uid 0"
|
assert host_uid != "0", "container's PID 1 is not idmapped away from host uid 0"
|
||||||
@@ -332,16 +283,28 @@ with subtest("(isolation): privilege escalation / container escape"):
|
|||||||
container_pidns = server.succeed(f"readlink /proc/{leader}/ns/pid").strip()
|
container_pidns = server.succeed(f"readlink /proc/{leader}/ns/pid").strip()
|
||||||
assert host_pidns != container_pidns, "container shares the host's PID namespace"
|
assert host_pidns != container_pidns, "container shares the host's PID namespace"
|
||||||
|
|
||||||
server.fail(ct_cmd(ct, "touch /nix/store/canary"))
|
server.succeed(
|
||||||
|
f"{NSENTER} --mount=/proc/{leader}/ns/mnt --root=/proc/{leader}/root -- "
|
||||||
|
f"{SH} -c 'echo x >> /var/lib/gitea/canary' >&2"
|
||||||
|
)
|
||||||
|
|
||||||
|
sshpiper_pid = container_pid("sshpiper")
|
||||||
|
server.fail(
|
||||||
|
f"{NSENTER} --mount=/proc/{sshpiper_pid}/ns/mnt --root=/proc/{sshpiper_pid}/root -- "
|
||||||
|
f"{SH} -c 'echo x >> /etc/ssh/ssh_host_ed25519_key' >&2"
|
||||||
|
)
|
||||||
|
server.fail(
|
||||||
|
f"{NSENTER} --mount=/proc/{leader}/ns/mnt --root=/proc/{leader}/root -- "
|
||||||
|
f"{SH} -c 'touch /nix/store/canary' >&2"
|
||||||
|
)
|
||||||
server.fail(
|
server.fail(
|
||||||
f"{NSENTER} --mount=/proc/{leader}/ns/mnt --root=/proc/{leader}/root -- "
|
f"{NSENTER} --mount=/proc/{leader}/ns/mnt --root=/proc/{leader}/root -- "
|
||||||
"/run/current-system/sw/bin/test -d /persist >&2"
|
"/run/current-system/sw/bin/test -d /persist >&2"
|
||||||
)
|
)
|
||||||
|
|
||||||
with subtest("(functional): external clients reach published ports"):
|
with subtest("(functional): external clients reach published ports"):
|
||||||
for hp, _, _ in FORWARD_TCP:
|
for port in (80, 25565, 22):
|
||||||
internet.succeed(ext_connect(hp))
|
internet.succeed(ext_connect(port))
|
||||||
# a non-published port should be unreachable
|
|
||||||
internet.fail(ext_connect(8080))
|
internet.fail(ext_connect(8080))
|
||||||
|
|
||||||
with subtest("(functional): no failing-reason restarts"):
|
with subtest("(functional): no failing-reason restarts"):
|
||||||
@@ -350,61 +313,18 @@ with subtest("(functional): no failing-reason restarts"):
|
|||||||
assert (
|
assert (
|
||||||
failed_units(f"-M {name}") == []
|
failed_units(f"-M {name}") == []
|
||||||
), f"{name} has failed units: {failed_units(f'-M {name}')}"
|
), f"{name} has failed units: {failed_units(f'-M {name}')}"
|
||||||
unit = "container" if KIND[name] == "nspawn" else "microvm"
|
restarts = server.succeed(f"systemctl show container@{name}.service -p NRestarts --value").strip()
|
||||||
restarts = server.succeed(f"systemctl show {unit}@{name}.service -p NRestarts --value").strip()
|
assert restarts == "0", f"container@{name}.service restarted {restarts} times"
|
||||||
assert restarts == "0", f"{unit}@{name}.service restarted {restarts} times"
|
|
||||||
|
|
||||||
with subtest("(functional): port forwards survive an nftables reload"):
|
with subtest("(functional): port forwards survive an nftables reload"):
|
||||||
if FORWARD_TCP:
|
|
||||||
hp, ct_name, _ = FORWARD_TCP[0]
|
|
||||||
server.succeed("systemctl reload nftables.service")
|
server.succeed("systemctl reload nftables.service")
|
||||||
elements = server.succeed("nft list map ip container-portforward tcp-fwd")
|
elements = server.succeed("nft list map ip container-portforward tcp-fwd")
|
||||||
assert re.search(rf"\b{hp}\s*:", elements), f"nftables reload emptied the map: {elements!r}"
|
assert re.search(r"\b80\s*:", elements), f"nftables reload emptied the map: {elements!r}"
|
||||||
internet.wait_until_succeeds(ext_connect(hp), timeout=30)
|
internet.wait_until_succeeds(ext_connect(80), timeout=30)
|
||||||
|
|
||||||
with subtest("(functional): published ports follow the container's lifetime"):
|
with subtest("(functional): published ports follow the container's lifetime"):
|
||||||
if FORWARD_TCP:
|
server.succeed("systemctl stop container@nginx")
|
||||||
hp, ct_name, _ = FORWARD_TCP[0]
|
internet.fail(ext_connect(80))
|
||||||
unit = "container" if KIND[ct_name] == "nspawn" else "microvm"
|
server.succeed("systemctl start container@nginx")
|
||||||
server.succeed(f"systemctl stop {unit}@{ct_name}")
|
server.wait_for_unit("container@nginx.service")
|
||||||
internet.fail(ext_connect(hp))
|
internet.wait_until_succeeds(ext_connect(80), timeout=30)
|
||||||
server.succeed(f"systemctl start {unit}@{ct_name}")
|
|
||||||
server.wait_for_unit(f"{unit}@{ct_name}.service")
|
|
||||||
internet.wait_until_succeeds(ext_connect(hp), timeout=30)
|
|
||||||
|
|
||||||
with subtest("(functional): declared devices are usable in-container"):
|
|
||||||
for name, devices in DEVICES.items():
|
|
||||||
for dev in devices:
|
|
||||||
# opened, not stat'd: without DeviceAllow= the node is still visible
|
|
||||||
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"):
|
|
||||||
for name in enterable:
|
|
||||||
for dev in {d for ds in DEVICES.values() for d in ds} - set(DEVICES.get(name, [])):
|
|
||||||
server.fail(ct_cmd(name, f"test -e {dev}"))
|
|
||||||
|
|
||||||
|
|
||||||
with subtest("(isolation): identity uid mapping keeps the user namespace"):
|
|
||||||
for name in (n for n, ds in DEVICES.items() if ds):
|
|
||||||
host_ns = server.succeed("readlink /proc/1/ns/user").strip()
|
|
||||||
ct_ns = server.succeed(f"readlink /proc/{container_pid(name)}/ns/user").strip()
|
|
||||||
assert host_ns != ct_ns, f"{name} shares the host user namespace"
|
|
||||||
|
|||||||
Reference in New Issue
Block a user