Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5792b8a680 |
+8
-2
@@ -5,7 +5,6 @@
|
|||||||
hostInfo,
|
hostInfo,
|
||||||
customPkgs,
|
customPkgs,
|
||||||
flakeRev,
|
flakeRev,
|
||||||
deployLabel,
|
|
||||||
...
|
...
|
||||||
}:
|
}:
|
||||||
let
|
let
|
||||||
@@ -63,7 +62,14 @@ 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;
|
system.nixos.label =
|
||||||
|
let
|
||||||
|
labelFile = ./.nixos-label;
|
||||||
|
in
|
||||||
|
if builtins.pathExists labelFile then
|
||||||
|
lib.removeSuffix "\n" (builtins.readFile labelFile)
|
||||||
|
else
|
||||||
|
flakeRev;
|
||||||
|
|
||||||
nix = {
|
nix = {
|
||||||
settings = {
|
settings = {
|
||||||
|
|||||||
@@ -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;
|
||||||
|
}
|
||||||
@@ -53,10 +53,6 @@ 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 =
|
||||||
@@ -180,9 +176,8 @@ in
|
|||||||
PermitEmptyPasswords = "yes";
|
PermitEmptyPasswords = "yes";
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
security.pam.services.sshd.allowNullPassword = true;
|
|
||||||
users.users.root.initialHashedPassword = "";
|
users.users.root.initialHashedPassword = "";
|
||||||
services.journald.settings.Journal.ForwardToConsole = "yes";
|
services.journald.extraConfig = "ForwardToConsole=yes";
|
||||||
|
|
||||||
virtualisation.containerd.enable = true;
|
virtualisation.containerd.enable = true;
|
||||||
virtualisation.containerd.settings.plugins."io.containerd.snapshotter.v1.overlayfs".mount_options =
|
virtualisation.containerd.settings.plugins."io.containerd.snapshotter.v1.overlayfs".mount_options =
|
||||||
|
|||||||
@@ -150,9 +150,6 @@ mkContainer {
|
|||||||
|
|
||||||
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,7 +208,6 @@ 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;
|
inherit (c) hostAddr;
|
||||||
|
|||||||
@@ -1223,43 +1223,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 +1269,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.
|
||||||
@@ -1367,12 +1330,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": 1791551030,
|
"lastModified": 1786300091,
|
||||||
"narHash": "sha256-jTx3O3MKqPjv+cDfBFQ5zlKECBEwzF91scC+mSumZyE=",
|
"narHash": "sha256-4UFJOVGpaYtHW5yasSv80MaJxTBYdk2zyf3jhKtt0wA=",
|
||||||
"owner": "microvm-nix",
|
"owner": "microvm-nix",
|
||||||
"repo": "microvm.nix",
|
"repo": "microvm.nix",
|
||||||
"rev": "f13928fe9900e91709d7ce581eefa47eaafa79e1",
|
"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": 1792210252,
|
"lastModified": 1786384358,
|
||||||
"narHash": "sha256-Mh0PUaIv4nFY+8wAGonaEh8iBzwsmdNlwjVHmFg1Biw=",
|
"narHash": "sha256-RzPPiWeUtuvymnpuEWsdtzli5w4kjZs49FqEs3/1u+I=",
|
||||||
"owner": "NixOS",
|
"owner": "NixOS",
|
||||||
"repo": "nixpkgs",
|
"repo": "nixpkgs",
|
||||||
"rev": "09063bd1f2b36fd9fd793c36dfade7bd40a93dfc",
|
"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,8 +7,6 @@
|
|||||||
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 =
|
||||||
@@ -17,7 +15,6 @@
|
|||||||
nixpkgs,
|
nixpkgs,
|
||||||
mtce,
|
mtce,
|
||||||
microvm,
|
microvm,
|
||||||
deploy-label,
|
|
||||||
...
|
...
|
||||||
}:
|
}:
|
||||||
let
|
let
|
||||||
@@ -26,12 +23,6 @@
|
|||||||
pkgs = import nixpkgs { inherit system; };
|
pkgs = import nixpkgs { inherit system; };
|
||||||
|
|
||||||
flakeRev = self.shortRev or self.dirtyShortRev or "unknown";
|
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 { };
|
||||||
@@ -65,12 +56,7 @@
|
|||||||
|
|
||||||
specialArgsFor = hostName: {
|
specialArgsFor = hostName: {
|
||||||
hostInfo = hostInfoFor hostName;
|
hostInfo = hostInfoFor hostName;
|
||||||
inherit
|
inherit inputs customPkgs flakeRev;
|
||||||
inputs
|
|
||||||
customPkgs
|
|
||||||
flakeRev
|
|
||||||
deployLabel
|
|
||||||
;
|
|
||||||
};
|
};
|
||||||
|
|
||||||
hostDefFor =
|
hostDefFor =
|
||||||
|
|||||||
@@ -48,17 +48,15 @@ runas git tag -v "$latest" || {
|
|||||||
sha=$(runas git rev-list -1 "$latest")
|
sha=$(runas git rev-list -1 "$latest")
|
||||||
report_status "pending" "deploying $latest" "$sha"
|
report_status "pending" "deploying $latest" "$sha"
|
||||||
|
|
||||||
label_dir=$(mktemp -d)
|
runas git checkout "$latest"
|
||||||
echo "$latest" > "$label_dir/label"
|
runas tee .nixos-label <<< "$latest" >/dev/null
|
||||||
flake_url="git+${GITEA_URL}/${GITEA_REPO}?ref=refs/tags/${latest}&rev=${sha}#$HOSTNAME"
|
runas git add .nixos-label
|
||||||
|
|
||||||
if nixos-rebuild switch --flake "$flake_url" --override-input deploy-label "path:$label_dir"; then
|
if nixos-rebuild switch --flake ".#$HOSTNAME"; then
|
||||||
rm -rf "$label_dir"
|
|
||||||
echo "$latest" > "$STATE_DIR/tag"
|
echo "$latest" > "$STATE_DIR/tag"
|
||||||
report_status "success" "deployed $latest" "$sha"
|
report_status "success" "deployed $latest" "$sha"
|
||||||
echo "deployed $latest"
|
echo "deployed $latest"
|
||||||
else
|
else
|
||||||
rm -rf "$label_dir"
|
|
||||||
report_status "failure" "nixos-rebuild failed" "$sha"
|
report_status "failure" "nixos-rebuild failed" "$sha"
|
||||||
exit 1
|
exit 1
|
||||||
fi
|
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;
|
||||||
|
|||||||
+91
-130
@@ -29,15 +29,12 @@ if TYPE_CHECKING:
|
|||||||
KIND: dict[str, str] = {}
|
KIND: dict[str, str] = {}
|
||||||
DEVICES: dict[str, list[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 +42,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")
|
||||||
@@ -153,32 +144,43 @@ 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"))
|
||||||
|
|
||||||
|
# TODO: re-enable mail
|
||||||
|
"""
|
||||||
|
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 +196,89 @@ 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(ct_connect("overseer", HOST_ADDR["overseer"], HOST_EXPORTER_PORT))
|
||||||
if name in enterable:
|
for port in (HOST_EXPORTER_PORT, HOST_CADVISOR_PORT):
|
||||||
for port in ports:
|
server.fail(ct_connect("git", HOST_ADDR["git"], port, timeout=2))
|
||||||
server.succeed(ct_connect(name, HOST_ADDR[name], port))
|
server.fail(ct_connect("git", HOST_ADDR["overseer"], port, timeout=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 ALL_HOST_ACCESS_PORTS:
|
|
||||||
server.fail(ct_connect(ct, HOST_ADDR[ct], 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 +287,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,27 +317,21 @@ 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"):
|
with subtest("(functional): declared devices are usable in-container"):
|
||||||
for name, devices in DEVICES.items():
|
for name, devices in DEVICES.items():
|
||||||
|
|||||||
Reference in New Issue
Block a user