fix: async-mutex not exclusively locking correectly

Jacky Zhao

2023-08-21 b69556c918e2a4a27b047e8de6b02861f04d5a9e

fix: async-mutex not exclusively locking correectly

 content/layout.md

@@ -30,7 +30,7 @@

Quartz **components**, like plugins, can take in additional properties as configuration options. If you're familiar with React terminology, you can think of them as Higher-order Components.

See [a list of all the components](./tags/component) for all available components along with their configuration options. You can also checkout the guide on [[creating components]] if you're interested in further customizing the behaviour of Quartz.
See [a list of all the components](component.md) for all available components along with their configuration options. You can also checkout the guide on [[creating components]] if you're interested in further customizing the behaviour of Quartz.

### Style


 quartz/bootstrap-cli.mjs

@@ -394,8 +394,15 @@

    const buildMutex = new Mutex()
    const timeoutIds = new Set()
    let firstBuild = true
    const build = async (clientRefresh) => {
      await buildMutex.acquire()
      const release = await buildMutex.acquire()
      if (firstBuild) {
        firstBuild = false
      } else {
        console.log(chalk.yellow("Detected a source code change, doing a hard rebuild..."))
      }

      const result = await ctx.rebuild().catch((err) => {
        console.error(`${chalk.red("Couldn't parse Quartz configuration:")} ${fp}`)
        console.log(`Reason: ${chalk.grey(err)}`)
@@ -418,7 +425,7 @@
      const { default: buildQuartz } = await import(cacheFile + `?update=${randomUUID()}`)
      await buildQuartz(argv, clientRefresh)
      clientRefresh()
      buildMutex.release()
      release()
    }

    const rebuild = (clientRefresh) => {
@@ -526,7 +533,6 @@
          ignoreInitial: true,
        })
        .on("all", async () => {
          console.log(chalk.yellow("Detected a source code change, doing a hard rebuild..."))
          rebuild(clientRefresh)
        })
    } else {

 quartz/build.ts

@@ -108,12 +108,13 @@
      toRemove.add(filePath)
    }

    timeoutIds.forEach((id) => clearTimeout(id))

    // debounce rebuilds every 250ms
    timeoutIds.add(
      setTimeout(async () => {
        await buildMutex.acquire()
        const release = await buildMutex.acquire()
        timeoutIds.forEach((id) => clearTimeout(id))
        timeoutIds.clear()

        const perf = new PerfTimer()
        console.log(chalk.yellow("Detected change, rebuilding..."))
        try {
@@ -134,6 +135,8 @@
            contentMap.delete(fp)
          }

          // TODO: we can probably traverse the link graph to figure out what's safe to delete here
          // instead of just deleting everything
          await rimraf(argv.output)
          const parsedFiles = [...contentMap.values()]
          const filteredContent = filterContent(ctx, parsedFiles)
@@ -146,7 +149,7 @@
        clientRefresh()
        toRebuild.clear()
        toRemove.clear()
        buildMutex.release()
        release()
      }, 250),
    )
  }