Merge PR #107 : 更新完還看得到版本號——CLI 重部署不再把版本標籤洗掉（Arcrun#106）

總管複驗（不聽自述，自己重跑並與 base 逐條比對）： cli main 是 0 pass / 3 fail（測試根本跑不起來）→ PR 49 pass / 0 fail ⇒ agent 那句「#97 的守衛測試一直沒在跑」是真的，又一個假綠 cypher 14 failed / 402 passed（base 14 / 400）；失敗清單 diff 無輸出＝零回歸設計比我建議的對：版本標籤每趟重烙、其他 vars 才沿用。我原本建議「一律沿用」會讓版本號永遠停在安裝當時。殘項（agent 誠實標的，不擋併）：沒在真實例上跑過、沒有真 Portal 截圖（它的環境指向 leo21c 紅線、無 youlin 憑證、瀏覽器未授權）。總管接手補這段。
fix(cli): 更新完還看得到版本號——CLI 重部署不再把版本標籤（和你的設定）洗掉
2026-08-12 14:05:57 +00:00 · 2026-08-12 21:58:43 +08:00 · 2026-08-12 21:10:12 +08:00 · 2026-08-12 20:03:30 +08:00 · 2026-08-12 11:42:03 +00:00 · 2026-08-12 19:33:12 +08:00
40 changed files with 2969 additions and 370 deletions
@@ -52,6 +52,14 @@ scripts/__pycache__/
 # D1 備份/匯出（wrangler d1 export 產物，含整庫全量資料=機敏，絕不 commit）
 *.sql
 backup-*.sql
+# 🔴 但 migration 不是備份，它是**要出貨的程式碼**（2026-08-12 實撞）：
+#    上面那條 `*.sql` 的用意是擋 D1 匯出（整庫全量資料＝機敏），卻連 migration 一起吃掉。
+#    後果：0001-0004 因為在該規則之前就 commit 所以還在，**0005/0006 從此沒進過版控**
+#    ⇒ 更新指令從 Gitea 抓 main，那兩個檔根本不在那裡 ⇒ 每個用戶都會收到
+#      「✗ D1 migration: 部署物缺 kbdb/migrations/0005…」——**不是誰忘了推，是規則吃掉的**。
+#    ⇒ 與 `.component-builds/**/component.wasm` 同慣例（見 rules/05-deploy-convention.md
+#      「WASM 來源」段），用否定規則放行。備份檔仍由 `backup-*.sql` 與目錄位置擋住。
+!kbdb/migrations/*.sql

 # GitHub 公開 mirror 工作目錄(publish-github.sh 產物)
 .github-public/
@@ -13285,7 +13285,12 @@ portalRouter.post(
      session_token: token,
      display_name: rec.values.display_name ?? "",
      role: rec.values.role ?? "user",
-      libraries: parseLibraries(rec.values.libraries)
+      libraries: parseLibraries(rec.values.libraries),
+      // session 還能活多久（秒）。**非機密**（是這台實例的 TTL 設定，不是任何人的憑據），
+      // 但呼叫端需要它才能把自己發的憑證對齊這個上限——arcrun-mcp 用它把 OAuth
+      // access_token 的 TTL 夾到 min(自己的 TTL, 這個值)：否則 MCP token 活 30 天、
+      // 底下的 portal session 7 天就死，使用者會在第 8 天遇到「連著卻查不到」的鬼打牆。
+      session_expires_in: sessionTtl(c.env)
      // 絕不回租戶字串（design §3.3：portal_user 拿到租戶字串就能繞過庫 filter 直打 /kbdb/*）
    });
  })
@@ -15363,6 +15368,151 @@ portalDataRouter.get(
    return c.json({ success: true, workflows, total: workflows.length, read_only: true });
  })
 );
+function recordLibrary(values) {
+  const lib = values?.library;
+  return typeof lib === "string" && lib.trim() ? lib.trim() : null;
+}
+function canReadRecord(rec, tenant2, libraries) {
+  if ((rec.owner_id ?? "") !== tenant2) return false;
+  const lib = recordLibrary(rec.values);
+  return lib === null || canReadLibrary(libraries, lib);
+}
+portalDataRouter.get(
+  "/portal/data/map",
+  (c) => run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) {
+      return c.json({ success: true, libraries: [], count: 0, note: "\u6B64\u5E33\u865F\u5C1A\u672A\u88AB\u6388\u6B0A\u4EFB\u4F55\u77E5\u8B58\u5EAB\uFF0C\u8ACB\u806F\u7D61\u7BA1\u7406\u54E1\u3002" });
+    }
+    const res = await kbdbFetch(c.env, `/map?owner_id=${encodeURIComponent(portalTenant(c.env))}`);
+    if (!res.ok) {
+      return new Response(res.body, { status: res.status, headers: { "Content-Type": "application/json" } });
+    }
+    const body = await res.json().catch(() => null);
+    if (!body || !Array.isArray(body.libraries)) {
+      return c.json({ error: "\u85CF\u66F8\u5730\u5716\u8B80\u53D6\u5931\u6557\uFF1AKBDB \u56DE\u61C9\u4E0D\u662F\u9810\u671F\u7684 libraries \u6E05\u55AE" }, 502);
+    }
+    const allowed = body.libraries.filter(
+      (l) => typeof l?.library === "string" && canReadLibrary(libraries, l.library)
+    );
+    return c.json({ success: true, libraries: allowed, count: allowed.length });
+  })
+);
+portalDataRouter.get(
+  "/portal/data/map/:library",
+  (c) => run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    const library = c.req.param("library");
+    if (!canReadLibrary(libraries, library)) return notFound(c);
+    const res = await kbdbFetch(
+      c.env,
+      `/map/${encodeURIComponent(library)}?owner_id=${encodeURIComponent(portalTenant(c.env))}`
+    );
+    if (res.status === 404) return notFound(c);
+    if (!res.ok) return c.json({ error: `KBDB \u56DE\u932F\uFF08HTTP ${res.status}\uFF09` }, 502);
+    return new Response(res.body, { status: 200, headers: { "Content-Type": "application/json" } });
+  })
+);
+portalDataRouter.get(
+  "/portal/data/templates",
+  (c) => run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const res = await kbdbFetch(c.env, "/templates");
+    if (!res.ok) return c.json({ error: `KBDB \u56DE\u932F\uFF08HTTP ${res.status}\uFF09` }, 502);
+    return new Response(res.body, { status: 200, headers: { "Content-Type": "application/json" } });
+  })
+);
+portalDataRouter.post(
+  "/portal/data/templates",
+  (c) => run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const body = await c.req.json().catch(() => null);
+    if (!body || typeof body.name !== "string" || !body.name.trim() || !Array.isArray(body.slots)) {
+      return c.json({ error: "name \u8207 slots[] \u5FC5\u586B" }, 400);
+    }
+    const res = await kbdbFetch(c.env, "/templates", {
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({
+        name: body.name,
+        slots: body.slots,
+        description: typeof body.description === "string" ? body.description : void 0,
+        created_by: portalTenant(c.env)
+      })
+    });
+    return new Response(res.body, { status: res.status, headers: { "Content-Type": "application/json" } });
+  })
+);
+portalDataRouter.get(
+  "/portal/data/records/by-template/:template",
+  (c) => run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) return c.json({ success: true, records: [], count: 0 });
+    const tenant2 = portalTenant(c.env);
+    const res = await kbdbFetch(
+      c.env,
+      `/records/by-template/${encodeURIComponent(c.req.param("template"))}?owner_id=${encodeURIComponent(tenant2)}`
+    );
+    if (!res.ok) return c.json({ error: `KBDB \u56DE\u932F\uFF08HTTP ${res.status}\uFF09` }, 502);
+    const body = await res.json().catch(() => null);
+    if (!body || !Array.isArray(body.records)) {
+      return c.json({ error: "record \u8B80\u53D6\u5931\u6557\uFF1AKBDB \u56DE\u61C9\u4E0D\u662F\u9810\u671F\u7684 records \u6E05\u55AE" }, 502);
+    }
+    const records = body.records.filter((r) => canReadRecord(r, tenant2, libraries));
+    return c.json({ success: true, records, count: records.length });
+  })
+);
+portalDataRouter.get(
+  "/portal/data/records/:recordId",
+  (c) => run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) return notFound(c);
+    const res = await kbdbFetch(c.env, `/records/${encodeURIComponent(c.req.param("recordId"))}`);
+    if (res.status === 404) return notFound(c);
+    if (!res.ok) return c.json({ error: `KBDB \u56DE\u932F\uFF08HTTP ${res.status}\uFF09` }, 502);
+    const body = await res.json().catch(() => null);
+    const record = body?.record;
+    if (!record) return notFound(c);
+    if (!canReadRecord(record, portalTenant(c.env), libraries)) return notFound(c);
+    return c.json({ success: true, record });
+  })
+);
+portalDataRouter.post(
+  "/portal/data/records",
+  (c) => run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) {
+      return c.json({ error: "\u6B64\u5E33\u865F\u5C1A\u672A\u88AB\u6388\u6B0A\u4EFB\u4F55\u77E5\u8B58\u5EAB\uFF0C\u7121\u6CD5\u5BEB\u5165" }, 403);
+    }
+    const body = await c.req.json().catch(() => null);
+    if (!body || typeof body.template !== "string" || !body.template.trim() || !body.values || typeof body.values !== "object") {
+      return c.json({ error: "template \u8207 values \u5FC5\u586B" }, 400);
+    }
+    const values = body.values;
+    const targetLib = recordLibrary(values);
+    if (targetLib !== null && !canReadLibrary(libraries, targetLib)) {
+      return c.json({ error: `\u7121\u300C${targetLib}\u300D\u5EAB\u7684\u6B0A\u9650\uFF0C\u4E0D\u80FD\u5BEB\u5165\u8A72\u5EAB` }, 403);
+    }
+    const res = await kbdbFetch(c.env, "/records", {
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({ template: body.template, values, owner_id: portalTenant(c.env) })
+    });
+    return new Response(res.body, { status: res.status, headers: { "Content-Type": "application/json" } });
+  })
+);
 portalDataRouter.get(
  "/portal/data/diagnostics",
  (c) => run(c, async () => {
@@ -3281,7 +3281,7 @@ async function createRecord(db, input) {
    });
    await db.prepare(`INSERT INTO entry_values (id, record_id, template_id, slot_name, entry_id) VALUES (?, ?, ?, ?, ?)`).bind(uid2("ev"), recordId, tpl.id, slot, entry.id).run();
  }
-  return { record_id: recordId, template_id: tpl.id, values: input.values };
+  return { record_id: recordId, template_id: tpl.id, values: input.values, owner_id: input.owner_id ?? null };
 }
 async function updateRecord(db, recordId, values) {
  const evRes = await db.prepare(
@@ -3312,7 +3312,7 @@ async function updateRecord(db, recordId, values) {
 }
 async function getRecord(db, recordId) {
  const res = await db.prepare(
-    `SELECT ev.slot_name as slot, e.content as content, ev.template_id as template_id
+    `SELECT ev.slot_name as slot, e.content as content, ev.template_id as template_id, e.owner_id as owner_id
       FROM entry_values ev JOIN entries e ON ev.entry_id = e.id
       WHERE ev.record_id = ?`
  ).bind(recordId).all();
@@ -3320,7 +3320,8 @@ async function getRecord(db, recordId) {
  if (rows.length === 0) return null;
  const values = {};
  for (const r of rows) values[r.slot] = r.content;
-  return { record_id: recordId, template_id: rows[0].template_id, values };
+  const owner_id = rows.find((r) => r.owner_id != null)?.owner_id ?? null;
+  return { record_id: recordId, template_id: rows[0].template_id, values, owner_id };
 }
 async function searchByTemplate(db, template, owner_id, limit = 100) {
  const tpl = await getTemplate(db, template);
@@ -3339,17 +3340,18 @@ async function searchByTemplate(db, template, owner_id, limit = 100) {
    const chunk = ids.slice(i, i + 90);
    const placeholders = chunk.map(() => "?").join(",");
    const evRes = await db.prepare(
-      `SELECT ev.record_id as record_id, ev.slot_name as slot, e.content as content, ev.template_id as template_id
+      `SELECT ev.record_id as record_id, ev.slot_name as slot, e.content as content, ev.template_id as template_id, e.owner_id as owner_id
         FROM entry_values ev JOIN entries e ON ev.entry_id = e.id
         WHERE ev.record_id IN (${placeholders})`
    ).bind(...chunk).all();
    for (const r of evRes.results ?? []) {
      let rec = byId.get(r.record_id);
      if (!rec) {
-        rec = { record_id: r.record_id, template_id: r.template_id, values: {} };
+        rec = { record_id: r.record_id, template_id: r.template_id, values: {}, owner_id: null };
        byId.set(r.record_id, rec);
      }
      rec.values[r.slot] = r.content;
+      if (rec.owner_id == null && r.owner_id != null) rec.owner_id = r.owner_id;
    }
  }
  return ids.map((id) => byId.get(id)).filter((r) => !!r);
@@ -1,18 +1,18 @@
 {
  "schema": 1,
  "built_for": "arcrun-tier2-worker-artifacts",
-  "generated_at": "2026-08-12T07:29:58.626Z",
-  "repo_head": "1791ffa4972b4135dacd4208e805f67b747479c4",
+  "generated_at": "2026-08-12T12:02:15.698Z",
+  "repo_head": "89b80ff90e95f07b5d44978ef58090ac783f53bd",
  "repo_dirty": false,
  "workers": [
    {
      "name": "arcrun-cypher-executor",
      "source_dir": "cypher-executor",
-      "source_commit": "f1370e2275eea62b64a88821a096f2c2cfe76fb0",
+      "source_commit": "10d150ac2b4385af95a457f3c411430c4a146cf9",
      "main_module": "worker.mjs",
      "main_file": "arcrun-cypher-executor/worker.mjs",
-      "js_bytes": 577374,
-      "content_sha256": "8411ed59b7ad9e1a74ac0d8e3b620d7166e7d0178ac5939e6cc736f2e8d1d2be",
+      "js_bytes": 584610,
+      "content_sha256": "6a424274ecf7beb28b747672296c4c33f949c6d7b134e8054e640e92198910ba",
      "modules": [],
      "compat_date": "2025-02-19",
      "compat_flags": [
@@ -58,11 +58,11 @@
    {
      "name": "arcrun-kbdb",
      "source_dir": "kbdb",
-      "source_commit": "c497ec418eba6cd94b1d5872671c51fd5812c11c",
+      "source_commit": "10d150ac2b4385af95a457f3c411430c4a146cf9",
      "main_module": "worker.mjs",
      "main_file": "arcrun-kbdb/worker.mjs",
-      "js_bytes": 149533,
-      "content_sha256": "ffb8d43467d0cefbd7545fdc0d347f2b965e3c3de20b3315eed7613f20266891",
+      "js_bytes": 149797,
+      "content_sha256": "8b23853cbc88aee0ca15ef20ca46e92bd8e75064cd311af2847f4d51811960b1",
      "modules": [],
      "compat_date": "2025-02-19",
      "compat_flags": [
@@ -148,11 +148,11 @@
    {
      "name": "arcrun-mcp",
      "source_dir": "mcp",
-      "source_commit": "035e8b255b0dcbd4238707f7d2ac8ccf9ee1ba72",
+      "source_commit": "10d150ac2b4385af95a457f3c411430c4a146cf9",
      "main_module": "worker.mjs",
      "main_file": "arcrun-mcp/worker.mjs",
-      "js_bytes": 1165388,
-      "content_sha256": "c5ff10f9b9d5a77217be343af12d2be3ee8f9792d3e1e091e48e5e6c8d24ca9d",
+      "js_bytes": 1179487,
+      "content_sha256": "1cd4c4d079d72bf7cba7c490ba6a88476f70b3ea51af7e5c93f9a184ae3c0ce6",
      "modules": [],
      "compat_date": "2024-11-27",
      "compat_flags": [
@@ -12,7 +12,7 @@
    "build:harness": "node scripts/build-harness-skill.mjs",
    "check:harness": "node scripts/check-harness-generation.mjs",
    "dev": "tsc --watch",
-    "test": "node --test \"tests/**/*.test.ts\"",
+    "test": "node --experimental-transform-types --import ./tests/register-ts-hooks.mjs --test \"tests/**/*.test.ts\"",
    "prepublishOnly": "npm run build && chmod +x dist/index.js"
  },
  "dependencies": {
@@ -170,10 +170,13 @@ export class CfAccountClient implements ResourceApi {
    const path = `/workers/scripts/${encodeURIComponent(script)}/settings`;
    const res = await this.cfRaw<{ bindings?: RawWorkerBinding[] }>(path);
    if (!res.ok) {
-      if (res.status === 404) return { deployed: false, bindings: [] };
+      if (res.status === 404) return { deployed: false, bindings: [], vars: {} };
      throw new Error(`讀 ${script} 綁定失敗：${res.error}`);
    }
-    return { deployed: true, bindings: normalizeBindings(res.result?.bindings ?? []) };
+    const raw = res.result?.bindings ?? [];
+    // #106：同一份回應裡也帶著 plain_text var（實測 CF `/settings` 會回 `text` 值）。
+    // 舊版只挑資源類、把 var 整批丟掉 → 重部署等於把它們洗掉。
+    return { deployed: true, bindings: normalizeBindings(raw), vars: normalizeVars(raw) };
  }

  /** 查 workers.dev subdomain（cypher-executor WORKER_SUBDOMAIN 用，組對內 component URL）。*/
@@ -234,6 +237,22 @@ interface RawWorkerBinding {
  id?: string;
  database_id?: string;
  index_name?: string;
+  /** `plain_text` 綁定的值（#106；secret_text 不會回值，本來就讀不到，也不該讀）。 */
+  text?: string;
+}
+
+/**
+ * 抽出已部署 worker 上的 `plain_text` var（#106）。
+ *
+ * 只收 `plain_text`——**`secret_text` 一律不碰**（CF 本來就不回值，也不該被 CLI 搬來搬去；
+ * wrangler deploy 不會動 secret，它們自己會留著）。
+ */
+function normalizeVars(raw: RawWorkerBinding[]): Record<string, string> {
+  const out: Record<string, string> = {};
+  for (const b of raw) {
+    if (b?.type === 'plain_text' && b.name && typeof b.text === 'string') out[b.name] = b.text;
+  }
+  return out;
 }

 /** 把 CF 的 binding 陣列收斂成 resolver 認得的三種資源。不認得的型別直接略過。 */
@@ -98,6 +98,119 @@ function giteaToken(): string | undefined {
  return process.env.ARCRUN_GITEA_TOKEN || process.env.GITEA_TOKEN || undefined;
 }

+/**
+ * 版本標籤的「發行頻道」來源（Arcrun#106）。
+ *
+ * Portal 設定頁與 daemon `cloudVersionStale()` 都是拿**這支**回的 `release` 當「最新版」，
+ * 再跟實例 `/health` 的 `bundle_version` 比。CLI 更新完若不烙一個同一把尺量得出來的版號，
+ * 使用者就只會看到「無法讀取目前版本」或永遠「落後」。
+ * fork／自架另有發行頻道者用 ARCRUN_RELEASE_API 覆蓋，不寫死。
+ */
+const ARCRUN_RELEASE_API = process.env.ARCRUN_RELEASE_API ?? 'https://install.arcrun.dev/api/latest';
+
+/** CLI 自己負責注入 / 自己烙的 var——**不從已部署的 worker 沿用**（沿用會蓋掉這趟算出來的正解）。 */
+export const CLI_MANAGED_VARS = [
+  'WORKER_SUBDOMAIN',        // 由 ctx.workerSubdomain 注入
+  'CF_ACCOUNT_ID',           // 由 ctx.accountId 注入
+  'MULTI_TENANT',            // 由 selfHosted 注入
+  'KBDB_BASE_URL',           // 由 workerSubdomain 組
+  'ARCRUN_BUNDLE_VERSION',   // 版本標籤：每趟重烙，**絕不沿用舊值**（見 resolveBundleStamp）
+  'ARCRUN_BUNDLE_COMMIT',
+] as const;
+
+/** 烙版本標籤的那顆 worker（`/health` 就是它吐的）。其餘 worker 不需要版本標籤。 */
+export const VERSION_STAMP_WORKER = 'arcrun-cypher-executor';
+
+/** 這趟部署要烙上去的版本標籤。 */
+export interface BundleStamp {
+  /** 寫進 `ARCRUN_BUNDLE_VERSION`。 */
+  version: string;
+  /** 寫進 `ARCRUN_BUNDLE_COMMIT`（查得到才有）。 */
+  commit?: string;
+  /** 給人看的一句話（CLI 會印出來），說明這個版號是怎麼來的。 */
+  note: string;
+}
+
+/**
+ * 算「這趟部署上去的東西，該叫幾版」（Arcrun#106）。
+ *
+ * 🔴 為什麼**不是沿用實例上原本那個值**：那個值描述的是**當時裝上去的那份程式碼**。
+ *   更新完程式碼換了，標籤沒換 = 一個永遠停在安裝當天的假標籤——比沒有標籤更糟，
+ *   因為 leo 會拿它當「我驗收過了」。版本標籤是**成品的屬性**，不是使用者的設定，
+ *   所以它是唯一一個「不沿用、每趟重烙」的 var（其餘 plain_text var 一律沿用，見 preservedVars）。
+ *
+ * 誠實邊界（mindset §7，這段要留著）：
+ *   - CLI 部的是 `ARCRUN_REPO@ref` 的**原始碼**，發行版號（semver）是**安裝器頻道**在發的，
+ *     兩者不是同一套編號。這裡取的是「部署當下該頻道公告的 release」，
+ *     語義＝「我跟這個頻道的最新發行同源」，並**另外把真正的 commit 一起烙上去**
+ *     （`ARCRUN_BUNDLE_COMMIT`／`/health` 的 `bundle_commit`）→ 有沒有漂掉，看 commit 就查得出來。
+ *   - 查不到 release（離線／頻道掛了）→ **不猜、不掰**，退成 `YYYY-MM-DD+<commit7>` 這個
+ *     舊實例本來就在用的格式。Portal 對非 semver 一律顯示成「較舊版本」——
+ *     那正是我們想要的：**寧可說不準，也不要假裝已是最新**。
+ */
+export async function resolveBundleStamp(
+  ref: string,
+  commit?: string,
+  fetchImpl: typeof fetch = fetch,
+): Promise<BundleStamp> {
+  const short = commit ? commit.slice(0, 7) : ref;
+  const today = new Date().toISOString().slice(0, 10);
+  try {
+    const res = await fetchImpl(ARCRUN_RELEASE_API, { signal: AbortSignal.timeout(15_000) });
+    if (!res.ok) throw new Error(`HTTP ${res.status}`);
+    const body = (await res.json()) as { release?: string } | null;
+    const release = String(body?.release ?? '').trim();
+    if (!/^\d+\.\d+\.\d+$/.test(release)) throw new Error(`發行頻道回的版號不是 semver（${release || '空'}）`);
+    return {
+      version: release,
+      commit,
+      note: `${release}（發行頻道 ${ARCRUN_RELEASE_API}${commit ? `；實際部署 commit ${short}` : ''}）`,
+    };
+  } catch (e) {
+    const version = `${today}+${short}`;
+    return {
+      version,
+      commit,
+      note:
+        `${version}（查不到發行版號：${e instanceof Error ? e.message : String(e)}）` +
+        `\n      → 誠實標成 commit 版；Portal 會顯示成「較舊版本」而不是假裝已是最新。`,
+    };
+  }
+}
+
+/**
+ * 把 `ref`（branch / tag / sha）解析成確切的 commit sha（Arcrun#106）。
+ *
+ * 兩個用途：① 版本標籤要烙「真的部了哪個 commit」；② 解出來之後**直接用 sha 下載 archive**——
+ * sha 是不可變的，順帶把 #13 P2 的「branch tarball 被中間層快取成舊的」整個病根拿掉。
+ * 查不到就回 undefined（呼叫端退回原本的用 ref 下載，行為不變）——這條路徑不該讓更新失敗。
+ */
+export async function resolveGiteaCommit(
+  ref: string,
+  fetchImpl: typeof fetch = fetch,
+): Promise<string | undefined> {
+  const headers = buildDownloadHeaders();
+  const tryUrls = [
+    `${ARCRUN_GITEA_BASE}/api/v1/repos/${ARCRUN_REPO}/branches/${encodeURIComponent(ref)}`,
+    `${ARCRUN_GITEA_BASE}/api/v1/repos/${ARCRUN_REPO}/commits?sha=${encodeURIComponent(ref)}&limit=1&stat=false`,
+  ];
+  for (const url of tryUrls) {
+    try {
+      const res = await fetchImpl(url, { headers, signal: AbortSignal.timeout(20_000) });
+      if (!res.ok) continue;
+      const body = (await res.json()) as
+        | { commit?: { id?: string } }
+        | Array<{ sha?: string }>
+        | null;
+      const sha = Array.isArray(body) ? body[0]?.sha : body?.commit?.id;
+      if (typeof sha === 'string' && /^[0-9a-f]{7,64}$/i.test(sha)) return sha;
+    } catch {
+      /* 換下一種問法；全都問不到就回 undefined */
+    }
+  }
+  return undefined;
+}
+
 /**
 * 組 Gitea archive 下載 URL（純函式，好離線測 URL 組裝）。
 * Gitea archive API：`GET {base}/api/v1/repos/{owner}/{repo}/archive/{ref}.tar.gz`。
@@ -253,9 +366,12 @@ export async function downloadAndDeploy(
  const mode = opts.mode ?? 'update';
  const api = opts.api ?? new CfAccountClient(ctx.accountId, ctx.apiToken);
  // 1. 下載 + 解壓 Gitea archive tarball
+  //    #106：先把 ref 解析成確切 commit，**用 sha 下載**（不可變 → 順帶解掉 branch tarball 被快取的老問題），
+  //    同一個 sha 稍後也會被烙成版本標籤。解不出來就照舊用 ref 下載（行為不變）。
+  const commit = await resolveGiteaCommit(ref);
  let root: string;
  try {
-    root = await downloadRepoTarball(ref);
+    root = await downloadRepoTarball(commit ?? ref, commit ? ref : undefined);
  } catch (e) {
    return {
      implemented: true,
@@ -310,6 +426,7 @@ export async function downloadAndDeploy(
  //    所以「解析看到的」和「最後寫進去的」保證是同一份檔案的同一種樣子。
  const requirements: BindingRequirement[] = [];
  const tomlPreviews = new Map<string, string>();   // dir → 注入前的原文
+  const dirScript = new Map<string, string>();      // dir → worker script 名（#106：var 沿用要逐顆對號）
  for (const dir of allDirs) {
    const tomlPath = join(dir, 'wrangler.toml');
    if (!existsSync(tomlPath)) continue;
@@ -318,12 +435,14 @@ export async function downloadAndDeploy(
    const preview = renderWranglerToml(raw, ctx, new Map());
    const parsed = parseWranglerRequirements(preview);
    if (!parsed.script) continue;   // 沒宣告 name 的 toml 不該存在；跳過而非亂猜
+    dirScript.set(dir, parsed.script);
    for (const b of parsed.bindings) {
      requirements.push({ ...b, worker: parsed.script });
    }
  }

  let resolved = new Map<string, ResolvedResource>();
+  let liveVars = new Map<string, Record<string, string>>();
  if (requirements.length > 0) {
    process.stdout.write(chalk.gray('  → 對照你帳號上已部署的 worker，確認每個綁定該用哪顆資源...'));
    let plan;
@@ -369,6 +488,7 @@ export async function downloadAndDeploy(
        message: `停手：\n${detail}${hint}\n\n沒有部署任何 worker——你現在的實例維持原樣。`,
      };
    }
+    liveVars = plan.liveVars;
    console.log(chalk.green(' ✓'));
    const adopted = [...resolved.values()].filter((r) => r.origin === 'adopted');
    const created = [...resolved.values()].filter((r) => r.origin === 'created');
@@ -407,6 +527,48 @@ export async function downloadAndDeploy(
    }
  }

+  // ── 2.8 var（plain_text）：既有的沿用、版本標籤重烙（Arcrun#106）─────────────────
+  //
+  // 🔴 #97 修好了「櫃子」（KV/D1/Vectorize 沿用既有），但 **var 這批「櫃子上的標籤」沒人管**：
+  //    wrangler deploy 是整份覆蓋，toml 沒寫的 var 直接消失。leo 2026-08-12 實撞的畫面
+  //    「無法讀取目前版本（知識庫服務可能正在啟動）」就是 `ARCRUN_BUNDLE_VERSION` 被這樣洗掉的。
+  //
+  // 兩種 var 走**相反**的規則，這是本次的核心判斷：
+  //    · 設定類（PORTAL_MAIL_RELAY_BASE / CONSOLE_TENANT / …）＝**使用者實例的事實** → 沿用
+  //    · 版本標籤（ARCRUN_BUNDLE_VERSION）＝**這份成品的屬性** → 每趟重烙，沿用舊值就是假標籤
+  //
+  // 範圍註記：`liveVars` 來自資源解析那一趟讀到的 worker（＝有資源綁定的那些：cypher/kbdb/mcp/registry）。
+  //   純零件 worker 沒有資源綁定、不在那份名單裡 → 這裡不會沿用它們的 var。目前它們的 var 只有
+  //   toml 自己帶的 `COMPONENT_ID`，沒有東西可丟；若哪天有人往零件 worker 注入設定，要在這裡補讀。
+  const extraVarsByDir = new Map<string, Record<string, string>>();
+  let stamp: BundleStamp | undefined;
+  if (dirScript.size > 0) {
+    const needStamp = [...dirScript.values()].includes(VERSION_STAMP_WORKER);
+    if (needStamp) {
+      process.stdout.write(chalk.gray('  → 算這趟要烙上去的版本標籤...'));
+      stamp = await resolveBundleStamp(ref, commit);
+      console.log(chalk.green(' ✓'));
+      console.log(chalk.gray(`    ARCRUN_BUNDLE_VERSION = ${stamp.note}`));
+    }
+    const preservedTotal: string[] = [];
+    for (const [dir, script] of dirScript) {
+      const raw = tomlPreviews.get(dir);
+      if (!raw) continue;
+      const keep = preservedVars(liveVars.get(script), raw);
+      for (const k of Object.keys(keep)) preservedTotal.push(`${script}:${k}`);
+      const vars: Record<string, string> = { ...keep };
+      if (stamp && script === VERSION_STAMP_WORKER) {
+        vars.ARCRUN_BUNDLE_VERSION = stamp.version;
+        if (stamp.commit) vars.ARCRUN_BUNDLE_COMMIT = stamp.commit;
+      }
+      if (Object.keys(vars).length > 0) extraVarsByDir.set(dir, vars);
+    }
+    if (preservedTotal.length > 0) {
+      console.log(chalk.gray(`    沿用你實例上既有的 ${preservedTotal.length} 個設定值（var）：`));
+      for (const item of preservedTotal) console.log(chalk.gray(`      = ${item}`));
+    }
+  }
+
  // 3. 對每個 worker：注入 KV id（+ cypher WORKER_SUBDOMAIN）→ wrangler deploy。tier1 先 tier2 後。
  // 逐 worker 串流進度（每個含 pnpm install + wrangler deploy，沉默會讓人以為卡住——
  //   壓測 2026-06-11 richblack 觀察：「D1 ✓」後停很久其實在這個迴圈靜默部署 20+ worker）。
@@ -422,7 +584,7 @@ export async function downloadAndDeploy(
    const label = dir.replace(/^.*\.component-builds\//, '').replace(/^.*\//, '');
    process.stdout.write(chalk.gray(`    [${i + 1}/${allDirs.length}] ${label} ...`));
    try {
-      injectWranglerConfig(tomlPath, ctx, resolved, tomlPreviews.get(dir));
+      injectWranglerConfig(tomlPath, ctx, resolved, tomlPreviews.get(dir), extraVarsByDir.get(dir));
      // 注入後算指紋：與 manifest 比，相同 = 上次成功部過且內容沒變 → 跳過。
      const hash = dirContentHash(dir, ctx.accountId);
      if (manifest[label] === hash) {
@@ -599,11 +761,13 @@ async function ensureVectorizeMetadataIndexes(ctx: DeployContext, indexName: str
 * 解法：fetch 時帶 no-cache header + 唯一 query param 強制繞過快取，每次抓到 ref 的最新內容。
 *
 * Arcrun#4：來源由 GitHub codeload 改為 Gitea archive API（走 GITEA_TOKEN，不寫死）。*/
-async function downloadRepoTarball(ref: string): Promise<string> {
+async function downloadRepoTarball(ref: string, fromRef?: string): Promise<string> {
  // 唯一 cache-buster query param：對不同 query 視為不同請求 → 繞過 stale 快取。
  const bust = `${Date.now()}-${Math.random().toString(36).slice(2)}`;
  const url = buildArchiveUrl(ref, bust);
-  console.log(chalk.gray(`  → 從 Gitea 下載最新版本（${ARCRUN_REPO}@${ref}，約 10–30 秒，視網速）...`));
+  // fromRef 有值 = ref 已被解析成 commit sha（#106），印出來讓人看得到「這趟到底部了哪個 commit」。
+  const label = fromRef ? `${fromRef} → ${ref.slice(0, 7)}` : ref;
+  console.log(chalk.gray(`  → 從 Gitea 下載最新版本（${ARCRUN_REPO}@${label}，約 10–30 秒，視網速）...`));
  const res = await fetch(url, {
    signal: AbortSignal.timeout(120_000),
    // 強制繞過任何中間快取，避免抓到 push 後尚未刷新的 stale tarball（#13 P2 假綠根因）。
@@ -701,11 +865,91 @@ function injectWranglerConfig(
  ctx: DeployContext,
  resolved: Map<string, ResolvedResource>,
  original?: string,
+  extraVars: Record<string, string> = {},
 ): void {
  if (!existsSync(tomlPath)) return;
  // original = 資源解析階段讀到的原文。用它而不是重讀檔案，確保「解析看到的」與「寫回去的」同源。
  const toml = original ?? readFileSync(tomlPath, 'utf8');
-  writeFileSync(tomlPath, renderWranglerToml(toml, ctx, resolved), 'utf8');
+  writeFileSync(tomlPath, renderWranglerToml(toml, ctx, resolved, extraVars), 'utf8');
+}
+
+/**
+ * 挑出「這顆已部署的 worker 上有、但這版 toml 不會自己帶的」plain_text var（Arcrun#106）。
+ *
+ * 規則就一句：**已部署 worker 上掛著什麼 var，那就是事實**（#97 對資源講的那句話，
+ * 原封不動套用在標籤上）。所以預設全部沿用，只有兩種例外：
+ *   ① `CLI_MANAGED_VARS`——這趟由 CLI 自己算（帳號 id／subdomain／單租戶旗標／版本標籤），
+ *      沿用等於拿舊值蓋掉正解。
+ *   ② 值一模一樣的（toml 已經寫了同樣的值）——寫進去只是雜訊，略過。
+ *
+ * ⚠️ 這裡刻意**不**做「toml 有宣告就以 toml 為準」：那正是這次的病
+ * ——repo toml 裡的 `CONSOLE_TENANT = "leo"`／`WORKER_SUBDOMAIN` 之類是**官方 prod 的值**，
+ * 拿它蓋掉使用者實例上的值，就是「更新一次把人家的設定洗成官方預設」。
+ */
+export function preservedVars(
+  live: Record<string, string> | undefined,
+  toml: string,
+): Record<string, string> {
+  const out: Record<string, string> = {};
+  if (!live) return out;
+  const managed = new Set<string>(CLI_MANAGED_VARS);
+  for (const key of Object.keys(live).sort()) {
+    if (managed.has(key)) continue;
+    if (!/^[A-Za-z0-9_]+$/.test(key)) continue;      // 怪名字不碰（applyVars 也會擋，這裡先濾掉不誤報）
+    if (readVar(toml, key) === live[key]) continue;   // toml 已經是同一個值 → 不必動
+    out[key] = live[key];
+  }
+  return out;
+}
+
+/** 讀 toml 裡某個 var 目前的值（只看未註解的行）。找不到回 undefined。 */
+function readVar(toml: string, key: string): string | undefined {
+  const m = toml.match(new RegExp(`^\\s*${key}\\s*=\\s*"([^"]*)"`, 'm'));
+  return m?.[1];
+}
+
+/** TOML basic string 轉義（值裡可能有引號／反斜線，例如網址或 JSON 片段）。 */
+function tomlEscape(value: string): string {
+  return value.replace(/\\/g, '\\\\').replace(/"/g, '\\"');
+}
+
+/**
+ * 把一組 var 寫進 toml 的 `[vars]`（Arcrun#106）。純函式。
+ *
+ * 三種既有狀態各自處理（比照 injectMultiTenant，同一種文字操作層級）：
+ *   1. 已有未註解的同名行 → 換值
+ *   2. 只有被註解掉的同名行 → 取消註解並填值
+ *   3. 都沒有 → 插在 `[vars]` header 下一行；連 `[vars]` 都沒有就在檔尾新開一段
+ */
+export function applyVars(toml: string, vars: Record<string, string>): string {
+  let out = toml;
+  for (const key of Object.keys(vars).sort()) {
+    // 只接受合法的 var 名（CF 那側本來就是這個字集）。怪名字寧可不寫，也不要拿它去組正規式。
+    if (!/^[A-Za-z0-9_]+$/.test(key)) continue;
+    const value = tomlEscape(vars[key]);
+    // 🔴 一律用「函式版 replace」：值裡若有 `$&`／`$1` 這種字元，字串版 replace 會把它當成
+    //   反向參照展開，寫出來的就不是使用者那個值了。
+    if (new RegExp(`^\\s*${key}\\s*=`, 'm').test(out)) {
+      out = out.replace(
+        new RegExp(`^(\\s*${key}\\s*=\\s*")[^"]*(".*)$`, 'm'),
+        (_m, head: string, tail: string) => `${head}${value}${tail}`,
+      );
+      continue;
+    }
+    if (new RegExp(`^\\s*#\\s*${key}\\s*=`, 'm').test(out)) {
+      out = out.replace(
+        new RegExp(`^(\\s*)#\\s*${key}\\s*=\\s*"[^"]*"(.*)$`, 'm'),
+        (_m, indent: string, tail: string) => `${indent}${key} = "${value}"${tail}`,
+      );
+      continue;
+    }
+    if (/^\s*\[vars\]\s*$/m.test(out)) {
+      out = out.replace(/^(\s*\[vars\]\s*)$/m, (_m, header: string) => `${header}\n${key} = "${value}"`);
+      continue;
+    }
+    out = `${out.replace(/\s*$/, '')}\n\n[vars]\n${key} = "${value}"\n`;
+  }
+  return out;
 }

 /**
@@ -715,11 +959,15 @@ function injectWranglerConfig(
 * 「除了資源 id 以外都已經定案」的 toml，資源解析就是照這份預覽去數需求的
 * ⇒ 解析階段看到的 binding 清單，與最後真的寫進檔案的，保證一致（Arcrun#97 的教訓：
 *   兩段程式對同一份檔案有不同想像，就會出現「以為沒有、其實有」）。
+ *
+ * `extraVars`（Arcrun#106）：這顆 worker 要**沿用的既有 var** ＋ 這趟要**重烙的版本標籤**。
+ *   預覽時不傳（vars 不影響資源需求解析，傳不傳都是同一份需求清單）。
 */
 export function renderWranglerToml(
  toml: string,
  ctx: DeployContext,
  resolved: Map<string, ResolvedResource>,
+  extraVars: Record<string, string> = {},
 ): string {
  // cypher-executor 的 WORKER_SUBDOMAIN（vars）換成用戶帳號 subdomain
  if (ctx.workerSubdomain && /WORKER_SUBDOMAIN/.test(toml)) {
@@ -770,6 +1018,11 @@ export function renderWranglerToml(
    toml = toml.replace(/# (\[ai\])\n# (binding = "AI")/, '$1\n$2');
  }

+  // 沿用的既有 var ＋ 這趟的版本標籤（#106）。**放在所有 CLI 注入之後**：
+  // CLI_MANAGED_VARS 已經在 preservedVars 排除掉，故這裡不會蓋掉上面剛算好的
+  // WORKER_SUBDOMAIN / CF_ACCOUNT_ID / MULTI_TENANT / KBDB_BASE_URL。
+  toml = applyVars(toml, extraVars);
+
  // 資源 id 一律最後注入，且**照 binding 名逐個對號**（不是「檔案裡第一個 database_id」那種盲換）。
  // 空 map = 預覽模式，這步什麼也不做。
  return applyResolvedBindings(toml, resolved);
@@ -41,6 +41,16 @@ export interface ScriptBindings {
  /** false = 這顆 worker 在帳號上還不存在（全新部署），不是「讀取失敗」。讀取失敗要 throw。 */
  deployed: boolean;
  bindings: LiveBinding[];
+  /**
+   * 這顆 worker 現在掛著的 `plain_text` var（名 → 值）。
+   *
+   * 🔴 Arcrun#106：#97 只把「資源類」綁定當成事實沿用（KV/D1/Vectorize），
+   *   plain_text var 整批沒人管 ⇒ 重部署把它們洗成 repo toml 的預設值。
+   *   最痛的一個是 `ARCRUN_BUNDLE_VERSION`（安裝器注入的版本標籤）——
+   *   更新完就消失，Portal 設定頁變成「無法讀取目前版本」。
+   *   **保留了櫃子，沒保留櫃子上的標籤**。這個欄位就是那些標籤。
+   */
+  vars?: Record<string, string>;
 }

 /** resolver 需要的 CF 能力（收窄成介面，方便離線測試餵假帳號）。 */
@@ -87,6 +97,14 @@ export interface ResourcePlan {
  create: PlannedCreate[];
  /** 非空 = 整趟停手。applyResourcePlan 會拒絕執行。 */
  blockers: string[];
+  /**
+   * 每顆**已部署** worker 現在掛著的 plain_text var（script → 名/值）。未部署的不在裡面。
+   *
+   * Arcrun#106：讀綁定的時候本來就把整份 `bindings[]` 拿回來了，var 就在同一份回應裡——
+   * 順手帶出來，**不另外打一次 API**，也不新增一種「查不到」的失敗模式
+   * （讀不到綁定這件事已經在上面 blockers 那一關擋掉了）。
+   */
+  liveVars: Map<string, Record<string, string>>;
 }

 export interface ResolvedResource {
@@ -137,11 +155,16 @@ export async function planResources(
  // 讀取失敗 ≠ 沒有綁。#97 的災情就是把「我查不到」當成「它不存在」。
  const scripts = [...new Set(requirements.map((r) => r.worker))].sort();
  const live = new Map<string, LiveBinding[]>();
+  const liveVars = new Map<string, Record<string, string>>();
  let readFailed = false;
  for (const script of scripts) {
    try {
      const res = await api.getScriptBindings(script);
-      if (res.deployed) live.set(script, res.bindings);
+      if (res.deployed) {
+        live.set(script, res.bindings);
+        // #106：同一份回應裡的 plain_text var 一起收下（呼叫端要拿它決定哪些 var 該沿用）。
+        liveVars.set(script, res.vars ?? {});
+      }
    } catch (e) {
      readFailed = true;
      blockers.push(
@@ -242,7 +265,7 @@ export async function planResources(
    });
  }

-  return { adopt, create: shareSameResource(adopt, create, byKey), blockers };
+  return { adopt, create: shareSameResource(adopt, create, byKey), blockers, liveVars };
 }

 /**
@@ -0,0 +1,4 @@
+/** `node --import ./tests/register-ts-hooks.mjs --test ...` 的進入點：註冊 ts-hooks.mjs。 */
+import { register } from 'node:module';
+
+register('./ts-hooks.mjs', import.meta.url);
@@ -493,7 +493,7 @@ test('CfAccountClient.getScriptBindings：404 = 還沒部署；其他錯誤要 t
      new Response(JSON.stringify({ success: false, errors: [{ message: 'not found' }] }), { status: 404 })
    ) as typeof fetch;
    const cf = new CfAccountClient('a', 't');
-    assert.deepEqual(await cf.getScriptBindings('nope'), { deployed: false, bindings: [] });
+    assert.deepEqual(await cf.getScriptBindings('nope'), { deployed: false, bindings: [], vars: {} });

    globalThis.fetch = (async () =>
      new Response(JSON.stringify({ success: false, errors: [{ message: 'boom' }] }), { status: 500 })
@@ -526,6 +526,8 @@ test('CfAccountClient.getScriptBindings：讀得懂 CF 回的 kv/d1/vectorize
      { kind: 'd1', binding: 'DB', value: 'db1' },
      { kind: 'vectorize', binding: 'VECTORIZE', value: 'idx1' },
    ]);
+    // #106：plain_text 也要收下來（service 這種不認得的仍略過）。
+    assert.deepEqual(res.vars, { ENVIRONMENT: 'production' });
  } finally {
    globalThis.fetch = orig;
  }
@@ -0,0 +1,21 @@
+/**
+ * 測試用 resolve hook：把 `./x.js` 這種 import 指回同名的 `./x.ts`（Arcrun#106 附帶修復）。
+ *
+ * 為什麼需要：`src/` 內部的 import 一律寫成 `.js`（NodeNext 慣例，編譯後才會有那個檔），
+ * 但測試是**直接載入 `src/**\/*.ts`**、不經過 tsc（`outDir: dist`，所以 `src/` 底下永遠不會有 .js）。
+ * Node 的型別剝離不會自己把 `.js` 對回 `.ts` ⇒ 三份測試在 node 22 上**一支都跑不起來**
+ * （`ERR_MODULE_NOT_FOUND: .../src/lib/cf-api.js`）——包含 #97 那份「使用者的東西還在不在」的迴歸守衛。
+ * 跑不起來的守衛等於沒有守衛，所以這裡補上。
+ *
+ * 只在「預設解析失敗」時才動作，且只換副檔名 → 對本來就解析得到的環境（新版 node / 已編譯）零影響。
+ */
+export async function resolve(specifier, context, next) {
+  try {
+    return await next(specifier, context);
+  } catch (err) {
+    if (typeof specifier === 'string' && specifier.endsWith('.js')) {
+      return next(specifier.slice(0, -3) + '.ts', context);
+    }
+    throw err;
+  }
+}
@@ -0,0 +1,243 @@
+/**
+ * Arcrun#106 迴歸守衛 —— 「更新完，設定頁還看得到版本號，而且是**這次**的版本號」
+ *
+ * 2026-08-12 實害：leo 更新完 leo21c，Portal 設定頁的版本欄變成
+ * 「無法讀取目前版本（知識庫服務可能正在啟動）」。
+ * 根因：`ARCRUN_BUNDLE_VERSION` 是部署時注入的 plain_text var，**只有安裝器會注入**；
+ * CLI 這條路重部署時 wrangler 整份覆蓋 toml，沒寫的 var 直接消失 ⇒ 標籤被洗掉。
+ * #97 修好了「櫃子」（KV/D1/Vectorize 沿用既有），**沒修「櫃子上的標籤」**。
+ *
+ * 這份測試守兩件相反的事（本次的核心判斷）：
+ *   · 設定類 var（安裝器注入的 PORTAL_MAIL_RELAY_BASE 之類）＝使用者實例的事實 → **沿用**
+ *   · 版本標籤 ARCRUN_BUNDLE_VERSION ＝這份成品的屬性 → **每趟重烙，絕不沿用舊值**
+ *     （沿用舊值 = 一個永遠停在安裝當天的假標籤，比沒有標籤更糟）
+ *
+ * 全部離線跑：真的 wrangler.toml + 真的 render/inject 程式碼，fetch 用假的，不碰任何實例。
+ */
+
+import { test } from 'node:test';
+import assert from 'node:assert/strict';
+import { readFileSync } from 'node:fs';
+import { join } from 'node:path';
+import { fileURLToPath } from 'node:url';
+
+import {
+  renderWranglerToml,
+  preservedVars,
+  applyVars,
+  resolveBundleStamp,
+  CLI_MANAGED_VARS,
+  VERSION_STAMP_WORKER,
+  type DeployContext,
+} from '../src/lib/deploy.ts';
+import { planResources, type ResourceApi, type ScriptBindings } from '../src/lib/resource-resolver.ts';
+
+const REPO = join(fileURLToPath(new URL('.', import.meta.url)), '..', '..');
+const CYPHER_TOML = readFileSync(join(REPO, 'cypher-executor', 'wrangler.toml'), 'utf8');
+
+const CTX: DeployContext = {
+  accountId: 'acc-user-123',
+  apiToken: 'token',
+  workerSubdomain: 'user-sub',
+  selfHosted: true,
+  kbdbEmbed: true,
+};
+
+/** 一台「安裝器裝出來、已經跑過的」實例上，cypher worker 現在掛著的 plain_text var。 */
+const LIVE_VARS: Record<string, string> = {
+  ARCRUN_BUNDLE_VERSION: '1.4.29',                                  // 安裝當時的舊標籤
+  PORTAL_MAIL_RELAY_BASE: 'https://mail.example.com',               // 安裝器注入、repo toml 沒有 → 洗掉就寄不出信
+  CONSOLE_TENANT: 'someone-else',                                   // repo toml 寫死 "leo"，不能拿官方值蓋掉人家的
+  WORKER_SUBDOMAIN: 'user-sub',                                     // CLI 自己算
+  CF_ACCOUNT_ID: 'acc-user-123',                                    // CLI 自己算
+  MULTI_TENANT: 'false',                                            // CLI 自己算
+  ENVIRONMENT: 'production',                                        // 與 toml 同值 → 不必重寫
+};
+
+/** 從 render 過的 toml 讀 [vars] 區塊（只看未註解的行）。 */
+function readVars(toml: string): Record<string, string> {
+  const out: Record<string, string> = {};
+  let inVars = false;
+  for (const raw of toml.split('\n')) {
+    const line = raw.trim();
+    if (/^\[\[?[A-Za-z0-9_]+\]?\]$/.test(line)) { inVars = line === '[vars]'; continue; }
+    if (!inVars || line.startsWith('#')) continue;
+    const m = line.match(/^([A-Za-z0-9_]+)\s*=\s*"([^"]*)"/);
+    if (m) out[m[1]] = m[2];
+  }
+  return out;
+}
+
+// ═════════════════════════════════════════════════════════════════════════════
+// ① 病灶本身：舊行為會把標籤洗掉
+// ═════════════════════════════════════════════════════════════════════════════
+
+test('#106 ①：repo 的 cypher toml 本來就沒有 ARCRUN_BUNDLE_VERSION——不補就是洗掉（病灶重現）', () => {
+  const rendered = renderWranglerToml(CYPHER_TOML, CTX, new Map());
+  assert.equal(
+    readVars(rendered).ARCRUN_BUNDLE_VERSION,
+    undefined,
+    '若這行開始有值，表示 toml 自己帶了版本標籤，本測試的前提要重寫',
+  );
+});
+
+// ═════════════════════════════════════════════════════════════════════════════
+// ② 設定類 var：沿用實例上的事實
+// ═════════════════════════════════════════════════════════════════════════════
+
+test('#106 ②：安裝器注入、repo toml 沒有的 var 會被沿用（不再被重部署洗掉）', () => {
+  const keep = preservedVars(LIVE_VARS, CYPHER_TOML);
+  assert.equal(keep.PORTAL_MAIL_RELAY_BASE, 'https://mail.example.com');
+  // repo toml 寫死的是官方值，使用者實例上的值才是事實
+  assert.equal(keep.CONSOLE_TENANT, 'someone-else');
+  // 與 toml 同值 → 不需要重寫進去（雜訊）
+  assert.equal(keep.ENVIRONMENT, undefined);
+});
+
+test('#106 ③：CLI 自己算的 var 一律不沿用（沿用等於拿舊值蓋掉這趟的正解）', () => {
+  const keep = preservedVars({ ...LIVE_VARS, WORKER_SUBDOMAIN: 'OLD-sub', CF_ACCOUNT_ID: 'OLD-acc' }, CYPHER_TOML);
+  for (const managed of CLI_MANAGED_VARS) {
+    assert.equal(keep[managed], undefined, `${managed} 不該被沿用`);
+  }
+  // 而且注入完的 toml 裡，這些值仍是這趟算出來的那個
+  const rendered = renderWranglerToml(CYPHER_TOML, CTX, new Map(), keep);
+  const vars = readVars(rendered);
+  assert.equal(vars.WORKER_SUBDOMAIN, 'user-sub');
+  assert.equal(vars.CF_ACCOUNT_ID, 'acc-user-123');
+  assert.equal(vars.MULTI_TENANT, 'false');
+  assert.equal(vars.KBDB_BASE_URL, 'https://arcrun-kbdb.user-sub.workers.dev');
+});
+
+// ═════════════════════════════════════════════════════════════════════════════
+// ③ 版本標籤：重烙，不沿用
+// ═════════════════════════════════════════════════════════════════════════════
+
+test('#106 ④：版本標籤取「發行頻道公告的 release」＋ 實際 commit，不是沿用舊值', async () => {
+  const fakeFetch = (async () =>
+    new Response(JSON.stringify({ release: '1.4.41', pin: 'ba81439' }), { status: 200 })) as typeof fetch;
+  const stamp = await resolveBundleStamp('main', 'f87d0e92f49690253e7c89c5badc82a08eb5d21b', fakeFetch);
+  assert.equal(stamp.version, '1.4.41');
+  assert.notEqual(stamp.version, LIVE_VARS.ARCRUN_BUNDLE_VERSION);   // ← 這就是本 issue
+  assert.equal(stamp.commit, 'f87d0e92f49690253e7c89c5badc82a08eb5d21b');
+  assert.match(stamp.version, /^\d+\.\d+\.\d+$/, 'Portal 拿它跟 /api/latest 比 semver，必須是純 semver');
+});
+
+test('#106 ⑤：查不到發行版號時誠實標成 commit 版，**不**沿用舊值、也不掰一個 semver', async () => {
+  const fakeFetch = (async () => { throw new Error('offline'); }) as typeof fetch;
+  const stamp = await resolveBundleStamp('main', 'f87d0e92f49690253e7c89c5badc82a08eb5d21b', fakeFetch);
+  assert.match(stamp.version, /^\d{4}-\d{2}-\d{2}\+f87d0e9$/);
+  assert.notEqual(stamp.version, LIVE_VARS.ARCRUN_BUNDLE_VERSION);
+  assert.doesNotMatch(stamp.version, /^\d+\.\d+\.\d+$/, '掰一個 semver 會讓 Portal 假裝「已是最新版」');
+});
+
+test('#106 ⑥：發行頻道回了不是 semver 的東西 → 當成查不到（不把垃圾當版號烙上去）', async () => {
+  const fakeFetch = (async () =>
+    new Response(JSON.stringify({ release: 'latest' }), { status: 200 })) as typeof fetch;
+  const stamp = await resolveBundleStamp('main', 'abc1234def', fakeFetch);
+  assert.match(stamp.version, /^\d{4}-\d{2}-\d{2}\+abc1234$/);
+});
+
+// ═════════════════════════════════════════════════════════════════════════════
+// ④ 端到端（離線）：一台已安裝的實例跑一次更新，Portal 讀得到的那個欄位長什麼樣
+// ═════════════════════════════════════════════════════════════════════════════
+
+test('#106 ⑦：模擬更新——版本標籤變新、設定 var 一個不少、資源沿用不受影響', async () => {
+  const api: ResourceApi = {
+    async getScriptBindings(script: string): Promise<ScriptBindings> {
+      if (script !== VERSION_STAMP_WORKER) return { deployed: false, bindings: [], vars: {} };
+      return {
+        deployed: true,
+        bindings: [
+          { kind: 'kv_namespace', binding: 'WEBHOOKS', value: 'kv-webhooks' },
+          { kind: 'kv_namespace', binding: 'CREDENTIALS_KV', value: 'kv-creds' },
+          { kind: 'kv_namespace', binding: 'RECIPES', value: 'kv-recipes' },
+          { kind: 'kv_namespace', binding: 'USERS_KV', value: 'kv-users' },
+          { kind: 'kv_namespace', binding: 'SESSIONS_KV', value: 'kv-sessions' },
+          { kind: 'kv_namespace', binding: 'ANALYTICS_KV', value: 'kv-analytics' },
+          { kind: 'kv_namespace', binding: 'EXEC_CONTEXT', value: 'kv-exec' },
+          { kind: 'd1', binding: 'CREDENTIALS_DB', value: 'd1-kbdb' },
+        ],
+        vars: LIVE_VARS,
+      };
+    },
+    async listKvNamespaces() {
+      return new Map([
+        ['a', 'kv-webhooks'], ['b', 'kv-creds'], ['c', 'kv-recipes'], ['d', 'kv-users'],
+        ['e', 'kv-sessions'], ['f', 'kv-analytics'], ['g', 'kv-exec'],
+      ]);
+    },
+    async listD1Databases() { return new Map([['arcrun-kbdb', 'd1-kbdb']]); },
+    async listVectorizeIndexes() { return []; },
+    async createKvNamespace() { throw new Error('這趟不該新建任何 KV'); },
+    async createD1Database() { throw new Error('這趟不該新建 D1'); },
+    async createVectorizeIndex() { throw new Error('這趟不該新建 Vectorize'); },
+  };
+
+  const preview = renderWranglerToml(CYPHER_TOML, CTX, new Map());
+  const { parseWranglerRequirements } = await import('../src/lib/resource-resolver.ts');
+  const parsed = parseWranglerRequirements(preview);
+  const plan = await planResources(
+    api,
+    parsed.bindings.map((b) => ({ ...b, worker: parsed.script })),
+    'update',
+  );
+  assert.deepEqual(plan.blockers, []);
+  // 讀綁定時順手把 var 帶回來——不另外打一次 API
+  assert.equal(plan.liveVars.get(VERSION_STAMP_WORKER)?.PORTAL_MAIL_RELAY_BASE, 'https://mail.example.com');
+
+  const fakeFetch = (async () =>
+    new Response(JSON.stringify({ release: '1.4.41' }), { status: 200 })) as typeof fetch;
+  const stamp = await resolveBundleStamp('main', 'f87d0e92f49690253e7c89c5badc82a08eb5d21b', fakeFetch);
+  const extra = {
+    ...preservedVars(plan.liveVars.get(parsed.script), CYPHER_TOML),
+    ARCRUN_BUNDLE_VERSION: stamp.version,
+    ARCRUN_BUNDLE_COMMIT: stamp.commit!,
+  };
+
+  const deployed = readVars(renderWranglerToml(CYPHER_TOML, CTX, new Map(), extra));
+
+  // ① Portal 設定頁讀的就是這個欄位——更新完必須有值，且是**這趟**的版本
+  assert.equal(deployed.ARCRUN_BUNDLE_VERSION, '1.4.41');
+  assert.equal(deployed.ARCRUN_BUNDLE_COMMIT, 'f87d0e92f49690253e7c89c5badc82a08eb5d21b');
+  // ② 安裝器注入的設定沒有在更新中消失
+  assert.equal(deployed.PORTAL_MAIL_RELAY_BASE, 'https://mail.example.com');
+  assert.equal(deployed.CONSOLE_TENANT, 'someone-else');
+  // ③ CLI 自己算的仍然是這趟算出來的
+  assert.equal(deployed.WORKER_SUBDOMAIN, 'user-sub');
+  assert.equal(deployed.MULTI_TENANT, 'false');
+});
+
+// ═════════════════════════════════════════════════════════════════════════════
+// ⑤ applyVars 的三種既有狀態 + 不弄壞別的區塊
+// ═════════════════════════════════════════════════════════════════════════════
+
+test('#106 ⑧：applyVars——改既有行／取消註解／插進 [vars]／連 [vars] 都沒有時新開一段', () => {
+  assert.match(applyVars('[vars]\nA = "old"\n', { A: 'new' }), /^\[vars\]\nA = "new"\n$/);
+  assert.match(applyVars('[vars]\n# A = "old"\n', { A: 'new' }), /A = "new"/);
+  assert.match(applyVars('[vars]\nB = "b"\n', { A: 'a' }), /\[vars\]\nA = "a"\nB = "b"/);
+  const noVars = applyVars('name = "w"\n', { A: 'a' });
+  assert.match(noVars, /\[vars\]\nA = "a"/);
+  assert.match(noVars, /^name = "w"/);
+});
+
+test('#106 ⑨：var 值裡的引號／反斜線會被轉義（不會產生壞掉的 toml）', () => {
+  const out = applyVars('[vars]\n', { A: 'say "hi"\\path' });
+  assert.match(out, /A = "say \\"hi\\"\\\\path"/);
+});
+
+test('#106 ⑨b：值裡有 $& / $1 也照原樣寫出（replace 反向參照陷阱）', () => {
+  assert.match(applyVars('[vars]\nA = "old"\n', { A: 'x$&y$1z' }), /A = "x\$&y\$1z"/);
+  assert.match(applyVars('[vars]\n', { A: 'x$&y' }), /A = "x\$&y"/);
+  // 怪名字不寫進去（不拿它組正規式）
+  assert.equal(applyVars('[vars]\n', { 'BAD NAME': 'v' }), '[vars]\n');
+});
+
+test('#106 ⑩：注入 var 不影響資源綁定解析（預覽與實際寫入看到的是同一份需求）', async () => {
+  const { parseWranglerRequirements } = await import('../src/lib/resource-resolver.ts');
+  const withoutVars = parseWranglerRequirements(renderWranglerToml(CYPHER_TOML, CTX, new Map()));
+  const withVars = parseWranglerRequirements(
+    renderWranglerToml(CYPHER_TOML, CTX, new Map(), { ARCRUN_BUNDLE_VERSION: '1.4.41', X: 'y' }),
+  );
+  assert.equal(withVars.script, withoutVars.script);
+  assert.deepEqual(withVars.bindings, withoutVars.bindings);
+});
@@ -2039,6 +2039,15 @@ function taipeiMonthDay(ms) { var d = new Date(ms + TAIPEI_OFFSET_MS); return {
  // 兩邊都是 semver（例 1.4.2），用數字逐段比，不用字串比（'1.4.10' < '1.4.9' 會出錯）。
  var INSTALLER_ORIGIN = 'https://install.arcrun.dev';

+  // Arcrun#106：版號後面可以帶 build metadata（`1.4.41+d61`、`1.4.41+a1b2c3d`）——
+  // 那是 semver 規格裡「比大小時要忽略」的那一段。舊寫法拿整串去比對正規式，
+  // 一律落到「較舊版本」（youlin 實例就是這樣，明明有版號卻顯示不出來）。
+  // 這裡只取前面的 `x.y.z` 當比較用的核心，顯示仍顯示完整原字串。
+  function semverCore(v) {
+    var m = String(v || '').match(/^(\d+\.\d+\.\d+)/);
+    return m ? m[1] : '';
+  }
+
  function cmpSemver(a, b) {
    var x = String(a || '').split('.').map(Number);
    var y = String(b || '').split('.').map(Number);
@@ -2055,9 +2064,14 @@ function taipeiMonthDay(ms) { var d = new Date(ms + TAIPEI_OFFSET_MS); return {
    var btn = $('st-ver-update');
    if (!line) return;

+    // #106：順便把 bundle_commit 帶回來（有注入才有）——版號是頻道編號，commit 才是「真的部了哪份碼」。
+    var mineCommit = '';
    var mineP = fetch(window.ARCRUN_API_BASE + '/health', { cache: 'no-store' })
      .then(function (r) { return r.ok ? r.json() : null; })
-      .then(function (j) { return (j && j.bundle_version) || ''; })
+      .then(function (j) {
+        mineCommit = (j && j.bundle_commit) || '';
+        return (j && j.bundle_version) || '';
+      })
      .catch(function () { return ''; });
    var latestP = fetch(INSTALLER_ORIGIN + '/api/latest')
      .then(function (r) { return r.ok ? r.json() : null; })
@@ -2070,15 +2084,19 @@ function taipeiMonthDay(ms) { var d = new Date(ms + TAIPEI_OFFSET_MS); return {
      if (!mine) { line.textContent = '無法讀取目前版本（知識庫服務可能正在啟動）'; return; }
      // 舊實例的 bundle_version 是舊格式（2026-07-31+8e83589），比不了 semver。
      // 這種情況一律當成「落後」——因為新版才會寫 semver 進來。
-      var mineIsSemver = /^\d+\.\d+\.\d+$/.test(mine);
+      // #106：`1.4.41+<commit>` 這種帶 build metadata 的**是** semver，取核心比即可。
+      var mineCore = semverCore(mine);
+      var mineIsSemver = !!mineCore;
+      // commit 是輔助資訊（有才顯示）：版號說「哪一版」，commit 說「真的是哪份碼」。
+      var commitNote = mineCommit ? '　<span class="muted">commit ' + esc(String(mineCommit).slice(0, 7)) + '</span>' : '';

      if (!latest) {
-        line.textContent = '目前版本 ' + mine + '（暫時查不到最新版，稍後再試）';
+        line.innerHTML = '目前版本 <strong>' + esc(mine) + '</strong>（暫時查不到最新版，稍後再試）' + commitNote;
        return;
      }
-      var behind = !mineIsSemver || cmpSemver(mine, latest) < 0;
+      var behind = !mineIsSemver || cmpSemver(mineCore, latest) < 0;
      if (!behind) {
-        line.innerHTML = '目前版本 <strong>' + esc(mine) + '</strong>　已是最新版';
+        line.innerHTML = '目前版本 <strong>' + esc(mine) + '</strong>　已是最新版' + commitNote;
        dot.style.display = 'none';
        btn.style.display = 'none';
        return;
@@ -15,11 +15,19 @@ export const healthRouter = new Hono<{ Bindings: Bindings }>();
 // 要在實例自己這一側就看得出來，不是等用戶登不進去才發現（#10「寧可明顯失敗」）。
 // 只回統計不回內容（帳號數／有沒有 console 帳密／分片數），不洩漏任何 email 或雜湊。
 // bundle_version 的既有行為不動（未注入就省略該欄——daemon 對空字串判 stale 是正確的）。
+// Arcrun#106（leo 08-12 實撞：更新完設定頁變成「無法讀取目前版本」）：
+// `bundle_version` 只在部署時被注入，而**只有安裝器會注入**——CLI 更新那條路重部署
+// 等於把這個標籤洗掉（wrangler deploy 整份覆蓋，toml 沒寫的 var 直接消失）。
+// 修在 CLI 那側（cli/src/lib/deploy.ts：既有 var 沿用 + 版本標籤每趟重烙）。
+// 這裡只多吐一個 `bundle_commit`：版號是「發行頻道的編號」，commit 才是「真的部了哪份碼」——
+// 兩個一起看才有辦法查「標籤有沒有跟成品漂掉」。沒注入就省略該欄（同 bundle_version 的既有行為）。
 healthRouter.get('/health', (c) => {
  const bundleVersion = c.env.ARCRUN_BUNDLE_VERSION;
+  const bundleCommit = c.env.ARCRUN_BUNDLE_COMMIT;
  return c.json({
    ok: true,
    ...(bundleVersion ? { bundle_version: bundleVersion } : {}),
+    ...(bundleCommit ? { bundle_commit: bundleCommit } : {}),
    auth_store: authStoreStatus(c.env),
    // arcrun-rag#38/#69/#25（2026-08-11）：安裝器判斷「要不要重推」只比 bundle_version——
    // 但這次要修的洞是「installer 從沒注入過 PORTAL_MAIL_RELAY_BASE」，跟 bundle 內容
@@ -653,6 +653,215 @@ portalDataRouter.get('/portal/data/workflows', (c) =>
  }),
 );

+// ═══════════════════════════════════════════════════════════════════════════
+// 授權的 AI（arcrun-mcp）走的資料面 — 與人類 portal 同一道閘、同一份權限
+// ═══════════════════════════════════════════════════════════════════════════
+//
+// leo 2026-08-12：「人類進 Portal 輸入帳密表示你是主人，可以查到你權限所有東西；
+//   AI 透過輸入帳密的 MCP 查詢表示是授權的 AI，可以查到主人允許查的任何東西。」
+//   「掛上 MCP 並輸入帳密，那個動作本身就是授權」⇒ **下游不得再要求第二次認證**。
+//
+// 之前的病：MCP 驗完帳密只留下一個布林值，身分當場丟掉（oauth/routes.ts 舊 `loginOk = res.ok`），
+// 於是查詢時只好去找一把**服務內部金鑰**（KBDB_INTERNAL_TOKEN）直打 KBDB——
+// 那條路繞過了本檔上半部所有的庫過濾，等於「誰登入都看到同一格、而且是全部」。
+//
+// 修法＝MCP 改帶**登入者的 portal session token** 打本段端點。所以本段的每一支：
+//   ① 一律 requirePortalUser（session → 回讀 user record → 停用即時生效），
+//   ② owner_id / library 由 server 注入，**呼叫端傳什麼都不看**（與上半部同一條紅線：
+//      呼叫端自己帶租戶字串＝繞過庫過濾），
+//   ③ 越權與不存在同回 404（不洩存在性）。
+//
+// 薄殼（rule 07）：這裡沒有新能力——template/record/map 的真身都在 KBDB 基本盤，
+// 本段只做「權限注入＋轉發」，與上半部 search/entries 一模一樣的做法。
+
+/**
+ * record 的庫歸屬。與 entry 不同：**沒有 `library` slot 的 record 不套庫過濾**。
+ *
+ * 為什麼不比照 entry 用 'general' fallback：entry 是知識內容（庫是它的第一屬性，沒標就歸
+ * general 是對的）；record 是結構化資料列（contact / workflow_metadata / triplet…），
+ * 「庫」只對 triplet 這種有標 library slot 的才有意義。若照抄 general fallback，
+ * 一個庫權限是 ["kb"] 的帳號會連自己建的 contact 都讀不回——那是誤殺，不是隔離。
+ * 租戶邊界仍然守著（owner_id 由 server 注入/逐筆比對），這裡只多守「有標庫的別越庫」。
+ */
+function recordLibrary(values: Record<string, unknown> | undefined): string | null {
+  const lib = values?.library;
+  return typeof lib === 'string' && lib.trim() ? lib.trim() : null;
+}
+
+/** record 可讀？租戶要對；有標 library 的還要在用戶庫集合內。 */
+function canReadRecord(
+  rec: { values?: Record<string, unknown>; owner_id?: string | null },
+  tenant: string,
+  libraries: string[],
+): boolean {
+  if ((rec.owner_id ?? '') !== tenant) return false;
+  const lib = recordLibrary(rec.values);
+  return lib === null || canReadLibrary(libraries, lib);
+}
+
+// GET /portal/data/map — 藏書地圖全館視圖，**只回這個帳號有權限的庫**。
+// KBDB 的 /map 對權限無知（它回全館），過濾在這裡做——MCP 不得比 portal 同一個帳號看得更多。
+portalDataRouter.get('/portal/data/map', (c) =>
+  run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) {
+      return c.json({ success: true, libraries: [], count: 0, note: '此帳號尚未被授權任何知識庫，請聯絡管理員。' });
+    }
+    const res = await kbdbFetch(c.env, `/map?owner_id=${encodeURIComponent(portalTenant(c.env))}`);
+    if (!res.ok) {
+      return new Response(res.body, { status: res.status, headers: { 'Content-Type': 'application/json' } });
+    }
+    const body = (await res.json().catch(() => null)) as { libraries?: { library?: string }[] } | null;
+    if (!body || !Array.isArray(body.libraries)) {
+      return c.json({ error: '藏書地圖讀取失敗：KBDB 回應不是預期的 libraries 清單' }, 502);
+    }
+    const allowed = body.libraries.filter(
+      (l) => typeof l?.library === 'string' && canReadLibrary(libraries, l.library),
+    );
+    return c.json({ success: true, libraries: allowed, count: allowed.length });
+  }),
+);
+
+// GET /portal/data/map/:library — 單庫詳圖。無權該庫 → 與不存在同回 404（不洩存在性）。
+portalDataRouter.get('/portal/data/map/:library', (c) =>
+  run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    const library = c.req.param('library');
+    if (!canReadLibrary(libraries, library)) return notFound(c);
+    const res = await kbdbFetch(
+      c.env,
+      `/map/${encodeURIComponent(library)}?owner_id=${encodeURIComponent(portalTenant(c.env))}`,
+    );
+    if (res.status === 404) return notFound(c);
+    if (!res.ok) return c.json({ error: `KBDB 回錯（HTTP ${res.status}）` }, 502);
+    return new Response(res.body, { status: 200, headers: { 'Content-Type': 'application/json' } });
+  }),
+);
+
+// GET /portal/data/templates — template 清單。
+// template＝虛擬表定義（schema），**全域共享不分租戶**（kbdb-proxy 同一裁定，leo 2026-06-14）：
+// 它描述「資料長什麼形狀」，不含任何人的內容。內容的隔離在 records/entries 那層。
+portalDataRouter.get('/portal/data/templates', (c) =>
+  run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const res = await kbdbFetch(c.env, '/templates');
+    if (!res.ok) return c.json({ error: `KBDB 回錯（HTTP ${res.status}）` }, 502);
+    return new Response(res.body, { status: 200, headers: { 'Content-Type': 'application/json' } });
+  }),
+);
+
+// POST /portal/data/templates — 建 template（name + slots）。
+// 鐵律：這是「虛擬表定義」，不是建真的資料表；KBDB 不提供建表/SQL。
+// created_by 記租戶（溯源），template 本身全域可見可用。
+portalDataRouter.post('/portal/data/templates', (c) =>
+  run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const body = (await c.req.json().catch(() => null)) as
+      | { name?: unknown; slots?: unknown; description?: unknown }
+      | null;
+    if (!body || typeof body.name !== 'string' || !body.name.trim() || !Array.isArray(body.slots)) {
+      return c.json({ error: 'name 與 slots[] 必填' }, 400);
+    }
+    const res = await kbdbFetch(c.env, '/templates', {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({
+        name: body.name,
+        slots: body.slots,
+        description: typeof body.description === 'string' ? body.description : undefined,
+        created_by: portalTenant(c.env),
+      }),
+    });
+    return new Response(res.body, { status: res.status, headers: { 'Content-Type': 'application/json' } });
+  }),
+);
+
+// GET /portal/data/records/by-template/:template — 某 template 底下的 record。
+// server 注入 owner_id（呼叫端傳的一律忽略）；有標 library 的再逐筆過濾。
+portalDataRouter.get('/portal/data/records/by-template/:template', (c) =>
+  run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) return c.json({ success: true, records: [], count: 0 });
+    const tenant = portalTenant(c.env);
+    const res = await kbdbFetch(
+      c.env,
+      `/records/by-template/${encodeURIComponent(c.req.param('template'))}?owner_id=${encodeURIComponent(tenant)}`,
+    );
+    if (!res.ok) return c.json({ error: `KBDB 回錯（HTTP ${res.status}）` }, 502);
+    const body = (await res.json().catch(() => null)) as
+      | { records?: { values?: Record<string, unknown>; owner_id?: string | null }[] }
+      | null;
+    if (!body || !Array.isArray(body.records)) {
+      return c.json({ error: 'record 讀取失敗：KBDB 回應不是預期的 records 清單' }, 502);
+    }
+    // KBDB 已按 owner_id 過濾；這裡再守一次庫（縱深防禦，且舊部署若回多了不會外洩）。
+    const records = body.records.filter((r) => canReadRecord(r, tenant, libraries));
+    return c.json({ success: true, records, count: records.length });
+  }),
+);
+
+// GET /portal/data/records/:recordId — 單筆 record。
+// 逐筆驗歸屬（owner_id 必須是本實例租戶）＋ 驗庫；兩者不符與不存在同回 404。
+portalDataRouter.get('/portal/data/records/:recordId', (c) =>
+  run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) return notFound(c);
+    const res = await kbdbFetch(c.env, `/records/${encodeURIComponent(c.req.param('recordId'))}`);
+    if (res.status === 404) return notFound(c);
+    if (!res.ok) return c.json({ error: `KBDB 回錯（HTTP ${res.status}）` }, 502);
+    const body = (await res.json().catch(() => null)) as
+      | { record?: { values?: Record<string, unknown>; owner_id?: string | null } }
+      | null;
+    const record = body?.record;
+    if (!record) return notFound(c);
+    if (!canReadRecord(record, portalTenant(c.env), libraries)) return notFound(c);
+    return c.json({ success: true, record });
+  }),
+);
+
+// POST /portal/data/records — 依 template 填一筆 record。
+// owner_id **一律由 server 定死成本實例租戶**（呼叫端傳的忽略）——寫入端若讓呼叫端挑歸屬，
+// 等於開一扇「把資料寫進別人格子」的門。要寫進某個庫（values.library）必須有該庫權限。
+portalDataRouter.post('/portal/data/records', (c) =>
+  run(c, async () => {
+    const auth = await requirePortalUser(c);
+    if (!auth.ok) return auth.res;
+    const libraries = parseLibraries(auth.user.values.libraries);
+    if (libraries.length === 0) {
+      return c.json({ error: '此帳號尚未被授權任何知識庫，無法寫入' }, 403);
+    }
+    const body = (await c.req.json().catch(() => null)) as
+      | { template?: unknown; values?: unknown }
+      | null;
+    if (!body || typeof body.template !== 'string' || !body.template.trim() || !body.values || typeof body.values !== 'object') {
+      return c.json({ error: 'template 與 values 必填' }, 400);
+    }
+    const values = body.values as Record<string, unknown>;
+    const targetLib = recordLibrary(values);
+    if (targetLib !== null && !canReadLibrary(libraries, targetLib)) {
+      // 寫入越庫是**明確拒絕**（403），不套讀取那條 404 不洩存在性的規則：
+      // 庫名是呼叫端自己指定的，這裡沒有「洩漏某庫存在」的問題，講清楚才可修正。
+      return c.json({ error: `無「${targetLib}」庫的權限，不能寫入該庫` }, 403);
+    }
+    const res = await kbdbFetch(c.env, '/records', {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ template: body.template, values, owner_id: portalTenant(c.env) }),
+    });
+    return new Response(res.body, { status: res.status, headers: { 'Content-Type': 'application/json' } });
+  }),
+);
+
 // GET /portal/data/diagnostics — 檢修孔（2026-08-07 leo 直接指令）：
 //
 //   「可以很簡單，就是一顆按鈕在設定裡，他按鈕下載一個檔案，把檔案發給我，你看那個檔。」
@@ -677,6 +677,11 @@ portalRouter.post('/portal/login', (c) =>
      display_name: rec.values.display_name ?? '',
      role: rec.values.role ?? 'user',
      libraries: parseLibraries(rec.values.libraries),
+      // session 還能活多久（秒）。**非機密**（是這台實例的 TTL 設定，不是任何人的憑據），
+      // 但呼叫端需要它才能把自己發的憑證對齊這個上限——arcrun-mcp 用它把 OAuth
+      // access_token 的 TTL 夾到 min(自己的 TTL, 這個值)：否則 MCP token 活 30 天、
+      // 底下的 portal session 7 天就死，使用者會在第 8 天遇到「連著卻查不到」的鬼打牆。
+      session_expires_in: sessionTtl(c.env),
      // 絕不回租戶字串（design §3.3：portal_user 拿到租戶字串就能繞過庫 filter 直打 /kbdb/*）
    });
  }),
@@ -75,6 +75,13 @@ export type Bindings = {
   * 未注入（本地 dev／舊實例）＝ undefined，/health 省略該欄。
   */
  ARCRUN_BUNDLE_VERSION?: string;
+  /**
+   * Arcrun#106：這份成品實際來自哪個 commit（40 碼 sha）。
+   * `ARCRUN_BUNDLE_VERSION` 是**發行頻道的編號**（semver，Portal/daemon 拿它比新舊），
+   * 這個是**真的部了哪份碼**——兩個一起吐，標籤跟成品漂掉時查得出來。
+   * 由 `acr init/update`（cli/src/lib/deploy.ts）注入；安裝器那條路沒有此 var → /health 省略該欄。
+   */
+  ARCRUN_BUNDLE_COMMIT?: string;
  // Platform telemetry api_key（可選，wrangler secret）
  // 對應 SDD .agents/specs/llm-interface/ M1.2
  // 設了會把 agent-telemetry block 都聚集在 platform_telemetry user_id 下
@@ -103,9 +110,8 @@ export type Bindings = {
  GITEA_TOKEN?: string; // wrangler secret（建議唯讀 scope token）
  GITEA_SPRINT_REPO?: string; // 預設 Leo/InkStoneCo
  GITEA_SPRINT_DIR?: string; // 預設 system-dev/docs/3-specs/autonomy-dispatch
-  // 安裝器部署時注入的 bundle 版本（格式 "YYYY-MM-DD/commit"，老實例無此 var）。
-  // daemon 比對此值決定是否提示用戶更新（/health 曝露，缺 var 時回空字串）。
-  ARCRUN_BUNDLE_VERSION?: string;
+  // （ARCRUN_BUNDLE_VERSION 原本在這裡重複宣告了一次——TS2300 重複識別字，
+  //   #106 順手併回上面那一處，說明同源，行為零變化。）
  // MCP access_token 存活秒數的「顯示鏡像」（console 設定頁 MCP TTL 佔位區塊用）。
  // 真相住在 mcp worker 的同名 env（mcp/src/types.ts，預設 2592000＝30 天）；cypher 這份
  // 只供顯示，兩處部署時要一致（#32 形態 config 同步教訓）。未設 → 頁面如實標「預設值」。
@@ -26,4 +26,33 @@ describe('GET /health — bundle_version 欄位', () => {
    expect(data.ok).toBe(true);
    expect(data.bundle_version).toBe('2026-07-28/6d06162');
  });
+
+  // Arcrun#106：CLI 更新那條路會多烙一個 commit（版號＝發行頻道編號，commit＝真的部了哪份碼）。
+  it('有 ARCRUN_BUNDLE_COMMIT 時一起回（acr update 注入情境）', async () => {
+    const fakeEnv = {
+      ARCRUN_BUNDLE_VERSION: '1.4.41',
+      ARCRUN_BUNDLE_COMMIT: 'f87d0e92f49690253e7c89c5badc82a08eb5d21b',
+    } as unknown as Bindings;
+    const res = await healthRouter.fetch(
+      new Request('http://localhost/health'),
+      fakeEnv,
+      {} as ExecutionContext,
+    );
+    const data = await res.json() as { bundle_version: string; bundle_commit: string };
+    expect(data.bundle_version).toBe('1.4.41');
+    expect(data.bundle_commit).toBe('f87d0e92f49690253e7c89c5badc82a08eb5d21b');
+  });
+
+  // 安裝器那條路沒有這個 var（回歸：不能因為多了新欄位就讓舊路徑多吐一個空字串出來）。
+  it('沒 ARCRUN_BUNDLE_COMMIT 就省略該欄（安裝器路徑不受影響）', async () => {
+    const fakeEnv = { ARCRUN_BUNDLE_VERSION: '1.4.41' } as unknown as Bindings;
+    const res = await healthRouter.fetch(
+      new Request('http://localhost/health'),
+      fakeEnv,
+      {} as ExecutionContext,
+    );
+    const data = await res.json() as { bundle_version: string; bundle_commit?: string };
+    expect(data.bundle_version).toBe('1.4.41');
+    expect(data.bundle_commit).toBeUndefined();
+  });
 });
@@ -232,6 +232,214 @@ describe('GET /portal/data/entries/:id（逐筆驗庫）', () => {
  });
 });

+// ═══════════════ 3b. 授權的 AI（arcrun-mcp）走的資料面 ═══════════════
+//
+// leo 2026-08-12：「AI 透過輸入帳密的 MCP 查詢表示是授權的 AI，可以查到主人允許查的任何東西。」
+// ⇒ 這幾支端點與人類走的 search/entries 是同一道閘：同一個 session、同一份庫權限、
+//   同樣「呼叫端自帶 owner_id 一律不生效」、同樣「越權與不存在同一句 404」。
+
+describe('藏書地圖 /portal/data/map（MCP 走的那條）', () => {
+  it('只回這個帳號有權限的庫；全館其他庫不出現在回應裡', async () => {
+    await seedSession('tok-m1', 'rec_1');
+    mockGetRecord('rec_1', userValues({ libraries: '["finance"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: (p: string) => p.startsWith('/map?'), method: 'GET' })
+      .reply(200, {
+        success: true,
+        libraries: [
+          { library: 'finance', narrative: '財務', top_entities: [], triplet_count: 3 },
+          { library: 'hr', narrative: '人資', top_entities: [], triplet_count: 9 },
+        ],
+        count: 2,
+      });
+    const res = await get('/portal/data/map', { Authorization: 'Bearer tok-m1' });
+    expect(res.status).toBe(200);
+    const data = (await res.json()) as { libraries: { library: string }[]; count: number };
+    expect(data.libraries.map((l) => l.library)).toEqual(['finance']);
+    expect(data.count).toBe(1);
+  });
+
+  it('["*"] 全庫 → 全部庫都回', async () => {
+    await seedSession('tok-m2', 'rec_2');
+    mockGetRecord('rec_2', userValues({ libraries: '["*"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: (p: string) => p.startsWith('/map?'), method: 'GET' })
+      .reply(200, {
+        success: true,
+        libraries: [
+          { library: 'finance', narrative: '', top_entities: [], triplet_count: 3 },
+          { library: 'hr', narrative: '', top_entities: [], triplet_count: 9 },
+        ],
+        count: 2,
+      });
+    const res = await get('/portal/data/map', { Authorization: 'Bearer tok-m2' });
+    const data = (await res.json()) as { libraries: { library: string }[] };
+    expect(data.libraries.map((l) => l.library)).toEqual(['finance', 'hr']);
+  });
+
+  it('庫集合為空 → 誠實空結果＋說明，不打 KBDB', async () => {
+    await seedSession('tok-m3', 'rec_3');
+    mockGetRecord('rec_3', userValues({ libraries: '[]' }));
+    const res = await get('/portal/data/map', { Authorization: 'Bearer tok-m3' });
+    expect(res.status).toBe(200);
+    const data = (await res.json()) as { count: number; note?: string };
+    expect(data.count).toBe(0);
+    expect(data.note).toContain('尚未被授權');
+  });
+
+  it('單庫詳圖：無權該庫 → 404 同一句（不打 KBDB，不洩該庫存不存在）', async () => {
+    await seedSession('tok-m4', 'rec_4');
+    mockGetRecord('rec_4', userValues({ libraries: '["finance"]' }));
+    const res = await get('/portal/data/map/hr', { Authorization: 'Bearer tok-m4' });
+    expect(res.status).toBe(404);
+    expect(((await res.json()) as { error: string }).error).toBe('找不到這筆資料');
+  });
+
+  it('單庫詳圖：有權該庫 → 200 轉發', async () => {
+    await seedSession('tok-m5', 'rec_5');
+    mockGetRecord('rec_5', userValues({ libraries: '["finance"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: (p: string) => p.startsWith('/map/finance'), method: 'GET' })
+      .reply(200, { success: true, map: { library: 'finance', triplet_count: 3 } });
+    const res = await get('/portal/data/map/finance', { Authorization: 'Bearer tok-m5' });
+    expect(res.status).toBe(200);
+  });
+
+  it('未登入 → 401', async () => {
+    expect((await get('/portal/data/map')).status).toBe(401);
+  });
+});
+
+describe('結構化資料 /portal/data/records、/portal/data/templates（MCP 走的那條）', () => {
+  it('by-template：server 注入 owner_id；caller 自帶的被靜默覆蓋（繞不過）', async () => {
+    await seedSession('tok-r1', 'rec_1');
+    mockGetRecord('rec_1', userValues({ libraries: '["*"]' }));
+    let captured = '';
+    fetchMock
+      .get(KBDB)
+      .intercept({
+        path: (p: string) => {
+          if (!p.startsWith('/records/by-template/contact')) return false;
+          captured = p;
+          return true;
+        },
+        method: 'GET',
+      })
+      .reply(200, { success: true, records: [], count: 0 });
+    const res = await get('/portal/data/records/by-template/contact?owner_id=someone-else', {
+      Authorization: 'Bearer tok-r1',
+    });
+    expect(res.status).toBe(200);
+    expect(new URL(`http://x${captured}`).searchParams.get('owner_id')).toBe(TENANT);
+  });
+
+  it('by-template：有標 library 的 record 越庫的被濾掉；沒標 library 的照回', async () => {
+    await seedSession('tok-r2', 'rec_2');
+    mockGetRecord('rec_2', userValues({ libraries: '["finance"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: (p: string) => p.startsWith('/records/by-template/triplet'), method: 'GET' })
+      .reply(200, {
+        success: true,
+        records: [
+          { record_id: 'r1', owner_id: TENANT, values: { library: 'finance', subject: 'A' } },
+          { record_id: 'r2', owner_id: TENANT, values: { library: 'hr', subject: 'B' } },
+          { record_id: 'r3', owner_id: TENANT, values: { subject: 'C' } }, // 沒標庫＝結構化資料列
+        ],
+        count: 3,
+      });
+    const res = await get('/portal/data/records/by-template/triplet', { Authorization: 'Bearer tok-r2' });
+    const data = (await res.json()) as { records: { record_id: string }[] };
+    expect(data.records.map((r) => r.record_id)).toEqual(['r1', 'r3']);
+  });
+
+  it('單筆：別的租戶的 record → 404 同一句（就算全庫權限也擋）', async () => {
+    await seedSession('tok-r3', 'rec_3');
+    mockGetRecord('rec_3', userValues({ libraries: '["*"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: '/records/r_other', method: 'GET' })
+      .reply(200, { success: true, record: { record_id: 'r_other', owner_id: 'other-tenant', values: {} } });
+    const res = await get('/portal/data/records/r_other', { Authorization: 'Bearer tok-r3' });
+    expect(res.status).toBe(404);
+    expect(((await res.json()) as { error: string }).error).toBe('找不到這筆資料');
+  });
+
+  it('單筆：越庫的 record → 404 同一句；有權的 → 200', async () => {
+    await seedSession('tok-r4', 'rec_4');
+    mockGetRecord('rec_4', userValues({ libraries: '["finance"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: '/records/r_hr', method: 'GET' })
+      .reply(200, { success: true, record: { record_id: 'r_hr', owner_id: TENANT, values: { library: 'hr' } } });
+    expect((await get('/portal/data/records/r_hr', { Authorization: 'Bearer tok-r4' })).status).toBe(404);
+
+    await seedSession('tok-r5', 'rec_5');
+    mockGetRecord('rec_5', userValues({ libraries: '["finance"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: '/records/r_fin', method: 'GET' })
+      .reply(200, { success: true, record: { record_id: 'r_fin', owner_id: TENANT, values: { library: 'finance' } } });
+    expect((await get('/portal/data/records/r_fin', { Authorization: 'Bearer tok-r5' })).status).toBe(200);
+  });
+
+  it('寫入：owner_id 由 server 定死，呼叫端塞的不算', async () => {
+    await seedSession('tok-r6', 'rec_6');
+    mockGetRecord('rec_6', userValues({ libraries: '["*"]' }));
+    let body: Record<string, unknown> = {};
+    fetchMock
+      .get(KBDB)
+      .intercept({
+        path: '/records',
+        method: 'POST',
+        body: (b: string) => {
+          body = JSON.parse(b) as Record<string, unknown>;
+          return true;
+        },
+      })
+      .reply(200, { success: true, record: { record_id: 'r_new' } });
+    const res = await SELF.fetch('http://localhost/portal/data/records', {
+      method: 'POST',
+      headers: { Authorization: 'Bearer tok-r6', 'Content-Type': 'application/json' },
+      body: JSON.stringify({ template: 'contact', values: { name: 'Leo' }, owner_id: 'someone-else' }),
+    });
+    expect(res.status).toBe(200);
+    expect(body.owner_id).toBe(TENANT);
+  });
+
+  it('寫入越庫 → 403（明確拒絕，庫名是呼叫端自己指定的，沒有存在性可洩）', async () => {
+    await seedSession('tok-r7', 'rec_7');
+    mockGetRecord('rec_7', userValues({ libraries: '["finance"]' }));
+    const res = await SELF.fetch('http://localhost/portal/data/records', {
+      method: 'POST',
+      headers: { Authorization: 'Bearer tok-r7', 'Content-Type': 'application/json' },
+      body: JSON.stringify({ template: 'note', values: { library: 'hr', body: 'x' } }),
+    });
+    expect(res.status).toBe(403);
+  });
+
+  it('templates 全域共享（schema 非內容）：登入即可列', async () => {
+    await seedSession('tok-t1', 'rec_t1');
+    mockGetRecord('rec_t1', userValues({ libraries: '["finance"]' }));
+    fetchMock
+      .get(KBDB)
+      .intercept({ path: '/templates', method: 'GET' })
+      .reply(200, { success: true, templates: [{ id: 'tpl1', name: 'contact' }], count: 1 });
+    const res = await get('/portal/data/templates', { Authorization: 'Bearer tok-t1' });
+    expect(res.status).toBe(200);
+    expect(((await res.json()) as { count: number }).count).toBe(1);
+  });
+
+  it('未登入 → 401（records / templates 都是）', async () => {
+    expect((await get('/portal/data/templates')).status).toBe(401);
+    expect((await get('/portal/data/records/by-template/contact')).status).toBe(401);
+    expect((await get('/portal/data/records/r1')).status).toBe(401);
+  });
+});
+
 // ═══════════════ 4. graph D-4 粗閘 ═══════════════

 describe('GET /portal/data/graph/neighbors/:name（D-4 粗閘）', () => {
@@ -0,0 +1,25 @@
+-- credential template seed（D38 圍牆修復，總管交辦，2026-08-07）
+-- SDD：無專屬 SDD（D38 事故修復任務，見 system-dev/wiki/decisions-summary.md D38 段）。
+--
+-- D38 鐵律（leo 2026-06-14 立、2026-08-07 擴大）：KBDB 三張表打天下，永遠不加新表；
+-- 新資料類型一律用 template + entries，同 0003_library_map.sql / 0004_execution_log_template.sql
+-- 的手法——對 templates 表 INSERT OR IGNORE 一列定義，不建新表、不動既有表的結構。
+--
+-- 這是「credential 目錄」的第二個家：原本 0002_credentials.sql 在 KBDB 裡多開了一張
+-- 獨立表（違規，見 kbdb-usage skill「反例」），本檔 + 0006_drop_credentials_table.sql
+-- 把它改回三張表的形狀——一筆 credential＝entries 表一列（entry_type='credential'，
+-- page_name=name 當冪等鍵，owner_id=api_key 做租戶隔離，其餘欄位打包進 metadata_json），
+-- 儲存精神比照既有 recipe_stat / execution_log（template 只負責文件化，實際資料不走
+-- entry_values 全展開的多列 record）。
+--
+-- 密文本體不在這裡：值仍住在 CF Workers per-script Secrets（掛在 cypher worker 上，管理
+-- API 唯寫，D19「擁有目錄，不擁有內容物」不變）。這張 template 定義的 slots 全部是目錄
+-- 欄位，零密文——與舊 0002_credentials.sql 的欄位定義一字不變，只是換了個家。
+INSERT OR IGNORE INTO templates (id, name, description, slots_json, created_by)
+VALUES (
+  'tpl-credential',
+  'credential',
+  'credential 目錄（D38 圍牆修復：改走 entries 表 entry_type=credential，取代舊 credentials 表；零密文，密文本體住 Workers per-script Secrets）',
+  '["name","service","sensitivity","secret_ref","last_used_at"]',
+  'system'
+);
@@ -0,0 +1,47 @@
+-- 退役 credentials 表（D38 圍牆修復，總管交辦，2026-08-07）
+-- SDD：無專屬 SDD（D38 事故修復任務，見 system-dev/wiki/decisions-summary.md D38 段）。
+--
+-- 這是本次唯一真的需要動表結構的一支 migration，理由（不是繞過鐵律，是鐵律要求的收尾）：
+--   D38 要求 KBDB 回到「只有三張核心表」的狀態。0002_credentials.sql 當初在 KBDB 裡多開了
+--   一張獨立表，是已知違規（kbdb-usage skill 明文列為反例）。要把違規清乾淨，唯一辦法就是
+--   真的把那張表拆掉——拆表本身不能只用 API 做（API 不提供「拆表」這種牆內維運操作，
+--   也不該提供），所以下面兩句 SQL 標 kbdb-sql-ok：這不是繞過圍牆去存取資料，是圍牆施工
+--   本身（kbdb/migrations/ 就是牆內，本檔存在的唯一目的就是讓舊表退場）。
+--
+-- 冪等設計（deploy.ts 每次部署都會重跑這支檔案，沒有 migration 追蹤表）：
+--   1. 先補一份空表存在保底——self-hosted 各實例套用進度不一，有些從沒跑過 0002（表從不
+--      存在）、有些已經跑過本檔一次（表已被拆）。沒有這一步，下面的搬資料/退場語句會因表
+--      不存在直接整支失敗（D1 對不存在的表沒有條件式跳過語法）。
+--   2. 把舊表裡「entries 還沒有對應列」的 row 搬進 entries（entry_type='credential'，
+--      page_name=name 冪等鍵，owner_id=api_key，其餘欄位打包進 metadata_json，欄位對應
+--      0005_credential_template.sql 定義的 slots）。NOT EXISTS 判斷防止重跑造成重複列。
+--   3. 搬完資料後表就沒有存在的理由，最後一步讓它退場。下次部署若又被步驟 1 重新墊一份
+--      空殼，也只是空表、立刻搬 0 筆、立刻退場，不影響任何人（真資料只會被搬一次，因為
+--      步驟 2 的判斷是看 entries 裡有沒有，不是看這是不是第一次跑）。
+CREATE TABLE IF NOT EXISTS credentials ( -- kbdb-sql-ok: 表退場施工步驟①保底存在，非資料存取違規，理由見檔頭
+  api_key      TEXT NOT NULL,
+  name         TEXT NOT NULL,
+  service      TEXT,
+  sensitivity  TEXT NOT NULL DEFAULT 'standard',
+  secret_ref   TEXT NOT NULL,
+  created_at   INTEGER NOT NULL,
+  last_used_at INTEGER,
+  PRIMARY KEY (api_key, name)
+);
+
+INSERT INTO entries (id, entry_type, owner_id, page_name, metadata_json, created_at, updated_at)
+SELECT
+  'e_cred_' || lower(hex(randomblob(8))),
+  'credential',
+  c.api_key,
+  c.name,
+  json_object('service', c.service, 'sensitivity', c.sensitivity, 'secret_ref', c.secret_ref, 'last_used_at', c.last_used_at),
+  c.created_at,
+  unixepoch()
+FROM credentials c
+WHERE NOT EXISTS (
+  SELECT 1 FROM entries e
+  WHERE e.entry_type = 'credential' AND e.owner_id = c.api_key AND e.page_name = c.name
+);
+
+DROP TABLE IF EXISTS credentials; -- kbdb-sql-ok: 表退場施工步驟③讓舊表退場，非資料存取違規，理由見檔頭
@@ -65,6 +65,13 @@ export interface RecordResult {
  record_id: string;
  template_id: string;
  values: Record<string, string>;
+  /**
+   * record 的歸屬（＝其底層 slot entries 的 owner_id，createRecord 寫入時同一值）。
+   * 2026-08-12 補：`GET /records/:id` 原本不回這欄，所以**呼叫端無從判斷這筆是不是自己的**
+   * ——按 id 直讀等於沒有租戶邊界。要讓 cypher 的 portal 資料面（授權的人/AI 走的那條）
+   * 能對單筆做「不是我的就回 404」，歸屬必須跟著資料一起回來。無歸屬的舊資料 → null。
+   */
+  owner_id: string | null;
 }

 export async function createRecord(db: D1Database, input: CreateRecordInput): Promise<RecordResult> {
@@ -85,7 +92,7 @@ export async function createRecord(db: D1Database, input: CreateRecordInput): Pr
      .bind(uid('ev'), recordId, tpl.id, slot, entry.id)
      .run();
  }
-  return { record_id: recordId, template_id: tpl.id, values: input.values };
+  return { record_id: recordId, template_id: tpl.id, values: input.values, owner_id: input.owner_id ?? null };
 }

 // Update an existing record's slot values (mira-dissolve T2.1, issue #6).
@@ -147,17 +154,19 @@ export async function updateRecord(
 export async function getRecord(db: D1Database, recordId: string): Promise<RecordResult | null> {
  const res = await db
    .prepare(
-      `SELECT ev.slot_name as slot, e.content as content, ev.template_id as template_id
+      `SELECT ev.slot_name as slot, e.content as content, ev.template_id as template_id, e.owner_id as owner_id
       FROM entry_values ev JOIN entries e ON ev.entry_id = e.id
       WHERE ev.record_id = ?`,
    )
    .bind(recordId)
-    .all<{ slot: string; content: string; template_id: string }>();
+    .all<{ slot: string; content: string; template_id: string; owner_id: string | null }>();
  const rows = res.results ?? [];
  if (rows.length === 0) return null;
  const values: Record<string, string> = {};
  for (const r of rows) values[r.slot] = r.content;
-  return { record_id: recordId, template_id: rows[0].template_id, values };
+  // 歸屬取第一個非 null 的 slot entry owner（同一 record 的 slot entries 同歸屬）
+  const owner_id = rows.find((r) => r.owner_id != null)?.owner_id ?? null;
+  return { record_id: recordId, template_id: rows[0].template_id, values, owner_id };
 }

 export async function searchByTemplate(db: D1Database, template: string, owner_id?: string, limit = 100): Promise<RecordResult[]> {
@@ -192,19 +201,20 @@ export async function searchByTemplate(db: D1Database, template: string, owner_i
    const placeholders = chunk.map(() => '?').join(',');
    const evRes = await db
      .prepare(
-        `SELECT ev.record_id as record_id, ev.slot_name as slot, e.content as content, ev.template_id as template_id
+        `SELECT ev.record_id as record_id, ev.slot_name as slot, e.content as content, ev.template_id as template_id, e.owner_id as owner_id
         FROM entry_values ev JOIN entries e ON ev.entry_id = e.id
         WHERE ev.record_id IN (${placeholders})`,
      )
      .bind(...chunk)
-      .all<{ record_id: string; slot: string; content: string; template_id: string }>();
+      .all<{ record_id: string; slot: string; content: string; template_id: string; owner_id: string | null }>();
    for (const r of evRes.results ?? []) {
      let rec = byId.get(r.record_id);
      if (!rec) {
-        rec = { record_id: r.record_id, template_id: r.template_id, values: {} };
+        rec = { record_id: r.record_id, template_id: r.template_id, values: {}, owner_id: null };
        byId.set(r.record_id, rec);
      }
      rec.values[r.slot] = r.content;
+      if (rec.owner_id == null && r.owner_id != null) rec.owner_id = r.owner_id;
    }
  }
  return ids.map((id) => byId.get(id)).filter((r): r is RecordResult => !!r);
@@ -1,13 +1,25 @@
 import { Hono } from "hono";
 import { cors } from "hono/cors";
 import { Env } from "./types.js";
-import { partnerAuthMiddleware } from "./middleware/partner-auth.js";
+import { partnerAuthMiddleware, type AuthPath } from "./middleware/partner-auth.js";
 import { handleMcpRequest } from "./mcp-handler.js";
+import { resolveKnowledgeIdentity } from "./lib/portal-client.js";
+import type { PortalIdentity } from "./oauth/store.js";
 import { inspectorHtml } from "./pages/inspector.js";
 import { kbdbFetch } from "./lib/kbdb-client.js";
 import { registerOAuthRoutes } from "./oauth/routes.js";

-const _app = new Hono<{ Bindings: Env; Variables: { org_namespace: string; partner_token: string } }>();
+const _app = new Hono<{
+  Bindings: Env;
+  Variables: {
+    org_namespace: string;
+    partner_token: string;
+    // 登入者身分（以帳密走 OAuth 連進來時才有）＋ 這條連線是哪種憑據。
+    // 知識面工具（kbdb_*）據此決定走 portal 資料面還是既有 KBDB 直連（見 lib/portal-client.ts）。
+    portal?: PortalIdentity;
+    auth_path: AuthPath;
+  };
+}>();

 // ── OAuth 2.1 server 路由（掛在 worker 根路徑，非 /mcp）──────────────────────────
 // well-known / authorize / token / register 必須在 origin 根，claude.ai 遠端 connector 才發現得到。
@@ -261,7 +273,8 @@ app.options("/mcp", (c) => {
 app.post("/", partnerAuthMiddleware, async (c) => {
  const orgNamespace = c.get("org_namespace");
  const partnerToken = c.get("partner_token");
-  return handleMcpRequest(c.req.raw, c.env, orgNamespace, partnerToken);
+  const identity = resolveKnowledgeIdentity(c.get("auth_path"), c.get("portal"));
+  return handleMcpRequest(c.req.raw, c.env, orgNamespace, partnerToken, identity);
 });

 // 輸出根 app（_app）：與 basePath('/mcp') 的 app 共享同一份 router，故 OAuth 根路由與
@@ -19,6 +19,7 @@

 import type { Env } from "../types.js";
 import { kbdbFetch } from "./kbdb-client.js";
+import { portalFetch, type KnowledgeIdentity } from "./portal-client.js";

 /** 全館視圖一行（kbdb GET /map 的 libraries[] 元素；top_entities 已是 top-3 名字）。 */
 export interface LibraryMapRow {
@@ -86,25 +87,45 @@ const MAP_FETCH_TIMEOUT_MS = 1500;
 const CACHE_TTL_OK_MS = 5 * 60 * 1000;
 const CACHE_TTL_FAIL_MS = 60 * 1000;

-let instructionsCache: { text: string | null; expiresAt: number } | null = null;
+/**
+ * 快取以「身分」分格（2026-08-12）。
+ *
+ * 為什麼不能共用一格：地圖本身就是情報（哪些庫存在、各有多少關聯、核心 entity 是誰）。
+ * 以帳密連線時只該看到自己有權限的庫；若跟服務級連線共用同一格快取，先連上的那個人
+ * 會把自己的視野留給下一個人——那是跨帳號外洩，不是效能問題。
+ */
+const instructionsCache = new Map<string, { text: string | null; expiresAt: number }>();

 /** 測試用：清掉 isolate 內快取（prod 不呼叫）。 */
 export function __resetLibraryMapInstructionsCacheForTests(): void {
-  instructionsCache = null;
+  instructionsCache.clear();
 }

 /**
 * 組 MCP server instructions 的藏書地圖段（design §4 / §6「session 啟動 → instructions 已含
 * 全館地圖（push 零查詢）」）。任何失敗（超時/HTTP 錯/空庫/壞 JSON）→ null（caller 靜默略過）。
+ *
+ * 以帳密連線（identity.kind === 'portal'）時走 cypher `/portal/data/map`——只拿得到這個
+ * 帳號有權限的庫；服務級憑據維持既有 KBDB `/map` 直連。舊 token（stale）不給地圖。
 */
-export async function buildLibraryMapInstructions(env: Env): Promise<string | null> {
+export async function buildLibraryMapInstructions(
+  env: Env,
+  identity: KnowledgeIdentity,
+): Promise<string | null> {
+  if (identity.kind === "stale") return null;
+  // 快取 key：portal 用 session（＝這個人這次登入），service 用固定字串。
+  // session token 只當 Map 的 key 活在 isolate 記憶體內，不落地、不寫 log。
+  const cacheKey = identity.kind === "portal" ? `portal:${identity.portal.session}` : "service";
  const now = Date.now();
-  if (instructionsCache && instructionsCache.expiresAt > now) return instructionsCache.text;
+  const hit = instructionsCache.get(cacheKey);
+  if (hit && hit.expiresAt > now) return hit.text;

  let text: string | null = null;
  try {
    const res = await Promise.race([
-      kbdbFetch(env, "/map"),
+      identity.kind === "portal"
+        ? portalFetch(env, identity.portal.session, "/portal/data/map")
+        : kbdbFetch(env, "/map"),
      new Promise<never>((_, reject) =>
        setTimeout(() => reject(new Error("library map fetch timeout")), MAP_FETCH_TIMEOUT_MS),
      ),
@@ -124,6 +145,13 @@ export async function buildLibraryMapInstructions(env: Env): Promise<string | nu
    text = null;
  }

-  instructionsCache = { text, expiresAt: now + (text ? CACHE_TTL_OK_MS : CACHE_TTL_FAIL_MS) };
+  instructionsCache.set(cacheKey, {
+    text,
+    expiresAt: now + (text ? CACHE_TTL_OK_MS : CACHE_TTL_FAIL_MS),
+  });
+  // isolate 內的快取，不做失效協議；但別讓不同帳號的格子無上限長大（isolate 可活很久）。
+  if (instructionsCache.size > 64) {
+    for (const [k, v] of instructionsCache) if (v.expiresAt <= now) instructionsCache.delete(k);
+  }
  return text;
 }
@@ -0,0 +1,113 @@
+/**
+ * Portal 資料面 client — 「授權的 AI」用登入者的身分查東西的唯一管道。
+ *
+ * leo 2026-08-12：「人類進 Portal 輸入帳密表示你是主人，可以查到你權限所有東西；
+ *   AI 透過輸入帳密的 MCP 查詢表示是授權的 AI，可以查到主人允許查的任何東西。」
+ *   「掛上 MCP 並輸入帳密，那個動作本身就是授權」⇒ **下游不得再要求第二次認證**。
+ *
+ * 所以這裡帶的是 **portal session token**（同意頁輸入帳密時 cypher 發的那張，
+ * 與人類在 portal 網頁上拿到的完全同一種），不是任何服務內部金鑰。
+ * 端點是 cypher 的 `/portal/data/*`——庫過濾、租戶注入、停用即時生效全在那邊 server 側做完，
+ * 本檔不做任何判斷（薄殼鐵律 rule 07：能力長在 API，介面只轉換）。
+ *
+ * 走既有 CYPHER_EXECUTOR service binding，不新增 binding、不新增金鑰。
+ */
+
+import type { Env } from "../types.js";
+import type { PortalIdentity } from "../oauth/store.js";
+import { errorResponse } from "./cypher-client.js";
+
+export interface PortalCallOpts {
+  method?: string;
+  body?: unknown;
+  query?: Record<string, string | number | undefined>;
+}
+
+/** 用登入者的 session 打 cypher 的 portal 資料面。 */
+export async function portalFetch(
+  env: Env,
+  session: string,
+  path: string,
+  opts: PortalCallOpts = {},
+): Promise<Response> {
+  if (!env.CYPHER_EXECUTOR) {
+    throw new Error("CYPHER_EXECUTOR service binding not configured");
+  }
+  const url = new URL(`https://cypher${path}`);
+  for (const [k, v] of Object.entries(opts.query ?? {})) {
+    if (v !== undefined && v !== "") url.searchParams.set(k, String(v));
+  }
+  return env.CYPHER_EXECUTOR.fetch(url.toString(), {
+    method: opts.method ?? "GET",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${session}`,
+    },
+    body: opts.body !== undefined ? JSON.stringify(opts.body) : undefined,
+  });
+}
+
+/**
+ * 知識面工具的身分解析結果。
+ *
+ * 三態刻意分開，因為「查不到」和「沒有」不可以長得一樣（leo 的老原則）：
+ *   - portal   ：有登入者 → 走 portal 資料面（權限＝這個人的權限）
+ *   - service  ：服務級憑據（static token / partner key）→ 維持既有 KBDB 直連（零回歸）
+ *   - stale    ：OAuth token 但沒帶身分（本次改版前簽發的舊 token）→ **誠實要求重新連線**，
+ *                不偷偷退回服務金鑰那條老路（那正是要修掉的「不管誰登入都看到同一格」）
+ */
+export type KnowledgeIdentity =
+  | { kind: "portal"; portal: PortalIdentity }
+  | { kind: "service" }
+  | { kind: "stale" };
+
+export function resolveKnowledgeIdentity(
+  authPath: "oauth" | "service",
+  portal: PortalIdentity | undefined,
+): KnowledgeIdentity {
+  if (authPath !== "oauth") return { kind: "service" };
+  return portal?.session ? { kind: "portal", portal } : { kind: "stale" };
+}
+
+/** 舊 token（沒帶身分）時的統一回覆：講清楚怎麼修，不假裝查不到資料。 */
+export function staleIdentityError() {
+  return errorResponse(
+    "identity_missing",
+    "這條 MCP 連線是舊版簽發的 token，裡面沒有登入者身分，因此查不到任何知識內容。" +
+      "重新連線一次（在 claude.ai 的 connector 設定裡重新授權、輸入你的 Portal 帳密）即可——" +
+      "不需要另外找任何 credential 或金鑰。",
+    [
+      "到 claude.ai → Settings → Connectors，把這個 connector 重新連線一次（會跳出輸入 Portal 帳密的頁面）",
+      "重連後 kbdb_* 全部工具都會用你這個帳號的權限查詢",
+    ],
+  );
+}
+
+/**
+ * portal 資料面的錯誤 → 給 AI 看的訊息。
+ * 401/403 特別處理：那代表**登入階段過期或帳號被停用**，不是「資料不存在」——
+ * 兩者混在一起會讓 AI 對使用者說「你的知識庫是空的」，那是畫面在說謊。
+ */
+export async function portalError(res: Response, what: string) {
+  const detail = await res.text().catch(() => "");
+  if (res.status === 401) {
+    return errorResponse(
+      "session_expired",
+      `${what}失敗：登入階段已過期（portal session 到期或已登出）。`,
+      [
+        "到 claude.ai → Settings → Connectors 重新連線這個 connector（重新輸入 Portal 帳密）",
+        "重連後權限與你在 portal 網頁上看到的一致",
+      ],
+      detail,
+    );
+  }
+  if (res.status === 403) {
+    return errorResponse(
+      "forbidden",
+      `${what}失敗：這個帳號沒有這項權限（帳號可能已停用，或沒有被授權該知識庫）。`,
+      ["請知識庫管理員在 portal 的帳號管理裡確認你的狀態與可用知識庫"],
+      detail,
+    );
+  }
+  return errorResponse(`portal_${res.status}`, `${what}失敗（HTTP ${res.status}）`, ["稍後重試"], detail);
+}
@@ -2,6 +2,7 @@ import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
 import { WebStandardStreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/webStandardStreamableHttp.js";
 import { registerAllTools } from "./tools/registry.js";
 import { buildLibraryMapInstructions } from "./lib/library-map.js";
+import type { KnowledgeIdentity } from "./lib/portal-client.js";
 import { Env } from "./types.js";

 export async function handleMcpRequest(
@@ -9,11 +10,16 @@ export async function handleMcpRequest(
  env: Env,
  orgNamespace: string,
  partnerToken: string,
+  identity: KnowledgeIdentity,
 ): Promise<Response> {
  // library-map SDD M4（design §4/§6）：連線時把全館藏書地圖嵌進 server instructions，
  // session 一開就知道館裡有哪些庫（push 零查詢）。builder 內建 timeout＋isolate TTL 快取
  //（選型理由見 lib/library-map.ts 檔頭）；任何失敗回 null → 靜默略過，絕不擋 MCP 連線（鐵律）。
-  const mapInstructions = await buildLibraryMapInstructions(env);
+  //
+  // 🔴 2026-08-12：以帳密連線時**改用登入者的身分**組地圖——否則 instructions 會把
+  //    整個知識庫的庫名一次推給一個可能只有部分權限的帳號（地圖本身就是情報）。
+  //    快取也因此改成 per-session key（見 lib/library-map.ts）。
+  const mapInstructions = await buildLibraryMapInstructions(env, identity);

  // 2026-07-30（leo 問「人類說『幫我用 arcrun 寫 xxx』，Haiku 會知道要用這些資源嗎？
  // 如果不會，要寫什麼在外面讓它一聽到就知道？」）：
@@ -60,7 +66,7 @@ export async function handleMcpRequest(
    { instructions },
  );

-  registerAllTools(server, env, orgNamespace, partnerToken);
+  registerAllTools(server, env, orgNamespace, partnerToken, identity);
  await server.connect(transport);

  return transport.handleRequest(request);
@@ -1,9 +1,19 @@
 import { Context, Next } from "hono";
 import { Env } from "../types.js";
-import { getAccessToken } from "../oauth/store.js";
+import { getAccessToken, type PortalIdentity } from "../oauth/store.js";
 import { constantTimeEqual } from "../oauth/crypto.js";
 import { originOf, resourceUri, wwwAuthenticateHeader } from "../oauth/metadata.js";

+/**
+ * 這條連線是**用誰的身分**進來的。決定知識面（kbdb_*）走哪條路：
+ *   - "oauth"：有人在同意頁輸入過 Portal 帳密 → 帶著他的 portal session 走 portal 資料面，
+ *              權限＝他在 portal 網頁上看得到的那些（庫過濾照吃）。
+ *   - "service"：static token / partner key 這類**服務級**憑據（本身就是真祕密，
+ *              代表整個實例或整個租戶，不是某個人）→ 維持既有的 KBDB 直連行為，零回歸。
+ * 兩條路刻意分開命名，因為「這張 token 背後有沒有一個人」正是本次要能分辨的事。
+ */
+export type AuthPath = "oauth" | "service";
+
 /**
 * MCP / GUI 端點認證中介層。
 *
@@ -19,7 +29,15 @@ import { originOf, resourceUri, wwwAuthenticateHeader } from "../oauth/metadata.
 *    已從預設路徑移除；只在明確設 ALLOW_PLAINTEXT_NAMESPACE="true" 的遷移情境才恢復。
 */
 export async function partnerAuthMiddleware(
-  c: Context<{ Bindings: Env; Variables: { org_namespace: string; partner_token: string } }>,
+  c: Context<{
+    Bindings: Env;
+    Variables: {
+      org_namespace: string;
+      partner_token: string;
+      portal?: PortalIdentity;
+      auth_path: AuthPath;
+    };
+  }>,
  next: Next
 ) {
  const origin = originOf(c.req.url);
@@ -50,6 +68,11 @@ export async function partnerAuthMiddleware(
      }
      c.set("org_namespace", at.namespace);
      c.set("partner_token", at.namespace); // 下游 cypher 用 namespace 當 X-Arcrun-API-Key（與 CLI 同一份身份）
+      // 登入者的身分（2026-08-12）：知識面工具（kbdb_*）帶著它打 cypher 的 portal 資料面，
+      // 權限與這個人在 portal 網頁上看到的完全一致。舊 token 沒有這欄 → undefined，
+      // 知識面工具會要求重新連線（不偷偷退回服務金鑰那條老路）。
+      c.set("portal", at.portal);
+      c.set("auth_path", "oauth");
      await next();
      return;
    }
@@ -60,6 +83,7 @@ export async function partnerAuthMiddleware(
    const ns = c.env.MCP_OWNER_NAMESPACE || "leo";
    c.set("org_namespace", ns);
    c.set("partner_token", ns);
+    c.set("auth_path", "service");
    await next();
    return;
  }
@@ -79,6 +103,7 @@ export async function partnerAuthMiddleware(
    }
    c.set("org_namespace", info.org_namespace);
    c.set("partner_token", token);
+    c.set("auth_path", "service");
    await next();
    return;
  }
@@ -89,6 +114,7 @@ export async function partnerAuthMiddleware(
  if (c.env.ALLOW_PLAINTEXT_NAMESPACE === "true") {
    c.set("org_namespace", token);
    c.set("partner_token", token);
+    c.set("auth_path", "service");
    await next();
    return;
  }
@@ -14,6 +14,7 @@ import {
  consumeAuthCode,
  putAccessToken,
  AUTH_CODE_TTL_SECONDS,
+  type PortalIdentity,
 } from "./store.js";
 import {
  originOf,
@@ -34,10 +35,25 @@ const CORS_JSON = {
  "Cache-Control": "no-store",
 } as const;

-function ownerNamespace(env: Env): string {
+/**
+ * **工作流面**（arcrun_* 工具）的租戶代號。知識面（kbdb_*）已不再讀它——
+ * 那邊改成跟著登入者的 portal session 走（見 store.ts PortalIdentity）。
+ *
+ * 為什麼這裡還留著、而且還有預設值：cypher 的 workflow API 是用「租戶代號當 opaque key」
+ * （X-Arcrun-API-Key）認的，不吃 portal session；要拆掉它得先在 cypher 開一組
+ * 吃 portal session 的 workflow 端點。那是下一步，不在本次範圍——
+ * 硬拆會把現在好好的 arcrun_* 弄壞。**誠實記在這裡，不假裝已經解決。**
+ *
+ * ⚠️ 預設值 "leo" 的**知識面**用法已消滅：它曾經是「不管誰登入都看到同一格」的根因
+ * （namespace 直接當 KBDB 的 owner_id 用）。現在它只當工作流面的 API key。
+ */
+function workflowTenant(env: Env): string {
  return env.MCP_OWNER_NAMESPACE || "leo";
 }

+/** portal session TTL 讀不到時的保守假設（秒）：短的那邊贏，寧可早點要求重連。 */
+const FALLBACK_PORTAL_SESSION_TTL = 604800; // 7 天（cypher portal.ts 的預設值）
+
 function tokenTtl(env: Env): number {
  const n = parseInt(env.MCP_TOKEN_TTL ?? "", 10);
  return Number.isFinite(n) && n > 0 ? n : DEFAULT_TOKEN_TTL;
@@ -248,7 +264,13 @@ export function registerOAuthRoutes<
    }
    // 認證下沉到 cypher 的 /portal/login（唯一真相源；同樣吃它的節流與停用檢查）。
    // 走 service binding（MCP 與 cypher 同帳號，屬 D28 允許的零件級組合）。
-    let loginOk = false;
+    //
+    // 🔴 2026-08-12（leo：「用登入能做的 mcp 就應該能做，結果要你去打 MCP 時自己找
+    //    credential 問題很大」）：這裡**接住登入回來的身分**，不再只留 `res.ok`。
+    //    舊版把身分丟掉 ⇒ 查詢時無身分可帶 ⇒ 只好去撈服務內部金鑰（KBDB_INTERNAL_TOKEN）
+    //    直打 KBDB ⇒ 繞過所有庫過濾、而且不管誰登入都看到同一格。根因就在這幾行。
+    let portal: PortalIdentity | null = null;
+    let portalTtl = FALLBACK_PORTAL_SESSION_TTL;
    try {
      const res = await c.env.CYPHER_EXECUTOR.fetch(
        new Request("https://cypher/portal/login", {
@@ -257,11 +279,34 @@ export function registerOAuthRoutes<
          body: JSON.stringify({ email, password }),
        }),
      );
-      loginOk = res.ok;
+      if (res.ok) {
+        const body = (await res.json().catch(() => null)) as {
+          session_token?: unknown;
+          display_name?: unknown;
+          role?: unknown;
+          libraries?: unknown;
+          session_expires_in?: unknown;
+        } | null;
+        const session = typeof body?.session_token === "string" ? body.session_token : "";
+        if (session) {
+          portal = {
+            session,
+            display_name: typeof body?.display_name === "string" ? body.display_name : "",
+            role: typeof body?.role === "string" ? body.role : "user",
+            libraries: Array.isArray(body?.libraries)
+              ? body.libraries.filter((x): x is string => typeof x === "string")
+              : [],
+          };
+          const ttl = Number(body?.session_expires_in);
+          if (Number.isFinite(ttl) && ttl > 0) portalTtl = ttl;
+        }
+      }
    } catch {
      return c.html(consentPage(consent, "暫時無法驗證帳密，請稍後再試。"), 503);
    }
-    if (!loginOk) {
+    if (!portal) {
+      // 帳密不對，或這台 cypher 舊到還不回 session_token。兩者都不可以發碼——
+      // 發了也是一張沒有身分的 token，查什麼都得再找一次 credential，正是要修的病。
      return c.html(consentPage(consent, "帳號或密碼不正確，請重試。"), 401);
    }
    if (!c.env.OAUTH_KV) {
@@ -275,7 +320,9 @@ export function registerOAuthRoutes<
      code_challenge_method: "S256",
      scope: consent.scope,
      resource: consent.resource,
-      namespace: ownerNamespace(c.env),
+      namespace: workflowTenant(c.env),
+      portal,
+      portal_session_expires_in: portalTtl,
    });
    const location = redirectWith(redirectUri, {
      code,
@@ -318,7 +365,9 @@ export function registerOAuthRoutes<
      return err("invalid_grant", "PKCE verification failed");
    }

-    const ttl = tokenTtl(c.env);
+    // token 活不過它底下的 portal session：否則第 8 天會出現「MCP 還連著、卻什麼都查不到」
+    // ——使用者看到的是壞掉，實際是身分過期。兩者一起到期，重連就是重新輸入帳密，一次搞定。
+    const ttl = Math.min(tokenTtl(c.env), data.portal_session_expires_in || FALLBACK_PORTAL_SESSION_TTL);
    const accessToken = randomToken(32);
    await putAccessToken(
      c.env.OAUTH_KV,
@@ -327,6 +376,7 @@ export function registerOAuthRoutes<
        namespace: data.namespace,
        client_id: data.client_id,
        scope: data.scope,
+        portal: data.portal,
        // RFC 8707：aud 一律用「本 server canonical resource URI」（非 client 原樣值）。
        // authorize 已只存 canonical，這裡再以當前 origin 重算一次確保與 partner-auth 嚴格比對一致。
        aud: resourceUri(originOf(c.req.url)),
@@ -4,6 +4,28 @@
 // KV key 一律用 SHA-256 hex（不把 raw code/token 當 key）→ 就算 KV list 也拿不到可用憑證。
 import { sha256Hex } from "./crypto.js";

+/**
+ * 登入者的身分（authorize 時用帳密換到，之後跟著 token 走）。
+ *
+ * leo 2026-08-12：「掛上 MCP 並輸入帳密，那個動作本身就是授權。」
+ * ⇒ 驗完帳密**不能只留一個布林值**——身分要接住並攜帶，下游才不必再要一次認證。
+ *
+ * `session` 是 cypher `/portal/login` 發的 portal session token，與人類在 portal 網頁上
+ * 拿到的完全同一種。它是「取得的暫時性認證」，正合本檔開頭的儲存鐵律（可進 KV、帶 TTL）；
+ * access_token 的 TTL 會被夾到不超過它（見 routes.ts），兩者一起到期，不會出現
+ * 「MCP 還連著、底下 session 早死」的鬼打牆。
+ *
+ * display_name / role / libraries 只是**給人看的回報值**（arcrun_whoami）。
+ * 真正的權限判定每次都由 cypher 回讀 user record 現算——這裡的副本不是判準，
+ * 所以管理員改權限或停用帳號會立刻生效，不必等 token 過期。
+ */
+export interface PortalIdentity {
+  session: string;
+  display_name: string;
+  role: string;
+  libraries: string[];
+}
+
 /** authorization code 綁定的資料（一次性；/token 驗證後即刪）。 */
 export interface AuthCodeData {
  client_id: string;
@@ -15,6 +37,10 @@ export interface AuthCodeData {
  resource: string;
  /** 換發後 token 綁定的資料分區（owner namespace）。 */
  namespace: string;
+  /** 這張 code 是誰換的（帳密驗過的那個人）。 */
+  portal: PortalIdentity;
+  /** portal session 剩餘秒數（authorize 當下）；access_token TTL 不得超過它。 */
+  portal_session_expires_in: number;
 }

 /** access token 綁定的資料。 */
@@ -26,6 +52,11 @@ export interface AccessTokenData {
  aud: string;
  /** 過期時間（epoch 秒），與 KV TTL 雙保險。 */
  exp: number;
+  /**
+   * 持這張 token 的是誰。**舊 token（本次改版前簽發的）沒有這欄** → undefined，
+   * 知識面工具會誠實要求重新連線，而不是偷偷退回服務金鑰那條老路（fail-closed）。
+   */
+  portal?: PortalIdentity;
 }

 const CODE_PREFIX = "oauth:code:";
@@ -5,31 +5,75 @@
 * 治本是給 AI 無腦入口：問工具拿身份。CLI 有 acr whoami，MCP 必須對齊（薄殼一致，rule 07 §5）——
 * 否則「AI 偏好 MCP」時又得繞回 curl。
 *
- * 薄殼：只回報 MCP 已解析的 orgNamespace（綁哪個帳號）+ cypher binding 連向，無業務邏輯。
+ * 2026-08-12 改：以帳密連線時，「我是誰」的答案是**登入的那個人**（display_name / role /
+ * 可用知識庫），不是一個租戶代號。原本回的 account_namespace 是租戶字串——那東西一旦落到
+ * 呼叫端手上就能拿去直打 /kbdb/*、繞過所有庫過濾（portal-data.ts 檔頭紅線），所以登入身分下
+ * 不再回它。工作流面（arcrun_*）仍用它當 API key，但那只在 server 內部用。
+ *
+ * 薄殼：只如實回報 MCP 已解析的身分，不做推斷、不打任何查詢。
 */
 import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
 import { toolName } from "../brand.js";
 import { Env } from "../types.js";
+import type { KnowledgeIdentity } from "../lib/portal-client.js";

-export function registerWhoami(server: McpServer, env: Env, orgNamespace: string) {
+export function registerWhoami(
+  server: McpServer,
+  env: Env,
+  orgNamespace: string,
+  identity: KnowledgeIdentity,
+) {
  server.tool(
    toolName("whoami"),
-    "回報這個 MCP 連線目前生效的身份：綁哪個帳號 / namespace、cypher 連向哪。" +
-      "部署 / 觸發 / 查 workflow 前先 call 此 tool 確認帳號，**不要自己 curl 猜帳號 URL**（會打到錯帳號）。",
+    "回報這個 MCP 連線目前生效的身份：以帳密連線時回「登入的是誰、能看哪些知識庫」；" +
+      "服務級 token 連線時回綁定的帳號 namespace。部署 / 觸發 / 查 workflow 前先 call 此 tool 確認身份，" +
+      "**不要自己 curl 猜帳號 URL**（會打到錯帳號）。",
    {},
    async () => {
-      // 薄殼：MCP 透過 service binding（CYPHER_EXECUTOR）連 cypher，binding 本身決定連哪台；
-      // 身份來自啟動時解析的 orgNamespace（綁哪個帳號的資料分區）。這裡只如實回報，不做推斷。
-      const identity = {
-        account_namespace: orgNamespace || "(未設)",
+      const base = {
        cypher: "service-binding:CYPHER_EXECUTOR",
        kbdb: "service-binding:KBDB",
-        note:
-          "此 MCP 已綁定上述帳號。部署/觸發/查詢都走這個身份；勿自行 curl 其他 URL 猜帳號。",
-      };
-      return {
-        content: [{ type: "text" as const, text: JSON.stringify(identity, null, 2) }],
      };
+
+      if (identity.kind === "portal") {
+        const { display_name, role, libraries } = identity.portal;
+        return json({
+          ...base,
+          auth: "portal-login（這條連線是有人輸入 Portal 帳密授權的）",
+          logged_in_as: display_name || "(未設顯示名稱)",
+          role,
+          libraries: libraries.length ? libraries : ["(尚未被授權任何知識庫)"],
+          knowledge_scope:
+            libraries.includes("*")
+              ? "全部知識庫（此帳號有全庫權限）"
+              : `僅限上列知識庫——kbdb_* 查得到的東西與這個帳號在 portal 網頁上看得到的完全一致`,
+          note:
+            "你是「主人授權的 AI」：主人查得到的你查得到，主人查不到的你也查不到。" +
+            "kbdb_* 不需要任何額外的 credential / 金鑰 / kbdb_base——已經登入過了，不會再問第二次。",
+        });
+      }
+
+      if (identity.kind === "stale") {
+        return json({
+          ...base,
+          auth: "舊版 token（沒有登入者身分）",
+          knowledge_scope: "查不到任何知識內容",
+          note:
+            "這條連線是本次改版前簽發的 token。到 claude.ai → Settings → Connectors " +
+            "重新連線一次（輸入 Portal 帳密）即可恢復，不需要找任何 credential。",
+        });
+      }
+
+      return json({
+        ...base,
+        auth: "service token（static token / partner key，代表整個實例或租戶，不是某個人）",
+        account_namespace: orgNamespace || "(未設)",
+        note: "此 MCP 已綁定上述帳號。部署/觸發/查詢都走這個身份；勿自行 curl 其他 URL 猜帳號。",
+      });
    },
  );
 }
+
+function json(obj: unknown) {
+  return { content: [{ type: "text" as const, text: JSON.stringify(obj, null, 2) }] };
+}
@@ -1,23 +1,27 @@
 /**
 * KBDB 資料層 MCP 薄殼（kbdb-base Phase 9.1，HANDOFF §2）
 *
- * rule 07 §5（薄殼鐵律）：能力長在基本盤 API，MCP 只做介面轉換 + 暴露，無業務邏輯。
- * 全走既有 kbdbFetch（KBDB service binding）打基本盤 HTTP API（kbdb/src/routes/*）。
+ * rule 07 §5（薄殼鐵律）：能力長在 API，MCP 只做介面轉換 + 暴露，無業務邏輯。
+ *
+ * ── 2026-08-12：改用「登入進來的那個人的身分」查詢 ────────────────────────────
+ * leo：「人類進 Portal 輸入帳密表示你是主人，可以查到你權限所有東西；AI 透過輸入帳密的
+ *   MCP 查詢表示是授權的 AI，可以查到主人允許查的任何東西。」
+ *   「掛上 MCP 並輸入帳密，那個動作本身就是授權」⇒ 下游不得再要求第二次認證。
+ *
+ * 之前的路：MCP 驗完帳密只留一個布林值 → 查詢時無身分可帶 → 只好帶**服務內部金鑰**
+ * （KBDB_INTERNAL_TOKEN）直打 KBDB。那條路繞過所有庫過濾，而且不管誰登入都看到同一格。
+ *
+ * 現在的路（identity.kind === 'portal'）：帶登入者的 portal session 打 cypher
+ * `/portal/data/*`——庫過濾／租戶注入／停用即時生效全在 server 側，與人類走 portal 網頁
+ * 是**同一道閘、同一份權限**。MCP 這邊一個判斷都不做。
+ *
+ * 服務級憑據（static token / partner key，identity.kind === 'service'）維持既有 KBDB 直連，
+ * 零回歸——那類憑據本身就是真祕密、代表整個實例或租戶，不是某個人。
 *
 * KBDB 鐵律（leo 2026-06-14，頂層 DECISION-kbdb-v3-baseplane.md）：
 *   - 任何人不准動表；**不提供建表 / SQL tool**。
- *   - AI 想存新類型的資料時只有「建 template（name+slots）+ 填 record（slot→content）」可用
- *     ——類 Supabase 萬用表，schema 由 template/slot 表達，不是真的 CREATE TABLE。
- *   - 薄殼只調基本盤 HTTP API，不直連 D1、不寫 SQL。
- *
- * 基本盤 API 契約（已存在，kbdb/src/routes）：
- *   POST   /templates                 { name, slots[], description?, created_by? } → { template }
- *   GET    /templates                 → { templates[], count }
- *   GET    /templates/:idOrName       → { template }
- *   POST   /records                   { template, values:{slot:content}, owner_id? } → { record }
- *   GET    /records/by-template/:t    ?owner_id= → { records[], count }
- *   GET    /records/:recordId         → { record }
- *   GET    /entries/search            ?q=&owner_id= → { entries[], count, mode:'keyword' }
+ *   - AI 想存新類型的資料時只有「建 template（name+slots）+ 填 record（slot→content）」可用。
+ *   - 薄殼只調 HTTP API，不直連 D1、不寫 SQL。
 */

 import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
@@ -25,22 +29,32 @@ import { z } from "zod";
 import type { Env } from "../types.js";
 import { kbdbFetch } from "../lib/kbdb-client.js";
 import { errorResponse, successResponse } from "../lib/cypher-client.js";
+import {
+  portalFetch,
+  portalError,
+  staleIdentityError,
+  type KnowledgeIdentity,
+} from "../lib/portal-client.js";
+
+/** 走 portal 資料面時，呼叫端傳的 owner_id 一律無效（server 用登入者的歸屬）——如實告訴 AI。 */
+const OWNER_IGNORED_HINT =
+  "owner_id 在登入身分下不生效：查詢範圍由你的帳號權限決定（與你在 portal 網頁看到的一致）";

 /** 註冊全部 KBDB 資料層工具（kbdb-base Phase 9.1）。不含建表/SQL tool（鐵律）。 */
-export function registerAllKbdbDataTools(server: McpServer, env: Env) {
-  registerCreateTemplate(server, env);
-  registerListTemplates(server, env);
-  registerCreateRecord(server, env);
-  registerGetRecord(server, env);
-  registerQuery(server, env);
-  registerSearch(server, env);
+export function registerAllKbdbDataTools(server: McpServer, env: Env, identity: KnowledgeIdentity) {
+  registerCreateTemplate(server, env, identity);
+  registerListTemplates(server, env, identity);
+  registerCreateRecord(server, env, identity);
+  registerGetRecord(server, env, identity);
+  registerQuery(server, env, identity);
+  registerSearch(server, env, identity);
 }

 /**
 * kbdb_create_template — 建一個 template（= 萬用表裡的一種「虛擬表/資料形狀」）。
 * 這是 AI 想存「新類型資料」時的唯一入口：沒有建表 API，改用 template + slots 描述欄位。
 */
-export function registerCreateTemplate(server: McpServer, env: Env) {
+export function registerCreateTemplate(server: McpServer, env: Env, identity: KnowledgeIdentity) {
  server.tool(
    "kbdb_create_template",
    "建一個 KBDB template（萬用表裡的一種資料形狀，類 Supabase 的虛擬表）。KBDB 不能建真的資料表——" +
@@ -50,16 +64,24 @@ export function registerCreateTemplate(server: McpServer, env: Env) {
      name: z.string().min(1).describe("template 名稱（唯一識別，之後填 record 用這個名字），如 'contact' / 'note'"),
      slots: z.array(z.string().min(1)).min(1).describe("欄位名清單，如 ['name','email','phone']"),
      description: z.string().optional().describe("這個 template 用途的簡述（選填）"),
-      created_by: z.string().optional().describe("建立者標記（選填）"),
+      created_by: z.string().optional().describe("建立者標記（選填；登入身分下由 server 記錄，不吃此值）"),
    },
    async ({ name, slots, description, created_by }) => {
+      if (identity.kind === "stale") return staleIdentityError();
      try {
-        const res = await kbdbFetch(env, "/templates", {
-          method: "POST",
-          headers: { "Content-Type": "application/json" },
-          body: JSON.stringify({ name, slots, description, created_by }),
-        });
+        const res =
+          identity.kind === "portal"
+            ? await portalFetch(env, identity.portal.session, "/portal/data/templates", {
+                method: "POST",
+                body: { name, slots, description },
+              })
+            : await kbdbFetch(env, "/templates", {
+                method: "POST",
+                headers: { "Content-Type": "application/json" },
+                body: JSON.stringify({ name, slots, description, created_by }),
+              });
        if (!res.ok) {
+          if (identity.kind === "portal") return portalError(res, `建 template「${name}」`);
          return errorResponse("create_template_failed", `建 template 失敗`, ["檢查 name 是否重複", "確認 slots 是非空字串陣列"], await res.text().catch(() => ""));
        }
        const data = await res.json();
@@ -74,17 +96,28 @@ export function registerCreateTemplate(server: McpServer, env: Env) {
 }

 /** kbdb_list_templates — 列出所有已建的 template（看有哪些資料形狀可用）。 */
-export function registerListTemplates(server: McpServer, env: Env) {
+export function registerListTemplates(server: McpServer, env: Env, identity: KnowledgeIdentity) {
  server.tool(
    "kbdb_list_templates",
    "列出 KBDB 裡所有 template（已定義的資料形狀）。要存資料前先看有沒有現成 template 可用，沒有再 kbdb_create_template。",
    {},
    async () => {
+      if (identity.kind === "stale") return staleIdentityError();
      try {
-        const res = await kbdbFetch(env, "/templates");
-        if (!res.ok) return errorResponse("list_templates_failed", `列 template 失敗`, ["稍後重試"], await res.text().catch(() => ""));
+        const res =
+          identity.kind === "portal"
+            ? await portalFetch(env, identity.portal.session, "/portal/data/templates")
+            : await kbdbFetch(env, "/templates");
+        if (!res.ok) {
+          if (identity.kind === "portal") return portalError(res, "列 template");
+          return errorResponse("list_templates_failed", `列 template 失敗`, ["稍後重試"], await res.text().catch(() => ""));
+        }
        const data = await res.json();
-        return successResponse(data, ["每個 template 的 slots_json 是它的欄位清單", "填資料用 kbdb_create_record"]);
+        return successResponse(data, [
+          "每個 template 的 slots_json 是它的欄位清單",
+          "填資料用 kbdb_create_record",
+          "template 是全域共享的「資料形狀」定義（schema），不含任何人的內容——內容的權限在 record/entry 那層",
+        ]);
      } catch (e) {
        return errorResponse("internal_error", e instanceof Error ? e.message : String(e), ["稍後重試"]);
      }
@@ -93,7 +126,7 @@ export function registerListTemplates(server: McpServer, env: Env) {
 }

 /** kbdb_create_record — 依某 template 填一筆 record（slot → 內容）。 */
-export function registerCreateRecord(server: McpServer, env: Env) {
+export function registerCreateRecord(server: McpServer, env: Env, identity: KnowledgeIdentity) {
  server.tool(
    "kbdb_create_record",
    "依某 template 填一筆 record（一列資料）。values 是 {slot名: 內容}，slot 名要對得上 template 的 slots。" +
@@ -101,23 +134,34 @@ export function registerCreateRecord(server: McpServer, env: Env) {
    {
      template: z.string().min(1).describe("template 的 name 或 id"),
      values: z.record(z.string()).describe("欄位內容 {slot名: 字串內容}，如 {name:'Leo', email:'leo@x.com'}"),
-      owner_id: z.string().optional().describe("資料歸屬標記（選填，如專案 id / 用戶 id）"),
+      owner_id: z.string().optional().describe("資料歸屬標記（選填；登入身分下一律由 server 定成你的歸屬，不吃此值）"),
    },
    async ({ template, values, owner_id }) => {
+      if (identity.kind === "stale") return staleIdentityError();
      try {
-        const res = await kbdbFetch(env, "/records", {
-          method: "POST",
-          headers: { "Content-Type": "application/json" },
-          body: JSON.stringify({ template, values, owner_id }),
-        });
+        const res =
+          identity.kind === "portal"
+            ? await portalFetch(env, identity.portal.session, "/portal/data/records", {
+                method: "POST",
+                body: { template, values },
+              })
+            : await kbdbFetch(env, "/records", {
+                method: "POST",
+                headers: { "Content-Type": "application/json" },
+                body: JSON.stringify({ template, values, owner_id }),
+              });
        if (!res.ok) {
+          if (identity.kind === "portal") return portalError(res, `填 record（template「${template}」）`);
          return errorResponse("create_record_failed", `填 record 失敗`, [
            `確認 template「${template}」存在（kbdb_list_templates）`,
            "values 的 slot 名要對得上 template 的 slots",
          ], await res.text().catch(() => ""));
        }
        const data = await res.json();
-        return successResponse(data, [`已存入。用 kbdb_query(template='${template}') 列出此 template 的所有 record`]);
+        return successResponse(data, [
+          `已存入。用 kbdb_query(template='${template}') 列出此 template 的所有 record`,
+          ...(identity.kind === "portal" ? [OWNER_IGNORED_HINT] : []),
+        ]);
      } catch (e) {
        return errorResponse("internal_error", e instanceof Error ? e.message : String(e), ["稍後重試"]);
      }
@@ -126,7 +170,7 @@ export function registerCreateRecord(server: McpServer, env: Env) {
 }

 /** kbdb_get_record — 用 record_id 取單筆 record。 */
-export function registerGetRecord(server: McpServer, env: Env) {
+export function registerGetRecord(server: McpServer, env: Env, identity: KnowledgeIdentity) {
  server.tool(
    "kbdb_get_record",
    "用 record_id 取一筆 record 的所有欄位內容。record_id 從 kbdb_create_record 回傳或 kbdb_query 列出取得。",
@@ -134,10 +178,23 @@ export function registerGetRecord(server: McpServer, env: Env) {
      record_id: z.string().min(1).describe("record 的 id（rec_xxx）"),
    },
    async ({ record_id }) => {
+      if (identity.kind === "stale") return staleIdentityError();
      try {
-        const res = await kbdbFetch(env, `/records/${encodeURIComponent(record_id)}`);
-        if (res.status === 404) return errorResponse("not_found", `record「${record_id}」不存在`, ["確認 record_id 正確", "用 kbdb_query 列出某 template 的 record 取 id"]);
-        if (!res.ok) return errorResponse("get_record_failed", `取 record 失敗`, ["稍後重試"], await res.text().catch(() => ""));
+        const res =
+          identity.kind === "portal"
+            ? await portalFetch(env, identity.portal.session, `/portal/data/records/${encodeURIComponent(record_id)}`)
+            : await kbdbFetch(env, `/records/${encodeURIComponent(record_id)}`);
+        if (res.status === 404) {
+          // 登入身分下，「不是你的」與「不存在」刻意同回 404（不洩存在性，portal 同一條紅線）。
+          return errorResponse("not_found", `查無 record「${record_id}」（不存在，或不在你的權限範圍內）`, [
+            "確認 record_id 正確",
+            "用 kbdb_query 列出某 template 的 record 取 id",
+          ]);
+        }
+        if (!res.ok) {
+          if (identity.kind === "portal") return portalError(res, "取 record");
+          return errorResponse("get_record_failed", `取 record 失敗`, ["稍後重試"], await res.text().catch(() => ""));
+        }
        const data = await res.json();
        return successResponse(data);
      } catch (e) {
@@ -148,21 +205,39 @@ export function registerGetRecord(server: McpServer, env: Env) {
 }

 /** kbdb_query — 列出某 template 底下的所有 record（結構化查詢）。 */
-export function registerQuery(server: McpServer, env: Env) {
+export function registerQuery(server: McpServer, env: Env, identity: KnowledgeIdentity) {
  server.tool(
    "kbdb_query",
    "列出某 template 底下的所有 record（結構化查詢，按 template 取整批資料）。要按關鍵字找內容用 kbdb_search。",
    {
      template: z.string().min(1).describe("template 的 name 或 id"),
-      owner_id: z.string().optional().describe("只取某歸屬的 record（選填）"),
+      owner_id: z.string().optional().describe("只取某歸屬的 record（選填；登入身分下不生效，範圍由你的權限決定）"),
    },
    async ({ template, owner_id }) => {
+      if (identity.kind === "stale") return staleIdentityError();
      try {
-        const path = `/records/by-template/${encodeURIComponent(template)}` + (owner_id ? `?owner_id=${encodeURIComponent(owner_id)}` : "");
-        const res = await kbdbFetch(env, path);
-        if (!res.ok) return errorResponse("query_failed", `查詢 record 失敗`, [`確認 template「${template}」存在`], await res.text().catch(() => ""));
+        const res =
+          identity.kind === "portal"
+            ? await portalFetch(
+                env,
+                identity.portal.session,
+                `/portal/data/records/by-template/${encodeURIComponent(template)}`,
+              )
+            : await kbdbFetch(
+                env,
+                `/records/by-template/${encodeURIComponent(template)}` +
+                  (owner_id ? `?owner_id=${encodeURIComponent(owner_id)}` : ""),
+              );
+        if (!res.ok) {
+          if (identity.kind === "portal") return portalError(res, `查詢 template「${template}」的 record`);
+          return errorResponse("query_failed", `查詢 record 失敗`, [`確認 template「${template}」存在`], await res.text().catch(() => ""));
+        }
        const data = await res.json();
-        return successResponse(data, ["用 kbdb_get_record(record_id) 取單筆全文", "按關鍵字找內容改用 kbdb_search"]);
+        return successResponse(data, [
+          "用 kbdb_get_record(record_id) 取單筆全文",
+          "按關鍵字找內容改用 kbdb_search",
+          ...(identity.kind === "portal" ? [OWNER_IGNORED_HINT] : []),
+        ]);
      } catch (e) {
        return errorResponse("internal_error", e instanceof Error ? e.message : String(e), ["稍後重試"]);
      }
@@ -175,26 +250,38 @@ export function registerQuery(server: McpServer, env: Env) {
 * 語義/關鍵字都在同一 KBDB MCP（用戶資料 RAG），不分散（issue #7 / D17 邊界）。
 * mode=semantic 但沒開 vectorize → base 自動降級 keyword + 回 capability_hint（發現閉環，叫 CC 幫開）。
 */
-export function registerSearch(server: McpServer, env: Env) {
+export function registerSearch(server: McpServer, env: Env, identity: KnowledgeIdentity) {
  server.tool(
    "kbdb_search",
    "搜尋 KBDB 內容。mode='keyword'（預設，D1 LIKE 關鍵字，基本盤永遠可用）或 'semantic'（AI 向量語義搜尋，" +
      "需先開 embed 模組）。語義沒開時會自動降級關鍵字並告訴你怎麼開。要按 template 取整批結構化資料用 kbdb_query。",
    {
      q: z.string().min(1).describe("搜尋關鍵字 / 語義查詢句"),
-      owner_id: z.string().optional().describe("限定某歸屬範圍內搜（選填）"),
+      owner_id: z.string().optional().describe("限定某歸屬範圍內搜（選填；登入身分下不生效，範圍由你的權限決定）"),
      source: z.string().optional().describe("只搜某來源（ingest source.uri，選填）"),
      mode: z.enum(["keyword", "semantic"]).optional().describe("keyword（預設）或 semantic（需開 vectorize）"),
    },
    async ({ q, owner_id, source, mode }) => {
+      if (identity.kind === "stale") return staleIdentityError();
      try {
-        const qs = new URLSearchParams({ q });
-        if (owner_id) qs.set("owner_id", owner_id);
-        if (source) qs.set("source", source);
-        if (mode) qs.set("mode", mode);
-        const res = await kbdbFetch(env, `/entries/search?${qs.toString()}`);
-        if (!res.ok) return errorResponse("search_failed", `搜尋失敗`, ["稍後重試"], await res.text().catch(() => ""));
-        const data = (await res.json()) as { mode?: string; capability_hint?: string };
+        let res: Response;
+        if (identity.kind === "portal") {
+          // /portal/data/search 只吃在權限範圍內「再收窄」的 filter；owner_id/library 由 server 定死。
+          res = await portalFetch(env, identity.portal.session, "/portal/data/search", {
+            query: { q, mode },
+          });
+        } else {
+          const qs = new URLSearchParams({ q });
+          if (owner_id) qs.set("owner_id", owner_id);
+          if (source) qs.set("source", source);
+          if (mode) qs.set("mode", mode);
+          res = await kbdbFetch(env, `/entries/search?${qs.toString()}`);
+        }
+        if (!res.ok) {
+          if (identity.kind === "portal") return portalError(res, "搜尋");
+          return errorResponse("search_failed", `搜尋失敗`, ["稍後重試"], await res.text().catch(() => ""));
+        }
+        const data = (await res.json()) as { mode?: string; capability_hint?: string; note?: string };
        // base 回 capability_hint → 語義沒開、已降級 keyword。把它當 next-step 傳給 AI（發現閉環）。
        const hints =
          data.capability_hint
@@ -202,6 +289,8 @@ export function registerSearch(server: McpServer, env: Env) {
            : data.mode === "semantic"
              ? ["mode:semantic = AI 向量語義搜尋"]
              : ["mode:keyword = D1 LIKE（基本盤）", "想要語義搜尋：mode='semantic'（需先開 vectorize）"];
+        if (identity.kind === "portal") hints.push(OWNER_IGNORED_HINT);
+        if (data.note) hints.push(data.note);
        return successResponse(data, hints);
      } catch (e) {
        return errorResponse("internal_error", e instanceof Error ? e.message : String(e), ["稍後重試"]);
@@ -23,6 +23,12 @@ import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
 import { z } from "zod";
 import type { Env } from "../types.js";
 import { cypherFetch, errorResponse, successResponse } from "../lib/cypher-client.js";
+import {
+  portalFetch,
+  portalError,
+  staleIdentityError,
+  type KnowledgeIdentity,
+} from "../lib/portal-client.js";

 /** graph 查詢 workflow 名（與 registry/examples/graph-neighbors/workflow.yaml 的 name 一致）。 */
 export const GRAPH_NEIGHBORS_WORKFLOW = "graph_neighbors";
@@ -35,8 +41,13 @@ const INSTALL_HINTS = [
 ];

 /** 註冊全部 KBDB graph 查詢工具（issue #68）。 */
-export function registerAllKbdbGraphTools(server: McpServer, env: Env, orgNamespace: string) {
-  registerGraphNeighbors(server, env, orgNamespace);
+export function registerAllKbdbGraphTools(
+  server: McpServer,
+  env: Env,
+  orgNamespace: string,
+  identity: KnowledgeIdentity,
+) {
+  registerGraphNeighbors(server, env, orgNamespace, identity);
  // graph_traverse：repo 內目前只有 graph-neighbors 有 workflow 定義（registry/examples/），
  // traverse 尚無可對齊的 input 形狀 → 不猜、不過度工程；等 workflow 進 registry 再加薄殼。
 }
@@ -45,7 +56,12 @@ export function registerAllKbdbGraphTools(server: McpServer, env: Env, orgNamesp
 * kbdb_graph_neighbors — knowledge graph 1-hop/N-hop 鄰居查詢。
 * 薄殼調 GET /q/{ns}/graph_neighbors，結果（最終節點輸出）原樣回給 MCP client。
 */
-export function registerGraphNeighbors(server: McpServer, env: Env, orgNamespace: string) {
+export function registerGraphNeighbors(
+  server: McpServer,
+  env: Env,
+  orgNamespace: string,
+  identity: KnowledgeIdentity,
+) {
  server.tool(
    "kbdb_graph_neighbors",
    "knowledge graph 鄰居查詢（1-hop/N-hop 關係遍歷）：給一個節點名，沿 KBDB triplet" +
@@ -60,10 +76,10 @@ export function registerGraphNeighbors(server: McpServer, env: Env, orgNamespace
      depth: z.number().int().min(1).max(10).optional().describe(
        "最大跳數（N-hop），預設 1（只看直接鄰居）",
      ),
-      kbdb_base: z.string().min(1).describe(
-        "你自己部署的 KBDB 對外 base URL（如 https://arcrun-kbdb.<你的subdomain>.workers.dev " +
-          "或 KBDB custom domain）。workflow 刻意不寫死任何一家的庫——" +
-          "帶錯（或照抄別人的值）＝查詢打進別人的庫",
+      kbdb_base: z.string().min(1).optional().describe(
+        "【登入身分下不需要，留空即可】你自己部署的 KBDB 對外 base URL。" +
+          "以帳密連線的 MCP 由 server 端自己知道要查哪個庫——不必、也不該由你指定" +
+          "（指定了也不會採用）。只有服務級 token（static token / partner key）連線時才需要填。",
      ),
      template: z.string().optional().describe(
        "triplet 記錄的 template 名，預設 'graph_triplet'（以實際部署的 kbdb-graph-plugin " +
@@ -74,6 +90,43 @@ export function registerGraphNeighbors(server: McpServer, env: Env, orgNamespace
      ),
    },
    async ({ subject, depth, kbdb_base, template, directed }) => {
+      if (identity.kind === "stale") return staleIdentityError();
+
+      // ── 登入身分：走 cypher 的 portal 資料面（與人類在 portal 按「關聯」同一支端點）──
+      // 那支已經有 D-4 graph 粗閘（沒有 graph 來源庫權限 → 403），也已經處理好
+      // 「這台實例沒裝 graph plugin 就改用 tenant 的 graph_neighbors workflow」的兩條路。
+      // ⇒ MCP 不必要 kbdb_base、不必知道租戶、不必再認證一次。
+      if (identity.kind === "portal") {
+        try {
+          const res = await portalFetch(
+            env,
+            identity.portal.session,
+            `/portal/data/graph/neighbors/${encodeURIComponent(subject)}`,
+            { query: { depth: depth ?? 1 } },
+          );
+          if (!res.ok) return portalError(res, `查「${subject}」的鄰居`);
+          const out = (await res.json().catch(() => null)) as
+            | { neighbors?: unknown[]; edges?: unknown[]; count?: number }
+            | null;
+          return successResponse(out, [
+            `${out?.count ?? 0} 個鄰居（depth 上限 ${depth ?? 1}）`,
+            "count=0 且不確定資料有沒有進圖：kbdb_query(template='triplet') 看三元組記錄",
+            "找關鍵字內容改用 kbdb_search；取單筆全文用 kbdb_get_record",
+            "查詢範圍＝你這個帳號被授權的知識庫（與 portal 網頁上的關聯檢視一致）",
+          ]);
+        } catch (e) {
+          return errorResponse("internal_error", e instanceof Error ? e.message : String(e), ["稍後重試"]);
+        }
+      }
+
+      // ── 服務級憑據：既有路徑（打 /q/:ns/graph_neighbors workflow），行為零變更 ──
+      if (!kbdb_base) {
+        return errorResponse(
+          "kbdb_base_required",
+          "以服務級 token 連線時，graph 查詢需要 kbdb_base（你自己 KBDB 的對外 URL）",
+          ["改用帳密連線（OAuth）則不需要此參數", "或帶上 kbdb_base 再試一次"],
+        );
+      }
      if (!orgNamespace) {
        return errorResponse(
          "no_namespace",
@@ -22,6 +22,12 @@ import type { Env } from "../types.js";
 import { kbdbFetch } from "../lib/kbdb-client.js";
 import { errorResponse, successResponse } from "../lib/cypher-client.js";
 import { entityNames, parseSlotArray, type LibraryMapRow } from "../lib/library-map.js";
+import {
+  portalFetch,
+  portalError,
+  staleIdentityError,
+  type KnowledgeIdentity,
+} from "../lib/portal-client.js";

 /**
 * 空庫/404 時的指引（誠實回報＋給下一步，鐵律：不假綠）。
@@ -39,8 +45,8 @@ const RECOMPUTE_HINTS = [
 ];

 /** 註冊全部藏書地圖工具（library-map M4）。 */
-export function registerAllKbdbMapTools(server: McpServer, env: Env) {
-  registerGetMap(server, env);
+export function registerAllKbdbMapTools(server: McpServer, env: Env, identity: KnowledgeIdentity) {
+  registerGetMap(server, env, identity);
 }

 /** 單庫詳圖回傳形狀（GET /map/:library 的 map，slot 陣列已 parse 成物件）。 */
@@ -62,7 +68,7 @@ interface LibraryMapDetail {
 * kbdb_get_map — 藏書地圖。無參數＝全館（每庫一行）；帶 library＝該庫詳圖。
 * design §6 retrieval 流程的第一站：地圖 → get_map(library) 細節 → graph/search 進庫。
 */
-export function registerGetMap(server: McpServer, env: Env) {
+export function registerGetMap(server: McpServer, env: Env, identity: KnowledgeIdentity) {
  server.tool(
    "kbdb_get_map",
    "藏書地圖：KBDB 全館導覽。不帶參數＝全館地圖（每庫一行：庫名＋narrative＋核心 top 3 entities＋" +
@@ -73,15 +79,26 @@ export function registerGetMap(server: McpServer, env: Env) {
      library: z.string().min(1).optional().describe(
        "庫名（如 'kb'／'notes'）。帶了回該庫詳圖；不帶回全館地圖（先看全館再挑庫）",
      ),
-      owner_id: z.string().optional().describe("限定某資料歸屬範圍（選填，與其他 kbdb_* 工具同義）"),
+      owner_id: z.string().optional().describe(
+        "限定某資料歸屬範圍（選填；登入身分下不生效，看得到哪些庫由你的帳號權限決定）",
+      ),
    },
    async ({ library, owner_id }) => {
+      if (identity.kind === "stale") return staleIdentityError();
      try {
-        const qs = owner_id ? `?owner_id=${encodeURIComponent(owner_id)}` : "";
+        // 登入身分：走 cypher 的 portal 資料面 —— 只會回這個帳號有權限的庫
+        //（KBDB 的 /map 對權限無知，會回全館；過濾在 cypher 那邊 server 側做）。
+        const isPortal = identity.kind === "portal";
+        const qs = !isPortal && owner_id ? `?owner_id=${encodeURIComponent(owner_id)}` : "";
+        const mapFetch = (path: string) =>
+          identity.kind === "portal"
+            ? portalFetch(env, identity.portal.session, `/portal/data${path}`)
+            : kbdbFetch(env, path);

        if (!library) {
          // 全館地圖：每庫一行（library＋narrative＋top 3 entities＋triplet_count）。
-          const res = await kbdbFetch(env, `/map${qs}`);
+          const res = await mapFetch(`/map${qs}`);
+          if (!res.ok && isPortal) return portalError(res, "取全館地圖");
          if (!res.ok) {
            return errorResponse(
              "map_fetch_failed",
@@ -90,7 +107,7 @@ export function registerGetMap(server: McpServer, env: Env) {
              await res.text().catch(() => ""),
            );
          }
-          const data = (await res.json()) as { libraries?: LibraryMapRow[]; count?: number };
+          const data = (await res.json()) as { libraries?: LibraryMapRow[]; count?: number; note?: string };
          const libraries = (Array.isArray(data.libraries) ? data.libraries : []).map((l) => ({
            ...l,
            // 防禦：top_entities 若是 JSON 字串形就 parse 成名字清單（失敗當空，誠實不 crash）。
@@ -101,8 +118,13 @@ export function registerGetMap(server: McpServer, env: Env) {
            // 空庫誠實回報：不是錯誤（端點正常）。地圖是讀時即時核對重算的（見 RECOMPUTE_HINTS
            // 註解），所以「地圖是空的」現在真的等於「這個租戶目前沒有任何三元組資料」，
            // 不再是「沒人跑過 recompute」那種曖昧狀態。
+            // 登入身分下還有第二種可能：這個帳號一個庫都沒被授權——「沒權限看」與「沒有資料」
+            // 不可以長得一樣，所以分開講（cypher 端會附 note 說明）。
            return successResponse({ libraries: [], count: 0 }, [
-              "全館地圖是空的：這個租戶目前沒有任何三元組資料（不是地圖沒算，是真的還沒有資料）",
+              isPortal
+                ? "看不到任何庫：可能是這個知識庫真的還沒有三元組資料，也可能是你的帳號還沒被授權任何庫——請向管理員確認你的可用知識庫"
+                : "全館地圖是空的：這個租戶目前沒有任何三元組資料（不是地圖沒算，是真的還沒有資料）",
+              ...(data.note ? [data.note] : []),
              ...RECOMPUTE_HINTS,
            ]);
          }
@@ -113,7 +135,7 @@ export function registerGetMap(server: McpServer, env: Env) {
        }

        // 單庫詳圖：完整 slots（slot 陣列 parse 成物件再回）。
-        const res = await kbdbFetch(env, `/map/${encodeURIComponent(library)}${qs}`);
+        const res = await mapFetch(`/map/${encodeURIComponent(library)}${qs}`);
        if (res.status === 404) {
          // 地圖是讀時即時核對重算的：只要這個庫「已知」（有三元組、entries 蓋過章、或登記過），
          // 上一步就會自動把它補成一筆 triplet_count:0 的地圖，走不到這個分支。真的落到 404，
@@ -121,10 +143,13 @@ export function registerGetMap(server: McpServer, env: Env) {
          // （可能打錯字，或這個庫在別的租戶／別的 owner_id 底下）。
          return errorResponse(
            "map_not_found",
-            `查無庫「${library}」——這個名字在這個租戶的資料裡從沒出現過（不是「這庫是空的」，是根本沒有這個庫；地圖是即時核對重算的，不是忘了 recompute）`,
-            ["kbdb_get_map 不帶參數看全館有哪些庫（確認庫名）", ...RECOMPUTE_HINTS],
+            isPortal
+              ? `查無庫「${library}」——這個名字不存在，或不在你被授權的知識庫範圍內（兩者刻意同一句話，不洩漏某個庫存不存在）`
+              : `查無庫「${library}」——這個名字在這個租戶的資料裡從沒出現過（不是「這庫是空的」，是根本沒有這個庫；地圖是即時核對重算的，不是忘了 recompute）`,
+            ["kbdb_get_map 不帶參數看全館有哪些庫（確認庫名／確認你有權限的庫）", ...RECOMPUTE_HINTS],
          );
        }
+        if (!res.ok && isPortal) return portalError(res, `取庫「${library}」詳圖`);
        if (!res.ok) {
          return errorResponse(
            "map_fetch_failed",
@@ -20,8 +20,15 @@ import { registerAllKbdbDataTools } from "./kbdb_data.js";
 import { registerAllKbdbGraphTools } from "./kbdb_graph.js";
 import { registerAllKbdbMapTools } from "./kbdb_map.js";
 import { registerWhoami } from "./arcrun_whoami.js";
+import type { KnowledgeIdentity } from "../lib/portal-client.js";

-export function registerAllTools(server: McpServer, env: Env, orgNamespace: string, partnerToken: string) {
+export function registerAllTools(
+  server: McpServer,
+  env: Env,
+  orgNamespace: string,
+  partnerToken: string,
+  identity: KnowledgeIdentity,
+) {
  registerSearchComponents(server, env, orgNamespace);
  // 🔴 2026-07-21 leo 拍板停用：零件走 PR、專業等級；recipe/workflow/app 誰都可以做。
  // 零件貢獻**只有一條路＝PR 人審**（leo 2026-08-01：「已經沒有 publish 了，
@@ -53,13 +60,15 @@ export function registerAllTools(server: McpServer, env: Env, orgNamespace: stri
  registerAllRecipeTools(server, env);
  // kbdb-base Phase 9.1: KBDB 資料層薄殼（template/record/query/search，HANDOFF §2）
  // 鐵律：不提供建表/SQL tool，AI 只有 template+slot 可用（類 Supabase 萬用表）
-  registerAllKbdbDataTools(server, env);
+  // 2026-08-12：知識面（kbdb_*）全部改吃 identity——以帳密連線者走 portal 資料面
+  // （權限＝那個人的權限），服務級憑據維持既有 KBDB 直連。見 lib/portal-client.ts。
+  registerAllKbdbDataTools(server, env, identity);
  // issue #68: KBDB graph 查詢薄殼（kbdb_graph_neighbors，調 /q/:ns/graph_neighbors 同步查詢端點）
  // 補齊 D17「KBDB MCP＝RAG 套餐」第三模式：關鍵字/語義之外的圖（關係遍歷）
-  registerAllKbdbGraphTools(server, env, orgNamespace);
+  registerAllKbdbGraphTools(server, env, orgNamespace, identity);
  // library-map SDD M4（Arcrun#39）: 藏書地圖薄殼（kbdb_get_map，調 kbdb GET /map／/map/:library）
  // retrieval 第一站：先看地圖定位庫，再 search/graph 進庫（design §6）
-  registerAllKbdbMapTools(server, env);
+  registerAllKbdbMapTools(server, env, identity);
  // §7.8 P1 D2: whoami（與 CLI acr whoami 對齊，AI 不繞 CLI 自己 curl 猜帳號）
-  registerWhoami(server, env, orgNamespace);
+  registerWhoami(server, env, orgNamespace, identity);
 }
@@ -2,6 +2,15 @@ export interface Env {
  COMPONENT_REGISTRY: Fetcher;
  CYPHER_EXECUTOR: Fetcher;
  KBDB: Fetcher;
+  /**
+   * KBDB 的服務內部金鑰。
+   *
+   * 2026-08-12 後**知識面（kbdb_*）以帳密連線時完全不用它**——那條路改走 cypher 的
+   * `/portal/data/*`，帶的是登入者自己的 portal session。它現在只剩兩個用途：
+   *   ① 官方 SaaS 的 partner-key 驗證（middleware/partner-auth.ts 第 3 條）
+   *   ② 服務級 token（static token）連線時的既有 KBDB 直連（零回歸）
+   * 兩者都拆掉之後，這個 binding 才能從 MCP 移除。
+   */
  KBDB_INTERNAL_TOKEN: string;
  API_KEY?: string;
  // Platform telemetry / feedback aggregation key (optional)
@@ -20,11 +29,16 @@ export interface Env {
  // 短效認證儲存：authorization code（TTL ~600s）+ access token（TTL = MCP_TOKEN_TTL）。
  // 只放「取得的暫時性認證」，key 用 SHA-256 hash（KV list 不外洩可用 token）。長效機密不進 KV。
  OAUTH_KV?: KVNamespace;
-  // Owner 祕密（CF Secret，非 KV、非明碼 var）：/authorize 同意頁的把關密碼。
-  // 只有 owner 知道 → 「只知 URL + 明碼 namespace」的人走不完 OAuth，拿不到 token。
-  // 未設 → OAuth /authorize 回 503（拒絕在無把關下發碼，不留不安全預設）。
+  // 【已停用，2026-07-30】舊的 owner 祕密。把關改成「使用者自己的 Portal 帳密」——
+  // 沒人給得了封測者這把祕密（安裝器產生後從不顯示、CF secret 又讀不回），
+  // 而且全實例共用一把、分不出是誰連上來的。程式已不再讀它；欄位留著只為不讓舊 toml 炸掉。
  MCP_OWNER_SECRET?: string;
-  // OAuth 換發出的 access_token 綁定的 namespace（owner 的資料分區）。預設 "leo"。
+  // **工作流面**（arcrun_* 工具）的租戶代號，當 cypher 的 X-Arcrun-API-Key 用。預設 "leo"。
+  //
+  // ⚠️ 2026-08-12 起**知識面（kbdb_*）不再讀這個欄位**：那邊改成跟著登入者的 portal session
+  // 走（oauth/store.ts PortalIdentity）。此欄位曾被當成 KBDB 的 owner_id ⇒ 不管誰登入
+  // 都看到同一格、而且是全部——那個用法已經消滅。
+  // 要連工作流面也拆掉它，得先在 cypher 開一組吃 portal session 的 workflow 端點（下一步）。
  MCP_OWNER_NAMESPACE?: string;
  // access_token 存活秒數（同時是 KV TTL）。字串（toml var）。預設 2592000（30 天）。
  // 過期後 claude.ai 重走 OAuth（owner 重輸祕密）——刻意不做 refresh token 以免長效機密落地。
@@ -59,14 +59,55 @@ async function pkcePair() {
  return { verifier, challenge };
 }

+/**
+ * cypher `/portal/login` 的假替身（2026-08-12 起 MCP 的把關就是這支——用使用者自己的
+ * Portal 帳密，沒有另一把 owner secret）。帳密對 → 回 session_token ＋ 身分欄位；不對 → 401。
+ */
+const GOOD_EMAIL = "leo@example.com";
+const GOOD_PASSWORD = "correct horse";
+
+function cypherMock(
+  over: {
+    /** null ＝ 登入成功但**不回** session_token（舊版 cypher）；預設回 "sess-abc" */
+    sessionToken?: string | null;
+    displayName?: string;
+    role?: string;
+    libraries?: string[];
+    sessionExpiresIn?: number;
+  } = {},
+): { fetcher: Fetcher; calls: Array<{ email: string; password: string }> } {
+  const calls: Array<{ email: string; password: string }> = [];
+  const fetcher = {
+    async fetch(req: Request) {
+      const body = (await req.json()) as { email: string; password: string };
+      calls.push(body);
+      if (body.email !== GOOD_EMAIL || body.password !== GOOD_PASSWORD) {
+        return new Response(JSON.stringify({ error: "email 或密碼錯誤" }), { status: 401 });
+      }
+      const sessionToken = over.sessionToken === undefined ? "sess-abc" : over.sessionToken;
+      return new Response(
+        JSON.stringify({
+          success: true,
+          ...(sessionToken ? { session_token: sessionToken } : {}),
+          display_name: over.displayName ?? "Leo",
+          role: over.role ?? "admin",
+          libraries: over.libraries ?? ["*"],
+          session_expires_in: over.sessionExpiresIn ?? 604800,
+        }),
+        { status: 200, headers: { "content-type": "application/json" } },
+      );
+    },
+  } as unknown as Fetcher;
+  return { fetcher, calls };
+}
+
 function baseEnv(over: Partial<Env> = {}): Env {
  return {
    COMPONENT_REGISTRY: {} as Fetcher,
-    CYPHER_EXECUTOR: {} as Fetcher,
+    CYPHER_EXECUTOR: cypherMock().fetcher,
    KBDB: {} as Fetcher,
    KBDB_INTERNAL_TOKEN: "internal",
    OAUTH_KV: makeKV(),
-    MCP_OWNER_SECRET: "s3cr3t-owner",
    MCP_OWNER_NAMESPACE: "leo",
    ...over,
  } as Env;
@@ -121,6 +162,8 @@ describe("oauth/store", () => {
      scope: "mcp",
      resource: "https://mcp/mcp",
      namespace: "leo",
+      portal: { session: "sess-abc", display_name: "Leo", role: "admin", libraries: ["*"] },
+      portal_session_expires_in: 604800,
    });
    const first = await consumeAuthCode(kv, "code-1");
    expect(first?.namespace).toBe("leo");
@@ -271,7 +314,11 @@ describe("oauth flow (整合)", () => {
      )}&code_challenge=${challenge}&code_challenge_method=S256&state=xyz&scope=mcp`,
    );
    expect(ok.status).toBe(200);
-    expect(await ok.text()).toContain("Owner 祕密");
+    const consentHtml = await ok.text();
+    // 同意頁問的是 Portal 帳密（不是另一把 owner secret）
+    expect(consentHtml).toContain("Portal");
+    expect(consentHtml).toContain('name="email"');
+    expect(consentHtml).toContain('name="password"');
    // 缺 PKCE → 400
    const bad = await app.req(
      `/authorize?response_type=code&client_id=c1&redirect_uri=${encodeURIComponent(
@@ -281,18 +328,19 @@ describe("oauth flow (整合)", () => {
    expect(bad.status).toBe(400);
  });

-  it("GET /authorize：MCP_OWNER_SECRET 未設 → 503（不留不安全預設）", async () => {
-    const app = buildApp(baseEnv({ MCP_OWNER_SECRET: undefined }));
+  it("GET /authorize：不需要任何 owner 祕密就看得到同意頁（封測者接自己的 AI 不會死在這頁）", async () => {
+    // 舊行為：未設 MCP_OWNER_SECRET → 503 ⇒ 每個封測者都卡住。現在把關是 Portal 帳密。
+    const app = buildApp(baseEnv());
    const { challenge } = await pkcePair();
    const r = await app.req(
      `/authorize?response_type=code&client_id=c1&redirect_uri=${encodeURIComponent(
        "https://claude.ai/cb",
      )}&code_challenge=${challenge}&code_challenge_method=S256`,
    );
-    expect(r.status).toBe(503);
+    expect(r.status).toBe(200);
  });

-  it("完整 code→token：正確 owner 祕密 + 正確 verifier → access_token", async () => {
+  it("完整 code→token：正確 Portal 帳密 + 正確 verifier → access_token", async () => {
    const env = baseEnv();
    const app = buildApp(env);
    const { verifier, challenge } = await pkcePair();
@@ -310,7 +358,8 @@ describe("oauth flow (整合)", () => {
        code_challenge_method: "S256",
        scope: "mcp",
        resource: "https://mcp.arcrun.dev/mcp",
-        owner_secret: "s3cr3t-owner",
+        email: GOOD_EMAIL,
+        password: GOOD_PASSWORD,
      }).toString(),
      redirect: "manual",
    });
@@ -344,6 +393,143 @@ describe("oauth flow (整合)", () => {
    expect(at?.aud).toBe("https://mcp.arcrun.dev/mcp");
  });

+  // ── 2026-08-12：身分要接住並攜帶（本次修的病根）─────────────────────────────
+  describe("登入者身分跟著 token 走（leo：掛上 MCP 並輸入帳密＝授權，下游不得再問一次）", () => {
+    it("驗完帳密不是只留布林值：token 帶得出 portal session 與該帳號的可用知識庫", async () => {
+      const env = baseEnv({ CYPHER_EXECUTOR: cypherMock({ libraries: ["kb"], displayName: "小明", role: "user" }).fetcher });
+      const app = buildApp(env);
+      const { verifier, challenge } = await pkcePair();
+      const redirect = "https://claude.ai/cb";
+      const authRes = await app.req("/authorize", {
+        method: "POST",
+        headers: { "content-type": "application/x-www-form-urlencoded" },
+        body: new URLSearchParams({
+          client_id: "c1",
+          redirect_uri: redirect,
+          code_challenge: challenge,
+          code_challenge_method: "S256",
+          email: GOOD_EMAIL,
+          password: GOOD_PASSWORD,
+        }).toString(),
+        redirect: "manual",
+      });
+      const code = new URL(authRes.headers.get("location")!).searchParams.get("code")!;
+      const tokRes = await app.req("/token", {
+        method: "POST",
+        headers: { "content-type": "application/x-www-form-urlencoded" },
+        body: new URLSearchParams({
+          grant_type: "authorization_code",
+          code,
+          code_verifier: verifier,
+          redirect_uri: redirect,
+        }).toString(),
+      });
+      const at = await getAccessToken(env.OAUTH_KV!, (await tokRes.json()).access_token);
+      expect(at?.portal?.session).toBe("sess-abc");
+      expect(at?.portal?.display_name).toBe("小明");
+      expect(at?.portal?.role).toBe("user");
+      expect(at?.portal?.libraries).toEqual(["kb"]);
+    });
+
+    it("**不同帳號登入 → token 帶的身分跟著換**（不是不管誰登入都同一格）", async () => {
+      // 兩個帳號權限不同：一個全庫、一個只有 kb。token 裡的身分必須各自不同。
+      const envA = baseEnv({ CYPHER_EXECUTOR: cypherMock({ sessionToken: "sess-A", displayName: "Leo", libraries: ["*"] }).fetcher });
+      const envB = baseEnv({ CYPHER_EXECUTOR: cypherMock({ sessionToken: "sess-B", displayName: "小明", libraries: ["kb"] }).fetcher });
+
+      async function tokenFor(env: Env) {
+        const app = buildApp(env);
+        const { verifier, challenge } = await pkcePair();
+        const redirect = "https://claude.ai/cb";
+        const a = await app.req("/authorize", {
+          method: "POST",
+          headers: { "content-type": "application/x-www-form-urlencoded" },
+          body: new URLSearchParams({
+            client_id: "c1",
+            redirect_uri: redirect,
+            code_challenge: challenge,
+            code_challenge_method: "S256",
+            email: GOOD_EMAIL,
+            password: GOOD_PASSWORD,
+          }).toString(),
+          redirect: "manual",
+        });
+        const code = new URL(a.headers.get("location")!).searchParams.get("code")!;
+        const t = await app.req("/token", {
+          method: "POST",
+          headers: { "content-type": "application/x-www-form-urlencoded" },
+          body: new URLSearchParams({
+            grant_type: "authorization_code",
+            code,
+            code_verifier: verifier,
+            redirect_uri: redirect,
+          }).toString(),
+        });
+        return getAccessToken(env.OAUTH_KV!, (await t.json()).access_token);
+      }
+
+      const a = await tokenFor(envA);
+      const b = await tokenFor(envB);
+      expect(a?.portal?.session).not.toBe(b?.portal?.session);
+      expect(a?.portal?.libraries).toEqual(["*"]);
+      expect(b?.portal?.libraries).toEqual(["kb"]);
+    });
+
+    it("access_token 活不過它底下的 portal session（TTL 取兩者較小）", async () => {
+      const env = baseEnv({
+        MCP_TOKEN_TTL: "2592000", // 30 天
+        CYPHER_EXECUTOR: cypherMock({ sessionExpiresIn: 3600 }).fetcher, // session 只有 1 小時
+      });
+      const app = buildApp(env);
+      const { verifier, challenge } = await pkcePair();
+      const redirect = "https://claude.ai/cb";
+      const a = await app.req("/authorize", {
+        method: "POST",
+        headers: { "content-type": "application/x-www-form-urlencoded" },
+        body: new URLSearchParams({
+          client_id: "c1",
+          redirect_uri: redirect,
+          code_challenge: challenge,
+          code_challenge_method: "S256",
+          email: GOOD_EMAIL,
+          password: GOOD_PASSWORD,
+        }).toString(),
+        redirect: "manual",
+      });
+      const code = new URL(a.headers.get("location")!).searchParams.get("code")!;
+      const t = await app.req("/token", {
+        method: "POST",
+        headers: { "content-type": "application/x-www-form-urlencoded" },
+        body: new URLSearchParams({
+          grant_type: "authorization_code",
+          code,
+          code_verifier: verifier,
+          redirect_uri: redirect,
+        }).toString(),
+      });
+      expect((await t.json()).expires_in).toBe(3600);
+    });
+
+    it("cypher 回 200 但沒給 session_token（舊版 cypher）→ 不發碼（不發一張沒有身分的 token）", async () => {
+      const app = buildApp(baseEnv({ CYPHER_EXECUTOR: cypherMock({ sessionToken: null }).fetcher }));
+      const { challenge } = await pkcePair();
+      const r = await app.req("/authorize", {
+        method: "POST",
+        headers: { "content-type": "application/x-www-form-urlencoded" },
+        body: new URLSearchParams({
+          client_id: "c1",
+          redirect_uri: "https://claude.ai/cb",
+          code_challenge: challenge,
+          code_challenge_method: "S256",
+          email: GOOD_EMAIL,
+          password: GOOD_PASSWORD,
+        }).toString(),
+        redirect: "manual",
+      });
+      expect(r.status).toBe(401);
+      expect(r.headers.get("location")).toBeNull();
+    });
+  });
+
  it("錯誤 owner 祕密 → 401、不發 code", async () => {
    const app = buildApp(baseEnv());
    const { challenge } = await pkcePair();
@@ -355,7 +541,8 @@ describe("oauth flow (整合)", () => {
        redirect_uri: "https://claude.ai/cb",
        code_challenge: challenge,
        code_challenge_method: "S256",
-        owner_secret: "WRONG",
+        email: GOOD_EMAIL,
+        password: "WRONG",
      }).toString(),
      redirect: "manual",
    });
@@ -377,7 +564,8 @@ describe("oauth flow (整合)", () => {
        redirect_uri: redirect,
        code_challenge: challenge,
        code_challenge_method: "S256",
-        owner_secret: "s3cr3t-owner",
+        email: GOOD_EMAIL,
+        password: GOOD_PASSWORD,
      }).toString(),
      redirect: "manual",
    });
@@ -445,7 +633,8 @@ describe("oauth resource（RFC 8707）簽發端把關", () => {
        code_challenge: challenge,
        code_challenge_method: "S256",
        resource,
-        owner_secret: "s3cr3t-owner",
+        email: GOOD_EMAIL,
+        password: GOOD_PASSWORD,
      }).toString(),
      redirect: "manual",
    });
@@ -570,7 +759,8 @@ describe("oauth store drift guard：OAUTH_KV 的 put 一律帶 TTL", () => {
        redirect_uri: redirect,
        code_challenge: challenge,
        code_challenge_method: "S256",
-        owner_secret: "s3cr3t-owner",
+        email: GOOD_EMAIL,
+        password: GOOD_PASSWORD,
      }).toString(),
      redirect: "manual",
    });
@@ -0,0 +1,208 @@
+/**
+ * kbdb_* 資料層工具：**用登入進來的那個人的身分查詢**（2026-08-12）。
+ *
+ * leo：「人類進 Portal 輸入帳密表示你是主人，可以查到你權限所有東西；AI 透過輸入帳密的
+ *   MCP 查詢表示是授權的 AI，可以查到主人允許查的任何東西。」
+ *   「掛上 MCP 並輸入帳密，那個動作本身就是授權」⇒ 下游不得再要求第二次認證。
+ *
+ * 本檔守三件事：
+ *   ① 以帳密連線時，查詢**帶登入者的 portal session** 打 cypher `/portal/data/*`
+ *      ——不再拿 KBDB 的服務內部金鑰直打 KBDB（那條路繞過所有庫過濾）。
+ *   ② 呼叫端自帶的 owner_id **一律不生效**（範圍由帳號權限決定，不由呼叫端指定）。
+ *   ③ 舊 token（沒有身分）**fail-closed**：誠實要求重新連線，不偷偷退回服務金鑰那條老路。
+ *   ④ 服務級憑據（static token / partner key）維持既有 KBDB 直連（零回歸）。
+ */
+import { describe, it, expect } from "vitest";
+import type { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+import type { Env } from "../../../src/types.js";
+import { registerAllKbdbDataTools } from "../../../src/tools/kbdb_data.js";
+import type { KnowledgeIdentity } from "../../../src/lib/portal-client.js";
+
+type ToolHandler = (args: Record<string, unknown>) => Promise<{
+  content: { type: string; text: string }[];
+  isError?: boolean;
+}>;
+
+function makeServer() {
+  const tools = new Map<string, { description: string; handler: ToolHandler }>();
+  const server = {
+    tool(name: string, description: string, _schema: unknown, handler: ToolHandler) {
+      tools.set(name, { description, handler });
+    },
+  };
+  return { server: server as unknown as McpServer, tools };
+}
+
+/** 兩個 binding 都掛上，才驗得出「該走哪一條」——走錯的那條會被記錄下來。 */
+function makeEnv(respond: (which: "cypher" | "kbdb", url: URL, init?: RequestInit) => Response) {
+  const cypherCalls: { url: URL; init?: RequestInit }[] = [];
+  const kbdbCalls: { url: URL; init?: RequestInit }[] = [];
+  const env = {
+    CYPHER_EXECUTOR: {
+      fetch: async (input: string, init?: RequestInit) => {
+        const url = new URL(input);
+        cypherCalls.push({ url, init });
+        return respond("cypher", url, init);
+      },
+    },
+    KBDB: {
+      fetch: async (input: string, init?: RequestInit) => {
+        const url = new URL(input);
+        kbdbCalls.push({ url, init });
+        return respond("kbdb", url, init);
+      },
+    },
+    KBDB_INTERNAL_TOKEN: "service-key-should-not-be-used-on-portal-path",
+  } as unknown as Env;
+  return { env, cypherCalls, kbdbCalls };
+}
+
+function parseResult(r: { content: { text: string }[] }) {
+  return JSON.parse(r.content[0].text) as Record<string, unknown>;
+}
+
+const PORTAL: KnowledgeIdentity = {
+  kind: "portal",
+  portal: { session: "sess-abc", display_name: "Leo", role: "admin", libraries: ["kb"] },
+};
+const SERVICE: KnowledgeIdentity = { kind: "service" };
+const STALE: KnowledgeIdentity = { kind: "stale" };
+
+function tools(identity: KnowledgeIdentity, respond: Parameters<typeof makeEnv>[0]) {
+  const { server, tools } = makeServer();
+  const e = makeEnv(respond);
+  registerAllKbdbDataTools(server, e.env, identity);
+  return { tools, ...e };
+}
+
+const OK = () => new Response(JSON.stringify({ success: true, entries: [], records: [], count: 0 }));
+
+describe("kbdb_* 以登入者身分查詢（portal 資料面）", () => {
+  const cases: Array<{ tool: string; args: Record<string, unknown>; path: string; method?: string }> = [
+    { tool: "kbdb_search", args: { q: "火星座標" }, path: "/portal/data/search" },
+    { tool: "kbdb_query", args: { template: "triplet" }, path: "/portal/data/records/by-template/triplet" },
+    { tool: "kbdb_get_record", args: { record_id: "rec_1" }, path: "/portal/data/records/rec_1" },
+    { tool: "kbdb_list_templates", args: {}, path: "/portal/data/templates" },
+    { tool: "kbdb_create_template", args: { name: "contact", slots: ["name"] }, path: "/portal/data/templates", method: "POST" },
+    { tool: "kbdb_create_record", args: { template: "contact", values: { name: "Leo" } }, path: "/portal/data/records", method: "POST" },
+  ];
+
+  for (const c of cases) {
+    it(`${c.tool} → 打 ${c.path}，帶登入者 session，完全不碰 KBDB 服務金鑰`, async () => {
+      const { tools: t, cypherCalls, kbdbCalls } = tools(PORTAL, OK);
+      const res = await t.get(c.tool)!.handler(c.args);
+      expect(res.isError).toBeUndefined();
+
+      // 走的是 cypher 的 portal 資料面，不是 KBDB 直連
+      expect(kbdbCalls, `${c.tool} 不該直打 KBDB`).toHaveLength(0);
+      expect(cypherCalls).toHaveLength(1);
+      expect(cypherCalls[0].url.pathname).toBe(c.path);
+      expect(cypherCalls[0].init?.method ?? "GET").toBe(c.method ?? "GET");
+
+      // 帶的是「那個人的 session」，不是任何服務金鑰
+      const auth = new Headers(cypherCalls[0].init!.headers as HeadersInit).get("Authorization");
+      expect(auth).toBe("Bearer sess-abc");
+      expect(auth).not.toContain("service-key");
+    });
+  }
+
+  it("呼叫端自帶 owner_id 一律不生效（不讓呼叫端自己挑租戶／歸屬）", async () => {
+    const { tools: t, cypherCalls } = tools(PORTAL, OK);
+    await t.get("kbdb_search")!.handler({ q: "x", owner_id: "someone-else" });
+    await t.get("kbdb_query")!.handler({ template: "triplet", owner_id: "someone-else" });
+    for (const call of cypherCalls) {
+      expect(call.url.searchParams.get("owner_id")).toBeNull();
+    }
+  });
+
+  it("寫入時 owner_id 不從呼叫端 body 走（server 定死成登入者的歸屬）", async () => {
+    const { tools: t, cypherCalls } = tools(PORTAL, OK);
+    await t.get("kbdb_create_record")!.handler({
+      template: "contact",
+      values: { name: "Leo" },
+      owner_id: "someone-else",
+    });
+    const body = JSON.parse(String(cypherCalls[0].init!.body)) as Record<string, unknown>;
+    expect(body).not.toHaveProperty("owner_id");
+  });
+
+  it("越庫寫入被擋（403）→ 誠實講是權限問題", async () => {
+    const { tools: t } = tools(PORTAL, () =>
+      new Response(JSON.stringify({ error: '無「secret」庫的權限，不能寫入該庫' }), { status: 403 }),
+    );
+    const res = await t.get("kbdb_create_record")!.handler({
+      template: "note",
+      values: { library: "secret", body: "x" },
+    });
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("forbidden");
+  });
+
+  it("查不是自己的 record（404）→ 與「不存在」同一句話（不洩存在性）", async () => {
+    const { tools: t } = tools(PORTAL, () =>
+      new Response(JSON.stringify({ error: "找不到這筆資料" }), { status: 404 }),
+    );
+    const res = await t.get("kbdb_get_record")!.handler({ record_id: "rec_someone_else" });
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("not_found");
+    expect(String(parseResult(res).human_message)).toContain("不在你的權限範圍內");
+  });
+
+  it("session 過期（401）→ session_expired，不謊稱資料是空的", async () => {
+    const { tools: t } = tools(PORTAL, () =>
+      new Response(JSON.stringify({ error: "session 無效或已過期" }), { status: 401 }),
+    );
+    const res = await t.get("kbdb_search")!.handler({ q: "x" });
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("session_expired");
+  });
+});
+
+describe("fail-closed：舊 token 沒有身分就查不到東西（不退回服務金鑰）", () => {
+  for (const name of [
+    "kbdb_search",
+    "kbdb_query",
+    "kbdb_get_record",
+    "kbdb_list_templates",
+    "kbdb_create_template",
+    "kbdb_create_record",
+  ]) {
+    it(`${name} → identity_missing，且一個查詢都不發`, async () => {
+      const { tools: t, cypherCalls, kbdbCalls } = tools(STALE, OK);
+      const res = await t.get(name)!.handler({
+        q: "x",
+        template: "t",
+        record_id: "r",
+        name: "n",
+        slots: ["a"],
+        values: { a: "b" },
+      });
+      expect(res.isError).toBe(true);
+      expect(parseResult(res).error_code).toBe("identity_missing");
+      expect(cypherCalls).toHaveLength(0);
+      expect(kbdbCalls).toHaveLength(0);
+    });
+  }
+});
+
+describe("回歸：服務級憑據維持既有 KBDB 直連", () => {
+  it("kbdb_search 仍直打 KBDB /entries/search，且照舊吃 owner_id", async () => {
+    const { tools: t, cypherCalls, kbdbCalls } = tools(SERVICE, OK);
+    const res = await t.get("kbdb_search")!.handler({ q: "x", owner_id: "leo" });
+    expect(res.isError).toBeUndefined();
+    expect(cypherCalls).toHaveLength(0);
+    expect(kbdbCalls).toHaveLength(1);
+    expect(kbdbCalls[0].url.pathname).toBe("/entries/search");
+    expect(kbdbCalls[0].url.searchParams.get("owner_id")).toBe("leo");
+  });
+
+  it("kbdb_query / kbdb_get_record 路徑不變", async () => {
+    const { tools: t, kbdbCalls } = tools(SERVICE, OK);
+    await t.get("kbdb_query")!.handler({ template: "triplet" });
+    await t.get("kbdb_get_record")!.handler({ record_id: "rec_1" });
+    expect(kbdbCalls.map((c) => c.url.pathname)).toEqual([
+      "/records/by-template/triplet",
+      "/records/rec_1",
+    ]);
+  });
+});
@@ -5,6 +5,17 @@ import {
  registerGraphNeighbors,
  GRAPH_NEIGHBORS_WORKFLOW,
 } from "../../../src/tools/kbdb_graph.js";
+import type { KnowledgeIdentity } from "../../../src/lib/portal-client.js";
+
+/** 服務級憑據（static token / partner key）——既有路徑，行為零變更。 */
+const SERVICE: KnowledgeIdentity = { kind: "service" };
+/** 有人輸入 Portal 帳密授權的連線——走 cypher 的 portal 資料面。 */
+const PORTAL: KnowledgeIdentity = {
+  kind: "portal",
+  portal: { session: "sess-abc", display_name: "Leo", role: "admin", libraries: ["*"] },
+};
+/** 本次改版前簽發的舊 token（沒有身分）。 */
+const STALE: KnowledgeIdentity = { kind: "stale" };

 // ── 假 McpServer：只攔 tool 註冊，抓出 handler 直接呼叫 ─────────────────────────
 type ToolHandler = (args: Record<string, unknown>) => Promise<{
@@ -45,7 +56,7 @@ describe("kbdb_graph_neighbors: registration", () => {
  it("registers under kbdb_* prefix (D17 KBDB MCP boundary)", () => {
    const { server, tools } = makeServer();
    const { env } = makeEnv(() => new Response("{}"));
-    registerGraphNeighbors(server, env, "leo");
+    registerGraphNeighbors(server, env, "leo", SERVICE);
    expect(tools.has("kbdb_graph_neighbors")).toBe(true);
    expect(tools.get("kbdb_graph_neighbors")!.description).toContain("graph");
  });
@@ -61,7 +72,7 @@ describe("kbdb_graph_neighbors: request shape", () => {
          { status: 200 },
        ),
    );
-    registerGraphNeighbors(server, env, "leo");
+    registerGraphNeighbors(server, env, "leo", SERVICE);
    const res = await tools.get("kbdb_graph_neighbors")!.handler({
      subject: "Arcrun",
      depth: 2,
@@ -88,7 +99,7 @@ describe("kbdb_graph_neighbors: request shape", () => {
    const { env, calls } = makeEnv(
      () => new Response(JSON.stringify({ success: true, neighbors: [], count: 0 })),
    );
-    registerGraphNeighbors(server, env, "leo");
+    registerGraphNeighbors(server, env, "leo", SERVICE);
    await tools.get("kbdb_graph_neighbors")!.handler({
      subject: "A",
      kbdb_base: "https://kbdb.example.com",
@@ -108,7 +119,7 @@ describe("kbdb_graph_neighbors: honest errors (鐵律：workflow 沒裝不 crash
    const { env } = makeEnv(
      () => new Response(JSON.stringify({ error: '找不到 workflow "graph_neighbors"' }), { status: 404 }),
    );
-    registerGraphNeighbors(server, env, "leo");
+    registerGraphNeighbors(server, env, "leo", SERVICE);
    const res = await tools.get("kbdb_graph_neighbors")!.handler({
      subject: "A",
      kbdb_base: "https://kbdb.example.com",
@@ -124,7 +135,7 @@ describe("kbdb_graph_neighbors: honest errors (鐵律：workflow 沒裝不 crash
    const { env } = makeEnv(
      () => new Response(JSON.stringify({ success: false, error: "boom", trace: [] }), { status: 500 }),
    );
-    registerGraphNeighbors(server, env, "leo");
+    registerGraphNeighbors(server, env, "leo", SERVICE);
    const res = await tools.get("kbdb_graph_neighbors")!.handler({
      subject: "A",
      kbdb_base: "https://kbdb.example.com",
@@ -143,7 +154,7 @@ describe("kbdb_graph_neighbors: honest errors (鐵律：workflow 沒裝不 crash
          status: 200,
        }),
    );
-    registerGraphNeighbors(server, env, "leo");
+    registerGraphNeighbors(server, env, "leo", SERVICE);
    const res = await tools.get("kbdb_graph_neighbors")!.handler({
      subject: "A",
      kbdb_base: "https://kbdb.example.com",
@@ -156,7 +167,7 @@ describe("kbdb_graph_neighbors: honest errors (鐵律：workflow 沒裝不 crash
  it("empty orgNamespace → no_namespace error, no fetch made", async () => {
    const { server, tools } = makeServer();
    const { env, calls } = makeEnv(() => new Response("{}"));
-    registerGraphNeighbors(server, env, "");
+    registerGraphNeighbors(server, env, "", SERVICE);
    const res = await tools.get("kbdb_graph_neighbors")!.handler({
      subject: "A",
      kbdb_base: "https://kbdb.example.com",
@@ -166,3 +177,77 @@ describe("kbdb_graph_neighbors: honest errors (鐵律：workflow 沒裝不 crash
    expect(calls).toHaveLength(0);
  });
 });
+
+// ── 2026-08-12：以帳密連線時走登入者的身分（leo：主人查得到的，授權的 AI 就查得到）──
+describe("kbdb_graph_neighbors: 登入身分（portal 資料面）", () => {
+  it("打 cypher 的 /portal/data/graph/neighbors，且帶的是登入者的 session（不是服務金鑰）", async () => {
+    const { server, tools } = makeServer();
+    const { env, calls } = makeEnv(
+      () =>
+        new Response(
+          JSON.stringify({
+            neighbors: [{ node: "B", predicate: "uses", from: "A", depth: 1 }],
+            edges: [],
+            count: 1,
+          }),
+          { status: 200 },
+        ),
+    );
+    registerGraphNeighbors(server, env, "leo", PORTAL);
+    const res = await tools.get("kbdb_graph_neighbors")!.handler({ subject: "A", depth: 2 });
+
+    expect(calls).toHaveLength(1);
+    expect(calls[0].url.pathname).toBe("/portal/data/graph/neighbors/A");
+    expect(calls[0].url.searchParams.get("depth")).toBe("2");
+    const headers = new Headers(calls[0].init!.headers as HeadersInit);
+    expect(headers.get("Authorization")).toBe("Bearer sess-abc");
+
+    expect(res.isError).toBeUndefined();
+    expect((parseResult(res).data as { count: number }).count).toBe(1);
+  });
+
+  it("**不需要 kbdb_base**：已經登入過了，不再要第二次「證明你是誰／你的庫在哪」", async () => {
+    const { server, tools } = makeServer();
+    const { env, calls } = makeEnv(
+      () => new Response(JSON.stringify({ neighbors: [], edges: [], count: 0 })),
+    );
+    registerGraphNeighbors(server, env, "leo", PORTAL);
+    const res = await tools.get("kbdb_graph_neighbors")!.handler({ subject: "A" });
+    expect(res.isError).toBeUndefined();
+    expect(calls).toHaveLength(1);
+    // 呼叫端就算硬塞 kbdb_base 也不會被拿去用（server 自己知道要查哪個庫）
+    expect(calls[0].url.searchParams.get("kbdb_base")).toBeNull();
+  });
+
+  it("session 過期（401）→ 誠實說是登入過期，不說「查不到資料」", async () => {
+    const { server, tools } = makeServer();
+    const { env } = makeEnv(
+      () => new Response(JSON.stringify({ error: "session 無效或已過期" }), { status: 401 }),
+    );
+    registerGraphNeighbors(server, env, "leo", PORTAL);
+    const res = await tools.get("kbdb_graph_neighbors")!.handler({ subject: "A" });
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("session_expired");
+  });
+
+  it("無 graph 權限（403）→ 誠實回沒權限，不假裝「沒有關聯」", async () => {
+    const { server, tools } = makeServer();
+    const { env } = makeEnv(
+      () => new Response(JSON.stringify({ error: "無知識圖譜檢視權限" }), { status: 403 }),
+    );
+    registerGraphNeighbors(server, env, "leo", PORTAL);
+    const res = await tools.get("kbdb_graph_neighbors")!.handler({ subject: "A" });
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("forbidden");
+  });
+
+  it("舊 token（沒有身分）→ 不偷偷退回服務金鑰那條老路，要求重新連線", async () => {
+    const { server, tools } = makeServer();
+    const { env, calls } = makeEnv(() => new Response("{}"));
+    registerGraphNeighbors(server, env, "leo", STALE);
+    const res = await tools.get("kbdb_graph_neighbors")!.handler({ subject: "A" });
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("identity_missing");
+    expect(calls).toHaveLength(0); // 一個查詢都沒發出去（fail-closed）
+  });
+});
@@ -7,6 +7,32 @@ import {
  renderLibraryMapLines,
  __resetLibraryMapInstructionsCacheForTests,
 } from "../../../src/lib/library-map.js";
+import type { KnowledgeIdentity } from "../../../src/lib/portal-client.js";
+
+/** 服務級憑據（static token / partner key）——既有 KBDB 直連路徑，行為零變更。 */
+const SERVICE: KnowledgeIdentity = { kind: "service" };
+/** 有人輸入 Portal 帳密授權的連線——走 cypher 的 portal 資料面（只看得到自己有權限的庫）。 */
+const PORTAL: KnowledgeIdentity = {
+  kind: "portal",
+  portal: { session: "sess-abc", display_name: "Leo", role: "admin", libraries: ["kb"] },
+};
+/** 本次改版前簽發的舊 token（沒有身分）。 */
+const STALE: KnowledgeIdentity = { kind: "stale" };
+
+/** 假 CYPHER_EXECUTOR binding（portal 資料面用）。 */
+function makePortalEnv(respond: (url: URL, init?: RequestInit) => Response) {
+  const calls: { url: URL; init?: RequestInit }[] = [];
+  const env = {
+    CYPHER_EXECUTOR: {
+      fetch: async (input: string, init?: RequestInit) => {
+        const url = new URL(input);
+        calls.push({ url, init });
+        return respond(url, init);
+      },
+    },
+  } as unknown as Env;
+  return { env, calls };
+}

 // ── 假 McpServer：只攔 tool 註冊，抓出 handler 直接呼叫（比照 kbdb-graph.test.ts）──────
 type ToolHandler = (args: Record<string, unknown>) => Promise<{
@@ -56,7 +82,7 @@ describe("kbdb_get_map: registration", () => {
  it("registers under kbdb_* prefix (D17) with the 'call this first' hint in description", () => {
    const { server, tools } = makeServer();
    const { env } = makeEnv(() => new Response("{}"));
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    expect(tools.has("kbdb_get_map")).toBe(true);
    // 任務規格：description 必含「不確定該查什麼時，先呼叫此工具」
    expect(tools.get("kbdb_get_map")!.description).toContain("不確定該查什麼時，先呼叫此工具");
@@ -69,7 +95,7 @@ describe("kbdb_get_map: 全館地圖（無參數）", () => {
    const { env, calls } = makeEnv(
      () => new Response(JSON.stringify({ success: true, libraries: [KB_ROW], count: 1 })),
    );
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({});

    expect(calls).toHaveLength(1);
@@ -90,7 +116,7 @@ describe("kbdb_get_map: 全館地圖（無參數）", () => {
    const { env, calls } = makeEnv(
      () => new Response(JSON.stringify({ success: true, libraries: [], count: 0 })),
    );
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    await tools.get("kbdb_get_map")!.handler({ owner_id: "leo" });
    expect(calls[0].url.searchParams.get("owner_id")).toBe("leo");
  });
@@ -105,7 +131,7 @@ describe("kbdb_get_map: 全館地圖（無參數）", () => {
    const { env } = makeEnv(
      () => new Response(JSON.stringify({ success: true, libraries: [row], count: 1 })),
    );
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({});
    const data = parseResult(res).data as {
      libraries: { top_entities: string[]; triplet_count: number }[];
@@ -119,7 +145,7 @@ describe("kbdb_get_map: 全館地圖（無參數）", () => {
    const { env } = makeEnv(
      () => new Response(JSON.stringify({ success: true, libraries: [], count: 0 })),
    );
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({});
    const body = parseResult(res);
    expect(body.ok).toBe(true);
@@ -135,7 +161,7 @@ describe("kbdb_get_map: 全館地圖（無參數）", () => {
    const { env } = makeEnv(
      () => new Response(JSON.stringify({ success: true, libraries: [], count: 0 })),
    );
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({});
    const body = parseResult(res);
    const hintsText = JSON.stringify(body.hints);
@@ -149,7 +175,7 @@ describe("kbdb_get_map: 全館地圖（無參數）", () => {
  it("HTTP error → map_fetch_failed with recompute hint, not a crash", async () => {
    const { server, tools } = makeServer();
    const { env } = makeEnv(() => new Response("boom", { status: 500 }));
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({});
    expect(res.isError).toBe(true);
    const body = parseResult(res);
@@ -178,7 +204,7 @@ describe("kbdb_get_map: 單庫詳圖（library 參數）", () => {
    const { env, calls } = makeEnv(
      () => new Response(JSON.stringify({ success: true, map: DETAIL })),
    );
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({ library: "kb" });
    expect(calls[0].url.pathname).toBe("/map/kb");
    const map = (parseResult(res).data as { map: typeof DETAIL }).map;
@@ -197,7 +223,7 @@ describe("kbdb_get_map: 單庫詳圖（library 參數）", () => {
      triplet_count: "111",
    };
    const { env } = makeEnv(() => new Response(JSON.stringify({ success: true, map: raw })));
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({ library: "kb" });
    expect(res.isError).toBeUndefined();
    const map = (parseResult(res).data as { map: Record<string, unknown> }).map;
@@ -212,7 +238,7 @@ describe("kbdb_get_map: 單庫詳圖（library 參數）", () => {
    const { env } = makeEnv(
      () => new Response(JSON.stringify({ success: false, error: "not found" }), { status: 404 }),
    );
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({ library: "ghost" });
    expect(res.isError).toBe(true);
    const body = parseResult(res);
@@ -233,7 +259,7 @@ describe("kbdb_get_map: 單庫詳圖（library 參數）", () => {
        },
      },
    } as unknown as Env;
-    registerGetMap(server, env);
+    registerGetMap(server, env, SERVICE);
    const res = await tools.get("kbdb_get_map")!.handler({ library: "kb" });
    expect(res.isError).toBe(true);
    expect(parseResult(res).error_code).toBe("internal_error");
@@ -258,7 +284,7 @@ describe("buildLibraryMapInstructions", () => {
          }),
        ),
    );
-    const text = await buildLibraryMapInstructions(env);
+    const text = await buildLibraryMapInstructions(env, SERVICE);
    expect(text).not.toBeNull();
    // design §4 格式：{library}：{narrative}｜核心：{top3}｜{triplet_count} triplets
    expect(text!).toContain("kb：leo 的知識庫主庫｜核心：00-INDEX、kb/00-INDEX、Gitea｜111 triplets");
@@ -269,7 +295,7 @@ describe("buildLibraryMapInstructions", () => {

  it("HTTP error → null（靜默略過，不 throw 不擋連線）", async () => {
    const { env } = makeEnv(() => new Response("boom", { status: 500 }));
-    await expect(buildLibraryMapInstructions(env)).resolves.toBeNull();
+    await expect(buildLibraryMapInstructions(env, SERVICE)).resolves.toBeNull();
  });

  it("binding throws → null（靜默略過）", async () => {
@@ -280,22 +306,22 @@ describe("buildLibraryMapInstructions", () => {
        },
      },
    } as unknown as Env;
-    await expect(buildLibraryMapInstructions(env)).resolves.toBeNull();
+    await expect(buildLibraryMapInstructions(env, SERVICE)).resolves.toBeNull();
  });

  it("empty libraries → null（沒地圖就不注入，不塞空段落）", async () => {
    const { env } = makeEnv(
      () => new Response(JSON.stringify({ success: true, libraries: [], count: 0 })),
    );
-    await expect(buildLibraryMapInstructions(env)).resolves.toBeNull();
+    await expect(buildLibraryMapInstructions(env, SERVICE)).resolves.toBeNull();
  });

  it("caches within TTL：same isolate 第二次不再打 /map", async () => {
    const { env, calls } = makeEnv(
      () => new Response(JSON.stringify({ success: true, libraries: [KB_ROW], count: 1 })),
    );
-    const first = await buildLibraryMapInstructions(env);
-    const second = await buildLibraryMapInstructions(env);
+    const first = await buildLibraryMapInstructions(env, SERVICE);
+    const second = await buildLibraryMapInstructions(env, SERVICE);
    expect(second).toBe(first);
    expect(calls).toHaveLength(1);
  });
@@ -318,3 +344,95 @@ describe("renderLibraryMapLines", () => {
    expect(renderLibraryMapLines([])).toBeNull();
  });
 });
+
+// ── 2026-08-12：地圖也要跟著登入者的權限走 ────────────────────────────────────
+// 地圖本身就是情報（有哪些庫、各有多少關聯、核心 entity 是誰）——不能整館推給
+// 一個只有部分權限的帳號。
+describe("藏書地圖：登入身分（portal 資料面）", () => {
+  beforeEach(() => __resetLibraryMapInstructionsCacheForTests());
+
+  it("kbdb_get_map 打 /portal/data/map，帶登入者 session，不碰 KBDB 服務金鑰", async () => {
+    const { server, tools } = makeServer();
+    const { env, calls } = makePortalEnv(
+      () => new Response(JSON.stringify({ success: true, libraries: [KB_ROW], count: 1 })),
+    );
+    registerGetMap(server, env, PORTAL);
+    const res = await tools.get("kbdb_get_map")!.handler({});
+    expect(res.isError).toBeUndefined();
+    expect(calls).toHaveLength(1);
+    expect(calls[0].url.pathname).toBe("/portal/data/map");
+    expect(new Headers(calls[0].init!.headers as HeadersInit).get("Authorization")).toBe("Bearer sess-abc");
+  });
+
+  it("呼叫端硬塞 owner_id 也不生效（查詢範圍由帳號權限決定，不由呼叫端指定）", async () => {
+    const { server, tools } = makeServer();
+    const { env, calls } = makePortalEnv(
+      () => new Response(JSON.stringify({ success: true, libraries: [KB_ROW], count: 1 })),
+    );
+    registerGetMap(server, env, PORTAL);
+    await tools.get("kbdb_get_map")!.handler({ owner_id: "someone-else" });
+    expect(calls[0].url.searchParams.get("owner_id")).toBeNull();
+  });
+
+  it("查沒權限的庫 → 與「不存在」同一句話（不洩存在性）", async () => {
+    const { server, tools } = makeServer();
+    const { env } = makePortalEnv(() => new Response(JSON.stringify({ error: "找不到這筆資料" }), { status: 404 }));
+    registerGetMap(server, env, PORTAL);
+    const res = await tools.get("kbdb_get_map")!.handler({ library: "secret-lib" });
+    expect(res.isError).toBe(true);
+    const body = parseResult(res);
+    expect(body.error_code).toBe("map_not_found");
+    expect(String(body.human_message)).toContain("不在你被授權");
+  });
+
+  it("session 過期（401）→ session_expired，不說「地圖是空的」", async () => {
+    const { server, tools } = makeServer();
+    const { env } = makePortalEnv(
+      () => new Response(JSON.stringify({ error: "session 無效或已過期" }), { status: 401 }),
+    );
+    registerGetMap(server, env, PORTAL);
+    const res = await tools.get("kbdb_get_map")!.handler({});
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("session_expired");
+  });
+
+  it("舊 token（沒身分）→ identity_missing，且一個查詢都不發（fail-closed）", async () => {
+    const { server, tools } = makeServer();
+    const { env, calls } = makePortalEnv(() => new Response("{}"));
+    registerGetMap(server, env, STALE);
+    const res = await tools.get("kbdb_get_map")!.handler({});
+    expect(res.isError).toBe(true);
+    expect(parseResult(res).error_code).toBe("identity_missing");
+    expect(calls).toHaveLength(0);
+  });
+
+  it("instructions 的地圖也走 portal 資料面（連線開場推的庫名不得超出權限）", async () => {
+    const { env, calls } = makePortalEnv(
+      () => new Response(JSON.stringify({ success: true, libraries: [KB_ROW], count: 1 })),
+    );
+    const text = await buildLibraryMapInstructions(env, PORTAL);
+    expect(text).toContain("kb");
+    expect(calls[0].url.pathname).toBe("/portal/data/map");
+  });
+
+  it("**快取不跨身分共用**：不同 session 各自打一次，不會拿到別人的視野", async () => {
+    const { env, calls } = makePortalEnv(
+      () => new Response(JSON.stringify({ success: true, libraries: [KB_ROW], count: 1 })),
+    );
+    const other: KnowledgeIdentity = {
+      kind: "portal",
+      portal: { session: "sess-other", display_name: "小明", role: "user", libraries: ["notes"] },
+    };
+    await buildLibraryMapInstructions(env, PORTAL);
+    await buildLibraryMapInstructions(env, other);
+    expect(calls).toHaveLength(2); // 兩次真的各打一次
+    await buildLibraryMapInstructions(env, PORTAL);
+    expect(calls).toHaveLength(2); // 同一 session 第二次才吃快取
+  });
+
+  it("舊 token → 不給地圖（instructions 不外洩任何庫名）", async () => {
+    const { env, calls } = makePortalEnv(() => new Response("{}"));
+    expect(await buildLibraryMapInstructions(env, STALE)).toBeNull();
+    expect(calls).toHaveLength(0);
+  });
+});
Author	SHA1	Message	Date
Leo	21293568d5	Merge PR #107 : 更新完還看得到版本號——CLI 重部署不再把版本標籤洗掉（Arcrun#106）總管複驗（不聽自述，自己重跑並與 base 逐條比對）： cli main 是 0 pass / 3 fail（測試根本跑不起來）→ PR 49 pass / 0 fail ⇒ agent 那句「#97 的守衛測試一直沒在跑」是真的，又一個假綠 cypher 14 failed / 402 passed（base 14 / 400）；失敗清單 diff 無輸出＝零回歸設計比我建議的對：版本標籤每趟重烙、其他 vars 才沿用。我原本建議「一律沿用」會讓版本號永遠停在安裝當時。殘項（agent 誠實標的，不擋併）：沒在真實例上跑過、沒有真 Portal 截圖（它的環境指向 leo21c 紅線、無 youlin 憑證、瀏覽器未授權）。總管接手補這段。	2026-08-12 14:05:57 +00:00
uncle6me-web	53b05c6d3d	fix(cli): 更新完還看得到版本號——CLI 重部署不再把版本標籤（和你的設定）洗掉 leo 08-12 實撞：更新完 leo21c，Portal 設定頁的「版本」變成「無法讀取目前版本（知識庫服務可能正在啟動）」。版本號是 leo 唯一的驗收介面，看不到就等於他無法自己確認任何一次更新有沒有生效。根因（Arcrun#106）：`bundle_version` 來自部署時注入的 plain_text var `ARCRUN_BUNDLE_VERSION`，而只有安裝器會注入。wrangler deploy 是整份覆蓋， toml 沒寫的 var 直接消失 ⇒ CLI 更新那條路每跑一次就把標籤洗掉一次。 #97 修好了「櫃子」（KV/D1/Vectorize 沿用既有），沒修「櫃子上的標籤」。修法（兩種 var 走相反的規則，這是本次的判斷）： · 設定類 var ＝使用者實例的事實 → 沿用（讀綁定時同一份回應就帶回來，不多打 API） ——把 #97「已部署的 worker 上綁著什麼就是事實」原封不動套用到 plain_text var。 · 版本標籤＝這份成品的屬性 → 每趟重烙，絕不沿用舊值。沿用舊值會得到一個永遠停在安裝當天的假標籤——比沒有標籤更糟，因為它會讓人以為驗收過了。版號取部署當下發行頻道公告的 release（Portal/daemon 就是拿它當「最新版」比），另外把真正部署的 commit 一起烙上去（/health 多吐 `bundle_commit`）→ 漂掉查得出來。查不到 release 就誠實退成 `YYYY-MM-DD+<commit7>`，不掰一個 semver 假裝已是最新。順帶（都是同一條路上的東西）： · ref 先解析成 commit sha 再用 sha 下載 archive——不可變，順手解掉 branch tarball 被快取的老病 · Portal 版本行接受帶 build metadata 的 semver（`1.4.41+d61` 這種先前一律被當成「較舊版本」） · cli 測試在 node 22 上本來一支都跑不起來（.js→.ts 解析 + parameter property），補上 resolve hook ——#97 那份「使用者的東西還在不在」的迴歸守衛也在其中，跑不起來的守衛等於沒有守衛 · types.ts 的 ARCRUN_BUNDLE_VERSION 重複宣告（TS2300）併回一處驗證見 PR：cli 49/49 綠、cypher health 4/4 綠、Portal 版本行原始碼實跑五種情境、對真實已部署 worker 的唯讀 dry-run。未做：真實實例上的 acr update 端到端（本機唯一有憑證的帳號是 leo21c＝紅線禁碰，youlin 無憑證）。 Refs: Leo/Arcrun#106, #97, #95 Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>	2026-08-12 21:58:43 +08:00
uncle6me-web	f87d0e92f4	fix(migrations): 0005/0006 從來沒進過版控——被 `.sql` 規則吃掉，每個用戶都收到「部署物缺」 leo 更新 leo21c 時撞到（他問「部分失敗？」）： ✗ D1 migration: 部署物缺 kbdb/migrations/0005_credential_template.sql ✗ D1 migration: 部署物缺 kbdb/migrations/0006_drop_credentials_table.sql （四顆 worker cypher/registry/kbdb/mcp 全部 ✓，失敗的只有這兩個檔）根因不是誰忘了推：.gitignore:53 的 `.sql` 是為了擋 D1 匯出備份（整庫全量＝機敏），但它連 migration 一起吃掉。0001-0004 還在，只因為它們在該規則之前就 commit 了（gitignore 不影響已追蹤檔案）⇒ 0005/0006 從產生那天起就不在任何 clone 裡。 ⇒ 這不是 leo 一台的事：更新指令從 Gitea 抓 main，那兩個檔不在那裡 ⇒ 任何人裝／更新都會收到同一組失敗，包含全新安裝。修法照 rules/05-deploy-convention.md「WASM 來源」段已有的慣例（`.component-builds/*/component.wasm` 就是用否定規則放行的）： !kbdb/migrations/.sql 範圍實測（沒開太大）： kbdb/migrations/0005、0006 → 放行 backup-2026.sql / kbdb/backup-x.sql / dump.sql / cypher-executor/export.sql → 仍被擋進版控前確認過無機敏值：grep 命中的 token/secret/api_key 全是欄位名（api_key、secret_ref）與註解；無 >=20 位英數的疑似真值。殘項：leo21c 實查 templates 9 個、credential 不在其中 ⇒ 0005 從未套用，那台仍停在 D38 之前（credentials 走 0002 的獨立表）。要補套需另跑一次更新。 Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-12 21:10:12 +08:00
uncle6me-web	ba152bc83a	chore(builds): 重編 tier2 成品——把 #105 放進執行檔（出貨路徑 A 的第 0 步） leo 選 A（把出貨線推到能出一版含 #105 的 bundle）。查證後發現最前面還有一層： cypher 源碼最後動 10d150a（#105）／成品最後動 a24f291（更早） mcp 源碼最後動 10d150a（#105）／成品最後動 8e10f1d（更早） ⇒ #105 改了 cypher 與 mcp 兩邊源碼，但沒有重編成品。這正是 Arcrun#93 那道「源碼比執行檔新就停下來」的閘要擋的狀態。用官方唯一編譯點 scripts/build-worker-artifacts.mjs（Arcrun#80 的機制，已存在）重編五顆，全部 5/5： arcrun-cypher-executor 571KB source=10d150ac arcrun-kbdb 146KB source=10d150ac arcrun-mcp 1152KB source=10d150ac arcrun-http-request 78KB source=1e85dfb4（未變） arcrun-code 150KB source=621cb8d9（未變）交叉驗證（不只信它自記的 commit）：/portal/data/ 這條 #105 才有的路徑在 arcrun-mcp 成品裡出現 8 次。下一步（等 leo 解閘）：把修好的引擎部署到 geek6688 當出貨機（ARCRUN_SHIP_BASE 可覆寫，預設是 leo21c——arcrun-rag#79 要搬離的正是這個），再從那台跑出貨線，第 17 站 purge 的 wait 節點才有帶修法的引擎可跑。 Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>	2026-08-12 20:03:30 +08:00
Leo	89b80ff90e	Merge PR #105 : MCP 用登入者的身分查詢，不再去找服務內部金鑰總管複驗（不聽自述，自己重跑，並與 base `a24f291` 逐條比對）： mcp tsc 乾淨；vitest 113/113 綠 cypher 14 紅與 base 逐字元相同（diff 無輸出）；passed 386→400，新增 14 條全過 kbdb 5 紅與 base 相同安全邊界 11 條全綠（跨租戶 404／越庫 404／owner_id 由 server 定死）殘項（已記，不擋併）： · kbdb 的 owner_id 欄位改動沒有新測試守著（213 總數未變） · 工作流面仍靠 MCP_OWNER_NAMESPACE \|\| leo 那個巧合，本 PR 刻意沒動（拔了 arcrun_* 會全面失效） · 端到端 ❌ 未驗：要部署到 leo21c，那道閘要 leo 親手解	2026-08-12 11:42:03 +00:00
uncle6me-web	10d150ac2b	fix(mcp): MCP 用登入者的身分查詢，不再去找一把服務內部金鑰 leo 2026-08-12：「人類進 Portal 輸入帳密表示你是主人，可以查到你權限所有東西； AI 透過輸入帳密的 MCP 查詢表示是授權的 AI，可以查到主人允許查的任何東西。」「掛上 MCP 並輸入帳密，那個動作本身就是授權」⇒ 下游不得再要求第二次認證。病根（不是金鑰沒同步，是身分沒接住）： oauth/routes.ts 驗完 Portal 帳密只留下 `loginOk = res.ok` 一個布林值，身分當場丟棄， namespace 改從 `MCP_OWNER_NAMESPACE \|\| "leo"` 拿。於是查詢時手上沒有身分可帶，只好用 KBDB_INTERNAL_TOKEN 直打 KBDB——那條路繞過 portal 所有庫過濾，而且不管誰登入都看到同一格、看到全部。CLI 也從不注入 MCP_OWNER_NAMESPACE，所以那個 "leo" 預設值是每台實例的實際行為，不是理論上的邊角。修法（走既有那條路，不發明新的）： 1. 接住身分：/authorize 解析 /portal/login 回應，把 portal session token ＋ display_name/role/libraries 存進 authorization code → access token。 /portal/login 補回 session_expires_in，access_token TTL 夾成 min(自己的 TTL, portal session TTL)——不讓「MCP 還連著、底下 session 早死」。 cypher 回 200 但沒給 session_token（舊版）→ 不發碼，不簽一張沒有身分的 token。 2. 攜帶身分：kbdb_* 全部改走 cypher `/portal/data/`，Authorization 帶登入者的 session。庫過濾／租戶注入／停用即時生效全在 server 側，與人類走 portal 網頁同一道閘。 kbdb_graph_neighbors 因此不再需要 kbdb_base（server 自己知道查哪個庫）。藏書地圖（含連線時注入 instructions 的那份）同樣只回有權限的庫，快取改 per-session 分格——地圖本身就是情報，不能讓先連上的人把視野留給下一個。 3. fail-closed：舊 token 沒有身分 → 誠實要求重新連線，不偷偷退回服務金鑰那條老路。服務級憑據（static token / partner key）維持既有 KBDB 直連，arcrun_ 零回歸。新增 cypher portal 資料面端點（能力長在 API，MCP 只暴露；rule 07）： GET /portal/data/map、/portal/data/map/:library GET /portal/data/templates、POST /portal/data/templates GET /portal/data/records/by-template/:t、GET /portal/data/records/:id POST /portal/data/records 全部：呼叫端自帶 owner_id 一律不生效；越權與不存在同回 404；寫入 owner_id 由 server 定死。 KBDB base：`GET /records/:id` 與 by-template 補回 owner_id 欄位——原本不回，呼叫端無從判斷「這筆是不是我的」，按 id 直讀等於沒有租戶邊界。沒動：KBDB fail-closed 閘、任何金鑰、租戶字串仍不下發給呼叫端。驗證： mcp tsc 綠；vitest 113/113 綠（改前 48 綠 29 紅） cypher vitest 400 綠 / 14 紅，14 紅與 base commit `a24f291` 逐條相同（既有） kbdb vitest 208 綠 / 5 紅，5 紅同為既有（migrations/*.sql 被 gitignore）端到端 ◐ 未驗：需部署到 leo21c，那道閘要 leo 親手解（見 PR） Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>	2026-08-12 19:33:12 +08:00