fix(facts): fold visibility tier into hot-memory meta cache key

trustedFactReads is re-read from config on every stdio tool call, so the
reader's visibility tier can now flip within one server process. The
meta-hook cache key (source, session, allow-list hash) didn't capture it,
so a mid-session opt-out of facts.trust_local_reads could keep serving a
private-inclusive cached payload for the 30s TTL. Compute the visibility
filter before the cache lookup and append the tier to the key, restoring
the header's cross-tier no-bleed invariant.

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/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/config.ts

@@ -908,6 +908,10 @@ export const KNOWN_CONFIG_KEYS: readonly string[] = [
   'facts.extraction_model',
   // #2113: output-token cap for the per-turn facts extractor (default 4000).
   'facts.extraction_max_tokens',
+  // Owner opt-in: let the local stdio MCP pipe read this owner's private facts
+  // (find_trajectory / recall). Default off; HTTP transport ignores it. See
+  // src/core/facts/reader-trust.ts.
+  'facts.trust_local_reads',
   // Dream cycle config
   'dream.synthesize.session_corpus_dir',
   'dream.synthesize.meeting_transcripts_dir',

src/core/engine.ts

@@ -591,6 +591,8 @@ export interface TrajectoryOpts {
   sourceIds?: string[];
   /** When true, filters to visibility='world' only. Set by MCP layer from ctx.remote. */
   remote?: boolean;
+  /** Owner opt-in: read private facts despite `remote`. See facts/reader-trust.ts. */
+  trustedFactReads?: boolean;
   /** Metric filter. When set, only facts with this canonical metric label participate. */
   metric?: string;
   /**

src/core/facts/meta-hook.ts

@@ -17,6 +17,7 @@
 import type { OperationContext } from './../operations.ts';
 import type { FactRow } from './../engine.ts';
 import { effectiveConfidence } from './decay.ts';
+import { readableFactVisibilities } from './reader-trust.ts';
 
 const DEFAULT_TTL_MS = 30_000;
 const DEFAULT_TOP_K = 10;
@@ -50,7 +51,13 @@ export async function getBrainHotMemoryMeta(
   const sessionId = (ctx as { source_session?: string }).source_session
     ?? null;
   const allowListHash = hashAllowList(ctx.takesHoldersAllowList);
-  const cacheKey = `${sourceId}::${sessionId ?? '_'}::${allowListHash}`;
+  // Visibility tier: untrusted remote → world-only; trusted local +
+  // owner-trusted reads → all rows. Folded into the cache key (the header's
+  // "cache entries don't bleed across tiers" invariant): trustedFactReads is
+  // re-read from config per call, so a mid-session opt-out must not keep
+  // serving a private-inclusive cached payload for the TTL window.
+  const visibility = readableFactVisibilities(ctx);
+  const cacheKey = `${sourceId}::${sessionId ?? '_'}::${allowListHash}::${visibility ? 'world' : 'all'}`;
 
   const ttl = Math.max(1000, opts.ttlMs ?? DEFAULT_TTL_MS);
   const topK = Math.max(1, Math.min(opts.topK ?? DEFAULT_TOP_K, 25));
@@ -61,10 +68,6 @@ export async function getBrainHotMemoryMeta(
     return cached.payload;
   }
 
-  // Build a fresh payload. Visibility tier: remote → world-only;
-  // local → all rows.
-  const visibility = ctx.remote === false ? undefined : ['world'] as ('world' | 'private')[];
-
   let rows: FactRow[] = [];
   if (sessionId) {
     rows = await ctx.engine.listFactsBySession(sourceId, sessionId, {

src/core/facts/reader-trust.ts

@@ -0,0 +1,48 @@
+/**
+ * Fact-read visibility trust.
+ *
+ * Fact rows are tagged `private` | `world`. Remote/untrusted callers
+ * (`remote === true`) see only `world` rows — the posture that keeps a
+ * published or HTTP-served brain from leaking private claims to strangers.
+ *
+ * But the stdio MCP server is an unauthenticated LOCAL pipe: on a single-owner
+ * machine the caller IS the owner, yet it still defaults `remote: true` for
+ * safety, so the owner's own agent is denied the owner's own private facts
+ * (e.g. `find_trajectory` returns empty over MCP even though the facts exist).
+ *
+ * `trustedFactReads` is a narrow, READ-ONLY trust elevation, deliberately
+ * DECOUPLED from `remote` so every other remote protection — file_upload
+ * confinement, source isolation, fence stripping, takes-holder scoping — stays
+ * fully in force. The stdio MCP server sets it ONLY when the brain owner opts
+ * in via the `facts.trust_local_reads` config (default off). The HTTP/published
+ * transport never sets it, so a served brain stays world-only regardless.
+ */
+export interface FactReaderTrust {
+  /**
+   * Mirrors OperationContext.remote. FAIL-CLOSED: anything not strictly
+   * `false` is treated as remote/untrusted (CLAUDE.md trust invariant).
+   */
+  remote?: boolean;
+  /** Owner opt-in: this remote caller may read private facts. */
+  trustedFactReads?: boolean;
+}
+
+/**
+ * True when the reader is restricted to `visibility = 'world'` rows.
+ * Fail-closed: an unset/undefined `remote` is untrusted — only an explicit
+ * `remote: false` (trusted local CLI) or an explicit owner opt-in
+ * (`trustedFactReads: true`) reads private rows.
+ */
+export function factsWorldOnly(t: FactReaderTrust): boolean {
+  return t.remote !== false && t.trustedFactReads !== true;
+}
+
+/**
+ * Visibility filter for list-style fact reads: `['world']` when the reader is
+ * world-only, `undefined` (no filter — all rows) when it is trusted.
+ */
+export function readableFactVisibilities(
+  t: FactReaderTrust,
+): ('private' | 'world')[] | undefined {
+  return factsWorldOnly(t) ? ['world'] : 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/operations.ts

@@ -18,6 +18,7 @@ import { captureEvalCandidate, isEvalCaptureEnabled, isEvalScrubEnabled } from '
 import type { HybridSearchMeta } from './types.ts';
 import { extractPageLinks, isAutoLinkEnabled, isAutoTimelineEnabled, isGlobalBasenameEnabled, parseTimelineEntries, makeResolver, type UnresolvedFrontmatterRef } from './link-extraction.ts';
 import { isFactsBackstopEligible } from './facts/eligibility.ts';
+import { readableFactVisibilities } from './facts/reader-trust.ts';
 import { stripTakesFence } from './takes-fence.ts';
 import { stripFactsFence } from './facts-fence.ts';
 import { getContentFlag } from './quarantine.ts';
@@ -332,6 +333,15 @@ export interface OperationContext {
    * remote/untrusted (defense in depth in case the type is bypassed via cast).
    */
   remote: boolean;
+  /**
+   * Owner opt-in (`facts.trust_local_reads`): allow this remote caller to read
+   * `private` facts. A NARROW, read-only trust elevation decoupled from
+   * `remote` — every other remote protection (file confinement, source
+   * isolation, fence stripping, takes scoping) stays in force. Set ONLY by the
+   * stdio MCP server when the config is on; the HTTP transport never sets it.
+   * Consulted via `src/core/facts/reader-trust.ts`.
+   */
+  trustedFactReads?: boolean;
   /**
    * Subagent runtime context (v0.16+). Set by the subagent tool dispatcher when
    * dispatching an op as a tool call from an LLM loop. Used to enforce per-op
@@ -3629,6 +3639,7 @@ const find_trajectory: Operation = {
       entitySlug: p.entity_slug,
       ...scope,
       remote: ctx.remote === true,
+      trustedFactReads: ctx.trustedFactReads === true,
       metric,
       kind,
       since,
@@ -3989,13 +4000,9 @@ const recall: Operation = {
     const includeExpired = p.include_expired === true;
     const grep = typeof p.grep === 'string' ? p.grep.toLowerCase() : null;
 
-    // Visibility filter: remote callers see world-only unless their token
-    // grants elevated visibility (future-proofing; v0.31 ships world-only
-    // for remote, all for local CLI).
-    const visibility =
-      ctx.remote === false
-        ? undefined
-        : ['world'] as ('private' | 'world')[];
+    // Visibility filter: world-only for untrusted remote callers; all rows for
+    // trusted local CLI and owner-trusted reads (facts.trust_local_reads).
+    const visibility = readableFactVisibilities(ctx);
 
     let rows: Awaited<ReturnType<typeof ctx.engine.listFactsByEntity>> = [];
 

src/core/pglite-engine.ts

@@ -18,12 +18,12 @@ import type {
 } from './engine.ts';
 import { MAX_SEARCH_LIMIT, clampSearchLimit } from './engine.ts';
 import { withRetry, BULK_RETRY_OPTS, resolveBulkRetryOpts, computeNextDelay, type BatchAuditSite } from './retry.ts';
+import { factsWorldOnly } from './facts/reader-trust.ts';
 import { logBatchRetry as auditLogBatchRetry, logBatchExhausted as auditLogBatchExhausted } from './audit/batch-retry-audit.ts';
 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';
@@ -4319,7 +4319,10 @@ export class PGLiteEngine implements BrainEngine {
     const useArray = Array.isArray(opts.sourceIds) && opts.sourceIds.length > 0;
     const sourceIds = useArray ? opts.sourceIds! : null;
     const sourceId = opts.sourceId ?? 'default';
-    const remoteFilter = opts.remote === true;
+    // Direct-engine contract: unset `remote` here means a trusted in-process
+    // caller (CLI/tests) — the fail-closed default lives in the op layer, which
+    // always passes explicit booleans. Normalize before the fail-closed helper.
+    const remoteFilter = factsWorldOnly({ remote: opts.remote === true, trustedFactReads: opts.trustedFactReads === true });
 
     // Build SQL dynamically. PGLite uses $N positional params; we
     // assemble the WHERE clauses + params array in tandem to keep them
@@ -5203,7 +5206,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

@@ -14,6 +14,7 @@ import type {
   SourceRow,
 } from './engine.ts';
 import { withRetry, BULK_RETRY_OPTS, resolveBulkRetryOpts, computeNextDelay, type BatchAuditSite } from './retry.ts';
+import { factsWorldOnly } from './facts/reader-trust.ts';
 import { logBatchRetry as auditLogBatchRetry, logBatchExhausted as auditLogBatchExhausted } from './audit/batch-retry-audit.ts';
 import type {
   DomainBankSampleOpts, CorpusSampleOpts, DomainBankRow,
@@ -4532,7 +4533,10 @@ export class PostgresEngine implements BrainEngine {
     const useArray = Array.isArray(opts.sourceIds) && opts.sourceIds.length > 0;
     const sourceIds = useArray ? opts.sourceIds! : null;
     const sourceId = opts.sourceId ?? 'default';
-    const remoteFilter = opts.remote === true;
+    // Direct-engine contract: unset `remote` here means a trusted in-process
+    // caller (CLI/tests) — the fail-closed default lives in the op layer, which
+    // always passes explicit booleans. Normalize before the fail-closed helper.
+    const remoteFilter = factsWorldOnly({ remote: opts.remote === true, trustedFactReads: opts.trustedFactReads === true });
 
     // Source-scope predicate: array path (federated) wins over scalar.
     // Engine.ts contract: returns chronological points; regressions +
@@ -5320,12 +5324,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'`;
-}

src/mcp/dispatch.ts

@@ -30,6 +30,13 @@ export interface ToolResult {
 export interface DispatchOpts {
   /** Defaults to true (remote/untrusted). Local CLI callers (`gbrain call`) pass false. */
   remote?: boolean;
+  /**
+   * Owner opt-in (`facts.trust_local_reads`): let this remote caller read
+   * `private` facts. Set ONLY by the stdio MCP server; the HTTP transport
+   * leaves it unset so a served brain stays world-only. See
+   * `src/core/facts/reader-trust.ts`.
+   */
+  trustedFactReads?: boolean;
   /** Override the default stderr logger (e.g. CLI uses console.* directly). */
   logger?: OperationContext['logger'];
   /**
@@ -203,6 +210,7 @@ export function buildOperationContext(
     logger: opts.logger || stderrLogger,
     dryRun: !!params.dry_run,
     remote: opts.remote ?? true,
+    trustedFactReads: opts.trustedFactReads === true,
     takesHoldersAllowList: opts.takesHoldersAllowList,
     // v0.34 D4: sourceId is REQUIRED at the type level. Auto-fill 'default'
     // for single-source brains and any caller who didn't resolve a sourceId.

src/mcp/server.ts

@@ -35,6 +35,16 @@ export async function startMcpServer(engine: BrainEngine) {
   // shape and cast through `any` (the SDK accepts it via the ServerResult union).
   server.setRequestHandler(CallToolRequestSchema, async (request: any): Promise<any> => {
     const { name, arguments: params } = request.params;
+    // Owner opt-in: the stdio pipe is local + unauthenticated, so on a
+    // single-owner machine its caller is the owner. When facts.trust_local_reads
+    // is on, let fact reads (find_trajectory / recall) see this owner's own
+    // private facts. Narrow + read-only — every other remote protection stays
+    // on (remote stays true). HTTP transport never sets this. Best-effort: a
+    // config read blip falls back to the safe world-only default.
+    let trustedFactReads = false;
+    try {
+      trustedFactReads = (await engine.getConfig('facts.trust_local_reads')) === 'true';
+    } catch { /* keep world-only default */ }
     // v0.28: stdio MCP has no per-token auth (local pipe). Default the
     // takes-holder allow-list to ['world'] so agent-facing callers don't
     // see private hunches via takes_list / takes_search / query. Operators
@@ -42,6 +52,7 @@ export async function startMcpServer(engine: BrainEngine) {
     // `gbrain call <op>` (sets remote=false in src/cli.ts).
     return dispatchToolCall(engine, name, params, {
       remote: true,
+      trustedFactReads,
       takesHoldersAllowList: ['world'],
       // v0.31: source defaults to 'default' for stdio (no per-token scope).
       // Operators who want a different source on stdio MCP should set

test/engine-find-trajectory.test.ts

@@ -165,6 +165,22 @@ describe('findTrajectory — visibility filter (D-CDX-1 / R6)', () => {
     const all = await engine.findTrajectory({ entitySlug: 'traj-vis-default' });
     expect(all.length).toBe(2);
   });
+
+  test('remote=true + trustedFactReads bypasses world-only (owner-trusted reads)', async () => {
+    await insertTyped({ entity_slug: 'traj-vis-trusted', metric: 'mrr', value: 50000, visibility: 'private', valid_from: new Date('2026-01-15') });
+    await insertTyped({ entity_slug: 'traj-vis-trusted', metric: 'mrr', value: 99999, visibility: 'world',   valid_from: new Date('2026-04-12') });
+
+    // Untrusted remote: world only.
+    const untrusted = await engine.findTrajectory({ entitySlug: 'traj-vis-trusted', remote: true });
+    expect(untrusted.length).toBe(1);
+    expect(untrusted[0].value).toBe(99999);
+
+    // Owner-trusted remote: sees the private point too. remote stays true — only
+    // fact-read visibility is elevated.
+    const trusted = await engine.findTrajectory({ entitySlug: 'traj-vis-trusted', remote: true, trustedFactReads: true });
+    expect(trusted.length).toBe(2);
+    expect(trusted.map(p => p.value).sort((a, b) => (a! - b!))).toEqual([50000, 99999]);
+  });
 });
 
 describe('findTrajectory — metric + since + until filters', () => {

test/facts-reader-trust.test.ts

@@ -0,0 +1,43 @@
+import { describe, test, expect } from 'bun:test';
+import {
+  factsWorldOnly,
+  readableFactVisibilities,
+} from '../src/core/facts/reader-trust.ts';
+
+describe('factsWorldOnly', () => {
+  test('FAIL-CLOSED: unset remote is untrusted (world-only)', () => {
+    expect(factsWorldOnly({})).toBe(true);
+    expect(factsWorldOnly({ remote: undefined })).toBe(true);
+    expect(factsWorldOnly({ trustedFactReads: false })).toBe(true);
+  });
+
+  test('explicit remote=false (trusted local CLI) sees all', () => {
+    expect(factsWorldOnly({ remote: false })).toBe(false);
+    expect(factsWorldOnly({ remote: false, trustedFactReads: false })).toBe(false);
+  });
+
+  test('untrusted remote callers are world-only', () => {
+    expect(factsWorldOnly({ remote: true })).toBe(true);
+    expect(factsWorldOnly({ remote: true, trustedFactReads: false })).toBe(true);
+  });
+
+  test('owner-trusted remote reads bypass the world-only filter', () => {
+    expect(factsWorldOnly({ remote: true, trustedFactReads: true })).toBe(false);
+  });
+
+  test('trustedFactReads is a no-op for an already-trusted local caller', () => {
+    expect(factsWorldOnly({ remote: false, trustedFactReads: true })).toBe(false);
+  });
+});
+
+describe('readableFactVisibilities', () => {
+  test("world-only readers get the ['world'] filter (incl. unset remote)", () => {
+    expect(readableFactVisibilities({ remote: true })).toEqual(['world']);
+    expect(readableFactVisibilities({})).toEqual(['world']);
+  });
+
+  test('trusted readers get undefined (no filter — all rows)', () => {
+    expect(readableFactVisibilities({ remote: false })).toBeUndefined();
+    expect(readableFactVisibilities({ remote: true, trustedFactReads: true })).toBeUndefined();
+  });
+});

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);
-  });
-});