Function collectMessages

biko/biko.ts:420–458

(
  client: any,
  sourceChat: ResolvedChat,
  sourceUser: ResolvedSourceUser,
  requestedCount: number,
)

): Promise<DigestRecord[]> {
  const initialRecords = await collectMessagesOnce(
    client,
    sourceChat,
    sourceUser,
    requestedCount,
  );

  if (!sourceUser.manualMode || initialRecords.length >= requestedCount) {
    return initialRecords;
  }

  try {
    const retriedSourceUser = await resolveSourceUser(client, sourceUser.raw);
    if (!retriedSourceUser.manualMode) {
      return await collectMessagesOnce(
        client,
        sourceChat,
        retriedSourceUser,
        requestedCount,
      );
    }
  } catch {
    // ignore and continue to deep manual scan fallback
  }

  return await collectMessagesOnce(
    client,
    sourceChat,
    sourceUser,
    requestedCount,
    MAX_SCAN_LIMIT,
  );
}

function formatDigestLine(record: DigestRecord): string {
  const prefix = `• <code>${htmlEscape(record.time)}</code> `;
  if (record.link) {
    return `${prefix}<a href="${htmlEscape(record.link)}">${htmlEscape(
      record.text,
    )}</a>`;
  }
  return `${prefix}${htmlEscape(record.text)}`;
}