流程包去掉发布机制 —— 严格检查 + 保存即生效,生效由运行时决定

用户要的是运行时机制:新建 + 编辑,存下去就生效,旧任务走完旧版本, 新任务调用时才加载新编排。所以「草稿 → 发布」两态整套去掉。 ## 闸从「发布」挪到「保存」 `savePackage` 现在先跑闭合校验,不闭合抛 `NotClosedError`(路由 412 带报告)—— **一个字节都不落库**。存进来的每一版都能起单,所以不需要「已发布」这个标记。 `publish` 用例、路由、`publishPackage` 存储方法一并删掉。实测:把进 A6 的边映射清空后保存 → 412,逐条点名「边 e-g3-a6 未完成载荷映射; 节点「报价议价」的必填字段未映射:rows」。 ## 保存恒新增版本号,服务端说了算这不是可选项,是「旧任务走完旧版本」的前提:工作流按 (包id, 版本) 去读定义, 就地覆盖 v1 就等于改掉所有在途 v1 任务正在读的编排 —— 它们会中途换了规则却毫不知情。版本号由用例层算(当前最大 + 1),**不采信入参**。实测:入参故意填 version: 999, 落的是 v2。store 层因此改成**只插不改**:撞键宁可让唯一约束报错,也不静默覆盖。起单取版从「最新已发布」改为「最新一版」(retired 除外);触发器的 requiredInputs 同口径。实测:改完描述存成 v2 后,新起的单用 v2,早先那单仍挂 v1。 ## 迁移:旧状态值不归一就是一读就炸状态枚举从 draft/published/retired 收成 active/retired。列上和 definition 这个 jsonb 里各存着一份 state,两处都要改 —— 不改,`processPackageSchema.parse` 读一行就抛。这不是开发期小麻烦,任何已部署实例都会中招。加了迁移 0012。 ## 界面:恒为 0 的假指标撤掉,不换个说法留着 - 编排面板:「已发布/草稿」芯片 → 「生效中/历史版本」(真正的区别是哪一版会被新起单取到); 发布按钮撤掉,保存按钮改成「保存并生效(存为 vN)」并在确认卡里说清影响面 - 历史版本只读,但就地指路:「去 v(N-1) 改(生效中)」,不让人自己找 - 蓝图面:「草稿 N · 未闭合 M」两个计数在新机制下**结构上恒为 0**(不闭合存不进来), 换成「共 N 个版本,保存即生效」 - 驾驶舱:「未闭合草稿」卡整张撤掉 —— 同理恒为 0。天然的第三张是「死路」 (route-dead-end 事件),但那需要一条按事件类型聚合的路由,没有之前不摆(同死信卡的规矩) ## 顺手修:种子的幂等判断本来是坏的比对用 `JSON.stringify` 认键序,而 jsonb 从 PG 读回来键是重排过的 —— 永远判不等, 每播一次种就多存一版一模一样的定义(实测一口气堆到 v3)。改成递归按键名排序后比对。连播三次,只第一次存。 ## 契约变更(破坏性,一步到位) `publish` 删除、`NotPublishableError` → `NotClosedError`、`publishable` → `closed`、状态枚举收窄。按规矩破坏性变更该走三步弃用 —— 这里一步改完,因为: ① depcruise 反查下游全在仓内(374 模块无违规),同批改完; ② 要弃用的是一个**产品决定不再存在**的机制,留弃用窗口没有意义。 CONTRACT.md 已同步,快照单独说明。 typecheck ✓ lint ✓ depcruise 374 模块 ✓ 495 测试 ✓ Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01KeDBx2PHLavbURXB8LJJ7m
2026-07-28 12:49:24 +08:00
parent 78622b8799
commit b2f5f69d6a
26 changed files with 307 additions and 355 deletions
@@ -30,14 +30,15 @@ function toWorkflow(row: WorkflowRow): WorkflowRecord {

 export function createProcessStore(db: Db): ProcessStore {
  return {
+    /*
+     * **只插不改**:版本一旦落库就是不可变的历史。
+     * 版本号由用例层算(恒新增),所以这里不该撞键;真撞了就让唯一约束报出来 ——
+     * 静默覆盖会改掉在途任务正在读的定义,那是最不该无声发生的事。
+     */
    async savePackage(pkg: ProcessPackage) {
      await db
        .insert(processPackageTable)
-        .values({ id: pkg.id, version: pkg.version, name: pkg.name, state: pkg.state, definition: pkg })
-        .onConflictDoUpdate({
-          target: [processPackageTable.id, processPackageTable.version],
-          set: { name: pkg.name, state: pkg.state, definition: pkg },
-        });
+        .values({ id: pkg.id, version: pkg.version, name: pkg.name, state: pkg.state, definition: pkg });
    },

    async getPackage(id, version) {
@@ -57,21 +58,6 @@ export function createProcessStore(db: Db): ProcessStore {
      return rows.map((r) => processPackageSchema.parse(r.definition));
    },

-    async publishPackage(id, version) {
-      const rows = await db
-        .select()
-        .from(processPackageTable)
-        .where(and(eq(processPackageTable.id, id), eq(processPackageTable.version, version)))
-        .limit(1);
-      const row = rows[0];
-      if (row === undefined) return;
-      const definition = { ...(row.definition as Record<string, unknown>), state: 'published' };
-      await db
-        .update(processPackageTable)
-        .set({ state: 'published', publishedAt: new Date(), definition })
-        .where(and(eq(processPackageTable.id, id), eq(processPackageTable.version, version)));
-    },
-
    async insertWorkflow(record) {
      await db.insert(workflowTable).values({
        id: record.id,
@@ -1,11 +1,14 @@
 /**
 * 边映射闭合校验 —— 纯逻辑,零 IO(编码规范 §5.3;语义出处 OS 03)。
 *
- * 「**连线即映射,画图即校验,不闭合不得发布。**
+ * 「**连线即映射,画图即校验,不闭合不得保存。**
 *  连一条边即须完成该边映射(必填未映射 = 边未完成),类型兼容依两端契约 schema 当场校验;
- *  存在未完成边、未满足必填或类型冲突的流程包**可存草稿、不得发布**。
+ *  存在未完成边、未满足必填或类型冲突的流程包**存不进来**。
 *  AND 汇合后的同名字段必须**显式指定来源分支**,不做隐式合并。」
 *
+ * 原文是「可存草稿、不得发布」——**已不成立**:没有草稿态也没有发布门,
+ * 闸落在保存上(严格检查 + 保存即生效)。画布上的半成品留在浏览器里,存不进库。
+ *
 * 前端画布的即时校验与后端裁决**同源** —— 这一份实现两边共用。
 */
 import type { ClosureReport, ClosureViolation, Edge, ProcessNode, ProcessPackage } from '@contracts';
@@ -70,7 +73,7 @@ export function checkClosure(input: ClosureInput): ClosureReport {

  violations.push(...checkTolerateDependencies(pkg, contracts, byId));

-  return { publishable: violations.length === 0, violations };
+  return { closed: violations.length === 0, violations };
 }

 function checkActivityNode(
@@ -214,7 +217,7 @@ function checkTolerateDependencies(
  return out;
 }

-/** 不闭合不得发布 —— 发布门的唯一判据 */
-export function publishable(report: ClosureReport): boolean {
-  return report.publishable;
+/** 不闭合不得**保存** —— 没有发布这道门,闸落在保存上,这是它的唯一判据 */
+export function closed(report: ClosureReport): boolean {
+  return report.closed;
 }
@@ -5,7 +5,7 @@
 */
 import type { ProcessNode, ProcessPackage, StaffId, TerminalState, WorkflowState } from '@contracts';
 import type { ProcessService, StartWorkflowInput } from '../../contract.ts';
-import { CallInterfaceViolationError, NotPublishableError, PositionVacantError } from '../../contract.ts';
+import { CallInterfaceViolationError, NotClosedError, PositionVacantError } from '../../contract.ts';
 import type {
  ActivityDirectory,
  ApprovalGateway,
@@ -47,19 +47,29 @@ export function createProcessService(deps: ProcessServiceDeps): ProcessService {
  }

  /**
-   * 起单取版:未指定版本时取**最新已发布** —— 草稿不入选。
-   * 若按「最新版本」取,治理台一存草稿,起单立刻被没发布的定义顶住;
-   * 草稿是编排中的半成品,运行时永远不该看见它。
+   * 起单取版:未指定版本时取**最新的一版**。
+   *
+   * 从前这里取「最新已发布」,因为草稿是编排中的半成品、运行时不该看见它。
+   * 现在没有草稿了 —— 「严格检查 + 保存生效」,不闭合根本存不进来,
+   * 所以库里的每一版都是能起单的。生效就是这个意思:**新任务起单时取到最新版**,
+   * 在途的按启动时快照的版本号读定义、跑完旧编排。
+   * `retired` 的版本拒起单(留给「这一版不再用了」)。
   */
-  async function latestPublished(id: string): Promise<ProcessPackage> {
+  async function latest(id: string): Promise<ProcessPackage> {
    const all = await deps.store.listPackages();
    const hit = all
-      .filter((pkg) => pkg.id === id && pkg.state === 'published')
+      .filter((pkg) => pkg.id === id && pkg.state !== 'retired')
      .sort((a, b) => b.version - a.version)[0];
-    if (hit === undefined) throw new Error(`流程包无已发布版本,不得起单:${id}`);
+    if (hit === undefined) throw new Error(`流程包无可用版本,不得起单:${id}`);
    return hit;
  }

+  /** 下一个版本号 —— 保存恒新增,不覆盖任何在途任务正在读的定义 */
+  async function nextVersion(id: string): Promise<number> {
+    const all = await deps.store.listPackages();
+    return all.filter((pkg) => pkg.id === id).reduce((max, pkg) => Math.max(max, pkg.version), 0) + 1;
+  }
+
  async function requireWorkflow(id: string): Promise<WorkflowRecord> {
    const record = await deps.store.getWorkflow(id);
    if (record === undefined) throw new Error(`工作流不存在:${id}`);
@@ -268,9 +278,24 @@ export function createProcessService(deps: ProcessServiceDeps): ProcessService {
  }

  return {
+    /**
+     * 保存 —— **严格检查 + 即刻生效**。没有发布这道门,所以闸落在这里。
+     *
+     * 两件事一起做,顺序不能换:
+     *   ① 先校验:不闭合直接抛,**一个字节都不落库**。存进来的就是能起单的。
+     *   ② 再定版:恒取「当前最大版本 + 1」,不采信入参的 version。
+     *
+     * 为什么不能就地覆盖:工作流按 (包id, 版本) 去读定义。覆盖 v1 就等于改掉
+     * 所有在途 v1 任务正在读的编排 —— 它们会中途换了规则却毫不知情,
+     * 而「旧任务走完旧版本」正是要防这个。恒新增之后,旧版本是不可变的历史,
+     * 在途任务读得到的永远是它启动那天的那一份。
+     */
    async savePackage(pkg) {
-      await deps.store.savePackage(pkg);
-      return pkg;
+      const report = await this.validate(pkg);
+      if (!report.closed) throw new NotClosedError(report);
+      const saved: ProcessPackage = { ...pkg, version: await nextVersion(pkg.id), state: 'active' };
+      await deps.store.savePackage(saved);
+      return saved;
    },

    async listPackages() {
@@ -291,21 +316,13 @@ export function createProcessService(deps: ProcessServiceDeps): ProcessService {
    },

    /** 不闭合不得发布 */
-    async publish(id, version) {
-      const pkg = await requirePackage(id, version);
-      const report = await this.validate(pkg);
-      if (!report.publishable) throw new NotPublishableError(report);
-      await deps.store.publishPackage(id, version);
-      return report;
-    },
-
    /** 起单:经调用接口调起流程包,生成一条工作流 */
    async start(input: StartWorkflowInput) {
      const pkg =
        input.packageVersion === undefined
-          ? await latestPublished(input.packageId)
+          ? await latest(input.packageId)
          : await requirePackage(input.packageId, input.packageVersion);
-      if (pkg.state !== 'published') throw new Error(`流程包未发布,不得起单:${pkg.id}@${pkg.version}`);
+      if (pkg.state === 'retired') throw new Error(`该版本已停用,不得起单:${pkg.id}@${pkg.version}`);

      // 先校验后建单:不合调用接口契约的输入**一条工作流都不留**。
      // (校验若放在建单之后,失败就会留下一条永远推不动的在途单,污染在途口径。)