Merge pull request #8071 from QwikDev/v2-fix-ssg-windows

fix: ssg on windows

Author: wmertens

.github/workflows/ci.yml

@@ -663,6 +663,8 @@ jobs:
           # too slow and flaky. Perhaps better in v2?
           # - host: ubuntu-latest
           #   browser: firefox
+          - host: windows-latest
+            browser: chromium
           - host: macos-latest
             browser: webkit
 
@@ -760,8 +762,6 @@ jobs:
         run: pnpm run test.e2e.integrations.${{ matrix.settings.browser }} --timeout 60000 --retries 7 --workers 1
 
       - name: Playwright E2E Qwik React Tests
-        # This just fails constantly on Windows due to weird segfaults
-        if: matrix.settings.host != 'windows-latest'
         run: pnpm run test.e2e.qwik-react.${{ matrix.settings.browser }} --timeout 60000 --retries 7 --workers 1
 
       - name: CLI E2E Tests

e2e/adapters-e2e/playwright.config.ts

@@ -44,5 +44,6 @@ export default defineConfig({
     port: 3000,
     stdout: 'pipe',
     reuseExistingServer: !process.env.CI,
+    timeout: 120000,
   },
 });

packages/qwik-router/src/adapters/shared/vite/index.ts

@@ -232,34 +232,6 @@ export function viteAdapter(opts: ViteAdapterPluginOptions) {
               process.exit(0);
             }, 5000).unref();
           }
-          if (opts.ssg !== null) {
-            /**
-             * HACK: for some reason the build hangs after SSG. `why-is-node-running` shows 4
-             * culprits:
-             *
-             * ```
-             * There are 4 handle(s) keeping the process running.
-             *
-             * # CustomGC
-             * ./node_modules/.pnpm/[email protected]/node_modules/lightningcss/node/index.js:20 - module.exports = require(`lightningcss-${parts.join('-')}`);
-             *
-             * # CustomGC
-             * ./node_modules/.pnpm/@[email protected]/node_modules/@tailwindcss/oxide/index.js:229 - return require('@tailwindcss/oxide-linux-x64-gnu')
-             *
-             * # Timeout
-             * node_modules/.vite-temp/vite.config.timestamp-1755270314169-a2a97ad5233f9.mjs:357
-             * ./node_modules/.pnpm/[email protected]_@[email protected][email protected][email protected][email protected][email protected][email protected]/node_modules/vite/dist/node/chunks/dep-CMEinpL-.js:36657 - return (await import(pathToFileURL(tempFileName).href)).default;
-             *
-             * # CustomGC
-             * ./packages/qwik/dist/optimizer.mjs:1328 - const mod2 = module.default.createRequire(import.meta.url)(`../bindings/${triple.platformArchABI}`);
-             * ```
-             *
-             * For now, we'll force exit the process after SSG with some delay.
-             */
-            setTimeout(() => {
-              process.exit(0);
-            }, 5000).unref();
-          }
         }
       },
     },

packages/qwik-router/src/ssg/deno/index.ts

@@ -10,7 +10,7 @@ import type { SsgOptions, SsgRenderOptions, SsgResult } from './types';
  */
 export async function generate(opts: SsgOptions) {
   const ssgPlatform = await getEntryModule();
-  const result: SsgResult = (await ssgPlatform.generate(opts)) as any;
+  const result: SsgResult = await ssgPlatform.generate(opts);
   return result;
 }
 
@@ -20,27 +20,10 @@ export type {
   SsgResult as StaticGenerateResult,
 };
 
-function getEntryModule() {
-  if (isDeno()) {
-    return import('./deno');
+async function getEntryModule() {
+  try {
+    return await import('./node');
+  } catch (e) {
+    throw new Error(`Unsupported platform`, { cause: e });
   }
-  if (isBun() || isNode()) {
-    return import('./node');
-  }
-  throw new Error(`Unsupported platform`);
-}
-
-function isDeno() {
-  return typeof Deno !== 'undefined';
-}
-
-function isBun() {
-  return typeof Bun !== 'undefined';
-}
-
-function isNode() {
-  return !isBun() && !isDeno() && typeof process !== 'undefined' && !!process.versions?.node;
 }
-
-declare const Deno: any;
-declare const Bun: any;

packages/qwik-router/src/ssg/index.ts

@@ -81,13 +81,17 @@ export async function mainThread(sys: System) {
         while (!isCompleted && main.hasAvailableWorker() && queue.length > 0) {
           const staticRoute = queue.shift();
           if (staticRoute) {
-            render(staticRoute);
+            render(staticRoute).catch((e) => {
+              console.error(`render failed for ${staticRoute.pathname}`, e);
+            });
           }
         }
 
         if (!isCompleted && isRoutesLoaded && queue.length === 0 && active.size === 0) {
           isCompleted = true;
-          completed();
+          completed().catch((e) => {
+            console.error('SSG completion failed', e);
+          });
         }
       };
 
@@ -135,6 +139,7 @@ export async function mainThread(sys: System) {
 
           flushQueue();
         } catch (e) {
+          console.error(`render failed for ${staticRoute.pathname}`, e);
           isCompleted = true;
           reject(e);
         }
@@ -217,8 +222,12 @@ export async function mainThread(sys: System) {
         flushQueue();
       };
 
-      loadStaticRoutes();
+      loadStaticRoutes().catch((e) => {
+        console.error('SSG route loading failed', e);
+        reject(e);
+      });
     } catch (e) {
+      console.error('SSG main thread failed', e);
       reject(e);
     }
   });
@@ -251,6 +260,6 @@ function validateOptions(opts: SsgOptions) {
   try {
     new URL(siteOrigin);
   } catch (e) {
-    throw new Error(`Invalid "origin": ${e}`);
+    throw new Error(`Invalid "origin"`, { cause: e as Error });
   }
 }

packages/qwik-router/src/ssg/main-thread.ts

@@ -1,6 +1,6 @@
 import type { SsgOptions } from '../types';
 import { createSystem } from './node-system';
-import { isMainThread, workerData } from 'node:worker_threads';
+import { isMainThread, workerData, threadId } from 'node:worker_threads';
 import { mainThread } from '../main-thread';
 import { workerThread } from '../worker-thread';
 
@@ -15,9 +15,20 @@ export async function generate(opts: SsgOptions) {
 }
 
 if (!isMainThread && workerData) {
+  const opts = workerData as SsgOptions;
   (async () => {
-    // self initializing worker thread with workerData
-    const sys = await createSystem(workerData);
-    await workerThread(sys);
-  })();
+    try {
+      if (opts.log === 'debug') {
+        // eslint-disable-next-line no-console
+        console.debug(`Worker thread starting (ID: ${threadId})`);
+      }
+      // self initializing worker thread with workerData
+      const sys = await createSystem(opts, threadId);
+      await workerThread(sys);
+    } catch (error) {
+      console.error(`Error occurred in worker thread (ID: ${threadId}): ${error}`);
+    }
+  })().catch((e) => {
+    console.error(e);
+  });
 }

packages/qwik-router/src/ssg/node/index.ts

@@ -10,10 +10,9 @@ import type {
 import fs from 'node:fs';
 import { cpus as nodeCpus } from 'node:os';
 import { Worker } from 'node:worker_threads';
-import { isAbsolute, resolve } from 'node:path';
+import { dirname, extname, isAbsolute, join, resolve } from 'node:path';
 import { ensureDir } from './node-system';
 import { normalizePath } from '../../utils/fs';
-import { createSingleThreadWorker } from '../worker-thread';
 
 export async function createNodeMainProcess(sys: System, opts: SsgOptions) {
   const ssgWorkers: SsgWorker[] = [];
@@ -51,45 +50,34 @@ export async function createNodeMainProcess(sys: System, opts: SsgOptions) {
     }
   }
 
-  const singleThreadWorker = await createSingleThreadWorker(sys);
-
-  const createWorker = (workerIndex: number) => {
-    if (workerIndex === 0) {
-      // same thread worker, don't start a new process
-      const ssgSameThreadWorker: SsgWorker = {
-        activeTasks: 0,
-        totalTasks: 0,
-
-        render: async (staticRoute) => {
-          ssgSameThreadWorker.activeTasks++;
-          ssgSameThreadWorker.totalTasks++;
-          const result = await singleThreadWorker(staticRoute);
-          ssgSameThreadWorker.activeTasks--;
-          return result;
-        },
-
-        terminate: async () => {},
-      };
-      return ssgSameThreadWorker;
-    }
-
+  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;
+      // CommonJS path
+      const ext = extname(__filename) || '.js';
+      workerFilePath = join(dirname(__filename), `index${ext}`);
     } else {
-      workerFilePath = import.meta.url;
-    }
+      // ESM path (import.meta.url)
+      const thisUrl = new URL(import.meta.url);
+      const pathname = thisUrl.pathname || '';
+      let ext = '.js';
+      if (pathname.endsWith('.ts')) {
+        ext = '.ts';
+      } else if (pathname.endsWith('.mjs')) {
+        ext = '.mjs';
+      }
 
-    if (typeof workerFilePath === 'string' && workerFilePath.startsWith('file://')) {
-      workerFilePath = new URL(workerFilePath);
+      workerFilePath = new URL(`./index${ext}`, thisUrl);
     }
 
     const nodeWorker = new Worker(workerFilePath, { workerData: opts });
-
+    nodeWorker.unref();
     const ssgWorker: SsgWorker = {
       activeTasks: 0,
       totalTasks: 0,
@@ -116,7 +104,9 @@ export async function createNodeMainProcess(sys: System, opts: SsgOptions) {
           terminateResolve = resolve;
           nodeWorker.postMessage(msg);
         });
-        await nodeWorker.terminate();
+        terminateTimeout = setTimeout(async () => {
+          await nodeWorker.terminate();
+        }, 1000) as unknown as number;
       },
     };
 
@@ -146,7 +136,11 @@ export async function createNodeMainProcess(sys: System, opts: SsgOptions) {
     });
 
     nodeWorker.on('exit', (code) => {
-      if (code !== 1) {
+      if (terminateTimeout) {
+        clearTimeout(terminateTimeout);
+        terminateTimeout = null;
+      }
+      if (code !== 0) {
         console.error(`worker exit ${code}`);
       }
     });
@@ -200,9 +194,15 @@ export async function createNodeMainProcess(sys: System, opts: SsgOptions) {
         console.error(e);
       }
     }
-    ssgWorkers.length = 0;
 
     await Promise.all(promises);
+    ssgWorkers.length = 0;
+
+    // On Windows, give extra time for all workers to fully exit
+    // This prevents resource conflicts in back-to-back builds
+    if (process.platform === 'win32') {
+      await new Promise((resolve) => setTimeout(resolve, 300));
+    }
   };
 
   if (sitemapOutFile) {
@@ -214,7 +214,11 @@ export async function createNodeMainProcess(sys: System, opts: SsgOptions) {
   }
 
   for (let i = 0; i < maxWorkers; i++) {
-    ssgWorkers.push(createWorker(i));
+    ssgWorkers.push(createWorker());
+    // On Windows, add delay between worker creation to avoid resource contention
+    if (process.platform === 'win32' && i < maxWorkers - 1) {
+      await new Promise((resolve) => setTimeout(resolve, 100));
+    }
   }
 
   const mainCtx: MainContext = {

packages/qwik-router/src/ssg/node/node-main.ts

@@ -7,7 +7,7 @@ import { createNodeWorkerProcess } from './node-worker';
 import { normalizePath } from '../../utils/fs';
 
 /** @public */
-export async function createSystem(opts: SsgOptions) {
+export async function createSystem(opts: SsgOptions, threadId?: number): Promise<System> {
   const createWriteStream = (filePath: string) => {
     return fs.createWriteStream(filePath, {
       flags: 'w',
@@ -26,6 +26,13 @@ export async function createSystem(opts: SsgOptions) {
   };
 
   const createLogger = async () => {
+    if (threadId !== undefined) {
+      return {
+        debug: opts.log === 'debug' ? console.debug.bind(console, `[${threadId}]`) : () => {},
+        error: console.error.bind(console, `[${threadId}]`),
+        info: console.info.bind(console, `[${threadId}]`),
+      };
+    }
     return {
       debug: opts.log === 'debug' ? console.debug.bind(console) : () => {},
       error: console.error.bind(console),

packages/qwik-router/src/ssg/node/node-system.ts

@@ -6,5 +6,8 @@ export async function createNodeWorkerProcess(
 ) {
   parentPort?.on('message', async (msg: WorkerInputMessage) => {
     parentPort?.postMessage(await onMessage(msg));
+    if (msg.type === 'close') {
+      parentPort?.close();
+    }
   });
 }