Merge branch 'main' into spec/artifact-sharing
This commit is contained in:
@@ -6,6 +6,11 @@ dist/
|
||||
# 例外：放行 .component-builds 的部署物 wasm — self-host 用戶 / acr init 從 repo 直接拿這份部署
|
||||
# （推翻 rule 05 原「wasm 不 commit」慣例，見 .agents/specs/arcrun/sdk-and-website/self-hosted-init.md §6）
|
||||
!.component-builds/**/component.wasm
|
||||
# 例外：code 零件（自足 Worker）的 vendored quickjs.wasm 同屬部署物 —— acr init/update 從
|
||||
# repo archive 直接部署（同上 .component-builds 放行邏輯）。來源＝npm 套件
|
||||
# @jitl/quickjs-wasmfile-release-sync 的 emscripten-module.wasm，由 postinstall vendor-wasm.mjs
|
||||
# 產出、跟套件版本走（升版時重跑 npm install 再 commit 覆蓋）。約 491KB。
|
||||
!registry/components/code/vendor/quickjs.wasm
|
||||
# 但「錯做成零件」的再次排除（後出現的規則勝出）：claude_api / km_writer / kbdb_upsert_block
|
||||
# 不是 endpoint 薄殼，是把工作流硬塞進零件（違反 DECISIONS §1）→ 要降級成工作流/recipe，
|
||||
# 不該進 repo 部署來源。commit 二進位進歷史無法乾淨移除 → 一開始就不放行。見 BACKLOG 降級待辦。
|
||||
|
||||
@@ -109,6 +109,23 @@ export const BUILTIN_COMPONENTS: ComponentDef[] = [
|
||||
component: wait
|
||||
ms: 1000`,
|
||||
},
|
||||
{
|
||||
// code 是自足 Worker（quickjs 沙箱，registry/components/code），非 TinyGo-wasm 家族，
|
||||
// 但同屬靜態零件（走 PR + 人類閘門 merge 新增）→ 進本清單正確（issue #13 W3 原則）。
|
||||
// 部署：acr init/update 的 downloadAndDeploy 自動部署（deploy.ts SELF_CONTAINED_COMPONENT_WORKERS）。
|
||||
canonical_id: 'code',
|
||||
display_name: '程式碼（沙箱 inline JS）',
|
||||
category: 'logic',
|
||||
description: 'QuickJS-wasm 沙箱執行 inline JS：讀 input、return JSON-able 值；碰不到網路/檔案/env',
|
||||
config_example:
|
||||
` my_code:
|
||||
component: code
|
||||
code: |
|
||||
const doubled = input.items.map(x => x * 2);
|
||||
return { doubled, count: doubled.length };
|
||||
input:
|
||||
items: [1, 2, 3]`,
|
||||
},
|
||||
// ── 資料類（Data） ─────────────────────────────────────────────────────────
|
||||
{
|
||||
canonical_id: 'set',
|
||||
|
||||
+41
-10
@@ -136,6 +136,24 @@ export const SECRET_TARGET_WORKERS = [
|
||||
'arcrun-auth-service-account',
|
||||
] as const;
|
||||
|
||||
/** 共享部署依賴（downloadAndDeploy 2.5：tarball root 裝一次，各 worker 往上 resolve）。
|
||||
* 含全部 worker 的 runtime deps：tier1 component 只要 hono；tier2 cypher/registry/mcp/kbdb
|
||||
* 另需 zod / @hono/zod-openapi / @modelcontextprotocol/sdk / js-yaml / yaml；
|
||||
* code 自足 Worker（registry/components/code）另需 quickjs-emscripten-core + wasmfile variant
|
||||
* （版本對齊該零件 package.json，drift 由 cli/tests/deploy-code-component.test.ts 看守）。
|
||||
* 漏一個會讓該 worker deploy 失敗，故寧可多列。export 供離線測試驗清單完整。*/
|
||||
export const SHARED_DEPLOY_DEPS: Record<string, string> = {
|
||||
hono: '^4.7.0',
|
||||
wrangler: '^4.0.0',
|
||||
zod: '^3.23.0',
|
||||
'@hono/zod-openapi': '^0.18.0',
|
||||
'@modelcontextprotocol/sdk': '^1.0.0',
|
||||
'js-yaml': '^4.1.0',
|
||||
yaml: '^2.4.0',
|
||||
'quickjs-emscripten-core': '^0.31.0',
|
||||
'@jitl/quickjs-wasmfile-release-sync': '^0.32.0',
|
||||
};
|
||||
|
||||
export interface DeployContext {
|
||||
accountId: string;
|
||||
apiToken: string;
|
||||
@@ -215,17 +233,11 @@ export async function downloadAndDeploy(
|
||||
let sharedBin = '';
|
||||
try {
|
||||
process.stdout.write(chalk.gray(' → 安裝共享部署依賴（一次，取代每個 worker 各裝）...'));
|
||||
// 含全部 worker 的 runtime deps（tier1 component 只要 hono；tier2 cypher/registry/mcp/kbdb
|
||||
// 另需 zod / @hono/zod-openapi / @modelcontextprotocol/sdk / js-yaml / yaml）→ 全裝 root，
|
||||
// 各 worker 往上 resolve，esbuild bundle 找得到。漏一個會讓該 worker deploy 失敗，故寧可多列。
|
||||
// 依賴清單抽出成 SHARED_DEPLOY_DEPS（export 供離線測試看守，見常數 doc）。
|
||||
writeFileSync(
|
||||
join(root, 'package.json'),
|
||||
JSON.stringify({ name: 'arcrun-deploy-shared', private: true, type: 'module',
|
||||
dependencies: {
|
||||
hono: '^4.7.0', wrangler: '^4.0.0', zod: '^3.23.0',
|
||||
'@hono/zod-openapi': '^0.18.0', '@modelcontextprotocol/sdk': '^1.0.0',
|
||||
'js-yaml': '^4.1.0', yaml: '^2.4.0',
|
||||
} }),
|
||||
dependencies: SHARED_DEPLOY_DEPS }),
|
||||
);
|
||||
execFileSync('npm', ['install', '--no-audit', '--no-fund'],
|
||||
{ cwd: root, stdio: ['ignore', 'ignore', 'pipe'] });
|
||||
@@ -479,8 +491,17 @@ async function downloadRepoTarball(ref: string): Promise<string> {
|
||||
return join(dir, top);
|
||||
}
|
||||
|
||||
/** 掃解壓出的部署物，回傳 tier1（.component-builds/*）與 tier2（cypher-executor/registry）目錄清單。*/
|
||||
function discoverWorkerDirs(root: string): { tier1: string[]; tier2: string[] } {
|
||||
/** 自足 Worker 零件（非 TinyGo-wasm 家族）：目錄相對 root + 部署 gate 必要產物（相對該目錄）。
|
||||
* 目前只有 code（quickjs 沙箱，registry/components/code）。gate 精神比照 tier1 的 component.wasm：
|
||||
* 必要產物（vendored quickjs.wasm，需 commit 進 repo）缺 → 誠實跳過，不讓 wrangler deploy 因缺檔失敗。
|
||||
* export 供離線測試驗「部署清單含 code + 產物 gate 正確」。*/
|
||||
export const SELF_CONTAINED_COMPONENT_WORKERS: ReadonlyArray<{ dir: string[]; requires: string[][] }> = [
|
||||
{ dir: ['registry', 'components', 'code'], requires: [['vendor', 'quickjs.wasm']] },
|
||||
];
|
||||
|
||||
/** 掃解壓出的部署物，回傳 tier1（.component-builds/* + 自足 Worker 零件）與
|
||||
* tier2（cypher-executor/registry/kbdb/mcp 引擎）目錄清單。export 供離線測試。*/
|
||||
export function discoverWorkerDirs(root: string): { tier1: string[]; tier2: string[] } {
|
||||
const tier1: string[] = [];
|
||||
const tier2: string[] = [];
|
||||
|
||||
@@ -497,6 +518,16 @@ function discoverWorkerDirs(root: string): { tier1: string[]; tier2: string[] }
|
||||
}
|
||||
}
|
||||
}
|
||||
// 自足 Worker 零件（如 code）：與 TinyGo 家族不同（自帶 index.ts + 相依 npm 套件 +
|
||||
// vendored quickjs.wasm），但同屬 tier1「零件」語義 → 一起先於引擎部署。
|
||||
// deps（quickjs-emscripten-core / wasmfile variant）由 root 共享安裝提供（SHARED_DEPLOY_DEPS），
|
||||
// wrangler 對相對路徑 .wasm import 自動綁 CompiledWasm（見該零件 index.ts 頭註）。
|
||||
for (const { dir: rel, requires } of SELF_CONTAINED_COMPONENT_WORKERS) {
|
||||
const dir = join(root, ...rel);
|
||||
const complete = existsSync(join(dir, 'wrangler.toml'))
|
||||
&& requires.every(r => existsSync(join(dir, ...r)));
|
||||
if (complete) tier1.push(dir);
|
||||
}
|
||||
// self-hosted 也部署自己的 MCP worker（mcp-account-source §5c：archive 主庫即得 MCP，
|
||||
// .mcp.json 指自己的 mcp 而非官方 mcp.arcrun.dev）。
|
||||
// kbdb：MCP 的 partnerAuthMiddleware 透過 KBDB service binding 打 arcrun-kbdb worker（mcp/wrangler.toml）。
|
||||
|
||||
@@ -0,0 +1,137 @@
|
||||
/**
|
||||
* deploy-code-component.test.ts — 離線驗「code 零件接進部署流程」（Arcrun#4 後續）。
|
||||
*
|
||||
* 驗三件事（不打網路、不部署）：
|
||||
* 1. 部署清單含 code：discoverWorkerDirs 在產物齊全時把 registry/components/code 收進 tier1；
|
||||
* 缺 vendored quickjs.wasm 時誠實跳過（gate 精神比照 tier1 component.wasm）。
|
||||
* 2. 產物完整：repo 內 code 零件的部署必要檔存在且 quickjs.wasm 已被 git 追蹤
|
||||
* （= 會進 Gitea archive tarball，acr update 才拿得到）；共享依賴 SHARED_DEPLOY_DEPS
|
||||
* 涵蓋 code 零件 package.json 的全部 runtime deps（drift 守門）。
|
||||
* 3. 注入正確：stripOfficialOnlyBindings 對 code 的 wrangler.toml 剝掉官方 route
|
||||
* （code.arcrun.dev），保留 workers_dev / COMPONENT_ID → self-hosted 落自己帳號的 workers.dev。
|
||||
*
|
||||
* 用 Node 內建 test runner（node --test，零額外依賴；Node ≥22.18 自帶 TS type-stripping）。
|
||||
*/
|
||||
import { test } from 'node:test';
|
||||
import assert from 'node:assert/strict';
|
||||
import { mkdtempSync, mkdirSync, writeFileSync, readFileSync, statSync } from 'node:fs';
|
||||
import { execFileSync } from 'node:child_process';
|
||||
import { createHash } from 'node:crypto';
|
||||
import { tmpdir } from 'node:os';
|
||||
import { join, dirname } from 'node:path';
|
||||
import { fileURLToPath } from 'node:url';
|
||||
import {
|
||||
discoverWorkerDirs,
|
||||
SELF_CONTAINED_COMPONENT_WORKERS,
|
||||
SHARED_DEPLOY_DEPS,
|
||||
stripOfficialOnlyBindings,
|
||||
injectMultiTenant,
|
||||
} from '../src/lib/deploy.ts';
|
||||
|
||||
const REPO_ROOT = join(dirname(fileURLToPath(import.meta.url)), '..', '..');
|
||||
const CODE_DIR = join(REPO_ROOT, 'registry', 'components', 'code');
|
||||
|
||||
// ── 1. 部署清單 ───────────────────────────────────────────────────────────────
|
||||
|
||||
function makeFixtureRoot(opts: { withWasm: boolean; withToml?: boolean }): string {
|
||||
const root = mkdtempSync(join(tmpdir(), 'arcrun-test-root-'));
|
||||
const dir = join(root, 'registry', 'components', 'code');
|
||||
mkdirSync(join(dir, 'vendor'), { recursive: true });
|
||||
if (opts.withToml !== false) writeFileSync(join(dir, 'wrangler.toml'), 'name = "arcrun-code"\n');
|
||||
if (opts.withWasm) writeFileSync(join(dir, 'vendor', 'quickjs.wasm'), 'fake-wasm');
|
||||
return root;
|
||||
}
|
||||
|
||||
test('discoverWorkerDirs：code 產物齊全 → 進 tier1（部署清單含 code）', () => {
|
||||
const root = makeFixtureRoot({ withWasm: true });
|
||||
const { tier1 } = discoverWorkerDirs(root);
|
||||
assert.ok(tier1.some(d => d.endsWith(join('registry', 'components', 'code'))),
|
||||
`tier1 應含 code 目錄，實得：${JSON.stringify(tier1)}`);
|
||||
});
|
||||
|
||||
test('discoverWorkerDirs：缺 vendor/quickjs.wasm → 誠實跳過（不讓 wrangler 因缺檔失敗）', () => {
|
||||
const root = makeFixtureRoot({ withWasm: false });
|
||||
const { tier1, tier2 } = discoverWorkerDirs(root);
|
||||
assert.ok(!tier1.concat(tier2).some(d => d.includes('code')),
|
||||
'wasm 缺席時不應把 code 排進部署清單');
|
||||
});
|
||||
|
||||
test('discoverWorkerDirs：缺 wrangler.toml → 跳過', () => {
|
||||
const root = makeFixtureRoot({ withWasm: true, withToml: false });
|
||||
const { tier1 } = discoverWorkerDirs(root);
|
||||
assert.equal(tier1.length, 0);
|
||||
});
|
||||
|
||||
test('SELF_CONTAINED_COMPONENT_WORKERS 宣告 code 目錄與必要產物', () => {
|
||||
const code = SELF_CONTAINED_COMPONENT_WORKERS.find(w => w.dir.join('/') === 'registry/components/code');
|
||||
assert.ok(code, '清單應含 registry/components/code');
|
||||
assert.ok(code!.requires.some(r => r.join('/') === 'vendor/quickjs.wasm'));
|
||||
});
|
||||
|
||||
// ── 2. 產物完整（對 repo 實體檢查） ──────────────────────────────────────────
|
||||
|
||||
test('repo 內 code 零件部署必要檔齊全，quickjs.wasm 已 commit（會進 Gitea archive）', () => {
|
||||
for (const f of ['wrangler.toml', 'index.ts', 'sandbox.mjs', join('vendor', 'quickjs.wasm')]) {
|
||||
assert.ok(statSync(join(CODE_DIR, f)).isFile(), `缺 ${f}`);
|
||||
}
|
||||
assert.ok(statSync(join(CODE_DIR, 'vendor', 'quickjs.wasm')).size > 100_000,
|
||||
'quickjs.wasm 尺寸異常（應約 491KB）');
|
||||
// git 追蹤 = 會被 git archive 打包進 Gitea 下載物（.gitignore 放行是否生效的最終證據）。
|
||||
const tracked = execFileSync('git', ['ls-files', '--', 'registry/components/code/vendor/quickjs.wasm'],
|
||||
{ cwd: REPO_ROOT, encoding: 'utf8' }).trim();
|
||||
assert.equal(tracked, 'registry/components/code/vendor/quickjs.wasm',
|
||||
'vendor/quickjs.wasm 未被 git 追蹤（.gitignore 放行失效或忘了 git add）');
|
||||
});
|
||||
|
||||
// vendored quickjs.wasm 的內容指紋（@jitl/quickjs-wasmfile-release-sync ^0.32.0 的
|
||||
// emscripten-module.wasm）。升套件版本卻沒重跑 vendor（npm install → postinstall）再 commit
|
||||
// → 這裡紅燈，防「package.json 升了、部署物 wasm 還是舊版」的 drift（審查小記 2026-07-07）。
|
||||
// 升版 SOP：cd registry/components/code && npm install → commit vendor/quickjs.wasm → 更新此常數。
|
||||
const QUICKJS_WASM_SHA256 = '105c3bed22d457e43e3d1c3c1c6959fda62a8fe06f0fc8a985303c3a2be72232';
|
||||
|
||||
test('vendored quickjs.wasm 內容指紋一致（升版沒重 vendor 就紅燈）', () => {
|
||||
const buf = readFileSync(join(CODE_DIR, 'vendor', 'quickjs.wasm'));
|
||||
const sha = createHash('sha256').update(buf).digest('hex');
|
||||
assert.equal(sha, QUICKJS_WASM_SHA256,
|
||||
'vendor/quickjs.wasm 指紋與紀錄不符：若剛升 quickjs 套件版本，重跑 npm install 讓 postinstall ' +
|
||||
'重 vendor、commit 新 wasm，並同步更新 QUICKJS_WASM_SHA256');
|
||||
});
|
||||
|
||||
test('SHARED_DEPLOY_DEPS 涵蓋 code 零件全部 runtime deps（drift 守門）', () => {
|
||||
const pkg = JSON.parse(readFileSync(join(CODE_DIR, 'package.json'), 'utf8')) as
|
||||
{ dependencies?: Record<string, string> };
|
||||
for (const [dep, ver] of Object.entries(pkg.dependencies ?? {})) {
|
||||
assert.ok(dep in SHARED_DEPLOY_DEPS,
|
||||
`code 零件 runtime dep「${dep}」不在 SHARED_DEPLOY_DEPS → 共享安裝路徑下 esbuild 會解析失敗`);
|
||||
assert.equal(SHARED_DEPLOY_DEPS[dep], ver,
|
||||
`「${dep}」版本 drift：SHARED_DEPLOY_DEPS=${SHARED_DEPLOY_DEPS[dep]} vs 零件 package.json=${ver}`);
|
||||
}
|
||||
});
|
||||
|
||||
// ── 3. 注入正確（用 repo 內真 wrangler.toml） ────────────────────────────────
|
||||
|
||||
test('stripOfficialOnlyBindings：剝掉 code.arcrun.dev route，保留 workers_dev + COMPONENT_ID', () => {
|
||||
const toml = readFileSync(join(CODE_DIR, 'wrangler.toml'), 'utf8');
|
||||
assert.match(toml, /code\.arcrun\.dev/, '前提：repo toml 應含官方 route（官方 CI 部署用）');
|
||||
const out = stripOfficialOnlyBindings(toml);
|
||||
assert.ok(!/\[\[routes\]\]|zone_name|code\.arcrun\.dev/.test(out), `官方 route 應被剝除：\n${out}`);
|
||||
assert.match(out, /workers_dev\s*=\s*true/, 'workers_dev 須保留（self-hosted 靠它對外）');
|
||||
assert.match(out, /COMPONENT_ID\s*=\s*"code"/, '[vars] COMPONENT_ID 須保留');
|
||||
assert.match(out, /name\s*=\s*"arcrun-code"/, 'worker 名須保留（cypher wasmWorkerUrl 慣例 arcrun-{kebab}）');
|
||||
});
|
||||
|
||||
test('injectMultiTenant：code toml 有 [vars] → 插入 MULTI_TENANT="false"（無害，與其他 worker 一致）', () => {
|
||||
const toml = readFileSync(join(CODE_DIR, 'wrangler.toml'), 'utf8');
|
||||
const out = injectMultiTenant(toml);
|
||||
assert.match(out, /MULTI_TENANT\s*=\s*"false"/);
|
||||
});
|
||||
|
||||
// ── 4. acr parts 清單含 code ─────────────────────────────────────────────────
|
||||
// （parts.ts 內部以 .js 副檔名 import 相鄰模組，node --test 的 type-stripping 不重寫
|
||||
// 副檔名 → 無法直接 import；以原始碼文字驗證清單含 code 條目。tsc 另保證型別正確。）
|
||||
|
||||
test('BUILTIN_COMPONENTS（acr parts 靜態清單）含 code 條目', () => {
|
||||
const src = readFileSync(join(REPO_ROOT, 'cli', 'src', 'commands', 'parts.ts'), 'utf8');
|
||||
assert.match(src, /canonical_id: 'code'/, 'parts.ts BUILTIN_COMPONENTS 應含 code');
|
||||
assert.match(src, /component: code/, 'code 條目應含 config_example（component: code）');
|
||||
});
|
||||
@@ -36,6 +36,11 @@ import type { Bindings, ComponentRunner, ServiceBinding } from '../types';
|
||||
const WASM_HTTP_RUNNER_IDS: ReadonlySet<string> = new Set([
|
||||
// 通用 HTTP 零件
|
||||
'http_request',
|
||||
// 通用 code 零件（sandbox inline JS，Arcrun#10 / 07-thin-shell §3.5 code-node）：獨立 Worker，
|
||||
// URL 走 wasmWorkerUrl 通用推導（arcrun-code.{WORKER_SUBDOMAIN}.workers.dev，
|
||||
// self-hosted 由 WORKER_SUBDOMAIN var 注入自己的 subdomain，無寫死官方域名）。
|
||||
// 漏這行 = workflow 寫 `component: code` 落到 step 8 直接「找不到零件」（#29 發現）。
|
||||
'code',
|
||||
// gmail / telegram / line_notify / google_sheets 已降級為 recipe（2026-05-29 Phase 2）：
|
||||
// recipe:gmail_send / telegram_send / line_notify_send / google_sheets_read|append
|
||||
// 走 step 6 KV recipe 解析，不再是零件。零件目錄已刪。
|
||||
|
||||
@@ -341,6 +341,136 @@ async function triggerNamed(
|
||||
return c.json(result, result.success ? 200 : 500);
|
||||
}
|
||||
|
||||
// ── 同步查詢 trigger（sync query）─────────────────────────────────────────────
|
||||
//
|
||||
// 動機：named webhook 的 /trigger 預設路徑雖已同步（await），但它回傳的是
|
||||
// `{ success, data, trace, duration_ms }` **信封**、且只有 POST 形態。
|
||||
// 查詢面（console / MCP 打 graph neighbors / traverse 之類）需要 request→response
|
||||
// **直接拿「工作流最終節點輸出」** 當 HTTP response body，且常是一個 GET。
|
||||
// 這組端點補上這個泛化：同步 await 執行 workflow graph → 把 **result.data（最終節點輸出）本身**
|
||||
// 當 response body 回（非 202、非信封）。補上它，任何查詢端點都能是一個 workflow。
|
||||
//
|
||||
// 認證：沿用 X-Arcrun-API-Key（header 形態）或 namespace 走 path（公開形態，與 /trigger path 版對稱；
|
||||
// self-hosted namespace 是明碼分區標籤非密碼，故可放 path — mindset §3 arcrun 不做授權判斷）。
|
||||
// 誠實（mindset §7）：節點失敗回錯誤 + trace 摘要（非把錯誤當輸出假綠）；paused 工作流無法同步
|
||||
// 給答案 → 明講（409），不假裝成功。
|
||||
|
||||
// 同步查詢輸出上限（防超大 response body 撐爆 Worker / 呼叫端）。
|
||||
// 超過 → 回 413 + 誠實錯誤（請在 workflow 內先聚合/分頁），不截斷假裝成功。
|
||||
const MAX_QUERY_OUTPUT_BYTES = 5 * 1024 * 1024; // 5 MiB
|
||||
|
||||
// GET：把 query string 全部欄位當 triggerContext（值皆 string）。
|
||||
function queryStringContext(c: Context<{ Bindings: Bindings }>): Record<string, unknown> {
|
||||
return { ...c.req.query() };
|
||||
}
|
||||
|
||||
// POST：body（JSON object）當 triggerContext；非物件 / 無 body → 空 context。
|
||||
async function bodyContext(c: Context<{ Bindings: Bindings }>): Promise<Record<string, unknown>> {
|
||||
const body = await c.req.json().catch(() => null);
|
||||
return body && typeof body === 'object' ? (body as Record<string, unknown>) : {};
|
||||
}
|
||||
|
||||
// 共用同步查詢邏輯（header 路徑與 path 路徑、GET 與 POST 都用，避免分叉）。
|
||||
async function queryNamed(
|
||||
c: Context<{ Bindings: Bindings }>,
|
||||
apiKey: string,
|
||||
name: string,
|
||||
triggerContext: Record<string, unknown>,
|
||||
) {
|
||||
const raw = await c.env.WEBHOOKS.get(kvKey(apiKey, name), 'text');
|
||||
if (!raw) {
|
||||
return c.json({ error: `找不到 workflow "${name}"，請先執行 acr push` }, 404);
|
||||
}
|
||||
|
||||
let record: NamedWorkflowRecord;
|
||||
try {
|
||||
record = JSON.parse(raw) as NamedWorkflowRecord;
|
||||
} catch {
|
||||
return c.json({ error: 'workflow 定義損毀' }, 500);
|
||||
}
|
||||
|
||||
const graph = record.graph as { id?: string; nodes?: unknown[] };
|
||||
const workflowId = graph.id ?? name;
|
||||
const nodes = Array.isArray(graph.nodes) ? (graph.nodes as GraphNode[]) : [];
|
||||
const userAgent = c.req.header('User-Agent') ?? undefined;
|
||||
|
||||
// 同步執行（await，非 waitUntil）：查詢端點必須 request→response 拿到結果。
|
||||
const result = await executeWebhookGraph(
|
||||
c.env,
|
||||
record.graph,
|
||||
triggerContext,
|
||||
name,
|
||||
apiKey,
|
||||
c.executionCtx,
|
||||
userAgent,
|
||||
);
|
||||
|
||||
// 執行判決寫入不阻塞回應（waitUntil，與 /trigger 一致）。
|
||||
c.executionCtx.waitUntil(
|
||||
writeExecutionVerdict(c.env, workflowId, nodes, result.success ? 'success' : 'failed', result.duration_ms, result.error ?? ''),
|
||||
);
|
||||
|
||||
if (!result.success) {
|
||||
// paused（如 claude_api 等外部 callback resume）無法同步給答案 → 明講，不假裝成功。
|
||||
const paused = typeof result.error === 'string' && /workflow paused/i.test(result.error);
|
||||
return c.json(
|
||||
{
|
||||
success: false,
|
||||
error: result.error ?? '工作流執行失敗',
|
||||
trace: result.trace,
|
||||
...(paused
|
||||
? { paused: true, hint: '此工作流會暫停等待非同步 callback，無法當同步查詢端點；改用 /webhooks/named/:name/trigger?async=1 + /workflows/resume。' }
|
||||
: {}),
|
||||
},
|
||||
paused ? 409 : 500,
|
||||
);
|
||||
}
|
||||
|
||||
// 成功 → 回「最終節點輸出」本身當 response body（非 202、非信封）。
|
||||
const serialized = JSON.stringify(result.data ?? null);
|
||||
const byteLen = new TextEncoder().encode(serialized).byteLength;
|
||||
if (byteLen > MAX_QUERY_OUTPUT_BYTES) {
|
||||
return c.json(
|
||||
{
|
||||
success: false,
|
||||
error: `查詢輸出過大（${byteLen} bytes > 上限 ${MAX_QUERY_OUTPUT_BYTES}）。請在 workflow 內先聚合 / 分頁再回。`,
|
||||
},
|
||||
413,
|
||||
);
|
||||
}
|
||||
return new Response(serialized, {
|
||||
status: 200,
|
||||
headers: {
|
||||
'Content-Type': 'application/json; charset=UTF-8',
|
||||
'X-Arcrun-Duration-Ms': String(result.duration_ms),
|
||||
},
|
||||
});
|
||||
}
|
||||
|
||||
// GET /webhooks/named/:name/query — header 認證，input 走 query string（console/MCP 主用）
|
||||
webhooksNamedRouter.get('/webhooks/named/:name/query', async (c) => {
|
||||
const apiKey = c.req.header('X-Arcrun-API-Key');
|
||||
if (!apiKey) return c.json({ error: '缺少 X-Arcrun-API-Key header' }, 401);
|
||||
return queryNamed(c, apiKey, c.req.param('name'), queryStringContext(c));
|
||||
});
|
||||
|
||||
// POST /webhooks/named/:name/query — header 認證，input 走 body
|
||||
webhooksNamedRouter.post('/webhooks/named/:name/query', async (c) => {
|
||||
const apiKey = c.req.header('X-Arcrun-API-Key');
|
||||
if (!apiKey) return c.json({ error: '缺少 X-Arcrun-API-Key header' }, 401);
|
||||
return queryNamed(c, apiKey, c.req.param('name'), await bodyContext(c));
|
||||
});
|
||||
|
||||
// POST /webhooks/named/:ns/:name/query — namespace 走 path（公開查詢，與 /trigger path 版對稱）
|
||||
webhooksNamedRouter.post('/webhooks/named/:ns/:name/query', async (c) => {
|
||||
return queryNamed(c, c.req.param('ns'), c.req.param('name'), await bodyContext(c));
|
||||
});
|
||||
|
||||
// GET /q/:ns/:name — 簡短查詢入口（namespace 走 path，input 走 query string）
|
||||
webhooksNamedRouter.get('/q/:ns/:name', async (c) => {
|
||||
return queryNamed(c, c.req.param('ns'), c.req.param('name'), queryStringContext(c));
|
||||
});
|
||||
|
||||
// GET /webhooks/named — 列出當前 api_key 下所有 workflow
|
||||
webhooksNamedRouter.get('/webhooks/named', async (c) => {
|
||||
const apiKey = c.req.header('X-Arcrun-API-Key');
|
||||
|
||||
@@ -0,0 +1,56 @@
|
||||
/**
|
||||
* component-loader：`code` 零件解析測試（#29 發現的白名單缺口）。
|
||||
*
|
||||
* 背景：workflow 寫 `component: code` 時，component-loader 解析鏈 step 1-6 都不命中
|
||||
* （非 builtin / 非 URL / 非 hash / 非邏輯零件 binding / 非 recipe），必須靠 step 7 的
|
||||
* WASM_HTTP_RUNNER_IDS 白名單 → wasmWorkerUrl 通用推導。白名單漏 `code` 就會落到
|
||||
* step 8 直接丟「找不到零件」——graph_neighbors 等用 code 節點的 workflow 全滅。
|
||||
*
|
||||
* 驗證：
|
||||
* 1. `code` 能被解析成 runner（不 throw）。
|
||||
* 2. runner 打的 URL = arcrun-code.{WORKER_SUBDOMAIN}.workers.dev（通用推導、無寫死
|
||||
* 官方 code.arcrun.dev → self-hosted 換 WORKER_SUBDOMAIN 即落地）。
|
||||
*/
|
||||
import { describe, it, expect, vi, afterEach } from 'vitest';
|
||||
import { env } from 'cloudflare:test';
|
||||
import { createComponentLoader, wasmWorkerUrl } from '../src/lib/component-loader';
|
||||
import type { Bindings } from '../src/types';
|
||||
|
||||
afterEach(() => {
|
||||
vi.unstubAllGlobals();
|
||||
});
|
||||
|
||||
describe('component-loader：code 零件解析（WASM HTTP runner 白名單）', () => {
|
||||
it('wasmWorkerUrl 通用推導：code → arcrun-code.{subdomain}.workers.dev（self-hosted 換 subdomain 即成立）', () => {
|
||||
expect(wasmWorkerUrl('code', 'uncle6-me')).toBe('https://arcrun-code.uncle6-me.workers.dev');
|
||||
expect(wasmWorkerUrl('code', 'my-selfhosted-sub')).toBe('https://arcrun-code.my-selfhosted-sub.workers.dev');
|
||||
});
|
||||
|
||||
it('component: code 能被解析成 runner，且 fetch 打 subdomain 推導的 URL', async () => {
|
||||
const fakeEnv = {
|
||||
...env,
|
||||
WORKER_SUBDOMAIN: 'test-sub',
|
||||
} as unknown as Bindings;
|
||||
|
||||
const loader = createComponentLoader(fakeEnv);
|
||||
// 白名單漏 `code` 時這裡就 throw「找不到零件 "code"」（#29 的故障型態）
|
||||
const runner = await loader('code');
|
||||
expect(typeof runner).toBe('function');
|
||||
|
||||
// stub fetch 捕 URL：證明 runner 打的是通用推導 URL，非寫死官方域名
|
||||
const calledUrls: string[] = [];
|
||||
const fetchSpy = vi.fn(async (url: unknown) => {
|
||||
calledUrls.push(String(url));
|
||||
return new Response(JSON.stringify({ success: true, data: { ok: true } }), {
|
||||
status: 200,
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
});
|
||||
});
|
||||
vi.stubGlobal('fetch', fetchSpy);
|
||||
|
||||
const result = await runner({ code: 'return {ok:true}', input: {} }) as Record<string, unknown>;
|
||||
expect(fetchSpy).toHaveBeenCalledTimes(1);
|
||||
expect(calledUrls[0]).toBe('https://arcrun-code.test-sub.workers.dev');
|
||||
expect(result.success).toBe(true);
|
||||
});
|
||||
});
|
||||
@@ -0,0 +1,132 @@
|
||||
/**
|
||||
* 同步查詢 trigger（sync query）測試 — webhooks-named.ts 的 /query 與 /q/* 端點。
|
||||
*
|
||||
* 驗證重點（對應交辦 Part 1）：
|
||||
* 1. 同步回「最終節點輸出」本身（非 202、非 {success,data,...} 信封）— GET(query string) 與 POST(body) 皆是。
|
||||
* 2. namespace 走 path 的公開形態（/q/:ns/:name、POST /webhooks/named/:ns/:name/query）。
|
||||
* 3. 節點失敗 → 誠實回錯誤 + trace（500），非假綠。
|
||||
* 4. 認證：缺 X-Arcrun-API-Key → 401；workflow 不存在 → 404。
|
||||
*
|
||||
* 用內建零件（comp_uppercase / comp_passthrough，純記憶體、無外部 fetch）當「極簡 workflow」，
|
||||
* 因此本測試就是「Part 1 同步 trigger 機制本身可用」的證據（確實同步回值而非 202）。
|
||||
*/
|
||||
import { describe, it, expect, beforeAll } from 'vitest';
|
||||
import { env, SELF } from 'cloudflare:test';
|
||||
|
||||
const API_KEY = 'test-tenant-query';
|
||||
|
||||
function kvKey(name: string, apiKey = API_KEY): string {
|
||||
return `${apiKey}:wf:${name}`;
|
||||
}
|
||||
|
||||
// 極簡 workflow：單一 comp_uppercase 節點。caller input（text）→ 大寫 → 當最終輸出回。
|
||||
// 無 Input/Output 節點：最終節點輸出即 comp_uppercase 的回傳，乾淨可斷言。
|
||||
const UPPER_WF = {
|
||||
name: 'q_upper',
|
||||
graph: {
|
||||
id: 'q_upper',
|
||||
name: 'sync query upper',
|
||||
nodes: [{ id: 'upper', type: 'Component', componentId: 'comp_uppercase' }],
|
||||
edges: [],
|
||||
},
|
||||
description: '同步查詢：把 text 轉大寫回傳（測試用）',
|
||||
created_at: new Date().toISOString(),
|
||||
};
|
||||
|
||||
// 會失敗的 workflow：引用不存在的零件 → 節點執行失敗。
|
||||
const FAIL_WF = {
|
||||
name: 'q_fail',
|
||||
graph: {
|
||||
id: 'q_fail',
|
||||
name: 'sync query fail',
|
||||
nodes: [{ id: 'boom', type: 'Component', componentId: 'comp_does_not_exist' }],
|
||||
edges: [],
|
||||
},
|
||||
description: '同步查詢：故意引用不存在零件（測試失敗路徑）',
|
||||
created_at: new Date().toISOString(),
|
||||
};
|
||||
|
||||
beforeAll(async () => {
|
||||
await env.WEBHOOKS.put(kvKey(UPPER_WF.name), JSON.stringify(UPPER_WF));
|
||||
await env.WEBHOOKS.put(kvKey(FAIL_WF.name), JSON.stringify(FAIL_WF));
|
||||
});
|
||||
|
||||
describe('同步查詢 trigger — 成功回最終節點輸出（非 202、非信封）', () => {
|
||||
it('POST /webhooks/named/:name/query（header 認證，body input）同步回輸出', async () => {
|
||||
const res = await SELF.fetch('http://localhost/webhooks/named/q_upper/query', {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json', 'X-Arcrun-API-Key': API_KEY },
|
||||
body: JSON.stringify({ text: 'hello' }),
|
||||
});
|
||||
expect(res.status).toBe(200); // 關鍵：非 202
|
||||
const data = await res.json() as Record<string, unknown>;
|
||||
// 回的是「最終節點輸出本身」：頂層直接有 text=HELLO，而非包在 { data: ... } 信封裡
|
||||
expect(data.text).toBe('HELLO');
|
||||
expect(data).not.toHaveProperty('duration_ms'); // 信封欄位不該出現在 body
|
||||
// duration 走 header，不污染輸出
|
||||
expect(res.headers.get('X-Arcrun-Duration-Ms')).not.toBeNull();
|
||||
});
|
||||
|
||||
it('GET /webhooks/named/:name/query（header 認證，query string input）同步回輸出', async () => {
|
||||
const res = await SELF.fetch('http://localhost/webhooks/named/q_upper/query?text=world', {
|
||||
headers: { 'X-Arcrun-API-Key': API_KEY },
|
||||
});
|
||||
expect(res.status).toBe(200);
|
||||
const data = await res.json() as Record<string, unknown>;
|
||||
expect(data.text).toBe('WORLD');
|
||||
});
|
||||
|
||||
it('GET /q/:ns/:name（namespace 走 path，query string input）同步回輸出', async () => {
|
||||
const res = await SELF.fetch(`http://localhost/q/${API_KEY}/q_upper?text=abc`);
|
||||
expect(res.status).toBe(200);
|
||||
const data = await res.json() as Record<string, unknown>;
|
||||
expect(data.text).toBe('ABC');
|
||||
});
|
||||
|
||||
it('POST /webhooks/named/:ns/:name/query（namespace 走 path，body input）同步回輸出', async () => {
|
||||
const res = await SELF.fetch(`http://localhost/webhooks/named/${API_KEY}/q_upper/query`, {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
body: JSON.stringify({ text: 'path' }),
|
||||
});
|
||||
expect(res.status).toBe(200);
|
||||
const data = await res.json() as Record<string, unknown>;
|
||||
expect(data.text).toBe('PATH');
|
||||
});
|
||||
});
|
||||
|
||||
describe('同步查詢 trigger — 誠實錯誤（不假綠）', () => {
|
||||
it('節點失敗 → 500 + error + trace（非把錯誤當輸出）', async () => {
|
||||
const res = await SELF.fetch('http://localhost/webhooks/named/q_fail/query', {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json', 'X-Arcrun-API-Key': API_KEY },
|
||||
body: JSON.stringify({}),
|
||||
});
|
||||
expect(res.status).toBe(500);
|
||||
const data = await res.json() as { success: boolean; error: string; trace: unknown };
|
||||
expect(data.success).toBe(false);
|
||||
expect(typeof data.error).toBe('string');
|
||||
expect(data.error.length).toBeGreaterThan(0);
|
||||
expect(data.trace).toBeDefined();
|
||||
});
|
||||
});
|
||||
|
||||
describe('同步查詢 trigger — 認證與存在性', () => {
|
||||
it('缺 X-Arcrun-API-Key（header 形態）→ 401', async () => {
|
||||
const res = await SELF.fetch('http://localhost/webhooks/named/q_upper/query', {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
body: JSON.stringify({ text: 'x' }),
|
||||
});
|
||||
expect(res.status).toBe(401);
|
||||
});
|
||||
|
||||
it('workflow 不存在 → 404', async () => {
|
||||
const res = await SELF.fetch('http://localhost/webhooks/named/no_such_wf/query', {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json', 'X-Arcrun-API-Key': API_KEY },
|
||||
body: JSON.stringify({}),
|
||||
});
|
||||
expect(res.status).toBe(404);
|
||||
});
|
||||
});
|
||||
BIN
Binary file not shown.
@@ -29,6 +29,7 @@
|
||||
| `daily-digest` | cron → 多源聚合（KBDB / RSS / 等） → 推送 |
|
||||
| `parallel-fanout` | 一份輸入分發多 workflow 並行處理 |
|
||||
| `error-retry` | try_catch + wait + retry 重試外部 API |
|
||||
| `graph-neighbors` | 同步查詢：撈 KBDB triplet → 記憶體 BFS 找 N 跳鄰居（查詢面工作流，走同步查詢 trigger） |
|
||||
|
||||
## 如何用（AI 視角）
|
||||
|
||||
|
||||
@@ -0,0 +1,67 @@
|
||||
# graph-neighbors
|
||||
|
||||
## 解決什麼問題
|
||||
把 graph plugin 內建的 `GET /graph/neighbors`（同步 request→response 拿鄰居）**改寫成一條 workflow**。
|
||||
示範「查詢面工作流」：查詢端點不必是框架寫死的 route，可以是一條 `workflow.yaml` —— 撈 triplet
|
||||
記錄 → 記憶體 BFS → 同步回鄰居。任何唯讀查詢都能這樣泛化成 workflow。
|
||||
|
||||
## 依賴的框架能力（本 PR 補上的）
|
||||
**同步查詢 trigger**（cypher-executor `webhooks-named.ts`）：現有 named webhook 的 `/trigger`
|
||||
回的是 `{success,data,trace,duration_ms}` 信封、且只有 POST。查詢面要 **GET + 直接拿最終節點輸出**。
|
||||
新端點同步 `await` 執行 graph → 把 `result.data`（最終節點輸出）本身當 response body 回（非 202）：
|
||||
- `GET /q/:ns/:name`（namespace 走 path，input 走 query string）
|
||||
- `GET /webhooks/named/:name/query`（X-Arcrun-API-Key header，input 走 query string）
|
||||
- `POST /webhooks/named/:name/query`（header，input 走 body）
|
||||
- `POST /webhooks/named/:ns/:name/query`（namespace 走 path，input 走 body）
|
||||
|
||||
## 怎麼觸發
|
||||
```bash
|
||||
# GET（最像原本的 /graph/neighbors）——{你的-cypher-domain}/{你的-kbdb-domain} 換成自己的部署
|
||||
curl "https://{你的-cypher-domain}/q/{namespace}/graph_neighbors?node=Arcrun&depth=2&template=graph_triplet&namespace={namespace}&kbdb_base=https://{你的-kbdb-domain}"
|
||||
|
||||
# POST（header 認證）
|
||||
curl -X POST https://{你的-cypher-domain}/webhooks/named/graph_neighbors/query \
|
||||
-H "X-Arcrun-API-Key: {namespace}" \
|
||||
-d '{"node":"Arcrun","depth":2,"template":"graph_triplet","namespace":"{namespace}","kbdb_base":"https://{你的-kbdb-domain}"}'
|
||||
```
|
||||
|
||||
> ⚠️ **敏感輸入請用 `POST /query`**：`GET /q/` 的參數走 query string，會進 CF / proxy / access log
|
||||
> 各層日誌；node 名、namespace 等若屬敏感，改走 POST body。
|
||||
回傳（最終節點輸出本身，非信封）：
|
||||
```json
|
||||
{ "success": true, "start": "Arcrun", "depth": 2, "directed": false,
|
||||
"neighbors": [ { "node": "cypher-executor", "predicate": "包含", "from": "Arcrun", "depth": 1 } ],
|
||||
"count": 1 }
|
||||
```
|
||||
|
||||
## 參數
|
||||
- `node`（必填）：BFS 起點節點名
|
||||
- `depth`（預設 1）：最大跳數
|
||||
- `template`（必填）：triplet 記錄的 base template id（⚠️ 以實際部署的 kbdb-graph-plugin triplet template 為準）
|
||||
- `namespace`（必填）：租戶 owner_id（self-hosted 明碼 namespace）
|
||||
- `kbdb_base`（必填）：**你自己的 KBDB base URL**（如 `https://kbdb.example.com`）。
|
||||
workflow 不寫死任何一家的庫——抄示範時帶錯（或照抄別人的值）＝查詢與資料流向直接打進別人的庫
|
||||
（KBDB_BASE_URL fallback 同家族坑，勿重蹈）。
|
||||
- `directed`（預設 false）：`true` 只走 subject→object；否則把 triplet 當雙向邊（無向鄰居）
|
||||
|
||||
## kbdb_base 該帶哪種 URL（1042）
|
||||
cypher-executor 對 kbdb 發 fetch，若打同 zone URL 會踩 CF 1042（same-zone self-fetch）。兩條路皆可：
|
||||
1. 帶 KBDB 的 **custom domain**（跨 zone、走公網前門，天然避開 1042）；
|
||||
2. self-hosted 有 **`global_fetch_strictly_public`** compatibility flag（credential-primitives-wasm
|
||||
Phase 7，cypher wrangler.toml），開了之後 **workers.dev URL 亦可**直接帶。
|
||||
|
||||
## ⚠️ 尚未 live 驗（待辦）
|
||||
- **`code` 零件尚未部署到 leo21c**（另線處理）→ 本工作流無法端到端 live 跑。
|
||||
workflow.yaml 已寫好放這裡待驗。
|
||||
- **同步查詢 trigger 本身已驗**：`cypher-executor/tests/query-trigger.test.ts`（7 測）用內建零件
|
||||
（comp_uppercase，純記憶體、無外部 fetch）證明「確實同步回最終節點輸出而非 202」。
|
||||
- 上線前另需對一次實際 triplet template id（本檔用 `{{input.template}}` 參數化，未寫死）。
|
||||
|
||||
## 對照
|
||||
記憶體 BFS 對照 `kbdb-graph-plugin` 的 `graph-traverse.ts:23-51`：triplet 當有向邊
|
||||
`subject --predicate--> object`，從起點逐跳擴張到 depth 上限，收集首次訪到的節點當鄰居。
|
||||
|
||||
## 學到什麼
|
||||
- 查詢端點可以是 workflow，不必是框架寫死的 route（同步查詢 trigger 讓這件事成立）
|
||||
- `code` 零件（sandbox inline JS）承載「非 call-api 的純計算」（BFS），不必為此鑄 domain 零件
|
||||
- 單一 `{{ref}}` pass-through 保留陣列型別 → `{{fetch_triplets.data.records}}` 拿到真陣列餵給 code
|
||||
@@ -0,0 +1 @@
|
||||
["graph", "triplet", "bfs", "neighbors", "kbdb", "sync-query", "query-endpoint", "code-node", "common-pattern"]
|
||||
@@ -0,0 +1,124 @@
|
||||
name: graph_neighbors
|
||||
description: >
|
||||
同步查詢：給一個節點 → 從 KBDB triplet 記錄建鄰接表 → 記憶體 BFS 找 N 跳鄰居 → 同步回鄰居清單。
|
||||
這是「查詢面工作流」示範：用同步查詢 trigger（GET /q/:ns/graph_neighbors 或
|
||||
POST /webhooks/named/:name/query），把 workflow 最終節點輸出直接當 HTTP response 拿回，
|
||||
取代 graph plugin 內建的 GET /graph/neighbors。對照 kbdb-graph-plugin graph-traverse.ts 的記憶體 BFS。
|
||||
|
||||
# ══════════════════════════════════════════════════════════════════════════════
|
||||
# ⚠️ 先改成你自己的 KBDB URL（self-hosted 必看）
|
||||
# fetch_triplets 的 base URL 走 {{input.kbdb_base}} 參數（每次呼叫帶），**沒有寫死官方庫**。
|
||||
# 照抄本示範時，把觸發參數 kbdb_base 換成你自己部署的 KBDB 對外 URL——
|
||||
# 抄了別人的值＝你的查詢與資料流向直接打進別人的庫（KBDB_BASE_URL fallback 同家族坑）。
|
||||
# ══════════════════════════════════════════════════════════════════════════════
|
||||
|
||||
# ── 1042 與 kbdb_base 該帶哪種 URL ──
|
||||
# cypher-executor 執行 http_request 節點時對 kbdb 發 fetch。若打同 zone URL 會踩 CF 1042
|
||||
# （same-zone self-fetch）。兩條路皆可：
|
||||
# a) 帶 KBDB 的 custom domain（跨 zone、走公網前門，天然避開 1042）；
|
||||
# b) self-hosted 有 `global_fetch_strictly_public` compatibility flag
|
||||
# （credential-primitives-wasm Phase 7，cypher wrangler.toml），開了之後
|
||||
# workers.dev URL 亦可直接帶。
|
||||
|
||||
# ── 觸發（同步查詢 trigger，非 202）──
|
||||
# GET https://{你的-cypher-domain}/q/{namespace}/graph_neighbors?node=Arcrun&depth=2&template=graph_triplet&namespace={namespace}&kbdb_base=https://{你的-kbdb-domain}
|
||||
# POST https://{你的-cypher-domain}/webhooks/named/graph_neighbors/query
|
||||
# -H "X-Arcrun-API-Key: {namespace}"
|
||||
# -d '{"node":"Arcrun","depth":2,"template":"graph_triplet","namespace":"{namespace}","kbdb_base":"https://{你的-kbdb-domain}"}'
|
||||
# → 直接回 { success, start, depth, directed, neighbors:[...], count }（最終節點輸出本身）。
|
||||
# （敏感輸入用 POST /query：GET /q/ 的 query string 會進各層 log，見 description.md。）
|
||||
|
||||
flow:
|
||||
- "input >> ON_SUCCESS >> fetch_triplets"
|
||||
- "fetch_triplets >> ON_SUCCESS >> bfs_neighbors"
|
||||
|
||||
config:
|
||||
# 1) 撈本租戶的 triplet 記錄。triplet = base 萬用表的一個 template（graph plugin 寫入），
|
||||
# slots = subject / predicate / object。base 端點：GET /records/by-template/:template?owner_id=
|
||||
# 回 { success, records:[{ record_id, values:{subject,predicate,object} }], count }。
|
||||
# ⚠️ template 名（此處 {{input.template}}，預設由呼叫者帶 graph_triplet）以實際部署的
|
||||
# kbdb-graph-plugin triplet template id 為準——上線前對一次。
|
||||
# ⚠️ base URL 由呼叫者帶（{{input.kbdb_base}}）——不寫死任何一家的庫（見檔頂警示）。
|
||||
fetch_triplets:
|
||||
component: http_request
|
||||
method: GET
|
||||
url: "{{input.kbdb_base}}/records/by-template/{{input.template}}?owner_id={{input.namespace}}"
|
||||
headers:
|
||||
Accept: "application/json"
|
||||
|
||||
# 2) ★ 記憶體 BFS（通用 code 零件，sandbox inline JS，無 LLM、無 fs/網路，stdin→stdout JSON）。
|
||||
# 對照 kbdb-graph-plugin graph-traverse.ts:23-51 的記憶體 BFS：把 triplet 當有向邊
|
||||
# subject --predicate--> object 建鄰接表，從 start 逐跳擴張到 depth 上限，收集新訪節點當鄰居。
|
||||
# directed=false（預設）時把邊當雙向（無向圖鄰居）；directed=true 只走 subject→object。
|
||||
bfs_neighbors:
|
||||
component: code
|
||||
code: |
|
||||
// graph_neighbors — 記憶體 BFS 找 N 跳鄰居（純函式、決定性、零 token）。
|
||||
// input（由下方 input: 映射解析後注入）：
|
||||
// records[] : triplet 記錄（{ values:{subject,predicate,object} } 或扁平 {subject,predicate,object}）
|
||||
// start : 起點節點名（字串）
|
||||
// depth : 最大跳數（字串或數字，來自 query string 時是字串）
|
||||
// directed : "true" 只走 subject→object；否則當無向
|
||||
|
||||
const records = Array.isArray(input.records) ? input.records : [];
|
||||
const start = String(input.start == null ? '' : input.start);
|
||||
const maxDepth = Math.max(1, parseInt(String(input.depth == null ? 1 : input.depth), 10) || 1);
|
||||
const directed = String(input.directed == null ? '' : input.directed) === 'true';
|
||||
|
||||
if (!start) {
|
||||
return { success: false, error: 'graph_neighbors 缺 start（node）參數' };
|
||||
}
|
||||
|
||||
// 建鄰接表：subject --predicate--> object。無向時同時加反向邊。
|
||||
const adj = new Map();
|
||||
function addEdge(from, to, predicate) {
|
||||
if (!adj.has(from)) adj.set(from, []);
|
||||
adj.get(from).push({ node: to, predicate: predicate });
|
||||
}
|
||||
for (const r of records) {
|
||||
const v = (r && typeof r === 'object' && r.values && typeof r.values === 'object') ? r.values : r;
|
||||
if (!v || typeof v !== 'object') continue;
|
||||
const s = v.subject, p = v.predicate, o = v.object;
|
||||
if (!s || !o) continue;
|
||||
addEdge(s, o, p);
|
||||
if (!directed) addEdge(o, s, p);
|
||||
}
|
||||
|
||||
// BFS：一層一跳，收集首次訪到的節點當鄰居（記 depth / 來源 / 關係）。
|
||||
const visited = new Set([start]);
|
||||
let frontier = [start];
|
||||
const neighbors = [];
|
||||
for (let d = 1; d <= maxDepth; d++) {
|
||||
const next = [];
|
||||
for (const cur of frontier) {
|
||||
const outs = adj.get(cur) || [];
|
||||
for (const e of outs) {
|
||||
if (visited.has(e.node)) continue;
|
||||
visited.add(e.node);
|
||||
neighbors.push({ node: e.node, predicate: e.predicate, from: cur, depth: d });
|
||||
next.push(e.node);
|
||||
}
|
||||
}
|
||||
frontier = next;
|
||||
if (frontier.length === 0) break;
|
||||
}
|
||||
|
||||
return {
|
||||
success: true,
|
||||
start: start,
|
||||
depth: maxDepth,
|
||||
directed: directed,
|
||||
neighbors: neighbors,
|
||||
count: neighbors.length,
|
||||
};
|
||||
# input 映射：{{...}} 對 workflow context 展開後注入 code 沙箱的 `input` 變數。
|
||||
# {{input.X}} 的 input = 上游 input 節點輸出（＝觸發 context）；{{fetch_triplets.data.records}}
|
||||
# = http_request 回應 body 的 records 陣列（單一 ref pass-through 保留陣列型別）。
|
||||
input:
|
||||
records: "{{fetch_triplets.data.records}}"
|
||||
start: "{{input.node}}"
|
||||
depth: "{{input.depth}}"
|
||||
directed: "{{input.directed}}"
|
||||
limits:
|
||||
timeout_ms: 3000 # 純 CPU BFS，充裕
|
||||
max_output_bytes: 2097152 # 鄰居清單上限 2 MiB（呼叫端同步查詢輸出也有 5 MiB 硬上限）
|
||||
Reference in New Issue
Block a user