Function pollNoActivityEvents

apps/sim/lib/workspace-events/no-activity.ts:249–274

()

 * never executed fires once, then respects the cooldown.
 */
export async function pollNoActivityEvents(): Promise<NoActivityPollResult> {
  const result: NoActivityPollResult = { subscriptions: 0, checked: 0, fired: 0, skipped: 0 }

  let cursor: string | null = null
  while (true) {
    const page = await fetchNoActivitySubscriptionPage(cursor)
    if (page.length === 0) break

    result.subscriptions += page.length
    cursor = page[page.length - 1].webhook.id

    for (const subscription of page) {
      await checkSubscription(subscription, result)
    }

    if (page.length < NO_ACTIVITY_SUBSCRIPTION_PAGE_SIZE) break
  }

  if (result.subscriptions === 0) return result

  logger.info(
    `no_activity poll completed: ${result.fired} fired, ${result.skipped} skipped of ${result.checked} checked`
  )

  return result
}