AskaEth
3acc81cec8
断点（M29 勘测定论）：后台批次结算后 `subagent.result` 发了、hub 也把它中继成 WS 帧，但**没有任何代码把结果回填父会话** —— `chat_messages` 无行、模型下一轮 看不到，于是「她拍了个子代理出去，但没有下文」。 回填拆成互不冒充的两条面（人格=身份红线：子代理结论绝不写成她的人格发言）： - 可观测/历史面（新文件 subagent_backfill.go）：独立订阅者（不塞进 hub）订阅 `subagent.result`，写父会话一条 `role=system` 注记（内容以 `[子代理结果]` 开头 并点名 `sub-<id>`），随后走既有 `message_persisted` 扇出 ⇒ 刷新/重连后仍在； - 模型面：同一行经转录播种成为下一回合的**系统注记**（`model.RoleSystem`）， 不是「她说过的话」。 落库口径：角色恒为 system（不冒充 user/assistant）、PersonaID 与 TurnID 留空 （注记不属于任何角色、也不属于任何一路回合）。 记忆抽取排除（新文件 subagent_backfill_extract.go）：`WithoutSubagentNotes` 装饰 `memory.Extractor`，判据是元数据（role=system + 注记标记，与 loop 的 summaryMarker 同一手法），组合根经 `loopMemoryExtractor` 套上 ⇒ 子代理结论绝不进记忆库；LLM 提取器的异步能力原样保留，压缩摘要（同样是 system）不被误剔。 可观测补齐（M29 §7）：`SpawnTool.await` 发布成功补带 source 的 INFO，`b==nil` 与 「无结果」的静默 return 改为 WARN，发布失败 WARN 带上 count/session；回填订阅者 顺手读 `bus.Dropped()`，涨了就记一条 WARN（总线丢事件不再是黑洞）。 测试（均可变异打红）：父会话恰一条 system 行且零伪造助手发言；注记/摘要/批次正文 有界且逐代理点名；不可用载荷与落库失败各留 WARN 且不广播；Start 真订阅总线； 结果不进记忆抽取（同步/异步/端到端接缝）；组合根真装配（真 bus 发布 → 父会话多 一行）。回归：go build ./... + go vet ./... + go test -count=1 ./... 全绿。 不做：不改 `subagent_result` 帧形状、不加进 frameReachesAll、不新开路由/帧族、 不注入人设、不改 Docs（契约归一建议报塔）。
29 lines
1.5 KiB
Go
29 lines
1.5 KiB
Go
package main
|
||
|
||
// 本文件只有一件事：给循环的记忆提取器套上「剔除子代理结果注记」这一层，并把这条
|
||
// 口径写在一个可测的入口上（M32）。
|
||
//
|
||
// 为什么要单独一个函数，而不是在 `wire_runtime.go` 的 Options 字面量里就地调一次：
|
||
//
|
||
// - 它是**红线级**口径（子代理结论绝不进记忆库），值得有一个名字与一个测试，
|
||
// 而不是夹在一长串 Options 里的一行调用 —— 那一行被删掉时没有任何东西会红；
|
||
// - 组合根里所有「必须套上」的装饰都走这种小函数（同 `a.buildMemoryExtractor()`
|
||
// 之于提取器本身），语义在函数名下，接线在唯一一处。
|
||
//
|
||
// 判据与实现见 `internal/services/gateway/subagent_backfill_extract.go`：元数据
|
||
// （role=system + 注记标记），不是提示词。
|
||
|
||
import (
|
||
"git.yeij.top/AskaEth/Cyrene_v2/internal/runtime/memory"
|
||
"git.yeij.top/AskaEth/Cyrene_v2/internal/services/gateway"
|
||
)
|
||
|
||
// loopMemoryExtractor 返回循环实际使用的提取器（`wire_runtime.go` 的
|
||
// `loop.Options.Extractor` 就是它）：内层是组合根按配置构建的那个（LLM 或确定性），
|
||
// 外层保证子代理结果注记**永远不进**抽取输入。
|
||
//
|
||
// base 为 nil 时返回 nil（未配置提取器的部署逐字不变：循环那边同样是 nil 即跳过）。
|
||
func loopMemoryExtractor(base memory.Extractor) memory.Extractor {
|
||
return gateway.WithoutSubagentNotes(base)
|
||
}
|