Method handleQuote

quote/quote.ts:1329–1410

(msg: Api.Message, command: "q" | "quote")

  };
  messages.forEach(scan);
  return out;
}

async function encodeFramesToWebm(frames: Buffer[], fps = TG_STICKER_FPS): Promise<Buffer> {
  const t0 = Date.now();
  const tmpBase = path.join(os.tmpdir(), `telebox_quote_webm_${Date.now()}_${Math.random().toString(16).slice(2)}`);
  const dir = `${tmpBase}_frames`;
  const outputFor = (crf: number) => `${tmpBase}_${crf}.webm`;
  const outputs: string[] = [];
  try {
    fs.mkdirSync(dir, { recursive: true });
    const tw = Date.now();
    frames.forEach((frame, i) => fs.writeFileSync(path.join(dir, `frame_${String(i + 1).padStart(3, "0")}.png`), frame));
    quoteTiming("webm.write_frames", tw, { frames: frames.length });

    let best: Buffer | undefined;
    let bestCrf = WEBM_CRF_STEPS[0];
    for (const crf of WEBM_CRF_STEPS) {
      const output = outputFor(crf);
      outputs.push(output);
      const te = Date.now();
      await execFileAsync("ffmpeg", [
        "-hide_banner", "-loglevel", "error", "-y",
        "-framerate", String(fps),
        "-i", path.join(dir, "frame_%03d.png"),
        "-vf", "split[v][a];[a]alphaextract[alpha];[v][alpha]alphamerge,format=yuva420p",
        "-an", "-c:v", "libvpx-vp9",
        "-deadline", "good", "-cpu-used", "4",
        "-b:v", "0", "-crf", String(crf),
        "-row-mt", "1", "-tile-columns", "1",
        "-auto-alt-ref", "0", "-pix_fmt", "yuva420p",
        "-metadata:s:v:0", "alpha_mode=1",
        output,
      ], 30000);
      const encoded = fs.readFileSync(output);
      quoteTiming("webm.ffmpeg_encode", te, { frames: frames.length, fps, crf, bytes: encoded.length });
      best = encoded;
      bestCrf = crf;
      if (encoded.length <= TG_STICKER_MAX_BYTES) break;
    }
    quoteTiming("webm.encode_total", t0, { frames: frames.length, bytes: best?.length || 0, crf: bestCrf });
    return best || Buffer.alloc(0);
  } finally {
    for (const output of outputs) try { if (fs.existsSync(output)) fs.unlinkSync(output); } catch (err: any) {
    console.debug("[quote] waitForStableFile loop error:", err?.message || err);
  }
    try { if (fs.existsSync(dir)) fs.rmSync(dir, { recursive: true, force: true }); } catch (err: any) {
    console.debug("[quote] waitForStableFile loop error:", err?.message || err);
  }
  }
}
async function generateAnimatedQuoteWebm(quoteMessages: any[], args: QuoteArgs): Promise<{ image: Buffer; ext: string; width?: number; height?: number; duration?: number }> {
  const t0 = Date.now();
  const emojiIds = collectAnimatedEmojiIds(quoteMessages);
  const mediaMessages = collectAnimatedMediaMessages(quoteMessages);
  const sources: { kind: "emoji" | "media"; key: string | any; raw: Buffer; size: number; info: { fps: number; duration: number } }[] = [];

  const rawSources = [