Function collectMessages

quote/quote.ts:1263–1294

(msg: Api.Message, args: QuoteArgs)

function isGifBuffer(buffer: Buffer | undefined): boolean {
  return !!buffer && buffer.length >= 6 && (buffer.subarray(0, 6).toString("ascii") === "GIF87a" || buffer.subarray(0, 6).toString("ascii") === "GIF89a");
}

function isAnimatedRasterBuffer(buffer: Buffer | undefined): boolean {
  return isWebmBuffer(buffer) || isGifBuffer(buffer);
}

function bufferKind(buffer: Buffer | undefined): string {
  if (!buffer) return "none";
  if (isGifBuffer(buffer)) return "gif";
  if (isWebmBuffer(buffer)) return "webm";
  if (buffer.length >= 8 && buffer.subarray(1, 4).toString("ascii") === "PNG") return "png";
  if (buffer[0] === 0xff && buffer[1] === 0xd8) return "jpg";
  if (buffer[0] === 0x1f && buffer[1] === 0x8b) return "gzip/tgs";
  return `other:${buffer.subarray(0, 8).toString("hex")}`;
}

async function probeWebmAlpha(buffer: Buffer): Promise<string> {
  const tmpBase = path.join(os.tmpdir(), `telebox_quote_alpha_${Date.now()}_${Math.random().toString(16).slice(2)}`);
  const input = `${tmpBase}.webm`;
  try {
    fs.writeFileSync(input, buffer);
    const out = await execFileCaptureAsync("ffprobe", [
      "-v", "error",
      "-select_streams", "v:0",
      "-show_entries", "stream=pix_fmt,width,height,duration:stream_tags=alpha_mode:format=duration",
      "-of", "default=noprint_wrappers=1",
      input,
    ], 10000);
    return out.trim().replace(/\s+/g, " ") || "empty-ffprobe";
  } catch (err: any) {
    return `probe-failed:${err?.message || err}`;
  } finally {
    try { if (fs.existsSync(input)) fs.unlinkSync(input); } catch (err) {
    console.debug("[quote] waitForStableFile loop error:", err?.message || err);
  }