Function collectMessagesOnce

biko/biko.ts:374–418

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

  manualScanLimit?: number,
): Promise<DigestRecord[]> {
  const records: DigestRecord[] = [];
  const iterParams: Record<string, any> = {
    limit: sourceUser.manualMode
      ? (manualScanLimit ??
        Math.min(
          Math.max(requestedCount * 20, requestedCount + 50),
          MAX_SCAN_LIMIT,
        ))
      : requestedCount,
  };

  if (!sourceUser.manualMode) {
    iterParams.fromUser = sourceUser.entity;
  }

  const iterator = client.iterMessages(sourceChat.entity, iterParams);

  for await (const message of iterator) {
    const current = message as any;

    if (sourceUser.manualMode) {
      const matched = await matchesManualSelector(current, sourceUser);
      if (!matched) continue;
    }

    const { day, time } = formatDateParts(current?.date);
    records.push({
      day,
      time,
      text: compactMessageText(buildMessageText(current)),
      link: buildChatMessageLink(sourceChat.entity, Number(current?.id)),
    });

    if (records.length >= requestedCount) break;
  }

  return records.reverse();
}

async function collectMessages(
  client: any,
  sourceChat: ResolvedChat,
  sourceUser: ResolvedSourceUser,
  requestedCount: number,
): Promise<DigestRecord[]> {
  const initialRecords = await collectMessagesOnce(
    client,
    sourceChat,