feat(cypher): POST /kbdb/records 開通 entry_ids 通道(Arcrun#128 的對外門)

基本盤補好而通道不開=能力在、沒人打得到——同 b6ef0f0 那次 PATCH 的形狀。
#129(wiki template)與 #130(三元組正規化)的寫入端走的就是這扇門。

改了兩件事(維持純轉發,判斷全在基本盤,薄殼鐵律見檔頭):
· 舊版寫死 `!body.values → 400`:只給 entry_ids 的合法請求會被自己的 proxy 擋掉
  ⇒ 改成「values 與 entry_ids 至少要有一個」
· 轉發 body 帶上 entry_ids;沒給的那個 key 就不塞(不憑空給基本盤一個空物件)

租戶隔離沿用本檔既有做法:**忽略 caller 自帶的 owner_id,一律注入 header 身份**。
配合基本盤這次加的檢查(被參照 entry 的 owner_id 必須與注入的租戶相符),
「呼叫端可以自己指定 entry_id」這條新路徑不會變成跨租戶的門。

驗(tests/kbdb-records-entry-ids-proxy.test.ts,6 條,fetchMock 假 host+斷網)
· 無 X-Arcrun-API-Key → 401 不碰 KBDB
· 只給 entry_ids → 轉發成功,body 為 {template, entry_ids, owner_id:'leo'}(無 values key),
  且 caller 自帶的 owner_id:'alice' 被忽略
· values 與 entry_ids 混用 → 兩個都轉過去
· 舊呼叫端只給 values → 轉發 body 與過去逐字相同,不夾帶 entry_ids
· 兩個都沒給 → 400 不轉發;base 擋跨租戶(400)→ 原樣透傳不假裝成功

cypher-executor 全套 445 綠 / 14 紅——那 14 條是**既有**紅燈
(auth-dispatcher/console-library-map-page/executor/portal-admin/portal-data),
已用 `git stash` 拿掉本次改動複跑同五個檔複驗:同樣 14 紅,與本次無關。

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
uncle6me-web
2026-08-15 14:48:01 +08:00
parent aa49b4eeb2
commit 9ba6ba75fc
2 changed files with 143 additions and 4 deletions
+17 -4
View File
@@ -81,20 +81,33 @@ kbdbProxyRouter.get('/kbdb/templates/:idOrName', async (c) => {
// ── records(以租戶 namespace 為 owner_id 隔離)──────────────────────────────── // ── records(以租戶 namespace 為 owner_id 隔離)────────────────────────────────
// POST /kbdb/records — 填一筆 recordtemplate + values)。owner_id 自動注入。 // POST /kbdb/records — 填一筆 recordtemplate + valuesentry_ids)。owner_id 自動注入。
//
// `entry_ids`Arcrun#128)= slot 指向**既有** entry 的 id,不新建、不複製;與 values 並存
// (給字串照舊新建)。這裡維持純轉發,判斷與擋人全在基本盤 kbdb(薄殼鐵律,見檔頭):
// · 兩者都沒給/型別不對 → base 回 400
// · 指到別人的 entry → base 擋(它比對被參照 entry 的 owner_id 與這裡注入的租戶身份,
// 所以「呼叫端自己指定 entry_id」這條新路徑不會變成跨租戶的門)
// 🔴 為什麼通道要一起開:#129wiki template)與 #130(三元組正規化)的寫入端走這扇門。
// 基本盤補好而通道不開=能力在、沒人打得到——同 PATCH 那次(b6ef0f0)的教訓。
kbdbProxyRouter.post('/kbdb/records', async (c) => { kbdbProxyRouter.post('/kbdb/records', async (c) => {
const owner = tenant(c); const owner = tenant(c);
if (!owner) return c.json(NEED_KEY, 401); if (!owner) return c.json(NEED_KEY, 401);
const body = await c.req.json().catch(() => null); const body = await c.req.json().catch(() => null);
if (!body || !body.template || !body.values) { if (!body || !body.template || (!body.values && !body.entry_ids)) {
return c.json({ error: 'template values 必填' }, 400); return c.json({ error: 'template 必填,values 與 entry_ids 至少要有一個' }, 400);
} }
const { base, headers } = kbdbBase(c.env); const { base, headers } = kbdbBase(c.env);
const res = await fetch(`${base}/records`, { const res = await fetch(`${base}/records`, {
method: 'POST', method: 'POST',
headers, headers,
// 強制以租戶身份隔離:忽略 caller 自帶 owner_id,一律用 header 身份(防跨租戶寫入) // 強制以租戶身份隔離:忽略 caller 自帶 owner_id,一律用 header 身份(防跨租戶寫入)
body: JSON.stringify({ template: body.template, values: body.values, owner_id: owner }), body: JSON.stringify({
template: body.template,
...(body.values ? { values: body.values } : {}),
...(body.entry_ids ? { entry_ids: body.entry_ids } : {}),
owner_id: owner,
}),
}); });
return new Response(res.body, { status: res.status, headers: { 'Content-Type': 'application/json' } }); return new Response(res.body, { status: res.status, headers: { 'Content-Type': 'application/json' } });
}); });
@@ -0,0 +1,126 @@
/**
* POST /kbdb/records — `entry_ids` 通道(Arcrun#128
*
* 背景:基本盤 kbdb 的 createRecord 現在接受 `entry_ids`slot 指向**既有** entry 的 id
* 不新建、不複製)。這條 proxy 之前寫死只轉發 `values`,且沒有 values 就 400
* ⇒ 走 X-Arcrun-API-Key 的呼叫者(#129 的 wiki 寫入端、#130 的三元組正規化)打不到新能力,
* 等於基本盤補好了、通道沒開(同 b6ef0f0 那次 PATCH 的形狀)。
*
* 驗的是 IO 接線(判斷真身在基本盤,這裡只測轉發,比照 kbdb-records-patch-proxy.test.ts):
* 1. 租戶閘:無 X-Arcrun-API-Key → 401 不碰 KBDB
* 2. 只給 entry_ids(沒有 values)→ 轉發成功(舊版這裡是 400)
* 3. 轉發的 body:帶 entry_ids **注入租戶當 owner_id**caller 自帶的 owner_id 被忽略)
* 4. values 與 entry_ids 混用 → 兩個都轉過去
* 5. 兩個都沒給 → 400,不轉發
* 6. base 擋跨租戶(400)→ 原樣透傳,不假裝成功
*
* KBDB 打 fetchMock 假 hostwrangler.test.toml KBDB_BASE_URL=https://kbdb.test)+
* disableNetConnect——測試絕不外連。
*/
import { SELF, fetchMock } from 'cloudflare:test';
import { beforeAll, afterEach, describe, it, expect } from 'vitest';
const KEY = { 'X-Arcrun-API-Key': 'leo', 'Content-Type': 'application/json' };
beforeAll(() => {
fetchMock.activate();
fetchMock.disableNetConnect();
});
afterEach(() => fetchMock.assertNoPendingInterceptors());
describe('POST /kbdb/recordsentry_ids)— 租戶閘與參數', () => {
it('無 X-Arcrun-API-Key → 401,不碰 KBDB', async () => {
const res = await SELF.fetch('http://localhost/kbdb/records', {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({ template: 'wiki', entry_ids: { gloss: 'e_1' } }),
});
expect(res.status).toBe(401);
});
it('values 與 entry_ids 都沒給 → 400,不轉發', async () => {
const res = await SELF.fetch('http://localhost/kbdb/records', {
method: 'POST',
headers: KEY,
body: JSON.stringify({ template: 'wiki' }),
});
expect(res.status).toBe(400);
});
});
describe('POST /kbdb/recordsentry_ids)— 轉發', () => {
it('只給 entry_ids(沒有 values)→ 轉發,且 owner_id 由租戶身份注入', async () => {
fetchMock
.get('https://kbdb.test')
.intercept({
path: '/records',
method: 'POST',
// 沒有 values 這個 key(不要憑空塞一個空物件給基本盤)
body: JSON.stringify({ template: 'wiki', entry_ids: { gloss: 'e_1', points: 'e_2' }, owner_id: 'leo' }),
})
.reply(200, {
success: true,
record: { record_id: 'rec_1', template_id: 'tpl-wiki', values: { gloss: '既有', points: '既有2' }, owner_id: 'leo' },
});
const res = await SELF.fetch('http://localhost/kbdb/records', {
method: 'POST',
headers: KEY,
// caller 自帶 owner_id:必須被忽略(防跨租戶寫入,本檔既有慣例)
body: JSON.stringify({ template: 'wiki', entry_ids: { gloss: 'e_1', points: 'e_2' }, owner_id: 'alice' }),
});
expect(res.status).toBe(200);
const data = (await res.json()) as { success: boolean; record: { values: Record<string, string> } };
expect(data.success).toBe(true);
expect(data.record.values.gloss).toBe('既有');
});
it('values 與 entry_ids 混用 → 兩個都轉過去', async () => {
fetchMock
.get('https://kbdb.test')
.intercept({
path: '/records',
method: 'POST',
body: JSON.stringify({ template: 'wiki', values: { title: '新建' }, entry_ids: { gloss: 'e_1' }, owner_id: 'leo' }),
})
.reply(200, { success: true, record: { record_id: 'rec_2', template_id: 'tpl-wiki', values: {}, owner_id: 'leo' } });
const res = await SELF.fetch('http://localhost/kbdb/records', {
method: 'POST',
headers: KEY,
body: JSON.stringify({ template: 'wiki', values: { title: '新建' }, entry_ids: { gloss: 'e_1' } }),
});
expect(res.status).toBe(200);
});
it('舊呼叫端(只給 values)→ 轉發的 body 不夾帶 entry_ids,行為與過去相同', async () => {
fetchMock
.get('https://kbdb.test')
.intercept({
path: '/records',
method: 'POST',
body: JSON.stringify({ template: 'triplet', values: { subject: 'A', predicate: 'r', object: 'B' }, owner_id: 'leo' }),
})
.reply(200, { success: true, record: { record_id: 'rec_3', template_id: 'tpl-triplet', values: {}, owner_id: 'leo' } });
const res = await SELF.fetch('http://localhost/kbdb/records', {
method: 'POST',
headers: KEY,
body: JSON.stringify({ template: 'triplet', values: { subject: 'A', predicate: 'r', object: 'B' } }),
});
expect(res.status).toBe(200);
});
it('base 擋下跨租戶參照(400)→ 原樣透傳,不假裝成功', async () => {
fetchMock
.get('https://kbdb.test')
.intercept({ path: '/records', method: 'POST' })
.reply(400, { success: false, error: 'entry owner mismatch: e_x(alice) != leo' });
const res = await SELF.fetch('http://localhost/kbdb/records', {
method: 'POST',
headers: KEY,
body: JSON.stringify({ template: 'wiki', entry_ids: { gloss: 'e_x' } }),
});
expect(res.status).toBe(400);
const data = (await res.json()) as { success: boolean; error: string };
expect(data.success).toBe(false);
expect(data.error).toContain('owner mismatch');
});
});