uncle6me-web
6a75117ba3
kbdb-base SDD §7.5（公庫/私庫雙向機制，richblack 2026-06-07 拍板）。
## KBDB Base worker（新）
- kbdb/：D1-only 核心三表（entries/templates/entry_values）+ CRUD + LIKE search
+ recipe-stats 端點（市場數據）+ 0001_base.sql migration（含 recipe_stat seed）
## Phase 2.3：init 建 D1 + 套 migration
- cli cf-api.ts 加 listD1Databases/ensureD1Database；init 建 arcrun-kbdb D1
- deploy.ts 部署後對 D1 套 0001_base.sql（CF /d1/query API，idempotent）+ 注入 database_id
## Phase 5.1：recipe 成功記錄（市場數據來源）
- GraphExecutor 收集本次用到的 recipe uuid（usedRecipeKeys）
- executeWebhookGraph 執行結束一次性記 per-uuid 成功/失敗到 KBDB（fire-and-forget）
## Phase 7.5：recipe UUID 身份 + app-store 模型
- recipe 領 uuid=唯一身份；canonical_id/author/公私=屬性（§7.5.5）
- recipe:{uuid} + idx:canonical/installed/hash；resolveRecipe 向後相容不破執行鏈
- POST /recipes/submit=領新 uuid 新增作者版本（非覆蓋，app-store）
- GET /public-recipes 搜尋（多作者+per-uuid 市場星數）/ :id pull（選市場最佳）
- 落空→found:false 創作引導（§7.5.6 閉環）
- POST /recipes/migrate-uuid 一次性轉舊 key（增量寫不刪舊、冪等）
- init-seed 用 UUID（author=system）
## 薄殼（rule 07 §5：CLI + MCP 覆蓋同組能力）
- CLI: acr recipe search/pull/submit-p（config 加 DEFAULT_PUBLIC_LIBRARY_URL）
- MCP: arcrun_recipe_search/pull/submit_p/push/list/delete（補齊漂移）
## 壓測修正
- api-recipe-seeds: google_sheets_append PUT→POST（:append 正確動詞，階段12）
四 worker tsc 全綠（cypher/cli/kbdb/mcp）。
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
64 lines
2.4 KiB
TypeScript
64 lines
2.4 KiB
TypeScript
// Recipe success/failure records (SDD section 7.1). Stored as an entry per recipe canonical_id.
|
|
// This is the "fuel" for submission-with-proof: real 2xx counts beat self-written tests.
|
|
import type { Bindings } from '../types';
|
|
|
|
interface RecipeStat {
|
|
canonical_id: string;
|
|
success_count: number;
|
|
failure_count: number;
|
|
last_status: string | null;
|
|
last_at: number | null;
|
|
}
|
|
|
|
// One entry per recipe: id = recipestat:{canonical_id}, entry_type='recipe_stat',
|
|
// counters live in metadata_json. Atomic upsert via D1.
|
|
function statId(canonicalId: string): string {
|
|
return `recipestat:${canonicalId}`;
|
|
}
|
|
|
|
export async function recordRecipeResult(db: D1Database, canonicalId: string, ok: boolean, nowMs: number): Promise<RecipeStat> {
|
|
const id = statId(canonicalId);
|
|
const existing = await db.prepare('SELECT metadata_json FROM entries WHERE id = ?').bind(id).first<{ metadata_json: string | null }>();
|
|
|
|
let stat: RecipeStat;
|
|
if (existing) {
|
|
const prev = existing.metadata_json ? (JSON.parse(existing.metadata_json) as RecipeStat) : emptyStat(canonicalId);
|
|
stat = {
|
|
canonical_id: canonicalId,
|
|
success_count: prev.success_count + (ok ? 1 : 0),
|
|
failure_count: prev.failure_count + (ok ? 0 : 1),
|
|
last_status: ok ? 'success' : 'failure',
|
|
last_at: nowMs,
|
|
};
|
|
await db
|
|
.prepare('UPDATE entries SET metadata_json = ?, updated_at = unixepoch() WHERE id = ?')
|
|
.bind(JSON.stringify(stat), id)
|
|
.run();
|
|
} else {
|
|
stat = {
|
|
canonical_id: canonicalId,
|
|
success_count: ok ? 1 : 0,
|
|
failure_count: ok ? 0 : 1,
|
|
last_status: ok ? 'success' : 'failure',
|
|
last_at: nowMs,
|
|
};
|
|
await db
|
|
.prepare('INSERT INTO entries (id, content, entry_type, metadata_json) VALUES (?, ?, ?, ?)')
|
|
.bind(id, canonicalId, 'recipe_stat', JSON.stringify(stat))
|
|
.run();
|
|
}
|
|
return stat;
|
|
}
|
|
|
|
export async function getRecipeStat(db: D1Database, canonicalId: string): Promise<RecipeStat> {
|
|
const row = await db.prepare('SELECT metadata_json FROM entries WHERE id = ?').bind(statId(canonicalId)).first<{ metadata_json: string | null }>();
|
|
if (!row || !row.metadata_json) return emptyStat(canonicalId);
|
|
return JSON.parse(row.metadata_json) as RecipeStat;
|
|
}
|
|
|
|
function emptyStat(canonicalId: string): RecipeStat {
|
|
return { canonical_id: canonicalId, success_count: 0, failure_count: 0, last_status: null, last_at: null };
|
|
}
|
|
|
|
export type { RecipeStat };
|