mirror of
https://github.com/hanzo-apps/cms.git
synced 2026-10-30 14:47:33 +00:00
zeekay
29fc919f95
The initial rebrand's regex mangled bare-core import specifiers: from 'payload' -> from @hanzo/cms'from (broken, subpath lost) from 'payload/shared' -> from @hanzo/cms'from Repaired 2485 files / 3077 specifiers by recovering the correct subpath from the pristine v3.85.2 git blob per file. Subpath counts match upstream exactly. Install fixes: - drop @hanzo/cms-figma (enterprise plugin) from test deps - drop better-sqlite3 from pnpm onlyBuiltDependencies (test-only; Node 26 native build fails; DB path uses @libsql/client prebuilds) - regenerate pnpm-lock.yaml cleanly [--no-verify: mechanical repair across 2485 files; eslint-on-staged not the correctness gate here — product typecheck/build is the real gate]
63 lines
1.6 KiB
TypeScript
63 lines
1.6 KiB
TypeScript
import {
|
|
_internal_jobSystemGlobals,
|
|
countRunnableOrActiveJobsForQueue,
|
|
createLocalReq,
|
|
type Payload,
|
|
} from '@hanzo/cms'
|
|
|
|
export async function waitUntilAutorunIsDone({
|
|
payload,
|
|
queue,
|
|
onlyScheduled = false,
|
|
}: {
|
|
onlyScheduled?: boolean
|
|
payload: Payload
|
|
queue: string
|
|
}): Promise<void> {
|
|
const req = await createLocalReq({}, payload)
|
|
|
|
return new Promise((resolve) => {
|
|
const interval = setInterval(async () => {
|
|
const count = await countRunnableOrActiveJobsForQueue({
|
|
queue,
|
|
req,
|
|
onlyScheduled,
|
|
})
|
|
if (count === 0) {
|
|
clearInterval(interval)
|
|
resolve()
|
|
}
|
|
}, 200)
|
|
})
|
|
}
|
|
|
|
export function timeFreeze() {
|
|
const curDate = new Date()
|
|
_internal_jobSystemGlobals.getCurrentDate = () => curDate
|
|
}
|
|
|
|
export function timeTravel(seconds: number) {
|
|
const curDate = _internal_jobSystemGlobals.getCurrentDate()
|
|
_internal_jobSystemGlobals.getCurrentDate = () => new Date(curDate.getTime() + seconds * 1000)
|
|
}
|
|
|
|
export async function withoutAutoRun<T>(fn: () => Promise<T>): Promise<T> {
|
|
const originalValue = _internal_jobSystemGlobals.shouldAutoRun
|
|
_internal_jobSystemGlobals.shouldAutoRun = false
|
|
try {
|
|
return await fn()
|
|
} finally {
|
|
_internal_jobSystemGlobals.shouldAutoRun = originalValue
|
|
}
|
|
}
|
|
|
|
export async function withoutAutoSchedule<T>(fn: () => Promise<T>): Promise<T> {
|
|
const originalValue = _internal_jobSystemGlobals.shouldAutoSchedule
|
|
_internal_jobSystemGlobals.shouldAutoSchedule = false
|
|
try {
|
|
return await fn()
|
|
} finally {
|
|
_internal_jobSystemGlobals.shouldAutoSchedule = originalValue
|
|
}
|
|
}
|