File size: 1,163 Bytes
f76c374 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 | export interface CronTriggerRunResult<T> {
started: boolean
value: T | null
}
export interface CronTriggerController {
isRunning(key: string): boolean
run<T>(key: string, action: () => Promise<T>, onStarted?: () => void): Promise<CronTriggerRunResult<T>>
}
// This is an interaction guard for one mounted UI surface. Cross-window and
// cross-process exclusion remains the backend's responsibility via its durable
// cron claim; a renderer-local Set must never be treated as the execution lock.
export function createCronTriggerController(
onRunningChange: (key: string, running: boolean) => void = () => undefined
): CronTriggerController {
const running = new Set<string>()
return {
isRunning: key => running.has(key),
async run<T>(key: string, action: () => Promise<T>, onStarted?: () => void) {
if (running.has(key)) {
return { started: false, value: null }
}
running.add(key)
try {
onRunningChange(key, true)
onStarted?.()
return { started: true, value: await action() }
} finally {
running.delete(key)
onRunningChange(key, false)
}
}
}
}
|