fix(bot+canvas): 多 pending inbox 串行处理 + bot 反馈队列 1:1 配对

Loop 4 (canvas): 浏览器后开 + 多条 pending → 旧 scan 一次性 fire 全部 →
BottomAIBar submitting 守护吃掉后续 → handleItem 已把 yjs 标 processing
→ 永远卡死. 改成 scanInboxNext() 只 fire 最老一条, BottomAIBar 跑完后
finally 回调推进下一条.

Loop 5 (bot): pendingFeedbackByRoom 单值多 cast 互相覆盖 → conclusion
配错 prompt. 改 FIFO 队列, 每次 conclusion 弹出最早 ctx, 与前端串行处
理形成 1:1 对应.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: nieao

server/feishu-bot.mjs

@@ -509,14 +509,17 @@ async function handleMessage(evt) {
 // 关联到最近一次该 room 的 cast (chatId), 拼卡片 (含 5 个分支 callback button) 发飞书.
 
 const reverseChannels = new Map() // room → { doc, provider, yNodes, observer, baseline:Set, sentConclusions:Set }
-const pendingFeedbackByRoom = new Map() // room → { chatId, prompt, sentAt, fed: false }
+const pendingFeedbackByRoom = new Map() // room → Array<{ chatId, prompt, sentAt }> (FIFO 队列)
 let _cardSchemaDumped = false
 
 function registerPendingFeedback(room, ctx) {
-  // 重置 fed=false 让新一轮 conclusion 能再次触发反馈卡
-  // (老 ctx 已发过的 conclusion key 仍在 sentConclusions 防重复, 不影响新轮 conclusion)
-  pendingFeedbackByRoom.set(room, { ...ctx, fed: false })
-  log(`[reverse] register pending feedback room=${room} prompt="${(ctx.prompt || '').slice(0, 30)}"`)
+  // FIFO 队列 — 多 cast 之间不会互相覆盖. 每个 conclusion 弹出最早一条 ctx.
+  // 配 BottomAIBar 的串行处理 (aletheiaInbox.scanInboxNext): 前端按 ts 升序 fire,
+  // bot 按 cast 顺序入队, conclusion 顺序也保持一致 → 1:1 对应不会错配.
+  const q = pendingFeedbackByRoom.get(room) || []
+  q.push({ ...ctx })
+  pendingFeedbackByRoom.set(room, q)
+  log(`[reverse] register pending feedback room=${room} queue=${q.length} prompt="${(ctx.prompt || '').slice(0, 30)}"`)
 }
 
 // 调用 source-proxy cast + 同时注册反馈跟踪 (callback 路径必走这个 helper, 避免漏注册)
@@ -556,12 +559,14 @@ function ensureReverseChannel(room) {
       // 关键判断: ontologyNode + isConclusion + 含 conclusion 文本
       if (n.type !== 'ontologyNode' || !n.data?.isConclusion) return
       if (sentConclusions.has(key)) return // 防同节点 update 重复触发
-      // 时间窗校验: 必须在 pendingFeedback.sentAt 之后产生
-      const ctx = pendingFeedbackByRoom.get(room)
-      if (!ctx || ctx.fed) return
+      // 弹出 FIFO 队列最早一条 ctx — 1:1 对应每次 cast
+      const q = pendingFeedbackByRoom.get(room)
+      if (!q || q.length === 0) return
+      const ctx = q[0]
       const cAt = Number(n.data?.created_at || 0)
       if (cAt && cAt < ctx.sentAt - 5000) return // 早于本次 cast 5s+ 的肯定不是
       sentConclusions.add(key)
+      q.shift() // 消费 ctx
       // 收集本次 cast 之后产生的所有新节点 (拼卡片用)
       const newNodes = []
       yNodes.forEach((nn, k) => {
@@ -570,15 +575,14 @@ function ensureReverseChannel(room) {
         if (at && at < ctx.sentAt - 5000) return
         newNodes.push({ id: k, ...nn })
       })
-      log(`[reverse] room=${room} conclusion ready key=${key} 新节点=${newNodes.length}`)
+      log(`[reverse] room=${room} conclusion ready key=${key} 新节点=${newNodes.length} 剩余队列=${q.length}`)
       // 调试: 第一次时 dump 所有新节点 data 字段, 找到伪 ontology 的 marker
       if (process.env.LARK_DEBUG === '1') {
         for (const nn of newNodes.filter(x => x.type === 'ontologyNode' && !x.data?.isConclusion).slice(0, 3)) {
           log(`[reverse-dump] ontology id=${nn.id} data=${JSON.stringify(nn.data || {}).slice(0, 400)}`)
         }
       }
       sendFeedbackCard(room, ctx, n, newNodes).catch((e) => logErr('反馈卡发送失败:', e.message))
-      ctx.fed = true
     })
   }
   yNodes.observe(observer)

src/collab/aletheiaInbox.js

@@ -71,6 +71,30 @@ function handleItem(id, item) {
   }
 }
 
+/** 找最老的 pending (按 ts 升序), 没有则返回 null */
+function findOldestPending() {
+  const map = getInboxMap()
+  let oldest = null
+  map.forEach((item, key) => {
+    if (item?.status !== 'pending') return
+    const ts = Number(item.ts || 0)
+    if (!oldest || ts < oldest.ts) oldest = { key, item, ts }
+  })
+  return oldest
+}
+
+/**
+ * 扫一次, 只 fire 最老的一条 pending — 让 BottomAIBar 串行处理.
+ * 当前一条 LLM 跑完后, BottomAIBar 应主动调本函数取下一条.
+ * 不能一次性 fire 全部: 因为 handleItem 会立刻把 yjs 状态标 processing,
+ * 而 BottomAIBar 自己有 submitting 守护会把后续 fire 全部丢弃, 导致 inbox 永远卡死 processing.
+ */
+export function scanInboxNext() {
+  if (!_attached) return
+  const oldest = findOldestPending()
+  if (oldest) handleItem(oldest.key, oldest.item)
+}
+
 /** mount 时挂上, unmount 时清掉 */
 export function attachAletheiaInbox() {
   if (_attached) return
@@ -82,7 +106,7 @@ export function attachAletheiaInbox() {
     event.changes.keys.forEach((change, key) => {
       if (change.action === 'add') {
         const item = map.get(key)
-        // 新增的 pending 立即处理
+        // 新增的 pending 立即处理 (handleItem 自带 submitting / 选举守护)
         handleItem(key, item)
       } else if (change.action === 'update') {
         // update 不做 fire (避免循环)
@@ -91,12 +115,8 @@ export function attachAletheiaInbox() {
   }
   map.observe(_observer)
 
-  // 初次挂上时, 扫一遍未处理的 pending (如果别的 cc 还没处理过)
-  setTimeout(() => {
-    map.forEach((item, key) => {
-      if (item && item.status === 'pending') handleItem(key, item)
-    })
-  }, 1500) // 等 awareness 稳定再扫
+  // 初次挂上时, 只 fire 最老的一条 pending — 后续靠 BottomAIBar 跑完后回调 scanInboxNext()
+  setTimeout(() => { scanInboxNext() }, 1500) // 等 awareness 稳定再扫
 }
 
 export function detachAletheiaInbox() {

src/pages/panels/BottomAIBar.jsx

@@ -15,6 +15,7 @@ import { useState, useRef, useEffect } from 'react'
 import useCanvasStore from '../../stores/useCanvasStore'
 import { parseFile } from '../../utils/fileParser'
 import { PROVIDER_PRESETS, getAiConfig } from '../../services/aiConfig'
+import { scanInboxNext } from '../../collab/aletheiaInbox'
 
 const MODES = [
   {
@@ -86,6 +87,9 @@ function BottomAIBar({ showLeftPanel = true, showRightPanel = true, rightPanelWi
         // 失败时保留 input 让用户手动重试
       } finally {
         setSubmitting(false)
+        // 排队的下一条 inbox 由我们主动触发 — observer 只对 add 事件 fire,
+        // 多条 pending 排队时必须靠这里串行推进
+        setTimeout(() => scanInboxNext(), 200)
       }
     }
     window.addEventListener('aletheia-inbox-fire', handler)