Function checkWatchedWorkflow

apps/sim/lib/workspace-events/no-activity.ts:151–200

* Checks one watched workflow and fires when it has gone quiet, accumulating * counts into `result`.

(
  subscription: SimSubscription,
  config: SimSubscriptionConfig,
  sourceWorkflow: { id: string; name: string },
  result: NoActivityPollResult
)

 * counts into `result`.
 */
async function checkWatchedWorkflow(
  subscription: SimSubscription,
  config: SimSubscriptionConfig,
  sourceWorkflow: { id: string; name: string },
  result: NoActivityPollResult
): Promise<void> {
  result.checked++

  const blockKey = subscription.webhook.blockId ?? subscription.webhook.path
  const cooldownMs = noActivityCooldownMs(config)

  const lastFiredAt = await readLastFiredAt(
    subscription.webhook.workflowId,
    blockKey,
    sourceWorkflow.id
  )
  if (isWithinCooldown(lastFiredAt, cooldownMs)) {
    result.skipped++
    return
  }

  if (await hasRecentActivity(sourceWorkflow.id, config)) {
    result.skipped++
    return
  }

  const claimed = await claimCooldown(
    subscription.webhook.workflowId,
    blockKey,
    sourceWorkflow.id,
    cooldownMs
  )
  if (!claimed) {
    result.skipped++
    return
  }

  const payload = buildNoActivityEventPayload({
    workflowId: sourceWorkflow.id,
    workflowName: sourceWorkflow.name,
  })

  await dispatchSimEvent(subscription, payload)
  result.fired++

  logger.info(`no_activity event fired for workflow ${sourceWorkflow.id}`, {
    subscriberWorkflowId: subscription.webhook.workflowId,
    inactivityHours: config.inactivityHours,
  })
}

/**
 * Checks a single no_activity subscription's watched workflows and fires