test: split test-esm-loader-hooks

test/fixtures/es-module-loaders/loader-delayed-async-load.mjs

@@ -0,0 +1,3 @@
+export function load(a, b, c) {
+  return new Promise(d => setTimeout(() => d(c(a, b)), 99));
+}

test/fixtures/es-module-loaders/loader-exit-on-load.mjs

@@ -0,0 +1,4 @@
+export function load(a, b, next) {
+  if (a === 'data:exit') process.exit(42);
+  return next(a, b);
+}

test/fixtures/es-module-loaders/loader-exit-on-resolve.mjs

@@ -0,0 +1,4 @@
+export function resolve(a, b, next) {
+  if (a === 'exit:') process.exit(42);
+  return next(a, b);
+}

test/fixtures/es-module-loaders/loader-exit-top-level.mjs

@@ -0,0 +1 @@
+process.exit(42);

test/fixtures/es-module-loaders/loader-globalpreload-and-initialize.mjs

@@ -0,0 +1,2 @@
+export function globalPreload() {}
+export function initialize() {}

test/fixtures/es-module-loaders/loader-globalpreload-only.mjs

@@ -0,0 +1 @@
+export function globalPreload() {}

test/fixtures/es-module-loaders/loader-globalpreload-with-return.mjs

@@ -0,0 +1,3 @@
+export function globalPreload() {
+  return '';
+}

test/fixtures/es-module-loaders/loader-initialize-exit.mjs

@@ -0,0 +1,3 @@
+export function initialize() {
+  process.exit(42);
+}

test/fixtures/es-module-loaders/loader-initialize-never-settling.mjs

@@ -0,0 +1,3 @@
+export function initialize() {
+  return new Promise(() => {});
+}

test/fixtures/es-module-loaders/loader-initialize-rejecting.mjs

@@ -0,0 +1,3 @@
+export function initialize() {
+  return Promise.reject();
+}

test/fixtures/es-module-loaders/loader-initialize-throw-null.mjs

@@ -0,0 +1,3 @@
+export function initialize() {
+  throw null;
+}

test/fixtures/es-module-loaders/loader-load-commonjs-with-source.mjs

@@ -0,0 +1,13 @@
+import { readFile } from 'node:fs/promises';
+import { fileURLToPath } from 'node:url';
+
+export async function load(url, context, nextLoad) {
+  const result = await nextLoad(url, context);
+  if (url.endsWith('/common/index.js')) {
+    result.source = '"use strict";module.exports=require("node:module").createRequire(' +
+             JSON.stringify(url) + ')(' + JSON.stringify(fileURLToPath(url)) + ');\n';
+  } else if (url.startsWith('file:') && (context.format == null || context.format === 'commonjs')) {
+    result.source = await readFile(new URL(url));
+  }
+  return result;
+}

test/fixtures/es-module-loaders/loader-load-source-maps.mjs

@@ -0,0 +1,9 @@
+import { readFile } from 'node:fs/promises';
+
+export async function load(url, context, nextLoad) {
+  const resolved = await nextLoad(url, context);
+  if (context.format === 'commonjs') {
+    resolved.source = await readFile(new URL(url));
+  }
+  return resolved;
+}

test/fixtures/es-module-loaders/loader-mixed-opt-in.mjs

@@ -0,0 +1,28 @@
+import { createRequire } from 'module';
+
+const require = createRequire(import.meta.url);
+const fixtures = require('../../common/fixtures.js');
+
+const fixturesPath = fixtures.path('empty.js');
+
+export function resolve(s, c, n) {
+  if (s.endsWith('entry-point')) {
+    return {
+      shortCircuit: true,
+      url: 'file:///c:/virtual-entry-point',
+      format: 'commonjs',
+    };
+  }
+  return n(s, c);
+}
+
+export async function load(u, c, n) {
+  if (u === 'file:///c:/virtual-entry-point') {
+    return {
+      shortCircuit: true,
+      source: `"use strict";require(${JSON.stringify(fixturesPath)});console.log("Hello");`,
+      format: 'commonjs',
+    };
+  }
+  return n(u, c);
+}

test/fixtures/es-module-loaders/loader-throw-bigint.mjs

@@ -0,0 +1 @@
+throw 1n;

test/fixtures/es-module-loaders/loader-throw-boolean.mjs

@@ -0,0 +1 @@
+throw true;

test/fixtures/es-module-loaders/loader-throw-empty-object.mjs

@@ -0,0 +1 @@
+throw {};

test/fixtures/es-module-loaders/loader-throw-error.mjs

@@ -0,0 +1 @@
+throw new Error('error message');

test/fixtures/es-module-loaders/loader-throw-function.mjs

@@ -0,0 +1 @@
+throw function fnName() {};

test/fixtures/es-module-loaders/loader-throw-null.mjs

@@ -0,0 +1 @@
+throw null;

test/fixtures/es-module-loaders/loader-throw-number.mjs

@@ -0,0 +1 @@
+throw 1;

test/fixtures/es-module-loaders/loader-throw-object.mjs

@@ -0,0 +1 @@
+throw { fn() {}, symbol: Symbol('symbol'), u: undefined };

test/fixtures/es-module-loaders/loader-throw-string.mjs

@@ -0,0 +1 @@
+throw 'literal string';

test/fixtures/es-module-loaders/loader-throw-symbol.mjs

@@ -0,0 +1 @@
+throw Symbol('symbol descriptor');

test/fixtures/es-module-loaders/loader-throw-undefined.mjs

@@ -0,0 +1 @@
+throw undefined;

test/fixtures/es-module-loaders/loader-worker-spawn.mjs

@@ -0,0 +1,7 @@
+import { Worker } from 'worker_threads';
+import { createRequire } from 'module';
+
+const require = createRequire(import.meta.url);
+const fixtures = require('../../common/fixtures.js');
+
+new Worker(fixtures.path('empty.js')).unref();

test/fixtures/es-module-loaders/register-hooks-with-register.mjs

@@ -0,0 +1,6 @@
+import { register } from 'node:module';
+import { fileURLToPath } from 'node:url';
+import { dirname, join } from 'node:path';
+
+const __dirname = dirname(fileURLToPath(import.meta.url));
+register(join(__dirname, 'hooks-initialize.mjs'), import.meta.url);

test/fixtures/es-module-loaders/register-loader-with-url-parenturl.mjs

@@ -0,0 +1,11 @@
+import {register} from 'node:module';
+import fixtures from '../../common/fixtures.js';
+
+register(
+  fixtures.fileURL('es-module-loaders/loader-load-foo-or-42.mjs'),
+  new URL('data:'),
+);
+
+import('node:os').then((result) => {
+  console.log(JSON.stringify(result));
+});

test/fixtures/module-hooks/register-loader-in-sequence.mjs

@@ -0,0 +1,11 @@
+import {register} from 'node:module';
+import fixtures from '../../common/fixtures.js';
+
+console.log('result 1', register(
+  fixtures.fileURL('es-module-loaders/hooks-initialize.mjs')
+));
+console.log('result 2', register(
+  fixtures.fileURL('es-module-loaders/hooks-initialize.mjs')
+));
+
+await import('node:os');

test/fixtures/module-hooks/register-loader-initialize-never-settling.mjs

@@ -0,0 +1,8 @@
+import {register} from 'node:module';
+import fixtures from '../../common/fixtures.js';
+
+try {
+  register(fixtures.fileURL('es-module-loaders/loader-initialize-never-settling.mjs'));
+} catch (e) {
+  console.log('caught', e.code);
+}

test/fixtures/module-hooks/register-loader-with-cjs.cjs

@@ -0,0 +1,14 @@
+'use strict';
+const {register} = require('node:module');
+const fixtures = require('../../common/fixtures.js');
+
+register(
+  fixtures.fileURL('es-module-loaders/hooks-initialize.mjs'),
+);
+register(
+  fixtures.fileURL('es-module-loaders/loader-load-foo-or-42.mjs'),
+);
+
+import('node:os').then((result) => {
+  console.log(JSON.stringify(result));
+});

test/fixtures/module-hooks/register-loader-with-ports.mjs

@@ -0,0 +1,22 @@
+import {MessageChannel} from 'node:worker_threads';
+import {register} from 'node:module';
+import {once} from 'node:events';
+import fixtures from '../../common/fixtures.js';
+
+const {port1, port2} = new MessageChannel();
+port1.on('message', (msg) => {
+  console.log('message', msg);
+});
+const result = register(
+  fixtures.fileURL('es-module-loaders/hooks-initialize-port.mjs'),
+  {data: port2, transferList: [port2]},
+);
+console.log('register', result);
+
+const timeout = setTimeout(() => {}, 2**31 - 1); // to keep the process alive.
+await Promise.all([
+  once(port1, 'message').then(() => once(port1, 'message')),
+  import('node:os'),
+]);
+clearTimeout(timeout);
+port1.close();

test/module-hooks/test-async-loader-hooks-called-with-expected-args.mjs

@@ -0,0 +1,28 @@
+// Test that loader hooks are called with all expected arguments
+import '../common/index.mjs';
+import assert from 'node:assert';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndAssert } from '../common/child_process.js';
+
+spawnSyncAndAssert(
+  execPath,
+  [
+    '--no-warnings',
+    '--experimental-loader',
+    fixtures.fileURL('es-module-loaders/hooks-input.mjs'),
+    fixtures.path('es-modules/json-modules.mjs'),
+  ],
+  {
+    stdout(output) {
+      const lines = output.split('\n');
+      assert.match(lines[0], /{"url":"file:\/\/\/.*\/json-modules\.mjs","format":"test","shortCircuit":true}/);
+      assert.match(lines[1], /{"source":{"type":"Buffer","data":\[.*\]},"format":"module","shortCircuit":true}/);
+      assert.match(lines[2], /{"url":"file:\/\/\/.*\/experimental\.json","format":"test","shortCircuit":true}/);
+      assert.match(lines[3], /{"source":{"type":"Buffer","data":\[.*\]},"format":"json","shortCircuit":true}/);
+      assert.strictEqual(lines.length, 4);
+    },
+    stderr: '',
+    trim: true,
+  },
+);

test/module-hooks/test-async-loader-hooks-called-with-register.mjs

@@ -0,0 +1,31 @@
+// Test that loader hooks are called with all expected arguments using register function
+import '../common/index.mjs';
+import assert from 'node:assert';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndAssert } from '../common/child_process.js';
+
+spawnSyncAndAssert(
+  execPath,
+  [
+    '--no-warnings',
+    '--experimental-loader=data:text/javascript,',
+    '--input-type=module',
+    '--eval',
+    "import { register } from 'node:module';" +
+    `register(${JSON.stringify(fixtures.fileURL('es-module-loaders/hooks-input.mjs'))});` +
+    `await import(${JSON.stringify(fixtures.fileURL('es-modules/json-modules.mjs'))});`,
+  ],
+  {
+    stdout(output) {
+      const lines = output.split('\n');
+      assert.match(lines[0], /{"url":"file:\/\/\/.*\/json-modules\.mjs","format":"test","shortCircuit":true}/);
+      assert.match(lines[1], /{"source":{"type":"Buffer","data":\[.*\]},"format":"module","shortCircuit":true}/);
+      assert.match(lines[2], /{"url":"file:\/\/\/.*\/experimental\.json","format":"test","shortCircuit":true}/);
+      assert.match(lines[3], /{"source":{"type":"Buffer","data":\[.*\]},"format":"json","shortCircuit":true}/);
+      assert.strictEqual(lines.length, 4);
+    },
+    stderr: '',
+    trim: true,
+  },
+);

test/module-hooks/test-async-loader-hooks-globalpreload-no-warning-with-initialize.mjs

@@ -0,0 +1,21 @@
+// Test that `globalPreload` should not emit warning when `initialize` is supplied
+
+import '../common/index.mjs';
+import assert from 'node:assert';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndAssert } from '../common/child_process.js';
+
+spawnSyncAndAssert(
+  execPath,
+  [
+    '--experimental-loader',
+    fixtures.fileURL('es-module-loaders/loader-globalpreload-and-initialize.mjs'),
+    fixtures.path('empty.js'),
+  ],
+  {
+    stderr(output) {
+      assert.doesNotMatch(output, /`globalPreload` has been removed; use `initialize` instead/);
+    },
+  },
+);

test/module-hooks/test-async-loader-hooks-globalpreload-warning.mjs

@@ -0,0 +1,23 @@
+// Test that `globalPreload` should emit warning
+import '../common/index.mjs';
+import assert from 'node:assert';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndAssert } from '../common/child_process.js';
+
+spawnSyncAndAssert(
+  execPath,
+  [
+    '--experimental-loader',
+    fixtures.fileURL('es-module-loaders/loader-globalpreload-only.mjs'),
+    '--experimental-loader',
+    fixtures.fileURL('es-module-loaders/loader-globalpreload-with-return.mjs'),
+    fixtures.path('empty.js'),
+  ],
+  {
+    stderr(output) {
+      const matches = output.match(/`globalPreload` has been removed; use `initialize` instead/g);
+      assert.strictEqual(matches.length, 1);
+    },
+  },
+);

test/module-hooks/test-async-loader-hooks-initialize-in-sequence.mjs

@@ -0,0 +1,21 @@
+// Test that `initialize` should execute in sequence
+import '../common/index.mjs';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndAssert } from '../common/child_process.js';
+
+spawnSyncAndAssert(
+  execPath,
+  [
+    '--no-warnings',
+    fixtures.path('module-hooks/register-loader-in-sequence.mjs'),
+  ],
+  {
+    stdout: 'hooks initialize 1\n' +
+            'result 1 undefined\n' +
+            'hooks initialize 2\n' +
+            'result 2 undefined',
+    trim: true,
+    stderr: '',
+  },
+);

test/module-hooks/test-async-loader-hooks-initialize-invoke.mjs

@@ -0,0 +1,22 @@
+// Test that `initialize` should be invoked correctly
+import '../common/index.mjs';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndAssert } from '../common/child_process.js';
+
+spawnSyncAndAssert(
+  execPath,
+  [
+    '--no-warnings',
+    '--experimental-loader',
+    fixtures.fileURL('es-module-loaders/hooks-initialize.mjs'),
+    '--input-type=module',
+    '--eval',
+    'import os from "node:os";',
+  ],
+  {
+    stdout: 'hooks initialize 1',
+    stderr: '',
+    trim: true,
+  },
+);

test/module-hooks/test-async-loader-hooks-initialize-never-settling.mjs

@@ -0,0 +1,18 @@
+// Test that `initialize` returning never-settling promise should be handled
+import '../common/index.mjs';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndAssert } from '../common/child_process.js';
+
+spawnSyncAndAssert(
+  execPath,
+  [
+    '--no-warnings',
+    fixtures.path('module-hooks/register-loader-initialize-never-settling.mjs'),
+  ],
+  {
+    stdout: 'caught ERR_ASYNC_LOADER_REQUEST_NEVER_SETTLED',
+    stderr: '',
+    trim: true,
+  },
+);

test/module-hooks/test-async-loader-hooks-initialize-process-exit.mjs

@@ -0,0 +1,23 @@
+// Test that it should be fine to call `process.exit` from a `initialize` hook
+import '../common/index.mjs';
+import { execPath } from 'node:process';
+import fixtures from '../common/fixtures.js';
+import { spawnSyncAndExit } from '../common/child_process.js';
+
+spawnSyncAndExit(
+  execPath,
+  [
+    '--no-warnings',
+    '--experimental-loader',
+    fixtures.fileURL('es-module-loaders/loader-initialize-exit.mjs'),
+    '--input-type=module',
+    '--eval',
+    'import "node:os"',
+  ],
+  {
+    status: 42,
+    signal: null,
+    stdout: '',
+    stderr: '',
+  },
+);