Function getFullChannelHistory

server/src/slack/client.ts:1274–1314

(
  channelId: string,
  options: {
    oldest?: string;  // Unix timestamp - only messages after this time
    latest?: string;  // Unix timestamp - only messages before this time
    maxMessages?: number;  // Stop after this many messages (default: no limit)
    onProgress?: (count: number) => void;  // Callback for progress updates
  } = {}
)

 * @returns Array of all messages in the time range
 */
export async function getFullChannelHistory(
  channelId: string,
  options: {
    oldest?: string;  // Unix timestamp - only messages after this time
    latest?: string;  // Unix timestamp - only messages before this time
    maxMessages?: number;  // Stop after this many messages (default: no limit)
    onProgress?: (count: number) => void;  // Callback for progress updates
  } = {}
): Promise<SlackHistoryMessage[]> {
  const allMessages: SlackHistoryMessage[] = [];
  let cursor: string | undefined;
  const maxMessages = options.maxMessages ?? Infinity;

  do {
    const result = await getChannelHistory(channelId, {
      oldest: options.oldest,
      latest: options.latest,
      limit: 200,  // Fetch in larger batches for efficiency
      cursor,
    });

    allMessages.push(...result.messages);

    if (options.onProgress) {
      options.onProgress(allMessages.length);
    }

    if (allMessages.length >= maxMessages) {
      break;
    }

    cursor = result.nextCursor;

    if (cursor) {
      await sleep(RATE_LIMIT_DELAY_MS);
    }
  } while (cursor);

  logger.debug({ channelId, messageCount: allMessages.length }, 'Fetched full channel history');
  return allMessages.slice(0, maxMessages);
}