GenarrativeAI/Genarrative
10
0
Fork 0
Code Issues 21 Pull Requests 6 Actions Packages Projects 1 Releases Wiki Activity

WIP: Feat/ 待发送消息从前端队列移入rust #514

Draft
k88936 wants to merge 3 commits from feat/msg-queue-to-rust into master
pull from: feat/msg-queue-to-rust
merge into: GenarrativeAI:master
Conversation 0 Commits 3 Files Changed 13
+1216 -22
k88936 commented 2026-09-24 21:25:18 +08:00
Member
Copy Link
Copy Source

closes #499
沿用thread manager, 状态存在日志里

closes #499 沿用thread manager, 状态存在日志里
k88936 added 3 commits 2026-09-24 21:25:18 +08:00
文档：DirectProject 命令入队化与待发消息队列归宿主设计定稿 1e7ea51368 
- 新增 ADR：命令=入队、放行归 Thread Manager、待发消息队列作为运行态事件归宿主
- 新增实施计划：五步落地顺序、标识符映射表、每步不变式与验收证据
- CONTEXT.md：接单/拒单词条替换为入队/入队失败/放行，新增待发消息队列与待发消息词条
- docs/README.md 补两条索引；decision-log.md 追加同日决策记录
运行态事件：待发消息队列的入队/移除事件与队列条目规则 faf85837bd 
- 新增 `DirectThreadEvent::QueueEnqueued`（`queue.enqueued`，带 canonical 用户条目与可选 `creationType`，不带 prompt）与 `QueueRemoved`（`queue.removed`，`reason` 为 typed 枚举 `cancelled | dispatched`）
- 新增 typed 枚举 `DirectQueueRemovalReason` 与 `DirectQueueRemovalOutcome`，并重跑 ts-rs 绑定
- 新增 `agent/direct_thread_queue.rs`：`PendingDirectTurn`（入队时冻结 canonical 形状与 prompt）、上限 `MAX_PENDING_DIRECT_TURNS = 5`、`EnqueueOutcome` / `EnqueueRejection`
- Thread Manager 的 `observe_event` 认队列事件：在队期间的 `queue.enqueued` 不可回收，`queue.removed` 把它转成可回收，新订阅者的 bootstrap 因此天然看得见当前队列
- `DirectCodexUserItem` 及其子类型补 `PartialEq`，`DirectThreadEvent` 不再需要 `Eq`
Thread Manager：待发消息队列的入队 / 取消 / 放行认领
Project CI / AI game creator shell Rust crates (pull_request) Successful in 1m12s
Details
Project CI / AI game creator shell Rust smoke (pull_request) Successful in 1m31s
Details
Project CI / Backend tests (pull_request) Successful in 4m1s
Details
Project CI / Frontend tests (pull_request) Successful in 2m5s
Details
Project CI / Native shell tests (pull_request) Successful in 6m7s
Details
Project CI / AI game creator shell Rust lane 1/2 (pull_request) Successful in 10m0s
Details
Project CI / AI game creator shell Rust lane 2/2 (pull_request) Successful in 10m3s
Details
Project CI / AI game creator shell web tests (pull_request) Successful in 1m52s
Details
Project CI / Repository checks (pull_request) Successful in 2m17s
Details
053e0bd932 
- `StoredEvent` 增加非序列化的 `pending` 产物字段：它的有无就是队列成员身份，队列的先后就是事件先后，不另建队列表
- 新增 `enqueue_pending_turn`：按 `clientTurnId` 幂等（判重范围「在队 ∪ 正在跑的那一轮」），容量用 `queue_has_room` 挡在队条目
- 新增 `remove_pending_turn`：typed 结果 `Removed | AlreadyDispatched | NotFound`，在临界区里取走产物并追加 `queue.removed{cancelled}`
- 新增 `claim_pending_turn`：同一临界区取队首 → 登记占用 → 追加 `turn.started` 与 `queue.removed{dispatched}`，已有未收口回合或队列为空时返回 `None`
- `mark_queue_events_cleanable` 跳过仍挂着产物的条目，保证在队条目永远不会被回收
- 新增薄包装 `enqueue_direct_pending_turn` / `remove_direct_pending_turn` / `claim_direct_pending_turn`，并补 5 条单测覆盖 bootstrap 可见、幂等、容量、放行原子性与三种取消结果
Some checks are pending
Project CI / AI game creator shell Rust crates (pull_request) Successful in 1m12s
Details
Project CI / AI game creator shell Rust smoke (pull_request) Successful in 1m31s
Details
Project CI / Backend tests (pull_request) Successful in 4m1s
Details
Project CI / Frontend tests (pull_request) Successful in 2m5s
Details
Project CI / Native shell tests (pull_request) Successful in 6m7s
Details
Project CI / AI game creator shell Rust lane 1/2 (pull_request) Successful in 10m0s
Details
Project CI / AI game creator shell Rust lane 2/2 (pull_request) Successful in 10m3s
Details
Project CI / AI game creator shell web tests (pull_request) Successful in 1m52s
Details
Project CI / Repository checks (pull_request) Successful in 2m17s
Details
This pull request is marked as a work in progress.
This branch is out-of-date with the base branch
View command line instructions

Checkout

From your project repository, check out a new branch and test the changes.
git fetch -u origin feat/msg-queue-to-rust:feat/msg-queue-to-rust
git checkout feat/msg-queue-to-rust
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
Clear labels
Compat/Breaking
Breaking change that won't be backward compatible
 Kind/Bug
Something is not working
 Kind/Documentation
Documentation changes
 Kind/Enhancement
Improve existing functionality
 Kind/Feature
New functionality
 Kind/Security
This is security issue
 Kind/Testing
Issue or pull request related to testing
Priority
Critical
1
The priority is critical
Priority
High
2
The priority is high
Priority
Low
4
The priority is low
Priority
Medium
3
The priority is medium
Reviewed
Confirmed
1
Issue has been confirmed
Reviewed
Duplicate
2
This issue or pull request already exists
Reviewed
Invalid
3
Invalid issue
Reviewed
Won't Fix
3
This issue won't be fixed
Status
Abandoned
3
Somebody has started to work on this but abandoned work
Status
Blocked
1
Something is blocking this issue or pull request
Status
Need More Info
2
Feedback is required to reproduce issue or to continue work
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
HuangJiaJia JenkenB k88936 (王德宇) kdletters (段舒康) laura2008 (王乐) lhk229 (孔令弘) Loer (农洛儿) loong suzmii (董羽秦) taobaisu (叶东旭) wuxiangwanzi (王子民) YixuanLiu ziyu
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: GenarrativeAI/Genarrative#514
Delete Branch "feat/msg-queue-to-rust"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?