Function convertTgsToWebm

yvlu/yvlu.ts:97–148

(tgsBuffer: Buffer)

        big: isBig,
      });
      const dcId = photo.dcId ?? fullEntity?.photo?.dc_id;
      const result = await withTimeout(
        client.invoke(
          new Api.upload.GetFile({
            location,
            offset: bigInteger.zero,
            limit: 512 * 1024,
            precise: true,
          }),
          dcId,
        ),
        QUOTE_RPC_TIMEOUT_MS,
        `downloadEntityAvatar.${isBig ? "big" : "small"}`,
      ) as { bytes?: unknown };
      const buffer = result?.bytes;
      return Buffer.isBuffer(buffer) && buffer.length > 0 ? buffer : undefined;
    } catch (err: any) {
      console.warn(`yvlu avatar ${isBig ? "big" : "small"} download failed`, err?.message || err);
      return undefined;
    }
  };

  const [small, big] = await Promise.all([tryDownload(false), tryDownload(true)]);
  const normalized = small ? await normalizeAvatarBuffer(small) : big ? await normalizeAvatarBuffer(big) : undefined;
  if (key) avatarCache.set(key, normalized);
  return normalized;
}

async function normalizeAvatarBuffer(buffer: Buffer): Promise<Buffer> {
  try {
    const sharp = (await import("sharp")).default;
    return await sharp(buffer)
      .resize(256, 256, { fit: "cover", position: "centre" })
      .flatten({ background: { r: 0, g: 0, b: 0 } })
      .png()
      .toBuffer();
  } catch (err: any) {
    console.warn("yvlu avatar normalize failed", err?.message || err);
    return buffer.length > 0 ? buffer : undefined;
  }
}

async function rawDownloadFile(client: any, location: any, dcId: number | undefined): Promise<Buffer | undefined> {
  if (!client || !location) return undefined;
  try {
    const result = await withTimeout(
      client.invoke(
        new Api.upload.GetFile({
          location,
          offset: bigInteger.zero,
          limit: 512 * 1024,
          precise: true,
        }),
        dcId,
      ),