Merge branch 'nodejs:main' into fix-possible-dereference-of-null

Author: Eusgor

README.md

@@ -401,8 +401,6 @@ For information about the governance of the Node.js project, see
   **Xuguang Mei** <<[email protected]>> (he/him)
 * [mhdawson](https://github.com/mhdawson) -
   **Michael Dawson** <<[email protected]>> (he/him)
-* [mildsunrise](https://github.com/mildsunrise) -
-  **Alba Mendez** <<[email protected]>> (she/her)
 * [MoLow](https://github.com/MoLow) -
   **Moshe Atlow** <<[email protected]>> (he/him)
 * [MrJithil](https://github.com/MrJithil) -
@@ -611,6 +609,8 @@ For information about the governance of the Node.js project, see
   **Mikeal Rogers** <<[email protected]>>
 * [miladfarca](https://github.com/miladfarca) -
   **Milad Fa** <<[email protected]>> (he/him)
+* [mildsunrise](https://github.com/mildsunrise) -
+  **Alba Mendez** <<[email protected]>> (she/her)
 * [misterdjules](https://github.com/misterdjules) -
   **Julien Gilli** <<[email protected]>>
 * [mmarchini](https://github.com/mmarchini) -

doc/api/esm.md

@@ -400,6 +400,35 @@ import { readFileSync } from 'node:fs';
 const buffer = readFileSync(new URL('./data.proto', import.meta.url));
 ```
 
+### `import.meta.main`
+
+<!-- YAML
+added:
+  - REPLACEME
+-->
+
+> Stability: 1.0 - Early development
+
+* {boolean} `true` when the current module is the entry point of the current process; `false` otherwise.
+
+Equivalent to `require.main === module` in CommonJS.
+
+Analogous to Python's `__name__ == "__main__"`.
+
+```js
+export function foo() {
+  return 'Hello, world';
+}
+
+function main() {
+  const message = foo();
+  console.log(message);
+}
+
+if (import.meta.main) main();
+// `foo` can be imported from another module without possible side-effects from `main`
+```
+
 ### `import.meta.resolve(specifier)`
 
 <!-- YAML
@@ -616,6 +645,10 @@ These CommonJS variables are not available in ES modules.
 They can instead be loaded with [`module.createRequire()`][] or
 [`process.dlopen`][].
 
+#### No `require.main`
+
+To replace `require.main === module`, there is the [`import.meta.main`][] API.
+
 #### No `require.resolve`
 
 Relative resolution can be handled via `new URL('./local', import.meta.url)`.
@@ -1181,6 +1214,7 @@ resolution for ESM specifiers is [commonjs-extension-resolution-loader][].
 [`import()`]: #import-expressions
 [`import.meta.dirname`]: #importmetadirname
 [`import.meta.filename`]: #importmetafilename
+[`import.meta.main`]: #importmetamain
 [`import.meta.resolve`]: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Operators/import.meta/resolve
 [`import.meta.url`]: #importmetaurl
 [`import`]: https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Statements/import

doc/api/zlib.md

@@ -615,7 +615,6 @@ Allowed flush values.
 * `zlib.constants.Z_FULL_FLUSH`
 * `zlib.constants.Z_FINISH`
 * `zlib.constants.Z_BLOCK`
-* `zlib.constants.Z_TREES`
 
 Return codes for the compression/decompression functions. Negative
 values are errors, positive values are used for special but normal

lib/_stream_duplex.js

@@ -2,5 +2,5 @@
 
 module.exports = require('stream').Duplex;
 
-process.emitWarning('The _stream_duplex module is deprecated.',
+process.emitWarning('The _stream_duplex module is deprecated. Use `node:stream` instead.',
                     'DeprecationWarning', 'DEP0193');

lib/_stream_passthrough.js

@@ -2,5 +2,5 @@
 
 module.exports = require('stream').PassThrough;
 
-process.emitWarning('The _stream_passthrough module is deprecated.',
+process.emitWarning('The _stream_passthrough module is deprecated. Use `node:stream` instead.',
                     'DeprecationWarning', 'DEP0193');

lib/_stream_readable.js

@@ -2,5 +2,5 @@
 
 module.exports = require('stream').Readable;
 
-process.emitWarning('The _stream_readable module is deprecated.',
+process.emitWarning('The _stream_readable module is deprecated. Use `node:stream` instead.',
                     'DeprecationWarning', 'DEP0193');

lib/_stream_transform.js

@@ -2,5 +2,5 @@
 
 module.exports = require('stream').Transform;
 
-process.emitWarning('The _stream_transform module is deprecated.',
+process.emitWarning('The _stream_transform module is deprecated. Use `node:stream` instead.',
                     'DeprecationWarning', 'DEP0193');

lib/_stream_wrap.js

@@ -2,5 +2,5 @@
 
 module.exports = require('internal/js_stream_socket');
 
-process.emitWarning('The _stream_wrap module is deprecated.',
+process.emitWarning('The _stream_wrap module is deprecated. Use `node:stream` instead.',
                     'DeprecationWarning', 'DEP0125');

lib/_stream_writable.js

@@ -2,5 +2,5 @@
 
 module.exports = require('stream').Writable;
 
-process.emitWarning('The _stream_writable module is deprecated.',
+process.emitWarning('The _stream_writable module is deprecated. Use `node:stream` instead.',
                     'DeprecationWarning', 'DEP0193');

lib/_tls_common.js

@@ -6,5 +6,5 @@ module.exports = {
   createSecureContext,
   translatePeerCertificate,
 };
-process.emitWarning('The _tls_common module is deprecated.',
+process.emitWarning('The _tls_common module is deprecated. Use `node:tls` instead.',
                     'DeprecationWarning', 'DEP0192');

lib/_tls_wrap.js

@@ -7,5 +7,5 @@ module.exports = {
   createServer,
   connect,
 };
-process.emitWarning('The _tls_wrap module is deprecated.',
+process.emitWarning('The _tls_wrap module is deprecated. Use `node:tls` instead.',
                     'DeprecationWarning', 'DEP0192');

lib/internal/errors.js

@@ -1338,7 +1338,12 @@ E('ERR_IMPORT_ATTRIBUTE_MISSING',
 E('ERR_IMPORT_ATTRIBUTE_TYPE_INCOMPATIBLE',
   'Module "%s" is not of type "%s"', TypeError);
 E('ERR_IMPORT_ATTRIBUTE_UNSUPPORTED',
-  'Import attribute "%s" with value "%s" is not supported', TypeError);
+  function error(attribute, value, url = undefined) {
+    if (url === undefined) {
+      return `Import attribute "${attribute}" with value "${value}" is not supported`;
+    }
+    return `Import attribute "${attribute}" with value "${value}" is not supported in ${url}`;
+  }, TypeError);
 E('ERR_INCOMPATIBLE_OPTION_PAIR',
   'Option "%s" cannot be used in combination with option "%s"', TypeError, HideStackFramesError);
 E('ERR_INPUT_TYPE_NOT_ALLOWED', '--input-type can only be used with string ' +

lib/internal/main/worker_thread.js

@@ -203,6 +203,20 @@ port.on('message', (message) => {
         break;
       }
 
+      case 'data-url': {
+        const { runEntryPointWithESMLoader } = require('internal/modules/run_main');
+
+        RegExpPrototypeExec(/^/, ''); // Necessary to reset RegExp statics before user code runs.
+        const promise = runEntryPointWithESMLoader((cascadedLoader) => {
+          return cascadedLoader.import(filename, undefined, { __proto__: null }, undefined, true);
+        });
+
+        PromisePrototypeThen(promise, undefined, (e) => {
+          workerOnGlobalUncaughtException(e, true);
+        });
+        break;
+      }
+
       default: {
         // script filename
         // runMain here might be monkey-patched by users in --require.

lib/internal/modules/esm/assert.js

@@ -57,7 +57,7 @@ function validateAttributes(url, format,
   const keys = ObjectKeys(importAttributes);
   for (let i = 0; i < keys.length; i++) {
     if (keys[i] !== 'type') {
-      throw new ERR_IMPORT_ATTRIBUTE_UNSUPPORTED(keys[i], importAttributes[keys[i]]);
+      throw new ERR_IMPORT_ATTRIBUTE_UNSUPPORTED(keys[i], importAttributes[keys[i]], url);
     }
   }
   const validType = formatTypeMap[format];
@@ -102,7 +102,7 @@ function handleInvalidType(url, type) {
 
   // `type` might not have been one of the types we understand.
   if (!ArrayPrototypeIncludes(supportedTypeAttributes, type)) {
-    throw new ERR_IMPORT_ATTRIBUTE_UNSUPPORTED('type', type);
+    throw new ERR_IMPORT_ATTRIBUTE_UNSUPPORTED('type', type, url);
   }
 
   // `type` was the wrong value for this format.

lib/internal/modules/esm/initialize_import_meta.js

@@ -51,12 +51,12 @@ function createImportMetaResolve(defaultParentURL, loader, allowParentURL) {
 /**
  * Create the `import.meta` object for a module.
  * @param {object} meta
- * @param {{url: string}} context
+ * @param {{url: string, isMain?: boolean}} context
  * @param {typeof import('./loader.js').ModuleLoader} loader Reference to the current module loader
  * @returns {{dirname?: string, filename?: string, url: string, resolve?: Function}}
  */
 function initializeImportMeta(meta, context, loader) {
-  const { url } = context;
+  const { url, isMain } = context;
 
   // Alphabetical
   if (StringPrototypeStartsWith(url, 'file:') === true) {
@@ -65,6 +65,8 @@ function initializeImportMeta(meta, context, loader) {
     setLazyPathHelpers(meta, url);
   }
 
+  meta.main = !!isMain;
+
   if (!loader || loader.allowImportMetaResolve) {
     meta.resolve = createImportMetaResolve(url, loader, experimentalImportMetaResolve);
   }

lib/internal/modules/esm/loader.js

@@ -248,10 +248,11 @@ class ModuleLoader {
    *
    * @param {string} source Source code of the module.
    * @param {string} url URL of the module.
+   * @param {{ isMain?: boolean }|undefined} context - context object containing module metadata.
    * @returns {object} The module wrap object.
    */
-  createModuleWrap(source, url) {
-    return compileSourceTextModule(url, source, this);
+  createModuleWrap(source, url, context = kEmptyObject) {
+    return compileSourceTextModule(url, source, this, context);
   }
 
   /**
@@ -289,7 +290,8 @@ class ModuleLoader {
    * @returns {Promise<object>} The module object.
    */
   eval(source, url, isEntryPoint = false) {
-    const wrap = this.createModuleWrap(source, url);
+    const context = isEntryPoint ? { isMain: true } : undefined;
+    const wrap = this.createModuleWrap(source, url, context);
     return this.executeModuleJob(url, wrap, isEntryPoint);
   }
 

lib/internal/modules/esm/translators.js

@@ -103,7 +103,8 @@ translators.set('module', function moduleStrategy(url, source, isMain) {
   source = stringify(source);
   debug(`Translating StandardModule ${url}`);
   const { compileSourceTextModule } = require('internal/modules/esm/utils');
-  const module = compileSourceTextModule(url, source, this);
+  const context = isMain ? { isMain } : undefined;
+  const module = compileSourceTextModule(url, source, this, context);
   return module;
 });
 

lib/internal/modules/esm/utils.js

@@ -42,6 +42,7 @@ const {
 const {
   emitExperimentalWarning,
   getCWDURL,
+  kEmptyObject,
 } = require('internal/util');
 const assert = require('internal/assert');
 const {
@@ -188,7 +189,7 @@ function registerModule(referrer, registry) {
  */
 function defaultInitializeImportMetaForModule(meta, wrap) {
   const cascadedLoader = require('internal/modules/esm/loader').getOrInitializeCascadedLoader();
-  return cascadedLoader.importMetaInitialize(meta, { url: wrap.url });
+  return cascadedLoader.importMetaInitialize(meta, { url: wrap.url, isMain: wrap.isMain });
 }
 
 /**
@@ -342,15 +343,22 @@ async function initializeHooks() {
  * @param {string} source Source code of the module.
  * @param {typeof import('./loader.js').ModuleLoader|undefined} cascadedLoader If provided,
  *        register the module for default handling.
+ * @param {{ isMain?: boolean }|undefined} context - context object containing module metadata.
  * @returns {ModuleWrap}
  */
-function compileSourceTextModule(url, source, cascadedLoader) {
+function compileSourceTextModule(url, source, cascadedLoader, context = kEmptyObject) {
   const hostDefinedOption = cascadedLoader ? source_text_module_default_hdo : undefined;
   const wrap = new ModuleWrap(url, undefined, source, 0, 0, hostDefinedOption);
 
   if (!cascadedLoader) {
     return wrap;
   }
+
+  const { isMain } = context;
+  if (isMain) {
+    wrap.isMain = true;
+  }
+
   // Cache the source map for the module if present.
   if (wrap.sourceMapURL) {
     maybeCacheSourceMap(url, source, wrap, false, undefined, wrap.sourceMapURL);

lib/internal/worker.js

@@ -7,7 +7,6 @@ const {
   AtomicsAdd,
   Float64Array,
   FunctionPrototypeBind,
-  JSONStringify,
   MathMax,
   ObjectEntries,
   Promise,
@@ -167,8 +166,8 @@ class Worker extends EventEmitter {
       doEval = 'classic';
     } else if (isURL(filename) && filename.protocol === 'data:') {
       url = null;
-      doEval = 'module';
-      filename = `import ${JSONStringify(`${filename}`)}`;
+      doEval = 'data-url';
+      filename = `${filename}`;
     } else {
       doEval = false;
       if (isURL(filename)) {

lib/sys.js

@@ -27,5 +27,5 @@
 // Note to maintainers: Although this module has been deprecated for a while
 // we do not plan to remove it. See: https://github.com/nodejs/node/pull/35407#issuecomment-700693439
 module.exports = require('util');
-process.emitWarning('sys is deprecated. Use util instead.',
+process.emitWarning('sys is deprecated. Use `node:util` instead.',
                     'DeprecationWarning', 'DEP0025');

lib/zlib.js

@@ -307,7 +307,7 @@ ZlibBase.prototype._final = function(callback) {
 // This is currently only used to figure out which flush flag to use for the
 // last chunk.
 // Roughly, the following holds:
-// Z_NO_FLUSH (< Z_TREES) < Z_BLOCK < Z_PARTIAL_FLUSH <
+// Z_NO_FLUSH < Z_BLOCK < Z_PARTIAL_FLUSH <
 //     Z_SYNC_FLUSH < Z_FULL_FLUSH < Z_FINISH
 const flushiness = [];
 const kFlushFlagList = [Z_NO_FLUSH, Z_BLOCK, Z_PARTIAL_FLUSH,

src/crypto/crypto_dh.cc

@@ -22,6 +22,8 @@ using ncrypto::DHPointer;
 using ncrypto::EVPKeyCtxPointer;
 using ncrypto::EVPKeyPointer;
 using v8::ArrayBuffer;
+using v8::BackingStoreInitializationMode;
+using v8::BackingStoreOnFailureMode;
 using v8::ConstructorBehavior;
 using v8::Context;
 using v8::DontDelete;
@@ -58,6 +60,20 @@ MaybeLocal<Value> DataPointerToBuffer(Environment* env, DataPointer&& data) {
   struct Flag {
     bool secure;
   };
+#ifdef V8_ENABLE_SANDBOX
+  auto backing = ArrayBuffer::NewBackingStore(
+      env->isolate(),
+      data.size(),
+      BackingStoreInitializationMode::kUninitialized,
+      BackingStoreOnFailureMode::kReturnNull);
+  if (!backing) {
+    THROW_ERR_MEMORY_ALLOCATION_FAILED(env);
+    return MaybeLocal<Value>();
+  }
+  if (data.size() > 0) {
+    memcpy(backing->Data(), data.get(), data.size());
+  }
+#else
   auto backing = ArrayBuffer::NewBackingStore(
       data.get(),
       data.size(),
@@ -67,6 +83,7 @@ MaybeLocal<Value> DataPointerToBuffer(Environment* env, DataPointer&& data) {
       },
       new Flag{data.isSecure()});
   data.release();
+#endif  // V8_ENABLE_SANDBOX
 
   auto ab = ArrayBuffer::New(env->isolate(), std::move(backing));
   return Buffer::New(env, ab, 0, ab->ByteLength()).FromMaybe(Local<Value>());