diff --git a/server/CLAUDE.md b/server/CLAUDE.md
index 01d5f267f..6bdc2f01c 100644
--- a/server/CLAUDE.md
+++ b/server/CLAUDE.md
@@ -16,6 +16,7 @@ npm run test:coverage     # istanbul coverage; per-domain ratchet over src/nest/
 npm run gen:plugin-facts  # regenerate the plugin-protocol tables into plugin-sdk/ + shared/
 npm run check:plugin-facts # CI gate — fails if the generated copies drifted
 node scripts/coverage-thresholds.mjs  # after test:coverage — prints the ratchet block for vitest.config.ts
+npm run db:call-graph -- --sync --tx [--domains nest/days,…]  # sync DB-touching methods + transaction sites (exit 1 if any)
 ```
 
 Single test: `npx vitest run tests/unit/nest/weather.controller.test.ts`, or `npx vitest run -t "returns 401 without cookie"`.
@@ -38,7 +39,7 @@ Nest owns everything. Every domain is a DI module under `src/nest/<domain>/` (`c
 
 - **Thin controller → injectable provider.** Never resurrect a plain function-module service; don't grow god services — split a domain into several modules when it outgrows one class (trips and auth already are).
 - **Inject, don't reach for module globals.** No new imports of the global `db` proxy from `nest/` layers; no new code depending on the `ws` singleton or event-sink globals. Modules must be importable without side effects.
-- **Transactions are not optional.** Multi-statement writes go in `db.transaction()`; never hand-roll `BEGIN`/`COMMIT`. Bind values with `?`; identifiers only via a literal allow-list.
+- **Transactions are not optional.** Multi-statement writes go in `await this.uow.transactional(async () => …)` (`UnitOfWork` from `nest/database`, provided by the global `OrmModule`); never hand-roll `BEGIN`/`COMMIT` and never call `db.transaction()` (the Phase 1 async sweep removes it). Every DB-touching method is `async`; `@typescript-eslint/no-floating-promises` and `no-misused-promises` are errors, so an unawaited call or a `Promise` in a condition fails lint. Bind values with `?`; identifiers only via a literal allow-list.
 - **Migrations are append-only.** A migration is identified by its class name in `mikro_orm_migrations`, and files sort by the timestamp in that name — never rename or delete one that has shipped, and never edit its body; add a new one. No env interpolation in SQL. (The old positional `schema_version` array is gone; `db/migrations.ts` is retained for tests and is not appended to.)
 - **Every write endpoint validates** through the Zod pipe with a schema from `@trek/shared` — no `Record<string, unknown>` + ad-hoc checks. Also verify every referenced id exists and belongs to the same trip.
 - **Every outbound `fetch`** gets a timeout, a response-size cap and boundary validation — no `as`-casting provider responses, no silent `catch → null`. User-influenced URLs go through the SSRF guard. Never fall back to another user's API key.
diff --git a/server/eslint.config.mjs b/server/eslint.config.mjs
index d29ea58ad..cecebbce9 100644
--- a/server/eslint.config.mjs
+++ b/server/eslint.config.mjs
@@ -25,9 +25,48 @@ export default tseslint.config(
   js.configs.recommended,
   ...tseslint.configs.recommended,
   eslintConfigPrettier,
+  {
+    files: ['src/**/*.ts'],
+    languageOptions: {
+      parserOptions: {
+        // Type-aware linting for src/: the project service asks TypeScript which
+        // config owns a file, the way an editor does, so there is no `project`
+        // array to keep in sync. Every file under src/ is in tsconfig.json's
+        // `include`, so the service resolves them all.
+        projectService: true,
+        tsconfigRootDir: import.meta.dirname,
+      },
+    },
+  },
+  {
+    // tests/ needs the classic `project` instead. The project service looks for
+    // the tsconfig.json nearest the file and refuses a file that config does not
+    // include ("was not found by the project service"); tsconfig.json includes
+    // only `src`, and its `allowDefaultProject` escape hatch rejects any glob
+    // containing `**`, so it cannot cover a tree this size. `tsconfig.tests.json`
+    // (the one `npm run typecheck:tests` uses) includes src + tests, which is
+    // exactly the program these files need.
+    files: ['tests/**/*.ts'],
+    languageOptions: {
+      parserOptions: {
+        project: ['./tsconfig.tests.json'],
+        tsconfigRootDir: import.meta.dirname,
+      },
+    },
+  },
   {
     files: ['src/**/*.ts', 'tests/**/*.ts'],
     rules: {
+      // --- The promise safety net for the Phase 1 async sweep (ORM migration) ---
+      // Turning a DB-touching method `async` makes every unawaited call site a
+      // silently reordered write, and every `if (svc.exists(id))` permanently
+      // true — neither of which the type checker reports. These two rules are
+      // the only thing that catches them, so they are errors, not warnings.
+      '@typescript-eslint/no-floating-promises': ['error', { ignoreVoid: true }],
+      '@typescript-eslint/no-misused-promises': [
+        'error',
+        { checksConditionals: true, checksVoidReturn: false, checksSpreads: true },
+      ],
       // --- Severities tuned to keep CI green on a codebase that was never linted ---
       // (each rule below has pre-existing violations; surfaced as warnings, not blockers)
       '@typescript-eslint/no-explicit-any': 'warn',
diff --git a/server/package.json b/server/package.json
index 3219ffe0f..b53833447 100644
--- a/server/package.json
+++ b/server/package.json
@@ -10,6 +10,7 @@
     "reset-admin": "node reset-admin.js",
     "typecheck": "tsc --noEmit",
     "typecheck:tests": "tsc -p tsconfig.tests.json --noEmit",
+    "db:call-graph": "node scripts/db-call-graph.mjs",
     "gen:plugin-facts": "node --import tsx scripts/gen-plugin-facts.ts",
     "check:plugin-facts": "node --import tsx scripts/gen-plugin-facts.ts --check",
     "format": "prettier --write \"src/**/*.ts\" \"test/**/*.ts\"",
diff --git a/server/scripts/db-call-graph.mjs b/server/scripts/db-call-graph.mjs
new file mode 100644
index 000000000..f99f9b6f9
--- /dev/null
+++ b/server/scripts/db-call-graph.mjs
@@ -0,0 +1,566 @@
+#!/usr/bin/env node
+/**
+ * The Phase 1 (async sweep) worklist and gate.
+ *
+ * WHAT IT MEASURES
+ *   --sync  every *synchronous* method under `server/src/**` that touches the
+ *           database — directly (a `get/all/run/prepare/transaction/exec/pragma`
+ *           or a `canAccessTrip/isOwner/rosterUserIds/getPlaceWithTags` call on a
+ *           DatabaseService / raw handle) or transitively (it calls, through
+ *           `this.*`, a method that does). These are exactly the methods the
+ *           sweep's R1 turns into `async` ones.
+ *   --tx    every real `…​.transaction(` call site (the AST sees calls, so the six
+ *           prose mentions inside doc comments that `grep` finds are not here).
+ *           These are the sites R2 routes through `UnitOfWork.transactional`.
+ *
+ * It exits 1 as soon as either list is non-empty, so a task can gate on it:
+ *   `node scripts/db-call-graph.mjs --sync --tx --domains nest/days,nest/budget`
+ *
+ * R0 EXCEPTIONS (never listed, by either flag): `DatabaseService` itself,
+ * `src/db/**`, `src/demo/**` and `src/nest/plugins/host/plugin-data.service.ts`.
+ * They stay synchronous for the whole of Phase 1 — see the recipe's R0.
+ *
+ * IT IS SYNTACTIC. It parses with `ts.createSourceFile` and no type checker, so
+ * it resolves `this.<dep>.<method>()` by the dependency's *written* type name: a
+ * dependency typed as an interface, a token or a union is not followed, and a
+ * call through a local (`const s = f(); s.get(…)`) is not attributed. It is a
+ * worklist and a ratchet, not a proof. Derived from the one-shot inventory pass
+ * that produced `docs/superpowers/plans/phase1-inventory.{md,json}`; Appendix C
+ * there lists the same accuracy caveats in full.
+ *
+ * LIFETIME: Plan 4 deletes this script along with `DatabaseService` — once no
+ * raw handle is left to call synchronously, there is nothing for it to count.
+ */
+import fs from 'node:fs';
+import path from 'node:path';
+import { fileURLToPath } from 'node:url';
+import { createRequire } from 'node:module';
+
+const HERE = path.dirname(fileURLToPath(import.meta.url));
+const SERVER = path.resolve(HERE, '..');
+const REPO = path.resolve(SERVER, '..');
+const require_ = createRequire(path.join(REPO, 'package.json'));
+const ts = require_('typescript');
+
+const SRC = path.join(SERVER, 'src');
+
+// ---------------------------------------------------------------- CLI
+function parseArgs(argv) {
+  const opts = { sync: false, tx: false, domains: null, json: false };
+  for (let i = 0; i < argv.length; i++) {
+    const a = argv[i];
+    if (a === '--sync') opts.sync = true;
+    else if (a === '--tx') opts.tx = true;
+    else if (a === '--json') opts.json = true;
+    else if (a === '--domains') opts.domains = splitDomains(argv[++i]);
+    else if (a.startsWith('--domains=')) opts.domains = splitDomains(a.slice('--domains='.length));
+    else if (a === '--help' || a === '-h') opts.help = true;
+    else {
+      process.stderr.write(`db-call-graph: unknown argument ${a}\n`);
+      opts.help = true;
+      opts.bad = true;
+    }
+  }
+  // No selector: report both, which is what a task's gate wants.
+  if (!opts.sync && !opts.tx) {
+    opts.sync = true;
+    opts.tx = true;
+  }
+  return opts;
+}
+function splitDomains(value) {
+  if (!value) return null;
+  const list = value
+    .split(',')
+    .map((d) => d.trim())
+    .filter(Boolean);
+  return list.length ? list : null;
+}
+const USAGE = `Usage: node scripts/db-call-graph.mjs [--sync] [--tx] [--domains a,b,…] [--json]
+
+  --sync           list synchronous DB-touching methods (direct + transitive)
+  --tx             list real transaction call sites
+  --domains a,b    restrict to these inventory domain names (nest/days, systemNotices, …)
+  --json           machine-readable output
+  (no --sync/--tx) both lists
+
+Exits 1 when a requested list is non-empty. R0 exceptions (DatabaseService,
+src/db/**, src/demo/**, plugins/host/plugin-data.service.ts) are never listed.
+`;
+
+const opts = parseArgs(process.argv.slice(2));
+if (opts.help) {
+  process.stdout.write(USAGE);
+  process.exit(opts.bad ? 2 : 0);
+}
+
+// ---------------------------------------------------------------- file walk
+function walk(dir, acc = []) {
+  for (const ent of fs.readdirSync(dir, { withFileTypes: true })) {
+    const p = path.join(dir, ent.name);
+    if (ent.isDirectory()) {
+      const r = path.relative(SRC, p).replace(/\\/g, '/');
+      // Generated/declarative trees with no call graph of their own.
+      if (r === 'db/migrations' || r === 'db/seeders' || r === 'db/entities' || r === 'typings') continue;
+      walk(p, acc);
+    } else if (ent.name.endsWith('.ts') && !ent.name.endsWith('.d.ts')) {
+      const r = path.relative(SRC, p).replace(/\\/g, '/');
+      if (r === 'db/migrations.ts') continue; // legacy test-only schema replay
+      acc.push(p);
+    }
+  }
+  return acc;
+}
+const files = walk(SRC).sort();
+
+// ---------------------------------------------------------------- constants
+const DB_METHODS = new Set(['get', 'all', 'run', 'prepare', 'transaction', 'exec', 'pragma']);
+const DB_HELPERS = new Set(['canAccessTrip', 'isOwner', 'rosterUserIds', 'getPlaceWithTags']);
+const DB_IDENT_NAMES = new Set(['db', 'conn', 'tx', 'database', 'dbs']);
+const DB_PROP_NAMES = new Set(['db', 'database', 'dbs']);
+const DB_SERVICE_TYPES = new Set(['DatabaseService']);
+
+/** R0: the raw seam and the out-of-scope trees. See the recipe's R0. */
+const R0_CLASSES = new Set(['DatabaseService']);
+function isR0File(relFile) {
+  return (
+    relFile.startsWith('src/db/') ||
+    relFile.startsWith('src/demo/') ||
+    relFile === 'src/nest/plugins/host/plugin-data.service.ts'
+  );
+}
+
+function relServer(p) {
+  return path.relative(SERVER, p).replace(/\\/g, '/');
+}
+
+function domainOf(file) {
+  const r = path.relative(SRC, file).replace(/\\/g, '/');
+  if (r.startsWith('nest/')) {
+    const seg = r.split('/')[1];
+    return seg.includes('.') ? 'nest(root)' : `nest/${seg}`;
+  }
+  if (r.startsWith('nest-mcp/')) return 'nest-mcp';
+  if (r.startsWith('systemNotices/')) return 'systemNotices';
+  if (r.startsWith('demo/')) return 'demo';
+  if (r.startsWith('mcp/')) return 'mcp';
+  if (r.startsWith('middleware/')) return 'middleware';
+  if (r.startsWith('db/')) return 'db';
+  if (r.startsWith('app-config/')) return 'app-config';
+  if (r.startsWith('utils/')) return 'utils';
+  return 'src(root)';
+}
+
+// ---------------------------------------------------------------- parse pass
+/** @type {Map<string, any>} className -> first record with that name */
+const classes = new Map();
+/** @type {any[]} */
+const allClasses = [];
+const txSites = [];
+
+function lineOf(sf, node) {
+  return sf.getLineAndCharacterOfPosition(node.getStart(sf)).line + 1;
+}
+
+function typeNameOf(typeNode) {
+  if (!typeNode) return null;
+  if (ts.isTypeReferenceNode(typeNode)) {
+    const n = typeNode.typeName;
+    return ts.isIdentifier(n) ? n.text : n.getText();
+  }
+  return typeNode.getText().replace(/\s+/g, ' ').slice(0, 60);
+}
+
+for (const file of files) {
+  const text = fs.readFileSync(file, 'utf8');
+  const sf = ts.createSourceFile(file, text, ts.ScriptTarget.ESNext, /* setParentNodes */ true, ts.ScriptKind.TS);
+
+  // Identifiers imported from db/database denote a raw handle / helper.
+  const dbDatabaseImports = new Set();
+  for (const st of sf.statements) {
+    if (!ts.isImportDeclaration(st) || !st.importClause) continue;
+    const spec = st.moduleSpecifier.text;
+    const names = [];
+    if (st.importClause.name) names.push(st.importClause.name.text);
+    const nb = st.importClause.namedBindings;
+    if (nb && ts.isNamedImports(nb)) for (const e of nb.elements) names.push(e.name.text);
+    if (nb && ts.isNamespaceImport(nb)) names.push(nb.name.text);
+    for (const n of names) if (/(^|\/)db\/database$/.test(spec)) dbDatabaseImports.add(n);
+  }
+
+  const fileRel = relServer(file);
+  const fileDomain = domainOf(file);
+
+  // ---- gather class-likes and module-level functions
+  const containers = [];
+  for (const st of sf.statements) {
+    if (ts.isClassDeclaration(st) && st.name) containers.push({ kind: 'class', node: st, name: st.name.text });
+  }
+  const moduleFns = [];
+  for (const st of sf.statements) {
+    if (ts.isFunctionDeclaration(st) && st.name && st.body) {
+      moduleFns.push({
+        name: st.name.text,
+        node: st,
+        async: !!st.modifiers?.some((m) => m.kind === ts.SyntaxKind.AsyncKeyword),
+      });
+    }
+    if (ts.isVariableStatement(st)) {
+      for (const d of st.declarationList.declarations) {
+        if (d.initializer && (ts.isArrowFunction(d.initializer) || ts.isFunctionExpression(d.initializer)) && ts.isIdentifier(d.name)) {
+          moduleFns.push({
+            name: d.name.text,
+            node: d.initializer,
+            async: !!d.initializer.modifiers?.some((m) => m.kind === ts.SyntaxKind.AsyncKeyword),
+          });
+        }
+      }
+    }
+  }
+  if (moduleFns.length) {
+    containers.push({ kind: 'module', node: sf, name: `${path.basename(file, '.ts')} (module)`, fns: moduleFns });
+  }
+
+  for (const c of containers) {
+    const deps = {}; // propName -> written type name
+    const dbProps = new Set();
+    const methods = [];
+    let classRec;
+
+    if (c.kind === 'class') {
+      for (const m of c.node.members) {
+        if (ts.isConstructorDeclaration(m)) {
+          for (const p of m.parameters) {
+            if (!ts.isIdentifier(p.name)) continue;
+            const tn = typeNameOf(p.type);
+            deps[p.name.text] = tn;
+            if (DB_SERVICE_TYPES.has(tn) || DB_PROP_NAMES.has(p.name.text)) dbProps.add(p.name.text);
+          }
+        } else if (ts.isPropertyDeclaration(m) && ts.isIdentifier(m.name)) {
+          const tn = typeNameOf(m.type);
+          if (tn && !deps[m.name.text]) deps[m.name.text] = tn;
+          if ((tn && DB_SERVICE_TYPES.has(tn)) || DB_PROP_NAMES.has(m.name.text)) dbProps.add(m.name.text);
+        }
+      }
+      // `private get db() { return this.dbs.connection; }` — the alias 14 services use.
+      for (const m of c.node.members) {
+        if (ts.isGetAccessorDeclaration(m) && m.name && ts.isIdentifier(m.name) && m.body) {
+          const stmts = m.body.statements;
+          const only = stmts.length === 1 && ts.isReturnStatement(stmts[0]) ? stmts[0].expression : null;
+          const aliasesDb =
+            only &&
+            ts.isPropertyAccessExpression(only) &&
+            ((only.expression.kind === ts.SyntaxKind.ThisKeyword && dbProps.has(only.name.text)) ||
+              (only.name.text === 'connection' &&
+                ts.isPropertyAccessExpression(only.expression) &&
+                only.expression.expression.kind === ts.SyntaxKind.ThisKeyword &&
+                dbProps.has(only.expression.name.text)));
+          const tn = typeNameOf(m.type);
+          if (aliasesDb || (tn && DB_SERVICE_TYPES.has(tn))) {
+            dbProps.add(m.name.text);
+            if (!deps[m.name.text]) deps[m.name.text] = 'DatabaseService';
+          }
+        }
+      }
+      for (const m of c.node.members) {
+        const mods = ts.getModifiers(m);
+        if (ts.isMethodDeclaration(m) && m.name && m.body) {
+          methods.push({
+            name: m.name.getText(sf),
+            kind: 'method',
+            body: m.body,
+            async: !!mods?.some((x) => x.kind === ts.SyntaxKind.AsyncKeyword),
+            line: lineOf(sf, m),
+          });
+        } else if (
+          ts.isPropertyDeclaration(m) &&
+          m.initializer &&
+          (ts.isArrowFunction(m.initializer) || ts.isFunctionExpression(m.initializer)) &&
+          m.name
+        ) {
+          methods.push({
+            name: m.name.getText(sf),
+            kind: 'method',
+            body: m.initializer.body,
+            async: !!m.initializer.modifiers?.some((x) => x.kind === ts.SyntaxKind.AsyncKeyword),
+            line: lineOf(sf, m),
+          });
+        } else if (
+          ts.isPropertyDeclaration(m) &&
+          m.initializer &&
+          m.name &&
+          (ts.isCallExpression(m.initializer) ||
+            ts.isNewExpression(m.initializer) ||
+            ts.isObjectLiteralExpression(m.initializer) ||
+            ts.isArrayLiteralExpression(m.initializer))
+        ) {
+          // e.g. `private readonly supervisor = create(fn, { onStatus: () => this.db.… })`
+          methods.push({ name: m.name.getText(sf), kind: 'field-init', body: m.initializer, async: false, line: lineOf(sf, m) });
+        } else if (ts.isConstructorDeclaration(m) && m.body) {
+          methods.push({ name: 'constructor', kind: 'constructor', body: m.body, async: false, line: lineOf(sf, m) });
+        } else if (ts.isGetAccessorDeclaration(m) && m.body && m.name) {
+          methods.push({ name: m.name.getText(sf), kind: 'getter', body: m.body, async: false, line: lineOf(sf, m) });
+        }
+      }
+      classRec = { name: c.name, kind: 'class', file: fileRel, domain: fileDomain, deps, dbProps: [...dbProps], methods: [] };
+    } else {
+      for (const f of c.fns) {
+        methods.push({ name: f.name, kind: 'function', body: f.node.body, async: f.async, line: lineOf(sf, f.node) });
+      }
+      classRec = { name: c.name, kind: 'module', file: fileRel, domain: fileDomain, deps: {}, dbProps: [], methods: [] };
+    }
+
+    // ---- receiver classification
+    function receiverKind(expr) {
+      if (ts.isIdentifier(expr)) {
+        if (dbDatabaseImports.has(expr.text)) return { text: expr.text };
+        if (DB_IDENT_NAMES.has(expr.text)) return { text: expr.text };
+        return null;
+      }
+      if (ts.isPropertyAccessExpression(expr)) {
+        if (expr.expression.kind === ts.SyntaxKind.ThisKeyword && dbProps.has(expr.name.text)) {
+          return { text: `this.${expr.name.text}` };
+        }
+        if (
+          expr.name.text === 'connection' &&
+          ts.isPropertyAccessExpression(expr.expression) &&
+          expr.expression.expression.kind === ts.SyntaxKind.ThisKeyword &&
+          dbProps.has(expr.expression.name.text)
+        ) {
+          return { text: `this.${expr.expression.name.text}.connection` };
+        }
+        if (expr.expression.kind === ts.SyntaxKind.ThisKeyword && expr.name.text === 'conn') {
+          return { text: 'this.conn' };
+        }
+      }
+      return null;
+    }
+
+    // ---- walk each method body
+    for (const m of methods) {
+      const dbCalls = [];
+      const calls = []; // {kind:'self'|'dep', dep, depType, method}
+
+      const visit = (node) => {
+        if (node !== m.body && (ts.isClassDeclaration(node) || ts.isClassExpression(node))) return;
+        if (ts.isCallExpression(node)) {
+          const callee = node.expression;
+          if (ts.isPropertyAccessExpression(callee)) {
+            const name = callee.name.text;
+            const recv = receiverKind(callee.expression);
+            if (recv && (DB_METHODS.has(name) || DB_HELPERS.has(name))) {
+              dbCalls.push({ recv: recv.text, method: name, line: lineOf(sf, node) });
+              if (name === 'transaction') {
+                txSites.push({
+                  file: fileRel,
+                  domain: fileDomain,
+                  class: classRec.name,
+                  method: m.name,
+                  line: lineOf(sf, node),
+                  receiver: recv.text,
+                });
+              }
+            }
+            if (callee.expression.kind === ts.SyntaxKind.ThisKeyword) {
+              calls.push({ kind: 'self', method: name });
+            } else if (
+              ts.isPropertyAccessExpression(callee.expression) &&
+              callee.expression.expression.kind === ts.SyntaxKind.ThisKeyword
+            ) {
+              const dep = callee.expression.name.text;
+              if (Object.prototype.hasOwnProperty.call(deps, dep)) {
+                calls.push({ kind: 'dep', dep, depType: deps[dep], method: name });
+              }
+            }
+          } else if (ts.isIdentifier(callee)) {
+            if (DB_HELPERS.has(callee.text) && dbDatabaseImports.has(callee.text)) {
+              dbCalls.push({ recv: '(import)', method: callee.text, line: lineOf(sf, node) });
+            }
+            if (c.kind === 'module' && moduleFns.some((f) => f.name === callee.text)) {
+              calls.push({ kind: 'self', method: callee.text });
+            }
+          }
+        }
+        ts.forEachChild(node, visit);
+      };
+      if (m.body) visit(m.body);
+
+      classRec.methods.push({
+        name: m.name,
+        kind: m.kind,
+        line: m.line,
+        async: m.async,
+        dbCalls,
+        dbCallCount: dbCalls.length,
+        calls,
+      });
+    }
+
+    allClasses.push(classRec);
+    if (!classes.has(classRec.name)) classes.set(classRec.name, classRec);
+  }
+}
+
+// ------------------------------------------------- transitive DB closure
+const methodKey = (cls, m) => `${cls}#${m}`;
+const methodIndex = new Map();
+for (const c of allClasses) for (const m of c.methods) methodIndex.set(methodKey(c.name, m.name), { cls: c, m });
+
+function calleeKeys(c, m) {
+  const out = [];
+  for (const call of m.calls) {
+    if (call.kind === 'self') out.push(methodKey(c.name, call.method));
+    else if (call.kind === 'dep' && call.depType && classes.has(call.depType)) out.push(methodKey(call.depType, call.method));
+  }
+  return out;
+}
+
+for (const c of allClasses) for (const m of c.methods) m.directDb = m.dbCallCount > 0;
+
+for (const c of allClasses) {
+  for (const m of c.methods) {
+    const seen = new Set();
+    const stack = calleeKeys(c, m).slice();
+    const dbCallees = new Set();
+    while (stack.length) {
+      const k = stack.pop();
+      if (seen.has(k)) continue;
+      seen.add(k);
+      const t = methodIndex.get(k);
+      if (!t) continue;
+      if (t.m.directDb) dbCallees.add(k);
+      for (const nk of calleeKeys(t.cls, t.m)) if (!seen.has(nk)) stack.push(nk);
+    }
+    m.transitiveDbCallees = [...dbCallees].sort();
+    m.touchesDb = m.directDb || dbCallees.size > 0;
+  }
+}
+
+// ------------------------------------------------- selection
+const domainFilter = opts.domains ? new Set(opts.domains) : null;
+const unknownDomains = domainFilter
+  ? [...domainFilter].filter((d) => !allClasses.some((c) => c.domain === d) && !files.some((f) => domainOf(f) === d))
+  : [];
+function inScope(rec) {
+  if (isR0File(rec.file) || R0_CLASSES.has(rec.name)) return false;
+  if (domainFilter && !domainFilter.has(rec.domain)) return false;
+  return true;
+}
+
+/** A `constructor` / field initializer / getter cannot simply become `async` — R1.3/R1.5/R1.6. */
+const CANNOT_BE_ASYNC = new Set(['constructor', 'field-init']);
+
+const syncMethods = [];
+const restructureSites = [];
+for (const c of allClasses) {
+  if (!inScope(c)) continue;
+  for (const m of c.methods) {
+    if (!m.touchesDb || m.async) continue;
+    const entry = {
+      domain: c.domain,
+      file: c.file,
+      class: c.name,
+      container: c.kind,
+      method: m.name,
+      methodKind: m.kind,
+      line: m.line,
+      direct: m.directDb,
+      dbCallSites: m.dbCallCount,
+      via: m.directDb ? [] : m.transitiveDbCallees,
+    };
+    if (CANNOT_BE_ASYNC.has(m.kind)) restructureSites.push(entry);
+    else syncMethods.push(entry);
+  }
+}
+const txSelected = txSites.filter((t) => {
+  if (isR0File(t.file) || R0_CLASSES.has(t.class)) return false;
+  if (domainFilter && !domainFilter.has(t.domain)) return false;
+  return true;
+});
+
+const byDomainClass = (a, b) => a.domain.localeCompare(b.domain) || a.file.localeCompare(b.file) || a.line - b.line;
+syncMethods.sort(byDomainClass);
+restructureSites.sort(byDomainClass);
+txSelected.sort(byDomainClass);
+
+// ------------------------------------------------- output
+const out = [];
+function group(entries, key) {
+  const m = new Map();
+  for (const e of entries) {
+    const k = key(e);
+    if (!m.has(k)) m.set(k, []);
+    m.get(k).push(e);
+  }
+  return m;
+}
+
+if (opts.json) {
+  out.push(
+    JSON.stringify(
+      {
+        scope: {
+          domains: opts.domains ?? 'all',
+          r0Exceptions: ['DatabaseService', 'src/db/**', 'src/demo/**', 'src/nest/plugins/host/plugin-data.service.ts'],
+        },
+        syncDbMethods: opts.sync ? syncMethods : undefined,
+        syncDbMethodCount: opts.sync ? syncMethods.length : undefined,
+        cannotBeAsync: opts.sync ? restructureSites : undefined,
+        transactionSites: opts.tx ? txSelected : undefined,
+        transactionSiteCount: opts.tx ? txSelected.length : undefined,
+        unknownDomains,
+      },
+      null,
+      2,
+    ),
+  );
+} else {
+  if (unknownDomains.length) {
+    out.push(`! no such domain: ${unknownDomains.join(', ')} (names come from the inventory, e.g. nest/days, systemNotices)`);
+    out.push('');
+  }
+  if (opts.sync) {
+    const scope = opts.domains ? opts.domains.join(', ') : 'all domains';
+    if (!syncMethods.length) {
+      out.push(`sync DB-touching methods: none (${scope})`);
+    } else {
+      const direct = syncMethods.filter((e) => e.direct).length;
+      out.push(
+        `sync DB-touching methods: ${syncMethods.length} (${direct} direct, ${syncMethods.length - direct} transitive) in ${scope}`,
+      );
+      for (const [k, entries] of group(syncMethods, (e) => `${e.domain}\u0000${e.file}\u0000${e.class}`)) {
+        const [domain, file, cls] = k.split('\u0000');
+        const d = entries.filter((e) => e.direct).length;
+        out.push('');
+        out.push(`  ${domain} · ${cls} · ${file}  (${d} direct, ${entries.length - d} transitive)`);
+        for (const e of entries) {
+          const detail = e.direct ? `${e.dbCallSites} db call site${e.dbCallSites === 1 ? '' : 's'}` : `via ${e.via.join(', ')}`;
+          out.push(`    ${String(e.line).padStart(5)}  ${e.method}  —  ${detail}`);
+        }
+      }
+    }
+    if (restructureSites.length) {
+      out.push('');
+      out.push(`  note: ${restructureSites.length} sync DB context(s) that cannot simply become async (recipe R1.5/R1.6 —`);
+      out.push('  restructure, or call an async helper with `void h().catch(…)`); not counted, not gating:');
+      for (const e of restructureSites) out.push(`    ${e.file}:${e.line}  ${e.class}.${e.method} (${e.methodKind})`);
+    }
+  }
+  if (opts.tx) {
+    if (opts.sync) out.push('');
+    const scope = opts.domains ? opts.domains.join(', ') : 'all domains';
+    if (!txSelected.length) {
+      out.push(`transaction sites: none (${scope})`);
+    } else {
+      out.push(`transaction sites: ${txSelected.length} in ${scope}`);
+      for (const t of txSelected) {
+        out.push(`  ${t.file}:${t.line}  ${t.class}.${t.method}  —  ${t.receiver}.transaction(`);
+      }
+    }
+  }
+}
+
+process.stdout.write(out.join('\n') + '\n');
+
+const found = (opts.sync && syncMethods.length > 0) || (opts.tx && txSelected.length > 0);
+process.exit(found ? 1 : 0);
diff --git a/server/src/nest/atlas/atlas-geo.ts b/server/src/nest/atlas/atlas-geo.ts
index aae5efbb1..5c81b4b53 100644
--- a/server/src/nest/atlas/atlas-geo.ts
+++ b/server/src/nest/atlas/atlas-geo.ts
@@ -91,7 +91,10 @@ let admin1Building: Promise<Map<string, string>> | null = null;
 
 function getAdmin1Store(): Promise<Map<string, string>> {
   if (admin1Store) return Promise.resolve(admin1Store);
-  if (!admin1Building) {
+  // `=== null`, not `!admin1Building`: a Promise in a boolean condition is what
+  // no-misused-promises/checksConditionals exists to catch, and the distinction
+  // matters once every DB-touching method returns one.
+  if (admin1Building === null) {
     admin1Building = buildAdmin1Store().then((s) => {
       admin1Store = s;
       admin1Building = null;
diff --git a/server/src/nest/backup/backup.impl.ts b/server/src/nest/backup/backup.impl.ts
index 3e2f48943..685a11acc 100644
--- a/server/src/nest/backup/backup.impl.ts
+++ b/server/src/nest/backup/backup.impl.ts
@@ -292,7 +292,9 @@ export async function createBackup(storage: StorageService, prefix: 'backup' | '
         }
       }
 
-      archive.finalize();
+      // finalize() is async: without this catch a failure that never reached the
+      // 'error' listener above would hang this promise and reject unobserved.
+      archive.finalize().catch(reject);
     });
 
     // The commit — and, under a mirror backend, the replica fan-out point.
diff --git a/server/src/nest/budget/exchange-rates.service.ts b/server/src/nest/budget/exchange-rates.service.ts
index d13510029..845592d6c 100644
--- a/server/src/nest/budget/exchange-rates.service.ts
+++ b/server/src/nest/budget/exchange-rates.service.ts
@@ -75,7 +75,9 @@ export class ExchangeRatesService {
 
     // Coalesce concurrent fetches for the same base.
     let p = inflight.get(key);
-    if (!p) {
+    // `=== undefined`, not `!p`: a Promise is always truthy, so the truthiness
+    // test reads as a live check but never is one (no-misused-promises).
+    if (p === undefined) {
       p = fetchRates(key)
         .then(rates => {
           if (rates) cache.set(key, { rates, ts: Date.now() });
diff --git a/server/src/nest/memories/trek-photo-cache.service.ts b/server/src/nest/memories/trek-photo-cache.service.ts
index 291d403e3..6f3470738 100644
--- a/server/src/nest/memories/trek-photo-cache.service.ts
+++ b/server/src/nest/memories/trek-photo-cache.service.ts
@@ -91,7 +91,10 @@ export class TrekPhotoCacheService {
 
   setInFlight(key: string, promise: Promise<Buffer | null>): void {
     inFlight.set(key, promise);
-    promise.finally(() => inFlight.delete(key));
+    // Book-keeping only: the caller awaits `promise` itself and observes its
+    // rejection, so the derived chain swallows the same one rather than raising
+    // a second, unhandled rejection.
+    void promise.finally(() => inFlight.delete(key)).catch(() => undefined);
   }
 
   async sweepExpired(): Promise<void> {
diff --git a/server/src/nest/plugins/host/plugin-jobs.ts b/server/src/nest/plugins/host/plugin-jobs.ts
index ec5ed839a..8ac5b4ff1 100644
--- a/server/src/nest/plugins/host/plugin-jobs.ts
+++ b/server/src/nest/plugins/host/plugin-jobs.ts
@@ -64,7 +64,9 @@ export function scheduleJobs(
 export function stopJobs(tasks: CronJob[] | undefined): void {
   for (const t of tasks ?? []) {
     try {
-      t.stop();
+      // cron's stop() is async; the rejection is swallowed for the same reason
+      // the synchronous throw below is — teardown must never throw.
+      void t.stop().catch(() => undefined);
     } catch {
       /* ignore — teardown must never throw */
     }
diff --git a/server/tests/helpers/test-uow.ts b/server/tests/helpers/test-uow.ts
new file mode 100644
index 000000000..40e2b6fd9
--- /dev/null
+++ b/server/tests/helpers/test-uow.ts
@@ -0,0 +1,24 @@
+import type Database from 'better-sqlite3';
+import { UnitOfWork } from '../../src/nest/database/unit-of-work';
+import { createTestOrm } from './test-orm';
+
+const perHandle = new WeakMap<Database.Database, Promise<UnitOfWork>>();
+
+/**
+ * The `UnitOfWork` a hand-constructed service needs, bound to the suite's own
+ * better-sqlite3 handle.
+ *
+ * `UnitOfWork.transactional` opens the transaction through MikroORM on that same
+ * handle, so the legacy raw statements a service still issues inside the
+ * callback run inside it — the arrangement the Phase 1 sweep relies on. Memoised
+ * per handle: one ORM per test file, however many services the file builds.
+ */
+export function createTestUnitOfWork(db: Database.Database): Promise<UnitOfWork> {
+  // `=== undefined` rather than a truthiness test: a Promise is always truthy,
+  // which is exactly what no-misused-promises/checksConditionals rejects.
+  const existing = perHandle.get(db);
+  if (existing !== undefined) return existing;
+  const pending = createTestOrm(db).then((t) => new UnitOfWork(t.em));
+  perHandle.set(db, pending);
+  return pending;
+}
diff --git a/server/tests/unit/demo/demo-reset-path.test.ts b/server/tests/unit/demo/demo-reset-path.test.ts
index 2ac204b02..415191277 100644
--- a/server/tests/unit/demo/demo-reset-path.test.ts
+++ b/server/tests/unit/demo/demo-reset-path.test.ts
@@ -68,8 +68,8 @@ describe('demo-reset DB path', () => {
     expect(copyFileSync).toHaveBeenCalledWith(LIVE_DB, BASELINE);
   });
 
-  it('DEMORESET-002: restores the baseline onto that same file, not data/travel.db', () => {
-    resetDemoUser();
+  it('DEMORESET-002: restores the baseline onto that same file, not data/travel.db', async () => {
+    await resetDemoUser();
     expect(copyFileSync).toHaveBeenCalledWith(BASELINE, LIVE_DB);
     // Closed before the copy and reopened after it — copying over an open
     // SQLite file is how a database ends up half of each.
@@ -77,10 +77,10 @@ describe('demo-reset DB path', () => {
     expect(databaseModule.reinitialize).toHaveBeenCalled();
   });
 
-  it('DEMORESET-003: an in-memory database is left alone rather than copied around', () => {
+  it('DEMORESET-003: an in-memory database is left alone rather than copied around', async () => {
     dbStub.name = ':memory:';
     saveBaseline();
-    resetDemoUser();
+    await resetDemoUser();
     expect(copyFileSync).not.toHaveBeenCalled();
   });
 });
diff --git a/server/tests/unit/helpers/test-uow.test.ts b/server/tests/unit/helpers/test-uow.test.ts
new file mode 100644
index 000000000..1402e51b9
--- /dev/null
+++ b/server/tests/unit/helpers/test-uow.test.ts
@@ -0,0 +1,42 @@
+import { afterAll, beforeAll, beforeEach, describe, expect, it } from 'vitest';
+import { createSnapshotTestDb } from '../../helpers/db-mock';
+import { resetTestDb } from '../../helpers/test-db';
+import { createTestUnitOfWork } from '../../helpers/test-uow';
+import { createUser } from '../../helpers/factories';
+import type { UnitOfWork } from '../../../src/nest/database/unit-of-work';
+
+const testDb = createSnapshotTestDb();
+let uow: UnitOfWork;
+
+beforeAll(async () => {
+  uow = await createTestUnitOfWork(testDb);
+});
+beforeEach(() => resetTestDb(testDb));
+afterAll(() => testDb.close());
+
+const countUsers = () => (testDb.prepare('SELECT COUNT(*) AS n FROM users').get() as { n: number }).n;
+
+describe('createTestUnitOfWork', () => {
+  it('TUOW-001: raw better-sqlite3 statements inside transactional() commit together', async () => {
+    await uow.transactional(async () => {
+      createUser(testDb);
+      createUser(testDb);
+    });
+    expect(countUsers()).toBe(2);
+  });
+
+  it('TUOW-002: a throw rolls raw statements back', async () => {
+    await expect(
+      uow.transactional(async () => {
+        createUser(testDb);
+        throw new Error('boom');
+      }),
+    ).rejects.toThrow('boom');
+    expect(countUsers()).toBe(0);
+  });
+
+  it('TUOW-003: the helper is memoised per handle', async () => {
+    const again = await createTestUnitOfWork(testDb);
+    expect(again).toBe(uow);
+  });
+});
diff --git a/server/tests/unit/nest/admin-jobs.test.ts b/server/tests/unit/nest/admin-jobs.test.ts
index 067660a21..24b0778a4 100644
--- a/server/tests/unit/nest/admin-jobs.test.ts
+++ b/server/tests/unit/nest/admin-jobs.test.ts
@@ -79,9 +79,9 @@ describe('DemoResetJob', () => {
     expect(logMock.logInfo).not.toHaveBeenCalled();
   });
 
-  it('AJOB-006 — the tick runs resetDemoUser and contains a throw to the Demo reset log line', () => {
+  it('AJOB-006 — the tick runs resetDemoUser and contains a throw to the Demo reset log line', async () => {
     const { job } = make(true);
-    job.tick();
+    await job.tick();
     expect(resetDemoUserMock).toHaveBeenCalledTimes(1);
 
     resetDemoUserMock.mockImplementation(() => { throw new Error('baseline gone'); });
diff --git a/server/tests/unit/nest/backup.controller.test.ts b/server/tests/unit/nest/backup.controller.test.ts
index be8c874a5..9954733d7 100644
--- a/server/tests/unit/nest/backup.controller.test.ts
+++ b/server/tests/unit/nest/backup.controller.test.ts
@@ -229,7 +229,7 @@ describe('BackupService (wrapper)', () => {
     await expect(wrapper.restoreBackup('svc.zip')).resolves.toEqual({ success: true });
     expect(backupSvc.restoreBackup).toHaveBeenCalledWith(storage, 'svc.zip');
 
-    wrapper.deleteBackup('svc.zip');
+    await wrapper.deleteBackup('svc.zip');
     expect(backupSvc.deleteBackup).toHaveBeenCalledWith(storage, 'svc.zip');
 
     expect(wrapper.isValidBackupFilename('svc.zip')).toBe(true);
diff --git a/server/tests/unit/nest/budget.controller.test.ts b/server/tests/unit/nest/budget.controller.test.ts
index e33f96685..6764265b2 100644
--- a/server/tests/unit/nest/budget.controller.test.ts
+++ b/server/tests/unit/nest/budget.controller.test.ts
@@ -61,13 +61,13 @@ describe('BudgetController (parity with the legacy /api/trips/:tripId/budget rou
     expect(settlement).toHaveBeenLastCalledWith('5', undefined, 'EUR');
   });
 
-  it('GET /settlement forwards the base query and the trip currency', () => {
+  it('GET /settlement forwards the base query and the trip currency', async () => {
     const settlement = vi.fn().mockReturnValue({ transfers: [] });
     const svc = makeService({
       verifyTripAccess: vi.fn().mockReturnValue({ id: 5, user_id: 1, currency: 'USD' }),
       settlement,
     } as Partial<BudgetService>);
-    new BudgetController(svc).settlement(user, tripRow, '5', 'GBP');
+    await new BudgetController(svc).settlement(user, tripRow, '5', 'GBP');
     expect(settlement).toHaveBeenCalledWith('5', 'GBP', 'USD');
   });
 
diff --git a/server/tests/unit/nest/collections.controller.test.ts b/server/tests/unit/nest/collections.controller.test.ts
index 7d3b28d8e..0b3375dc0 100644
--- a/server/tests/unit/nest/collections.controller.test.ts
+++ b/server/tests/unit/nest/collections.controller.test.ts
@@ -99,7 +99,7 @@ describe('CollectionsController', () => {
       const c = new CollectionsController(svc, new RuntimeEnvService(), storageStub);
       c.savePlace(user, { collection_id: 3, name: 'A' } as never, 'sid');
       expect(svc.savePlace).toHaveBeenCalledWith(1, { collection_id: 3, name: 'A' }, 'sid');
-      c.updatePlace(user, '9', { name: 'B' } as never, 'sid');
+      await c.updatePlace(user, '9', { name: 'B' } as never, 'sid');
       expect(svc.updatePlace).toHaveBeenCalledWith(1, 9, { name: 'B' }, 'sid');
       c.setStatus(user, '9', { status: 'want' } as never, 'sid');
       expect(svc.setStatus).toHaveBeenCalledWith(1, 9, 'want', 'sid');
diff --git a/server/tests/unit/nest/memories.controller.test.ts b/server/tests/unit/nest/memories.controller.test.ts
index 9b565161e..57ec25329 100644
--- a/server/tests/unit/nest/memories.controller.test.ts
+++ b/server/tests/unit/nest/memories.controller.test.ts
@@ -128,19 +128,19 @@ describe('UnifiedMemoriesController (parity with /api/integrations/memories/unif
   });
 
   describe('DELETE /trips/:tripId/photos', () => {
-    it('removes the photo on success', () => {
+    it('removes the photo on success', async () => {
       const removeTripPhoto = vi.fn().mockReturnValue({ data: {} });
       const svc = makeService({ removeTripPhoto });
       const res = makeRes();
-      new UnifiedMemoriesController(svc).removePhoto(user, '5', { photo_id: 11 }, res);
+      await new UnifiedMemoriesController(svc).removePhoto(user, '5', { photo_id: 11 }, res);
       expect(removeTripPhoto).toHaveBeenCalledWith('5', 7, 11);
       expect(res.json).toHaveBeenCalledWith({ success: true });
     });
 
-    it('maps the error envelope', () => {
+    it('maps the error envelope', async () => {
       const svc = makeService({ removeTripPhoto: vi.fn().mockReturnValue({ error: { status: 404, message: 'Photo not found' } }) });
       const res = makeRes();
-      new UnifiedMemoriesController(svc).removePhoto(user, '5', { photo_id: 11 }, res);
+      await new UnifiedMemoriesController(svc).removePhoto(user, '5', { photo_id: 11 }, res);
       expect(res.status).toHaveBeenCalledWith(404);
       expect(res.json).toHaveBeenCalledWith({ error: 'Photo not found' });
     });
diff --git a/server/tests/unit/shutdown.test.ts b/server/tests/unit/shutdown.test.ts
index ab608db20..91164dc66 100644
--- a/server/tests/unit/shutdown.test.ts
+++ b/server/tests/unit/shutdown.test.ts
@@ -94,8 +94,9 @@ describe('runShutdown', () => {
     const deps = makeDeps({ getWsClients: () => [socket] });
     const server = deps.server as unknown as ReturnType<typeof makeServer>;
 
-    // Never resolves on its own: this is the hang #2193 died on.
-    runShutdown('SIGTERM', deps);
+    // Never resolves on its own: this is the hang #2193 died on. Deliberately
+    // not awaited, so the rejection path is logged rather than left unobserved.
+    void runShutdown('SIGTERM', deps).catch((err: unknown) => console.error(err));
     await vi.advanceTimersByTimeAsync(SOCKET_DRAIN_MS);
 
     expect(socket.terminate).toHaveBeenCalled();
@@ -117,7 +118,9 @@ describe('runShutdown', () => {
     // WAL behind for boot-time recovery on every restart.
     const deps = makeDeps({ closeNestApp: vi.fn(() => new Promise<void>(() => {})) });
 
-    runShutdown('SIGTERM', deps);
+    // Deliberately not awaited: the close callback never fires, so this promise
+    // only settles through the forced exit below.
+    void runShutdown('SIGTERM', deps).catch((err: unknown) => console.error(err));
     await vi.advanceTimersByTimeAsync(FORCED_EXIT_MS);
 
     expect(deps.closeDb).toHaveBeenCalledTimes(1);