Function fetchSlackMessagesPaginated

apps/sim/tools/slack/utils.ts:121–192

(
  opts: SlackPaginateOptions
)

 * the `ok` field is checked on every page.
 */
export async function fetchSlackMessagesPaginated(
  opts: SlackPaginateOptions
): Promise<SlackPaginateResult> {
  const { token, method, baseParams, limit, maxPages, missingScopeHint } = opts
  const perPage = Math.min(Math.max(Number(limit) || 0, 1), SLACK_PAGE_MAX)

  const messages: any[] = []
  let cursor = opts.cursor?.trim() || undefined
  let nextCursor: string | null = null
  let pages = 0

  while (pages < maxPages) {
    const url = new URL(`https://slack.com/api/${method}`)
    for (const [key, value] of Object.entries(baseParams)) {
      const trimmed = typeof value === 'string' ? value.trim() : value
      if (trimmed) url.searchParams.append(key, String(trimmed))
    }
    url.searchParams.append('limit', String(perPage))
    if (cursor) url.searchParams.append('cursor', cursor)

    let response: Response
    let attempt = 0
    while (true) {
      response = await fetch(url.toString(), {
        method: 'GET',
        headers: { Authorization: `Bearer ${token}` },
      })

      if (response.status === 429 && attempt < SLACK_RATE_LIMIT_MAX_RETRIES) {
        attempt += 1
        const retryAfter = parseRetryAfter(response.headers.get('retry-after')) ?? 1000
        await sleep(retryAfter)
        continue
      }
      break
    }

    const data = await response.json()

    if (!data.ok) {
      if (data.error === 'missing_scope') {
        throw new Error(
          `Missing required permissions. Please reconnect your Slack account with the necessary scopes (${missingScopeHint}).`
        )
      }
      if (data.error === 'invalid_auth') {
        throw new Error('Invalid authentication. Please check your Slack credentials.')
      }
      if (data.error === 'channel_not_found') {
        throw new Error('Channel not found. Please check the channel ID.')
      }
      if (data.error === 'ratelimited') {
        throw new Error('Slack rate limit exceeded. Please retry in a moment.')
      }
      throw new Error(data.error || `Failed to call ${method}`)
    }

    for (const msg of data.messages ?? []) messages.push(mapSlackMessage(msg))