fix(ports): enforce pre-start port clearance across suites\n\n- start-all: ensurePortFree before all consumers-react & expose servers; Next binds to 127.0.0.1\n- ssr start-exposes/shells: ensurePortFree before serve; kill any listeners via lsof/fuser\n- add diagnostics and stronger kill loops

Author: ScriptedAlchemy

federated-css-react-ssr/scripts/start-exposes.cjs

@@ -2,6 +2,7 @@ const { spawn } = require('node:child_process');
 const path = require('node:path');
 const waitOn = require('wait-on');
 const kill = require('kill-port');
+const { execSync } = require('node:child_process');
 
 const root = path.resolve(__dirname, '..');
 
@@ -17,6 +18,28 @@ async function killPort(port) {
   }
 }
 
+const delay = ms => new Promise(r => setTimeout(r, ms));
+function isPortInUse(port) {
+  try {
+    const out = execSync(`lsof -nPiTCP -sTCP:LISTEN | grep :${port}\\>`, { stdio: ['ignore', 'pipe', 'ignore'] }).toString();
+    return out.trim().length > 0;
+  } catch {
+    return false;
+  }
+}
+function forceKillPort(port) {
+  try { execSync(`lsof -ti:${port} | xargs kill -9`, { stdio: 'ignore' }); } catch {}
+  try { execSync(`fuser -k ${port}/tcp`, { stdio: 'ignore' }); } catch {}
+}
+async function ensurePortFree(port, timeoutMs = 15000) {
+  const start = Date.now();
+  while (Date.now() - start < timeoutMs) {
+    if (!isPortInUse(port)) return;
+    forceKillPort(port);
+    await delay(500);
+  }
+}
+
 async function exec(cmd, args, opts = {}) {
   return new Promise((resolve, reject) => {
     const p = run(cmd, args, opts);
@@ -54,6 +77,8 @@ async function main() {
     const cwd = path.join('expose-apps', dir);
     console.log(`[exposes] building ${dir}...`);
     await exec('pnpm', ['-C', cwd, 'run', 'build']);
+    console.log(`[exposes] ensuring port ${port} is free for ${dir}...`);
+    await ensurePortFree(port, 20000);
     console.log(`[exposes] serving ${dir} on ${port}...`);
     const p = run('pnpm', ['-C', cwd, 'run', 'serve']);
     procs.push(p);

federated-css-react-ssr/scripts/start-shells.cjs

@@ -2,6 +2,7 @@ const { spawn } = require('node:child_process');
 const path = require('node:path');
 const waitOn = require('wait-on');
 const kill = require('kill-port');
+const { execSync } = require('node:child_process');
 
 const root = path.resolve(__dirname, '..');
 
@@ -17,6 +18,28 @@ async function killPort(port) {
   }
 }
 
+const delay = ms => new Promise(r => setTimeout(r, ms));
+function isPortInUse(port) {
+  try {
+    const out = execSync(`lsof -nPiTCP -sTCP:LISTEN | grep :${port}\\>`, { stdio: ['ignore', 'pipe', 'ignore'] }).toString();
+    return out.trim().length > 0;
+  } catch {
+    return false;
+  }
+}
+function forceKillPort(port) {
+  try { execSync(`lsof -ti:${port} | xargs kill -9`, { stdio: 'ignore' }); } catch {}
+  try { execSync(`fuser -k ${port}/tcp`, { stdio: 'ignore' }); } catch {}
+}
+async function ensurePortFree(port, timeoutMs = 15000) {
+  const start = Date.now();
+  while (Date.now() - start < timeoutMs) {
+    if (!isPortInUse(port)) return;
+    forceKillPort(port);
+    await delay(500);
+  }
+}
+
 async function exec(cmd, args, opts = {}) {
   return new Promise((resolve, reject) => {
     const p = run(cmd, args, opts);
@@ -54,6 +77,8 @@ async function main() {
     console.log(`[shells] building ${dir}...`);
     await exec('pnpm', ['-C', cwd, 'run', 'build']);
 
+    console.log(`[shells] ensuring port ${port} is free for ${dir}...`);
+    await ensurePortFree(port, 20000);
     console.log(`[shells] starting ${dir} on port ${port}...`);
     const p = run('pnpm', ['-C', cwd, 'run', 'serve']);
     procs.push(p);

federated-css/scripts/start-all.cjs

@@ -129,6 +129,8 @@ async function main() {
       const buildProc = run('pnpm', ['-C', cwd, 'run', 'build']);
       buildProc.on('exit', code => (code === 0 ? res() : rej(new Error(`build ${dir} failed`))));
     });
+    console.log(`[federated-css] ensuring port ${port} is free for consumers-react ${dir}...`);
+    await ensurePortFree(port, 20000);
     const serveProc = run('pnpm', ['-C', cwd, 'run', 'serve']);
     procs.push(serveProc);
 
@@ -172,6 +174,8 @@ async function main() {
     const dir = dirMap[port];
     if (!dir) continue;
     const cwd = path.join('expose-remotes', dir);
+    console.log(`[federated-css] ensuring port ${port} is free for expose ${dir}...`);
+    await ensurePortFree(port, 20000);
     const p = run('pnpm', ['-C', cwd, 'run', 'serve']);
     procs.push(p);
     const exposeResources = [
@@ -205,7 +209,7 @@ async function main() {
       console.log(`[federated-css] ensuring port ${port} is free for ${label}...`);
       await ensurePortFree(port, 20000);
       console.log(`[federated-css] starting ${label} with next start...`);
-      const proc = run('pnpm', ['-C', cwd, 'exec', 'next', 'start', '-p', String(port)]);
+      const proc = run('pnpm', ['-C', cwd, 'exec', 'next', 'start', '-H', '127.0.0.1', '-p', String(port)]);
       procs.push(proc);
 
       try {