fix: handle parallel installs

Author: merceyz

.github/workflows/ci.yml

@@ -32,6 +32,9 @@ jobs:
         env:
           TARGET_BRANCH: ${{github.event.pull_request.base.ref}}
 
+      - name: 'Check for type errors'
+        run: yarn typecheck
+
   build:
     strategy:
       fail-fast: false

.pnp.cjs

@@ -55,7 +55,7 @@ async function main() {
   const remapPath = (p: string) => path.resolve(__dirname, path.relative(virtualNodewinDir, p));
 
   const easyStatFs = Object.assign(Object.create(fs), {
-    readFile: (p: string, encoding: string, cb: (err: any, str: string) => void) => fs.readFile(remapPath(p), encoding, cb),
+    readFile: (p: string, encoding: BufferEncoding, cb: (err: any, str: string) => void) => fs.readFile(remapPath(p), encoding, cb),
     stat: (p: string, cb: () => void) => fs.stat(remapPath(p), cb),
   });
 

.yarn/cache/@types-glob-npm-7.2.0-772334bf9a-6ae717fedf.zip

@@ -27,7 +27,8 @@
     "@babel/preset-typescript": "^7.13.0",
     "@types/debug": "^4.1.5",
     "@types/jest": "^26.0.23",
-    "@types/node": "^13.9.2",
+    "@types/node": "^17.0.10",
+    "@types/rimraf": "^3.0.2",
     "@types/semver": "^7.1.0",
     "@types/tar": "^4.0.3",
     "@types/which": "^1.3.2",
@@ -43,6 +44,7 @@
     "eslint-plugin-arca": "^0.9.5",
     "jest": "^26.0.0",
     "nock": "^13.0.4",
+    "rimraf": "^3.0.2",
     "semver": "^7.1.3",
     "supports-color": "^7.1.0",
     "tar": "^6.0.1",
@@ -60,6 +62,7 @@
     "corepack": "ts-node ./sources/main.ts",
     "prepack": "node ./.yarn/releases/*.*js build",
     "postpack": "rm -rf dist shims",
+    "typecheck": "tsc --noEmit",
     "test": "yarn jest"
   },
   "files": [

.yarn/cache/@types-minimatch-npm-3.0.5-802bb0797f-c41d136f67.zip

@@ -87,39 +87,50 @@ export async function installVersion(installTarget: string, locator: Locator, {s
   const url = spec.url.replace(`{}`, locator.reference);
   debugUtils.log(`Installing ${locator.name}@${locator.reference} from ${url}`);
 
-  return await fsUtils.mutex(installFolder, async () => {
-    // Creating a temporary folder inside the install folder means that we
-    // are sure it'll be in the same drive as the destination, so we can
-    // just move it there atomically once we are done
+  // Creating a temporary folder inside the install folder means that we
+  // are sure it'll be in the same drive as the destination, so we can
+  // just move it there atomically once we are done
 
-    const tmpFolder = folderUtils.getTemporaryFolder(installTarget);
-    const stream = await httpUtils.fetchUrlStream(url);
+  const tmpFolder = folderUtils.getTemporaryFolder(installTarget);
+  const stream = await httpUtils.fetchUrlStream(url);
 
-    const parsedUrl = new URL(url);
-    const ext = path.posix.extname(parsedUrl.pathname);
+  const parsedUrl = new URL(url);
+  const ext = path.posix.extname(parsedUrl.pathname);
 
-    let outputFile: string | null = null;
+  let outputFile: string | null = null;
 
-    let sendTo: any;
-    if (ext === `.tgz`) {
-      sendTo = tar.x({strip: 1, cwd: tmpFolder});
-    } else if (ext === `.js`) {
-      outputFile = path.join(tmpFolder, path.posix.basename(parsedUrl.pathname));
-      sendTo = fs.createWriteStream(outputFile);
-    }
+  let sendTo: any;
+  if (ext === `.tgz`) {
+    sendTo = tar.x({strip: 1, cwd: tmpFolder});
+  } else if (ext === `.js`) {
+    outputFile = path.join(tmpFolder, path.posix.basename(parsedUrl.pathname));
+    sendTo = fs.createWriteStream(outputFile);
+  }
 
-    stream.pipe(sendTo);
+  stream.pipe(sendTo);
 
-    await new Promise(resolve => {
-      sendTo.on(`finish`, resolve);
-    });
+  await new Promise(resolve => {
+    sendTo.on(`finish`, resolve);
+  });
 
-    await fs.promises.mkdir(path.dirname(installFolder), {recursive: true});
+  await fs.promises.mkdir(path.dirname(installFolder), {recursive: true});
+  try {
     await fs.promises.rename(tmpFolder, installFolder);
+  } catch (err) {
+    if (
+      err.code === `ENOTEMPTY` ||
+      // On Windows the error code is EPERM so we check if it's because its a directory
+      (err.code === `EPERM` && (await fs.promises.stat(installFolder)).isDirectory())
+    ) {
+      debugUtils.log(`Another instance of corepack installed ${locator.name}@${locator.reference}`);
+      await fsUtils.rimraf(tmpFolder);
+    } else {
+      throw err;
+    }
+  }
 
-    debugUtils.log(`Install finished`);
-    return installFolder;
-  });
+  debugUtils.log(`Install finished`);
+  return installFolder;
 }
 
 export async function runVersion(installSpec: { location: string, spec: PackageManagerSpec }, locator: Locator, binName: string, args: Array<string>, context: Context) {