Function unixWaveScript

e2e/cli/election-cold-start.test.ts:80–107

(exe: string, dir: string, n: number)

// single parseable summary line. Unix (linux+macos) flavor; the election logic
// under test is OS-agnostic, the shell around it is not.
const unixWaveScript = (exe: string, dir: string, n: number): string =>
  [
    "set -u",
    `EXE=${exe}`,
    `D=${dir}`,
    // `timeout` is GNU coreutils: present on Linux, absent on the macOS guest
    // (where it would be `gtimeout`). Fall back to no wrapper; the test's own
    // 300s budget and `tools search` self-completing are the backstops.
    "TO=$(command -v timeout 2>/dev/null || command -v gtimeout 2>/dev/null || true)",
    "run_client() {",
    '  if [ -n "$TO" ]; then',
    `    "$TO" 120 env EXECUTOR_DATA_DIR="$D" EXECUTOR_SCOPE_DIR="$D" "$EXE" tools search "probe-$1" >"$D/out-$1" 2>&1`,
    "  else",
    `    env EXECUTOR_DATA_DIR="$D" EXECUTOR_SCOPE_DIR="$D" "$EXE" tools search "probe-$1" >"$D/out-$1" 2>&1`,
    "  fi",
    '  echo $? >"$D/rc-$1"',
    "}",
    `i=1; while [ $i -le ${n} ]; do run_client $i & i=$((i+1)); done; wait`,
    "ok=0; spawned=0; i=1",
    `while [ $i -le ${n} ]; do`,
    '  rc=$(cat "$D/rc-$i" 2>/dev/null || echo X); [ "$rc" = "0" ] && ok=$((ok+1))',
    '  grep -q "Starting daemon" "$D/out-$i" 2>/dev/null && spawned=$((spawned+1))',
    "  i=$((i+1)); done",
    `manifests=$(ls "$D"/daemon-active-* 2>/dev/null | wc -l | tr -d ' ')`,
    `port=$(cat "$D"/daemon-localhost-*.json 2>/dev/null | sed -n 's/.*"port":[ ]*\\([0-9]*\\).*/\\1/p' | head -1)`,
    `health=$(curl -s -o /dev/null -w '%{http_code}' --max-time 5 "http://localhost:$port/api/health" 2>/dev/null || echo 000)`,
    `echo "PROBE_SUMMARY ok=$ok n=${n} spawned=$spawned manifests=$manifests port=$port health=$health"`,
  ].join("\n");

const parseSummary = (stdout: string): Record<string, string> => {
  const line = stdout.split("\n").find((l) => l.includes("PROBE_SUMMARY"));