Claude
5fc7277c3c
零 u6u 洩漏（leo 要求 1）：connector tool 清單只剩 arcrun_*，並移除壞掉/
重複的 u6u_ workflow tool（deploy/execute/get/list_workflows 由 arcrun_
push/run/get/list_workflows 取代）；MCP server name 也由 u6u-mcp-server
改 arcrun-mcp-server。
前綴單一真相源（leo 要求 2）：新增 mcp/src/brand.ts（TOOL_PREFIX + toolName()
helper），所有 server.tool() 註冊一律走 toolName("suffix")，前綴不再明碼散寫。
未來 rebrand 只改 brand.ts 一行。
- 12 個獨有能力 tool rename（component/tag/gui/search_workflows）
- 4 個重複/壞掉 tool 移除
- inter-tool hint、描述字串、註解內 u6u_ 名字全數更新
- tsc exit 0；vitest 19/19 綠
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_015d5jDbuqT5Htwv3Q88XXKk
41 lines
2.3 KiB
TypeScript
41 lines
2.3 KiB
TypeScript
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
|
|
import { toolName } from "../brand.js";
|
|
import { z } from "zod";
|
|
import { Env } from "../types.js";
|
|
import { kbdbFetch } from "../lib/kbdb-client.js";
|
|
|
|
export function registerListComponents(server: McpServer, env: Env, orgNamespace: string) {
|
|
server.tool(
|
|
toolName("list_components"),
|
|
"列出當前命名空間下所有已發佈的零件，可選擇按 tag 篩選。",
|
|
{ tag: z.string().optional().describe("按 tag 名稱篩選（選填）") },
|
|
async ({ tag }) => {
|
|
try {
|
|
if (!env.KBDB) {
|
|
return { content: [{ type: "text", text: "Error: KBDB service binding unavailable" }], isError: true };
|
|
}
|
|
let componentIds: string[] | null = null;
|
|
if (tag) {
|
|
const tagResp = await kbdbFetch(env, `/records/search?template=resource_tag&user_id=${encodeURIComponent(orgNamespace)}&tag_name=${encodeURIComponent(tag)}&resource_type=component`);
|
|
if (!tagResp.ok) {
|
|
return { content: [{ type: "text", text: `Error querying tags: ${await tagResp.text()}` }], isError: true };
|
|
}
|
|
const tagData = await tagResp.json<{ records: Array<{ slots: { resource_id: string } }> }>();
|
|
componentIds = tagData.records.map(r => r.slots.resource_id);
|
|
if (componentIds.length === 0) return { content: [{ type: "text", text: JSON.stringify([], null, 2) }] };
|
|
}
|
|
const resp = await kbdbFetch(env, `/records/search?template=component_metadata&user_id=${encodeURIComponent(orgNamespace)}`);
|
|
if (!resp.ok) {
|
|
return { content: [{ type: "text", text: `Error querying components: ${await resp.text()}` }], isError: true };
|
|
}
|
|
const data = await resp.json<{ records: Array<{ slots: { component_id: string; name: string; published_at: string; org_namespace: string } }> }>();
|
|
let components = data.records.map(r => r.slots);
|
|
if (componentIds !== null) components = components.filter(c => componentIds!.includes(c.component_id));
|
|
return { content: [{ type: "text", text: JSON.stringify(components, null, 2) }] };
|
|
} catch (error) {
|
|
return { content: [{ type: "text", text: `Internal Error: ${error instanceof Error ? error.message : String(error)}` }], isError: true };
|
|
}
|
|
}
|
|
);
|
|
}
|