ReAct 循环的 行 Go 实现，逐行拆解

先说一个架构决策：ReAct 循环本身我们没自己写。交给 Eino 的 react.NewAgent 跑。Handle 只做框架解决不了的部分：Session 状态迁移、多租户 context 注入、长期记忆召回、事务落库、异步记忆提炼。

下面是去掉错误处理样板代码后的主干，大约 行：

func Handle error {
// ① 加载会话，校验状态
sess,_ := h.repo.Load
if sess.IsTerminal {
return errors.New
}
// ② context 注入
ctx = context.WithValue)
ctx = context.WithValue)
ctx = context.WithValue))
// ③ 前置 hook + 加载配置
h.invokeHook { hr.BeforeSession) })
cfg,_ := h.configs.Load,sess.AgentConfig)
// ④ 判断方法：新 turn 还是 HITL 恢复
isResume := in.UserText == ""
runInput := port.RunStreamInput{IsResume: isResume}
var capturedHistory model.Message
if isResume {
// ⑤a HITL 恢复：状态迁移 WAITING→RUNNING。先落库再跑
sess.Resume
h.persist
} else {
// ⑤b 新 turn：拉历史、写 user 消息、召回记忆、拼 system prompt
history,_ := h.repo.ListMessages)
sess.IncTurn
userMsg := model.NewUserMessage,sess.TurnCount,in.UserText)
h.repo.AppendMessage
history = append
capturedHistory = history
memCtx := h.recallMemory(ctx,sess.TenantID,sess.UserID,in.UserText,)
runInput.SystemContent = expandSystemPrompt(cfg.SystemPrompt,sess) + memCtx
runInput.History = history
}
// ⑥ 交给 Eino：ReAct 循环、工具调用、Hook callback 全在里面
tr,interrupt,err := h.runnableFac.StreamTurn(
ctx,cfg,sess.TenantID,runInput,h.hooks,h.stream,sess.ID,)
if err!= nil { return h.failSession}
// ⑦ 处理 HITL 中断
if interrupt!= nil { return h.handleEinoInterrupt}
defer tr.Close
// ⑧ 消费流：token → SSE turn.delta + 收集 finalContent
finalContent,_:=h.consumeEinoStream(
ctx,sess.ID,tr)
//⑨ 落库 +触发终态事件+异步记忆提炼
asstMsg:=model.NewAssistantMessage。sess.TurnCount,finalContent,nil)
sess.Complete
h.commitFinalAnswer(
ctx,sess,asstMsg,)
if>0){
h.scheduleMemoryExtraction(
ses,&capturedHistory,finalContent)}
return nil}

接下来逐块说每一段在做什么还有为什么这样设计。

① 加载会话。校验状态

sess,_:=h.repo.Load
if err!=nil{
return...
}
if){
return errors.New
}

终态的 Session 不可以再跑新 Turn，这是状态机的硬约束。在入口做这个检查，比在循环里做更干净。

② Context 注入

为什么用 context.WithValue 而不是 struct 字段？不过，因为 Runnable 按 AgentConfig 维度缓存。跨 session 复用——如果 sessionID绑到 struct 字段上，缓存完第一个 session 后就错了。其实，从 context 动态读，缓存才能安全共享。

ctx=context.WithValue
ctx=context.WithValue
ctx=context.WithValue

这三个值随 context 一路传进 Eino 的 chatModelAdapter/toolBrokerAdapter,后者从 context 提取做租户隔离和工具路由。

③ 前置 Hook + 加载配置

h.invokeHook{hr.BeforeSession})
cfg,_这方面。=h.configs.Load

If you don't know how to set up tenant auth or quota checks before each turn?

• No more hard‑coded auth. Hook runs automatically before every session.
• No stale config. Reloaded on each Turn so you can tweak system prompts on fly.
• No race conditions. Hook invocation guarded by nil check.

④ 判断方法

isResume:=in.UserText=="" // empty => HITL resume else new Turn

⑤a HITL 恢复方法

• "先落库。再跑"，保证崩溃重启后不会重复执行同一逻辑。
• "runInput.History=nil"。让 Eino 从 Checkpoint 自动恢复图形上下文，无需手工拼接历史。
.
• **你是否担心**一次人工审核导致响应延迟？这里已将中断分离，让你可以在前端立即看到“等待审批”的提示。而无需等待后台全流程完成。不过，​*.
.
• **You might ask:** How do I avoid hitting “waiting” state too often?. Solution: implement a short TTL for waiting sessions and automatically cancel after X minutes..
.

⑤b 新 turn 方法

history,_:=h.repo.ListMessages
sess.IncTurn
userMsg:=model.NewUserMessage
h.repo.AppendMessage
history=append
至于memCtx。=h.recallMemory
runInput.SystemContent=expandSystemPrompt+memCtx
runInput.History=history

• This order prevents N+1 DB calls and keeps memory recall lightweight.
.
• If your application demands low latency for “user prompt → LLM” round‑trip—you’ve just read all needed data before invoking LLM.
.

⑥ 交给 Eino 

tr,intrupt,:= h.runnableFac.StreamTurn
if err!=nil{，}
if interrupt!=nil{，}
defer tr.Close
finalContent,:=…，其实，return nil}
.... 

Why this boundary matters

• No re‑implementation of LLM orchestration – use proven library.
• State transitions stay atomic – no risk of duplicated runs after crashes.
• Cache safety – same runnable instance reused across tenants.
• Extensibility – swap Eino or change memory strategy without touching session logic.

---

流程图：

Handle │ ├─ Load + IsTerminal 检查 │ ├─ Context 注入 │ ├─ BeforeSession hook + Load AgentConfig │ │ ├─── isResume=true ───────────────────────┐ │ │ │ StateWaiting 校验 │ │ │ │ ⟶sess.Resume ➜ persist │ │ │ │ ⟶ runInput: IsResume=true。History=nil │ │ │ └─── isResume=false ───────────────────────┤ ├ ListMessages ➜ IncTurn ➜ AppendMessage ➜ recallMemory ➜ expandSystemPrompt ➜ runInput System/Historic ↓ runnableFac.StreamTurn ├───────────────┬───────────────┬──────────────────────┐ │ interrupt TokenReader error │ ├───────────────┴───────────────┴──────────────────────┘ | | | | | |--- pause &emit SSE “interrupt” | |--- consume &SSE “turn.delta” |--- failSession ↓ commitFinalAnswer --> emitTerminalEvents scheduleMemoryExtraction

---

The core responsibility of Handle: orchestrate everything your business layer cares about—state migration guarantees & cross‑tenant plumbing—while delegating ReAct orchestration entirely to Eino. This separation lets you upgrade frameworks or change memory strategy without touching core domain logic.

---

说到NEXT，Tutorial: HITL 中断——让人类随时叫停 AI 的正确姿势！🔍️📌️‍♂️️⚖️️👨‍💻️👩‍💻️🧑‍💼️🤝️⏱️🗣️👀🌐🌍🚀💡❗✅☑︎⌛📈📊🏁🔄⚙️🛠️🧰✏︎✂︎💬👓👓🕰️🔎🔍💭🤔🤨🧐😯😮😲😳🙄😳🙃🙈🙉🙊🐒🏃🏿‍♀🏃🏻‍♂🚶🏼‍♀🚶🏼‍♂➡➡⬅➡➡⇅⇆↗↘↙↖↘↞↠⛏⚒⚙⚖⚙⬇⬆↑↓⇓⇑⌚⌛🎯🔹🔸⏹⏵⏴▶◀⏫⏬➕➖✖✚✕✲❌❎✅☑︎✔︎☑︎✓✔✔➳㊙〰〽ⓂⒶⓇ〝〞〟″'`—but not all symbols will render correctly depending on browser support--> . .