Method handleChat

pkg/agent/actor.go:282–312

handleChat 处理同步对话

(ctx *actor.Context, msg *ChatMsg)

// handleChat 处理同步对话
func (a *AgentActor) handleChat(ctx *actor.Context, msg *ChatMsg) {
	execCtx, cancel := a.withCancellation(msg.Ctx)
	defer cancel()

	go func() {
		result, err := a.agent.Chat(execCtx, msg.Text)

		response := &ChatResultMsg{
			Result: result,
			Error:  err,
		}

		if err != nil && !errors.Is(err, context.Canceled) {
			a.recordError(err)
		}

		// 通过 channel 返回结果
		if msg.ReplyTo != nil {
			select {
			case msg.ReplyTo <- response:
			default:
				agentLog.Warn(context.Background(), "chat reply channel full or closed", map[string]any{"agent_id": a.agent.ID()})
			}
		}

		// 也通过 Actor 消息回复
		if ctx.Sender != nil {
			ctx.Reply(response)
		}
	}()
}

// handleStream 处理流式对话
func (a *AgentActor) handleStream(_ *actor.Context, msg *StreamMsg) {