Function resolveNodeImportInternal

src/node.ts:29–55

(cacheRoot: string, packageRoot: string, spec: string)

const bundlePromises = new Map<string, Promise<string>>();

async function resolveNodeImportInternal(cacheRoot: string, packageRoot: string, spec: string): Promise<string> {
  const {name, path = "."} = parseNpmSpecifier(spec);
  const require = createRequire(pathToFileURL(op.join(packageRoot, "/")));
  const pathResolution = require.resolve(spec);
  const packageResolution = await packageDirectory({cwd: op.dirname(pathResolution)});
  if (!packageResolution) throw new Error(`unable to resolve package.json: ${spec}`);
  const {version} = JSON.parse(await readFile(op.join(packageResolution, "package.json"), "utf-8"));
  const resolution = `${name}@${version}/${extname(path) ? path : path === "." ? "index.js" : `${path}.js`}`;
  const outputPath = op.join(cacheRoot, toOsPath(resolution));
  const resolutionPath = `/_node/${resolution}`;
  if (existsSync(outputPath)) return resolutionPath;
  let promise = bundlePromises.get(outputPath);
  if (promise) return promise; // coalesce concurrent requests
  promise = (async () => {
    console.log(`${spec} ${faint("→")} ${outputPath}`);
    await prepareOutput(outputPath);
    if (isJavaScript(pathResolution)) {
      await writeFile(outputPath, await bundle(resolutionPath, spec, require, cacheRoot, packageResolution), "utf-8");
    } else {
      await copyFile(pathResolution, outputPath);
    }
    return resolutionPath;
  })();
  promise.catch(console.error).then(() => bundlePromises.delete(outputPath));
  bundlePromises.set(outputPath, promise);
  return promise;
}

/**
 * Resolves the direct dependencies of the specified node import path, such as