src: improve package.json reader performance

Author: anonrig

lib/internal/modules/cjs/loader.js

@@ -82,7 +82,6 @@ const {
   pendingDeprecate,
   emitExperimentalWarning,
   kEmptyObject,
-  filterOwnProperties,
   setOwnProperty,
   getLazy,
 } = require('internal/util');
@@ -353,36 +352,10 @@ function initializeCJS() {
 //   -> a.<ext>
 //   -> a/index.<ext>
 
-const packageJsonCache = new SafeMap();
-
 function readPackage(requestPath) {
   const jsonPath = path.resolve(requestPath, 'package.json');
-
-  const existing = packageJsonCache.get(jsonPath);
-  if (existing !== undefined) return existing;
-
-  const result = packageJsonReader.read(jsonPath);
-  const json = result.containsKeys === false ? '{}' : result.string;
-  if (json === undefined) {
-    packageJsonCache.set(jsonPath, false);
-    return false;
-  }
-
-  try {
-    const filtered = filterOwnProperties(JSONParse(json), [
-      'name',
-      'main',
-      'exports',
-      'imports',
-      'type',
-    ]);
-    packageJsonCache.set(jsonPath, filtered);
-    return filtered;
-  } catch (e) {
-    e.path = jsonPath;
-    e.message = 'Error parsing ' + jsonPath + ': ' + e.message;
-    throw e;
-  }
+  // Return undefined or the filtered package.json as a JS object
+  return packageJsonReader.read(jsonPath);
 }
 
 let _readPackage = readPackage;
@@ -423,7 +396,7 @@ function readPackageScope(checkPath) {
 function tryPackage(requestPath, exts, isMain, originalPath) {
   const pkg = _readPackage(requestPath)?.main;
 
-  if (!pkg) {
+  if (pkg === undefined) {
     return tryExtensions(path.resolve(requestPath, 'index'), exts, isMain);
   }
 
@@ -563,7 +536,7 @@ function resolveExports(nmPath, request) {
     return;
   const pkgPath = path.resolve(nmPath, name);
   const pkg = _readPackage(pkgPath);
-  if (pkg?.exports != null) {
+  if (pkg?.exports !== undefined) {
     try {
       const { packageExportsResolve } = require('internal/modules/esm/resolve');
       return finalizeEsmResolution(packageExportsResolve(

lib/internal/modules/esm/package_config.js

@@ -1,18 +1,10 @@
 'use strict';
 
 const {
-  JSONParse,
-  ObjectPrototypeHasOwnProperty,
   SafeMap,
   StringPrototypeEndsWith,
 } = primordials;
 const { URL, fileURLToPath } = require('internal/url');
-const {
-  ERR_INVALID_PACKAGE_CONFIG,
-} = require('internal/errors').codes;
-
-const { filterOwnProperties } = require('internal/util');
-
 
 /**
  * @typedef {string | string[] | Record<string, unknown>} Exports
@@ -42,9 +34,10 @@ function getPackageConfig(path, specifier, base) {
     return existing;
   }
   const packageJsonReader = require('internal/modules/package_json_reader');
-  const source = packageJsonReader.read(path).string;
-  if (source === undefined) {
-    const packageConfig = {
+  const packageJSON = packageJsonReader.read(path);
+
+  if (packageJSON === undefined) {
+    const json = {
       pjsonPath: path,
       exists: false,
       main: undefined,
@@ -53,48 +46,19 @@ function getPackageConfig(path, specifier, base) {
       exports: undefined,
       imports: undefined,
     };
-    packageJSONCache.set(path, packageConfig);
-    return packageConfig;
-  }
-
-  let packageJSON;
-  try {
-    packageJSON = JSONParse(source);
-  } catch (error) {
-    throw new ERR_INVALID_PACKAGE_CONFIG(
-      path,
-      (base ? `"${specifier}" from ` : '') + fileURLToPath(base || specifier),
-      error.message,
-    );
+    packageJSONCache.set(path, json);
+    return json;
   }
 
-  let { imports, main, name, type } = filterOwnProperties(packageJSON, ['imports', 'main', 'name', 'type']);
-  const exports = ObjectPrototypeHasOwnProperty(packageJSON, 'exports') ? packageJSON.exports : undefined;
-  if (typeof imports !== 'object' || imports === null) {
-    imports = undefined;
-  }
-  if (typeof main !== 'string') {
-    main = undefined;
-  }
-  if (typeof name !== 'string') {
-    name = undefined;
-  }
   // Ignore unknown types for forwards compatibility
-  if (type !== 'module' && type !== 'commonjs') {
-    type = 'none';
+  if (packageJSON.type !== 'module' && packageJSON.type !== 'commonjs') {
+    packageJSON.type = 'none';
   }
 
-  const packageConfig = {
-    pjsonPath: path,
-    exists: true,
-    main,
-    name,
-    type,
-    exports,
-    imports,
-  };
-  packageJSONCache.set(path, packageConfig);
-  return packageConfig;
+  packageJSON.pjsonPath = path;
+  packageJSON.exists = true;
+  packageJSONCache.set(path, packageJSON);
+  return packageJSON;
 }
 
 

lib/internal/modules/package_json_reader.js

@@ -1,6 +1,10 @@
 'use strict';
 
-const { SafeMap } = primordials;
+const {
+  JSONParse,
+  JSONStringify,
+  SafeMap,
+} = primordials;
 const { internalModuleReadJSON } = internalBinding('fs');
 const { pathToFileURL } = require('url');
 const { toNamespacedPath } = require('path');
@@ -10,28 +14,52 @@ const cache = new SafeMap();
 let manifest;
 
 /**
- *
+ * Returns undefined for all failure cases.
  * @param {string} jsonPath
  */
 function read(jsonPath) {
   if (cache.has(jsonPath)) {
     return cache.get(jsonPath);
   }
 
-  const { 0: string, 1: containsKeys } = internalModuleReadJSON(
+  const {
+    0: includes_keys,
+    1: name,
+    2: main,
+    3: exports,
+    4: imports,
+    5: type,
+    6: shouldParseExports,
+    7: shouldParseImports,
+  } = internalModuleReadJSON(
     toNamespacedPath(jsonPath),
   );
-  const result = { string, containsKeys };
+
+  let result;
+
+  if (includes_keys !== undefined) {
+    result = { name, main, exports, imports, type, includes_keys };
+
+    // Execute JSONParse on demand for improving performance
+    if (shouldParseExports && exports !== undefined) {
+      result.exports = JSONParse(exports);
+    }
+
+    if (shouldParseImports && imports !== undefined) {
+      result.imports = JSONParse(imports);
+    }
+  }
+
   const { getOptionValue } = require('internal/options');
-  if (string !== undefined) {
+  if (name !== undefined) {
     if (manifest === undefined) {
       manifest = getOptionValue('--experimental-policy') ?
         require('internal/process/policy').manifest :
         null;
     }
     if (manifest !== null) {
       const jsonURL = pathToFileURL(jsonPath);
-      manifest.assertIntegrity(jsonURL, string);
+      manifest.assertIntegrity(jsonURL, JSONStringify(result));
     }
   }
   cache.set(jsonPath, result);

src/node_file.cc

@@ -32,8 +32,10 @@
 #include "tracing/trace_event.h"
 
 #include "req_wrap-inl.h"
+#include "simdjson.h"
 #include "stream_base-inl.h"
 #include "string_bytes.h"
+#include "v8-primitive.h"
 
 #include <fcntl.h>
 #include <sys/types.h>
@@ -1079,41 +1081,109 @@ static void InternalModuleReadJSON(const FunctionCallbackInfo<Value>& args) {
   }
 
   const size_t size = offset - start;
-  char* p = &chars[start];
-  char* pe = &chars[size];
-  char* pos[2];
-  char** ppos = &pos[0];
-
-  while (p < pe) {
-    char c = *p++;
-    if (c == '\\' && p < pe && *p == '"') p++;
-    if (c != '"') continue;
-    *ppos++ = p;
-    if (ppos < &pos[2]) continue;
-    ppos = &pos[0];
-
-    char* s = &pos[0][0];
-    char* se = &pos[1][-1];  // Exclude quote.
-    size_t n = se - s;
-
-    if (n == 4) {
-      if (0 == memcmp(s, "main", 4)) break;
-      if (0 == memcmp(s, "name", 4)) break;
-      if (0 == memcmp(s, "type", 4)) break;
-    } else if (n == 7) {
-      if (0 == memcmp(s, "exports", 7)) break;
-      if (0 == memcmp(s, "imports", 7)) break;
+  simdjson::ondemand::parser parser;
+  simdjson::padded_string json_string(chars.data() + start, size);
+  simdjson::ondemand::document document;
+  simdjson::ondemand::object obj;
+  auto error = parser.iterate(json_string).get(document);
+
+  if (error || document.get_object().get(obj)) {
+    args.GetReturnValue().Set(Array::New(isolate));
+    return;
+  }
+
+  auto js_string = [&](std::string_view sv) {
+    return ToV8Value(env->context(), sv, isolate).ToLocalChecked();
+  };
+
+  bool includes_keys{false};
+  Local<Value> name = Undefined(isolate);
+  Local<Value> main = Undefined(isolate);
+  Local<Value> exports = Undefined(isolate);
+  Local<Value> imports = Undefined(isolate);
+  Local<Value> type = Undefined(isolate);
+  bool should_parse_exports{false};
+  bool should_parse_imports{false};
+
+  // Check for "name" field
+  std::string_view name_value{};
+  if (!obj["name"].get_string().get(name_value)) {
+    name = js_string(name_value);
+    includes_keys = true;
+  }
+
+  // Check for "main" field
+  std::string_view main_value{};
+  if (!obj["main"].get_string().get(main_value)) {
+    main = js_string(main_value);
+    includes_keys = true;
+  }
+
+  // Check for "exports" field
+  simdjson::ondemand::value exports_value{};
+  if (!obj["exports"].get(exports_value)) {
+    simdjson::ondemand::json_type exports_type{};
+    if (!exports_value.type().get(exports_type)) {
+      std::string_view exports_string_value{};
+      if (exports_type == simdjson::ondemand::json_type::string) {
+        if (!exports_value.get_string().get(exports_string_value)) {
+          exports = js_string(exports_string_value);
+          includes_keys = true;
+        }
+      } else if (exports_type == simdjson::ondemand::json_type::object) {
+        simdjson::ondemand::object subobject;
+        if (!exports_value.get_object().get(subobject)) {
+          if (!subobject.raw_json().get(exports_string_value)) {
+            exports = js_string(exports_string_value);
+            should_parse_exports = true;
+            includes_keys = true;
+          }
+        }
+      }
+    }
+  }
+
+  // Check for "imports" field
+  simdjson::ondemand::value imports_value{};
+  if (!obj["imports"].get(imports_value)) {
+    simdjson::ondemand::json_type imports_type{};
+    if (!imports_value.type().get(imports_type)) {
+      std::string_view imports_string_value{};
+      if (imports_type == simdjson::ondemand::json_type::string) {
+        if (!imports_value.get_string().get(imports_string_value)) {
+          imports = js_string(imports_string_value);
+          includes_keys = true;
+        }
+      } else if (imports_type == simdjson::ondemand::json_type::object) {
+        simdjson::ondemand::object subobject;
+        if (!imports_value.get_object().get(subobject)) {
+          if (!subobject.raw_json().get(imports_string_value)) {
+            imports = js_string(imports_string_value);
+            should_parse_imports = true;
+            includes_keys = true;
+          }
+        }
+      }
     }
   }
 
+  std::string_view type_value{};
+  if (!obj["type"].get(type_value)) {
+    type = js_string(type_value);
+    includes_keys = true;
+  }
 
   Local<Value> return_value[] = {
-    String::NewFromUtf8(isolate,
-                        &chars[start],
-                        v8::NewStringType::kNormal,
-                        size).ToLocalChecked(),
-    Boolean::New(isolate, p < pe ? true : false)
+      Boolean::New(isolate, includes_keys),
+      name,
+      main,
+      exports,
+      imports,
+      type,
+      Boolean::New(isolate, should_parse_exports),
+      Boolean::New(isolate, should_parse_imports),
   };
+
   args.GetReturnValue().Set(
     Array::New(isolate, return_value, arraysize(return_value)));
 }