Method Execute

pkg/tools/builtin/killshell.go:62–221

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

}

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

	shellID := GetStringParam(input, "shell_id", "")
	signal := GetStringParam(input, "signal", "SIGTERM")
	force := GetBoolParam(input, "force", false)
	wait := GetBoolParam(input, "wait", true)
	timeoutSeconds := GetIntParam(input, "timeout", 10)
	cleanup := GetBoolParam(input, "cleanup", true)

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

	start := time.Now()

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

	// 获取任务信息以验证存在
	task, err := taskManager.GetTask(shellID)
	if err != nil {
		return map[string]any{
			"ok":    false,
			"error": "background shell not found: " + shellID,
			"recommendations": []string{
				"确认shell_id是否正确",
				"检查任务是否已经被终止",
				"使用BashOutput工具查看可用的后台任务",
			},
			"shell_id":    shellID,
			"duration_ms": time.Since(start).Milliseconds(),
		}, nil
	}

	// 检查任务状态
	if task.Status != "running" {
		return map[string]any{
			"ok":          false,
			"error":       "task is not running, current status: " + task.Status,
			"shell_id":    shellID,
			"command":     task.Command,
			"pid":         task.PID,
			"status":      task.Status,
			"duration_ms": time.Since(start).Milliseconds(),
			"recommendations": []string{
				"任务已经完成或失败，无需终止",
				"使用BashOutput工具查看任务结果",
			},
		}, nil
	}

	// 确定要发送的信号
	finalSignal := signal
	if force {