-
Notifications
You must be signed in to change notification settings - Fork 30k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
esm: refactor test-esm-loader-resolve-type
- Loading branch information
1 parent
fa041a2
commit e5470e0
Showing
3 changed files
with
47 additions
and
41 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
18 changes: 18 additions & 0 deletions
18
test/fixtures/es-module-loaders/hook-resolve-type-loader.mjs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,18 @@ | ||
/** @type {MessagePort} */ | ||
let port; | ||
export function initialize(data) { | ||
port = data.port; | ||
} | ||
|
||
export async function resolve(specifier, context, next) { | ||
const nextResult = await next(specifier, context); | ||
const { format } = nextResult; | ||
|
||
if (format === 'module' || specifier.endsWith('.mjs')) { | ||
port.postMessage({ type: 'module' }); | ||
} else if (format == null || format === 'commonjs') { | ||
port.postMessage({ type: 'commonjs' }); | ||
} | ||
|
||
return nextResult; | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,44 +1,30 @@ | ||
import * as fixtures from '../../common/fixtures.mjs'; | ||
import { register } from 'node:module'; | ||
import { MessageChannel } from 'node:worker_threads'; | ||
|
||
let importedESM = 0; | ||
let importedCJS = 0; | ||
export function getModuleTypeStats() { | ||
return { importedESM, importedCJS }; | ||
}; | ||
|
||
export function globalPreload({ port }) { | ||
port.on('message', (int32) => { | ||
port.postMessage({ importedESM, importedCJS }); | ||
Atomics.store(int32, 0, 1); | ||
Atomics.notify(int32, 0); | ||
}); | ||
port.unref(); | ||
return ` | ||
const { receiveMessageOnPort } = getBuiltin('worker_threads'); | ||
global.getModuleTypeStats = async function getModuleTypeStats() { | ||
const sab = new SharedArrayBuffer(4); | ||
const int32 = new Int32Array(sab); | ||
port.postMessage(int32); | ||
// Artificial timeout to keep the event loop alive. | ||
// https://bugs.chromium.org/p/v8/issues/detail?id=13238 | ||
// TODO(targos) Remove when V8 issue is resolved. | ||
const timeout = setTimeout(() => { throw new Error('timeout'); }, 1_000); | ||
await Atomics.waitAsync(int32, 0, 0).value; | ||
clearTimeout(timeout); | ||
return receiveMessageOnPort(port).message; | ||
}; | ||
`; | ||
} | ||
|
||
export async function load(url, context, next) { | ||
return next(url); | ||
} | ||
const { port1, port2 } = new MessageChannel(); | ||
|
||
export async function resolve(specifier, context, next) { | ||
const nextResult = await next(specifier, context); | ||
const { format } = nextResult; | ||
register(fixtures.fileURL('es-module-loaders/hook-resolve-type-loader.mjs'), { | ||
data: { port: port2 }, | ||
transferList: [port2], | ||
}); | ||
|
||
if (format === 'module' || specifier.endsWith('.mjs')) { | ||
importedESM++; | ||
} else if (format == null || format === 'commonjs') { | ||
importedCJS++; | ||
port1.on('message', ({ type }) => { | ||
switch (type) { | ||
case 'module': | ||
importedESM++; | ||
break; | ||
case 'commonjs': | ||
importedCJS++; | ||
break; | ||
} | ||
}); | ||
|
||
return nextResult; | ||
} | ||
|
||
port1.unref(); | ||
port2.unref(); |