vrr/Pulse
2
0
Fork 0
mirror of https://github.com/rcourtman/Pulse.git synced 2026-04-28 03:20:11 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix(e2e): add signal handlers and detailed tracing to diagnose exit code 13

Browse source
This commit is contained in:
rcourtman 2025-12-19 15:59:48 +00:00
parent 98c4a08d64
commit d786e55f8f
1 changed files with 34 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

36
tests/integration/scripts/pretest.mjs
View file

@ -1,5 +1,24 @@
import { spawn } from 'node:child_process';
// Add signal handlers to debug unexpected termination
const signals = ['SIGTERM', 'SIGINT', 'SIGHUP', 'SIGPIPE', 'SIGQUIT'];
signals.forEach(sig => {
process.on(sig, () => {
console.error(`[pretest] Received signal: ${sig}`);
process.exit(128 + (process[sig] || 1));
});
});
process.on('uncaughtException', (err) => {
console.error('[pretest] Uncaught exception:', err);
process.exit(1);
});
process.on('unhandledRejection', (reason, promise) => {
console.error('[pretest] Unhandled rejection at:', promise, 'reason:', reason);
process.exit(1);
});
const truthy = (value) => {
if (!value) return false;
return ['1', 'true', 'yes', 'on'].includes(String(value).trim().toLowerCase());
@ -13,6 +32,7 @@ if (!process.env.PULSE_E2E_BOOTSTRAP_TOKEN) {
process.env.PULSE_E2E_BOOTSTRAP_TOKEN = DEFAULT_E2E_BOOTSTRAP_TOKEN;
}
const run = (command, args, options = {}) =>
new Promise((resolve, reject) => {
const child = spawn(command, args, { stdio: 'inherit', ...options });
@ -35,19 +55,31 @@ const canRun = async (command, args) => {
};
const waitForHealth = async (healthURL, timeoutMs = 120_000) => {
console.log(`[pretest] Starting health check loop for ${healthURL}`);
const startedAt = Date.now();
let attempt = 0;
while (Date.now() - startedAt < timeoutMs) {
attempt++;
console.log(`[pretest] Health check attempt ${attempt}...`);
try {
console.log(`[pretest] Calling fetch...`);
const res = await fetch(healthURL, { method: 'GET' });
if (res.ok) return;
} catch {
console.log(`[pretest] Fetch returned status ${res.status}`);
if (res.ok) {
console.log(`[pretest] Health check succeeded!`);
return;
}
} catch (error) {
console.log(`[pretest] Fetch error: ${error.code || error.message}`);
// ignore and retry
}
console.log(`[pretest] Sleeping 1s before retry...`);
await new Promise((r) => setTimeout(r, 1000));
}
throw new Error(`Timed out waiting for ${healthURL}`);
};
if (truthy(process.env.PULSE_E2E_INSECURE_TLS)) {
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';
}