Function checkSubscription

apps/sim/lib/workspace-events/no-activity.ts:208–236

* Checks a single no_activity subscription's watched workflows and fires * events for the inactive ones, accumulating counts into `result`. The * watched-workflow scan is keyset-paginated, so coverage is complete even in * workspaces with more workflows than one page.

(
  subscription: SimSubscription,
  result: NoActivityPollResult
)

 * workspaces with more workflows than one page.
 */
async function checkSubscription(
  subscription: SimSubscription,
  result: NoActivityPollResult
): Promise<void> {
  const config = parseSubscriptionConfig(subscription.webhook.providerConfig)
  if (!config || config.eventType !== 'no_activity') return

  const workspaceId = subscription.workflow.workspaceId
  if (!workspaceId) return

  let cursor: string | null = null
  while (true) {
    const page = await fetchWatchedWorkflowPage(
      workspaceId,
      subscription.webhook.workflowId,
      config,
      cursor
    )
    if (page.length === 0) break

    cursor = page[page.length - 1].id

    for (const sourceWorkflow of page) {
      await checkWatchedWorkflow(subscription, config, sourceWorkflow, result)
    }

    if (page.length < NO_ACTIVITY_WORKFLOW_PAGE_SIZE) break
  }
}

/**
 * Checks every no_activity subscription and fires side-effect workflows for