Function waitForStableFile

quote/quote.ts:589–612

(filePath: string, timeoutMs = 8000)

  const key = JSON.stringify(peer, (_, v) => typeof v === "bigint" ? v.toString() : v);
  if (entityCache.has(key)) return entityCache.get(key);
  try {
    const entity = await withTimeout(client.getEntity(peer), QUOTE_RPC_TIMEOUT_MS, "getPeerEntity.getEntity");
    entityCache.set(key, entity);
    return entity;
  } catch (_) {
    entityCache.set(key, undefined);
    return undefined;
  }
}

async function ensureFullEntity(client: any, entity: any): Promise<any> {
  if (!entity || !client) return entity;
  if (entity.id && entity.emojiStatus === undefined && entity.emoji_status === undefined) {
    try {
      const full = await withTimeout(client.getEntity(entity), QUOTE_RPC_TIMEOUT_MS, "ensureFullEntity");
      return full || entity;
    } catch { return entity; }
  }
  return entity;
}

async function senderEntity(msg: Api.Message): Promise<any | undefined> {
  const peer = (msg as any).senderId ?? (msg as any).fromId;
  const key = peer ? `sender:${stableEntityKey(peer)}` : undefined;
  if (key && entityCache.has(key)) return entityCache.get(key);
  try {
    const sender = await withTimeout((msg as any).getSender?.(), QUOTE_RPC_TIMEOUT_MS, "senderEntity.getSender");