feat(core): interrupt 投递、可打断工具与 World 的排队事件操作

[Phantivia]

Closes #179

改动

新增 interrupt 触发。 事件到达时停止当前轮:

• 模型调用中:无论有无外部输出都取消。已外化的部分按 recordAbortedStream 保存,提前执行过的调用用真实回执,其余调用得到 [not executed: interrupted by a new event]。
• 工具执行中:声明了 interruptible 的工具收到 ctx.signal,Core 等它返回,在回执末尾注明执行期间发出过打断信号,做到哪一步由工具回执说明;未声明的工具执行到结束;本轮尚未开始的调用不执行。
• 之后在同一批内接收新事件,开始下一轮。

ToolDef.interruptible。 缺省为不可打断。工具的 signal 不再合并模型请求的取消信号;此前它只会在关机时与模型请求一起被取消,preempt 发生时工具还没开始。

preempt 取消后不再结束本次唤醒。 被取消的轮计入轮数,在同一批内带着新事件重新请求,不调用 onTurnEnded。此前 QQ 的未确认草稿、cua 的本轮授权会因为一次抢占被清掉。一直有 preempt 事件到达时,本批在 rounds().hard 处收束。

到达时没有可取消的轮。 preempt 或 interrupt 在工具执行中、onDelivery 等待中或两轮之间到达时,事件在下一次模型请求前送入,不等再一轮工具返回。

外化判定统一。 默认规则导出为 defaultExternalizes。Cormini 合并多个接收器时,未声明 externalizes 的接收器逐个回落到默认规则;此前合并后一律为 false。

撤回在循环停止后也写记录。 事件已离开队列,重启补投按 core.withdrawal 记录跳过它。

World 的排队事件操作。

• withdrawPending(cursor):撤回本 World 一条未投递的事件。事件库追加 core.withdrawal 记录,重启补投跳过该事件,水位可越过它。
• promotePending(cursor, trigger):让排队中的事件按 flush / preempt / interrupt 立即触发。暂停或投递闸门挡着时只取消它的 piggyback,放行后随整批投递,不打断。
• onEventsSettled(events, outcome):本 World 的事件写入主 session(delivered)或被操作者清空队列(discarded)时调用。

两个新宿主方法是可选成员,跨进程宿主(minecraft engine-child)未实现。

docs/sessions.md 补上一批之内新事件进入上下文的轮次边界,以及两种取消之后的行为。

测试

• tests/core/loop.test.ts:被抢占的轮不调用 onTurnEnded(旧代码计数为 2);interrupt 停下 interruptible 工具、跳过后续调用、新事件接在回执之后并触发 onEventsSettled;interrupt 取消已外化的模型轮并保留已输出正文;撤回记录让重启补投跳过该事件。
• tests/core/bus.test.ts:promote 把 piggyback 项改为 interrupt 并通知主循环。
• tests/cormini/output-tap.test.ts:两个未声明 externalizes 的接收器合并后,正文增量判为已外化(旧代码为 false)。
• pnpm test 4823 通过,pnpm run typecheck、pnpm typecheck:web 无报错。

English

This adds an interrupt trigger. It cancels the in-flight model call whether or not it has produced output, keeping what was already externalized. It signals running tools that declare interruptible, and skips calls in the round that have not started. The new event is then delivered after the round's receipts, in the same batch.

preempt keeps its meaning (cancel only a round with no external output). It now continues in the same batch and no longer fires onTurnEnded, which used to discard QQ drafts and cua permissions. When either trigger finds nothing to cancel, the event goes into the next model request instead of waiting for another round of tools.

The default externalization rule is exported as defaultExternalizes, and Cormini's merged tap falls back to it per tap. Previously a merged tap treated a tap without externalizes as false, while a single tap used the default rule.

Worlds gain withdrawPending, promotePending and onEventsSettled. A withdrawal is recorded in the event store as core.withdrawal, so a restart does not requeue the event.

🤖 Generated with Claude Code

[cursor]

先前三条已不再成立：docs/sessions.md 已补轮次边界（25cbf55）；recordWithdrawn 已去掉循环停止后的提前返回；PR 描述不再引用旧回执标记。

— Cortico PR Gate via Cursor Cloud Agent

  

_{Sent by Cursor Automation: Cortico PR Gate}

[cursor]

先前关于 promotePending 契约与闸门路径不一致的那条已不再成立：5d341008 已把 types.ts、bus.ts 与 docs/worlds.md 改成与代码一致（暂停或闸门挡着时只取消 piggyback，放行后随整批投递，不按 trigger 打断）。

— Cortico PR Gate via Cursor Cloud Agent

  

_{Sent by Cursor Automation: Cortico PR Gate}