Function claimCooldown

apps/sim/lib/workspace-events/state.ts:41–67

(
  workflowId: string,
  blockId: string,
  scopeKey: string,
  cooldownMs: number
)

 * deployment version).
 */
export async function claimCooldown(
  workflowId: string,
  blockId: string,
  scopeKey: string,
  cooldownMs: number
): Promise<boolean> {
  const now = new Date()
  const threshold = new Date(now.getTime() - cooldownMs)

  const rows = await db
    .insert(simTriggerState)
    .values({
      workflowId,
      blockId,
      scopeKey,
      lastFiredAt: now,
      updatedAt: now,
    })
    .onConflictDoUpdate({
      target: [simTriggerState.workflowId, simTriggerState.blockId, simTriggerState.scopeKey],
      set: { lastFiredAt: now, updatedAt: now },
      setWhere: sql`${simTriggerState.lastFiredAt} IS NULL OR ${simTriggerState.lastFiredAt} < ${threshold}`,
    })
    .returning({ workflowId: simTriggerState.workflowId })

  return rows.length > 0
}

export function isWithinCooldown(lastFiredAt: Date | null, cooldownMs: number): boolean {
  if (!lastFiredAt) return false