Files
Basilosaurusrex f027651f9b main repo
2025-11-24 18:09:40 +01:00

87 lines
4.1 KiB
JavaScript

import * as Log from "../output/log";
import { NextBuildContext } from "../build-context";
import { Worker } from "next/dist/compiled/jest-worker";
import origDebug from "next/dist/compiled/debug";
import path from "path";
const debug = origDebug("next:build:webpack-build");
async function webpackBuildWithWorker() {
const { config, telemetryPlugin, buildSpinner, nextBuildSpan, ...prunedBuildContext } = NextBuildContext;
const getWorker = (compilerName)=>{
var _worker__workerPool;
const _worker = new Worker(path.join(__dirname, "impl.js"), {
exposedMethods: [
"workerMain"
],
numWorkers: 1,
maxRetries: 0,
forkOptions: {
env: {
...process.env,
NEXT_PRIVATE_BUILD_WORKER: "1"
}
}
});
_worker.getStderr().pipe(process.stderr);
_worker.getStdout().pipe(process.stdout);
for (const worker of ((_worker__workerPool = _worker._workerPool) == null ? void 0 : _worker__workerPool._workers) || []){
worker._child.on("exit", (code, signal)=>{
if (code || signal) {
console.error(`Compiler ${compilerName} unexpectedly exited with code: ${code} and signal: ${signal}`);
}
});
}
return _worker;
};
const combinedResult = {
duration: 0,
turbotraceContext: {}
};
// order matters here
const ORDERED_COMPILER_NAMES = [
"server",
"edge-server",
"client"
];
for (const compilerName of ORDERED_COMPILER_NAMES){
var _curResult_serializedPagesManifestEntries, _curResult_serializedPagesManifestEntries1, _curResult_serializedPagesManifestEntries2, _curResult_serializedPagesManifestEntries3, _curResult_turbotraceContext;
const worker = getWorker(compilerName);
const curResult = await worker.workerMain({
buildContext: prunedBuildContext,
compilerName
});
// destroy worker so it's not sticking around using memory
await worker.end();
// Update plugin state
prunedBuildContext.pluginState = curResult.pluginState;
prunedBuildContext.serializedPagesManifestEntries = {
edgeServerAppPaths: (_curResult_serializedPagesManifestEntries = curResult.serializedPagesManifestEntries) == null ? void 0 : _curResult_serializedPagesManifestEntries.edgeServerAppPaths,
edgeServerPages: (_curResult_serializedPagesManifestEntries1 = curResult.serializedPagesManifestEntries) == null ? void 0 : _curResult_serializedPagesManifestEntries1.edgeServerPages,
nodeServerAppPaths: (_curResult_serializedPagesManifestEntries2 = curResult.serializedPagesManifestEntries) == null ? void 0 : _curResult_serializedPagesManifestEntries2.nodeServerAppPaths,
nodeServerPages: (_curResult_serializedPagesManifestEntries3 = curResult.serializedPagesManifestEntries) == null ? void 0 : _curResult_serializedPagesManifestEntries3.nodeServerPages
};
combinedResult.duration += curResult.duration;
if ((_curResult_turbotraceContext = curResult.turbotraceContext) == null ? void 0 : _curResult_turbotraceContext.entriesTrace) {
combinedResult.turbotraceContext = curResult.turbotraceContext;
const { entryNameMap } = combinedResult.turbotraceContext.entriesTrace;
if (entryNameMap) {
combinedResult.turbotraceContext.entriesTrace.entryNameMap = new Map(entryNameMap);
}
}
}
buildSpinner == null ? void 0 : buildSpinner.stopAndPersist();
Log.event("Compiled successfully");
return combinedResult;
}
export async function webpackBuild() {
const config = NextBuildContext.config;
if (config.experimental.webpackBuildWorker) {
debug("using separate compiler workers");
return await webpackBuildWithWorker();
} else {
debug("building all compilers in same process");
const webpackBuildImpl = require("./impl").webpackBuildImpl;
return await webpackBuildImpl();
}
}
//# sourceMappingURL=index.js.map