test(dream): conform dream-dir-source-stamp to canonical PGLite isolation pattern

check:test-isolation R3/R4 flagged the new test file: engine was created
in beforeEach (outside beforeAll) and never disconnected in afterAll.
Switch to the canonical shared-engine pattern (beforeAll create,
beforeEach resetPgliteState, afterAll disconnect) per
test/helpers/reset-pglite.ts.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

skills/article-enrichment/SKILL.md

@@ -85,10 +85,6 @@ gbrain get media/articles/<slug>
 
 # 5. Cross-link entities
 #    For every person/company mentioned, add a timeline back-link.
-#    Mark NEW pages minted for article subjects the reader only reads ABOUT
-#    (not personal contacts) as reference: `gbrain reference <slug>`
-#    (or reference: true in frontmatter). Exempts them from coverage nudges;
-#    they stay searchable. Default for real contacts: do NOT set it.
 ```
 
 ## Quality bar

skills/book-mirror/SKILL.md

@@ -273,13 +273,6 @@ Cross-link entities mentioned in the analysis:
 - For every person the right column references with a brain page, add a
   back-link from `people/<slug>` to the new `media/books/<slug>-personalized`
   page (per `conventions/quality.md` Iron Law).
-- **Mark book figures as reference entities.** Any NEW person/company page you
-  mint for a figure from the book (an author, a historical figure, a company
-  the book discusses) — someone the reader reads ABOUT but doesn't personally
-  interact with — should be flagged: `gbrain reference <slug>` (or
-  `reference: true` in frontmatter). They stay fully searchable/linkable but
-  are exempt from coverage nudges (timeline/links). Skip this for anyone the
-  reader actually knows. Default for normal contacts: do NOT set it.
 
 ## Quality bar (the bar)
 

skills/conventions/reference-entities.md

@@ -1,62 +0,0 @@
-# Convention: Reference entities (canon figures)
-
-Some person/company pages are people/orgs the user **reads about** but does not
-personally interact with — a book's author, a historical figure, a company an
-article discusses (Andy Grove, Kleiner Perkins, Intel…). They are real
-knowledge, worth a page, but they have **no dated history in the user's own
-life**, so the entity coverage metrics (`timeline_coverage`,
-`entity_link_coverage`) flag them as permanently incomplete with no honest fix.
-
-The `reference: true` frontmatter flag resolves this.
-
-## What it does
-
-- A page with `reference: true` is **exempt from the entity coverage metrics
-  only** (`timeline_coverage`, `entity_link_coverage`, and their onboard
-  nudges).
-- It keeps its real `type` (`person` / `company`), so it stays **fully
-  searchable, enrichable, linkable, and edge-resolvable**. NOTHING about
-  retrieval changes — this is the whole reason it's a flag, not a new `type`.
-- It is **opt-in**. Absent / `false` / anything-but-`true` = a normal entity
-  that DOES count toward coverage. **This is the default — do not set it on real
-  contacts.**
-
-## When to set it
-
-Set `reference: true` when the entity is a figure/org the user reads ABOUT, not
-someone they deal with:
-
-- authors and figures discussed in a book (book-mirror) or article
-  (article-enrichment)
-- historical / canon figures imported as reference knowledge
-- companies named only as examples in source material
-
-Do NOT set it for people the user actually meets, emails, or works with — those
-are normal entities whose missing timeline/links is a real, actionable gap.
-
-## How to set it
-
-```bash
-gbrain reference <slug>            # mark as reference
-gbrain reference <slug> --unset    # back to a normal entity
-```
-
-The command writes the flag to BOTH the markdown frontmatter (durable; survives
-re-ingest / engine rebuild — markdown is the source of truth) AND the engine
-JSONB (so coverage reflects it immediately, no re-sync). It's idempotent. You
-can also hand-edit frontmatter (`reference: true`) and re-ingest.
-
-## Why a flag, not a type
-
-A new `type: reference-person` would drop the page out of every
-`type IN ('person','company')` filter — search, enrichment, whoknows, link
-inference — so you'd lose the figure everywhere, not just the metric. The flag
-narrows the change to exactly the coverage denominators and nothing else.
-
-## Implementation
-
-`src/core/reference-flag.ts` — `referenceExclusionSql(alias?)` is the single
-source of truth for the predicate `(frontmatter->>'reference') IS DISTINCT FROM
-'true'`, ANDed into both numerator and denominator at every coverage site
-(getHealth in both engines, onboard/checks.ts, init-nudge.ts). Backed by the GIN
-index on `pages.frontmatter`.

skills/enrich/SKILL.md

@@ -268,18 +268,6 @@ Active items, pending decisions, things to track.
 - **YYYY-MM-DD** | Event description [Source: ...]
 ```
 
-### Reference entities (canon figures)
-
-If the entity is someone/something the user reads ABOUT but does not personally
-interact with — a book author, a historical figure, a company discussed in an
-article — mark the page as reference: `gbrain reference <slug>` (or
-`reference: true` in frontmatter). Reference pages keep their `person`/`company`
-type and stay fully searchable, enrichable, and linkable; they are only exempt
-from the entity coverage nudges (timeline/links) that don't apply to figures
-with no dated history in the user's own life. **Default: do NOT set it** — real
-people and companies the user deals with are normal entities. Full convention:
-`conventions/reference-entities.md`.
-
 ### Step 7: Cross-reference
 
 - Update company pages from person enrichment (and vice versa)

skills/maintain/SKILL.md

@@ -270,11 +270,6 @@ Populate them periodically or after major imports:
 - `gbrain stats` — verify `link_count > 0` and `timeline_entry_count > 0` after extraction.
 - `gbrain health` — review `link_coverage` and `timeline_coverage` percentages
   on entity pages (person/company). Below 50% means more extraction is needed.
-  Note: pages flagged `reference: true` (canon/reference figures the user only
-  reads about) are EXEMPT from these two metrics — if coverage looks stuck
-  because of book/article-imported figures with no real history, mark them with
-  `gbrain reference <slug>` rather than chasing the percentage. See
-  `conventions/reference-entities.md`.
 
 Available link types (use with `gbrain graph-query --type`):
 `attended`, `works_at`, `invested_in`, `founded`, `advises`, `mentions`, `source`.

src/cli.ts

@@ -54,7 +54,7 @@ export function bigintToStringReplacer(_key: string, value: unknown): unknown {
 }
 
 // CLI-only commands that bypass the operation layer
-export const CLI_ONLY = new Set(['init', 'reinit-pglite', 'upgrade', 'post-upgrade', 'check-update', 'integrations', 'publish', 'check-backlinks', 'lint', 'report', 'import', 'export', 'files', 'embed', 'serve', 'call', 'config', 'doctor', 'migrate', 'eval', 'sync', 'extract', 'extract-conversation-facts', 'enrich', 'reference', 'features', 'autopilot', 'graph-query', 'jobs', 'agent', 'apply-migrations', 'skillpack-check', 'skillpack', 'resolvers', 'integrity', 'repair-jsonb', 'orphans', 'sources', 'mounts', 'dream', 'check-resolvable', 'routing-eval', 'skillify', 'smoke-test', 'providers', 'storage', 'repos', 'code-def', 'code-refs', 'reindex', 'reindex-code', 'reindex-frontmatter', 'code-callers', 'code-callees', 'reconcile-links', 'frontmatter', 'auth', 'friction', 'claw-test', 'book-mirror', 'takes', 'think', 'salience', 'anomalies', 'calibration', 'transcripts', 'models', 'remote', 'recall', 'forget', 'edges-backfill', 'cache', 'ze-switch', 'founder', 'brainstorm', 'lsd', 'schema', 'capture', 'onboard', 'conversation-parser', 'status', 'connect', 'skillopt', 'quarantine', 'self-upgrade', 'advisor', 'watch', 'reindex-search-vector']);
+export const CLI_ONLY = new Set(['init', 'reinit-pglite', 'upgrade', 'post-upgrade', 'check-update', 'integrations', 'publish', 'check-backlinks', 'lint', 'report', 'import', 'export', 'files', 'embed', 'serve', 'call', 'config', 'doctor', 'migrate', 'eval', 'sync', 'extract', 'extract-conversation-facts', 'enrich', 'features', 'autopilot', 'graph-query', 'jobs', 'agent', 'apply-migrations', 'skillpack-check', 'skillpack', 'resolvers', 'integrity', 'repair-jsonb', 'orphans', 'sources', 'mounts', 'dream', 'check-resolvable', 'routing-eval', 'skillify', 'smoke-test', 'providers', 'storage', 'repos', 'code-def', 'code-refs', 'reindex', 'reindex-code', 'reindex-frontmatter', 'code-callers', 'code-callees', 'reconcile-links', 'frontmatter', 'auth', 'friction', 'claw-test', 'book-mirror', 'takes', 'think', 'salience', 'anomalies', 'calibration', 'transcripts', 'models', 'remote', 'recall', 'forget', 'edges-backfill', 'cache', 'ze-switch', 'founder', 'brainstorm', 'lsd', 'schema', 'capture', 'onboard', 'conversation-parser', 'status', 'connect', 'skillopt', 'quarantine', 'self-upgrade', 'advisor', 'watch', 'reindex-search-vector']);
 // CLI-only commands whose handlers print their own --help text. These are
 // excluded from the generic short-circuit so detailed per-command and
 // per-subcommand usage stays reachable.
@@ -1652,11 +1652,6 @@ async function handleCliOnly(command: string, args: string[]) {
         await runFiles(engine, args);
         break;
       }
-      case 'reference': {
-        const { runReference } = await import('./commands/reference.ts');
-        await runReference(engine, args);
-        break;
-      }
       case 'embed': {
         const { runEmbed } = await import('./commands/embed.ts');
         await runEmbed(engine, args);

src/commands/autopilot.ts

@@ -38,6 +38,7 @@ import { logSelfUpgrade } from '../core/audit/self-upgrade-audit.ts';
 import { detectInstallMethod } from './upgrade.ts';
 import { evaluateQuietHours } from '../core/minions/quiet-hours.ts';
 import { inspectLock } from '../core/db-lock.ts';
+import { registerCleanup } from '../core/process-cleanup.ts';
 
 /**
  * v0.37.7.0 #1162 — classify autopilot reconnect-loop errors.
@@ -433,6 +434,37 @@ export async function runAutopilot(engine: BrainEngine, args: string[]) {
   let stopping = false;
   let childSupervisor: ChildWorkerSupervisor | null = null;
 
+  // #1872: graceful engine shutdown. On PGLite the cycle steps run INLINE in
+  // this process, so a hard `process.exit` mid-write (systemctl stop →
+  // SIGTERM) kills WASM Postgres with the WAL dirty and can corrupt the
+  // brain. Two exit paths must both close the engine:
+  //   - autopilot's own shutdown() below (owns SIGINT + internal stops like
+  //     max_crashes / cycle-failure-cap), and
+  //   - process-cleanup's SIGTERM handler (installed at cli.ts module load;
+  //     it runs the cleanup registry with a 3s deadline and then exits) —
+  //     which is why closeEngine is ALSO registered there.
+  // closeEngine aborts the in-flight inline cycle (runCycle checks the
+  // signal between phases and threads it into phase sub-work), gives it a
+  // short bounded window to wind down, then disconnects. PGLite's
+  // disconnect() drains the pending query and checkpoints before closing;
+  // a second call is a no-op (disconnect snapshots + nulls the handle), so
+  // both paths firing is safe.
+  const shutdownAbort = new AbortController();
+  let inflightInlineCycle: Promise<unknown> | null = null;
+  const closeEngine = async () => {
+    shutdownAbort.abort(new Error('autopilot shutdown'));
+    if (inflightInlineCycle) {
+      // ponytail: 2s cap keeps us inside process-cleanup's 3s deadline; a
+      // between-phase abort resolves instantly, a mid-phase one may not.
+      await Promise.race([
+        inflightInlineCycle.catch(() => { /* cycle errors already logged by the loop */ }),
+        new Promise((r) => setTimeout(r, 2_000)),
+      ]);
+    }
+    try { await engine.disconnect(); } catch { /* best-effort */ }
+  };
+  const deregisterEngineClose = registerCleanup('autopilot-engine-close', closeEngine);
+
   if (spawnManagedWorker) {
     const cliPath = resolveGbrainCliPath();
     // Cgroup-aware auto-sized RSS watchdog cap (issue #1678). The old flat
@@ -520,6 +552,10 @@ export async function runAutopilot(engine: BrainEngine, args: string[]) {
         childSupervisor.killChild('SIGKILL');
       }
     }
+    // #1872: abort the in-flight inline cycle and close the engine BEFORE
+    // process.exit — a hard exit mid-write corrupts PGLite's WASM Postgres.
+    await closeEngine();
+    deregisterEngineClose();
     try { unlinkSync(lockPath); } catch { /* already gone */ }
     process.exit(0);
   };
@@ -1008,16 +1044,21 @@ export async function runAutopilot(engine: BrainEngine, args: string[]) {
       // path's phase set). Now both converge on the same primitive.
       try {
         const { runCycle } = await import('../core/cycle.ts');
-        const report = await runCycle(engine, {
+        // #1872: track the promise so closeEngine can drain it on shutdown,
+        // and pass the abort signal so the cycle winds down between phases.
+        const cyclePromise = runCycle(engine, {
           brainDir: repoPath,
           // Autopilot daemon path: pulls by default (matches
           // pre-v0.17 autopilot behavior). CLI dream defaults false
           // for cron safety; that choice is scoped to dream only.
           pull: true,
+          signal: shutdownAbort.signal,
           yieldBetweenPhases: async () => {
             await new Promise(r => setImmediate(r));
           },
         });
+        inflightInlineCycle = cyclePromise;
+        const report = await cyclePromise.finally(() => { inflightInlineCycle = null; });
         // Only 'failed' (every attempted phase failed) trips the autopilot
         // circuit breaker. 'partial' means at least one phase warned or
         // failed while others ran — that's a soft signal, not a fatal

src/commands/dream.ts

@@ -26,6 +26,7 @@
 import type { BrainEngine } from '../core/engine.ts';
 import {
   runCycle,
+  resolveSourceForDir,
   ALL_PHASES,
   type CyclePhase,
   type CycleReport,
@@ -380,9 +381,9 @@ Options:
 
   --source <id>       Scope the cycle to one source so doctor's
                       cycle_freshness check sees a fresh stamp on
-                      completion. Without this, gbrain dream's
-                      timestamp never lands and federated brains
-                      see "stale cycle" forever.
+                      completion. When omitted, gbrain derives the
+                      source from --dir / the configured checkout
+                      when it matches a source's local_path (#1869).
   --source-id <id>    Alias for --source. Matches the v0.37.7.0+
                       naming used by import/extract/graph-query.
 
@@ -634,6 +635,25 @@ export async function runDream(engine: BrainEngine | null, args: string[]): Prom
     );
     process.exit(1);
   }
+
+  // #1869: a path-scoped run (--dir, or the configured sync.repo_path) whose
+  // directory matches a registered source's local_path IS that source's cycle
+  // — derive the source id so runCycle writes last_source_cycle_at /
+  // last_full_cycle_at on success and doctor's cycle_freshness check stops
+  // reading perpetually stale. Explicit --source still wins (resolved above).
+  // Fixed here at the command level, NOT in runCycle's stamp gate, so legacy
+  // global callers (autopilot-global-maintenance runs GLOBAL_PHASES with a
+  // brainDir and no sourceId) can't falsely stamp per-source freshness.
+  // A derived match on an archived source is skipped silently (falls back to
+  // legacy unscoped behavior) — stamping it would mask staleness on restore,
+  // mirroring the explicit --source archived guard above.
+  if (resolvedSourceId === undefined && engine !== null && brainDir !== null) {
+    const derived = await resolveSourceForDir(engine, brainDir);
+    if (derived !== undefined) {
+      const src = await fetchSource(engine, derived);
+      if (src?.archived !== true) resolvedSourceId = derived;
+    }
+  }
   // ─── issue #1678: bounded single-hold extract_atoms drain ──────────
   if (opts.drain) {
     if (engine === null) {

src/commands/reference.ts

@@ -1,130 +0,0 @@
-// gbrain reference <slug> [--unset] [--brain <dir>] [--json]
-//
-// Mark (or unmark) a page as a reference-only entity. A reference page keeps its
-// real type (person/company) — fully searchable/enrichable/linkable — but is
-// exempt from the entity coverage metrics (timeline_coverage,
-// entity_link_coverage). See src/core/reference-flag.ts for the rationale.
-//
-// Durability: the flag is written to BOTH the markdown frontmatter (source of
-// truth; survives re-ingest / engine rebuild) AND the engine `pages.frontmatter`
-// JSONB (so the metric reflects it immediately, no re-sync needed).
-
-import { existsSync, readFileSync, writeFileSync } from 'node:fs';
-import { isAbsolute, join, resolve } from 'node:path';
-import { setCliExitVerdict } from '../core/cli-force-exit.ts';
-import type { BrainEngine } from '../core/engine.ts';
-import { REFERENCE_FRONTMATTER_KEY } from '../core/reference-flag.ts';
-import { resolveSourceId } from '../core/source-resolver.ts';
-
-/** Insert/replace/remove `reference: true` in a markdown frontmatter block.
- *  Minimal-diff: only the one line changes; key order is otherwise preserved. */
-export function applyReferenceFrontmatter(content: string, on: boolean): string {
-  const keyLine = `${REFERENCE_FRONTMATTER_KEY}: true`;
-  const block = content.match(/^---\n([\s\S]*?)\n---/);
-
-  if (!block) {
-    // No frontmatter. Nothing to remove; if setting, prepend a block.
-    if (!on) return content;
-    return `---\n${keyLine}\n---\n\n${content}`;
-  }
-
-  let fm = block[1];
-  const hasKey = new RegExp(`^${REFERENCE_FRONTMATTER_KEY}:.*$`, 'm').test(fm);
-
-  if (on) {
-    fm = hasKey
-      ? fm.replace(new RegExp(`^${REFERENCE_FRONTMATTER_KEY}:.*$`, 'm'), keyLine)
-      : `${fm}\n${keyLine}`;
-  } else {
-    if (!hasKey) return content;
-    fm = fm.replace(new RegExp(`^${REFERENCE_FRONTMATTER_KEY}:.*$\\n?`, 'm'), '');
-  }
-
-  // Function replacement so YAML chars ($, & …) in fm aren't treated as
-  // replacement patterns.
-  return content.replace(/^---\n[\s\S]*?\n---/, () => `---\n${fm}\n---`);
-}
-
-function parseArgs(args: string[]): { slug?: string; unset: boolean; json: boolean; brain?: string; source?: string } {
-  let slug: string | undefined;
-  let unset = false;
-  let json = false;
-  let brain: string | undefined;
-  let source: string | undefined;
-  for (let i = 0; i < args.length; i++) {
-    const a = args[i];
-    if (a === '--unset') unset = true;
-    else if (a === '--json') json = true;
-    else if (a === '--brain' || a === '--dir') brain = args[++i];
-    else if (a === '--source') source = args[++i];
-    else if (!a.startsWith('--') && !slug) slug = a;
-  }
-  return { slug, unset, json, brain, source };
-}
-
-async function resolveBrainDir(engine: BrainEngine, explicit?: string): Promise<string | null> {
-  if (explicit) return resolve(explicit);
-  const configured = await engine.getConfig('sync.repo_path');
-  if (configured && existsSync(configured)) return resolve(configured);
-  return null;
-}
-
-export async function runReference(engine: BrainEngine, args: string[]): Promise<void> {
-  const { slug, unset, json, brain, source } = parseArgs(args);
-  if (!slug) {
-    console.error('Usage: gbrain reference <slug> [--unset] [--source <id>] [--brain <dir>] [--json]');
-    setCliExitVerdict(2);
-    return;
-  }
-
-  const brainDir = await resolveBrainDir(engine, brain);
-  if (!brainDir) {
-    console.error('reference: could not resolve brain dir. Pass --brain <dir> or set sync.repo_path.');
-    setCliExitVerdict(1);
-    return;
-  }
-
-  const rel = slug.endsWith('.md') ? slug : `${slug}.md`;
-  const filePath = isAbsolute(rel) ? rel : join(brainDir, rel);
-  if (!existsSync(filePath)) {
-    console.error(`reference: page not found on disk: ${filePath}`);
-    setCliExitVerdict(1);
-    return;
-  }
-
-  // 1) Durable: edit the markdown frontmatter.
-  const before = readFileSync(filePath, 'utf8');
-  const after = applyReferenceFrontmatter(before, !unset);
-  const fileChanged = after !== before;
-  if (fileChanged) writeFileSync(filePath, after, 'utf8');
-
-  // 2) Immediate: update the engine frontmatter JSONB so the metric reflects it
-  //    without waiting for a re-sync. Scoped to (source_id, slug) — slug is only
-  //    unique per source, so a bare-slug UPDATE would clobber same-named pages
-  //    in every other source. Resolve the source from the brain dir (tier-4
-  //    local_path match) unless --source / GBRAIN_SOURCE overrides.
-  const cleanSlug = slug.replace(/\.md$/, '');
-  const sourceId = await resolveSourceId(engine, source ?? null, brainDir);
-  if (unset) {
-    await engine.executeRaw(
-      `UPDATE pages SET frontmatter = frontmatter - '${REFERENCE_FRONTMATTER_KEY}' WHERE slug = $1 AND source_id = $2`,
-      [cleanSlug, sourceId],
-    );
-  } else {
-    await engine.executeRaw(
-      `UPDATE pages SET frontmatter = jsonb_set(COALESCE(frontmatter, '{}'::jsonb), '{${REFERENCE_FRONTMATTER_KEY}}', 'true'::jsonb) WHERE slug = $1 AND source_id = $2`,
-      [cleanSlug, sourceId],
-    );
-  }
-
-  const result = { slug: cleanSlug, source_id: sourceId, reference: !unset, file_changed: fileChanged, file: filePath };
-  if (json) {
-    console.log(JSON.stringify(result));
-  } else {
-    const verb = unset ? 'unmarked' : 'marked';
-    console.log(`${verb} ${cleanSlug} as reference=${!unset}${fileChanged ? '' : ' (frontmatter already current)'}`);
-    if (!unset) {
-      console.log('  → exempt from timeline_coverage / entity_link_coverage; still fully searchable & linkable.');
-    }
-  }
-}

src/core/cycle.ts

@@ -855,8 +855,16 @@ interface SyncPhaseResult extends PhaseResult {
  * Resolve the source id for a brain directory by looking up the sources
  * table. Returns undefined when no registered source matches (falls back
  * to pre-v0.18 global config.sync.* keys).
+ *
+ * Exported for dream.ts (#1869): a `gbrain dream --dir <path>` run whose
+ * path matches a registered source's local_path is a per-source cycle in
+ * everything but name, so dream derives the source id up front and passes
+ * it as opts.sourceId — landing the freshness stamp without changing
+ * runCycle's stamp/lock semantics for legacy global callers (the
+ * autopilot-global-maintenance handler runs GLOBAL_PHASES with a brainDir
+ * and MUST NOT stamp per-source freshness; see rejected PR #2549).
  */
-async function resolveSourceForDir(
+export async function resolveSourceForDir(
   engine: BrainEngine,
   brainDir: string | null,
 ): Promise<string | undefined> {

src/core/onboard/checks.ts

@@ -18,7 +18,6 @@
 import type { BrainEngine } from '../engine.ts';
 import type { RemediationStep } from '../remediation-step.ts';
 import { makeRemediationStep } from '../remediation-step.ts';
-import { referenceExclusionSql } from '../reference-flag.ts';
 
 /** Shared shape returned by all four checks. */
 export interface OnboardCheckResult {
@@ -121,8 +120,7 @@ export async function checkEntityLinkCoverage(
     engine,
     `SELECT COUNT(*) AS count FROM pages
        WHERE type IN ('person', 'company', 'organization', 'entity')
-         AND deleted_at IS NULL
-         AND ${referenceExclusionSql()}`,
+         AND deleted_at IS NULL`,
   );
 
   if (totalEntities === 0) {
@@ -146,7 +144,6 @@ export async function checkEntityLinkCoverage(
        SELECT p.id FROM pages p ${sampleClause}
        WHERE p.type IN ('person', 'company', 'organization', 'entity')
          AND p.deleted_at IS NULL
-         AND ${referenceExclusionSql('p')}
          AND EXISTS (SELECT 1 FROM links l WHERE l.to_page_id = p.id)
      ) sub`,
   );
@@ -218,8 +215,7 @@ export async function checkTimelineCoverage(
     engine,
     `SELECT COUNT(*) AS count FROM pages
        WHERE type IN ('person', 'company', 'organization', 'entity')
-         AND deleted_at IS NULL
-         AND ${referenceExclusionSql()}`,
+         AND deleted_at IS NULL`,
   );
 
   if (totalEntities === 0) {
@@ -241,7 +237,6 @@ export async function checkTimelineCoverage(
        SELECT p.id FROM pages p ${sampleClause}
        WHERE p.type IN ('person', 'company', 'organization', 'entity')
          AND p.deleted_at IS NULL
-         AND ${referenceExclusionSql('p')}
          AND EXISTS (SELECT 1 FROM timeline_entries t WHERE t.page_id = p.id)
      ) sub`,
   );

src/core/onboard/init-nudge.ts

@@ -14,7 +14,6 @@
 // also short-circuits (CI/scripted callers see nothing).
 
 import type { BrainEngine } from '../engine.ts';
-import { referenceExclusionSql } from '../reference-flag.ts';
 
 const NUDGE_BUDGET_MS = 3000;
 
@@ -58,8 +57,7 @@ export async function runInitNudge(engine: BrainEngine): Promise<void> {
       engine.executeRaw<{ count: string | number }>(
         `SELECT COUNT(*) AS count FROM pages
            WHERE type IN ('person', 'company', 'organization', 'entity')
-             AND deleted_at IS NULL
-             AND ${referenceExclusionSql()}`,
+             AND deleted_at IS NULL`,
         [],
         { signal: controller.signal },
       ),
@@ -67,7 +65,6 @@ export async function runInitNudge(engine: BrainEngine): Promise<void> {
         `SELECT COUNT(*) AS count FROM pages p
            WHERE p.type IN ('person', 'company', 'organization', 'entity')
              AND p.deleted_at IS NULL
-             AND ${referenceExclusionSql('p')}
              AND EXISTS (SELECT 1 FROM links l WHERE l.to_page_id = p.id)`,
         [],
         { signal: controller.signal },
@@ -76,7 +73,6 @@ export async function runInitNudge(engine: BrainEngine): Promise<void> {
         `SELECT COUNT(*) AS count FROM pages p
            WHERE p.type IN ('person', 'company', 'organization', 'entity')
              AND p.deleted_at IS NULL
-             AND ${referenceExclusionSql('p')}
              AND EXISTS (SELECT 1 FROM timeline_entries t WHERE t.page_id = p.id)`,
         [],
         { signal: controller.signal },

src/core/pglite-engine.ts

@@ -23,7 +23,6 @@ import { runMigrations } from './migrate.ts';
 import { PGLITE_SCHEMA_SQL, getPGLiteSchema } from './pglite-schema.ts';
 import { DEFAULT_EMBEDDING_MODEL, DEFAULT_EMBEDDING_DIMENSIONS } from './ai/defaults.ts';
 import { DELETE_BATCH_SIZE } from './engine-constants.ts';
-import { referenceExclusionSql } from './reference-flag.ts';
 import { MARKDOWN_CHUNKER_VERSION } from './chunkers/recursive.ts';
 import { acquireLock, releaseLock, type LockHandle } from './pglite-lock.ts';
 import { getFtsLanguage } from './fts-language.ts';
@@ -5203,7 +5202,6 @@ export class PGLiteEngine implements BrainEngine {
     const { rows: [h] } = await this.db.query(`
       WITH entity_pages AS (
         SELECT id, slug FROM pages WHERE type IN ('person', 'company')
-          AND ${referenceExclusionSql()}
       )
       SELECT
         (SELECT count(*) FROM pages) as page_count,

src/core/postgres-engine.ts

@@ -5320,12 +5320,7 @@ export class PostgresEngine implements BrainEngine {
     // is working as intended, not an orphan.
     const [h] = await sql`
       WITH entity_pages AS (
-        -- reference:true pages are exempt from coverage metrics.
-        -- Inlined (postgres.js tagged-template interpolation = bound param,
-        -- not raw SQL); keep in sync with referenceExclusionSql() in
-        -- reference-flag.ts.
         SELECT id, slug FROM pages WHERE type IN ('person', 'company')
-          AND (frontmatter->>'reference') IS DISTINCT FROM 'true'
       )
       SELECT
         (SELECT count(*) FROM pages) as page_count,

src/core/reference-flag.ts

@@ -1,37 +0,0 @@
-// Reference / canon entities.
-//
-// A page with frontmatter `reference: true` is a reference-only entity — a
-// figure or organization imported from a book / article / external source that
-// the user reads ABOUT but does not actively interact with (e.g. Andy Grove,
-// Kleiner Perkins). It keeps its real `type` (`person` / `company`), so it stays
-// fully searchable, enrichable, linkable, and edge-resolvable — NOTHING about
-// retrieval changes.
-//
-// The ONLY behavior it opts out of is the entity *coverage* metrics
-// (`timeline_coverage`, `entity_link_coverage` + their onboard-nudge mirrors).
-// Those metrics nudge "this entity should accumulate dated history / inbound
-// links"; that assumption is right for people you actually deal with and wrong
-// for canon imports, which have no dated events in the user's life. Excluding
-// them keeps the metric honest and actionable instead of permanently red.
-//
-// Opt-in: absent / false / anything-but-true = normal entity (the default).
-// Set via `gbrain reference <slug>` (or hand-edit frontmatter).
-
-export const REFERENCE_FRONTMATTER_KEY = 'reference';
-
-/**
- * SQL predicate (true for NON-reference pages) to AND into entity-coverage
- * denominators AND numerators so the ratio stays consistent. JSONB `->>` yields
- * text; `IS DISTINCT FROM 'true'` treats absent (NULL) and every non-true value
- * as a normal counted entity. Backed by the GIN index on `pages.frontmatter`.
- *
- * @param alias optional table alias (e.g. 'p' for `pages p`); omit for bare `pages`.
- *
- * NOTE: postgres-engine.ts uses a postgres.js tagged template where `${}` is a
- * bound parameter, not raw SQL, so it inlines this predicate literally — keep
- * the two in sync.
- */
-export function referenceExclusionSql(alias = ''): string {
-  const col = alias ? `${alias}.frontmatter` : 'frontmatter';
-  return `(${col}->>'${REFERENCE_FRONTMATTER_KEY}') IS DISTINCT FROM 'true'`;
-}

test/autopilot-shutdown-engine-close.test.ts

@@ -0,0 +1,63 @@
+/**
+ * #1872 — autopilot SIGTERM/SIGINT must close the engine before exit.
+ *
+ * On PGLite the cycle steps run INLINE in the autopilot process, so a hard
+ * `process.exit` mid-write (systemctl stop → SIGTERM) kills WASM Postgres
+ * with the WAL dirty and can corrupt the brain. Two exit paths must both
+ * close the engine:
+ *
+ *   - autopilot's own shutdown() (owns SIGINT + internal stops like
+ *     max_crashes / cycle-failure-cap), and
+ *   - process-cleanup's SIGTERM handler (installed at cli.ts module load,
+ *     which exits within its 3s cleanup deadline) — reached via the
+ *     registered 'autopilot-engine-close' cleanup callback.
+ *
+ * Because the shutdown path is deep inside `runAutopilot()` (a long-running
+ * daemon loop that ends in process.exit), a behavioral test would have to
+ * spawn + signal a real daemon. Following the established precedent
+ * (test/autopilot-supervisor-wiring.test.ts, test/autopilot-fanout-wiring.test.ts),
+ * these static-shape regressions pin the load-bearing wiring instead.
+ */
+import { describe, expect, it } from 'bun:test';
+import { readFileSync } from 'fs';
+import { join } from 'path';
+
+const AUTOPILOT_SRC = readFileSync(
+  join(import.meta.dir, '..', 'src', 'commands', 'autopilot.ts'),
+  'utf8',
+);
+
+describe('autopilot.ts graceful engine shutdown (#1872)', () => {
+  it('registers an engine-close callback in the process-cleanup registry (SIGTERM path)', () => {
+    // process-cleanup owns SIGTERM (installed at cli.ts:10) and hard-exits
+    // after its cleanup pass; without this registration the engine is never
+    // closed on `systemctl stop`.
+    expect(AUTOPILOT_SRC).toContain(
+      "import { registerCleanup } from '../core/process-cleanup.ts';",
+    );
+    expect(AUTOPILOT_SRC).toContain(
+      "registerCleanup('autopilot-engine-close', closeEngine)",
+    );
+  });
+
+  it('closeEngine aborts the in-flight inline cycle then disconnects the engine', () => {
+    // Abort first (runCycle checks the signal between phases and threads it
+    // into phase sub-work), bounded drain, then disconnect.
+    expect(AUTOPILOT_SRC).toMatch(
+      /const closeEngine = async \(\) => \{[\s\S]{0,900}shutdownAbort\.abort\([\s\S]{0,900}engine\.disconnect\(\)/,
+    );
+  });
+
+  it('the inline runCycle call carries the shutdown abort signal and is tracked as in-flight', () => {
+    // PGLite / --inline path: the cycle runs in-process, so shutdown must be
+    // able to (a) signal it to wind down and (b) await it before closing.
+    expect(AUTOPILOT_SRC).toMatch(/signal:\s*shutdownAbort\.signal/);
+    expect(AUTOPILOT_SRC).toMatch(/inflightInlineCycle\s*=\s*cyclePromise/);
+  });
+
+  it('shutdown() awaits closeEngine() before process.exit(0) (SIGINT + internal-stop path)', () => {
+    expect(AUTOPILOT_SRC).toMatch(
+      /await closeEngine\(\);[\s\S]{0,400}process\.exit\(0\)/,
+    );
+  });
+});

test/dream-dir-source-stamp.test.ts

@@ -0,0 +1,99 @@
+/**
+ * #1869 — `gbrain dream --dir <path>` stamps cycle freshness when the path
+ * matches a registered source's local_path.
+ *
+ * Pre-fix, only `--source <id>` runs wrote last_source_cycle_at /
+ * last_full_cycle_at (runCycle's stamp gate reads opts.sourceId, and dream
+ * never derived one from --dir), so a path-scoped brain showed doctor's
+ * cycle_freshness as perpetually stale.
+ *
+ * The fix lives in dream.ts (derive the source id from the resolved brain
+ * dir via resolveSourceForDir), NOT in runCycle's stamp gate — a runCycle-
+ * wide change would make the autopilot-global-maintenance handler (global
+ * phases, brainDir set, no sourceId) falsely stamp per-source freshness
+ * (the #2194 poisoning class; see rejected PR #2549).
+ *
+ * Same real-PGLite/no-mocks discipline as test/dream.test.ts; same
+ * GBRAIN_HOME isolation as test/cycle-last-full-cycle-at.test.ts (the
+ * cycle's PGLite file lock lives under ~/.gbrain).
+ */
+import { describe, test, expect, beforeAll, afterAll, beforeEach, afterEach } from 'bun:test';
+import { mkdtempSync, rmSync } from 'fs';
+import { join } from 'path';
+import { tmpdir } from 'os';
+import { PGLiteEngine } from '../src/core/pglite-engine.ts';
+import { resetPgliteState } from './helpers/reset-pglite.ts';
+import { runDream } from '../src/commands/dream.ts';
+import { withEnv } from './helpers/with-env.ts';
+
+let engine: PGLiteEngine;
+let brainDir: string;
+let gbrainHome: string;
+
+beforeAll(async () => {
+  engine = new PGLiteEngine();
+  await engine.connect({});
+  await engine.initSchema();
+}, 60_000);
+
+afterAll(async () => {
+  await engine.disconnect();
+});
+
+beforeEach(async () => {
+  await resetPgliteState(engine);
+  brainDir = mkdtempSync(join(tmpdir(), 'gbrain-dream-stamp-'));
+  gbrainHome = mkdtempSync(join(tmpdir(), 'gbrain-dream-stamp-home-'));
+}, 60_000);
+
+afterEach(() => {
+  rmSync(brainDir, { recursive: true, force: true });
+  rmSync(gbrainHome, { recursive: true, force: true });
+});
+
+async function seedSource(id: string, archived = false): Promise<void> {
+  await engine.executeRaw(
+    `INSERT INTO sources (id, name, local_path, config, archived, created_at)
+     VALUES ($1, $2, $3, '{}'::jsonb, $4, NOW())`,
+    [id, id, brainDir, archived],
+  );
+}
+
+async function readLastFullCycleAt(sourceId: string): Promise<string | null> {
+  const rows = await engine.executeRaw<{ config: Record<string, unknown> | null }>(
+    `SELECT config FROM sources WHERE id = $1`,
+    [sourceId],
+  );
+  const raw = rows[0]?.config?.last_full_cycle_at;
+  return typeof raw === 'string' ? raw : null;
+}
+
+describe('gbrain dream --dir <path> freshness stamp (#1869)', () => {
+  test('--dir matching a source local_path stamps last_full_cycle_at', async () => {
+    await withEnv({ GBRAIN_HOME: gbrainHome }, async () => {
+      await seedSource('path-scoped');
+      expect(await readLastFullCycleAt('path-scoped')).toBeNull();
+
+      const report = await runDream(engine, ['--dir', brainDir, '--phase', 'lint', '--json']);
+      expect(report).toBeTruthy();
+      if (report) expect(['ok', 'clean']).toContain(report.status);
+
+      // Pre-fix this stays null forever: dream never passed a sourceId, so
+      // runCycle's stamp gate skipped the write.
+      expect(await readLastFullCycleAt('path-scoped')).not.toBeNull();
+    });
+  }, 60_000);
+
+  test('--dir matching an ARCHIVED source does not stamp it', async () => {
+    await withEnv({ GBRAIN_HOME: gbrainHome }, async () => {
+      await seedSource('mothballed', true);
+
+      const report = await runDream(engine, ['--dir', brainDir, '--phase', 'lint', '--json']);
+      expect(report).toBeTruthy();
+
+      // Stamping an archived source would mask data staleness when it is
+      // later restored (mirrors the explicit --source archived guard).
+      expect(await readLastFullCycleAt('mothballed')).toBeNull();
+    });
+  }, 60_000);
+});

test/dream.test.ts

@@ -562,12 +562,22 @@ describe('runDream — --source / --source-id (v0.41.13)', () => {
 
   // ─── Back-compat: bare `gbrain dream` does NOT write per-source stamp ─
 
-  test('gbrain dream (no --source) leaves all sources untouched (back-compat regression)', async () => {
-    await seedSource('alpha');
-    await seedSource('beta');
+  test('gbrain dream (no --source) stamps only the source whose local_path matches --dir (#1869)', async () => {
+    // Pre-#1869 this asserted NO source was ever stamped without an explicit
+    // --source — which is exactly the bug: a path-scoped `gbrain dream --dir`
+    // run never landed a freshness stamp and doctor's cycle_freshness stayed
+    // stale forever. New truth: the source whose local_path matches the
+    // resolved brain dir is derived and stamped; unrelated sources stay
+    // untouched (cross-source isolation).
+    await seedSource('alpha'); // local_path = repo → derived + stamped
+    await engine.executeRaw(
+      `INSERT INTO sources (id, name, local_path, config, archived, created_at)
+       VALUES ($1, $2, $3, '{}'::jsonb, false, NOW())`,
+      ['beta', 'beta', '/somewhere/else'],
+    );
     const report = await runDream(engine, ['--dir', repo, '--phase', 'lint', '--json']);
     expect(report).toBeTruthy();
-    expect(await readLastFullCycleAt('alpha')).toBeNull();
+    expect(await readLastFullCycleAt('alpha')).not.toBeNull();
     expect(await readLastFullCycleAt('beta')).toBeNull();
   }, 60_000);
 

test/reference-flag.test.ts

@@ -1,154 +0,0 @@
-import { describe, expect, test } from 'bun:test';
-import { referenceExclusionSql, REFERENCE_FRONTMATTER_KEY } from '../src/core/reference-flag.ts';
-import { applyReferenceFrontmatter } from '../src/commands/reference.ts';
-
-describe('referenceExclusionSql', () => {
-  test('bare pages (no alias)', () => {
-    expect(referenceExclusionSql()).toBe(`(frontmatter->>'reference') IS DISTINCT FROM 'true'`);
-  });
-  test('aliased', () => {
-    expect(referenceExclusionSql('p')).toBe(`(p.frontmatter->>'reference') IS DISTINCT FROM 'true'`);
-  });
-  test('key constant', () => {
-    expect(REFERENCE_FRONTMATTER_KEY).toBe('reference');
-  });
-});
-
-describe('applyReferenceFrontmatter', () => {
-  const page = `---\ntitle: Andy Grove\ntype: person\ntags: []\n---\n\n# Andy Grove\n\nBody.`;
-
-  test('adds reference: true to an existing frontmatter block', () => {
-    const out = applyReferenceFrontmatter(page, true);
-    expect(out).toContain('reference: true');
-    expect(out).toContain('type: person');   // other keys preserved
-    expect(out).toContain('# Andy Grove');    // body preserved
-  });
-
-  test('is idempotent — does not duplicate the key', () => {
-    const once = applyReferenceFrontmatter(page, true);
-    const twice = applyReferenceFrontmatter(once, true);
-    expect(twice).toBe(once);
-    expect(twice.match(/reference: true/g)).toHaveLength(1);
-  });
-
-  test('replaces a stale reference: false with true', () => {
-    const off = `---\ntype: person\nreference: false\n---\n\nBody.`;
-    const out = applyReferenceFrontmatter(off, true);
-    expect(out).toContain('reference: true');
-    expect(out).not.toContain('reference: false');
-  });
-
-  test('--unset removes the key', () => {
-    const on = applyReferenceFrontmatter(page, true);
-    const off = applyReferenceFrontmatter(on, false);
-    expect(off).not.toContain('reference:');
-    expect(off).toContain('type: person');
-  });
-
-  test('--unset on a page without the key is a no-op', () => {
-    expect(applyReferenceFrontmatter(page, false)).toBe(page);
-  });
-
-  test('setting on a frontmatter-less page prepends a block', () => {
-    const raw = '# Just a heading\n\nNo frontmatter here.';
-    const out = applyReferenceFrontmatter(raw, true);
-    expect(out.startsWith('---\nreference: true\n---\n')).toBe(true);
-    expect(out).toContain('# Just a heading');
-  });
-
-  test('preserves body containing YAML-special chars', () => {
-    const tricky = `---\ntype: person\n---\n\nText with $& and $1 literals.`;
-    const out = applyReferenceFrontmatter(tricky, true);
-    expect(out).toContain('Text with $& and $1 literals.');
-    expect(out).toContain('reference: true');
-  });
-});
-
-// ── e2e: getHealth exemption + (source_id, slug)-scoped JSONB write ─────────
-
-import { afterAll, beforeAll } from 'bun:test';
-import * as fs from 'node:fs';
-import * as os from 'node:os';
-import * as path from 'node:path';
-import { PGLiteEngine } from '../src/core/pglite-engine.ts';
-import { runReference } from '../src/commands/reference.ts';
-import { withEnv } from './helpers/with-env.ts';
-
-describe('reference flag e2e (PGLite)', () => {
-  let engine: PGLiteEngine;
-  let brainDir: string;
-
-  beforeAll(async () => {
-    engine = new PGLiteEngine();
-    await engine.connect({ database_url: '' });
-    await engine.initSchema();
-
-    brainDir = fs.mkdtempSync(path.join(os.tmpdir(), 'gbrain-ref-'));
-    fs.mkdirSync(path.join(brainDir, 'people'), { recursive: true });
-    fs.writeFileSync(
-      path.join(brainDir, 'people/andy-grove.md'),
-      '---\ntitle: Andy Grove\ntype: person\n---\n\n# Andy Grove\n',
-      'utf8',
-    );
-
-    await engine.executeRaw(
-      `INSERT INTO sources (id, name, local_path, config, created_at)
-       VALUES ('src-a', 'a', $1, '{}'::jsonb, now()), ('src-b', 'b', NULL, '{}'::jsonb, now())`,
-      [brainDir],
-    );
-    // Same slug in BOTH sources — the write must only touch src-a.
-    await engine.putPage('people/andy-grove', {
-      type: 'person', title: 'Andy Grove', compiled_truth: 'canon figure',
-    }, { sourceId: 'src-a' });
-    await engine.putPage('people/andy-grove', {
-      type: 'person', title: 'Andy Grove', compiled_truth: 'other-source twin',
-    }, { sourceId: 'src-b' });
-    // A normal contact WITH a timeline entry, so coverage has a live numerator.
-    const contact = await engine.putPage('people/alice-example', {
-      type: 'person', title: 'Alice Example', compiled_truth: 'real contact',
-    }, { sourceId: 'src-a' });
-    await engine.executeRaw(
-      `INSERT INTO timeline_entries (page_id, date, summary) VALUES ($1, '2026-01-01', 'met')`,
-      [contact.id],
-    );
-  });
-
-  afterAll(async () => {
-    await engine.disconnect();
-    fs.rmSync(brainDir, { recursive: true, force: true });
-  });
-
-  test('runReference scopes the JSONB write to the resolved (source_id, slug)', async () => {
-    await withEnv({ GBRAIN_SOURCE: undefined }, () =>
-      runReference(engine, ['people/andy-grove', '--brain', brainDir]));
-
-    const rows = await engine.executeRaw<{ source_id: string; ref: string | null }>(
-      `SELECT source_id, frontmatter->>'reference' AS ref FROM pages WHERE slug = 'people/andy-grove' ORDER BY source_id`,
-    );
-    expect(rows).toEqual([
-      { source_id: 'src-a', ref: 'true' },
-      { source_id: 'src-b', ref: null },   // twin in the other source untouched
-    ]);
-    // Durable half: frontmatter on disk got the flag too.
-    expect(fs.readFileSync(path.join(brainDir, 'people/andy-grove.md'), 'utf8'))
-      .toContain('reference: true');
-  });
-
-  test('getHealth exempts reference pages from timeline/link coverage', async () => {
-    const health = await engine.getHealth();
-    // 3 person pages; the 2 reference-less twins would drag coverage to 1/3.
-    // With the src-a twin marked reference, denominator = 2 (alice + src-b twin).
-    expect(health.timeline_coverage).toBeCloseTo(0.5);
-  });
-
-  test('unset restores the page to a normal counted entity', async () => {
-    await withEnv({ GBRAIN_SOURCE: undefined }, () =>
-      runReference(engine, ['people/andy-grove', '--unset', '--brain', brainDir]));
-    const rows = await engine.executeRaw<{ ref: string | null }>(
-      `SELECT frontmatter->>'reference' AS ref FROM pages WHERE slug = 'people/andy-grove' AND source_id = 'src-a'`,
-    );
-    expect(rows[0].ref).toBeNull();
-    const health = await engine.getHealth();
-    expect(health.timeline_coverage).toBeCloseTo(1 / 3);
-  });
-});