Function hydrateCustomEmojiBuffers

quote/quote.ts:1115–1172

(client: any, messages: any[])

  } finally {
    try { if (fs.existsSync(input)) fs.unlinkSync(input); } catch (err) {
    console.debug("[quote] waitForStableFile loop error:", err?.message || err);
  }
  }
}

function looksLikeAnimatedEmoji(buffer: Buffer | undefined): boolean {
  if (!buffer || buffer.length < 16) return false;
  const head = buffer.subarray(0, 64).toString("utf8");
  if (isAnimatedRasterBuffer(buffer)) return true;
  // WebM (EBML header + "webm" string): 0x1A 0x45 0xDF 0xA3 + "webm" in first 64 bytes
  if (buffer[0] === 0x1a && buffer[1] === 0x45 && buffer[2] === 0xdf && buffer[3] === 0xa3 && head.includes("webm")) return true;
  // Lottie JSON: starts with {"v" or has "layers"
  if (head.trimStart().startsWith("{\"v\"") || head.includes("\"layers\"")) return true;
  // .tgs gzip/lottie
  if (buffer[0] === 0x1f && buffer[1] === 0x8b) return true;
  return false;
}

async function convertAnimatedEmojiToPng(buffer: Buffer): Promise<Buffer | undefined> {
  const tmpBase = path.join(os.tmpdir(), `telebox_quote_emoji_${Date.now()}_${Math.random().toString(16).slice(2)}`);
  const input = `${tmpBase}.bin`;
  const output = `${tmpBase}.png`;
  try {
    fs.writeFileSync(input, buffer);
    // ffmpeg handles webm/video stickers. It may not handle tgs/lottie; those will fall back below.
    await execFileAsync("ffmpeg", [
      "-hide_banner", "-loglevel", "error", "-y",
      "-c:v", "libvpx-vp9",
      "-i", input,
      "-frames:v", "1",
      "-vf", "scale=128:128:force_original_aspect_ratio=decrease:flags=lanczos,format=rgba",
      "-f", "image2", output
    ], 12000);
    if (fs.existsSync(output)) {
      const png = fs.readFileSync(output);
      if (png.length > 0) {
        return await (await getSharp())(png, { animated: false }).ensureAlpha().png({ force: true }).toBuffer();
      }
    }
  } catch (_) {
    // keep fallback quiet; normal static buffers and unsupported tgs land here
  } finally {
    try { if (fs.existsSync(input)) fs.unlinkSync(input); } catch (err) {
    console.debug("[quote] waitForStableFile loop error:", err?.message || err);
  }
    try { if (fs.existsSync(output)) fs.unlinkSync(output); } catch (err) {
    console.debug("[quote] waitForStableFile loop error:", err?.message || err);
  }
  }

  try {
    // Some animated emoji downloads are tgs/lottie. Sharp cannot render lottie,
    // but if Telegram provided a raster thumbnail this path is not used.
    return await (await getSharp())(buffer, { animated: false }).resize(128, 128, { fit: "inside" }).png({ force: true }).toBuffer();
  } catch (_) {
    return undefined;
  }
}