三面拆分⑫:设计台九区一级目录 —— 一区一内容,测试台收成单例仿真

设计中心从「蓝图 + 四库」摊成九区,顺序即设计的次序:
蓝图 → 触发器 → 流程包 → 活动库 → 工具箱 → 数据域 → 知识库 → 大模型 → 测试台。
触发器与大模型从「并进流程包 / 塞在系统区」里拿出来独立成区 —— 前者与流程包平级
(不入包结构、不随包版本),后者是设计者天天要碰的东西;知识库先立个诚实的空占位。

一区一内容,于是区内页签栏整条删掉(壳层在只剩一格时收起):
  · 流程包:总览的三枚计数并进货架顶端
  · 测试台:入站邮件演练移到触发器区就地验(它验的正是那一区定的规则)
  · 大模型:从系统区拆出,系统区只剩通道实例

测试台一次只跑一条流。起单前先销毁上一单,刷新页面能认回在跑的那一单,
「停止仿真」把工作流连同它派出的任务、工单、实例、留痕一并拔掉 ——
不留半单挂在别人工作台上。实测:起单 → 1 单落到 AI 工作台 → 停止 → 库里零残留。

功能工具补中文名(migration 0018,读回退到逻辑名),治理台一律主显示中文名。
顺带清掉几处说教式文案(「这些是工具,不是模型 —— 模型是它们跑在上面的发动机…」那类)。

五闸:typecheck / lint / depcruise / test 绿;api:check 快照随本提交入库。

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01KeDBx2PHLavbURXB8LJJ7m

apps/api/src/app/routes/governance-ops.ts

@@ -4,6 +4,7 @@
  * 「治理台九功能**不设**后端 governance 模块:每个功能是对应模块的管理用例 + 路由组装。」
  * 「治理动作本身留痕入事件流 —— 治理也被治理。」
  */
+import { sql } from 'drizzle-orm';
 import type { Hono } from 'hono';
 import type { ApiError, GovernanceFunction, GrantAction } from '@contracts';
 import {
@@ -25,7 +26,9 @@ import {
   listTriggersRoute,
   registerToolRoute,
   saveProcessRoute,
+  testCurrentRoute,
   testRunRoute,
+  testStopRoute,
   traceOfWorkflowRoute,
   setProcessStateRoute,
   reassignTaskRoute,
@@ -42,6 +45,53 @@ import { NotClosedError, PinnedVersionError, StaleVersionError } from '@modules/
 import type { Container } from '../container.ts';
 import type { AppEnv } from '../http-env.ts';
 
+/** `db.execute` 的行读取 —— Drizzle 的返回型随驱动变,窄化收在这一处 */
+function rowsOf<T>(result: unknown): T[] {
+  const bag = result as { rows?: T[] } | T[];
+  return Array.isArray(bag) ? bag : (bag.rows ?? []);
+}
+
+/**
+ * 销毁仿真单 —— 把测试台起的那一条(或指定的一条)**连根拔掉**。
+ *
+ * 顺序按外键的反方向来:先拆挂在任务上的东西(工单、卡、记忆、运行时、意向、监听),
+ * 再拆任务与节点实例,最后拆工作流本身;trace 与事件按工作流清。
+ * 用 `source->>'ref' = 'testbed'` 认门:**只动测试台自己起的单**,
+ * 生产单一个字都不碰(它们的来源是触发器或纪要登记)。
+ */
+async function destroySimulations(container: Container, workflowId?: string): Promise<number> {
+  const scope = workflowId === undefined ? sql`` : sql` and id = ${workflowId}`;
+  const wfs = await container.db.execute<{ id: string }>(
+    sql`select id from sys.workflow where source->>'ref' = 'testbed'${scope}`,
+  );
+  const ids = rowsOf<{ id: string }>(wfs).map((r) => r.id);
+  if (ids.length === 0) return 0;
+
+  let taskCount = 0;
+  for (const id of ids) {
+    const tasks = await container.db.execute<{ id: string }>(sql`select id from sys.task where workflow_id = ${id}`);
+    const taskIds = rowsOf<{ id: string }>(tasks).map((r) => r.id);
+    taskCount += taskIds.length;
+    for (const taskId of taskIds) {
+      await container.db.execute(sql`delete from sys.work_order where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.chat_card where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.chat_message where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.task_memory where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.task_memory_seal where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.task_view where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.flow_state where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.loop_state where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.action_intent where task_id = ${taskId}`);
+      await container.db.execute(sql`delete from sys.listener where task_id = ${taskId}`);
+    }
+    await container.db.execute(sql`delete from sys.task where workflow_id = ${id}`);
+    await container.db.execute(sql`delete from sys.node_instance where workflow_id = ${id}`);
+    await container.db.execute(sql`delete from sys.trace_span where workflow_id = ${id}`);
+    await container.db.execute(sql`delete from sys.workflow where id = ${id}`);
+  }
+  return taskCount;
+}
+
 export function registerGovernanceOpsRoutes(app: Hono<AppEnv>, container: Container): void {
   /**
    * 岗位授权:客体 = 治理功能,动作按路由分级 —— **看是 `read`,动才是 `govern`**。
@@ -230,6 +280,8 @@ export function registerGovernanceOpsRoutes(app: Hono<AppEnv>, container: Contai
       return c.json(body, 400);
     }
     const me = await container.org.findByAccount(c.get('account'));
+    // **一次只跑一条**:再起一单就先把上一单连根拔掉 —— 仿真台上不留过夜的东西
+    await destroySimulations(container);
     try {
       const record = await container.process.start({
         packageId: parsed.data.packageId,
@@ -247,6 +299,33 @@ export function registerGovernanceOpsRoutes(app: Hono<AppEnv>, container: Contai
     }
   });
 
+  /**
+   * 停止仿真 —— **连根拔掉**:工作流、活动任务、工单、节点实例、trace 一并销毁。
+   * 仿真不是生产:试跑留下的任务不该在别人工作台上过夜,也不该混进在途口径。
+   */
+  app.post(testStopRoute.path, async (c) => {
+    const denied = await governProcess(c.get('account'));
+    if (denied) return c.json(denied, denyStatus(denied));
+    const parsed = testStopRoute.body.safeParse(await c.req.json());
+    if (!parsed.success) {
+      const body: ApiError = { code: 'validation-failed', message: '停止仿真入参不合协议' };
+      return c.json(body, 400);
+    }
+    const tasks = await destroySimulations(container, parsed.data.workflowId);
+    return c.json({ destroyed: true, tasks });
+  });
+
+  /** 当前在跑的仿真 —— 刷新页面也认得回来(测试台一次只跑一条) */
+  app.get(testCurrentRoute.path, async (c) => {
+    const denied = await governProcess(c.get('account'));
+    if (denied) return c.json(denied, denyStatus(denied));
+    const rows = await container.db.execute<{ id: string; subject: string }>(
+      sql`select id, subject from sys.workflow where source->>'ref' = 'testbed' order by started_at desc limit 1`,
+    );
+    const hit = rowsOf<{ id: string; subject: string }>(rows)[0];
+    return c.json(hit === undefined ? {} : { workflowId: hit.id, subject: hit.subject });
+  });
+
   /** 全链 Trace:一条工作流的 span 树 —— 节点 → 步骤 / 工具 / 模型 / 人卡 */
   app.get(traceOfWorkflowRoute.path, async (c) => {
     const denied = await governProcess(c.get('account'));
@@ -545,7 +624,8 @@ export function registerGovernanceOpsRoutes(app: Hono<AppEnv>, container: Contai
     }
     const { contract, samples, connectionValues } = parsed.data;
     const verdict = await container.toolbox.register({
-      contract,
+      // 没给中文名就以逻辑名兜底 —— 主名不能空
+      contract: { ...contract, displayName: contract.displayName ?? contract.name },
       // 期望形状统一按「出参是个对象」收:细的形状由契约 output schema 自己说
       samples: samples.map((s) => ({ input: s.input, expectShape: { type: 'object' } })),
       ...(connectionValues === undefined ? {} : { connectionValues }),
@@ -563,6 +643,7 @@ export function registerGovernanceOpsRoutes(app: Hono<AppEnv>, container: Contai
     const tools = await container.toolbox.list();
     return c.json({
       tools: tools.map((t) => ({
+        displayName: t.displayName,
         name: t.name,
         version: t.version,
         description: t.description,