Method Execute

pkg/tools/builtin/ask_user.go:138–269

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

}

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

	// 解析问题列表
	questions, err := t.parseQuestions(input["questions"])
	if err != nil {
		return NewClaudeErrorResponse(err), nil
	}

	// 验证问题数量
	if len(questions) < 1 || len(questions) > 4 {
		return NewClaudeErrorResponse(fmt.Errorf("questions count must be between 1 and 4, got %d", len(questions))), nil
	}

	// 验证每个问题
	for i, q := range questions {
		if err := t.validateQuestion(q, i); err != nil {
			return NewClaudeErrorResponse(err), nil
		}
	}

	// 生成请求ID
	requestID := uuid.New().String()

	// 创建响应通道（带缓冲，确保发送不会阻塞）
	responseChan := make(chan map[string]any, 1)
	t.pendingRequests[requestID] = responseChan

	// 创建请求对象并注册到全局表
	req := &askUserRequest{
		responseChan: responseChan,
		answered:     false,
	}
	globalAskUserRequestsMu.Lock()
	globalAskUserRequests[requestID] = req
	globalAskUserRequestsMu.Unlock()

	askUserLog.Info(context.Background(), "registered request, waiting for user response", map[string]any{"request_id": requestID})

	// 创建响应回调函数（用于 Emit 事件）
	respond := func(answers map[string]any) error {
		return RespondToAskUser(requestID, answers)
	}

	// 发送事件到 Control 通道
	if tc.Reporter != nil {
		// 通过 Reporter 发送中间结果，包含事件信息
		tc.Reporter.Intermediate("ask_user_event", map[string]any{
			"request_id": requestID,
			"questions":  questions,
			"event_type": "ask_user",
		})
	}

	// 如果有 Emit 函数，使用它发送事件