policy: increase tests via permutation matrix

PR-URL: #34404
Reviewed-By: James M Snell <jasnell@gmail.com>

lib/internal/modules/cjs/loader.js

@@ -262,18 +262,13 @@ function readPackage(requestPath) {
   const existing = packageJsonCache.get(jsonPath);
   if (existing !== undefined) return existing;
 
-  const result = packageJsonReader.read(path.toNamespacedPath(jsonPath));
+  const result = packageJsonReader.read(jsonPath);
   const json = result.containsKeys === false ? '{}' : result.string;
   if (json === undefined) {
     packageJsonCache.set(jsonPath, false);
     return false;
   }
 
-  if (manifest) {
-    const jsonURL = pathToFileURL(jsonPath);
-    manifest.assertIntegrity(jsonURL, json);
-  }
-
   try {
     const parsed = JSONParse(json);
     const filtered = {

lib/internal/modules/esm/get_source.js

@@ -1,5 +1,10 @@
 'use strict';
 
+const { getOptionValue } = require('internal/options');
+const manifest = getOptionValue('--experimental-policy') ?
+  require('internal/process/policy').manifest :
+  null;
+
 const { Buffer } = require('buffer');
 
 const fs = require('fs');
@@ -15,20 +20,22 @@ const DATA_URL_PATTERN = /^[^/]+\/[^,;]+(?:[^,]*?)(;base64)?,([\s\S]*)$/;
 
 async function defaultGetSource(url, { format } = {}, defaultGetSource) {
   const parsed = new URL(url);
+  let source;
   if (parsed.protocol === 'file:') {
-    return {
-      source: await readFileAsync(parsed)
-    };
+    source = await readFileAsync(parsed);
   } else if (parsed.protocol === 'data:') {
     const match = DATA_URL_PATTERN.exec(parsed.pathname);
     if (!match) {
       throw new ERR_INVALID_URL(url);
     }
     const [ , base64, body ] = match;
-    return {
-      source: Buffer.from(body, base64 ? 'base64' : 'utf8')
-    };
+    source = Buffer.from(body, base64 ? 'base64' : 'utf8');
+  } else {
+    throw new ERR_INVALID_URL_SCHEME(['file', 'data']);
+  }
+  if (manifest) {
+    manifest.assertIntegrity(parsed, source);
   }
-  throw new ERR_INVALID_URL_SCHEME(['file', 'data']);
+  return { source };
 }
 exports.defaultGetSource = defaultGetSource;

lib/internal/modules/package_json_reader.js

@@ -2,21 +2,35 @@
 
 const { SafeMap } = primordials;
 const { internalModuleReadJSON } = internalBinding('fs');
+const { pathToFileURL } = require('url');
+const { toNamespacedPath } = require('path');
 
 const cache = new SafeMap();
 
 /**
  *
- * @param {string} path
+ * @param {string} jsonPath
  */
-function read(path) {
-  if (cache.has(path)) {
-    return cache.get(path);
+function read(jsonPath) {
+  if (cache.has(jsonPath)) {
+    return cache.get(jsonPath);
   }
 
-  const [string, containsKeys] = internalModuleReadJSON(path);
+  const [string, containsKeys] = internalModuleReadJSON(
+    toNamespacedPath(jsonPath)
+  );
   const result = { string, containsKeys };
-  cache.set(path, result);
+  const { getOptionValue } = require('internal/options');
+  if (string !== undefined) {
+    const manifest = getOptionValue('--experimental-policy') ?
+      require('internal/process/policy').manifest :
+      null;
+    if (manifest) {
+      const jsonURL = pathToFileURL(jsonPath);
+      manifest.assertIntegrity(jsonURL, string);
+    }
+  }
+  cache.set(jsonPath, result);
   return result;
 }
 

lib/internal/worker.js

@@ -205,6 +205,9 @@ class Worker extends EventEmitter {
       cwdCounter: cwdCounter || workerIo.sharedCwdCounter,
       workerData: options.workerData,
       publicPort: port2,
+      manifestURL: getOptionValue('--experimental-policy') ?
+        require('internal/process/policy').url :
+        null,
       manifestSrc: getOptionValue('--experimental-policy') ?
         require('internal/process/policy').src :
         null,