Method executeSingleTool

pkg/agent/processor.go:383–831

executeSingleTool 执行单个工具

(ctx context.Context, tu *types.ToolUseBlock)

// executeSingleTool 执行单个工具
func (a *Agent) executeSingleTool(ctx context.Context, tu *types.ToolUseBlock) types.ContentBlock {
	// 检查工具输入是否有解析错误（流式响应被截断等情况）
	if parseError, ok := tu.Input["__parse_error__"].(bool); ok && parseError {
		errorMsg := "工具参数解析失败"
		if msg, ok := tu.Input["__error_message__"].(string); ok {
			errorMsg = msg
		}
		procLog.Error(ctx, "tool input parse error detected", map[string]any{
			"tool":  tu.Name,
			"id":    tu.ID,
			"error": errorMsg,
		})
		a.eventBus.EmitProgress(&types.ProgressToolErrorEvent{
			Call: types.ToolCallSnapshot{
				ID:        tu.ID,
				Name:      tu.Name,
				State:     types.ToolCallStateFailed,
				Arguments: tu.Input,
			},
			Error: errorMsg,
		})
		return &types.ToolResultBlock{
			ToolUseID: tu.ID,
			Content:   fmt.Sprintf(`{"ok":false,"error":"%s","hint":"请重新调用工具，确保提供完整的参数"}`, errorMsg),
			IsError:   true,
		}
	}

	// Plan 模式检查：验证工具调用是否允许
	if a.planMode != nil && a.planMode.IsActive() {
		allowed, reason := a.planMode.ValidateToolCall(tu.Name, tu.Input)
		if !allowed {
			errorMsg := "Plan Mode restriction: " + reason
			a.eventBus.EmitProgress(&types.ProgressToolErrorEvent{
				Call: types.ToolCallSnapshot{
					ID:        tu.ID,
					Name:      tu.Name,
					State:     types.ToolCallStateFailed,
					Arguments: tu.Input,
				},
				Error: errorMsg,
			})
			return &types.ToolResultBlock{
				ToolUseID: tu.ID,
				Content:   fmt.Sprintf(`{"ok":false,"error":"%s","plan_mode":true}`, errorMsg),
				IsError:   true,
			}
		}
	}

	// 权限检查
	if a.permissionInspector != nil {
		call := &types.ToolCallSnapshot{
			ID:        tu.ID,
			Name:      tu.Name,
			Arguments: tu.Input,
		}
		checkResult, err := a.permissionInspector.Check(ctx, call)