Method handleQuestion

ai/ai.ts:4421–4498

(
    msg: Api.Message,
    question: string,
    trigger?: Api.Message,
    token?: AbortToken,
  )

  async handleQuestion(
    msg: Api.Message,
    question: string,
    trigger?: Api.Message,
    token?: AbortToken,
  ): Promise<void> {
    const config = await this.getConfig();

    if (
      !config.currentChatTag ||
      !config.currentChatModel ||
      !config.configs[config.currentChatTag]
    ) {
      const prefixes = getPrefixes();
      throw new UserError(
        `请先配置 API 并设置模型\n使用 ${prefixes[0]}ai config add <tag> <url> <key> [type] 和 ${prefixes[0]}ai model chat <tag> <model-path>`,
      );
    }

    token?.throwIfAborted();

    await sendProcessing(msg, "chat");

    const replyMsg = await safeGetReplyMessage(msg);
    let context = getMessageText(replyMsg);
    const replyToId = replyMsg?.id;
    const imageParts = [
      ...(await getMessageImageParts(replyMsg)),
      ...(await getMessageImageParts(msg)),
    ];

    const normalizedQuestion = question.trim();
    const normalizedContext = context.trim();
    if (
      normalizedQuestion &&
      normalizedContext &&
      normalizedQuestion === normalizedContext
    ) {
      context = "";
    }

    const userText = context
      ? `上下文:\n${context}\n\n问题:\n${question}`
      : question;

    const response = await this.aiService.callAI(userText, imageParts, token);
    const answer = response.text || "AI 回复为空";

    const collapseSafe = config.collapse;
    const htmlAnswer = TelegramFormatter.markdownToHtml(answer, {
      collapseSafe,
    });
    const safeQuestion = htmlEscape(question);
    const formattedAnswer = `Q:\n${safeQuestion}\n\nA:\n${htmlAnswer}`;

    token?.throwIfAborted();

    if (config.telegraph.enabled && formattedAnswer.length > 4050) {
      await this.handleLongContentWithTelegraph(