Method sendMedia

ai/ai.ts:1393–1468

(
    msg: Api.Message,
    mediaItems: T[],
    prompt: string,
    replyToId: number | undefined,
    token: AbortToken | undefined,
    options: {
      previewEnabled: boolean;
      poweredByTag: string;
      collapse: boolean;
      directory: string;
      filePrefix: string;
      rawFilePrefix?: string;
      getExtension: (mimeType: string) => string;
      resolve: (
        item: T,
        mediaToken?: AbortToken,
      ) => Promise<{ data?: Buffer; mimeType: string } | null>;
      prepareForSend?: (rawPath: string, finalPath: string) => Promise<string>;
    },
  )

  private async sendMedia<T extends AIImage | AIVideo>(
    msg: Api.Message,
    mediaItems: T[],
    prompt: string,
    replyToId: number | undefined,
    token: AbortToken | undefined,
    options: {
      previewEnabled: boolean;
      poweredByTag: string;
      collapse: boolean;
      directory: string;
      filePrefix: string;
      rawFilePrefix?: string;
      getExtension: (mimeType: string) => string;
      resolve: (
        item: T,
        mediaToken?: AbortToken,
      ) => Promise<{ data?: Buffer; mimeType: string } | null>;
      prepareForSend?: (rawPath: string, finalPath: string) => Promise<string>;
    },
  ): Promise<void> {
    if (!mediaItems.length) return;

    const peerId = msg.chatId || msg.peerId;
    const promptText = htmlEscape(prompt);
    const promptBlock = options.collapse
      ? `<blockquote expandable>${promptText}</blockquote>`
      : promptText;
    const poweredByText = `\n<i>🍀Powered by ${options.poweredByTag}</i>`;
    const caption = promptBlock + poweredByText;
    const mediaDir = createDirectoryInAssets(options.directory);
    const timestamp = Date.now();

    for (let i = 0; i < mediaItems.length; i++) {
      const item = mediaItems[i];
      token?.throwIfAborted();

      const resolved = await options.resolve(item, token);
      if (!resolved?.data) continue;

      const extension = options.getExtension(resolved.mimeType);
      const rawPrefix = options.rawFilePrefix ?? options.filePrefix;
      const rawName = `${rawPrefix}_${timestamp}_${i}${extension}`;
      const finalName = `${options.filePrefix}_${timestamp}_${i}${extension}`;
      const rawPath = path.join(mediaDir, rawName);
      const finalPath = path.join(mediaDir, finalName);

      try {
        await fs.promises.writeFile(rawPath, resolved.data);
        const pathToSend = options.prepareForSend
          ? await options.prepareForSend(rawPath, finalPath)
          : rawPath;

        if (!msg.client) {
          throw new Error("客户端未初始化");
        }

        const topicRootId = getTopicRootId(msg);
        const replyTo = replyToId ?? topicRootId;