| | |
| | | }) |
| | | |
| | | const buildMutex = new Mutex() |
| | | const timeoutIds = new Set() |
| | | let lastBuildMs = 0 |
| | | let cleanupBuild = null |
| | | const build = async (clientRefresh) => { |
| | | const buildStart = new Date().getTime() |
| | | lastBuildMs = buildStart |
| | | const release = await buildMutex.acquire() |
| | | if (lastBuildMs > buildStart) { |
| | | release() |
| | | return |
| | | } |
| | | |
| | | if (cleanupBuild) { |
| | | await cleanupBuild() |
| | |
| | | clientRefresh() |
| | | } |
| | | |
| | | const rebuild = (clientRefresh) => { |
| | | timeoutIds.forEach((id) => clearTimeout(id)) |
| | | timeoutIds.clear() |
| | | timeoutIds.add(setTimeout(() => build(clientRefresh), 250)) |
| | | } |
| | | |
| | | if (argv.serve) { |
| | | const connections = [] |
| | | const clientRefresh = () => connections.forEach((conn) => conn.send("rebuild")) |
| | |
| | | ignoreInitial: true, |
| | | }) |
| | | .on("all", async () => { |
| | | rebuild(clientRefresh) |
| | | build(clientRefresh) |
| | | }) |
| | | } else { |
| | | await build(() => {}) |