Function toQuoteMessage

quote/quote.ts:1211–1261

(msg: Api.Message, args: QuoteArgs)

  try {
    return await withTimeout(client.invoke(new (Api as any).messages.GetCustomEmojiDocuments({ documentId: unique.map((id) => BigInt(id)) })), QUOTE_RPC_TIMEOUT_MS, "getCustomEmojiDocuments.invoke");
  } catch (err: any) {
    console.warn("quote custom emoji fetch failed", err?.message || err);
    return [];
  }
}

async function hydrateCustomEmojiBuffers(client: any, messages: any[]): Promise<void> {
  const ids: string[] = [];
  const scanEntity = (entity: any) => {
    const id = entity?.custom_emoji_id;
    if (id && !customEmojiCache.get(String(id))) ids.push(String(id));
  };
  const scanMessage = (message: any) => {
    (message.entities || []).forEach(scanEntity);
    (message.caption_entities || []).forEach(scanEntity);
    const statusId = message.from?.emoji_status?.custom_emoji_id || message.from?.emoji_status?.customEmojiId || message.emoji_status?.custom_emoji_id || message.emoji_status?.customEmojiId;
    if (statusId && !customEmojiCache.get(String(statusId))) ids.push(String(statusId));
    if (message.replyMessage) scanMessage(message.replyMessage);
    if (message.forward) scanMessage(message.forward);
  };
  messages.forEach(scanMessage);
  const docs = await getCustomEmojiDocuments(client, ids);
  await runWithConcurrency(docs, EMOJI_FETCH_CONCURRENCY, async (doc: any) => {
    const id = String(doc.id ?? doc.documentId ?? doc.document_id ?? "");
    if (!id) return;
    let rawBuffer = await downloadCustomEmojiAnimatedPreferred(client, doc);
    const wasAnimated = looksLikeAnimatedEmoji(rawBuffer);
    if (isAnimatedRasterBuffer(rawBuffer)) animatedCustomEmojiCache.set(id, rawBuffer);
    const buffer = await normalizeCustomEmojiBuffer(rawBuffer);
    customEmojiCache.set(id, buffer);
    console.warn("quote custom emoji loaded", id, buffer ? buffer.length : 0, wasAnimated ? "animated-converted" : "static", "source", isGifBuffer(rawBuffer) ? "gif" : isWebmBuffer(rawBuffer) ? "webm" : "other", "mime", doc.mimeType || doc.mime_type || "", "thumbs", doc.thumbs?.length || 0, "videoThumbs", doc.videoThumbs?.length || doc.video_thumbs?.length || 0);
  });
  const loadedDocIds = new Set(docs.map((doc: any) => String(doc.id ?? doc.documentId ?? doc.document_id ?? "")).filter(Boolean));
  ids.forEach((id) => {
    if (!loadedDocIds.has(id)) console.warn("quote custom emoji document missing", id);
    else if (!customEmojiCache.get(id)) console.warn("quote custom emoji buffer missing", id);
  });

  const applyEntity = (entity: any) => {
    const id = entity?.custom_emoji_id;
    if (!id) return;
    const buffer = customEmojiCache.get(String(id));
    if (buffer) entity.customEmojiBuffer = buffer;
    else console.warn("quote custom emoji apply missing", String(id));
  };
  const applyMessage = (message: any) => {
    (message.entities || []).forEach(applyEntity);
    (message.caption_entities || []).forEach(applyEntity);
    const statusId = message.from?.emoji_status?.custom_emoji_id || message.from?.emoji_status?.customEmojiId || message.emoji_status?.custom_emoji_id || message.emoji_status?.customEmojiId;
    if (statusId) {
      const buffer = customEmojiCache.get(String(statusId));
      if (buffer) {
        console.warn("quote sender emoji status cached", String(statusId), buffer.length);
        if (message.from?.emoji_status) message.from.emoji_status.customEmojiBuffer = buffer;