Function sendImageAlbum

cosplay/cosplay.ts:325–385

(
  client: any,
  chatId: any,
  filePaths: string[],
  photoSetUrl?: string
)

}

async function sendImageAlbum(
  client: any,
  chatId: any,
  filePaths: string[],
  photoSetUrl?: string
): Promise<void> {
  try {
    const files = filePaths.map(
      (filePath) =>
        new CustomFile(path.basename(filePath), fs.statSync(filePath).size, filePath)
    );

    const singles: Api.InputSingleMedia[] = [];

    const { getInputPhoto, getInputDocument } = await import("teleproto/Utils");

    for (let i = 0; i < files.length; i++) {
      const file = files[i];

      const handle = await client.uploadFile({ file, workers: 1 });
      const uploaded = new Api.InputMediaUploadedPhoto({ file: handle });

      const r = await client.invoke(
        new Api.messages.UploadMedia({ peer: chatId, media: uploaded })
      );

      let media: Api.TypeInputMedia;
      if (r instanceof Api.MessageMediaPhoto) {
        const id = getInputPhoto(r.photo);
        media = new Api.InputMediaPhoto({ id, spoiler: true });
      } else if (r instanceof Api.MessageMediaDocument) {
        const id = getInputDocument(r.document);
        media = new Api.InputMediaDocument({ id, spoiler: true });
      } else {
        console.warn("非预期的 UploadMedia 返回类型，已跳过");
        continue;
      }

      singles.push(
        new Api.InputSingleMedia({
          media,
          message: i === 0 && photoSetUrl ? `套图链接: ${photoSetUrl}` : "",
          entities: undefined,
        })
      );
    }

    if (!singles.length) {
      throw new Error("无可发送的媒体");
    }

    await client.invoke(
      new Api.messages.SendMultiMedia({ peer: chatId, multiMedia: singles })
    );
  } catch (err: any) {
    console.warn("剧透相册发送失败，尝试逐条发送", err?.message || err);
    for (const filePath of filePaths) {
      await sendSingleImage(client, chatId, filePath, photoSetUrl);