Method execute

ai/ai.ts:4559–4691

(
    msg: Api.Message,
    args: string[],
    _prefixes: string[],
  )

  async execute(
    msg: Api.Message,
    args: string[],
    _prefixes: string[],
  ): Promise<void> {
    const prefixes = getPrefixes();
    const config = await this.getConfig();

    const promptInput = args.slice(1).join(" ").trim();

    const replyMsg = await safeGetReplyMessage(msg);
    requireUser(!!promptInput || !!replyMsg, "至少需要一条提示");

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

    await sendProcessing(msg, "search");

    const replyToId = replyMsg?.id;

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

    const normalizedPrompt = promptInput.trim();
    const normalizedContext = (context || "").trim();

    if (
      normalizedPrompt &&
      normalizedContext &&
      normalizedPrompt === normalizedContext
    ) {
      context = "";
    }

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

    const token = this.aiService.createAbortToken();
    try {
      const { text, sources } = await this.aiService.callSearch(
        userText,
        imageParts,
        token,
      );

      const sourcesText =
        sources && sources.length > 0
          ? "\n\n<b>🔗 Sources</b>\n" +