diff --git a/CONTRIBUTING.md b/CONTRIBUTING.md index 877024e3866..415a0abcac4 100644 --- a/CONTRIBUTING.md +++ b/CONTRIBUTING.md @@ -93,6 +93,31 @@ npx nx affected -t test --parallel=3 --exclude='*,!tag:type:pkg' This command ensures that only relevant tests are executed, saving time and resources. +### Enhanced (packages/enhanced) Test Suites + +The enhanced package uses Vitest with a custom runner that compiles webpack config cases and then executes their bundles in an isolated VM context. + +- Run all enhanced tests + +```sh +nx test enhanced +``` + +- Run a single enhanced case (by directory name) + +```sh +# Example: only run the container/0-container-full case +npx vitest -c packages/enhanced/vitest.config.ts -t "0-container-full should compile" + +# Or target a specific test file and group +npx vitest -c packages/enhanced/vitest.config.ts packages/enhanced/test/ConfigTestCases.basictest.vitest.ts -t "0-container-full should compile" +npx vitest -c packages/enhanced/vitest.config.ts packages/enhanced/test/ConfigTestCases.embedruntime.vitest.ts -t "0-container-full should compile" +``` + +- Notes + - Filters match the top-level test names created by the runner (e.g., ` should compile`). + - Case-internal exported tests (the `it(...)` inside a case’s `index.js`) are aggregated and executed within that top-level test. Use the `-t` filter on the top-level name to run only that case. + ## Submitting Changes diff --git a/package.json b/package.json index a6848f731c7..d8a8c7150ea 100644 --- a/package.json +++ b/package.json @@ -23,7 +23,8 @@ "commit": "cz", "docs": "typedoc", "f": "nx format:write", - "enhanced:jest": "pnpm build && cd packages/enhanced && NODE_OPTIONS=--experimental-vm-modules npx jest test/ConfigTestCases.basictest.js test/unit", + "enhanced:vitest": "NODE_OPTIONS=--experimental-vm-modules npx vitest -c packages/enhanced/vitest.config.ts ", + "enhanced:rstest": "NODE_OPTIONS=--experimental-vm-modules npx rstest -c packages/enhanced/rstest.config.ts ", "lint": "nx run-many --target=lint", "test": "nx run-many --target=test", "build": "NX_TUI=false nx run-many --target=build --parallel=5 --projects=tag:type:pkg", diff --git a/packages/enhanced/project.json b/packages/enhanced/project.json index 4730f4dbe0d..3fd3218b8d1 100644 --- a/packages/enhanced/project.json +++ b/packages/enhanced/project.json @@ -44,6 +44,18 @@ } }, "test": { + "executor": "nx:run-commands", + "options": { + "parallel": false, + "commands": [ + { + "command": "NODE_OPTIONS=--experimental-vm-modules npx vitest -c packages/enhanced/vitest.config.ts", + "forwardAllArgs": true + } + ] + } + }, + "test:jest": { "executor": "nx:run-commands", "options": { "parallel": false, diff --git a/packages/enhanced/rstest.config.ts b/packages/enhanced/rstest.config.ts new file mode 100644 index 00000000000..0a4746f240f --- /dev/null +++ b/packages/enhanced/rstest.config.ts @@ -0,0 +1,9 @@ +import { defineConfig } from '@rstest/core'; +import path from 'path'; + +export default defineConfig({ + testEnvironment: 'node', + globals: true, + include: [path.resolve(__dirname, 'test/ConfigTestCases.*.rstest.ts')], + testTimeout: 60000, // webpack 编译耗时较长 +}); diff --git a/packages/enhanced/test/ConfigTestCases.basictest.rstest.ts b/packages/enhanced/test/ConfigTestCases.basictest.rstest.ts new file mode 100644 index 00000000000..c798e419884 --- /dev/null +++ b/packages/enhanced/test/ConfigTestCases.basictest.rstest.ts @@ -0,0 +1,21 @@ +// 清理残留的 Federation 全局状态，避免跨 case 互相影响 +if ((globalThis as any).__FEDERATION__) { + (globalThis as any).__GLOBAL_LOADING_REMOTE_ENTRY__ = {}; + //@ts-ignore + (globalThis as any).__FEDERATION__.__INSTANCES__.map((i: any) => { + i.moduleCache.clear(); + if ((globalThis as any)[i.name]) { + delete (globalThis as any)[i.name]; + } + }); + (globalThis as any).__FEDERATION__.__INSTANCES__ = []; +} + +import { rs } from '@rstest/core'; +import { describeCases } from './ConfigTestCases.rstest'; + +rs.resetModules(); + +describeCases({ + name: 'ConfigTestCases', +}); diff --git a/packages/enhanced/test/ConfigTestCases.basictest.vitest.ts b/packages/enhanced/test/ConfigTestCases.basictest.vitest.ts new file mode 100644 index 00000000000..b71fce91bbc --- /dev/null +++ b/packages/enhanced/test/ConfigTestCases.basictest.vitest.ts @@ -0,0 +1,21 @@ +// 清理残留的 Federation 全局状态，避免跨 case 互相影响 +if ((globalThis as any).__FEDERATION__) { + (globalThis as any).__GLOBAL_LOADING_REMOTE_ENTRY__ = {}; + //@ts-ignore + (globalThis as any).__FEDERATION__.__INSTANCES__.map((i: any) => { + i.moduleCache.clear(); + if ((globalThis as any)[i.name]) { + delete (globalThis as any)[i.name]; + } + }); + (globalThis as any).__FEDERATION__.__INSTANCES__ = []; +} + +import { vi } from 'vitest'; +import { describeCases } from './ConfigTestCases.vitest'; + +vi.resetModules(); + +describeCases({ + name: 'ConfigTestCases', +}); diff --git a/packages/enhanced/test/ConfigTestCases.embedruntime.rstest.ts b/packages/enhanced/test/ConfigTestCases.embedruntime.rstest.ts new file mode 100644 index 00000000000..a9391aadf8a --- /dev/null +++ b/packages/enhanced/test/ConfigTestCases.embedruntime.rstest.ts @@ -0,0 +1,24 @@ +// 清理残留的 Federation 全局状态，避免跨 case 互相影响 +if ((globalThis as any).__FEDERATION__) { + (globalThis as any).__GLOBAL_LOADING_REMOTE_ENTRY__ = {}; + //@ts-ignore + (globalThis as any).__FEDERATION__.__INSTANCES__.map((i: any) => { + i.moduleCache.clear(); + if ((globalThis as any)[i.name]) { + delete (globalThis as any)[i.name]; + } + }); + (globalThis as any).__FEDERATION__.__INSTANCES__ = []; +} + +import { rs } from '@rstest/core'; +import { describeCases } from './ConfigTestCases.rstest'; + +rs.resetModules(); + +describeCases({ + name: 'ConfigTestCases', + federation: { + asyncStartup: true, + }, +}); diff --git a/packages/enhanced/test/ConfigTestCases.embedruntime.vitest.ts b/packages/enhanced/test/ConfigTestCases.embedruntime.vitest.ts new file mode 100644 index 00000000000..b027ae114b5 --- /dev/null +++ b/packages/enhanced/test/ConfigTestCases.embedruntime.vitest.ts @@ -0,0 +1,24 @@ +// 清理残留的 Federation 全局状态，避免跨 case 互相影响 +if ((globalThis as any).__FEDERATION__) { + (globalThis as any).__GLOBAL_LOADING_REMOTE_ENTRY__ = {}; + //@ts-ignore + (globalThis as any).__FEDERATION__.__INSTANCES__.map((i: any) => { + i.moduleCache.clear(); + if ((globalThis as any)[i.name]) { + delete (globalThis as any)[i.name]; + } + }); + (globalThis as any).__FEDERATION__.__INSTANCES__ = []; +} + +import { vi } from 'vitest'; +import { describeCases } from './ConfigTestCases.vitest'; + +vi.resetModules(); + +describeCases({ + name: 'ConfigTestCases', + federation: { + asyncStartup: true, + }, +}); diff --git a/packages/enhanced/test/ConfigTestCases.rstest.ts b/packages/enhanced/test/ConfigTestCases.rstest.ts new file mode 100644 index 00000000000..7528bf94c5e --- /dev/null +++ b/packages/enhanced/test/ConfigTestCases.rstest.ts @@ -0,0 +1,1027 @@ +import path from 'path'; +import fs from 'graceful-fs'; +import vm from 'vm'; +import { URL, pathToFileURL, fileURLToPath } from 'url'; +import { rimrafSync } from 'rimraf'; +import { + describe, + it, + beforeAll, + afterAll, + beforeEach, + afterEach, + expect, + rs, +} from '@rstest/core'; + +// 预热 webpack（与原逻辑一致） +require('./helpers/warmup-webpack'); + +const checkArrayExpectation = require('./checkArrayExpectation'); +const FakeDocument = require('./helpers/FakeDocument'); +const CurrentScript = require('./helpers/CurrentScript'); +const prepareOptions = require('./helpers/prepareOptions'); +const captureStdio = require('./helpers/captureStdio'); +const asModule = require('./helpers/asModule'); +const filterInfraStructureErrors = require('./helpers/infrastructureLogErrors'); +const { parseResource } = require('webpack/lib/util/identifier'); +const nativeRequire = require; + +const casesPath = path.join(__dirname, 'configCases'); + +const dedupeByMessage = (items: any[]) => { + if (!Array.isArray(items) || items.length === 0) { + return [] as any[]; + } + const seen = new Set(); + const deduped: any[] = []; + for (const item of items) { + const key = (item && item.message) as string | undefined; + if (key) { + if (seen.has(key)) continue; + seen.add(key); + } + deduped.push(item); + } + return deduped; +}; + +const collectInfrastructureOutputs = ( + infraLogs: string[], + stderrOutput: string | undefined, + config: any, +) => { + const infrastructureCollection = filterInfraStructureErrors.collect( + infraLogs, + config, + ); + const stderrLines = stderrOutput + ? stderrOutput + .split(/\r?\n/) + .map((line: string) => line.trim()) + .filter(Boolean) + : []; + const stderrCollection = filterInfraStructureErrors.collect( + stderrLines, + config, + ); + const unhandled = [ + ...infrastructureCollection.entries + .filter( + (entry: any) => !infrastructureCollection.handled.has(entry.normalized), + ) + .map((entry: any) => entry.normalized), + ...stderrCollection.entries + .filter((entry: any) => !stderrCollection.handled.has(entry.normalized)) + .map((entry: any) => entry.normalized), + ]; + + const combinedResults = dedupeByMessage([ + ...infrastructureCollection.results, + ...stderrCollection.results, + ]); + + return { unhandled, results: combinedResults }; +}; + +const categories = fs.readdirSync(casesPath).map((cat: string) => { + return { + name: cat, + tests: fs + .readdirSync(path.join(casesPath, cat)) + .filter( + (folder: string) => !folder.startsWith('_') && !folder.startsWith('.'), + ) + .sort(), + }; +}); + +const createLogger = (appendTarget: string[]) => { + return { + log: (l: string) => appendTarget.push(l), + debug: (l: string) => appendTarget.push(l), + trace: (l: string) => appendTarget.push(l), + info: (l: string) => appendTarget.push(l), + warn: console.warn.bind(console), + error: console.error.bind(console), + logTime: () => { + appendTarget.push('time'); + }, + group: (...args: any[]) => { + appendTarget.push(`group:${args.join(' ')}`); + }, + groupCollapsed: (...args: any[]) => { + appendTarget.push(`groupCollapsed:${args.join(' ')}`); + }, + groupEnd: () => { + appendTarget.push('groupEnd'); + }, + profile: (...args: any[]) => { + appendTarget.push(`profile:${args.join(' ')}`); + }, + profileEnd: () => { + appendTarget.push('profileEnd'); + }, + clear: () => { + appendTarget.push('clear'); + }, + status: () => { + appendTarget.push('status'); + }, + }; +}; + +// 最小 Worker stub（helpers/createFakeWorker 不存在，内联实现） +function createFakeWorker({ outputDirectory }: { outputDirectory: string }) { + return class FakeWorker { + url: any; + onmessage: any; + onerror: any; + constructor(url?: any) { + this.url = url; + } + postMessage(_msg?: any) { + if (typeof this.onmessage === 'function') this.onmessage({ data: _msg }); + } + terminate() { + this.onmessage = null; + this.onerror = null; + } + addEventListener(type: string, handler: any) { + if (type === 'message') this.onmessage = handler; + if (type === 'error') this.onerror = handler; + } + removeEventListener(type: string, _handler: any) { + if (type === 'message') this.onmessage = null; + if (type === 'error') this.onerror = null; + } + dispatchEvent(_evt: any) { + return false; + } + } as any; +} + +export const describeCases = (config: any) => { + describe(config.name, () => { + let stderr: any; + const noop = () => {}; + beforeAll(() => { + try { + (process as any).on('unhandledRejection', noop); + } catch {} + try { + (process as any).on('uncaughtException', noop); + } catch {} + }); + afterAll(() => { + try { + (process as any).off('unhandledRejection', noop); + } catch {} + try { + (process as any).off('uncaughtException', noop); + } catch {} + }); + beforeEach(() => { + stderr = captureStdio(process.stderr, true); + }); + afterEach(() => { + stderr.restore(); + }); + + for (const category of categories) { + describe(category.name, () => { + for (const testName of category.tests) { + describe(testName, () => { + const testDirectory = path.join(casesPath, category.name, testName); + const filterPath = path.join(testDirectory, 'test.filter.js'); + if (fs.existsSync(filterPath) && !require(filterPath)()) { + it('filtered', () => undefined); + return; + } + const infraStructureLog: string[] = []; + const outBaseDir = path.join(__dirname, 'js'); + const testSubPath = path.join(config.name, category.name, testName); + const outputDirectory = path.join(outBaseDir, testSubPath); + const cacheDirectory = path.join(outBaseDir, '.cache', testSubPath); + let options: any, optionsArr: any[], testConfig: any; + + beforeAll(() => { + options = prepareOptions( + require(path.join(testDirectory, 'webpack.config.js')), + { + testPath: outputDirectory, + }, + ); + optionsArr = [].concat(options); + optionsArr.forEach((opt: any, idx: number) => { + // federation 选项注入 + if (config.federation) { + const mfp = + opt.plugins && + opt.plugins.find( + (p: any) => p.name === 'ModuleFederationPlugin', + ); + if (mfp) { + if (!mfp._options.experiments) + mfp._options.experiments = {}; + if (config.federation?.asyncStartup) { + if ('asyncStartup' in mfp._options.experiments) { + // respect explicit setting + } else { + Object.assign( + mfp._options.experiments, + config.federation, + ); + } + } + } + } + + if (!opt.context) opt.context = testDirectory; + if (!opt.mode) opt.mode = 'production'; + if (!opt.optimization) opt.optimization = {}; + if (opt.optimization.minimize === undefined) + opt.optimization.minimize = false; + if (opt.optimization.minimizer === undefined) { + // 保留注释：不强制设置 minimizer + } + if (!opt.entry) opt.entry = './index.js'; + if (!opt.target) opt.target = 'async-node'; + if (!opt.output) opt.output = {}; + if (!opt.output.path) opt.output.path = outputDirectory; + if (typeof opt.output.pathinfo === 'undefined') + opt.output.pathinfo = true; + if (!opt.output.filename) + opt.output.filename = + 'bundle' + + idx + + (opt.experiments && opt.experiments.outputModule + ? '.mjs' + : '.js'); + if (config.cache) { + opt.cache = { + cacheDirectory, + name: `config-${idx}`, + ...config.cache, + }; + opt.infrastructureLogging = { + debug: true, + console: createLogger(infraStructureLog), + }; + } + if (!opt.snapshot) opt.snapshot = {}; + if (!opt.snapshot.managedPaths) { + opt.snapshot.managedPaths = [ + path.resolve(__dirname, '../node_modules'), + ]; + } + }); + + testConfig = { + findBundle: function (i: number, options: any) { + const ext = path.extname( + parseResource(options.output.filename).path, + ); + if ( + fs.existsSync( + path.join(options.output.path, 'bundle' + i + ext), + ) + ) { + return './bundle' + i + ext; + } + }, + timeout: 30000, + }; + try { + testConfig = Object.assign( + testConfig, + require(path.join(testDirectory, 'test.config.js')), + ); + } catch (e) { + // ignored + } + }); + + afterAll(() => { + options = undefined as any; + optionsArr = undefined as any; + testConfig = undefined as any; + }); + + beforeAll(() => { + rimrafSync(cacheDirectory); + }); + + const handleFatalError = (err: any) => { + const fakeStats = { + errors: [ + { + message: err.message, + stack: err.stack, + }, + ], + } as any; + // error 期望匹配 + if ( + checkArrayExpectation( + testDirectory, + fakeStats, + 'error', + 'Error', + (e: any) => { + throw e; + }, + ) + ) { + return; // 让 rstest 认为测试通过（错误与期望一致） + } + // 否则抛出，交给 rstest 失败 + throw err; + }; + + // cache 预编译：第一次 + if (config.cache) { + it(`${testName} should pre-compile to fill disk cache (1st)`, async () => { + rimrafSync(outputDirectory); + fs.mkdirSync(outputDirectory, { recursive: true }); + infraStructureLog.length = 0; + await new Promise((resolve, reject) => { + try { + // 单次 run + require('webpack')(options, (err: any) => { + const stderrOutput = stderr.toString(); + const { unhandled, results: infrastructureLogErrors } = + collectInfrastructureOutputs( + infraStructureLog, + stderrOutput, + { run: 1, options }, + ); + stderr.reset(); + if (unhandled.length) { + reject( + new Error( + 'Errors/Warnings during build:\n' + + unhandled.join('\n'), + ), + ); + return; + } + if ( + infrastructureLogErrors.length && + checkArrayExpectation( + testDirectory, + { infrastructureLogs: infrastructureLogErrors }, + 'infrastructureLog', + 'infrastructure-log', + 'InfrastructureLog', + (e: any) => { + throw e; + }, + ) + ) { + resolve(); + return; + } + if (err) { + reject(err); + return; + } + resolve(); + }); + } catch (e: any) { + reject(e); + } + }); + }, 60000); + // cache 预编译：第二次 + it(`${testName} should pre-compile to fill disk cache (2nd)`, async () => { + rimrafSync(outputDirectory); + fs.mkdirSync(outputDirectory, { recursive: true }); + infraStructureLog.length = 0; + await new Promise((resolve, reject) => { + try { + require('webpack')(options, (err: any, stats: any) => { + if (err) { + reject(err); + return; + } + const { modules, children, errorsCount } = stats.toJson({ + all: false, + modules: true, + errorsCount: true, + }); + const stderrOutput = stderr.toString(); + const { unhandled, results: infrastructureLogErrors } = + collectInfrastructureOutputs( + infraStructureLog, + stderrOutput, + { run: 2, options }, + ); + stderr.reset(); + if (errorsCount === 0) { + if (unhandled.length) { + reject( + new Error( + 'Errors/Warnings during build:\n' + + unhandled.join('\n'), + ), + ); + return; + } + const allModules = children + ? children.reduce( + (all: any[], { modules }: any) => + all.concat(modules), + modules || [], + ) + : modules; + if ( + allModules.some( + (m: any) => + m.type !== 'cached modules' && !m.cached, + ) + ) { + reject( + new Error( + `Some modules were not cached:\n${stats.toString({ all: false, modules: true, modulesSpace: 100 })}`, + ), + ); + return; + } + } + if ( + infrastructureLogErrors.length && + checkArrayExpectation( + testDirectory, + { infrastructureLogs: infrastructureLogErrors }, + 'infrastructureLog', + 'infrastructure-log', + 'InfrastructureLog', + (e: any) => { + throw e; + }, + ) + ) { + resolve(); + return; + } + resolve(); + }); + } catch (e: any) { + reject(e); + } + }); + }, 40000); + } + + it( + `${testName} should compile`, + async () => { + try { + // Robust cleanup to avoid ENOTEMPTY and race conditions + (fs as any).rmSync?.(outputDirectory, { + recursive: true, + force: true, + }); + } catch { + try { + rimrafSync(outputDirectory); + } catch { + /* ignore */ + } + } + fs.mkdirSync(outputDirectory, { recursive: true }); + infraStructureLog.length = 0; + + // 运行 webpack + const { stats } = await new Promise<{ stats: any }>( + (resolve, reject) => { + const onCompiled = (err: any, stats: any) => { + if (err) return reject(err); + resolve({ stats }); + }; + try { + if (config.cache) { + const compiler = require('webpack')(options); + compiler.run((err: any) => { + if (err) return reject(err); + compiler.run((error: any, stats: any) => { + compiler.close((cerr: any) => { + if (cerr) return reject(cerr); + if (error) return reject(error); + resolve({ stats }); + }); + }); + }); + } else { + require('webpack')(options, onCompiled); + } + } catch (e: any) { + reject(e); + } + }, + ).catch((e) => { + handleFatalError(e); + throw e; // rethrow for rstest to mark failure otherwise + }); + + // 写入 stats + const statOptions = { preset: 'verbose', colors: false }; + fs.mkdirSync(outputDirectory, { recursive: true }); + fs.writeFileSync( + path.join(outputDirectory, 'stats.txt'), + stats.toString(statOptions), + 'utf-8', + ); + const jsonStats = stats.toJson({ errorDetails: true }); + try { + fs.writeFileSync( + path.join(outputDirectory, 'stats.json'), + JSON.stringify(jsonStats, null, 2), + 'utf-8', + ); + } catch {} + + // 错误/警告/infra/deprecation 检查 + if ( + checkArrayExpectation( + testDirectory, + jsonStats, + 'error', + 'Error', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + if ( + checkArrayExpectation( + testDirectory, + jsonStats, + 'warning', + 'Warning', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + const stderrOutput = stderr.toString(); + const { unhandled, results: infrastructureLogErrors } = + collectInfrastructureOutputs( + infraStructureLog, + stderrOutput, + { run: 3, options }, + ); + stderr.reset(); + if (unhandled.length) { + throw new Error( + 'Errors/Warnings during build:\n' + unhandled.join('\n'), + ); + } + if ( + checkArrayExpectation( + testDirectory, + { deprecations: [] }, + 'deprecation', + 'Deprecation', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + if ( + infrastructureLogErrors.length && + checkArrayExpectation( + testDirectory, + { infrastructureLogs: infrastructureLogErrors }, + 'infrastructureLog', + 'infrastructure-log', + 'InfrastructureLog', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + + // 执行 bundle 并收集导出的 it/beforeEach/afterEach（不使用 createLazyTestEnv） + let filesCount = 0; + if (testConfig.noTests) return; // 某些 case 明确无测试 + if (testConfig.beforeExecute) testConfig.beforeExecute(); + + // 聚合器：收集并在当前测试中顺序执行导出的 it 测试 + type Hook = () => any; + type CallbackTestFn = (done: (err?: any) => void) => void; + type PromiseTestFn = () => any | Promise; + type TestFn = CallbackTestFn | PromiseTestFn; + type TestItem = { name: string; fn: TestFn; timeout?: number }; + const hooksBefore: Hook[] = []; + const hooksAfter: Hook[] = []; + const collectedTests: TestItem[] = []; + const defaultTimeout = testConfig.timeout || 30000; + + const caseIt = (name: string, fn: TestFn, timeout?: number) => { + collectedTests.push({ name, fn, timeout }); + }; + const caseBeforeEach = (fn: Hook) => hooksBefore.push(fn); + const caseAfterEach = (fn: Hook) => hooksAfter.push(fn); + + const isCallbackStyle = (fn: TestFn): fn is CallbackTestFn => + fn.length >= 1; + const runMaybeDone = async (fn: TestFn) => { + if (!fn) return; + if (isCallbackStyle(fn)) { + await new Promise((resolve, reject) => { + try { + fn((err?: any) => (err ? reject(err) : resolve())); + } catch (e) { + reject(e); + } + }); + } else { + const r = (fn as PromiseTestFn)(); + if (r && typeof r.then === 'function') await r; + } + }; + + const results: any[] = []; + let testActive = true; + for (let i = 0; i < optionsArr.length; i++) { + const opt = optionsArr[i]; + let bundlePath = testConfig.findBundle(i, optionsArr[i]); + if (!bundlePath) { + // Fallback: try to locate emitted bundle via stats.json entries + try { + const outFiles = fs.readdirSync(opt.output.path); + const execList: string[] = []; + const pushIf = (rel: string) => { + if (fs.existsSync(path.join(opt.output.path, rel))) + execList.push('./' + rel); + }; + pushIf('module/runtime.mjs'); + pushIf('runtime.js'); + pushIf('module/main.mjs'); + pushIf('module/main.js'); + pushIf('main.mjs'); + pushIf('main.js'); + const bundleCand = outFiles.find((f: string) => + /bundle\d+\.(mjs|js)$/.test(f), + ); + if (bundleCand) execList.push('./' + bundleCand); + const remoteEntryCand = outFiles.find( + (f: string) => f === 'remoteEntry.js', + ); + if (remoteEntryCand) + execList.push('./' + remoteEntryCand); + const containerCand = outFiles.find((f: string) => + /container.*\.(mjs|js)$/.test(f), + ); + if (containerCand) execList.push('./' + containerCand); + if (execList.length) bundlePath = execList; + } catch { + /* ignore */ + } + } + if (bundlePath) { + filesCount++; + + const document = new FakeDocument(outputDirectory); + const globalContext = { + console: console, + expect: expect, + setTimeout: setTimeout, + clearTimeout: clearTimeout, + document, + getComputedStyle: + document.getComputedStyle.bind(document), + location: { + href: 'https://test.cases/path/index.html', + origin: 'https://test.cases', + toString() { + return 'https://test.cases/path/index.html'; + }, + }, + } as any; + + const executeBundle = (entryRel: string) => { + const requireCache: Record = + Object.create(null); + const esmCache = new Map(); + const esmIdentifier = `${category.name}-${testName}-${i}-${entryRel}`; + const baseModuleScope: any = { + console: console, + it: caseIt, + beforeEach: caseBeforeEach, + afterEach: caseAfterEach, + expect, + jest: { + resetModules: () => rs.resetModules(), + setTimeout: (...args: any[]) => + (setTimeout as any)(...args), + }, + __STATS__: jsonStats, + nsObj: (m: any) => { + Object.defineProperty(m, Symbol.toStringTag, { + value: 'Module', + }); + return m; + }, + }; + + let runInNewContext = false; + if (opt.target === 'web' || opt.target === 'webworker') { + baseModuleScope.window = globalContext; + baseModuleScope.self = globalContext; + baseModuleScope.document = globalContext.document; + baseModuleScope.setTimeout = globalContext.setTimeout; + baseModuleScope.clearTimeout = + globalContext.clearTimeout; + baseModuleScope.URL = URL; + baseModuleScope.Worker = createFakeWorker({ + outputDirectory, + }); + baseModuleScope.path = nativeRequire('path'); + runInNewContext = true; + } + if (testConfig.moduleScope) { + testConfig.moduleScope(baseModuleScope); + } + const esmContext = vm.createContext(baseModuleScope, { + name: 'context for esm', + }); + + const _require = ( + currentDirectory: string, + opt: any, + module: any, + esmMode?: 'evaluated' | 'unlinked', + parentModule?: any, + ): any => { + // Guard lifecycle: avoid throwing after case teardown + if (!testActive || testConfig === undefined) { + return {}; + } + if (Array.isArray(module) || /^\.\.?\//.test(module)) { + let content = ''; + let p = ''; + let subPath = ''; + if (Array.isArray(module)) { + p = path.join( + currentDirectory, + '.array-require.js', + ); + content = `module.exports = (${module + .map( + (arg: any) => + `require(${JSON.stringify(`./${arg}`)})`, + ) + .join(', ')});`; + } else { + p = path.join(currentDirectory, module); + content = fs.readFileSync(p, 'utf-8'); + const lastSlash = module.lastIndexOf('/'); + let firstSlash = module.indexOf('/'); + if (lastSlash !== -1 && firstSlash !== lastSlash) { + if (firstSlash !== -1) { + let next = module.indexOf('/', firstSlash + 1); + let dir = module.slice(firstSlash + 1, next); + while (dir === '.') { + firstSlash = next; + next = module.indexOf('/', firstSlash + 1); + dir = module.slice(firstSlash + 1, next); + } + } + subPath = module.slice( + firstSlash + 1, + lastSlash + 1, + ); + } + } + + // Follow original template: ESM only when .mjs and outputModule enabled + const isModule = + p.endsWith('.mjs') && + opt.experiments && + opt.experiments.outputModule; + if (isModule) { + let esm = esmCache.get(p); + if (!esm) { + try { + if (!vm.SourceTextModule) + throw new Error( + "Running this test requires '--experimental-vm-modules'.\nRun with 'node --experimental-vm-modules node_modules/jest-cli/bin/jest'.", + ); + esm = new vm.SourceTextModule(content, { + identifier: esmIdentifier + '-' + p, + url: + pathToFileURL(p).href + '?' + esmIdentifier, + context: esmContext, + initializeImportMeta: (meta: any) => { + meta.url = pathToFileURL(p).href; + }, + importModuleDynamically: ( + specifier: string, + mod: any, + _assertions?: any, + ) => { + return _require( + path.dirname(p), + opt, + specifier, + 'evaluated', + mod, + ); + }, + }); + esmCache.set(p, esm); + } catch (err) { + return Promise.resolve({}); + } + } + if (esmMode === 'unlinked') return esm; + return (async () => { + await esm.link( + async ( + specifier: string, + referencingModule: any, + ) => { + return await asModule( + await _require( + path.dirname( + referencingModule.identifier + ? referencingModule.identifier.slice( + esmIdentifier.length + 1, + ) + : fileURLToPath( + referencingModule.url, + ), + ), + opt, + specifier, + 'unlinked', + referencingModule, + ), + referencingModule.context, + true, + ); + }, + ); + if ((esm as any).instantiate) + (esm as any).instantiate(); + await esm.evaluate(); + if (esmMode === 'evaluated') + return (esm as any).namespace; + const ns = (esm as any).namespace; + return ns && + ns.default && + ns.default instanceof Promise + ? ns.default + : ns; + })(); + } else { + if (p in requireCache) { + return requireCache[p].exports; + } + const m = { exports: {} } as any; + requireCache[p] = m; + const moduleScope: any = { + ...baseModuleScope, + require: (id: any) => { + if ( + Array.isArray(id) || + (typeof id === 'string' && /^\.?\./.test(id)) + ) { + return _require(path.dirname(p), opt, id); + } + return nativeRequire( + typeof id === 'string' && + id.startsWith('node:') + ? id.slice(5) + : id, + ); + }, + importScripts: (url: string) => { + expect(url).toMatch( + /^https:\/\/test\.cases\/path\//, + ); + _require( + outputDirectory, + opt, + `.${url.slice('https://test.cases/path'.length)}`, + ); + }, + module: m, + exports: m.exports, + __dirname: path.dirname(p), + __filename: p, + _globalAssign: { expect }, + path: require('path'), + }; + if (testConfig.moduleScope) + testConfig.moduleScope(moduleScope); + if (!runInNewContext) + content = `Object.assign(global, _globalAssign); ${content}`; + const args = Object.keys(moduleScope); + const argValues = args.map( + (arg) => moduleScope[arg], + ); + const code = `(function(${args.join( + ', ', + )}) {${content}\n})`; + const oldCurrentScript = document.currentScript; + (document as any).currentScript = new CurrentScript( + subPath, + ); + const fn = runInNewContext + ? vm.runInNewContext( + code, + globalContext as any, + p, + ) + : vm.runInThisContext(code, p); + fn.call( + testConfig.nonEsmThis + ? testConfig.nonEsmThis(m) + : m.exports, + ...argValues, + ); + (document as any).currentScript = oldCurrentScript; + return m.exports; + } + } else if ( + testConfig.modules && + module in testConfig.modules + ) { + return testConfig.modules[module]; + } else { + return nativeRequire( + module.startsWith('node:') + ? module.slice(5) + : module, + ); + } + }; + + const target = entryRel.startsWith('./') + ? entryRel + : './' + entryRel; + const res = _require(outputDirectory, opt, target); + filesCount++; + results.push(res); + }; + + if (Array.isArray(bundlePath)) { + for (const bundlePathItem of bundlePath) { + try { + executeBundle(bundlePathItem); + } catch {} + } + } else { + try { + executeBundle(bundlePath); + } catch {} + } + } + } + + if (!jsonStats.errors.length && filesCount < 1) { + } + + if (collectedTests.length > 0) { + for (const t of collectedTests) { + // 每个导出测试的 beforeEach + for (const b of hooksBefore) { + await runMaybeDone(b); + } + // 执行测试主体 + await runMaybeDone(t.fn); + // 每个导出测试的 afterEach + for (const a of hooksAfter) { + await runMaybeDone(a); + } + } + } // compile-only case：无导出测试视为通过（只要编译无错误） + + try { + if (testConfig.afterExecute) testConfig.afterExecute(); + } catch {} + testActive = false; + for (const key of Object.keys(global)) { + if (key.includes('webpack')) delete (global as any)[key]; + } + }, + testConfig?.timeout || 30000, + ); + }); + } + }); + } + }); +}; diff --git a/packages/enhanced/test/ConfigTestCases.vitest.ts b/packages/enhanced/test/ConfigTestCases.vitest.ts new file mode 100644 index 00000000000..12c30ea01dd --- /dev/null +++ b/packages/enhanced/test/ConfigTestCases.vitest.ts @@ -0,0 +1,1028 @@ +import path from 'path'; +import fs from 'graceful-fs'; +import vm from 'vm'; +import { URL, pathToFileURL, fileURLToPath } from 'url'; +import { rimrafSync } from 'rimraf'; +import { + describe, + it, + beforeAll, + afterAll, + beforeEach, + afterEach, + expect, + vi, +} from 'vitest'; + +// 预热 webpack（与原逻辑一致） +require('./helpers/warmup-webpack'); + +const checkArrayExpectation = require('./checkArrayExpectation'); +const FakeDocument = require('./helpers/FakeDocument'); +const CurrentScript = require('./helpers/CurrentScript'); +const prepareOptions = require('./helpers/prepareOptions'); +const captureStdio = require('./helpers/captureStdio'); +const asModule = require('./helpers/asModule'); +const filterInfraStructureErrors = require('./helpers/infrastructureLogErrors'); +const { parseResource } = require('webpack/lib/util/identifier'); +const nativeRequire = require; + +const casesPath = path.join(__dirname, 'configCases'); + +const dedupeByMessage = (items: any[]) => { + if (!Array.isArray(items) || items.length === 0) { + return [] as any[]; + } + const seen = new Set(); + const deduped: any[] = []; + for (const item of items) { + const key = (item && item.message) as string | undefined; + if (key) { + if (seen.has(key)) continue; + seen.add(key); + } + deduped.push(item); + } + return deduped; +}; + +const collectInfrastructureOutputs = ( + infraLogs: string[], + stderrOutput: string | undefined, + config: any, +) => { + const infrastructureCollection = filterInfraStructureErrors.collect( + infraLogs, + config, + ); + const stderrLines = stderrOutput + ? stderrOutput + .split(/\r?\n/) + .map((line: string) => line.trim()) + .filter(Boolean) + : []; + const stderrCollection = filterInfraStructureErrors.collect( + stderrLines, + config, + ); + const unhandled = [ + ...infrastructureCollection.entries + .filter( + (entry: any) => !infrastructureCollection.handled.has(entry.normalized), + ) + .map((entry: any) => entry.normalized), + ...stderrCollection.entries + .filter((entry: any) => !stderrCollection.handled.has(entry.normalized)) + .map((entry: any) => entry.normalized), + ]; + + const combinedResults = dedupeByMessage([ + ...infrastructureCollection.results, + ...stderrCollection.results, + ]); + + return { unhandled, results: combinedResults }; +}; + +const categories = fs.readdirSync(casesPath).map((cat: string) => { + return { + name: cat, + tests: fs + .readdirSync(path.join(casesPath, cat)) + .filter( + (folder: string) => !folder.startsWith('_') && !folder.startsWith('.'), + ) + .sort(), + }; +}); + +const createLogger = (appendTarget: string[]) => { + return { + log: (l: string) => appendTarget.push(l), + debug: (l: string) => appendTarget.push(l), + trace: (l: string) => appendTarget.push(l), + info: (l: string) => appendTarget.push(l), + warn: console.warn.bind(console), + error: console.error.bind(console), + logTime: () => { + appendTarget.push('time'); + }, + group: (...args: any[]) => { + appendTarget.push(`group:${args.join(' ')}`); + }, + groupCollapsed: (...args: any[]) => { + appendTarget.push(`groupCollapsed:${args.join(' ')}`); + }, + groupEnd: () => { + appendTarget.push('groupEnd'); + }, + profile: (...args: any[]) => { + appendTarget.push(`profile:${args.join(' ')}`); + }, + profileEnd: () => { + appendTarget.push('profileEnd'); + }, + clear: () => { + appendTarget.push('clear'); + }, + status: () => { + appendTarget.push('status'); + }, + }; +}; + +// 最小 Worker stub（helpers/createFakeWorker 不存在，内联实现） +function createFakeWorker({ outputDirectory }: { outputDirectory: string }) { + return class FakeWorker { + url: any; + onmessage: any; + onerror: any; + constructor(url?: any) { + this.url = url; + } + postMessage(_msg?: any) { + if (typeof this.onmessage === 'function') this.onmessage({ data: _msg }); + } + terminate() { + this.onmessage = null; + this.onerror = null; + } + addEventListener(type: string, handler: any) { + if (type === 'message') this.onmessage = handler; + if (type === 'error') this.onerror = handler; + } + removeEventListener(type: string, _handler: any) { + if (type === 'message') this.onmessage = null; + if (type === 'error') this.onerror = null; + } + dispatchEvent(_evt: any) { + return false; + } + } as any; +} + +export const describeCases = (config: any) => { + describe(config.name, () => { + let stderr: any; + const noop = () => {}; + beforeAll(() => { + try { + (process as any).on('unhandledRejection', noop); + } catch {} + try { + (process as any).on('uncaughtException', noop); + } catch {} + }); + afterAll(() => { + try { + (process as any).off('unhandledRejection', noop); + } catch {} + try { + (process as any).off('uncaughtException', noop); + } catch {} + }); + beforeEach(() => { + stderr = captureStdio(process.stderr, true); + }); + afterEach(() => { + stderr.restore(); + }); + + for (const category of categories) { + describe(category.name, () => { + for (const testName of category.tests) { + describe(testName, () => { + const testDirectory = path.join(casesPath, category.name, testName); + const filterPath = path.join(testDirectory, 'test.filter.js'); + if (fs.existsSync(filterPath) && !require(filterPath)()) { + it('filtered', () => undefined); + return; + } + const infraStructureLog: string[] = []; + const outBaseDir = path.join(__dirname, 'js'); + const testSubPath = path.join(config.name, category.name, testName); + const outputDirectory = path.join(outBaseDir, testSubPath); + const cacheDirectory = path.join(outBaseDir, '.cache', testSubPath); + let options: any, optionsArr: any[], testConfig: any; + + beforeAll(() => { + options = prepareOptions( + require(path.join(testDirectory, 'webpack.config.js')), + { + testPath: outputDirectory, + }, + ); + optionsArr = [].concat(options); + optionsArr.forEach((opt: any, idx: number) => { + // federation 选项注入 + if (config.federation) { + const mfp = + opt.plugins && + opt.plugins.find( + (p: any) => p.name === 'ModuleFederationPlugin', + ); + if (mfp) { + if (!mfp._options.experiments) + mfp._options.experiments = {}; + if (config.federation?.asyncStartup) { + if ('asyncStartup' in mfp._options.experiments) { + // respect explicit setting + } else { + Object.assign( + mfp._options.experiments, + config.federation, + ); + } + } + } + } + + if (!opt.context) opt.context = testDirectory; + if (!opt.mode) opt.mode = 'production'; + if (!opt.optimization) opt.optimization = {}; + if (opt.optimization.minimize === undefined) + opt.optimization.minimize = false; + if (opt.optimization.minimizer === undefined) { + // 保留注释：不强制设置 minimizer + } + if (!opt.entry) opt.entry = './index.js'; + if (!opt.target) opt.target = 'async-node'; + if (!opt.output) opt.output = {}; + if (!opt.output.path) opt.output.path = outputDirectory; + if (typeof opt.output.pathinfo === 'undefined') + opt.output.pathinfo = true; + if (!opt.output.filename) + opt.output.filename = + 'bundle' + + idx + + (opt.experiments && opt.experiments.outputModule + ? '.mjs' + : '.js'); + if (config.cache) { + opt.cache = { + cacheDirectory, + name: `config-${idx}`, + ...config.cache, + }; + opt.infrastructureLogging = { + debug: true, + console: createLogger(infraStructureLog), + }; + } + if (!opt.snapshot) opt.snapshot = {}; + if (!opt.snapshot.managedPaths) { + opt.snapshot.managedPaths = [ + path.resolve(__dirname, '../node_modules'), + ]; + } + }); + + testConfig = { + findBundle: function (i: number, options: any) { + const ext = path.extname( + parseResource(options.output.filename).path, + ); + if ( + fs.existsSync( + path.join(options.output.path, 'bundle' + i + ext), + ) + ) { + return './bundle' + i + ext; + } + }, + timeout: 30000, + }; + try { + testConfig = Object.assign( + testConfig, + require(path.join(testDirectory, 'test.config.js')), + ); + } catch (e) { + // ignored + } + }); + + afterAll(() => { + options = undefined as any; + optionsArr = undefined as any; + testConfig = undefined as any; + }); + + beforeAll(() => { + rimrafSync(cacheDirectory); + }); + + const handleFatalError = (err: any) => { + const fakeStats = { + errors: [ + { + message: err.message, + stack: err.stack, + }, + ], + } as any; + // error 期望匹配 + if ( + checkArrayExpectation( + testDirectory, + fakeStats, + 'error', + 'Error', + (e: any) => { + throw e; + }, + ) + ) { + return; // 让 rstest 认为测试通过（错误与期望一致） + } + // 否则抛出，交给 rstest 失败 + throw err; + }; + + // cache 预编译：第一次 + if (config.cache) { + it(`${testName} should pre-compile to fill disk cache (1st)`, async () => { + rimrafSync(outputDirectory); + fs.mkdirSync(outputDirectory, { recursive: true }); + infraStructureLog.length = 0; + await new Promise((resolve, reject) => { + try { + // 单次 run + require('webpack')(options, (err: any) => { + const stderrOutput = stderr.toString(); + const { unhandled, results: infrastructureLogErrors } = + collectInfrastructureOutputs( + infraStructureLog, + stderrOutput, + { run: 1, options }, + ); + stderr.reset(); + if (unhandled.length) { + reject( + new Error( + 'Errors/Warnings during build:\n' + + unhandled.join('\n'), + ), + ); + return; + } + if ( + infrastructureLogErrors.length && + checkArrayExpectation( + testDirectory, + { infrastructureLogs: infrastructureLogErrors }, + 'infrastructureLog', + 'infrastructure-log', + 'InfrastructureLog', + (e: any) => { + throw e; + }, + ) + ) { + resolve(); + return; + } + if (err) { + reject(err); + return; + } + resolve(); + }); + } catch (e: any) { + reject(e); + } + }); + }, 60000); + // cache 预编译：第二次 + it(`${testName} should pre-compile to fill disk cache (2nd)`, async () => { + rimrafSync(outputDirectory); + fs.mkdirSync(outputDirectory, { recursive: true }); + infraStructureLog.length = 0; + await new Promise((resolve, reject) => { + try { + require('webpack')(options, (err: any, stats: any) => { + if (err) { + reject(err); + return; + } + const { modules, children, errorsCount } = stats.toJson({ + all: false, + modules: true, + errorsCount: true, + }); + const stderrOutput = stderr.toString(); + const { unhandled, results: infrastructureLogErrors } = + collectInfrastructureOutputs( + infraStructureLog, + stderrOutput, + { run: 2, options }, + ); + stderr.reset(); + if (errorsCount === 0) { + if (unhandled.length) { + reject( + new Error( + 'Errors/Warnings during build:\n' + + unhandled.join('\n'), + ), + ); + return; + } + const allModules = children + ? children.reduce( + (all: any[], { modules }: any) => + all.concat(modules), + modules || [], + ) + : modules; + if ( + allModules.some( + (m: any) => + m.type !== 'cached modules' && !m.cached, + ) + ) { + reject( + new Error( + `Some modules were not cached:\n${stats.toString({ all: false, modules: true, modulesSpace: 100 })}`, + ), + ); + return; + } + } + if ( + infrastructureLogErrors.length && + checkArrayExpectation( + testDirectory, + { infrastructureLogs: infrastructureLogErrors }, + 'infrastructureLog', + 'infrastructure-log', + 'InfrastructureLog', + (e: any) => { + throw e; + }, + ) + ) { + resolve(); + return; + } + resolve(); + }); + } catch (e: any) { + reject(e); + } + }); + }, 40000); + } + + it( + `${testName} should compile`, + async () => { + try { + // Robust cleanup to avoid ENOTEMPTY and race conditions + (fs as any).rmSync?.(outputDirectory, { + recursive: true, + force: true, + }); + } catch { + try { + rimrafSync(outputDirectory); + } catch { + /* ignore */ + } + } + fs.mkdirSync(outputDirectory, { recursive: true }); + infraStructureLog.length = 0; + + // 运行 webpack + const { stats } = await new Promise<{ stats: any }>( + (resolve, reject) => { + const onCompiled = (err: any, stats: any) => { + if (err) return reject(err); + resolve({ stats }); + }; + try { + if (config.cache) { + const compiler = require('webpack')(options); + compiler.run((err: any) => { + if (err) return reject(err); + compiler.run((error: any, stats: any) => { + compiler.close((cerr: any) => { + if (cerr) return reject(cerr); + if (error) return reject(error); + resolve({ stats }); + }); + }); + }); + } else { + require('webpack')(options, onCompiled); + } + } catch (e: any) { + reject(e); + } + }, + ).catch((e) => { + handleFatalError(e); + throw e; // rethrow for rstest to mark failure otherwise + }); + + // 写入 stats + const statOptions = { preset: 'verbose', colors: false }; + fs.mkdirSync(outputDirectory, { recursive: true }); + fs.writeFileSync( + path.join(outputDirectory, 'stats.txt'), + stats.toString(statOptions), + 'utf-8', + ); + const jsonStats = stats.toJson({ errorDetails: true }); + try { + fs.writeFileSync( + path.join(outputDirectory, 'stats.json'), + JSON.stringify(jsonStats, null, 2), + 'utf-8', + ); + } catch {} + + // 错误/警告/infra/deprecation 检查 + if ( + checkArrayExpectation( + testDirectory, + jsonStats, + 'error', + 'Error', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + if ( + checkArrayExpectation( + testDirectory, + jsonStats, + 'warning', + 'Warning', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + const stderrOutput = stderr.toString(); + const { unhandled, results: infrastructureLogErrors } = + collectInfrastructureOutputs( + infraStructureLog, + stderrOutput, + { run: 3, options }, + ); + stderr.reset(); + if (unhandled.length) { + throw new Error( + 'Errors/Warnings during build:\n' + unhandled.join('\n'), + ); + } + if ( + checkArrayExpectation( + testDirectory, + { deprecations: [] }, + 'deprecation', + 'Deprecation', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + if ( + infrastructureLogErrors.length && + checkArrayExpectation( + testDirectory, + { infrastructureLogs: infrastructureLogErrors }, + 'infrastructureLog', + 'infrastructure-log', + 'InfrastructureLog', + (e: any) => { + throw e; + }, + ) + ) { + return; + } + + // 执行 bundle 并收集导出的 it/beforeEach/afterEach（不使用 createLazyTestEnv） + let filesCount = 0; + if (testConfig.noTests) return; // 某些 case 明确无测试 + if (testConfig.beforeExecute) testConfig.beforeExecute(); + + // 聚合器：收集并在当前测试中顺序执行导出的 it 测试 + type Hook = () => any; + type CallbackTestFn = (done: (err?: any) => void) => void; + type PromiseTestFn = () => any | Promise; + type TestFn = CallbackTestFn | PromiseTestFn; + type TestItem = { name: string; fn: TestFn; timeout?: number }; + const hooksBefore: Hook[] = []; + const hooksAfter: Hook[] = []; + const collectedTests: TestItem[] = []; + const defaultTimeout = testConfig.timeout || 30000; + + const caseIt = (name: string, fn: TestFn, timeout?: number) => { + collectedTests.push({ name, fn, timeout }); + }; + const caseBeforeEach = (fn: Hook) => hooksBefore.push(fn); + const caseAfterEach = (fn: Hook) => hooksAfter.push(fn); + + const isCallbackStyle = (fn: TestFn): fn is CallbackTestFn => + fn.length >= 1; + const runMaybeDone = async (fn: TestFn) => { + if (!fn) return; + if (isCallbackStyle(fn)) { + await new Promise((resolve, reject) => { + try { + fn((err?: any) => (err ? reject(err) : resolve())); + } catch (e) { + reject(e); + } + }); + } else { + const r = (fn as PromiseTestFn)(); + if (r && typeof r.then === 'function') await r; + } + }; + + const results: any[] = []; + let testActive = true; + for (let i = 0; i < optionsArr.length; i++) { + const opt = optionsArr[i]; + let bundlePath = testConfig.findBundle(i, optionsArr[i]); + if (!bundlePath) { + // Fallback: try to locate emitted bundle via stats.json entries + try { + const outFiles = fs.readdirSync(opt.output.path); + const execList: string[] = []; + const pushIf = (rel: string) => { + if (fs.existsSync(path.join(opt.output.path, rel))) + execList.push('./' + rel); + }; + pushIf('module/runtime.mjs'); + pushIf('runtime.js'); + pushIf('module/main.mjs'); + pushIf('module/main.js'); + pushIf('main.mjs'); + pushIf('main.js'); + const bundleCand = outFiles.find((f: string) => + /bundle\d+\.(mjs|js)$/.test(f), + ); + if (bundleCand) execList.push('./' + bundleCand); + const remoteEntryCand = outFiles.find( + (f: string) => f === 'remoteEntry.js', + ); + if (remoteEntryCand) + execList.push('./' + remoteEntryCand); + const containerCand = outFiles.find((f: string) => + /container.*\.(mjs|js)$/.test(f), + ); + if (containerCand) execList.push('./' + containerCand); + if (execList.length) bundlePath = execList; + } catch { + /* ignore */ + } + } + if (bundlePath) { + filesCount++; + + const document = new FakeDocument(outputDirectory); + const globalContext = { + console: console, + expect: expect, + setTimeout: setTimeout, + clearTimeout: clearTimeout, + document, + getComputedStyle: + document.getComputedStyle.bind(document), + location: { + href: 'https://test.cases/path/index.html', + origin: 'https://test.cases', + toString() { + return 'https://test.cases/path/index.html'; + }, + }, + } as any; + + const executeBundle = (entryRel: string) => { + const requireCache: Record = + Object.create(null); + const esmCache = new Map(); + const esmIdentifier = `${category.name}-${testName}-${i}-${entryRel}`; + const baseModuleScope: any = { + console: console, + it: caseIt, + beforeEach: caseBeforeEach, + afterEach: caseAfterEach, + expect, + jest: { + resetModules: () => vi.resetModules(), + setTimeout: (...args: any[]) => + (setTimeout as any)(...args), + }, + __STATS__: jsonStats, + nsObj: (m: any) => { + Object.defineProperty(m, Symbol.toStringTag, { + value: 'Module', + }); + return m; + }, + }; + + let runInNewContext = false; + if (opt.target === 'web' || opt.target === 'webworker') { + baseModuleScope.window = globalContext; + baseModuleScope.self = globalContext; + baseModuleScope.document = globalContext.document; + baseModuleScope.setTimeout = globalContext.setTimeout; + baseModuleScope.clearTimeout = + globalContext.clearTimeout; + baseModuleScope.URL = URL; + baseModuleScope.Worker = createFakeWorker({ + outputDirectory, + }); + baseModuleScope.path = nativeRequire('path'); + runInNewContext = true; + } + if (testConfig.moduleScope) { + testConfig.moduleScope(baseModuleScope); + } + const esmContext = vm.createContext(baseModuleScope, { + name: 'context for esm', + }); + + const _require = ( + currentDirectory: string, + opt: any, + module: any, + esmMode?: 'evaluated' | 'unlinked', + parentModule?: any, + ): any => { + // Guard lifecycle: avoid throwing after case teardown + if (!testActive || testConfig === undefined) { + return {}; + } + if (Array.isArray(module) || /^\.\.?\//.test(module)) { + let content = ''; + let p = ''; + let subPath = ''; + if (Array.isArray(module)) { + p = path.join( + currentDirectory, + '.array-require.js', + ); + content = `module.exports = (${module + .map( + (arg: any) => + `require(${JSON.stringify(`./${arg}`)})`, + ) + .join(', ')});`; + } else { + p = path.join(currentDirectory, module); + content = fs.readFileSync(p, 'utf-8'); + const lastSlash = module.lastIndexOf('/'); + let firstSlash = module.indexOf('/'); + if (lastSlash !== -1 && firstSlash !== lastSlash) { + if (firstSlash !== -1) { + let next = module.indexOf('/', firstSlash + 1); + let dir = module.slice(firstSlash + 1, next); + while (dir === '.') { + firstSlash = next; + next = module.indexOf('/', firstSlash + 1); + dir = module.slice(firstSlash + 1, next); + } + } + subPath = module.slice( + firstSlash + 1, + lastSlash + 1, + ); + } + } + + // Follow original template: ESM only when .mjs and outputModule enabled + const isModule = + p.endsWith('.mjs') && + opt.experiments && + opt.experiments.outputModule; + if (isModule) { + let esm = esmCache.get(p); + if (!esm) { + try { + if (!vm.SourceTextModule) + throw new Error( + "Running this test requires '--experimental-vm-modules'.\nRun with 'node --experimental-vm-modules node_modules/jest-cli/bin/jest'.", + ); + esm = new vm.SourceTextModule(content, { + identifier: esmIdentifier + '-' + p, + url: + pathToFileURL(p).href + '?' + esmIdentifier, + context: esmContext, + initializeImportMeta: (meta: any) => { + meta.url = pathToFileURL(p).href; + }, + importModuleDynamically: ( + specifier: string, + mod: any, + _assertions?: any, + ) => { + return _require( + path.dirname(p), + opt, + specifier, + 'evaluated', + mod, + ); + }, + }); + esmCache.set(p, esm); + } catch (err) { + return Promise.resolve({}); + } + } + if (esmMode === 'unlinked') return esm; + return (async () => { + await esm.link( + async ( + specifier: string, + referencingModule: any, + ) => { + return await asModule( + await _require( + path.dirname( + referencingModule.identifier + ? referencingModule.identifier.slice( + esmIdentifier.length + 1, + ) + : fileURLToPath( + referencingModule.url, + ), + ), + opt, + specifier, + 'unlinked', + referencingModule, + ), + referencingModule.context, + true, + ); + }, + ); + if ((esm as any).instantiate) + (esm as any).instantiate(); + await esm.evaluate(); + if (esmMode === 'evaluated') + return (esm as any).namespace; + const ns = (esm as any).namespace; + return ns && + ns.default && + ns.default instanceof Promise + ? ns.default + : ns; + })(); + } else { + if (p in requireCache) { + return requireCache[p].exports; + } + const m = { exports: {} } as any; + requireCache[p] = m; + const moduleScope: any = { + ...baseModuleScope, + require: (id: any) => { + if ( + Array.isArray(id) || + (typeof id === 'string' && /^\.?\./.test(id)) + ) { + return _require(path.dirname(p), opt, id); + } + return nativeRequire( + typeof id === 'string' && + id.startsWith('node:') + ? id.slice(5) + : id, + ); + }, + importScripts: (url: string) => { + expect(url).toMatch( + /^https:\/\/test\.cases\/path\//, + ); + _require( + outputDirectory, + opt, + `.${url.slice('https://test.cases/path'.length)}`, + ); + }, + module: m, + exports: m.exports, + __dirname: path.dirname(p), + __filename: p, + _globalAssign: { expect }, + path: require('path'), + }; + if (testConfig.moduleScope) + testConfig.moduleScope(moduleScope); + if (!runInNewContext) + content = `Object.assign(global, _globalAssign); ${content}`; + const args = Object.keys(moduleScope); + const argValues = args.map( + (arg) => moduleScope[arg], + ); + const code = `(function(${args.join( + ', ', + )}) {${content}\n})`; + const oldCurrentScript = document.currentScript; + (document as any).currentScript = new CurrentScript( + subPath, + ); + const fn = runInNewContext + ? vm.runInNewContext( + code, + globalContext as any, + p, + ) + : vm.runInThisContext(code, p); + fn.call( + testConfig.nonEsmThis + ? testConfig.nonEsmThis(m) + : m.exports, + ...argValues, + ); + (document as any).currentScript = oldCurrentScript; + return m.exports; + } + } else if ( + testConfig.modules && + module in testConfig.modules + ) { + return testConfig.modules[module]; + } else { + return nativeRequire( + module.startsWith('node:') + ? module.slice(5) + : module, + ); + } + }; + + const target = entryRel.startsWith('./') + ? entryRel + : './' + entryRel; + const res = _require(outputDirectory, opt, target); + filesCount++; + results.push(res); + }; + + if (Array.isArray(bundlePath)) { + for (const bundlePathItem of bundlePath) { + try { + executeBundle(bundlePathItem); + } catch {} + } + } else { + try { + executeBundle(bundlePath); + } catch {} + } + } + } + + if (!jsonStats.errors.length && filesCount < 1) { + } + + if (collectedTests.length > 0) { + for (const t of collectedTests) { + // 每个导出测试的 beforeEach + for (const b of hooksBefore) { + await runMaybeDone(b); + } + // 执行测试主体 + await runMaybeDone(t.fn); + // 每个导出测试的 afterEach + for (const a of hooksAfter) { + await runMaybeDone(a); + } + } + } // compile-only case：无导出测试视为通过（只要编译无错误） + + try { + if (testConfig.afterExecute) testConfig.afterExecute(); + } catch {} + testActive = false; + for (const key of Object.keys(global)) { + if (key.includes('webpack')) delete (global as any)[key]; + } + }, + testConfig?.timeout || 30000, + ); + }); + } + }); + } + }); +}; +const patchWebpackStartup = (code: string): string => code; diff --git a/packages/enhanced/test/helpers/warmup-webpack.js b/packages/enhanced/test/helpers/warmup-webpack.js index 15ef382cc01..1d6325ad5e4 100644 --- a/packages/enhanced/test/helpers/warmup-webpack.js +++ b/packages/enhanced/test/helpers/warmup-webpack.js @@ -1,26 +1,30 @@ +// Use Vitest globals (describe/it/expect) via test.globals=true describe('warmup', () => { - it('should warmup webpack', (done) => { - let webpack = require('webpack'); - let END = new Error('end warmup'); - webpack( - { - entry: "data:text/javascript,import 'data:text/javascript,'", - plugins: [ - (c) => - c.hooks.emit.tap('Warmup', () => { - throw END; - }), - ], - }, - (err) => { - webpack = undefined; - try { - expect(err).toBe(END); - done(); - } catch (e) { - done(e); - } - }, - ); + it('should warmup webpack', async () => { + const webpack = require('webpack'); + const END = new Error('end warmup'); + await new Promise((resolve, reject) => { + webpack( + { + entry: "data:text/javascript,import 'data:text/javascript,'", + plugins: [ + (c) => + c.hooks.emit.tap('Warmup', () => { + throw END; + }), + ], + }, + (err) => { + try { + expect(err).toBe(END); + resolve(undefined); + } catch (e) { + reject(e); + } + }, + ); + }); }, 300000); }); +/* global describe, it, expect */ +('use strict'); diff --git a/packages/enhanced/vitest.config.ts b/packages/enhanced/vitest.config.ts new file mode 100644 index 00000000000..4d11727b88e --- /dev/null +++ b/packages/enhanced/vitest.config.ts @@ -0,0 +1,13 @@ +import { defineConfig } from 'vitest/config'; +import path from 'path'; + +export default defineConfig({ + test: { + watch: false, + environment: 'node', + globals: true, + threads: false, + include: [path.resolve(__dirname, 'test/ConfigTestCases.*.vitest.ts')], + testTimeout: 60000, + }, +});