Function withCascadeLock

apps/sim/lib/table/cascade-lock.ts:36–61

(
  tableId: string,
  rowId: string,
  ownerId: string,
  fn: () => Promise<T>
)

 * doesn't prevent duplicate workflow executions.
 */
export async function withCascadeLock<T>(
  tableId: string,
  rowId: string,
  ownerId: string,
  fn: () => Promise<T>
): Promise<{ status: 'acquired'; result: T } | { status: 'contended' }> {
  const key = cascadeLockKey(tableId, rowId)
  const acquired = await acquireLock(key, ownerId, LOCK_TTL_SECONDS)
  if (!acquired) return { status: 'contended' }

  const heartbeat = setInterval(() => {
    extendLock(key, ownerId, LOCK_TTL_SECONDS).catch((err) => {
      logger.warn(`Heartbeat refresh failed for ${key}`, { error: toError(err).message })
    })
  }, HEARTBEAT_INTERVAL_MS)

  try {
    const result = await fn()
    return { status: 'acquired', result }
  } finally {
    clearInterval(heartbeat)
    await releaseLock(key, ownerId).catch((err) => {
      logger.warn(`Lock release failed for ${key}`, { error: toError(err).message })
    })
  }
}