chore(ssr): add prewarm diagnostics (ss/lsof) when remoteEntry timeouts occur; improves CI triage

Author: ScriptedAlchemy

federated-css-react-ssr/shell-apps/css-jss/server/index.js

@@ -16,6 +16,12 @@ async function waitUrl(url, timeout = 300000) {
     } catch (_) {}
 
     if (Date.now() - start > timeout) {
+      // extra diagnostics in CI: try to print which ports are listening
+      try {
+        const { execSync } = require('node:child_process');
+        const ss = execSync(`ss -ltnp | grep :${new URL(url).port} || true`, { stdio: ['ignore','pipe','ignore'] }).toString().trim();
+        if (ss) console.log(`[prewarm] port diag ${new URL(url).port}: ${ss}`);
+      } catch (e) {}
       throw new Error(`prewarm timeout for ${url}`);
     }
     await new Promise(r => setTimeout(r, 5000));

federated-css-react-ssr/shell-apps/css-scss/server/index.js

@@ -12,7 +12,14 @@ async function waitUrl(url, timeout = 300000) {
       const res = await fetch(url);
       if (res.ok) return;
     } catch (_) {}
-    if (Date.now() - start > timeout) throw new Error(`prewarm timeout for ${url}`);
+    if (Date.now() - start > timeout) {
+      try {
+        const { execSync } = require('node:child_process');
+        const ss = execSync(`ss -ltnp | grep :${new URL(url).port} || true`, { stdio: ['ignore','pipe','ignore'] }).toString().trim();
+        if (ss) console.log(`[prewarm] port diag ${new URL(url).port}: ${ss}`);
+      } catch {}
+      throw new Error(`prewarm timeout for ${url}`);
+    }
     await new Promise(r => setTimeout(r, 5000));
   }
 }

federated-css-react-ssr/shell-apps/jss-styled-components-css-module/server/index.js

@@ -12,7 +12,14 @@ async function waitUrl(url, timeout = 300000) {
       const res = await fetch(url);
       if (res.ok) return;
     } catch (_) {}
-    if (Date.now() - start > timeout) throw new Error(`prewarm timeout for ${url}`);
+    if (Date.now() - start > timeout) {
+      try {
+        const { execSync } = require('node:child_process');
+        const ss = execSync(`ss -ltnp | grep :${new URL(url).port} || true`, { stdio: ['ignore','pipe','ignore'] }).toString().trim();
+        if (ss) console.log(`[prewarm] port diag ${new URL(url).port}: ${ss}`);
+      } catch {}
+      throw new Error(`prewarm timeout for ${url}`);
+    }
     await new Promise(r => setTimeout(r, 5000));
   }
 }

federated-css-react-ssr/shell-apps/jss-styled-components/server/index.js

@@ -12,7 +12,14 @@ async function waitUrl(url, timeout = 300000) {
       const res = await fetch(url);
       if (res.ok) return;
     } catch (_) {}
-    if (Date.now() - start > timeout) throw new Error(`prewarm timeout for ${url}`);
+    if (Date.now() - start > timeout) {
+      try {
+        const { execSync } = require('node:child_process');
+        const ss = execSync(`ss -ltnp | grep :${new URL(url).port} || true`, { stdio: ['ignore','pipe','ignore'] }).toString().trim();
+        if (ss) console.log(`[prewarm] port diag ${new URL(url).port}: ${ss}`);
+      } catch {}
+      throw new Error(`prewarm timeout for ${url}`);
+    }
     await new Promise(r => setTimeout(r, 5000));
   }
 }

federated-css-react-ssr/shell-apps/less-scss/server/index.js

@@ -12,7 +12,14 @@ async function waitUrl(url, timeout = 300000) {
       const res = await fetch(url);
       if (res.ok) return;
     } catch (_) {}
-    if (Date.now() - start > timeout) throw new Error(`prewarm timeout for ${url}`);
+    if (Date.now() - start > timeout) {
+      try {
+        const { execSync } = require('node:child_process');
+        const ss = execSync(`ss -ltnp | grep :${new URL(url).port} || true`, { stdio: ['ignore','pipe','ignore'] }).toString().trim();
+        if (ss) console.log(`[prewarm] port diag ${new URL(url).port}: ${ss}`);
+      } catch {}
+      throw new Error(`prewarm timeout for ${url}`);
+    }
     await new Promise(r => setTimeout(r, 5000));
   }
 }

federated-css-react-ssr/shell-apps/scss-tailwind-css/server/index.js

@@ -12,7 +12,14 @@ async function waitUrl(url, timeout = 300000) {
       const res = await fetch(url);
       if (res.ok) return;
     } catch (_) {}
-    if (Date.now() - start > timeout) throw new Error(`prewarm timeout for ${url}`);
+    if (Date.now() - start > timeout) {
+      try {
+        const { execSync } = require('node:child_process');
+        const ss = execSync(`ss -ltnp | grep :${new URL(url).port} || true`, { stdio: ['ignore','pipe','ignore'] }).toString().trim();
+        if (ss) console.log(`[prewarm] port diag ${new URL(url).port}: ${ss}`);
+      } catch {}
+      throw new Error(`prewarm timeout for ${url}`);
+    }
     await new Promise(r => setTimeout(r, 5000));
   }
 }

federated-css/scripts/start-all.cjs

@@ -24,6 +24,17 @@ function forceKillPort(port) {
   try { execSync(`fuser -k ${port}/tcp`, { stdio: 'ignore' }); } catch {}
 }
 
+function diagnosePort(port, label) {
+  try {
+    const ssout = execSync(`ss -ltnp | grep :${port} || true`, { stdio: ['ignore', 'pipe', 'ignore'] }).toString().trim();
+    if (ssout) console.log(`[federated-css] diag ${label} port ${port}: ${ssout}`);
+  } catch {}
+  try {
+    const lsofout = execSync(`lsof -nPiTCP -sTCP:LISTEN | grep :${port} || true`, { stdio: ['ignore', 'pipe', 'ignore'] }).toString().trim();
+    if (lsofout) console.log(`[federated-css] diag ${label} port ${port} (lsof): ${lsofout}`);
+  } catch {}
+}
+
 async function ensurePortFree(port, timeoutMs = 15000) {
   const start = Date.now();
   while (Date.now() - start < timeoutMs) {
@@ -225,6 +236,7 @@ async function main() {
       } catch (error) {
         lastError = error;
         console.warn(`[federated-css] ${label} failed to start: ${error.message}`);
+        diagnosePort(port, label);
         removeProc(proc);
         try {
           proc.kill('SIGTERM');