Something went wrong. Try again.
opencode v2 mirror
Something went wrong. Try again.
TypeScript
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788type QueueInput = { paused: () => boolean bootstrap: () => Promise<void> bootstrapInstance: (directory: string) => Promise<void> | void key?: (directory: string) => string}
export function createRefreshQueue(input: QueueInput) { const queued = new Map<string, string>() let root = false let running = false let timer: ReturnType<typeof setTimeout> | undefined
const key = input.key ?? ((directory: string) => directory)
const tick = () => new Promise<void>((resolve) => setTimeout(resolve, 0))
const take = (count: number) => { if (queued.size === 0) return [] as string[] const items: string[] = [] for (const [id, directory] of queued) { queued.delete(id) items.push(directory) if (items.length >= count) break } return items }
const schedule = () => { if (timer) return timer = setTimeout(() => { timer = undefined void drain() }, 0) }
const push = (directory: string) => { if (!directory) return queued.set(key(directory), directory) if (input.paused()) return schedule() }
const refresh = () => { root = true if (input.paused()) return schedule() }
async function drain() { if (running) return running = true try { while (true) { if (input.paused()) return if (root) { root = false await input.bootstrap() await tick() continue } const dirs = take(2) if (dirs.length === 0) return await Promise.all(dirs.map((dir) => input.bootstrapInstance(dir))) await tick() } } finally { running = false // oxlint-disable-next-line no-unsafe-finally -- intentional: early return skips schedule() when paused if (input.paused()) return if (root || queued.size) schedule() } }
return { push, refresh, clear(directory: string) { queued.delete(key(directory)) }, dispose() { if (!timer) return clearTimeout(timer) timer = undefined }, }}