Method executeTools

pkg/agent/processor.go:297–380

executeTools 执行工具

(ctx context.Context, toolUses []*types.ToolUseBlock)

// executeTools 执行工具
func (a *Agent) executeTools(ctx context.Context, toolUses []*types.ToolUseBlock) error {
	toolResults := make([]types.ContentBlock, 0, len(toolUses))

	for _, tu := range toolUses {
		result := a.executeSingleTool(ctx, tu)
		toolResults = append(toolResults, result)
	}

	// 保存工具结果
	a.mu.Lock()
	a.messages = append(a.messages, types.Message{
		Role:          types.MessageRoleUser,
		ContentBlocks: toolResults,
	})

	// ✅ 修复：保存前在内存中修剪
	if a.shouldTrimMessages() {
		a.messages = a.trimMessagesInMemory(a.messages, a.config.Store.MaxMessages)
		procLog.Debug(ctx, "messages trimmed in memory before save (after tool execution)", map[string]any{
			"agent_id":     a.id,
			"max_messages": a.config.Store.MaxMessages,
			"actual_count": len(a.messages),
		})
	}

	a.stepCount++
	a.mu.Unlock()

	// 持久化（已修剪的消息）
	if err := a.deps.Store.SaveMessages(ctx, a.id, a.messages); err != nil {
		return fmt.Errorf("save messages: %w", err)
	}

	// 持久化工具记录
	records := make([]types.ToolCallRecord, 0, len(a.toolRecords))
	for _, record := range a.toolRecords {
		records = append(records, *record)
	}
	if err := a.deps.Store.SaveToolCallRecords(ctx, a.id, records); err != nil {
		return fmt.Errorf("save tool records: %w", err)
	}

	// 检查迭代限制（防止无限循环）
	a.mu.Lock()
	a.iterationCount++
	currentIter := a.iterationCount
	maxIter := a.maxIterations
	if maxIter <= 0 {
		maxIter = 50
	}
	a.mu.Unlock()

	if currentIter > maxIter {
		procLog.Warn(ctx, "iteration limit reached, waiting for user confirmation", map[string]any{
			"agent_id": a.id, "iteration": currentIter, "max": maxIter,
		})

		// 发送迭代限制事件，等待用户确认是否继续