Function createNodeMainProcess

packages/qwik-city/src/static/node/node-main.ts:17–238

(sys: System, opts: StaticGenerateOptions)

import { normalizePath } from '../../utils/fs';

export async function createNodeMainProcess(sys: System, opts: StaticGenerateOptions) {
  const ssgWorkers: StaticGeneratorWorker[] = [];
  const sitemapBuffer: string[] = [];
  let sitemapStream: fs.WriteStream | null = null;

  opts = { ...opts };

  let outDir = opts.outDir;
  if (typeof outDir !== 'string') {
    throw new Error(`Missing "outDir" option`);
  }
  if (!isAbsolute(outDir)) {
    throw new Error(`"outDir" must be an absolute file path, received: ${outDir}`);
  }
  outDir = normalizePath(outDir);

  let maxWorkers = nodeCpus().length;
  if (typeof opts.maxWorkers === 'number') {
    maxWorkers = Math.max(1, Math.min(opts.maxWorkers, maxWorkers));
  }

  let maxTasksPerWorker = 20;
  if (typeof opts.maxTasksPerWorker === 'number') {
    maxTasksPerWorker = Math.max(1, Math.min(opts.maxTasksPerWorker, 50));
  }

  let sitemapOutFile = opts.sitemapOutFile;
  if (sitemapOutFile !== null) {
    if (typeof sitemapOutFile !== 'string') {
      sitemapOutFile = 'sitemap.xml';
    }
    if (!isAbsolute(sitemapOutFile)) {
      sitemapOutFile = resolve(outDir, sitemapOutFile);
    }
  }
  const createWorker = () => {
    let terminateResolve: (() => void) | null = null;
    const mainTasks = new Map<string, WorkerMainTask>();

    let workerFilePath: string | URL;
    let terminateTimeout: number | null = null;

    // Launch the worker using the package's index module, which bootstraps the worker thread.
    if (typeof __filename === 'string') {
      workerFilePath = __filename;
    } else {
      workerFilePath = import.meta.url;
    }

    if (typeof workerFilePath === 'string' && workerFilePath.startsWith('file://')) {
      workerFilePath = new URL(workerFilePath);
    }

    const nodeWorker = new Worker(workerFilePath, { workerData: opts });
    nodeWorker.unref();

    const ssgWorker: StaticGeneratorWorker = {
      activeTasks: 0,