Method Execute

pkg/tools/builtin/bashoutput.go:80–257

(ctx context.Context, input map[string]any, tc *tools.ToolContext)

}

func (t *BashOutputTool) Execute(ctx context.Context, input map[string]any, tc *tools.ToolContext) (any, error) {
	// 验证必需参数
	if err := ValidateRequired(input, []string{"bash_id"}); err != nil {
		return NewClaudeErrorResponse(err), nil
	}

	bashID := GetStringParam(input, "bash_id", "")
	filter := GetStringParam(input, "filter", "")
	lines := GetIntParam(input, "lines", 100)
	follow := GetBoolParam(input, "follow", false)
	includeStderr := GetBoolParam(input, "include_stderr", true)
	since := GetStringParam(input, "since", "")
	resourceInfo := GetBoolParam(input, "resource_info", false)
	clearCache := GetBoolParam(input, "clear_cache", false)

	if bashID == "" {
		return NewClaudeErrorResponse(errors.New("bash_id cannot be empty")), nil
	}

	start := time.Now()

	// 获取任务管理器
	taskManager := GetGlobalTaskManager()

	// 获取任务信息
	task, err := taskManager.GetTask(bashID)
	if err != nil {
		return map[string]any{
			"ok":    false,
			"error": "background task not found: " + bashID,
			"recommendations": []string{
				"确认bash_id是否正确",
				"检查任务是否还在运行",
				"使用Bash工具查看可用的后台任务",
			},
			"bash_id":     bashID,
			"duration_ms": time.Since(start).Milliseconds(),
		}, nil
	}

	// 获取任务输出
	stdout, stderr, err := taskManager.GetTaskOutput(bashID, filter, lines)
	if err != nil {
		return map[string]any{
			"ok":          false,
			"error":       fmt.Sprintf("failed to get task output: %v", err),
			"bash_id":     bashID,
			"duration_ms": time.Since(start).Milliseconds(),
		}, nil
	}

	// 处理clear_cache
	if clearCache {
		// 清理任务的输出文件缓存
		tm := taskManager.(*FileTaskManager)
		_ = tm.cleanupOutputFiles(bashID)
	}