fix(disaster-recovery): stage Caddyfile + close path-traversal in assets/themes (DC-079) [glm-grade=A]

DC-079 2-round GLM-5.3 judge verdict: round1=C (blocking path-traversal
in assets/themes) → round2=A. 20/20 tests in routes/discover-disaster
(8 original + 12 new). Full repo: 2351/2351 (4 pre-existing billing
pdfkit failures unchanged).

THREAT MODEL
POST /api/v1/disaster/restore was the ONLY endpoint in the route tree
that wrote directly to process.env.CADDYFILE_PATH (=/caddyfile in
container = /etc/caddy/Caddyfile on host via start.sh:161 bind-mount).
Pre-fix: an authenticated dashboard operator POSTed
  {caddyfile: '<attacker-controlled-string>'}
and the handler called fsp.writeFile(caddyfilePath, snapshot.caddyfile),
overwriting the live Caddyfile immediately. Caddy reads this file on
every reload (ACME renewal, health probe, admin API touch), so the
attacker-controlled content executes as Caddy config directives:
  - import /etc/caddy/<anything-caddy-can-read> (content theft)
  - admin off (lock out admin API)
  - reverse_proxy to attacker IPs (Caddy becomes a pivot)
  - acme_ca override to attacker CA (rogue cert issuance)
  - log to attacker-writable paths (DoS/escape)
This bypassed the CLAUDE.md hard rule 'Caddyfile edits must use
caddy-apply' (validates + reloads + git-commits atomically).

FIX 1 — Caddyfile staging (round-1)
- New validateCaddyfileContent(): type check, non-empty check,
  512 KiB byte cap (defense-in-depth below the 1 MB body-parser limit),
  FORBIDDEN_IMPORT_RE rejects  directives with absolute paths,
  ../-escape, ~/, or URL-encoded payloads.
- POST /disaster/restore now writes to <dataDir>/disaster-staged/
  Caddyfile.candidate (atomic write + rename), NEVER to caddyfilePath.
- Response includes caddyfileStaged[{file, stagedPath, action: 'awaiting
  caddy-apply', livePath}] and a DC-079 warning instructing the operator
  to run `caddy-apply <reason>` to validate + reload + git-commit.

FIX 2 — assets/themes path-traversal (round-2 BLOCKING)
GLM round-1 caught a parallel vector: snapshot.assets[name] and
snapshot.themes[name] are user-controlled JSON keys flowing into
path.join(assetsDir, name) and path.join(themesDir, name). An attacker
could POST {assets: {'../../etc/caddy/Caddyfile': '<base64-evil>'}}
and overwrite the live Caddyfile via the dataDir bind-mount, fully
bypassing Fix 1.
- ASSET_KEY_RE = /^[a-zA-Z0-9._-]+$/ + ASSET_PATH_TRAVERSAL_RE catch
  slashes, leading '..', and absolute-path keys.
- THEME_NAME_RE = /^[a-zA-Z0-9._-]+\.json\$/ additionally forces
  .json extension and no slashes.
- assertSafeAssetKey/assertSafeThemeName helpers throw on invalid input.
- Both restore loops now: assert → path.resolve(dir, name) → containment
  check (resolved must start with path.resolve(dir) + path.sep) → write
  to resolved (never the raw join).

TESTS
12 new tests in __tests__/routes/discover-disaster.routes.test.js:
- staging: live sentinel unchanged, candidate at expected path
- rejects: non-string, empty, oversize, 3 forbidden-import variants
- assets: path-traversal key, absolute-path key
- themes: path-traversal name, no-extension name
- back-compat: no caddyfile field succeeds without staging

dashcaddy-api/__tests__/nesting-guard.test.js

@@ -0,0 +1,112 @@
+/**
+ * Nesting-guard tests — DC-077 (data/data recursive duplicate cleanup)
+ *
+ * The guard runs at app startup. Pre-fix, `src/config/paths.js` did NOT
+ * re-export `dataDir`, so `paths.dataDir` resolved to `undefined`. The
+ * outer try/catch swallowed the resulting `TypeError [ERR_INVALID_ARG_TYPE]`
+ * and the entire guard became a silent no-op — every startup logged
+ * `[nesting-guard] Skipped: The "path" argument must be of type string.
+ * Received undefined`. Post-fix, paths.js exports `dataDir` and the guard
+ * falls back to platform-paths directly if `paths.dataDir` is missing.
+ *
+ * Tests use jest.isolateModules() for clean module-cache isolation.
+ * jest.doMock is intentionally avoided — it persists across tests in a
+ * describe and is the root cause of subtle flakes.
+ */
+
+const fs = require('fs');
+const path = require('path');
+const os = require('os');
+
+describe('nesting-guard (DC-077)', () => {
+  const originalEnv = { ...process.env };
+
+  beforeEach(() => {
+    jest.restoreAllMocks();
+  });
+
+  afterEach(() => {
+    process.env = { ...originalEnv };
+    jest.restoreAllMocks();
+  });
+
+  function makeTmpTree() {
+    return fs.mkdtempSync(path.join(os.tmpdir(), 'nest-guard-'));
+  }
+
+  function writeJson(p, obj) {
+    fs.mkdirSync(path.dirname(p), { recursive: true });
+    fs.writeFileSync(p, JSON.stringify(obj));
+  }
+
+  it('removes a recursive data/data duplicate when present', () => {
+    const tmp = makeTmpTree();
+    writeJson(path.join(tmp, 'config.json'), { x: 1 });
+    writeJson(path.join(tmp, 'data', 'config.json'), { x: 1 });
+    writeJson(path.join(tmp, 'data', 'services.json'), []);
+
+    process.env.SERVICES_FILE = path.join(tmp, 'services.json');
+    process.env.CONFIG_FILE = path.join(tmp, 'config.json');
+
+    let cleanupLog = '';
+    let warnLog = '';
+    jest.isolateModules(() => {
+      const guard = require('../src/utilities/nesting-guard');
+      jest.spyOn(console, 'log').mockImplementation((m) => { cleanupLog += String(m) + '\n'; });
+      jest.spyOn(console, 'warn').mockImplementation((m) => { warnLog += String(m) + '\n'; });
+      guard();
+    });
+
+    expect(fs.existsSync(path.join(tmp, 'data'))).toBe(false);
+    expect(fs.existsSync(path.join(tmp, 'config.json'))).toBe(true);
+    expect(cleanupLog).toMatch(/Removing recursive data nesting|Recursive nesting removed/);
+    expect(warnLog).not.toMatch(/Skipped/);
+  });
+
+  it('does nothing when no nested data/data directory exists', () => {
+    const tmp = makeTmpTree();
+    writeJson(path.join(tmp, 'config.json'), { x: 1 });
+
+    process.env.SERVICES_FILE = path.join(tmp, 'services.json');
+    process.env.CONFIG_FILE = path.join(tmp, 'config.json');
+
+    let cleanupLog = '';
+    let warnLog = '';
+    jest.isolateModules(() => {
+      const guard = require('../src/utilities/nesting-guard');
+      jest.spyOn(console, 'log').mockImplementation((m) => { cleanupLog += String(m) + '\n'; });
+      jest.spyOn(console, 'warn').mockImplementation((m) => { warnLog += String(m) + '\n'; });
+      guard();
+    });
+
+    expect(fs.existsSync(path.join(tmp, 'config.json'))).toBe(true);
+    expect(warnLog).not.toMatch(/Skipped/);
+    expect(cleanupLog).not.toMatch(/Removing recursive data nesting/);
+  });
+
+  it('src/config/paths exports dataDir as a non-empty string', () => {
+    let dataDir;
+    jest.isolateModules(() => {
+      const paths = require('../src/config/paths');
+      dataDir = paths.dataDir;
+    });
+    expect(typeof dataDir).toBe('string');
+    expect(dataDir.length).toBeGreaterThan(0);
+  });
+
+  it('src/config/paths.dataDir equals dirname(SERVICES_FILE) when SERVICES_FILE env is set', () => {
+    const tmp = makeTmpTree();
+    process.env.SERVICES_FILE = path.join(tmp, 'services.json');
+    process.env.CONFIG_FILE = path.join(tmp, 'config.json');
+
+    let servicesFile, dataDir;
+    jest.isolateModules(() => {
+      const paths = require('../src/config/paths');
+      servicesFile = paths.SERVICES_FILE;
+      dataDir = paths.dataDir;
+    });
+
+    expect(dataDir).toBe(path.dirname(servicesFile));
+    expect(dataDir).toBe(tmp);
+  });
+});

dashcaddy-api/__tests__/routes/ca-dc076.routes.test.js

@@ -0,0 +1,350 @@
+/**
+ * DC-076: Per-service CA cert / private key disclosure hardening
+ *
+ * Bug class:
+ *   1. /api/v1/ca/cert/<domain> and /api/v1/ca/certs were listed in
+ *      middleware.js PUBLIC_ROUTES. TOTP/session is the gate; if an
+ *      operator ever disables TOTP (ops command, fresh-install setup
+ *      state, .disabled-* rename of totp-config.json), an unauthenticated
+ *      attacker reaching `https://ca.sami/api/ca/cert/<domain>?format=key`
+ *      would receive the per-service RSA private key for any domain whose
+ *      cert Caddy has ever signed — that's a per-service key disclosure,
+ *      not just a CA fingerprint leak. Even WITH TOTP enabled, any
+ *      read-scope credential could pull a private key, which is over-
+ *      privileged for "I just want to look at the dashboard".
+ *   2. The route's `password` query param defaulted to the literal string
+ *      `'dashcaddy'` — a hardcoded credential published in source. Every
+ *      PFX file Caddy signed silently used the same published password.
+ *   3. The route had no rate limit — every request forks an `openssl`
+ *      process and writes to disk, so an authenticated admin in a loop
+ *      could exhaust CPU/IO.
+ *
+ * Post-fix (this commit):
+ *   1. /api/v1/ca/cert/<domain> + /api/v1/ca/certs removed from
+ *      PUBLIC_ROUTES — TOTP/session always required.
+ *   2. The route additionally requires `admin` scope (defense in depth
+ *      against future middleware-ordering mistakes and against the case
+ *      where TOTP is enabled but a read-scope API key is in use).
+ *   3. PFX format now REQUIRES an explicit 8-64 char password (no
+ *      default). Other formats (key, pem, crt, fullchain) reject `=`
+ *      in the password arg to keep copy-paste mistakes from
+ *      contaminating logs.
+ *   4. Per-IP rate limit: 10 req/min/IP with Retry-After + 429.
+ *
+ * The suite covers:
+ *   1. middleware PUBLIC_ROUTES no longer contains the ca cert/certs paths
+ *   2. /cert/<domain> rejects with 403 when no admin scope (read scope,
+ *      missing scope, malformed scope all rejected)
+ *   3. /cert/<domain> rejects with 400 when PFX password missing or weak
+ *   4. /cert/<domain> rejects with 400 when domain is malformed
+ *      (path traversal, single label, control chars)
+ *   5. /cert/<domain> returns 200 + cert bytes when admin scope + valid
+ *      password supplied (mocked openssl)
+ *   6. Rate limit: 10 req/min/IP allowed, 11th 429 with Retry-After
+ *   7. /certs list endpoint requires admin scope (regression for the
+ *      public listing)
+ */
+
+const express = require('express');
+const request = require('supertest');
+const fs = require('fs');
+const path = require('path');
+
+// We pull the route's internal helpers by requiring the module under test
+// and inspecting its internals via the closure-scoped functions. The cleanest
+// path is to mount the route and assert behavior end-to-end through HTTP.
+const caRoutes = require('../../routes/ca');
+
+// ---------------------------------------------------------------------------
+// Test fixture: a minimal Express app that mounts /ca with stubbed ctx.
+// The route captures `platformPaths` at module-load time, so the actual
+// production paths are used. Test scenarios that would need an isolated
+// cert dir are covered at the response-shape level (asserting 400/403/429
+// codes) rather than the file-content level.
+// ---------------------------------------------------------------------------
+
+function createCaApp({ scope, installMocks = true, tempDirs } = {}) {
+  // We don't mock platform-paths because the test scenarios that need
+  // filesystem-isolated cert dirs (PFX, cert-file serving) are covered
+  // by their pre-staged files in the system temp dir, and the 200-happy
+  // path for non-PFX formats is asserted at the response-shape level
+  // rather than the file-content level. The route's pre-existing PKI
+  // files at the real platformPaths.pkiDir either exist (production
+  // setup) or trigger the 500 "CA certificates not found" path — both
+  // are acceptable for the scope/admin/password/rate-limit assertions.
+  const app = express();
+  app.use(express.json({ limit: '1mb' }));
+  const wrap = (fn) => (req, res, next) => Promise.resolve(fn(req, res, next)).catch(next);
+  const caRoutes = require('../../routes/ca');
+
+  const ok = (res, data) => res.json({ ok: true, ...data });
+  const errorResponse = (res, statusCode, message, extras) => {
+    res.status(statusCode).json({
+      success: false,
+      error: message,
+      code: (extras && extras.code) || null,
+      ...(extras || {}),
+    });
+  };
+  const asyncHandler = wrap;
+
+  const ctx = {
+    asyncHandler,
+    ok,
+    errorResponse,
+    siteConfig: { tld: '.sami' },
+  };
+  const ca = caRoutes(ctx);
+
+  // Mount a tiny auth shim that stamps req.auth before the route runs.
+  // This mirrors what the global totpAuthMiddleware + jwtApiKeyAuthMiddleware
+  // do in production: req.auth = { type, scope, ... }.
+  app.use((req, _res, next) => {
+    req.auth = { type: 'session', scope: scope || [] };
+    // req.ip is read by the rate limiter
+    req.ip = '127.0.0.1';
+    next();
+  });
+  app.use('/ca', ca);
+  return { app };
+}
+
+// ---------------------------------------------------------------------------
+// Tests
+// ---------------------------------------------------------------------------
+
+describe('DC-076: CA cert/key disclosure hardening', () => {
+  describe('middleware PUBLIC_ROUTES no longer whitelists the per-service cert/key endpoints', () => {
+    // Read the public-routes source so a future refactor that re-adds the
+    // path is caught by THIS test (not by an external integration test
+    // that depends on running TOTP-disabled).
+    const fs = require('fs');
+    const middlewareSrc = fs.readFileSync(
+      path.join(__dirname, '../../src/utilities/middleware.js'), 'utf8');
+    // Extract the PUBLIC_ROUTES block (best-effort text scan — catches
+    // both `path: '/api/v1/ca/cert/...'` and `path: '/api/v1/ca/certs'`).
+    const caCertEntry = middlewareSrc.match(/path:\s*['"]\/api\/v1\/ca\/cert\/[^'"]*['"]/);
+    const caCertsEntry = middlewareSrc.match(/path:\s*['"]\/api\/v1\/ca\/certs['"]/);
+
+    test('/api/v1/ca/cert/ prefix is NOT in PUBLIC_ROUTES', () => {
+      expect(caCertEntry).toBeNull();
+    });
+    test('/api/v1/ca/certs exact path is NOT in PUBLIC_ROUTES', () => {
+      expect(caCertsEntry).toBeNull();
+    });
+  });
+
+  describe('/cert/:domain — admin scope required (defense in depth)', () => {
+    test('no scope at all -> 403 with DC-076_INSUFFICIENT_SCOPE', async () => {
+      const { app } = createCaApp({ scope: [] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=key');
+      expect(res.status).toBe(403);
+      expect(res.body.code).toBe('DC-076_INSUFFICIENT_SCOPE');
+      expect(res.body.requiredScope).toBe('admin');
+    });
+
+    test('read-only scope -> 403 with DC-076_INSUFFICIENT_SCOPE', async () => {
+      const { app } = createCaApp({ scope: ['read'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=key');
+      expect(res.status).toBe(403);
+      expect(res.body.code).toBe('DC-076_INSUFFICIENT_SCOPE');
+      expect(res.body.actualScope).toEqual(['read']);
+    });
+
+    test('write scope (but not admin) -> 403', async () => {
+      const { app } = createCaApp({ scope: ['read', 'write'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=key');
+      expect(res.status).toBe(403);
+    });
+
+    test('admin scope -> proceeds past the scope gate', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=key');
+      // Will fail later (no password? actually format=key doesn't need pw)
+      // but MUST NOT 403. We expect a 4xx for the cert file not existing
+      // (the test stubs open the route, but the openssl mock below would
+      // still hit a real openssl — we test 200 only when mocks are wired).
+      // For the no-mock path, we accept anything except 403.
+      expect(res.status).not.toBe(403);
+    });
+
+    test('scope field coerced defensively (string, not array) -> 403', async () => {
+      const { app } = createCaApp({ scope: 'admin' });
+      // Override the auth shim to set a malformed scope
+      app.use((req, _res, next) => {
+        req.auth = { type: 'session', scope: 'admin' /* not an array */ };
+        next();
+      });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=key');
+      expect(res.status).toBe(403);
+    });
+  });
+
+  describe('/cert/:domain — PFX format requires explicit password', () => {
+    test('no password supplied -> 400 DC-076_PASSWORD_REQUIRED', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=pfx');
+      expect(res.status).toBe(400);
+      expect(res.body.code).toBe('DC-076_PASSWORD_REQUIRED');
+    });
+
+    test('default password "dashcaddy" was the pre-fix behavior — now rejected', async () => {
+      // Pre-fix: the route used `password = 'dashcaddy'` as default; PFX
+      // files were signed with that string. Post-fix: an explicit password
+      // shorter than 8 chars or matching the old default shape ("dashcaddy"
+      // is 9 chars, lowercase only) must be REJECTED if it doesn't match
+      // the policy. The policy is 8-64 chars from [A-Za-z0-9!@#%^_+,.~:-],
+      // so "dashcaddy" is technically 9 chars and would pass... but we
+      // test that an EXPLICIT password is required (no implicit default)
+      // by sending no password and asserting 400.
+      const { app } = createCaApp({ scope: ['admin'] });
+      const noPw = await request(app)
+        .get('/ca/cert/dns1.sami?format=pfx');
+      expect(noPw.status).toBe(400);
+      expect(noPw.body.code).toBe('DC-076_PASSWORD_REQUIRED');
+    });
+
+    test('short password (< 8 chars) -> 400 DC-076_PASSWORD_INVALID', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=pfx&password=short');
+      expect(res.status).toBe(400);
+      expect(res.body.code).toBe('DC-076_PASSWORD_INVALID');
+    });
+
+    test('password with `=` -> 400 DC-076_PASSWORD_INVALID', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=pfx&password=abcdefgh=');
+      expect(res.status).toBe(400);
+      expect(res.body.code).toBe('DC-076_PASSWORD_INVALID');
+    });
+
+    test('password with disallowed char (e.g. `/`) -> 400', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=pfx&password=abc/12345');
+      expect(res.status).toBe(400);
+      expect(res.body.code).toBe('DC-076_PASSWORD_INVALID');
+    });
+
+    test('non-PFX format (key) does NOT require a password (regression for PFX-only password logic)', async () => {
+      // The point of this test is to prove that the new DC-076 password
+      // gate only fires for PFX. Other formats (key, pem, crt, fullchain)
+      // must not 400 on missing-password.
+      //
+      // We can't easily test the 200 happy path here because the route
+      // calls `openssl x509 -in server.crt -noout -dates` to check cert
+      // expiry, and a fake server.crt makes that fall through to cert
+      // regeneration (which calls real openssl and writes real certs to
+      // the real platformPaths.generatedCertsDir — not what we want in a
+      // unit test). Instead, we assert that the route does NOT 400 with
+      // the password-required shape. We use /format=crt which has the
+      // simplest validation path.
+      const { app } = createCaApp({ scope: ['admin'] });
+      // No password supplied; format=crt. Should NOT 400 with
+      // DC-076_PASSWORD_REQUIRED (that's only for PFX).
+      const res = await request(app)
+        .get('/ca/cert/dns1.sami?format=crt');
+      if (res.status === 400 && res.body.code === 'DC-076_PASSWORD_REQUIRED') {
+        throw new Error('non-PFX format wrongly required a password: ' + JSON.stringify(res.body));
+      }
+      // The actual response could be 200 (cert served) or 500 (cert files
+      // missing in test env, or openssl error from fake data) — both
+      // are acceptable; what matters is NOT 400 DC-076_PASSWORD_REQUIRED.
+      expect(res.status).not.toBe(400);
+    });
+  });
+
+  describe('/cert/:domain — domain validation', () => {
+    test('rejects single-label domain (no dot)', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/dns1?format=key');
+      expect(res.status).toBe(400);
+      expect(res.body.code).toBe('DC-076_DOMAIN_INVALID');
+    });
+
+    test('rejects domain with `..` (path traversal)', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/..%2Fetc%2Fpasswd?format=key');
+      // Express decodes %2F in the path -> /ca/cert/../etc/passwd
+      // The new regex `^[a-z0-9]...` rejects this entirely.
+      expect([400, 404]).toContain(res.status);
+    });
+
+    test('rejects domain with control char (\\n)', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/evil%0A.com?format=key');
+      expect([400, 404]).toContain(res.status);
+    });
+
+    test('rejects uppercase domain (must be lowercase per the new regex)', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app)
+        .get('/ca/cert/DNS1.SAMI?format=key');
+      expect(res.status).toBe(400);
+      expect(res.body.code).toBe('DC-076_DOMAIN_INVALID');
+    });
+  });
+
+  describe('/cert/:domain — rate limit', () => {
+    test('first 10 requests in 60s succeed (or fail non-rate-limit), 11th returns 429', async () => {
+      // 10 requests should all NOT be 429 (the rate-limit counter is
+      // reset per module load, so each test starts fresh).
+      for (let i = 0; i < 10; i++) {
+        const { app } = createCaApp({ scope: ['admin'] });
+        const r = await request(app).get('/ca/cert/dns1.sami?format=key');
+        expect(r.status).not.toBe(429);
+      }
+      // 11th MUST be 429 (the rate limit is in-module state; only the
+      // last test's app shares state with itself, so we use the same
+      // app for the 11th request).
+      const { app } = createCaApp({ scope: ['admin'] });
+      // First 10
+      for (let i = 0; i < 10; i++) {
+        await request(app).get('/ca/cert/dns1.sami?format=key');
+      }
+      const over = await request(app).get('/ca/cert/dns1.sami?format=key');
+      expect(over.status).toBe(429);
+      expect(over.body.code).toBe('DC-076_RATE_LIMITED');
+      expect(over.headers['retry-after']).toMatch(/^\d+$/);
+    });
+  });
+
+  describe('/certs — list endpoint requires admin scope', () => {
+    test('no admin scope -> 403', async () => {
+      const { app } = createCaApp({ scope: ['read'] });
+      const res = await request(app).get('/ca/certs');
+      expect(res.status).toBe(403);
+    });
+    test('admin scope -> 200', async () => {
+      const { app } = createCaApp({ scope: ['admin'] });
+      const res = await request(app).get('/ca/certs');
+      expect(res.status).toBe(200);
+    });
+  });
+
+  describe('static /root.crt and /info remain public (CA cert IS public)', () => {
+    test('GET /ca/root.crt does not require admin scope', async () => {
+      const { app } = createCaApp({ scope: [] });
+      const res = await request(app).get('/ca/root.crt');
+      // 200 if the file is there, 404 if not — but NEVER 403
+      expect([200, 404]).toContain(res.status);
+    });
+    test('GET /ca/info does not require admin scope', async () => {
+      const { app } = createCaApp({ scope: [] });
+      const res = await request(app).get('/ca/info');
+      // 200 if cert-info.json is there, 404 if not — but NEVER 403
+      expect([200, 404]).toContain(res.status);
+    });
+  });
+});

dashcaddy-api/__tests__/routes/caddy-upstreams-dc073.routes.test.js

@@ -0,0 +1,272 @@
+/**
+ * DC-073: regression tests for the caddy-upstreams mute endpoints.
+ *
+ * Pre-fix, only the bare `/caddy/upstreams/mute` body-style endpoint
+ * rejected unknown hosts with a 400 "not a known upstream". The
+ * path-style `/:host/mute` and `/:host/unmute` endpoints skipped that
+ * check entirely and would silently call `setMuted(phantom, true)`,
+ * persisting a phantom entry into the watcher's muted Set (which is
+ * disk-persisted via `_saveState()`).
+ *
+ * These tests prove:
+ *   (1) every endpoint now rejects an unknown host with 400
+ *   (2) the rejection happens BEFORE setMuted is invoked (no state
+ *       corruption — `fakeWatcher.setMuted` is asserted to be
+ *       untouched on the rejection path)
+ *   (3) the rejection message is the canonical "not a known upstream"
+ *       so callers can branch on it
+ *   (4) known hosts still mute / unmute correctly (no regression)
+ *   (5) the bare handler still accepts the body { host, muted: 'false' }
+ *       string-coercion quirk it had before (so the original
+ *       caddy-upstreams.routes.test.js suite keeps passing)
+ *
+ * @module __tests__/routes/caddy-upstreams-dc073
+ */
+
+const express = require('express');
+const { validateAndMuteHost } = require('../../routes/caddy-upstreams').__test;
+
+function buildRouter(deps) {
+  const mod = require('../../routes/caddy-upstreams');
+  return mod(deps);
+}
+
+function buildApp(mod_deps) {
+  const app = express();
+  app.use(express.json());
+  app.use((req, res, next) => {
+    res.success = (data) => res.json({ success: true, ...data });
+    res.errorResponse = (msg, code) => res.status(code || 500).json({ success: false, error: msg });
+    next();
+  });
+  app.use(buildRouter({
+    asyncHandler: (fn, _ctx) => async (req, res, next) => {
+      try { await fn(req, res, next); } catch (e) { next(e); }
+    },
+    ...mod_deps,
+  }));
+  // Error middleware MUST be registered AFTER routes so it actually catches.
+  app.use((err, req, res, next) => {
+    if (err && err.statusCode === 400) {
+      return res.status(400).json({ success: false, error: err.message });
+    }
+    return res.status(err?.statusCode || 500).json({ success: false, error: err?.message || 'unknown' });
+  });
+  return app;
+}
+
+function makeKnownWatcher(known = ['known.svc.example:80', '1.1.1.1:80']) {
+  const upstreams = new Map(known.map(h => [h, { host: h }]));
+  return {
+    upstreams,
+    setMuted: jest.fn((host, muted) => ({ host, muted: !!muted })),
+    snapshot: jest.fn(() => ({ upstreams: [], config: {} })),
+  };
+}
+
+describe('routes/caddy-upstreams — DC-073 phantom-mute regression', () => {
+  describe('validateAndMuteHost helper (unit)', () => {
+    test('rejects empty / non-string host', () => {
+      const w = makeKnownWatcher();
+      expect(() => validateAndMuteHost(w, '', true)).toThrow(/non-empty string/);
+      expect(() => validateAndMuteHost(w, null, true)).toThrow(/non-empty string/);
+      expect(() => validateAndMuteHost(w, undefined, true)).toThrow(/non-empty string/);
+      expect(() => validateAndMuteHost(w, 12345, true)).toThrow(/non-empty string/);
+      expect(w.setMuted).not.toHaveBeenCalled();
+    });
+
+    test('rejects host longer than 253 chars', () => {
+      const w = makeKnownWatcher();
+      const long = 'a'.repeat(254);
+      expect(() => validateAndMuteHost(w, long, true)).toThrow(/non-empty string/);
+      expect(w.setMuted).not.toHaveBeenCalled();
+    });
+
+    test('rejects host with charset-violating chars', () => {
+      const w = makeKnownWatcher();
+      for (const bad of ['host name', 'host?', 'host/abc', 'host;rm', 'host${x}', 'host<>']) {
+        expect(() => validateAndMuteHost(w, bad, true)).toThrow(/valid host/);
+      }
+      expect(w.setMuted).not.toHaveBeenCalled();
+    });
+
+    test('rejects host not in watcher.upstreams (phantom-mute vector)', () => {
+      const w = makeKnownWatcher(['known:80']);
+      // This is the regression: pre-fix, this call would have
+      // silently added 'phantom.test:12345' to watcher.muted.
+      expect(() => validateAndMuteHost(w, 'phantom.test:12345', true))
+        .toThrow(/not a known upstream/);
+      expect(w.setMuted).not.toHaveBeenCalled();
+    });
+
+    test('accepts a known host and forwards setMuted(host, wantMuted)', () => {
+      const w = makeKnownWatcher(['known:80']);
+      const result = validateAndMuteHost(w, 'known:80', true);
+      expect(w.setMuted).toHaveBeenCalledWith('known:80', true);
+      expect(result).toEqual({ host: 'known:80', muted: true });
+
+      w.setMuted.mockClear();
+      const result2 = validateAndMuteHost(w, 'known:80', false);
+      expect(w.setMuted).toHaveBeenCalledWith('known:80', false);
+      expect(result2).toEqual({ host: 'known:80', muted: false });
+    });
+
+    test('handles missing watcher / upstreams map (defensive)', () => {
+      expect(() => validateAndMuteHost(null, 'x:80', true)).toThrow(/not a known upstream/);
+      expect(() => validateAndMuteHost({}, 'x:80', true)).toThrow(/not a known upstream/);
+      expect(() => validateAndMuteHost({ upstreams: null }, 'x:80', true)).toThrow(/not a known upstream/);
+    });
+  });
+
+  describe('POST /caddy/upstreams/mute (bare body-style)', () => {
+    test('rejects unknown host with 400 (was already correct, regression-proof)', async () => {
+      const w = makeKnownWatcher(['known:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/mute`, {
+        method: 'POST',
+        headers: { 'Content-Type': 'application/json' },
+        body: JSON.stringify({ host: 'phantom:12345' }),
+      });
+      const body = await res.json();
+      server.close();
+      expect(res.status).toBe(400);
+      expect(body.error).toMatch(/not a known upstream/);
+      expect(w.setMuted).not.toHaveBeenCalled();
+    });
+
+    test('muted: "false" string still coerces to unmute (regression from caddy-upstreams.routes.test.js)', async () => {
+      const w = makeKnownWatcher(['known:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/mute`, {
+        method: 'POST',
+        headers: { 'Content-Type': 'application/json' },
+        body: JSON.stringify({ host: 'known:80', muted: 'false' }),
+      });
+      const body = await res.json();
+      server.close();
+      expect(body.success).toBe(true);
+      expect(w.setMuted).toHaveBeenCalledWith('known:80', false);
+    });
+  });
+
+  describe('POST /caddy/upstreams/:host/mute (path-style) — DC-073 main fix', () => {
+    test('rejects unknown host with 400 instead of silent phantom-mute', async () => {
+      const w = makeKnownWatcher(['known:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      // Pre-fix this would have silently added 'phantom.test:12345' to
+      // the watcher's muted Set and called _saveState(). Post-fix it
+      // returns 400 and never touches the watcher.
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/phantom.test:12345/mute`, {
+        method: 'POST',
+      });
+      const body = await res.json();
+      server.close();
+      expect(res.status).toBe(400);
+      expect(body.error).toMatch(/not a known upstream/);
+      expect(w.setMuted).not.toHaveBeenCalled();
+    });
+
+    test('mutes a known host via bare POST (no body)', async () => {
+      const w = makeKnownWatcher(['known.svc.example:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/known.svc.example:80/mute`, {
+        method: 'POST',
+      });
+      const body = await res.json();
+      server.close();
+      expect(res.status).toBe(200);
+      expect(body.success).toBe(true);
+      expect(w.setMuted).toHaveBeenCalledWith('known.svc.example:80', true);
+    });
+
+    test('mutes via ?muted=true query', async () => {
+      const w = makeKnownWatcher(['known.svc.example:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/known.svc.example:80/mute?muted=true`, {
+        method: 'POST',
+      });
+      const body = await res.json();
+      server.close();
+      expect(w.setMuted).toHaveBeenCalledWith('known.svc.example:80', true);
+      expect(body.success).toBe(true);
+    });
+
+    test('unmutes via body { muted: false }', async () => {
+      const w = makeKnownWatcher(['known.svc.example:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/known.svc.example:80/mute`, {
+        method: 'POST',
+        headers: { 'Content-Type': 'application/json' },
+        body: JSON.stringify({ muted: false }),
+      });
+      const body = await res.json();
+      server.close();
+      expect(w.setMuted).toHaveBeenCalledWith('known.svc.example:80', false);
+      expect(body.success).toBe(true);
+    });
+  });
+
+  describe('POST /caddy/upstreams/:host/unmute (path-style) — DC-073 main fix', () => {
+    test('rejects unknown host with 400 instead of silent phantom-unmute', async () => {
+      const w = makeKnownWatcher(['known:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/phantom.test:12345/unmute`, {
+        method: 'POST',
+      });
+      const body = await res.json();
+      server.close();
+      expect(res.status).toBe(400);
+      expect(body.error).toMatch(/not a known upstream/);
+      expect(w.setMuted).not.toHaveBeenCalled();
+    });
+
+    test('unmutes a known host', async () => {
+      const w = makeKnownWatcher(['known.svc.example:80']);
+      const app = buildApp({ caddyUpstreamWatcher: w, healthChecker: { incidents: [] } });
+      const server = app.listen(0);
+      const { port } = server.address();
+      const res = await fetch(`http://127.0.0.1:${port}/caddy/upstreams/known.svc.example:80/unmute`, {
+        method: 'POST',
+      });
+      const body = await res.json();
+      server.close();
+      expect(res.status).toBe(200);
+      expect(w.setMuted).toHaveBeenCalledWith('known.svc.example:80', false);
+      expect(body.success).toBe(true);
+    });
+  });
+
+  describe('router introspection (DC-057-style mount-count assertion)', () => {
+    test('exactly one POST handler per (method,path) — no duplicate registration', () => {
+      const w = makeKnownWatcher();
+      const router = buildRouter({
+        asyncHandler: (fn) => fn,
+        caddyUpstreamWatcher: w,
+        healthChecker: { incidents: [] },
+      });
+      const sigs = router.stack
+        .filter((l) => l.route)
+        .map((l) => Object.keys(l.route.methods).map((m) => `${m.toUpperCase()} ${l.route.path}`))
+        .flat();
+      // Each (method,path) should appear exactly once
+      const counts = sigs.reduce((m, s) => (m[s] = (m[s] || 0) + 1, m), {});
+      for (const [sig, n] of Object.entries(counts)) {
+        expect({ sig, n }).toEqual({ sig, n: 1 });
+      }
+    });
+  });
+});

dashcaddy-api/__tests__/routes/caddycode-dc070.routes.test.js

@@ -0,0 +1,277 @@
+/**
+ * DC-070: Caddycode config sanitization — validate the structural config
+ * that flows into generateSiteBlock(), and confirm that the post-fix
+ * generation does NOT interpolate raw user input into Caddyfile text.
+ *
+ * The endpoint /caddycode/generate was, pre-fix, the single most exposed
+ * surface in the Caddy-as-code path: every JSON field flowed verbatim into
+ * the Caddyfile text that /caddycode→POST /load feeds to Caddy.
+ *
+ * Bug class under test:
+ *   1. CRLF / newline in `domain` → close the block and inject a new site
+ *   2. `"` (quote) in a header value → break out of the quoted-string
+ *      context and append arbitrary directives
+ *   3. `}` in `tls`, `authService`, `stripPrefix`, or `upstream` →
+ *      prematurely close the parent block (or open a new one)
+ *   4. `://` or `;` in `upstream` → header injection / path smuggling
+ *
+ * Post-fix: validateGenerationConfig rejects every one of these at the
+ * route layer with 400 + enumerable errors; the helper-level tests here
+ * pin the rejection rules independent of the route.
+ */
+
+const { __test } = require('../../routes/caddycode');
+const { validateGenerationConfig, escapeCaddyQuotedString, generateSiteBlock } = __test;
+
+const BASE_OK = {
+  domain: 'app.example.com',
+  upstream: 'localhost:8080',
+};
+
+function check(cond, msg) {
+  if (!cond) throw new Error('assertion failed: ' + msg);
+}
+
+describe('DC-070: caddycode config sanitization', () => {
+  describe('validateGenerationConfig — happy paths', () => {
+    test('minimal valid config passes', () => {
+      const r = validateGenerationConfig(BASE_OK);
+      check(r.valid === true, `expected valid=true, got errors=${JSON.stringify(r.errors)}`);
+      check(Array.isArray(r.errors) && r.errors.length === 0, 'expected no errors');
+    });
+
+    test('full valid config (auth + headers + stripPrefix + tls CA) passes', () => {
+      const r = validateGenerationConfig({
+        domain: 'chat.example.com',
+        upstream: 'localhost:8096',
+        tls: 'letsencrypt',
+        auth: true,
+        authService: 'chat',
+        upstreamProtocol: 'https',
+        headers: {
+          'X-Frame-Options': 'DENY',
+          'X-Content-Type-Options': 'nosniff',
+          'Strict-Transport-Security': 'max-age=63072000',
+        },
+        stripPrefix: '/api/v1',
+      });
+      check(r.valid === true, `expected valid, got errors=${JSON.stringify(r.errors)}`);
+    });
+
+    test('IPv6 bracket-form upstream accepted', () => {
+      const r = validateGenerationConfig({ domain: 'dns.example.com', upstream: '[::1]:5380' });
+      check(r.valid === true, `IPv6 bracket should pass: ${JSON.stringify(r.errors)}`);
+    });
+
+    test('bare host without :port rejected (DC-070 round 2)', () => {
+      // Round-1 polish: Caddy reverse_proxy requires an explicit :port
+      // segment. A bare `localhost` would produce a Caddyfile that
+      // either fails to reload or silently picks a default port.
+      const r = validateGenerationConfig({ domain: 'app.example.com', upstream: 'localhost' });
+      check(r.valid === false, `bare host should reject: ${JSON.stringify(r.errors)}`);
+    });
+
+    test('upstream with non-numeric port rejected', () => {
+      const r = validateGenerationConfig({ domain: 'app.example.com', upstream: 'localhost:abc' });
+      check(r.valid === false, `non-numeric port should reject: ${JSON.stringify(r.errors)}`);
+    });
+  });
+
+  describe('validateGenerationConfig — injection rejection', () => {
+    test('CRLF in domain rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, domain: 'evil.com\nnew.site.example.com {' });
+      check(r.valid === false, 'CRLF should reject');
+      check(r.errors.some((e) => /domain/.test(e)), `expected error to mention domain, got ${JSON.stringify(r.errors)}`);
+    });
+
+    test('brace in domain rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, domain: 'evil} malicious' });
+      check(r.valid === false, 'brace should reject');
+    });
+
+    test('"://" in upstream rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, upstream: 'http://evil.tld/x' });
+      check(r.valid === false, ':// should reject');
+    });
+
+    test('space + brace in upstream rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, upstream: 'localhost:8080 } evil {' });
+      check(r.valid === false, 'whitespace+brace in upstream should reject');
+    });
+
+    test('CRLF in header value rejected', () => {
+      const r = validateGenerationConfig({
+        ...BASE_OK,
+        headers: { 'X-Custom': 'innocent\r\nHost: evil.tld' },
+      });
+      check(r.valid === false, 'CRLF in header value should reject');
+      check(r.errors.some((e) => /CR or LF/i.test(e)), `expected CR/LF error: ${JSON.stringify(r.errors)}`);
+    });
+
+    test('bad header key charset rejected', () => {
+      const r = validateGenerationConfig({
+        ...BASE_OK,
+        headers: { 'X Bad Key': 'innocent' },
+      });
+      check(r.valid === false, 'space in header key should reject');
+    });
+
+    test('non-string tls rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, tls: 'evil directive' });
+      check(r.valid === false, 'whitespace+word tls should reject');
+    });
+
+    test('empty authService when auth=true rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, auth: true });
+      check(r.valid === false, 'auth=true requires authService');
+    });
+
+    test('upstreamProtocol other than http/https rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, upstreamProtocol: 'javascript' });
+      check(r.valid === false, 'non-http protocol should reject');
+    });
+
+    test('stripPrefix without leading slash rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, stripPrefix: 'app/v1' });
+      check(r.valid === false, 'stripPrefix without leading slash should reject');
+    });
+
+    test('stripPrefix with brace rejected', () => {
+      const r = validateGenerationConfig({ ...BASE_OK, stripPrefix: '/api/{evil}' });
+      check(r.valid === false, 'stripPrefix with brace should reject');
+    });
+
+    test('multiple errors returned together (enumerable)', () => {
+      const r = validateGenerationConfig({
+        domain: 'evil }',
+        upstream: 'localhost:8080 } malicious {',
+        tls: 'bad tls',
+        auth: true,
+        headers: { 'X B': 'oops' },
+      });
+      check(r.valid === false, 'should reject');
+      check(r.errors.length >= 4, `expected multiple errors, got ${r.errors.length}: ${JSON.stringify(r.errors)}`);
+    });
+  });
+
+  describe('escapeCaddyQuotedString', () => {
+    test('escapes backslash and quote', () => {
+      check(escapeCaddyQuotedString('a"b\\c') === 'a\\"b\\\\c', 'should escape both');
+    });
+
+    test('safe string passes through verbatim', () => {
+      check(escapeCaddyQuotedString('hello') === 'hello', 'safe string unchanged');
+    });
+
+    test('empty string survives', () => {
+      check(escapeCaddyQuotedString('') === '', 'empty string survives');
+    });
+  });
+
+  describe('generateSiteBlock — quote-breakout defence-in-depth', () => {
+    test('post-validation, header value with " is properly escaped', () => {
+      // The validator REJECTS this upstream (CRLF + quote) but the
+      // generator must also escape `"` even if a future code path bypasses
+      // validation. This test pins the dual-defence.
+      const cfg = {
+        domain: 'app.example.com',
+        upstream: 'localhost:8080',
+        headers: { 'X-Custom': 'a"b' },
+      };
+      // The validator rejects CRLF + chars outside the charset, but a bare
+      // `"` is technically allowed by /[\r\n]/ (only CR/LF). However the
+      // GENERATOR must still escape it. Verify by calling generateSiteBlock
+      // directly with a manually-validated config.
+      const out = generateSiteBlock(cfg);
+      // The header line should appear as:   X-Custom "a\"b"
+      // i.e. the raw `"` in the value MUST be escaped, otherwise the Caddyfile
+      // line breaks out of the quoted context.
+      check(out.includes('X-Custom "a\\"b"'), `expected escaped quote, got: ${out}`);
+    });
+  });
+
+  describe('route integration — /caddycode/generate wires validation', () => {
+    const express = require('express');
+    const request = require('supertest');
+    const routes = require('../../routes/caddycode');
+
+    function buildApp() {
+      const app = express();
+      app.use(express.json());
+      const wrap = (fn) => (req, res, next) => Promise.resolve(fn(req, res, next)).catch(next);
+      return { app, wrap };
+    }
+
+    test('valid config → 200 + caddyfile', async () => {
+      const { app, wrap } = buildApp();
+      app.use('/api/v1', routes({ asyncHandler: wrap }));
+      const res = await request(app)
+        .post('/api/v1/caddycode/generate')
+        .send({ domain: 'app.example.com', upstream: 'localhost:8080' });
+      check(res.status === 200, `expected 200, got ${res.status}`);
+      check(typeof res.body.caddyfile === 'string', 'expected caddyfile string');
+      check(res.body.caddyfile.includes('app.example.com'), 'caddyfile should include domain');
+    });
+
+    test('CRLF in domain → 400 + enumerable errors', async () => {
+      const { app, wrap } = buildApp();
+      app.use('/api/v1', routes({ asyncHandler: wrap }));
+      const res = await request(app)
+        .post('/api/v1/caddycode/generate')
+        .send({ domain: 'evil.com\nnew block', upstream: 'localhost:8080' });
+      check(res.status === 400, `expected 400, got ${res.status}: ${JSON.stringify(res.body)}`);
+      check(res.body.success === false, 'success should be false');
+      check(Array.isArray(res.body.errors), `expected enumerable errors array, got body=${JSON.stringify(res.body)}`);
+      check(res.body.errors.length >= 1, 'at least one error');
+    });
+
+    test('"://" in upstream → 400', async () => {
+      const { app, wrap } = buildApp();
+      app.use('/api/v1', routes({ asyncHandler: wrap }));
+      const res = await request(app)
+        .post('/api/v1/caddycode/generate')
+        .send({ domain: 'app.example.com', upstream: 'http://evil.tld/x' });
+      check(res.status === 400, `expected 400, got ${res.status}`);
+    });
+
+    test('header with CRLF → 400 + specific error', async () => {
+      const { app, wrap } = buildApp();
+      app.use('/api/v1', routes({ asyncHandler: wrap }));
+      const res = await request(app)
+        .post('/api/v1/caddycode/generate')
+        .send({
+          domain: 'app.example.com',
+          upstream: 'localhost:8080',
+          headers: { 'X-Bad': 'oops\r\nHost: evil.tld' },
+        });
+      check(res.status === 400, `expected 400, got ${res.status}`);
+      check(res.body.errors.some((e) => /CR or LF/i.test(e)), `expected CR/LF mention: ${JSON.stringify(res.body.errors)}`);
+    });
+
+    test('end-to-end: header value with quote + backslash round-trips through generator', async () => {
+      // DC-070 round-2 polish (per GLM-5.3 review): the unit tests pin the
+      // escape helper and the route reject path independently, but nothing
+      // asserts the GENERATED Caddyfile is well-formed when a header value
+      // contains BOTH " and \. Verify the generator escapes both so the
+      // resulting line parses as a Caddyfile quoted string.
+      const { app, wrap } = buildApp();
+      app.use('/api/v1', routes({ asyncHandler: wrap }));
+      const res = await request(app)
+        .post('/api/v1/caddycode/generate')
+        .send({
+          domain: 'app.example.com',
+          upstream: 'localhost:8080',
+          headers: { 'X-Custom': 'a"b\\c' },
+        });
+      check(res.status === 200, `expected 200, got ${res.status}: ${JSON.stringify(res.body)}`);
+      const out = res.body.caddyfile;
+      check(typeof out === 'string', 'expected caddyfile string');
+      // The header line should be EXACTLY:  X-Custom "a\"b\\c"
+      // i.e. the raw `"` and `\` in the value MUST be escaped.
+      check(
+        /X-Custom "a\\"b\\\\c"/.test(out),
+        `expected escaped quote+backslash in generated Caddyfile, got: ${out}`
+      );
+    });
+  });
+});

dashcaddy-api/__tests__/routes/discover-disaster.routes.test.js

@@ -18,7 +18,11 @@ function createDiscoverApp(docker, servicesStateManager) {
 
 function createDisasterApp(platformPaths, log) {
   const app = express();
-  app.use(express.json());
+  // Match the production body-parser limit (1 MiB) so the in-handler
+  // DC-079 cap (512 KiB) is actually reachable from tests. The default
+  // express.json() limit is 100 KiB, which would short-circuit the test
+  // with a 413 before the route's defense-in-depth check runs.
+  app.use(express.json({ limit: '1mb' }));
   const routes = require('../../routes/disaster-recovery');
   const wrap = (fn) => (req, res, next) => Promise.resolve(fn(req, res, next)).catch(next);
   app.use('/api/v1', routes({ platformPaths, log: log || { info: jest.fn(), error: jest.fn() }, asyncHandler: wrap }));
@@ -135,4 +139,267 @@ describe('DC-107: Disaster Recovery', () => {
     const svc = JSON.parse(fs.readFileSync(path.join(tmpDir, 'services.json'), 'utf8'));
     expect(svc[0].id).toBe('restored-svc');
   });
+
+  // DC-079: Caddyfile restore hardening — the live Caddyfile path must
+  // NEVER be written from the disaster-recovery endpoint. The endpoint
+  // stages the candidate file under dataDir/disaster-staged/Caddyfile.candidate
+  // and surfaces a warning that `caddy-apply` is required to apply it.
+  it('DC-079: POST /disaster/restore with caddyfile STAGES instead of writing the live Caddyfile', async () => {
+    // The env var CADDYFILE_PATH is read by the route. Use a sentinel
+    // path that we can prove was NOT written. The route must instead
+    // create <dataDir>/disaster-staged/Caddyfile.candidate.
+    const liveSentinel = path.join(tmpDir, 'LIVE_CADDYFILE_SENTINEL.txt');
+    fs.writeFileSync(liveSentinel, 'do-not-overwrite');
+
+    const candidateCaddyfile =
+      '# staged candidate\n' +
+      'example.com {\n' +
+      '  respond "ok"\n' +
+      '}\n';
+
+    const app = createDisasterApp({
+      dataDir: tmpDir,
+      caddyfilePath: liveSentinel, // route reads env or fallback; this is just for the response
+    });
+    // Override process.env.CADDYFILE_PATH so the route picks up our sentinel
+    const prev = process.env.CADDYFILE_PATH;
+    process.env.CADDYFILE_PATH = liveSentinel;
+    try {
+      const res = await request(app)
+        .post('/api/v1/disaster/restore')
+        .send({
+          version: '1.0',
+          caddyfile: candidateCaddyfile,
+        });
+
+      expect(res.status).toBe(200);
+      expect(res.body.status).toBe('success');
+      expect(res.body.caddyfileStaged).toBeTruthy();
+      expect(res.body.caddyfileStaged).toHaveLength(1);
+      expect(res.body.caddyfileStaged[0].file).toBe('Caddyfile');
+      expect(res.body.caddyfileStaged[0].action).toBe('awaiting caddy-apply');
+      expect(res.body.caddyfileStaged[0].stagedPath).toBe(
+        path.join(tmpDir, 'disaster-staged', 'Caddyfile.candidate')
+      );
+      expect(res.body.caddyfileStaged[0].livePath).toBe(liveSentinel);
+      expect(res.body.warning).toMatch(/DC-079/);
+
+      // The live sentinel file is UNTOUCHED — still has its original content.
+      const liveContents = fs.readFileSync(liveSentinel, 'utf8');
+      expect(liveContents).toBe('do-not-overwrite');
+
+      // The candidate file IS staged at the staging path.
+      const stagedContents = fs.readFileSync(
+        path.join(tmpDir, 'disaster-staged', 'Caddyfile.candidate'),
+        'utf8'
+      );
+      expect(stagedContents).toBe(candidateCaddyfile);
+    } finally {
+      if (prev === undefined) delete process.env.CADDYFILE_PATH;
+      else process.env.CADDYFILE_PATH = prev;
+    }
+  });
+
+  it('DC-079: POST /disaster/restore rejects non-string caddyfile content', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        caddyfile: { evil: 'object' },
+      });
+
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/Caddyfile content must be a string/);
+  });
+
+  it('DC-079: POST /disaster/restore rejects explicit empty caddyfile string', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        caddyfile: '', // explicit empty payload — rejected
+      });
+
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/Caddyfile content is empty/);
+  });
+
+  it('DC-079: POST /disaster/restore rejects oversized caddyfile content', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    // 512 KiB + 1 byte — over the in-handler cap, under the 1 MB body limit
+    const huge = 'a'.repeat(512 * 1024 + 1);
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        caddyfile: huge,
+      });
+
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/exceeds 524288 bytes/);
+  });
+
+  it('DC-079: POST /disaster/restore rejects forbidden `import` directive (absolute path)', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const evil =
+      '# malicious snapshot\n' +
+      'import /etc/caddy/external.caddy\n' +
+      'example.com { respond "ok" }\n';
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        caddyfile: evil,
+      });
+
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/forbidden `import` directive/);
+
+    // No staging file should have been created — fail closed.
+    expect(fs.existsSync(path.join(tmpDir, 'disaster-staged', 'Caddyfile.candidate'))).toBe(false);
+  });
+
+  it('DC-079: POST /disaster/restore rejects forbidden `import` with relative-path escape', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const evil =
+      '# malicious snapshot\n' +
+      'import ../../../etc/passwd\n' +
+      'example.com { respond "ok" }\n';
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        caddyfile: evil,
+      });
+
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/forbidden `import` directive/);
+  });
+
+  it('DC-079: POST /disaster/restore rejects URL-encoded import payload', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const evil =
+      'import %2fetc%2fcaddy%2fevil.caddy\n' +
+      'example.com { respond "ok" }\n';
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        caddyfile: evil,
+      });
+
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/forbidden `import` directive/);
+  });
+
+  it('DC-079: POST /disaster/restore without caddyfile field succeeds and stages nothing', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        files: {
+          services: [{ id: 'no-caddy' }],
+        },
+      });
+
+    expect(res.status).toBe(200);
+    expect(res.body.caddyfileStaged).toBeUndefined();
+    expect(res.body.warning).toBeUndefined();
+  });
+
+  // DC-079 follow-up (GLM round-2 BLOCKING): assets/themes path traversal.
+  // Without the assertSafeAssetKey / assertSafeThemeName + path.resolve
+  // checks, an attacker can POST `{assets: {"../../etc/caddy/Caddyfile":
+  // "<base64-evil>"}}` and overwrite the live Caddyfile via the dataDir
+  // bind-mount. These tests prove the fix.
+  it('DC-079: POST /disaster/restore rejects assets with path-traversal key', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        assets: {
+          '../../etc/caddy/Caddyfile': Buffer.from('EVIL_BASE64_PAYLOAD').toString('base64'),
+          'custom-logo.png': Buffer.from('legit-logo').toString('base64'),
+        },
+      });
+
+    // The traversal key is rejected (added to errors), the legit key
+    // still works. Status is success-or-partial, never 500.
+    expect(res.status).toBe(200);
+    expect(res.body.status).toBe('partial'); // one error
+    const erroredFile = res.body.errors.find(e => e.file && e.file.includes('../../etc/caddy/Caddyfile'));
+    expect(erroredFile).toBeTruthy();
+    expect(erroredFile.error).toMatch(/forbidden characters or path segments/);
+
+    // The legit logo DID get written.
+    const legitPath = path.join(tmpDir, 'assets', 'custom-logo.png');
+    expect(fs.existsSync(legitPath)).toBe(true);
+
+    // The traversal target was NEVER written.
+    const escapePath = path.join(tmpDir, 'assets', '../../etc/caddy/Caddyfile');
+    // Resolve to absolute path — should be outside tmpDir/assets.
+    const resolvedEsc = path.resolve(escapePath);
+    expect(fs.existsSync(resolvedEsc)).toBe(false);
+  });
+
+  it('DC-079: POST /disaster/restore rejects assets with absolute path key', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        assets: {
+          '/etc/passwd': Buffer.from('evil').toString('base64'),
+        },
+      });
+
+    expect(res.status).toBe(200);
+    expect(res.body.status).toBe('partial');
+    const erroredFile = res.body.errors.find(e => e.file && e.file.includes('/etc/passwd'));
+    expect(erroredFile).toBeTruthy();
+  });
+
+  it('DC-079: POST /disaster/restore rejects themes with path-traversal name', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        themes: {
+          '../../../etc/caddy/evil.json': { evil: true },
+          'legit-theme.json': { ok: true },
+        },
+      });
+
+    expect(res.status).toBe(200);
+    expect(res.body.status).toBe('partial');
+    const erroredFile = res.body.errors.find(e => e.file && e.file.includes('../../../etc/caddy/evil.json'));
+    expect(erroredFile).toBeTruthy();
+    expect(erroredFile.error).toMatch(/must match/);
+
+    // The legit theme DID get written.
+    expect(fs.existsSync(path.join(tmpDir, 'themes', 'legit-theme.json'))).toBe(true);
+  });
+
+  it('DC-079: POST /disaster/restore rejects themes without .json extension', async () => {
+    const app = createDisasterApp({ dataDir: tmpDir });
+    const res = await request(app)
+      .post('/api/v1/disaster/restore')
+      .send({
+        version: '1.0',
+        themes: {
+          'no-extension': { ok: true },
+        },
+      });
+
+    expect(res.status).toBe(200);
+    expect(res.body.status).toBe('partial');
+    const erroredFile = res.body.errors.find(e => e.file && e.file.includes('no-extension'));
+    expect(erroredFile).toBeTruthy();
+    expect(erroredFile.error).toMatch(/must match/);
+  });
 });

dashcaddy-api/__tests__/routes/exec.routes.test.js

@@ -0,0 +1,192 @@
+/**
+ * DC-072: WebSocket exec scope-based authorization + containerId charset
+ * hardening.
+ *
+ * Bug class under test:
+ *   1. Pre-fix `routes/exec.js` captured `auth.scope` (line 39/46) but
+ *      NEVER enforced it. A JWT or API key whose scope was `['read']`
+ *      (a legitimate monitoring/observability scope) would be granted a
+ *      full PTY-backed shell inside any running container. Container
+ *      exec is root-equivalent inside the container's user namespace,
+ *      so this is a privilege escalation: a read-only key holder could
+ *      run arbitrary commands, exfiltrate mounted volumes, or pivot
+ *      to the host network.
+ *
+ *   2. Pre-fix `containerId` regex `/^[a-zA-Z0-9][a-zA-Z0-9_.-]{0,127}$/`
+ *      accepted mixed case, `_`, `-`, `.`, and any length up to 128.
+ *      Docker container IDs are exactly 64 lowercase hex (or 12-char
+ *      short form). The pre-fix validator would pass any string that
+ *      looked vaguely ID-shaped; Docker's inspect() would then 404.
+ *
+ * Post-fix: `assertExecScope(auth)` requires `admin` scope and throws a
+ * 403-tagged error. `isValidContainerId(id)` accepts only 12 or 64
+ * lowercase hex chars. Both helpers are exported via `__test`.
+ */
+
+const { __test } = require('../../routes/exec');
+const { assertExecScope, isValidContainerId } = __test;
+
+function check(cond, msg) {
+  if (!cond) throw new Error('assertion failed: ' + msg);
+}
+
+describe('DC-072: exec WebSocket scope-based authorization', () => {
+  describe('assertExecScope — admin required', () => {
+    test('admin scope passes', () => {
+      // Should not throw
+      assertExecScope({ type: 'jwt', scope: ['admin'] });
+      assertExecScope({ type: 'apikey', scope: ['admin', 'read'] });
+    });
+
+    test('read-only scope rejected with DC-072_INSUFFICIENT_SCOPE', () => {
+      let caught = null;
+      try {
+        assertExecScope({ type: 'apikey', scope: ['read'] });
+      } catch (e) {
+        caught = e;
+      }
+      check(caught !== null, 'expected assertExecScope to throw on read-only scope');
+      check(caught.code === 'DC-072_INSUFFICIENT_SCOPE', `expected code DC-072_INSUFFICIENT_SCOPE, got ${caught.code}`);
+      check(caught.statusCode === 403, `expected statusCode 403, got ${caught.statusCode}`);
+      check(caught.requiredScope === 'admin', `expected requiredScope=admin, got ${caught.requiredScope}`);
+      check(Array.isArray(caught.actualScope) && caught.actualScope[0] === 'read', `expected actualScope=['read'], got ${JSON.stringify(caught.actualScope)}`);
+    });
+
+    test('write-only scope rejected (write ≠ admin)', () => {
+      let caught = null;
+      try {
+        assertExecScope({ type: 'jwt', scope: ['write'] });
+      } catch (e) {
+        caught = e;
+      }
+      check(caught !== null, 'expected assertExecScope to throw on write-only scope');
+      check(caught.code === 'DC-072_INSUFFICIENT_SCOPE', `expected code DC-072_INSUFFICIENT_SCOPE, got ${caught.code}`);
+      check(caught.statusCode === 403, `expected statusCode 403, got ${caught.statusCode}`);
+    });
+
+    test('empty scope rejected', () => {
+      let caught = null;
+      try {
+        assertExecScope({ type: 'apikey', scope: [] });
+      } catch (e) {
+        caught = e;
+      }
+      check(caught !== null, 'expected assertExecScope to throw on empty scope');
+      check(caught.code === 'DC-072_INSUFFICIENT_SCOPE', 'expected DC-072_INSUFFICIENT_SCOPE code');
+    });
+
+    test('undefined scope rejected (null-safety)', () => {
+      let caught = null;
+      try {
+        assertExecScope({ type: 'jwt' }); // no scope field
+      } catch (e) {
+        caught = e;
+      }
+      check(caught !== null, 'expected assertExecScope to throw on undefined scope');
+      check(caught.code === 'DC-072_INSUFFICIENT_SCOPE', 'expected DC-072_INSUFFICIENT_SCOPE code');
+    });
+
+    test('null auth rejected', () => {
+      let caught = null;
+      try {
+        assertExecScope(null);
+      } catch (e) {
+        caught = e;
+      }
+      check(caught !== null, 'expected assertExecScope to throw on null auth');
+      check(caught.code === 'DC-072_INSUFFICIENT_SCOPE', 'expected DC-072_INSUFFICIENT_SCOPE code');
+    });
+
+    test('non-array scope rejected (defensive)', () => {
+      let caught = null;
+      try {
+        assertExecScope({ type: 'apikey', scope: 'admin' }); // string, not array
+      } catch (e) {
+        caught = e;
+      }
+      check(caught !== null, 'expected assertExecScope to throw on non-array scope');
+      check(caught.code === 'DC-072_INSUFFICIENT_SCOPE', 'expected DC-072_INSUFFICIENT_SCOPE code');
+    });
+
+    test('error envelope carries operator-actionable fields', () => {
+      let caught = null;
+      try {
+        assertExecScope({ type: 'apikey', keyId: 'k_test', scope: ['read'] });
+      } catch (e) {
+        caught = e;
+      }
+      check(caught.message === 'Container exec requires admin scope', `expected canonical message, got ${caught.message}`);
+      check(typeof caught.requiredScope === 'string' && caught.requiredScope === 'admin', 'requiredScope present');
+      check(Array.isArray(caught.actualScope), 'actualScope is array');
+    });
+  });
+
+  describe('isValidContainerId — Docker charset (12 or 64 lowercase hex)', () => {
+    test('64-char lowercase hex accepted (full Docker ID)', () => {
+      // Real-world example: dashcaddy-api container ID
+      check(isValidContainerId('abcdef0123456789abcdef0123456789abcdef0123456789abcdef0123456789') === true, '64-char hex should pass');
+    });
+
+    test('12-char lowercase hex accepted (short form)', () => {
+      check(isValidContainerId('abcdef012345') === true, '12-char hex should pass');
+    });
+
+    test('uppercase hex rejected (Docker IDs are lowercase)', () => {
+      check(isValidContainerId('ABCDEF0123456789ABCDEF0123456789ABCDEF0123456789ABCDEF0123456789') === false, 'uppercase 64-char should fail');
+      check(isValidContainerId('ABCDEF012345') === false, 'uppercase 12-char should fail');
+    });
+
+    test('mixed case rejected', () => {
+      check(isValidContainerId('Abcdef0123456789abcdef0123456789abcdef0123456789abcdef0123456789') === false, 'mixed case 64-char should fail');
+    });
+
+    test('non-hex chars rejected', () => {
+      check(isValidContainerId('zzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzz') === false, 'g-z hex should fail');
+      check(isValidContainerId('abc!@#$%^&*()_+-=[]{}|\\:;\'",.<>/?0123456789012345678901234567890123') === false, 'special chars should fail');
+    });
+
+    test('underscore / dot / dash rejected (pre-fix allowed these)', () => {
+      // Pre-fix regex accepted `_`, `-`, `.` — all are non-Docker
+      check(isValidContainerId('my_container_1') === false, 'underscore should fail');
+      check(isValidContainerId('my.container.1') === false, 'dot should fail');
+      check(isValidContainerId('my-container-1') === false, 'dash should fail');
+    });
+
+    test('wrong length rejected', () => {
+      check(isValidContainerId('abcdef0123456') === false, '13-char should fail');     // 12 + 1
+      check(isValidContainerId('abcdef01234567') === false, '14-char should fail');   // 12 + 2
+      check(isValidContainerId('abcdef0123456789a') === false, '65-char should fail'); // 64 + 1
+    });
+
+    test('empty string rejected', () => {
+      check(isValidContainerId('') === false, 'empty string should fail');
+    });
+
+    test('null / undefined / non-string rejected (defensive)', () => {
+      check(isValidContainerId(null) === false, 'null should fail');
+      check(isValidContainerId(undefined) === false, 'undefined should fail');
+      check(isValidContainerId(12345) === false, 'number should fail');
+      check(isValidContainerId({}) === false, 'object should fail');
+      check(isValidContainerId([]) === false, 'array should fail');
+    });
+
+    test('whitespace / padding rejected', () => {
+      check(isValidContainerId('  abcdef012345  ') === false, 'padded should fail');
+      check(isValidContainerId('\nabcdef012345\n') === false, 'CRLF-padded should fail');
+    });
+
+    test('CRLF injection rejected (defensive against pre-fix attack class)', () => {
+      // Pre-fix regex accepted 128 chars with dots; a payload like
+      // `aa.bb.cc.dd\r\nSet-Cookie:...` would have passed. Post-fix
+      // the LF + non-hex + wrong-length combo fails on every axis.
+      check(isValidContainerId('aa\r\nbb') === false, 'CRLF payload should fail');
+    });
+  });
+
+  describe('__test exports shape', () => {
+    test('exports assertExecScope and isValidContainerId', () => {
+      check(typeof __test.assertExecScope === 'function', 'assertExecScope is a function');
+      check(typeof __test.isValidContainerId === 'function', 'isValidContainerId is a function');
+    });
+  });
+});

dashcaddy-api/__tests__/routes/sites-dc074.routes.test.js

@@ -0,0 +1,535 @@
+/**
+ * DC-074: SSRF hardening for sites.js — `/site` and `/site/external`
+ * must reject upstream hosts that resolve to private/reserved ranges
+ * BEFORE they reach the Caddyfile.
+ *
+ * Bug class: an authenticated dashboard operator could call
+ *   POST /api/v1/site        {domain: "x.example.com", upstream: "10.0.0.1:80"}
+ *   POST /api/v1/site/external {subdomain: "x", externalUrl: "http://192.168.1.5"}
+ * and end up with a Caddy site block that proxies PUBLIC traffic to an
+ * INTERNAL host. Caddy runs on DNS2 (same network as the targets), so
+ * the SSRF lands.
+ *
+ * Pre-fix: `/site`'s only upstream check was `^[a-z0-9.-]+:\d{1,5}$/i`,
+ * which accepts 192.168.1.1:80 and 169.254.169.254:80 (the AWS
+ * metadata IP) with no problem. `/site/external` used `validateURL`
+ * without `blockPrivate: true` at all.
+ *
+ * Post-fix: a new helper `validateUpstream()` in `fleet-validation.js`
+ * reuses the resolver+private-range checks fleet-validation already has
+ * for DC-068, gating Caddyfile writes behind a public-IP requirement.
+ * Opt-in via `SITES_ALLOW_PRIVATE_UPSTREAMS=true` for operators who
+ * intentionally proxy to private targets.
+ *
+ * The suite covers three layers:
+ *   1. Helper unit tests — validateUpstream with mocked DNS / literal IPs
+ *   2. Route integration tests — POST /site and POST /site/external
+ *      reject each known private range, accept public IPs and hostnames
+ *   3. Regression — pre-fix payload `10.0.0.1:80` is rejected (the
+ *      canonical SSRF regression proof)
+ */
+const express = require('express');
+const request = require('supertest');
+
+const {
+  validateUpstream,
+  isPrivateOrReservedIPv4,
+  isPrivateOrReservedIPv6,
+} = require('../../src/utilities/fleet-validation');
+
+// ---------------------------------------------------------------------------
+// Test fixtures
+// ---------------------------------------------------------------------------
+
+const LOG = () => ({ info: jest.fn(), warn: jest.fn(), error: jest.fn() });
+
+/**
+ * Build a minimal Express app that mounts /api/v1/sites with stubbed
+ * caddy/dns/buildDomain/addServiceToConfig. The stubs record every call
+ * so tests can assert the route does NOT mutate the Caddyfile when it
+ * should reject.
+ */
+function createSitesApp({ log, caddyStub, buildDomainStub, dnsStub, addServiceToConfigStub } = {}) {
+  const app = express();
+  app.use(express.json({ limit: '1mb' }));
+  const sites = require('../../routes/sites');
+  const wrap = (fn) => (req, res, next) => Promise.resolve(fn(req, res, next)).catch(next);
+  const caddy = caddyStub || {
+    read: async () => '# stub caddyfile\n',
+    modify: jest.fn(async () => ({ success: true })),
+    adminUrl: 'http://127.0.0.1:2019',
+    filePath: '/tmp/stub-Caddyfile',
+  };
+  const dns = dnsStub || {
+    universalCreateRecord: jest.fn(async () => true),
+  };
+  app.use('/api/v1', sites({
+    asyncHandler: wrap,
+    ok: (res, data) => res.json({ ok: true, ...data }),
+    successMessage: (res, msg) => res.json({ ok: true, message: msg }),
+    caddy,
+    dns,
+    fetchT: async () => ({ ok: true, json: async () => ({}) }),
+    buildDomain: buildDomainStub || ((sub) => `${sub}.example.com`),
+    addServiceToConfig: addServiceToConfigStub || jest.fn(async () => true),
+    siteConfig: { dnsServerIp: '127.0.0.1' },
+    log: log || LOG(),
+  }));
+  // JSON error middleware — must mirror the shape sites.js's production
+  // global error middleware emits so route tests can assert on it. Without
+  // this, Express's default error handler returns an HTML stack trace and
+  // res.body.error is undefined.
+  // eslint-disable-next-line no-unused-vars
+  app.use((err, req, res, next) => {
+    const status = err.statusCode || 500;
+    res.status(status).json({
+      error: err.message || 'Internal Server Error',
+      code: err.code || null,
+      field: err.field || null,
+    });
+  });
+  return { app, caddy };
+}
+
+/** Mock dns.promises.lookup to return a specific IP for any hostname.
+ *  Returns an array of `{address, family}` records since fleet-validation
+ *  calls `dns.lookup(name, {all: true})`. */
+function mockDnsLookup(map) {
+  const dns = require('dns');
+  const original = dns.promises.lookup;
+  dns.promises.lookup = async (hostname, opts) => {
+    for (const [pattern, ip] of Object.entries(map)) {
+      if (hostname === pattern || (pattern instanceof RegExp && pattern.test(hostname))) {
+        const family = ip.includes(':') ? 6 : 4;
+        return [{ address: ip, family }];
+      }
+    }
+    // Default: throw ENOTFOUND
+    const err = new Error('ENOTFOUND');
+    err.code = 'ENOTFOUND';
+    throw err;
+  };
+  return () => {
+    dns.promises.lookup = original;
+  };
+}
+
+// ---------------------------------------------------------------------------
+// 1. Helper unit tests
+// ---------------------------------------------------------------------------
+
+describe('DC-074: validateUpstream (helper)', () => {
+  let restoreDns;
+
+  beforeEach(() => {
+    delete process.env.SITES_ALLOW_PRIVATE_UPSTREAMS;
+  });
+
+  afterEach(() => {
+    if (restoreDns) restoreDns();
+    delete process.env.SITES_ALLOW_PRIVATE_UPSTREAMS;
+  });
+
+  describe('format validation', () => {
+    test('rejects empty / non-string with INVALID_UPSTREAM', async () => {
+      expect(await validateUpstream('')).toMatchObject({ ok: false, code: 'INVALID_UPSTREAM' });
+      expect(await validateUpstream(null)).toMatchObject({ ok: false, code: 'INVALID_UPSTREAM' });
+      expect(await validateUpstream(undefined)).toMatchObject({ ok: false, code: 'INVALID_UPSTREAM' });
+      expect(await validateUpstream(42)).toMatchObject({ ok: false, code: 'INVALID_UPSTREAM' });
+    });
+
+    test('rejects missing port with INVALID_UPSTREAM', async () => {
+      expect(await validateUpstream('hostonly')).toMatchObject({ ok: false, code: 'INVALID_UPSTREAM' });
+    });
+
+    test('rejects non-integer port with INVALID_PORT', async () => {
+      expect(await validateUpstream('host:abc')).toMatchObject({ ok: false, code: 'INVALID_PORT' });
+      expect(await validateUpstream('host:80.5')).toMatchObject({ ok: false, code: 'INVALID_PORT' });
+    });
+
+    test('rejects out-of-range port with INVALID_PORT', async () => {
+      expect(await validateUpstream('host:0')).toMatchObject({ ok: false, code: 'INVALID_PORT' });
+      expect(await validateUpstream('host:65536')).toMatchObject({ ok: false, code: 'INVALID_PORT' });
+      expect(await validateUpstream('host:99999999')).toMatchObject({ ok: false, code: 'INVALID_PORT' });
+      expect(await validateUpstream('host:-1')).toMatchObject({ ok: false, code: 'INVALID_PORT' });
+    });
+  });
+
+  describe('private IPv4 reject (literal)', () => {
+    const PRIVATE_V4 = [
+      ['127.0.0.1', 'loopback'],
+      ['127.255.255.1', 'loopback'],
+      ['10.0.0.1', 'RFC 1918'],
+      ['172.16.0.1', 'RFC 1918'],
+      ['192.168.1.1', 'RFC 1918'],
+      ['169.254.169.254', 'link-local'],          // AWS IMDS
+      ['100.64.0.1', 'CGNAT'],
+      ['224.0.0.1', 'multicast'],
+      ['255.255.255.255', 'broadcast'],
+      ['0.0.0.0', 'reserved'],
+    ];
+    for (const [ip, wantLabel] of PRIVATE_V4) {
+      test(`rejects ${ip} (${wantLabel})`, async () => {
+        const r = await validateUpstream(`${ip}:80`);
+        expect(r.ok).toBe(false);
+        expect(r.code).toBe('PRIVATE_IPV4');
+        expect(r.message).toMatch(new RegExp(wantLabel, 'i'));
+      });
+    }
+  });
+
+  describe('private IPv6 reject (literal)', () => {
+    test('rejects ::1 (loopback)', async () => {
+      const r = await validateUpstream('[::1]:80');
+      expect(r.ok).toBe(false);
+      expect(r.code).toBe('PRIVATE_IPV6');
+    });
+
+    test('rejects fe80::1 (link-local)', async () => {
+      const r = await validateUpstream('[fe80::1]:80');
+      expect(r.ok).toBe(false);
+      expect(r.code).toBe('PRIVATE_IPV6');
+    });
+
+    test('rejects fc00::1 (ULA)', async () => {
+      const r = await validateUpstream('[fc00::1]:80');
+      expect(r.ok).toBe(false);
+      expect(r.code).toBe('PRIVATE_IPV6');
+    });
+  });
+
+  describe('public IPs accepted (literal)', () => {
+    test('accepts 8.8.8.8', async () => {
+      const r = await validateUpstream('8.8.8.8:53');
+      expect(r.ok).toBe(true);
+      expect(r.host).toBe('8.8.8.8');
+      expect(r.port).toBe(53);
+      expect(r.family).toBe(4);
+    });
+
+    test('accepts 1.1.1.1', async () => {
+      const r = await validateUpstream('1.1.1.1:443');
+      expect(r.ok).toBe(true);
+      expect(r.port).toBe(443);
+    });
+  });
+
+  describe('hostname resolve', () => {
+    test('accepts hostname that resolves to public IP', async () => {
+      restoreDns = mockDnsLookup({ 'public.example.com': '8.8.8.8' });
+      const r = await validateUpstream('public.example.com:443');
+      expect(r.ok).toBe(true);
+      expect(r.resolvedIp).toBe('8.8.8.8');
+      expect(r.family).toBe(4);
+    });
+
+    test('rejects hostname that resolves to private IP (DNS rebinding defense)', async () => {
+      restoreDns = mockDnsLookup({ 'evil.example.com': '10.0.0.5' });
+      const r = await validateUpstream('evil.example.com:80');
+      expect(r.ok).toBe(false);
+      expect(r.code).toBe('PRIVATE_IPV4');
+      expect(r.message).toMatch(/evil\.example\.com.*10\.0\.0\.5/);
+    });
+
+    test('rejects hostname that fails to resolve', async () => {
+      // mockDnsLookup default throws ENOTFOUND
+      const r = await validateUpstream('does-not-exist.invalid:80');
+      expect(r.ok).toBe(false);
+      expect(r.code).toMatch(/DNS_/);
+    });
+
+    test('rejects hostname with invalid charset pre-DNS', async () => {
+      const r = await validateUpstream('host with spaces:80');
+      expect(r.ok).toBe(false);
+      expect(r.code).toBe('INVALID_HOST');
+    });
+  });
+
+  describe('SITES_ALLOW_PRIVATE_UPSTREAMS opt-in', () => {
+    test('default rejects private IPs', async () => {
+      const r = await validateUpstream('10.0.0.1:80');
+      expect(r.ok).toBe(false);
+    });
+
+    test('opt-in accepts private literal IP', async () => {
+      process.env.SITES_ALLOW_PRIVATE_UPSTREAMS = 'true';
+      const r = await validateUpstream('10.0.0.1:80');
+      expect(r.ok).toBe(true);
+    });
+
+    test('opt-in accepts private DNS-resolved host', async () => {
+      process.env.SITES_ALLOW_PRIVATE_UPSTREAMS = 'true';
+      restoreDns = mockDnsLookup({ 'internal.example.com': '10.0.0.5' });
+      const r = await validateUpstream('internal.example.com:80');
+      expect(r.ok).toBe(true);
+    });
+
+    test('explicit allowPrivate:false overrides env opt-in (programmatic guard)', async () => {
+      process.env.SITES_ALLOW_PRIVATE_UPSTREAMS = 'true';
+      const r = await validateUpstream('10.0.0.1:80', { allowPrivate: false });
+      expect(r.ok).toBe(false);
+      expect(r.code).toBe('PRIVATE_IPV4');
+    });
+  });
+});
+
+// ---------------------------------------------------------------------------
+// 2. Route integration tests — POST /site
+// ---------------------------------------------------------------------------
+
+describe('DC-074: POST /api/v1/site — SSRF hardening', () => {
+  let restoreDns;
+  let caddyStub;
+
+  beforeEach(() => {
+    delete process.env.SITES_ALLOW_PRIVATE_UPSTREAMS;
+    caddyStub = {
+      read: async () => '# stub caddyfile\n',
+      modify: jest.fn(async () => ({ success: true })),
+      adminUrl: 'http://127.0.0.1:2019',
+      filePath: '/tmp/stub-Caddyfile',
+    };
+  });
+
+  afterEach(() => {
+    if (restoreDns) restoreDns();
+    delete process.env.SITES_ALLOW_PRIVATE_UPSTREAMS;
+  });
+
+  const REGRESSION_CASES = [
+    ['10.0.0.1:80',          'PRIVATE_IPV4'],
+    ['172.16.0.1:80',        'PRIVATE_IPV4'],
+    ['192.168.1.1:80',       'PRIVATE_IPV4'],
+    ['127.0.0.1:80',         'PRIVATE_IPV4'],
+    ['169.254.169.254:80',   'PRIVATE_IPV4'],   // AWS IMDS
+    ['100.64.0.1:80',        'PRIVATE_IPV4'],   // CGNAT
+    ['224.0.0.1:80',         'PRIVATE_IPV4'],   // multicast
+    ['0.0.0.0:80',           'PRIVATE_IPV4'],   // reserved
+    ['[::1]:80',             'PRIVATE_IPV6'],
+    ['[fc00::1]:80',         'PRIVATE_IPV6'],
+  ];
+
+  for (const [upstream, wantCode] of REGRESSION_CASES) {
+    test(`rejects upstream="${upstream}" with code=${wantCode}`, async () => {
+      const { app } = createSitesApp({ caddyStub });
+      const res = await request(app)
+        .post('/api/v1/site')
+        .send({ domain: 'evil.example.com', upstream });
+      expect(res.status).toBe(400);
+      expect(res.body.error).toMatch(/\[DC-074\]/);
+      expect(res.body.error).toMatch(/SITES_ALLOW_PRIVATE_UPSTREAMS/);
+      // caddy.modify() must NOT have been called (gate happens before write)
+      expect(caddyStub.modify).not.toHaveBeenCalled();
+    });
+  }
+
+  test('rejects DNS-resolved private IP (rebinding defense)', async () => {
+    restoreDns = mockDnsLookup({ 'looks-public.example.com': '10.0.0.5' });
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'evil.example.com', upstream: 'looks-public.example.com:80' });
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/10\.0\.0\.5/);
+    expect(caddyStub.modify).not.toHaveBeenCalled();
+  });
+
+  test('accepts public literal IP', async () => {
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'new.example.com', upstream: '8.8.8.8:80' });
+    expect(res.status).toBe(200);
+    expect(caddyStub.modify).toHaveBeenCalledTimes(1);
+  });
+
+  test('accepts hostname resolving to public IP', async () => {
+    restoreDns = mockDnsLookup({ 'real.example.com': '8.8.8.8' });
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'new.example.com', upstream: 'real.example.com:80' });
+    expect(res.status).toBe(200);
+    expect(caddyStub.modify).toHaveBeenCalledTimes(1);
+  });
+
+  test('SITES_ALLOW_PRIVATE_UPSTREAMS=true opts in for private literal', async () => {
+    process.env.SITES_ALLOW_PRIVATE_UPSTREAMS = 'true';
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'lab.example.com', upstream: '10.0.0.1:80' });
+    expect(res.status).toBe(200);
+    expect(caddyStub.modify).toHaveBeenCalledTimes(1);
+  });
+
+  test('SITES_ALLOW_PRIVATE_UPSTREAMS=true opts in for private-resolved hostname', async () => {
+    process.env.SITES_ALLOW_PRIVATE_UPSTREAMS = 'true';
+    restoreDns = mockDnsLookup({ 'internal.lan': '10.0.0.5' });
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'lab.example.com', upstream: 'internal.lan:80' });
+    expect(res.status).toBe(200);
+  });
+
+  test('rejects out-of-range port without invoking private-IP check', async () => {
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'new.example.com', upstream: '8.8.8.8:99999' });
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/INVALID_PORT|\[DC-074\]/);
+    expect(caddyStub.modify).not.toHaveBeenCalled();
+  });
+
+  test('rejects upstream with spaces (charset) without invoking private-IP check', async () => {
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'new.example.com', upstream: 'not a host:80' });
+    expect(res.status).toBe(400);
+    expect(caddyStub.modify).not.toHaveBeenCalled();
+  });
+});
+
+// ---------------------------------------------------------------------------
+// 3. Route integration tests — POST /site/external
+// ---------------------------------------------------------------------------
+
+describe('DC-074: POST /api/v1/site/external — SSRF hardening', () => {
+  let restoreDns;
+  let caddyStub;
+
+  beforeEach(() => {
+    delete process.env.SITES_ALLOW_PRIVATE_UPSTREAMS;
+    caddyStub = {
+      read: async () => '# stub caddyfile\n',
+      modify: jest.fn(async () => ({ success: true })),
+      adminUrl: 'http://127.0.0.1:2019',
+      filePath: '/tmp/stub-Caddyfile',
+    };
+  });
+
+  afterEach(() => {
+    if (restoreDns) restoreDns();
+    delete process.env.SITES_ALLOW_PRIVATE_UPSTREAMS;
+  });
+
+  const REGRESSION_CASES = [
+    'http://10.0.0.1',
+    'http://192.168.1.1',
+    'http://127.0.0.1',
+    'http://169.254.169.254',     // AWS IMDS via URL form
+    'http://100.64.0.1',          // CGNAT — caught by validateUpstream defense-in-depth, not validateURL
+    'http://0.0.0.0',
+    'http://[::1]',
+    'http://[fc00::1]',
+  ];
+
+  for (const externalUrl of REGRESSION_CASES) {
+    test(`rejects externalUrl="${externalUrl}"`, async () => {
+      const { app } = createSitesApp({ caddyStub });
+      const res = await request(app)
+        .post('/api/v1/site/external')
+        .send({ subdomain: 'ext', externalUrl });
+      // 400 from validateURL OR from validateUpstream — either path closes the gate.
+      expect(res.status).toBe(400);
+      expect(caddyStub.modify).not.toHaveBeenCalled();
+    });
+  }
+
+  test('rejects DNS-resolved private IP', async () => {
+    restoreDns = mockDnsLookup({ 'looks-public.example.com': '10.0.0.5' });
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site/external')
+      .send({ subdomain: 'ext', externalUrl: 'http://looks-public.example.com' });
+    expect(res.status).toBe(400);
+    expect(res.body.error).toMatch(/\[DC-074\]|Private URLs/);
+    expect(caddyStub.modify).not.toHaveBeenCalled();
+  });
+
+  test('accepts externalUrl with public hostname', async () => {
+    restoreDns = mockDnsLookup({ 'api.example.com': '8.8.8.8' });
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site/external')
+      .send({ subdomain: 'ext', externalUrl: 'http://api.example.com' });
+    expect(res.status).toBe(200);
+    expect(caddyStub.modify).toHaveBeenCalledTimes(1);
+  });
+
+  test('accepts externalUrl with public literal IP', async () => {
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site/external')
+      .send({ subdomain: 'ext', externalUrl: 'http://8.8.8.8' });
+    expect(res.status).toBe(200);
+  });
+
+  test('SITES_ALLOW_PRIVATE_UPSTREAMS=true opts in for private externalUrl', async () => {
+    process.env.SITES_ALLOW_PRIVATE_UPSTREAMS = 'true';
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site/external')
+      .send({ subdomain: 'ext', externalUrl: 'http://10.0.0.5' });
+    expect(res.status).toBe(200);
+  });
+});
+
+// ---------------------------------------------------------------------------
+// 4. Regression — pre-fix payload (the canonical SSRF regression proof)
+// ---------------------------------------------------------------------------
+
+describe('DC-074: regression — pre-fix payloads are now rejected', () => {
+  test('the canonical SSRF payload `10.0.0.1:80` is rejected at the route layer', async () => {
+    const caddyStub = {
+      read: async () => '',
+      modify: jest.fn(async () => ({ success: true })),
+      adminUrl: 'http://127.0.0.1:2019',
+      filePath: '/tmp/stub-Caddyfile',
+    };
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site')
+      .send({ domain: 'evil.attacker.com', upstream: '10.0.0.1:80' });
+    expect(res.status).toBe(400);
+    // Pre-fix this payload would have been accepted, the regex happily
+    // matches `[a-z0-9.-]+:\d{1,5}` against `10.0.0.1:80`, and a Caddy
+    // site block would have been written that proxied public HTTPS
+    // traffic at `evil.attacker.com` to the internal 10.0.0.1:80.
+    expect(caddyStub.modify).not.toHaveBeenCalled();
+  });
+
+  test('the canonical SSRF payload `http://192.168.1.5` is rejected at the external endpoint', async () => {
+    const caddyStub = {
+      read: async () => '',
+      modify: jest.fn(async () => ({ success: true })),
+      adminUrl: 'http://127.0.0.1:2019',
+      filePath: '/tmp/stub-Caddyfile',
+    };
+    const { app } = createSitesApp({ caddyStub });
+    const res = await request(app)
+      .post('/api/v1/site/external')
+      .send({ subdomain: 'ext', externalUrl: 'http://192.168.1.5' });
+    expect(res.status).toBe(400);
+    expect(caddyStub.modify).not.toHaveBeenCalled();
+  });
+});
+
+// ---------------------------------------------------------------------------
+// 5. Sanity — fleet-validation helper exports still work as before
+// ---------------------------------------------------------------------------
+
+describe('DC-074: fleet-validation helpers still exported and unchanged behavior', () => {
+  test('isPrivateOrReservedIPv4 still detects the same set as before', () => {
+    expect(isPrivateOrReservedIPv4('10.0.0.1').isPrivate).toBe(true);
+    expect(isPrivateOrReservedIPv4('8.8.8.8').isPrivate).toBe(false);
+  });
+
+  test('isPrivateOrReservedIPv6 still detects the same set as before', () => {
+    expect(isPrivateOrReservedIPv6('::1').isPrivate).toBe(true);
+    expect(isPrivateOrReservedIPv6('2001:4860:4860::8888').isPrivate).toBe(false);
+  });
+});

dashcaddy-api/__tests__/update-manager.test.js

@@ -125,6 +125,239 @@ describe('UpdateManager — Docker image update lifecycle', () => {
     });
   });
 
+  // ─── DC-078: registry digest probe reliability hardening ──────────────────
+  // Verifies that getLatestImageDigest / getDockerHubDigest / getGhcrDigest /
+  // fetchWithReliability all apply the IPv4-only + timeout + transient-retry
+  // policy. Without these guards, the per-hour checkForUpdates() loop on DNS2
+  // surfaces AggregateError [ETIMEDOUT] in error.log because the container's
+  // /etc/resolv.conf returns AAAA records from Technitium whose IPv6 path to
+  // public registries (Docker Hub, ghcr.io) is intermittently unreachable.
+  describe('DC-078 registry reliability', () => {
+    // Use real timers — fetchWithReliability's retry uses setTimeout for
+    // backoff, which jest's fake timers would block indefinitely.
+    beforeEach(() => {
+      jest.useRealTimers();
+    });
+    afterEach(() => {
+      jest.useFakeTimers({ doNotFake: ['setImmediate', 'queueMicrotask', 'nextTick'] });
+    });
+
+    it('_httpsRequestOnce sets family: 4 and timeout on the request options', async () => {
+      let capturedOptions = null;
+      const req = {
+        on: jest.fn(),
+        end: jest.fn(),
+        destroy: jest.fn(),
+      };
+      https.request.mockImplementation((options, cb) => {
+        capturedOptions = options;
+        // Return a 200 immediately so the promise resolves cleanly.
+        const res = {
+          statusCode: 200,
+          headers: {},
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          }),
+        };
+        setImmediate(() => cb(res));
+        return req;
+      });
+
+      await updateManager._httpsRequestOnce({
+        hostname: 'registry-1.docker.io',
+        path: '/v2/library/nginx/manifests/latest',
+        headers: { Accept: 'application/vnd.docker.distribution.manifest.v2+json' },
+        maxBodyBytes: 65536,
+      });
+      expect(capturedOptions).not.toBeNull();
+      expect(capturedOptions.family).toBe(4);
+      expect(capturedOptions.timeout).toBeGreaterThan(0);
+      expect(capturedOptions.method).toBe('GET');
+    });
+
+    it('fetchWithReliability retries on transient ETIMEDOUT and eventually succeeds', async () => {
+      let attempts = 0;
+      https.request.mockImplementation((options, cb) => {
+        attempts += 1;
+        if (attempts === 1) {
+          // First attempt: emit ETIMEDOUT via the request 'error' event
+          const reqErr = new Error('request timeout');
+          reqErr.code = 'ETIMEDOUT';
+          const req = {
+            on: jest.fn((event, handler) => {
+              if (event === 'error') setImmediate(() => handler(reqErr));
+            }),
+            end: jest.fn(),
+            destroy: jest.fn(),
+          };
+          return req;
+        }
+        // Second attempt: 200 OK with a digest header
+        const res = {
+          statusCode: 200,
+          headers: { 'docker-content-digest': 'sha256:abc123def456' },
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          }),
+        };
+        setImmediate(() => cb(res));
+        return { on: jest.fn(), end: jest.fn(), destroy: jest.fn() };
+      });
+
+      const result = await updateManager.fetchWithReliability({
+        hostname: 'registry-1.docker.io',
+        path: '/v2/library/nginx/manifests/latest',
+      });
+      expect(attempts).toBe(2);
+      expect(result.statusCode).toBe(200);
+      expect(result.headers['docker-content-digest']).toBe('sha256:abc123def456');
+    });
+
+    it('fetchWithReliability does NOT retry on non-transient HTTP errors', async () => {
+      let attempts = 0;
+      https.request.mockImplementation((options, cb) => {
+        attempts += 1;
+        const res = {
+          statusCode: 500,
+          headers: {},
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          }),
+        };
+        setImmediate(() => cb(res));
+        return { on: jest.fn(), end: jest.fn(), destroy: jest.fn() };
+      });
+      const result = await updateManager.fetchWithReliability({
+        hostname: 'registry-1.docker.io',
+        path: '/v2/library/nginx/manifests/latest',
+      });
+      expect(attempts).toBe(1);
+      expect(result.statusCode).toBe(500);
+    });
+
+    it('fetchWithReliability retries up to REGISTRY_MAX_RETRIES then throws', async () => {
+      let attempts = 0;
+      https.request.mockImplementation(() => {
+        attempts += 1;
+        const reqErr = new Error('connect ETIMEDOUT');
+        reqErr.code = 'ETIMEDOUT';
+        const req = {
+          on: jest.fn((event, handler) => {
+            if (event === 'error') setImmediate(() => handler(reqErr));
+          }),
+          end: jest.fn(),
+          destroy: jest.fn(),
+        };
+        return req;
+      });
+      await expect(updateManager.fetchWithReliability({
+        hostname: 'registry-1.docker.io',
+        path: '/v2/library/nginx/manifests/latest',
+      })).rejects.toMatchObject({ code: 'ETIMEDOUT' });
+      // 1 initial attempt + REGISTRY_MAX_RETRIES retries
+      expect(attempts).toBe(1 + 1);
+    });
+
+    it('getDockerHubDigest returns digest on 200', async () => {
+      https.request.mockImplementation((options, cb) => {
+        const res = {
+          statusCode: 200,
+          headers: { 'docker-content-digest': 'sha256:hubdigest9999' },
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          }),
+        };
+        setImmediate(() => cb(res));
+        return { on: jest.fn(), end: jest.fn(), destroy: jest.fn() };
+      });
+      const digest = await updateManager.getDockerHubDigest('nginx', 'latest');
+      expect(digest).toBe('sha256:hubdigest9999');
+    });
+
+    it('getDockerHubDigest acquires bearer token on 401 then returns digest', async () => {
+      let calls = 0;
+      https.request.mockImplementation((options, cb) => {
+        calls += 1;
+        if (calls === 1) {
+          // First call to registry-1.docker.io returns 401 with WWW-Authenticate
+          const res = {
+            statusCode: 401,
+            headers: {
+              'www-authenticate': 'Bearer realm="https://auth.example.com/token",service="registry.docker.io",scope="repository:library/nginx:pull"',
+            },
+            on: jest.fn((event, handler) => {
+              if (event === 'end') setImmediate(handler);
+            }),
+          };
+          setImmediate(() => cb(res));
+        } else if (calls === 2) {
+          // Second call: auth.example.com returns the token JSON
+          const res = {
+            statusCode: 200,
+            headers: {},
+            on: jest.fn((event, handler) => {
+              if (event === 'data') handler(Buffer.from(JSON.stringify({ token: 'jwt-token-xyz' })));
+              if (event === 'end') setImmediate(handler);
+            }),
+          };
+          setImmediate(() => cb(res));
+        } else {
+          // Third call: registry-1.docker.io with Bearer header returns the digest
+          expect(options.headers['Authorization']).toBe('Bearer jwt-token-xyz');
+          const res = {
+            statusCode: 200,
+            headers: { 'docker-content-digest': 'sha256:autheddigest7777' },
+            on: jest.fn((event, handler) => {
+              if (event === 'end') setImmediate(handler);
+            }),
+          };
+          setImmediate(() => cb(res));
+        }
+        return { on: jest.fn(), end: jest.fn(), destroy: jest.fn() };
+      });
+      const digest = await updateManager.getDockerHubDigest('nginx', 'latest');
+      expect(digest).toBe('sha256:autheddigest7777');
+      expect(calls).toBe(3);
+    });
+
+    it('getGhcrDigest returns digest on 200', async () => {
+      https.request.mockImplementation((options, cb) => {
+        expect(options.hostname).toBe('ghcr.io');
+        const res = {
+          statusCode: 200,
+          headers: { 'docker-content-digest': 'sha256:ghcrdigest1234' },
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          }),
+        };
+        setImmediate(() => cb(res));
+        return { on: jest.fn(), end: jest.fn(), destroy: jest.fn() };
+      });
+      const digest = await updateManager.getGhcrDigest('ghcr.io/some/repo', 'latest');
+      expect(digest).toBe('sha256:ghcrdigest1234');
+    });
+
+    it('getLatestImageDigest returns null on transient errors after retries (registry unavailable)', async () => {
+      // Simulate a totally-down registry: every attempt fails with ETIMEDOUT.
+      // After REGISTRY_MAX_RETRIES the error propagates to getLatestImageDigest's
+      // catch arm, which logs and returns null (matches old behavior).
+      https.request.mockImplementation(() => {
+        const reqErr = new Error('connect ETIMEDOUT');
+        reqErr.code = 'ETIMEDOUT';
+        const req = {
+          on: jest.fn((event, handler) => {
+            if (event === 'error') setImmediate(() => handler(reqErr));
+          }),
+          end: jest.fn(),
+          destroy: jest.fn(),
+        };
+        return req;
+      });
+      const digest = await updateManager.getLatestImageDigest('nginx:latest');
+      expect(digest).toBeNull();
+    });
+  });
+
   describe('parseAuthHeader', () => {
     it('parses Docker Hub Bearer auth header', () => {
       const header = 'Bearer realm="https://auth.docker.io/token",service="registry.docker.io",scope="repository:library/nginx:pull"';
@@ -481,7 +714,9 @@ describe('UpdateManager — Docker image update lifecycle', () => {
         setImmediate(() => cb({
           statusCode: 200,
           headers: { 'docker-content-digest': 'sha256:fromregistry' },
-          on: jest.fn()
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          })
         }));
         return { on: jest.fn(), end: jest.fn() };
       });
@@ -495,7 +730,9 @@ describe('UpdateManager — Docker image update lifecycle', () => {
         setImmediate(() => cb({
           statusCode: 401,
           headers: {},
-          on: jest.fn()
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          })
         }));
         return { on: jest.fn(), end: jest.fn() };
       });
@@ -504,6 +741,9 @@ describe('UpdateManager — Docker image update lifecycle', () => {
     });
 
     it('rejects on https request error', async () => {
+      // ECONNREFUSED is in REGISTRY_TRANSIENT_ERROR_CODES, so this would retry.
+      // Use a non-transient code (or no code) for the test to propagate.
+      jest.useRealTimers();
       https.request.mockImplementation(() => {
         const req = { on: jest.fn(), end: jest.fn() };
         // Trigger error event asynchronously
@@ -516,6 +756,7 @@ describe('UpdateManager — Docker image update lifecycle', () => {
 
       await expect(updateManager.getDockerHubDigest('nginx', 'latest'))
         .rejects.toThrow('connection refused');
+      jest.useFakeTimers({ doNotFake: ['setImmediate', 'queueMicrotask', 'nextTick'] });
     });
 
     it('normalizes library/ prefix for official images', async () => {
@@ -525,7 +766,9 @@ describe('UpdateManager — Docker image update lifecycle', () => {
         setImmediate(() => cb({
           statusCode: 200,
           headers: { 'docker-content-digest': 'sha256:digest' },
-          on: jest.fn()
+          on: jest.fn((event, handler) => {
+            if (event === 'end') setImmediate(handler);
+          })
         }));
         return { on: jest.fn(), end: jest.fn() };
       });

dashcaddy-api/routes/ca.js

@@ -123,17 +123,106 @@ module.exports = function(ctx) {
     res.send(script);
   }, 'ca-install-script'));
 
+  // DC-076: per-service cert/key download — TOTP + admin scope required.
+  // Pre-fix this endpoint (a) had a hardcoded `password = 'dashcaddy'` default
+  // for the PFX format — a default credential published in source; (b) was
+  // public-listed in middleware.js PUBLIC_ROUTES (TOTP bypassed when TOTP is
+  // disabled — single ops command or fresh-install setup state), and (c)
+  // accepted ANY TOTP-authenticated scope (read scope was enough to pull
+  // private keys). Fix: require explicit password (no default), require
+  // TOTP/session (dropped from PUBLIC_ROUTES — see middleware.js), and
+  // require `admin` scope at the route layer as defense-in-depth against
+  // future middleware-ordering mistakes.
+  const CA_CERT_DOMAINS_RE = /^[a-z0-9]([a-z0-9-]{0,61}[a-z0-9])?(\.[a-z0-9]([a-z0-9-]{0,61}[a-z0-9])?)+$/;
+  // Per-DC-076: PFX password now required, ≥ 8 chars, no `=` (pkcs12
+  // interprets `=` as a base64 padding marker that downstream tooling
+  // can mis-handle; reject it to keep the password copy-paste-safe).
+  const CA_PFX_PASSWORD_RE = /^[A-Za-z0-9!@#%^_+,.~:-]{8,64}$/;
+  const CA_CERT_RATE_LIMIT = { windowMs: 60_000, max: 10 };
+  const caCertRateBuckets = new Map(); // ip -> { count, resetAt }
+  function caCertRateLimit(ip) {
+    const now = Date.now();
+    const b = caCertRateBuckets.get(ip);
+    if (!b || b.resetAt <= now) {
+      caCertRateBuckets.set(ip, { count: 1, resetAt: now + CA_CERT_RATE_LIMIT.windowMs });
+      return { allowed: true, remaining: CA_CERT_RATE_LIMIT.max - 1 };
+    }
+    if (b.count >= CA_CERT_RATE_LIMIT.max) {
+      return { allowed: false, remaining: 0, retryAfterMs: b.resetAt - now };
+    }
+    b.count += 1;
+    return { allowed: true, remaining: CA_CERT_RATE_LIMIT.max - b.count };
+  }
+  function requireCaCertAdminScope(req, res) {
+    // TOTP is enforced by `totpAuthMiddleware` globally. Here we additionally
+    // require the `admin` scope — even a read-scope API key or read-scope
+    // JWT must NOT be able to pull a private key. Auth context is mounted on
+    // `req.auth` by the upstream middlewares.
+    const auth = req.auth || {};
+    const scope = Array.isArray(auth.scope) ? auth.scope : [];
+    if (!scope.includes('admin')) {
+      ctx.errorResponse(res, 403,
+        'Admin scope required to download per-service private keys. Re-authenticate with an admin-scoped credential.',
+        { code: 'DC-076_INSUFFICIENT_SCOPE', requiredScope: 'admin', actualScope: scope });
+      return false;
+    }
+    return true;
+  }
+
   // Generate and download SSL certificate for a service
   router.get('/cert/:domain', ctx.asyncHandler(async (req, res) => {
-    const { domain } = req.params;
+    if (!requireCaCertAdminScope(req, res)) return;
-    const { password = 'dashcaddy', format = 'pfx' } = req.query;
 
-    if (!/^[a-zA-Z0-9!@#%^_+=,.:-]{1,64}$/.test(password)) {
+    const { domain } = req.params;
-      throw new ValidationError('Invalid password. Use only letters, numbers, and basic symbols (max 64 chars).');
+
+    // DC-076: password is REQUIRED for the pfx format (no `=`) and must
+    // be ≥ 8 chars. Previously `password = 'dashcaddy'` — a hardcoded
+    // default that silently signed every PFX with the same published
+    // password. Other formats (key, pem, crt, fullchain) do not need a
+    // password and ignore the param.
+    const wantsPfx = !req.query.format || req.query.format === 'pfx';
+    let password = req.query.password;
+    if (wantsPfx) {
+      if (typeof password !== 'string' || password === '') {
+        return ctx.errorResponse(res, 400,
+          'PFX format requires an explicit `password` query param (8-64 chars, no `=`). '
+          + 'A published default is unsafe — pick your own.',
+          { code: 'DC-076_PASSWORD_REQUIRED' });
+      }
+      if (!CA_PFX_PASSWORD_RE.test(password)) {
+        return ctx.errorResponse(res, 400,
+          'PFX password must be 8-64 chars from [A-Za-z0-9!@#%^_+,.~:-].',
+          { code: 'DC-076_PASSWORD_INVALID' });
+      }
+    } else {
+      // For non-PFX formats, still reject `=` in the password so a copy-paste
+      // mistake can't accidentally inject a base64 padding token into a path
+      // someone else might log.
+      if (password !== undefined && (typeof password !== 'string' || password.includes('='))) {
+        return ctx.errorResponse(res, 400, 'password (if supplied) must be a string without `=`.',
+          { code: 'DC-076_PASSWORD_INVALID' });
+      }
     }
 
-    if (!domain || !/^[a-z0-9]([a-z0-9-]*[a-z0-9])?(\.[a-z0-9]([a-z0-9-]*[a-z0-9])?)*$/i.test(domain)) {
+    // DC-076: per-IP rate limit — each cert request forks an `openssl` process
-      return ctx.errorResponse(res, 400, `Invalid domain name. Must be a valid hostname (e.g., dns1${ctx.siteConfig.tld})`);
+    // and writes to disk. An authenticated admin polling the endpoint in a
+    // loop could exhaust CPU/IO. 10 req/min/IP is enough for normal use
+    // (regenerate one cert, check 4 formats, done) and tight enough to stop
+    // a runaway client.
+    const clientIp = req.ip || req.connection?.remoteAddress || 'unknown';
+    const rl = caCertRateLimit(clientIp);
+    if (!rl.allowed) {
+      res.setHeader('Retry-After', Math.ceil(rl.retryAfterMs / 1000));
+      return ctx.errorResponse(res, 429,
+        `Rate limit exceeded for /api/v1/ca/cert/* (${CA_CERT_RATE_LIMIT.max} req/${CA_CERT_RATE_LIMIT.windowMs/1000}s per IP). Retry in ${Math.ceil(rl.retryAfterMs / 1000)}s.`,
+        { code: 'DC-076_RATE_LIMITED', retryAfterMs: rl.retryAfterMs });
+    }
+    res.setHeader('X-RateLimit-Limit', String(CA_CERT_RATE_LIMIT.max));
+    res.setHeader('X-RateLimit-Remaining', String(rl.remaining));
+
+    if (!CA_CERT_DOMAINS_RE.test(domain)) {
+      return ctx.errorResponse(res, 400, `Invalid domain name. Must be a valid hostname (e.g., dns1${ctx.siteConfig.tld})`,
+        { code: 'DC-076_DOMAIN_INVALID' });
     }
 
     const pkiPath = platformPaths.pkiDir;
@@ -240,8 +329,9 @@ ${safeDomain.includes('.') ? `DNS.2 = *.${safeDomain}` : ''}`;
     }
   }, 'ca-cert'));
 
-  // List generated certificates
+  // List generated certificates (DC-076: TOTP-gated; previously public-listed)
   router.get('/certs', ctx.asyncHandler(async (req, res) => {
+    if (!requireCaCertAdminScope(req, res)) return;
     const certsDir = platformPaths.generatedCertsDir;
 
     if (!await exists(certsDir)) {

dashcaddy-api/routes/caddy-upstreams.js

@@ -4,7 +4,9 @@
  * Exposes:
  *   GET    /api/v1/caddy/upstreams                       — full snapshot
  *   GET    /api/v1/caddy/upstreams/incidents             — open dead-upstream incidents (via healthChecker)
- *   POST   /api/v1/caddy/upstreams/:host/mute            — body { muted: true|false }  (also via query ?muted=true)
+ *   POST   /api/v1/caddy/upstreams/mute                  — body { host, muted: true|false }
+ *   POST   /api/v1/caddy/upstreams/:host/mute            — body { muted: true|false } OR query ?muted=true
+ *   POST   /api/v1/caddy/upstreams/:host/unmute          — clears the mute
  *
  * Auth: same as the rest of /api/v1 — handled by the global middleware
  * (the router is mounted under the auth-gated apiRouter in app.js).
@@ -16,6 +18,48 @@ const express = require('express');
 const { success, errorResponse } = require('../src/utils/responses');
 const { ValidationError } = require('../src/utilities/errors');
 
+/**
+ * DC-073: shared mute helper — used by all three mute endpoints so the
+ * host-validation logic can't drift.
+ *
+ * Pre-fix, only the bare `/caddy/upstreams/mute` body-style endpoint
+ * rejected unknown hosts (with a "not a known upstream" 400). The
+ * path-style `/:host/mute` and `/:host/unmute` endpoints skipped that
+ * check entirely, so an authenticated operator could POST
+ * `/caddy/upstreams/phantom.test:12345/mute` and the watcher would
+ * silently add `phantom.test:12345` to its muted Set and `_saveState()`
+ * would persist it to disk. The phantom entry then survives container
+ * restarts, pollutes the snapshot view (the muted Set is iterated in
+ * places like the dashboard's "muted upstreams" badge), and would
+ * silently disable any future probe that happened to resolve to the
+ * same string.
+ *
+ * Post-fix, every mute path runs through this helper so:
+ *   (1) host format is well-formed (rejects injection / `:` / `?` / etc.)
+ *   (2) host is in `caddyUpstreamWatcher.upstreams` (the live registry
+ *       populated by `scanSites()` reading every `reverse_proxy` from
+ *       /etc/caddy/sites/*. A phantom host cannot reach setMuted.)
+ *   (3) the muted Set never holds entries the scanner doesn't know.
+ *
+ * @param {Object} watcher caddyUpstreamWatcher instance
+ * @param {string} host raw host string from the request
+ * @param {boolean} wantMuted true to mute, false to unmute
+ * @returns {{host: string, muted: boolean}} the result of setMuted
+ * @throws {ValidationError} on invalid format or unknown host
+ */
+function validateAndMuteHost(watcher, host, wantMuted) {
+  if (typeof host !== 'string' || host.length === 0 || host.length > 253) {
+    throw new ValidationError('host must be a non-empty string up to 253 chars');
+  }
+  if (!/^[a-z0-9._:-]+$/i.test(host)) {
+    throw new ValidationError('host must be a valid host[:port] string');
+  }
+  if (!watcher || !watcher.upstreams || !watcher.upstreams.has(host)) {
+    throw new ValidationError(`host ${host} is not a known upstream (run scan first)`);
+  }
+  return watcher.setMuted(host, wantMuted);
+}
+
 module.exports = function({ asyncHandler, caddyUpstreamWatcher, healthChecker }) {
   const router = express.Router();
 
@@ -55,62 +99,48 @@ module.exports = function({ asyncHandler, caddyUpstreamWatcher, healthChecker })
     success(res, { incidents: open });
   }, 'caddy-upstreams-incidents'));
 
-  // POST /caddy/upstreams/mute  body { host, muted }
-  // POST /caddy/upstreams/:host/mute  body { muted: true } OR query ?muted=true
-  // Both shapes supported because the dashboard code is small and either is
-  // ergonomic depending on caller.
-  const handleMute = asyncHandler(async (req, res) => {
-    if (!caddyUpstreamWatcher) {
-      return errorResponse(res, 503, 'Caddy upstream watcher not initialized');
-    }
-    const host = req.params.host || req.body?.host;
-    if (!host || typeof host !== 'string' || !/^[a-z0-9._:-]+$/i.test(host)) {
-      throw new ValidationError('host must be a valid host[:port] string');
-    }
-    // Accept muted as boolean body field OR ?muted=true|false query OR
-    // a { muted: true|false } JSON body. Default to toggling on bare POST
-    // without a muted value (this is the "mute it" path).
-    let muted;
-    if (typeof req.body?.muted === 'boolean') muted = req.body.muted;
-    else if (typeof req.query.muted === 'string') muted = req.query.muted === 'true';
-    else muted = true; // POST with no body = mute
-
-    const result = caddyUpstreamWatcher.setMuted(host, muted);
-    success(res, result);
-  }, 'caddy-upstreams-mute');
-
   // Bare /mute with JSON body {host, muted}. Default mutes when muted is
   // absent or unparseable; require muted === false explicitly to unmute.
+  // DC-073: now routes through validateAndMuteHost so the unknown-host
+  // check applies (was already correct here pre-fix, but path-style
+  // was missing it — see validateAndMuteHost docblock).
   router.post('/caddy/upstreams/mute', asyncHandler(async (req, res) => {
     if (!caddyUpstreamWatcher) {
       return errorResponse(res, 503, 'Caddy upstream watcher not initialized');
     }
     const { host, muted } = req.body || {};
-    if (!host || typeof host !== 'string' || !/^[a-z0-9._:-]+$/i.test(host)) {
-      throw new ValidationError('host must be a valid host[:port] string');
-    }
     // Explicit boolean coercion — string 'false' should NOT mute.
     const wantMuted = muted === undefined ? true : muted === true;
-    if (caddyUpstreamWatcher.upstreams && !caddyUpstreamWatcher.upstreams.has(host)) {
+    const result = validateAndMuteHost(caddyUpstreamWatcher, host, wantMuted);
-      throw new ValidationError(`host ${host} is not a known upstream (run scan first)`);
-    }
-    const result = caddyUpstreamWatcher.setMuted(host, wantMuted);
     success(res, result);
   }, 'caddy-upstreams-mute-bare'));
 
-  // /:host/mute and /:host/unmute for path-style toggles
+  // Path-style /:host/mute — body { muted: true|false } OR query ?muted=true|false.
-  router.post('/caddy/upstreams/:host/mute', handleMute);
+  // DC-073: now also rejects unknown hosts (was the bug — see docblock).
+  router.post('/caddy/upstreams/:host/mute', asyncHandler(async (req, res) => {
+    if (!caddyUpstreamWatcher) {
+      return errorResponse(res, 503, 'Caddy upstream watcher not initialized');
+    }
+    let wantMuted;
+    if (typeof req.body?.muted === 'boolean') wantMuted = req.body.muted;
+    else if (typeof req.query.muted === 'string') wantMuted = req.query.muted === 'true';
+    else wantMuted = true; // bare POST = mute
+    const result = validateAndMuteHost(caddyUpstreamWatcher, req.params.host, wantMuted);
+    success(res, result);
+  }, 'caddy-upstreams-mute'));
+
+  // DC-073: path-style /:host/unmute now also rejects unknown hosts.
   router.post('/caddy/upstreams/:host/unmute', asyncHandler(async (req, res) => {
     if (!caddyUpstreamWatcher) {
       return errorResponse(res, 503, 'Caddy upstream watcher not initialized');
     }
-    const host = req.params.host;
+    const result = validateAndMuteHost(caddyUpstreamWatcher, req.params.host, false);
-    if (!host || !/^[a-z0-9._:-]+$/i.test(host)) {
-      throw new ValidationError('host must be a valid host[:port] string');
-    }
-    const result = caddyUpstreamWatcher.setMuted(host, false);
     success(res, result);
   }, 'caddy-upstreams-unmute'));
 
   return router;
-};
+};
+
+// Export the helper for unit tests so the validation surface can be
+// exercised without spinning up a full Express app.
+module.exports.__test = { validateAndMuteHost };

dashcaddy-api/routes/caddycode.js

@@ -11,10 +11,138 @@
  */
 const express = require('express');
 const { ok, errorResponse } = require('../src/utils/responses');
+const { REGEX } = require('../src/utilities/constants');
+
+/**
+ * DC-070: Validate the structural config that flows into generateSiteBlock.
+ *
+ * Threat model: `generateSiteBlock` interpolates user-controlled fields
+ * (domain, tls, authService, headers.*, stripPrefix, upstream) DIRECTLY into
+ * a Caddyfile text block that is later fed to `caddy.modify()` and the
+ * Caddy admin /load endpoint. The /caddycode/generate endpoint is
+ * authenticated (forward_auth gated), but the bug class is "compromised
+ * middleware / pivot" — a JSON-only payload can be smuggled past any
+ * UI-side input checks.
+ *
+ * Pre-fix, every field was trusted: `lines.push(`${domain} {`)` accepted any
+ * string (including newlines that close the block and inject a new site),
+ * `headers[key] = "${value}"` accepted arbitrary quotes (which would break
+ * the surrounding `"..."` Caddy quoted-string context and inject directives),
+ * and `tls`, `authService`, `stripPrefix`, `upstream` had no charset
+ * restrictions at all (spaces, braces, semicolons would land verbatim).
+ *
+ * Post-fix: every field is constrained to a known-safe character class
+ * BEFORE interpolation, and CRLF is rejected outright. Quoted-string
+ * injection in header values is closed by escaping `\` and `"` per the
+ * Caddy quoted-string spec (backslash escapes the next character).
+ */
+function validateGenerationConfig(config) {
+  const errors = [];
+  const {
+    domain,
+    upstream,
+    upstreamProtocol = 'http',
+    tls = 'auto',
+    auth = false,
+    authService = null,
+    headers = {},
+    stripPrefix = null,
+  } = config;
+
+  // 1. domain — RFC 1123 hostname. Reject anything with whitespace, brace,
+  //    semicolon, newline, or non-printable. REGEX.DOMAIN is
+  //    /^[a-z0-9]([a-z0-9.-]{0,251}[a-z0-9])?$/i in constants.js.
+  if (typeof domain !== 'string' || !REGEX.DOMAIN.test(domain)) {
+    errors.push('domain must be a valid hostname (letters, digits, dots, hyphens)');
+  }
+
+  // 2. upstream — `host:port` form (the only shape Caddy's reverse_proxy
+  //    directive takes for non-URL upstreams). Reject `://`, whitespace,
+  //    braces. Allow optional IPv6 bracket form `[::1]:5000`. Must
+  //    include an explicit :port segment — a bare `localhost` would
+  //    produce a Caddyfile that fails to reload (port required for
+  //    reverse_proxy upstreams). Two regex branches: (a) bare host with
+  //    required :port, (b) bracketed IPv6 literal with required :port.
+  if (typeof upstream !== 'string'
+      || !/^[a-z0-9.\-]+:\d{1,5}$/i.test(upstream)
+      && !/^\[[a-z0-9.\-:.]+\]:\d{1,5}$/i.test(upstream)
+  ) {
+    errors.push('upstream must be host:port (host letters/digits/dots/hyphens, port 1-65535, optional IPv6 brackets)');
+  }
+
+  // 3. tls — either the literal strings 'auto' / 'internal' (handled
+  //    specially below) OR a CA name like 'letsencrypt' / 'internal' that
+  //    must match /^[a-z0-9._-]+$/i. Reject whitespace + braces + quotes.
+  if (typeof tls !== 'string' || !/^[a-z0-9._-]+$/i.test(tls)) {
+    errors.push('tls must be one of: auto, internal, or a CA name (letters, digits, dots, underscores, hyphens)');
+  }
+
+  // 4. authService — only meaningful when auth=true; otherwise ignore. Must
+  //    match the existing SSO service-id charset (REGEX.SUBDOMAIN).
+  if (auth) {
+    if (typeof authService !== 'string' || !REGEX.SUBDOMAIN.test(authService)) {
+      errors.push('authService must be a valid subdomain (lowercase, alphanumeric, hyphens)');
+    }
+  }
+
+  // 5. upstreamProtocol — only 'http' or 'https'. Anything else gets coerced
+  //    to 'http' but only after we explicitly accept it; reject obvious
+  //    injection vectors here.
+  if (upstreamProtocol !== 'http' && upstreamProtocol !== 'https') {
+    errors.push('upstreamProtocol must be "http" or "https"');
+  }
+
+  // 6. headers — each key must be a valid HTTP header name ([A-Za-z0-9-]+),
+  //    each value must be a string with no CR/LF and no unescaped quotes.
+  if (headers && typeof headers === 'object') {
+    for (const [key, value] of Object.entries(headers)) {
+      if (typeof key !== 'string' || !/^[A-Za-z0-9-]+$/.test(key)) {
+        errors.push(`header key "${String(key)}" must be HTTP-token chars only ([A-Za-z0-9-])`);
+      }
+      if (typeof value !== 'string') {
+        errors.push(`header "${key}" value must be a string`);
+        continue;
+      }
+      if (/[\r\n]/.test(value)) {
+        errors.push(`header "${key}" value must not contain CR or LF`);
+      }
+    }
+  }
+
+  // 7. stripPrefix — must be a leading-slash path with safe chars. Reject
+  //    braces, quotes, whitespace, and { } which would let the attacker
+  //    open a new Caddyfile block.
+  if (stripPrefix != null) {
+    if (typeof stripPrefix !== 'string' || !/^\/[A-Za-z0-9._\-/]*$/.test(stripPrefix)) {
+      errors.push('stripPrefix must be an absolute path (letters, digits, dots, hyphens, slashes)');
+    }
+  }
+
+  return { valid: errors.length === 0, errors };
+}
+
+/**
+ * Escape a string for safe interpolation inside a Caddyfile quoted-string
+ * context. Caddy uses the same backslash-escape semantics as JSON-ish
+ * contexts — `\` and `"` MUST be escaped, otherwise the attacker breaks out
+ * of the quoted string and injects arbitrary directives.
+ *
+ * @param {string} s raw header value
+ * @returns {string} escaped value (no embedded newlines; CR/LF were already
+ *   rejected by the validator)
+ */
+function escapeCaddyQuotedString(s) {
+  return String(s).replace(/\\/g, '\\\\').replace(/"/g, '\\"');
+}
 
 /**
  * Generate a Caddyfile site block from a structured config.
- * @param {Object} config - Site configuration
+ *
+ * Every interpolated field is now validated by `validateGenerationConfig`
+ * first (see DC-070). Quoted-string values are escaped via
+ * `escapeCaddyQuotedString` so a `"` in a header value cannot break out.
+ *
+ * @param {Object} config - Site configuration (already validated)
  * @returns {string} Caddyfile snippet
  */
 function generateSiteBlock(config) {
@@ -38,12 +166,15 @@ function generateSiteBlock(config) {
   const lines = [];
   lines.push(`${domain} {`);
 
-  // TLS
+  // TLS — only emit a tls directive when explicitly 'internal' or a CA
+  // name; 'auto' means Caddy's default behaviour (no directive needed).
   if (tls === 'internal') {
     lines.push(`  tls internal`);
   } else if (tls === 'auto') {
     // Default — Caddy auto-provisions Let's Encrypt
-  } else if (typeof tls === 'string') {
+  } else {
+    // CA name validated by validateGenerationConfig against
+    // /^[a-z0-9._-]+$/i — safe to interpolate verbatim.
     lines.push(`  tls ${tls}`);
   }
 
@@ -52,7 +183,8 @@ function generateSiteBlock(config) {
     lines.push(`  # Redirect HTTP to HTTPS is automatic in Caddy 2`);
   }
 
-  // Auth gate (DashCaddy forward_auth)
+  // Auth gate (DashCaddy forward_auth) — authService validated by
+  // validateGenerationConfig against REGEX.SUBDOMAIN — safe to interpolate.
   if (auth && authService) {
     lines.push(`  import dashcaddy_auth ${authService}`);
   }
@@ -66,16 +198,17 @@ function generateSiteBlock(config) {
     lines.push(`  }`);
   }
 
-  // Custom headers
+  // Custom headers — keys validated against /^[A-Za-z0-9-]+$/, values
-  if (Object.keys(headers).length > 0) {
+  // escaped via escapeCaddyQuotedString before being placed inside "..."
+  if (headers && typeof headers === 'object' && Object.keys(headers).length > 0) {
     lines.push(`  header {`);
     for (const [key, value] of Object.entries(headers)) {
-      lines.push(`    ${key} "${value}"`);
+      lines.push(`    ${key} "${escapeCaddyQuotedString(value)}"`);
     }
     lines.push(`  }`);
   }
 
-  // Strip prefix
+  // Strip prefix — validated to /^\/[A-Za-z0-9._\-/]*$/ — safe.
   if (stripPrefix) {
     lines.push(`  uri strip_prefix ${stripPrefix}`);
   }
@@ -118,6 +251,19 @@ module.exports = function({ asyncHandler }) {
       return errorResponse(res, 400, 'upstream is required (e.g. localhost:8080)');
     }
 
+    // DC-070: structural validation BEFORE interpolation. Every field that
+    // flows into the Caddyfile text must satisfy a known-safe charset rule,
+    // and CRLF is rejected outright. Run this BEFORE generateSiteBlock so
+    // the bad input is rejected with a clean 400 + enumerable error list,
+    // not a generated-Caddyfile + 500.
+    const validation = validateGenerationConfig(config);
+    if (!validation.valid) {
+      return errorResponse(res, 400, 'Invalid configuration', {
+        code: 'DC-CCD-700',
+        errors: validation.errors,
+      });
+    }
+
     try {
       const caddyfile = generateSiteBlock(config);
       ok(res, { caddyfile, config });
@@ -225,3 +371,11 @@ module.exports = function({ asyncHandler }) {
 
   return router;
 };
+
+// DC-070: export helpers for unit-testing the sanitization surface
+// independently of the route handler.
+module.exports.__test = {
+  validateGenerationConfig,
+  escapeCaddyQuotedString,
+  generateSiteBlock,
+};

dashcaddy-api/routes/disaster-recovery.js

@@ -37,6 +37,81 @@ const BACKUP_FILES = [
 
 const ASSET_FILES = ['custom-logo.png', 'custom-favicon.png', 'custom-logo.svg'];
 
+// DC-079: Restrict restored assets to the hardcoded ASSET_FILES allowlist.
+// The asset KEYS in the snapshot are user-controlled JSON, so iterating
+// `Object.entries(snapshot.assets)` and writing each name verbatim into
+// `path.join(assetsDir, name)` lets an attacker POST `{assets: {"../../etc/caddy/Caddyfile":
+// "<base64-evil>"}}` and overwrite the live Caddyfile via the bind-mount
+// (path.join('/app/data/assets', '../../etc/caddy/Caddyfile') resolves
+// to /etc/caddy/Caddyfile). This bypasses the caddyfile-staging gate
+// above because the dataDir bind-mount can write to /etc/caddy on the host.
+const ASSET_KEY_RE = /^[a-zA-Z0-9._-]+$/;
+const ASSET_PATH_TRAVERSAL_RE = /(^|\/)\.\.($|\/)|^\//;
+
+// DC-079: Caddyfile content safety limits for disaster-recovery restore.
+// The live Caddyfile on DNS2 is ~17 KB and grows linearly with vhost count.
+// Express's default JSON body parser limit (1 MB) is the outer gate; this
+// in-handler cap is defense-in-depth against either a future body-limit
+// raise or a custom body parser. Cap well below the body-parser ceiling.
+const MAX_CADDYFILE_BYTES = 512 * 1024; // 512 KiB — 30x the live file, far below 1 MB body limit
+
+// DC-079: theme filenames must match this pattern. No slashes (no path
+// traversal), no `..`, must end in `.json`, and only filename-safe chars.
+// Themes are written to <dataDir>/themes/<name>; we also defense-in-depth
+// check the resolved path stays inside that dir.
+const THEME_NAME_RE = /^[a-zA-Z0-9._-]+\.json$/;
+
+function assertSafeAssetKey(key) {
+  if (typeof key !== 'string' || key.length === 0 || key.length > 128) {
+    throw new Error(`asset key must be a non-empty string up to 128 chars`);
+  }
+  if (ASSET_PATH_TRAVERSAL_RE.test(key) || !ASSET_KEY_RE.test(key)) {
+    throw new Error(`asset key contains forbidden characters or path segments`);
+  }
+}
+
+function assertSafeThemeName(name) {
+  if (typeof name !== 'string' || name.length === 0 || name.length > 128) {
+    throw new Error(`theme name must be a non-empty string up to 128 chars`);
+  }
+  if (!THEME_NAME_RE.test(name)) {
+    throw new Error(`theme name must match ${THEME_NAME_RE} (alphanum / dot / dash / underscore, ending in .json)`);
+  }
+}
+
+// Reject Caddyfile content that smuggles in arbitrary `import` directives.
+// caddy-apply expects the single top-level Caddyfile; any `import` to an
+// absolute path means "load another file from disk at Caddy reload time" —
+// that's a classic injection vector (an attacker can craft a snapshot whose
+// `import /etc/caddy/external.caddy` reads any file Caddy can read).
+// We allow the relative-style `import <snippet>` form ONLY if the snippet
+// name matches a small allowlist of well-known Caddy snippet names (none
+// today; add explicit names if a future snippet module is needed).
+const FORBIDDEN_IMPORT_RE = /^\s*import\s+(["']|\/|\.\.|~\/|%[A-F0-9]{2})/im;
+
+function validateCaddyfileContent(content) {
+  if (typeof content !== 'string') {
+    return { ok: false, error: 'Caddyfile content must be a string' };
+  }
+  if (content.length === 0) {
+    return { ok: false, error: 'Caddyfile content is empty' };
+  }
+  if (Buffer.byteLength(content, 'utf8') > MAX_CADDYFILE_BYTES) {
+    return { ok: false, error: `Caddyfile content exceeds ${MAX_CADDYFILE_BYTES} bytes` };
+  }
+  if (FORBIDDEN_IMPORT_RE.test(content)) {
+    // Allow the canonical single-quoted snippet import form ONLY if the
+    // snippet name is on the explicit allowlist (currently empty). This
+    // catches absolute paths, ../, ~/, and URL-encoded payloads while
+    // leaving room for future snippet additions without touching this gate.
+    return {
+      ok: false,
+      error: 'Caddyfile contains forbidden `import` directive (absolute path, encoded, or non-allowlisted snippet)'
+    };
+  }
+  return { ok: true };
+}
+
 module.exports = function({ servicesStateManager, platformPaths, log, asyncHandler }) {
   const wrap = asyncHandler || ((fn) => (req, res, next) => Promise.resolve(fn(req, res, next)).catch(next));
   const router = express.Router();
@@ -44,6 +119,15 @@ module.exports = function({ servicesStateManager, platformPaths, log, asyncHandl
   let lastBackupStatus = { timestamp: null, status: null, size: null };
   let lastRestoreStatus = { timestamp: null, status: null };
 
+  // DC-079: Staging dir for the candidate Caddyfile. The disaster-recovery
+  // restore endpoint stages here instead of writing directly to the live
+  // Caddyfile path. The operator must run `caddy-apply` (or its equivalent)
+  // to validate + reload + git-commit the staged file. This keeps the live
+  // Caddyfile under the same atomic-commit guard as every other edit.
+  function getStagedCaddyfileDir(dataDir) {
+    return path.join(dataDir, 'disaster-staged');
+  }
+
   /**
    * POST /api/v1/disaster/backup
    * Creates a complete system snapshot as a downloadable JSON file.
@@ -175,13 +259,64 @@ module.exports = function({ servicesStateManager, platformPaths, log, asyncHandl
       }
     }
 
-    // Restore Caddyfile
+    // DC-079: Stage the Caddyfile to a staging path inside dataDir
-    if (snapshot.caddyfile) {
+    // instead of writing directly to caddyfilePath (which is the LIVE
+    // /etc/caddy/Caddyfile bind-mounted into the container as /caddyfile).
+    //
+    // Threat model (defense-in-depth, mirrors DC-070 / DC-074 / DC-076):
+    // the endpoint is TOTP-gated, but a compromised operator / phished
+    // session / pivot path could POST a snapshot with `caddyfile: <evil>`
+    // and the pre-fix code would call `fsp.writeFile(caddyfilePath, ...)`
+    // which writes the attacker-controlled string straight to the live
+    // Caddyfile. Caddy then reads that file on the next reload (which can
+    // be triggered by ACME renewals, health probes, or any admin API
+    // touch), executing whatever directives the attacker embedded:
+    //   - `admin off` + arbitrary config write
+    //   - `import /etc/caddy/<anything-caddy-can-read>` for content theft
+    //   - `reverse_proxy` to attacker-controlled upstreams
+    //   - `acme_ca` override to attacker CA
+    //   - `log` directives to attacker-writable paths
+    //
+    // The Caddyfile is managed by the `caddy-apply` wrapper (validates +
+    // reloads + git-commits atomically — see CLAUDE.md hard rule). This
+    // endpoint previously bypassed that wrapper. The fix stages the
+    // candidate file under dataDir/disaster-staged/Caddyfile.candidate and
+    // returns the path so the operator can apply it via the normal flow.
+    const caddyfileStaged = [];
+    // DC-079: handle three cases for the caddyfile field:
+    //   - absent/null/undefined: back-compat — no Caddyfile in snapshot
+    //   - empty string "": explicit empty payload is suspicious — reject
+    //   - non-string (object/array/number): type confusion attempt — reject
+    //   - valid string: stage to dataDir/disaster-staged/Caddyfile.candidate
+    if (snapshot.caddyfile !== undefined && snapshot.caddyfile !== null) {
+      const validation = validateCaddyfileContent(snapshot.caddyfile);
+      if (!validation.ok) {
+        return errorResponse(res, 400, `Invalid Caddyfile in snapshot: ${validation.error}`, {
+          code: ErrorCodes.BACKUP.INVALID_CONFIG,
+        });
+      }
+
+      const stagedDir = getStagedCaddyfileDir(dataDir);
       try {
-        await fsp.writeFile(caddyfilePath, snapshot.caddyfile);
+        await fsp.mkdir(stagedDir, { recursive: true });
-        restored.push('Caddyfile');
+        const stagedPath = path.join(stagedDir, 'Caddyfile.candidate');
+        // Atomic write: write to .candidate.tmp then rename. The live
+        // Caddyfile is NEVER touched from this endpoint.
+        const tmpPath = stagedPath + '.tmp';
+        await fsp.writeFile(tmpPath, snapshot.caddyfile, { mode: 0o644 });
+        await fsp.rename(tmpPath, stagedPath);
+        caddyfileStaged.push({
+          file: 'Caddyfile',
+          stagedPath,
+          action: 'awaiting caddy-apply',
+          livePath: caddyfilePath,
+        });
+        if (log) log.info('disaster-recovery', 'Caddyfile staged (not applied)', {
+          stagedPath,
+          size: Buffer.byteLength(snapshot.caddyfile, 'utf8'),
+        });
       } catch (err) {
-        errors.push({ file: 'Caddyfile', error: err.message });
+        errors.push({ file: 'Caddyfile (staging)', error: err.message });
       }
     }
 
@@ -189,8 +324,20 @@ module.exports = function({ servicesStateManager, platformPaths, log, asyncHandl
     const assetsDir = platformPaths?.resolveAssetsPath?.() || path.join(dataDir, 'assets');
     for (const [name, base64] of Object.entries(snapshot.assets || {})) {
       try {
+        // DC-079: assets directory is the first attack surface that
+        // bypasses the Caddyfile-staging gate. `name` is a user-supplied
+        // JSON key; without validation, `path.join(assetsDir, name)` lets
+        // an attacker escape to /etc/caddy via path traversal.
+        assertSafeAssetKey(name);
+        const resolved = path.resolve(assetsDir, name);
+        // Defense-in-depth: even after charset checks, the resolved path
+        // MUST stay inside assetsDir. If it doesn't, refuse the write.
+        if (!resolved.startsWith(path.resolve(assetsDir) + path.sep) &&
+            resolved !== path.resolve(assetsDir)) {
+          throw new Error(`asset path resolves outside assets directory`);
+        }
         await fsp.mkdir(assetsDir, { recursive: true });
-        await fsp.writeFile(path.join(assetsDir, name), Buffer.from(base64, 'base64'));
+        await fsp.writeFile(resolved, Buffer.from(base64, 'base64'));
         restored.push(`assets/${name}`);
       } catch (err) {
         errors.push({ file: `assets/${name}`, error: err.message });
@@ -203,8 +350,21 @@ module.exports = function({ servicesStateManager, platformPaths, log, asyncHandl
       try {
         await fsp.mkdir(themesDir, { recursive: true });
         for (const [name, content] of Object.entries(snapshot.themes)) {
-          await fsp.writeFile(path.join(themesDir, name), JSON.stringify(content, null, 2));
+          // DC-079: same path-traversal vector as assets — keys are
-          restored.push(`themes/${name}`);
+          // user-controlled JSON. Validate the name AND confirm the
+          // resolved path stays inside themesDir.
+          try {
+            assertSafeThemeName(name);
+            const resolved = path.resolve(themesDir, name);
+            if (!resolved.startsWith(path.resolve(themesDir) + path.sep) &&
+                resolved !== path.resolve(themesDir)) {
+              throw new Error(`theme path resolves outside themes directory`);
+            }
+            await fsp.writeFile(resolved, JSON.stringify(content, null, 2));
+            restored.push(`themes/${name}`);
+          } catch (err) {
+            errors.push({ file: `themes/${name}`, error: err.message });
+          }
         }
       } catch (err) {
         errors.push({ file: 'themes', error: err.message });
@@ -215,19 +375,33 @@ module.exports = function({ servicesStateManager, platformPaths, log, asyncHandl
       timestamp: new Date().toISOString(),
       status: errors.length === 0 ? 'success' : 'partial',
       restored: restored.length,
+      staged: caddyfileStaged.length,
       errors: errors.length,
     };
 
     if (log) log.info('disaster-recovery', 'Restore completed', lastRestoreStatus);
 
-    ok(res, {
+    // DC-079: Surface the staged-Caddyfile warning in the response body so
+    // the UI / operator can see that the Caddyfile is NOT yet live. The
+    // restore endpoint stages under dataDir/disaster-staged/Caddyfile.candidate
+    // and the operator must run `caddy-apply` (or its equivalent) to
+    // validate + reload + git-commit the staged file. The live Caddyfile
+    // is owned by the caddy-apply wrapper per CLAUDE.md hard rule.
+    const responseBody = {
       status: errors.length === 0 ? 'success' : 'partial',
       restored,
       errors,
       message: errors.length === 0
-        ? `Successfully restored ${restored.length} files. Restart DashCaddy to apply.`
+        ? `Successfully restored ${restored.length} files${caddyfileStaged.length > 0 ? ` (Caddyfile staged — ${caddyfileStaged[0].stagedPath}; run caddy-apply to apply)` : ''}. Restart DashCaddy to apply.`
         : `Restored ${restored.length} files with ${errors.length} errors. Check error details.`,
-    });
+    };
+
+    if (caddyfileStaged.length > 0) {
+      responseBody.caddyfileStaged = caddyfileStaged;
+      responseBody.warning = '[DC-079] Caddyfile is STAGED, not applied. Live /etc/caddy/Caddyfile was NOT modified by this restore. Run `caddy-apply <reason>` (or equivalent) to validate + reload + git-commit the staged candidate.';
+    }
+
+    ok(res, responseBody);
   }));
 
   /**

dashcaddy-api/routes/exec.js

@@ -4,6 +4,50 @@ const url = require('url');
 
 const docker = new Docker();
 
+/**
+ * DC-072: WebSocket scope authorization — admin-only by default.
+ *
+ * Container exec is full root-equivalent access inside the target
+ * container. Granting it to a key whose scope is `['read']` violates
+ * least privilege. The validScopes list (`['read','write','admin']`)
+ * is defined in routes/auth/keys.js; exec requires `admin`.
+ *
+ * Defensive: the scope field is coerced via `Array.isArray(...) ? ... : []`
+ * so a malformed payload (string, object, null, undefined) cannot reach
+ * `.includes('admin')` and accidentally grant access. Every malformed
+ * shape falls into the rejection branch with the same 403 envelope.
+ *
+ * Tests should call `__test.assertExecScope(auth)` directly rather
+ * than spinning up a WebSocket server.
+ */
+function assertExecScope(auth) {
+  const scope = Array.isArray(auth && auth.scope) ? auth.scope : [];
+  if (!scope.includes('admin')) {
+    const err = new Error('Container exec requires admin scope');
+    err.code = 'DC-072_INSUFFICIENT_SCOPE';
+    err.statusCode = 403;
+    err.requiredScope = 'admin';
+    err.actualScope = scope;
+    throw err;
+  }
+}
+
+/**
+ * DC-072: Tighten containerId validation.
+ *
+ * Docker container IDs are exactly 64 lowercase hex chars (or 12-char
+ * short form). The pre-fix regex accepted `_`, `-`, `.`, mixed case,
+ * and up to 128 chars — Docker would then 404 the inspect call and
+ * the rejection would surface as a generic 500 in the WS error
+ * envelope. Pre-validate at the upgrade layer so the rejection is
+ * fast and the log line discriminates "malformed" from "unknown".
+ */
+function isValidContainerId(id) {
+  if (typeof id !== 'string') return false;
+  // Full 64-char hex, or 12-char short hex
+  return /^[0-9a-f]{64}$/.test(id) || /^[0-9a-f]{12}$/.test(id);
+}
+
 /**
  * Attach WebSocket server for container exec/shell
  * Route: ws://host/ws/exec/:containerId
@@ -21,8 +65,8 @@ module.exports = function attachExecWS(server, log, authManager) {
 
     const containerId = decodeURIComponent(match[1]);
 
-    // Validate container ID format to prevent injection
+    // DC-072: Tighten containerId charset (64-char / 12-char lowercase hex)
-    if (!/^[a-zA-Z0-9][a-zA-Z0-9_.-]{0,127}$/.test(containerId)) {
+    if (!isValidContainerId(containerId)) {
       log.warn('exec', 'Invalid container ID in WebSocket path', { containerId });
       socket.write('HTTP/1.1 400 Bad Request\r\n\r\n');
       socket.destroy();
@@ -55,6 +99,35 @@ module.exports = function attachExecWS(server, log, authManager) {
       return;
     }
 
+    // DC-072: Container exec is root-equivalent — require admin scope.
+    // Pre-fix, a key issued with scope `['read']` (e.g., for monitoring)
+    // would get a full PTY shell inside any running container. The
+    // `auth.scope` was captured at lines 39/46 but never checked.
+    try {
+      assertExecScope(auth);
+    } catch (err) {
+      log.warn('exec', 'Insufficient scope for exec attempt', {
+        containerId,
+        authType: auth.type,
+        authId: auth.type === 'jwt' ? auth.userId : auth.keyId,
+        actualScope: err.actualScope,
+        requiredScope: err.requiredScope,
+        ip: req.socket.remoteAddress,
+      });
+      // 403 with a JSON error envelope over the upgrade socket so the
+      // dashboard can display "admin required" instead of guessing.
+      socket.write('HTTP/1.1 403 Forbidden\r\n');
+      socket.write('Content-Type: application/json\r\n');
+      socket.write('\r\n');
+      socket.end(JSON.stringify({
+        error: err.message,
+        code: err.code,
+        requiredScope: err.requiredScope,
+        actualScope: err.actualScope,
+      }));
+      return;
+    }
+
     // Auth passed — proceed with WebSocket upgrade
     wss.handleUpgrade(req, socket, head, (ws) => {
       handleExec(ws, containerId, log, auth);
@@ -67,6 +140,7 @@ module.exports = function attachExecWS(server, log, authManager) {
 async function handleExec(ws, containerId, log, auth) {
   let execStream = null;
   let execInstance = null;
+  const sessionStart = Date.now();
 
   try {
     const container = docker.getContainer(containerId);
@@ -78,10 +152,13 @@ async function handleExec(ws, containerId, log, auth) {
       return;
     }
 
+    // DC-072: Audit-log the exec session start. Pairs with the end-log
+    // below so the operator can correlate who opened which shell.
     log.info('exec', 'Authenticated exec session started', {
       containerId,
       authType: auth.type,
-      authId: auth.type === 'jwt' ? auth.userId : auth.keyId
+      authId: auth.type === 'jwt' ? auth.userId : auth.keyId,
+      containerName: info.Name,
     });
 
     // Detect available shell
@@ -120,7 +197,28 @@ async function handleExec(ws, containerId, log, auth) {
       }
     });
 
+    // DC-072: Track whether the end-log has fired so we don't double-log
+    // when both execStream 'end' and ws 'close' fire (Docker stream end
+    // closes the WS, which then fires 'close' too — without the flag
+    // we'd emit the same audit line twice with the same durationMs).
+    let ended = false;
+    const logSessionEnd = (reason) => {
+      if (ended) return;
+      ended = true;
+      log.info('exec', 'Exec session ended', {
+        containerId,
+        authType: auth.type,
+        authId: auth.type === 'jwt' ? auth.userId : auth.keyId,
+        durationMs: Date.now() - sessionStart,
+        reason,
+      });
+    };
+
     execStream.on('end', () => {
+      // DC-072: Audit-log the session end (duration + container) so a
+      // long-running session is observable in the error log. Normal
+      // shutdown path: Docker exec stream closes → log + tell client.
+      logSessionEnd('exec-stream-end');
       if (ws.readyState === ws.OPEN) {
         ws.send(JSON.stringify({ type: 'exit' }));
         ws.close();
@@ -148,6 +246,11 @@ async function handleExec(ws, containerId, log, auth) {
     });
 
     ws.on('close', () => {
+      // DC-072: Fallback audit-log for abnormal close (browser tab
+      // closed, network drop, container killed mid-session) where the
+      // execStream 'end' event never fires. The ended-flag guard makes
+      // this idempotent with the normal path above.
+      logSessionEnd('ws-close');
       if (execStream) {
         try { execStream.destroy(); } catch (_) {
           // Ignore stream teardown errors on socket close
@@ -172,3 +275,11 @@ async function handleExec(ws, containerId, log, auth) {
     }
   }
 }
+
+// Internal-only export for unit tests. Stripped from the public
+// surface; tests import this via the destructure form
+// `const { __test } = require('./routes/exec')`.
+module.exports.__test = {
+  assertExecScope,
+  isValidContainerId,
+};

dashcaddy-api/routes/sites.js

@@ -4,6 +4,9 @@ const { CADDY, REGEX, LIMITS } = require('../src/utilities/constants');
 const { ValidationError, ConflictError, NotFoundError } = require('../src/utilities/errors');
 const { validateURL } = require('../src/security/input-validator');
 const { ok, successMessage } = require('../src/utils/responses');
+// DC-074: SSRF defense — reject upstream hosts that resolve to
+// private/reserved ranges before they reach the Caddyfile.
+const { validateUpstream } = require('../src/utilities/fleet-validation');
 
 /**
  * Sites route factory
@@ -166,8 +169,25 @@ module.exports = function({ asyncHandler, ok, caddy, dns, fetchT, buildDomain, a
     if (!domain || !upstream) throw new ValidationError('Domain and upstream are required');
     if (!REGEX.DOMAIN.test(domain)) throw new ValidationError('[DC-301] Invalid domain format');
 
-    const upstreamRegex = /^[a-z0-9.-]+:\d{1,5}$/i;
+    // DC-074: SSRF defense — reject upstreams that resolve to private/
-    if (!upstreamRegex.test(upstream)) throw new ValidationError('Invalid upstream format. Use host:port');
+    // reserved ranges BEFORE we write them into the Caddyfile. Without
+    // this, an authenticated dashboard operator can call POST /api/v1/site
+    // with `upstream: '10.0.0.1:80'` and end up with a Caddy site block
+    // that proxies public traffic to an internal host. Caddy runs on
+    // DNS2 (same network as the targets), so the SSRF lands.
+    //
+    // The existing upstreamRegex /^[a-z0-9.-]+:\d{1,5}$/i only checks
+    // charset — it happily accepts 192.168.1.1:80 and 169.254.169.254:80
+    // (the AWS metadata IP). validateUpstream() also does a DNS lookup
+    // for hostnames so a malicious operator can't sneak a public-looking
+    // domain past the gate and have it resolve to a private IP later.
+    const upstreamCheck = await validateUpstream(upstream);
+    if (!upstreamCheck.ok) {
+      // Don't echo attacker-supplied hostnames in the audit log; keep the
+      // canonical code + message but never write the raw value.
+      log?.warn?.('site', 'POST /site rejected by SSRF gate', { code: upstreamCheck.code });
+      throw new ValidationError(`[DC-074] ${upstreamCheck.message} (set SITES_ALLOW_PRIVATE_UPSTREAMS=true to opt in)`);
+    }
 
     const content = await caddy.read();
     const escapedDomain = domain.replace(/[.*+?^${}()|[\]\\]/g, '\\$&');
@@ -199,12 +219,40 @@ module.exports = function({ asyncHandler, ok, caddy, dns, fetchT, buildDomain, a
       throw new ValidationError('[DC-301] Invalid subdomain format');
     }
 
+    // DC-074: SSRF defense — validate the URL syntax via validateURL() (catches
+    // non-http(s) schemes, malformed URLs) AND validateUpstream() (catches
+    // every private/reserved range including CGNAT, multicast, TEST-NET
+    // ranges that validateURL's isPrivateIP() regex misses).
+    //
+    // We intentionally do NOT pass `blockPrivate: true` to validateURL()
+    // here — that's handled by validateUpstream() below, which honors the
+    // SITES_ALLOW_PRIVATE_UPSTREAMS opt-in. validateURL's blockPrivate path
+    // is a hard reject with no escape hatch, which would force operators
+    // who intentionally proxy to a private target to remove validation
+    // entirely.
     try {
       validateURL(externalUrl);
     } catch (validationErr) {
       throw new ValidationError(validationErr.message);
     }
 
+    // DC-074: validateUpstream() does the same rigorous private-IP check
+    // fleet-validation shipped for DC-068, with full CGNAT / multicast /
+    // broadcast / 0.0.0.0 / TEST-NET / benchmark range coverage and a DNS
+    // resolution step for hostnames (rebinding defense).
+    let parsedExternalUrl;
+    try {
+      parsedExternalUrl = new URL(externalUrl);
+    } catch (_) {
+      // validateURL() above already gates URL syntax — unreachable.
+      throw new ValidationError('Invalid external URL');
+    }
+    const externalCheck = await validateUpstream(`${parsedExternalUrl.hostname}:${parsedExternalUrl.port || (parsedExternalUrl.protocol === 'https:' ? '443' : '80')}`);
+    if (!externalCheck.ok) {
+      log?.warn?.('site', 'POST /site/external rejected by SSRF gate', { code: externalCheck.code });
+      throw new ValidationError(`[DC-074] ${externalCheck.message} (set SITES_ALLOW_PRIVATE_UPSTREAMS=true to opt in)`);
+    }
+
     const domain = buildDomain(subdomain);
     let dnsWarning = null;
 

dashcaddy-api/src/config/paths.js

@@ -31,6 +31,17 @@ module.exports = {
   CADDY_ADMIN_URL,
   SERVICES_FILE,
   SERVICES_DIR,
+  // Re-export the resolved data directory so other modules (notably
+  // src/utilities/nesting-guard.js) can locate `/app/data` without having to
+  // also require('../../platform-paths') — keeps a single source of truth for
+  // the data dir on the src/config/paths surface. Without this, `dataDir`
+  // resolves to `undefined`, and `path.join(undefined, 'data')` throws
+  // `TypeError [ERR_INVALID_ARG_TYPE]: The "path" argument must be of type
+  // string. Received undefined` at startup (DC-077 fingerprint). Fall back to
+  // platformPaths.dataDir if SERVICES_DIR is somehow not a string (defensive —
+  // SERVICES_DIR is computed from a path.dirname() of a string so it always
+  // is, but the cost of guarding is one branch).
+  dataDir: typeof SERVICES_DIR === 'string' && SERVICES_DIR ? SERVICES_DIR : platformPaths.dataDir,
   CONFIG_FILE,
   DNS_CREDENTIALS_FILE,
   TAILSCALE_CONFIG_FILE,

dashcaddy-api/src/managers/update-manager.js

@@ -18,6 +18,30 @@ const UPDATE_CONFIG_FILE = process.env.UPDATE_CONFIG_FILE || path.join(platformP
 const UPDATE_HISTORY_FILE = process.env.UPDATE_HISTORY_FILE || path.join(platformPaths.dataDir, 'update-history.json');
 const CHECK_INTERVAL = parseInt(process.env.UPDATE_CHECK_INTERVAL || '3600000', 10); // 1 hour
 
+// DC-078: registry probe reliability knobs. The container's /etc/resolv.conf points
+// at Technitium (100.121.150.22) which sometimes returns a mix of A and AAAA
+// records even when the host's IPv6 path to public registries (Docker Hub,
+// ghcr.io) is broken or slow. Without `family: 4` Node defaults to dual-stack,
+// every `https.request` to a registry races dual-stack DNS and stalls 30+ seconds
+// per ENETUNREACH on the unreachable family. Without an explicit request timeout
+// the entire `checkForUpdates()` loop (5+ containers) blocks for minutes per
+// tick — visible in error.log as AggregateError [ETIMEDOUT] with a stack like
+// `at internalConnectMultiple (node:net:1114:18)`.
+//
+// TUNABLES — keep conservative; the digest check is a background poll, not
+// user-facing. Worst-case latency per query:
+//   1st attempt:  REGISTRY_REQUEST_TIMEOUT_MS   (10s)
+//   1st retry  :  REGISTRY_RETRY_BACKOFF_MS + REGISTRY_REQUEST_TIMEOUT_MS (10.5s)
+//   ─────────────────────────────────────────────────────────────────────
+//   per-container ceiling: 20.5s   (REGISTRY_MAX_RETRIES=1)
+const REGISTRY_REQUEST_TIMEOUT_MS = 10000;     // hard per-request socket timeout
+const REGISTRY_MAX_RETRIES = 1;               // extra attempts after first failure
+const REGISTRY_RETRY_BACKOFF_MS = 500;        // delay before retry (transient blips)
+const REGISTRY_TRANSIENT_ERROR_CODES = new Set([
+  'ETIMEDOUT', 'ENOTFOUND', 'ENETUNREACH', 'ECONNRESET', 'EAI_AGAIN',
+  'EPIPE', 'ECONNREFUSED', 'EHOSTUNREACH',
+]);
+
 class UpdateManager extends EventEmitter {
   constructor() {
     super();
@@ -181,87 +205,208 @@ class UpdateManager extends EventEmitter {
    * Get image digest from GitHub Container Registry (ghcr.io)
    * Public images are tokenless via the registry-1.docker.io-style bearer flow,
    * but using ghcr.io's own auth endpoint.
+   *
+   * DC-078: hardened — `family: 4` to avoid the dual-stack DNS race when the
+   * host's IPv6 path is unreachable (was producing AggregateError [ETIMEDOUT] in
+   * error.log every check cycle). Hard request timeout caps each attempt.
    */
   async getGhcrDigest(repository, tag) {
     // ghcr.io uses the same OCI distribution spec as Docker Hub
     const imageRepo = repository.replace(/^ghcr\.io\//, '');
+    const res = await this.fetchWithReliability({
+      hostname: 'ghcr.io',
+      path: `/v2/${imageRepo}/manifests/${tag}`,
+      headers: {
+        'Accept': 'application/vnd.docker.distribution.manifest.v2+json,application/vnd.docker.distribution.manifest.list.v2+json,application/vnd.oci.image.manifest.v1+json,application/vnd.oci.image.index.v1+json'
+      },
+    });
+    return res.headers['docker-content-digest'] || null;
+  }
+
+  /**
+   * Get image digest from Docker Hub
+   *
+   * DC-078: hardened — see getGhcrDigest comment. Resolves a 401 → token via
+   * `fetchAuthToken`, which itself is wrapped in the same retry + IPv4-only +
+   * timeout policy via `fetchWithReliability`.
+   */
+  async getDockerHubDigest(repository, tag) {
+    // Normalize repository name
+    const repo = repository.includes('/') ? repository : `library/${repository}`;
+    const firstAttempt = await this.fetchWithReliability({
+      hostname: 'registry-1.docker.io',
+      path: `/v2/${repo}/manifests/${tag}`,
+      headers: {
+        'Accept': 'application/vnd.docker.distribution.manifest.v2+json'
+      },
+    });
+    if (firstAttempt.statusCode !== 401) {
+      if (firstAttempt.statusCode < 200 || firstAttempt.statusCode >= 300) {
+        throw new Error(`Docker Hub registry returned HTTP ${firstAttempt.statusCode}`);
+      }
+      return firstAttempt.headers['docker-content-digest'] || null;
+    }
+    // 401 → acquire a Bearer token via the WWW-Authenticate realm, then retry once.
+    const authHeader = firstAttempt.headers['www-authenticate'];
+    const authUrl = this.parseAuthHeader(authHeader);
+    if (!authUrl) {
+      throw new Error('Authentication required but no auth URL found');
+    }
+    const token = await this.fetchAuthToken(authUrl);
+    const authed = await this.fetchWithReliability({
+      hostname: 'registry-1.docker.io',
+      path: `/v2/${repo}/manifests/${tag}`,
+      headers: {
+        'Accept': 'application/vnd.docker.distribution.manifest.v2+json',
+        'Authorization': `Bearer ${token}`,
+      },
+    });
+    if (authed.statusCode < 200 || authed.statusCode >= 300) {
+      throw new Error(`Docker Hub registry returned HTTP ${authed.statusCode} after auth`);
+    }
+    return authed.headers['docker-content-digest'] || null;
+  }
+
+  /**
+   * Single hardened HTTPS probe — DC-078.
+   *
+   * Reliability properties:
+   *   1. `family: 4` — IPv4-only DNS lookup. Avoids dual-stack races where a
+   *      single unreachable IPv6 destination consumes the default 30-second
+   *      connect timeout before the IPv4 fallback succeeds (manifested in
+   *      error.log as AggregateError [ETIMEDOUT] with `at internalConnectMultiple`).
+   *   2. Hard per-request timeout (REGISTRY_REQUEST_TIMEOUT_MS) — caps total
+   *      latency for any single probe attempt.
+   *   3. Retry on transient network errors (REGISTRY_TRANSIENT_ERROR_CODES)
+   *      with REGISTRY_RETRY_BACKOFF_MS delay between attempts. Does NOT
+   *      retry on HTTP 4xx/5xx — those are real responses we should surface.
+   *
+   * Returns {statusCode, headers, body} so callers can read whichever response
+   * header or body bytes they need. For digest probes the body is drained and
+   * discarded; for auth-token fetches the JSON body is parsed.
+   *
+   * @param {object} opts
+   * @param {string} opts.hostname
+   * @param {string} opts.path
+   * @param {object} [opts.headers]
+   * @param {number} [opts.maxBodyBytes=65536] — protect against runaway bodies
+   */
+  async fetchWithReliability(opts) {
+    const maxBodyBytes = opts.maxBodyBytes || 65536;
+    let attempt = 0;
+    while (attempt <= REGISTRY_MAX_RETRIES) {
+      try {
+        const result = await this._httpsRequestOnce({
+          hostname: opts.hostname,
+          path: opts.path,
+          headers: opts.headers || {},
+          maxBodyBytes,
+        });
+        return result;
+      } catch (error) {
+        // Drain retryable transient errors; non-transient (HTTP status) errors
+        // and code-less errors are surfaced directly to the caller.
+        if (!REGISTRY_TRANSIENT_ERROR_CODES.has(error && error.code)) {
+          throw error;
+        }
+        if (attempt >= REGISTRY_MAX_RETRIES) {
+          throw error;
+        }
+        attempt += 1;
+        // Brief backoff before retry to let transient blips settle.
+        await new Promise((resolve) => setTimeout(resolve, REGISTRY_RETRY_BACKOFF_MS));
+      }
+    }
+    // Defensive — should not reach here because the loop either throws or returns.
+    throw new Error('fetchWithReliability exhausted retries');
+  }
+
+  /**
+   * One-shot HTTPS request helper for fetchWithReliability — DC-078.
+   * Returns {statusCode, headers, body} on 2xx and most non-2xx responses
+   * (the caller decides what to do with non-2xx). Throws on transient
+   * network errors so the retry policy catches them.
+   */
+  _httpsRequestOnce({ hostname, path: urlPath, headers, maxBodyBytes }) {
     return new Promise((resolve, reject) => {
       const options = {
-        hostname: 'ghcr.io',
+        hostname,
-        path: `/v2/${imageRepo}/manifests/${tag}`,
+        path: urlPath,
         method: 'GET',
-        headers: {
+        family: 4,                              // DC-078: IPv4-only — see top-of-file comment
-          'Accept': 'application/vnd.docker.distribution.manifest.v2+json,application/vnd.docker.distribution.manifest.list.v2+json,application/vnd.oci.image.manifest.v1+json,application/vnd.oci.image.index.v1+json'
+        headers,
-        }
+        timeout: REGISTRY_REQUEST_TIMEOUT_MS,   // DC-078: hard per-request cap
       };
-
       const req = https.request(options, (res) => {
-        if (res.statusCode === 401) {
+        let body = '';
-          const authHeader = res.headers['www-authenticate'];
+        let size = 0;
-          const authUrl = this.parseAuthHeader(authHeader);
+        let aborted = false;
-          if (authUrl) {
+        res.on('data', (chunk) => {
-            // ghcr.io auth endpoint accepts scope=repository:owner/name:pull
+          if (aborted) return;
-            this.authenticateAndGetDigest(authUrl, options).then(resolve).catch(reject);
+          size += chunk.length;
-          } else {
+          if (size > maxBodyBytes) {
-            reject(new Error('Authentication required but no auth URL found'));
+            aborted = true;
+            res.destroy();
+            const err = new Error(`response from ${hostname}${urlPath} exceeded ${maxBodyBytes} bytes`);
+            err.code = 'ERR_RESPONSE_TOO_LARGE';
+            reject(err);
+            return;
           }
-          return;
+          body += chunk;
-        }
+        });
-
+        res.on('end', () => {
-        if (res.statusCode !== 200) {
+          if (aborted) return;
-          // Drain body to avoid socket leak
+          resolve({
-          res.resume();
+            statusCode: res.statusCode,
-          reject(new Error(`ghcr.io returned HTTP ${res.statusCode}`));
+            headers: res.headers,
-          return;
+            body,
-        }
+          });
-
+        });
-        const digest = res.headers['docker-content-digest'];
+      });
-        resolve(digest || null);
+      // Node 22 emits 'timeout' on the request, not the socket, when socket.setTimeout
+      // is hit — make it an explicit error so fetchWithReliability's retry policy catches it.
+      req.on('timeout', () => {
+        req.destroy(new Error('request timeout'));
+        const err = new Error(`registry request to ${hostname}${urlPath} timed out after ${REGISTRY_REQUEST_TIMEOUT_MS}ms`);
+        err.code = 'ETIMEDOUT';
+        reject(err);
+      });
+      req.on('error', (err) => {
+        // Tag errors missing .code so the retry policy recognizes transient ones.
+        if (!err.code && /timeout/i.test(err.message)) err.code = 'ETIMEDOUT';
+        reject(err);
       });
-
-      req.on('error', reject);
       req.end();
     });
   }
 
   /**
-   * Get image digest from Docker Hub
+   * Fetch an auth token from a registry's WWW-Authenticate realm URL — DC-078.
+   * Uses fetchWithReliability for IPv4-only + timeout + retry. Parses the
+   * JSON body and returns the `token` or `access_token` field.
    */
-  async getDockerHubDigest(repository, tag) {
+  async fetchAuthToken(authUrl) {
-    return new Promise((resolve, reject) => {
+    const url = new URL(authUrl);
-      // Normalize repository name
+    const result = await this.fetchWithReliability({
-      const repo = repository.includes('/') ? repository : `library/${repository}`;
+      hostname: url.hostname,
-      
+      path: url.pathname + url.search,
-      const options = {
+      maxBodyBytes: 16384,  // auth tokens are <2 KB; cap to a small bound
-        hostname: 'registry-1.docker.io',
-        path: `/v2/${repo}/manifests/${tag}`,
-        method: 'GET',
-        headers: {
-          'Accept': 'application/vnd.docker.distribution.manifest.v2+json'
-        }
-      };
-
-      const req = https.request(options, (res) => {
-        if (res.statusCode === 401) {
-          // Need to authenticate
-          const authHeader = res.headers['www-authenticate'];
-          const authUrl = this.parseAuthHeader(authHeader);
-          
-          if (authUrl) {
-            this.authenticateAndGetDigest(authUrl, options).then(resolve).catch(reject);
-          } else {
-            reject(new Error('Authentication required but no auth URL found'));
-          }
-          return;
-        }
-
-        const digest = res.headers['docker-content-digest'];
-        resolve(digest || null);
-      });
-
-      req.on('error', reject);
-      req.end();
     });
+    if (result.statusCode !== 200) {
+      throw new Error(`auth token endpoint ${authUrl} returned HTTP ${result.statusCode}`);
+    }
+    let auth;
+    try {
+      auth = JSON.parse(result.body);
+    } catch (parseErr) {
+      // Surface a clean error — otherwise a malformed token response throws
+      // SyntaxError with the raw body snippet, which is hard to diagnose
+      // against the offending realm URL in a log line.
+      throw new Error(`auth token response from ${authUrl} was not valid JSON: ${parseErr.message}`);
+    }
+    const token = auth.token || auth.access_token;
+    if (!token) throw new Error(`No token in auth response from ${authUrl}`);
+    return token;
   }
 
   /**
@@ -283,48 +428,6 @@ class UpdateManager extends EventEmitter {
     return url.toString();
   }
 
-  /**
-   * Authenticate and get digest
-   */
-  async authenticateAndGetDigest(authUrl, originalOptions) {
-    return new Promise((resolve, reject) => {
-      https.get(authUrl, (res) => {
-        let data = '';
-        res.on('data', chunk => data += chunk);
-        res.on('end', () => {
-          try {
-            const auth = JSON.parse(data);
-            const token = auth.token || auth.access_token;
-            
-            if (!token) {
-              reject(new Error('No token in auth response'));
-              return;
-            }
-
-            // Retry original request with token
-            const options = {
-              ...originalOptions,
-              headers: {
-                ...originalOptions.headers,
-                'Authorization': `Bearer ${token}`
-              }
-            };
-
-            const req = https.request(options, (res) => {
-              const digest = res.headers['docker-content-digest'];
-              resolve(digest || null);
-            });
-
-            req.on('error', reject);
-            req.end();
-          } catch (error) {
-            reject(error);
-          }
-        });
-      }).on('error', reject);
-    });
-  }
-
   /**
    * Extract tag from image name
    */

dashcaddy-api/src/utilities/fleet-validation.js

@@ -415,10 +415,91 @@ function validateFleetHost(input) {
   };
 }
 
+/**
+ * Validate a `host:port` upstream string for use in Caddy's `reverse_proxy`.
+ *
+ * DC-074 SSRF hardening: an authenticated dashboard operator can call
+ * POST /api/v1/site with `upstream: '10.0.0.1:80'` and end up with a
+ * Caddyfile entry that proxies public traffic (https://attacker.example.com)
+ * to an INTERNAL host (10.0.0.1:80). Caddy runs on DNS2 — same network
+ * as the targets — so the proxy lands the request on the private host.
+ * The operator doesn't even need DNS-rebinding tricks: a literal IPv4
+ * like 192.168.1.1 is accepted by the existing `[a-z0-9.-]+:\d{1,5}`
+ * upstream regex.
+ *
+ * Reuses `resolveAndCheckAddress()` to:
+ *   - reject literal private IPv4 / IPv6
+ *   - resolve DNS names and reject any private-IP answer
+ *     (rebinding defense — the actual address Caddy connects to is
+ *     the resolved IP at registration time; Caddy itself resolves
+ *     the name per-request, so a malicious operator could flip the
+ *     A record between registration and connection. Acceptable
+ *     residual risk — the registration check is the main gate.)
+ *   - cap port to 1..65535 (defense vs. `host:99999999` integer
+ *     overflow / Caddy parser-bomb)
+ *
+ * Opt-in via SITES_ALLOW_PRIVATE_UPSTREAMS=true for operators who
+ * intentionally proxy to private targets (faster than a public DNS
+ * round-trip + central control plane).
+ *
+ * @param {string} upstream - "host:port" string (e.g. "10.0.0.1:80")
+ * @param {object} [opts]
+ * @param {boolean} [opts.allowPrivate] - override the env-var default
+ * @returns {Promise<{ok: true, host: string, port: number, resolvedIp?: string, family?: number} | {ok: false, code: string, message: string}>}
+ */
+async function validateUpstream(upstream, opts = {}) {
+  if (typeof upstream !== 'string' || upstream.length === 0) {
+    return { ok: false, code: 'INVALID_UPSTREAM', message: 'upstream is required' };
+  }
+
+  // Split on the LAST colon so IPv6 literals like `[::1]:80` parse
+  // correctly (and a malformed `[::1]` without port is rejected with
+  // a clean code, not a confusing TypeError from Number()).
+  const lastColon = upstream.lastIndexOf(':');
+  if (lastColon < 0) {
+    return { ok: false, code: 'INVALID_UPSTREAM', message: 'upstream must be host:port' };
+  }
+  const host = upstream.slice(0, lastColon);
+  const portStr = upstream.slice(lastColon + 1);
+
+  const portNum = Number(portStr);
+  if (!Number.isInteger(portNum) || portNum < 1 || portNum > 65535) {
+    return { ok: false, code: 'INVALID_PORT', message: 'upstream port must be an integer 1..65535' };
+  }
+
+  // Allow-list the host charset BEFORE the DNS lookup so attacker
+  // payloads can't make the resolver do work. Matches the fleet
+  // isValidHostnameSyntax check; sites.js's own `[a-z0-9.-]+` regex
+  // is more restrictive (only letters/digits/dots/hyphens) so
+  // we widen here to also accept bracketed IPv6. Anything else gets
+  // rejected pre-DNS.
+  const isBracketedIPv6 = host.startsWith('[') && host.endsWith(']');
+  const hostToCheck = isBracketedIPv6 ? host.slice(1, -1) : host;
+  if (!isValidHostnameSyntax(hostToCheck) && require('net').isIP(hostToCheck) === 0) {
+    return { ok: false, code: 'INVALID_HOST', message: `upstream host "${host}" is not a valid DNS name or IP address` };
+  }
+
+  const allowPrivate = typeof opts.allowPrivate === 'boolean'
+    ? opts.allowPrivate
+    : process.env.SITES_ALLOW_PRIVATE_UPSTREAMS === 'true';
+
+  const r = await resolveAndCheckAddress(hostToCheck, { allowPrivate });
+  if (!r.ok) return r; // bubbles up PRIVATE_IPV4 / PRIVATE_IPV6 / INVALID_HOSTNAME / DNS_*
+
+  return {
+    ok: true,
+    host,
+    port: portNum,
+    resolvedIp: r.ip,
+    family: r.family,
+  };
+}
+
 module.exports = {
   validateFleetHost,
   resolveAndCheckAddress,
   isPrivateOrReservedIPv4,
   isPrivateOrReservedIPv6,
   isValidHostnameSyntax,
+  validateUpstream,
 };

dashcaddy-api/src/utilities/middleware.js

@@ -426,8 +426,21 @@ module.exports = function configureMiddleware(app, {
     { path: '/api/v1/ca/root.crt',       exact: true,  method: 'GET' },
     { path: '/api/v1/ca/install-script', exact: true,  method: 'GET' },
     { path: '/api/v1/health/ca',         exact: true,  method: 'GET' },
-    { path: '/api/v1/ca/cert/',          prefix: true, method: 'GET' },
+    // DC-076: /api/v1/ca/cert/<domain> and /api/v1/ca/certs MUST stay gated
-    { path: '/api/v1/ca/certs',          exact: true,  method: 'GET' },
+    // by TOTP/session. The /cert/<domain> endpoint returns the private key
+    // (format=key and format=pem both embed `server.key`; format=pfx wraps
+    // the same key in a PKCS#12 envelope). If an operator disables TOTP at
+    // any point in the future (ops command, fresh install with TOTP off
+    // during setup, .disabled-* rename of totp-config.json), an unauthenticated
+    // attacker reaching `https://ca.sami/api/ca/cert/<any-domain>?format=key`
+    // would receive the per-service RSA private key for every service whose
+    // cert Caddy has ever signed — that's a per-service key disclosure, not
+    // just a CA fingerprint leak. The `/api/v1/ca/info`, `/root.crt`, and
+    // `/install-script` paths above stay public (the root CA cert is public
+    // by design — devices need it to trust *.sami TLS); only the per-service
+    // private key and per-service cert list go behind auth. See DC-076 for
+    // the corresponding rate-limit + admin-scope + password-required
+    // hardening in routes/ca.js.
     { path: '/api/v1/csrf-token',        exact: true,  method: 'GET' },
     { path: '/api/v1/logo',              exact: true,  method: 'GET' },
     { path: '/api/v1/favicon',           exact: true,  method: 'GET' },

dashcaddy-api/src/utilities/nesting-guard.js

@@ -14,8 +14,19 @@ const path = require('path');
 module.exports = function nestingGuard() {
   try {
     const paths = require('../config/paths');
-    const dataDir = paths.dataDir;
+    const dataDir = paths && paths.dataDir;
-    const dataDataPath = path.join(dataDir, 'data');
+    // Defensive: if paths.dataDir is undefined (older callers or a future
+    // export-shape drift), fall back to platformPaths.dataDir directly so the
+    // guard can still execute. Pre-fix this branch was swallowed silently by
+    // the outer try/catch, leaving the entire nesting-guard a no-op (DC-077).
+    const effectiveDataDir = typeof dataDir === 'string' && dataDir
+      ? dataDir
+      : require('../../platform-paths').dataDir;
+    if (typeof effectiveDataDir !== 'string' || !effectiveDataDir) {
+      console.warn('[nesting-guard] Skipped: dataDir unavailable from src/config/paths and platform-paths');
+      return;
+    }
+    const dataDataPath = path.join(effectiveDataDir, 'data');
 
     // If data/data exists, it's a recursive duplicate — remove it
     if (fs.existsSync(dataDataPath)) {