// Boot the cloud target for the vitest suite: claim this checkout's port// block atomically (src/ports.ts), then run the shared boot recipe// (cloud.boot.ts — emulated WorkOS + Autumn + the app's real dev stack, the// same recipe the dev CLI uses). Set E2E_CLOUD_URL to attach to a running// stack instead.import { mkdirSync } from "node:fs";import { resolve } from "node:path"; import { claimAndBoot } from "../src/ports";import { E2E_COOKIE_PASSWORD, E2E_WORKOS_CLIENT_ID } from "../targets/cloud";import { isBootReadinessTimeout, waitForHttp } from "./boot";import { bootCloud } from "./cloud.boot";import { ensureE2eMcpSessionTimeoutEnv } from "./mcp-session-timeouts";import { bootMotel, motelExporterEnv } from "./motel";import { RUNS_DIR } from "../src/scenario"; // dev-db + vite dev stdout/stderr, swept into the failure-only artifact// upload (CI uploads e2e/runs/**): see .github/workflows/ci.yml. A// mid-shard OOM abort or a 500 cascade otherwise leaves no trace: boot.ts// defaults to stdio "ignore" unless E2E_VERBOSE=1. Skip the file when// E2E_VERBOSE is set so local `E2E_VERBOSE=1` keeps its inherited,// live-in-terminal output (boot.ts prioritizes logFile over E2E_VERBOSE, so// passing both would silently swallow the verbose stream into the file).const bootLogFile = process.env.E2E_VERBOSE ? undefined : resolve(RUNS_DIR, "cloud", "server-logs", "boot.log"); const optionalCloudEnv = (): Record<string, string> => { // The Sentry/OTel correlation scenario always runs in this suite, so the // verification route and beforeSend payload logging default on here; the // env vars remain overridable for local runs against a different setup. const env: Record<string, string> = { SENTRY_OTEL_VERIFY: "true", SENTRY_OTEL_LOG_PAYLOAD: "true", }; for (const key of ["SENTRY_DSN", "SENTRY_OTEL_LOG_PAYLOAD", "SENTRY_OTEL_VERIFY"]) { const value = process.env[key]; if (value) env[key] = value; } return env;}; export default async function setup(): Promise<(() => Promise<void>) | void> { if (process.env.E2E_CLOUD_URL) { await waitForHttp(process.env.E2E_CLOUD_URL); return; } if (bootLogFile) mkdirSync(resolve(bootLogFile, ".."), { recursive: true }); ensureE2eMcpSessionTimeoutEnv(); // Suite-owned trace store — every run captures distributed traces. Booted // once outside the retry: it binds its own OS-assigned port (not a claimed // one), so an EADDRINUSE on the claimed block doesn't implicate it. const motel = await bootMotel(); // Publish to the test workers (they inherit this process's env): scenarios // that assert on exported spans yield the Telemetry service, which exists // only when this is set. No motel → those scenarios skip, never fail. if (motel) process.env.E2E_MOTEL_URL = motel.url; // Claim a free port block (preferred block first, walk forward past // squatters/colliding checkouts), boot the stack, and retry on EADDRINUSE — // on Linux CI an ephemeral outbound socket can still grab a claimed port // between probe and bind, so re-claim the next block and retry. claimAndBoot // publishes the claimed ports via env (E2E_*_PORT) so the test workers — // spawned after this — derive the same URLs; the imported targets/cloud // constants were computed BEFORE the claim, so use the claimed values here. let booted; try { booted = await claimAndBoot( [ { envVar: "E2E_CLOUD_PORT", offset: 0, label: "cloud vite dev" }, { envVar: "E2E_CLOUD_DB_PORT", offset: 1, label: "cloud dev-db (PGlite)" }, { envVar: "E2E_WORKOS_EMULATOR_PORT", offset: 2, label: "WorkOS emulator" }, { envVar: "E2E_AUTUMN_EMULATOR_PORT", offset: 3, label: "Autumn emulator" }, ], async (ports) => { const publicUrl = `http://localhost:${ports.E2E_CLOUD_PORT!}`; const cloud = await bootCloud({ cloudPort: ports.E2E_CLOUD_PORT!, dbPort: ports.E2E_CLOUD_DB_PORT!, workosPort: ports.E2E_WORKOS_EMULATOR_PORT!, autumnPort: ports.E2E_AUTUMN_EMULATOR_PORT!, workosClientId: E2E_WORKOS_CLIENT_ID, cookiePassword: E2E_COOKIE_PASSWORD, publicUrl, logFile: bootLogFile, // Server + browser spans → the suite's motel. The app's exporter is // endpoint-agnostic, so the same layer that ships prod traces to // Axiom ships e2e traces to the suite store — "why was that page // slow" gets a span waterfall, not a guess. extraEnv: { ...motelExporterEnv(motel, publicUrl), ...optionalCloudEnv() }, }); return { teardown: cloud.teardown, value: cloud }; }, { label: "cloud", retryWhen: isBootReadinessTimeout }, ); // Publish the Autumn emulator URL to the test workers (they inherit this // process's env): scenarios that assert on tracked usage yield the Autumn // service, which exists only when this is set. No emulator → those scenarios // skip, never fail. (Cloud-only; selfhost never boots Autumn.) process.env.E2E_AUTUMN_URL = booted.value.autumnUrl; } catch (error) { await motel?.teardown(); throw error; } return async () => { await booted.teardown(); await motel?.teardown(); };}
// Boot the cloud target for the vitest suite: claim this checkout's port
// block atomically (src/ports.ts), then run the shared boot recipe
// (cloud.boot.ts — emulated WorkOS + Autumn + the app's real dev stack, the
// same recipe the dev CLI uses). Set E2E_CLOUD_URL to attach to a running
// stack instead.
import { mkdirSync } from "node:fs";
import { resolve } from "node:path";
import { claimAndBoot } from "../src/ports";
import { E2E_COOKIE_PASSWORD, E2E_WORKOS_CLIENT_ID } from "../targets/cloud";
import { isBootReadinessTimeout, waitForHttp } from "./boot";
import { bootCloud } from "./cloud.boot";
import { ensureE2eMcpSessionTimeoutEnv } from "./mcp-session-timeouts";
import { bootMotel, motelExporterEnv } from "./motel";
import { RUNS_DIR } from "../src/scenario";
// dev-db + vite dev stdout/stderr, swept into the failure-only artifact
// upload (CI uploads e2e/runs/**): see .github/workflows/ci.yml. A
// mid-shard OOM abort or a 500 cascade otherwise leaves no trace: boot.ts
// defaults to stdio "ignore" unless E2E_VERBOSE=1. Skip the file when
// E2E_VERBOSE is set so local `E2E_VERBOSE=1` keeps its inherited,
// live-in-terminal output (boot.ts prioritizes logFile over E2E_VERBOSE, so
// passing both would silently swallow the verbose stream into the file).
const bootLogFile = process.env.E2E_VERBOSE
? undefined
: resolve(RUNS_DIR, "cloud", "server-logs", "boot.log");
const optionalCloudEnv = (): Record<string, string> => {
// The Sentry/OTel correlation scenario always runs in this suite, so the
// verification route and beforeSend payload logging default on here; the
// env vars remain overridable for local runs against a different setup.
const env: Record<string, string> = {
SENTRY_OTEL_VERIFY: "true",
SENTRY_OTEL_LOG_PAYLOAD: "true",
};
for (const key of ["SENTRY_DSN", "SENTRY_OTEL_LOG_PAYLOAD", "SENTRY_OTEL_VERIFY"]) {
const value = process.env[key];
if (value) env[key] = value;
}
return env;
};
export default async function setup(): Promise<(() => Promise<void>) | void> {
if (process.env.E2E_CLOUD_URL) {
await waitForHttp(process.env.E2E_CLOUD_URL);
return;
}
if (bootLogFile) mkdirSync(resolve(bootLogFile, ".."), { recursive: true });
ensureE2eMcpSessionTimeoutEnv();
// Suite-owned trace store — every run captures distributed traces. Booted
// once outside the retry: it binds its own OS-assigned port (not a claimed
// one), so an EADDRINUSE on the claimed block doesn't implicate it.
const motel = await bootMotel();
// Publish to the test workers (they inherit this process's env): scenarios
// that assert on exported spans yield the Telemetry service, which exists
// only when this is set. No motel → those scenarios skip, never fail.
if (motel) process.env.E2E_MOTEL_URL = motel.url;
// Claim a free port block (preferred block first, walk forward past
// squatters/colliding checkouts), boot the stack, and retry on EADDRINUSE —
// on Linux CI an ephemeral outbound socket can still grab a claimed port
// between probe and bind, so re-claim the next block and retry. claimAndBoot
// publishes the claimed ports via env (E2E_*_PORT) so the test workers —
// spawned after this — derive the same URLs; the imported targets/cloud
// constants were computed BEFORE the claim, so use the claimed values here.
let booted;
try {
booted = await claimAndBoot(
[
{ envVar: "E2E_CLOUD_PORT", offset: 0, label: "cloud vite dev" },
{ envVar: "E2E_CLOUD_DB_PORT", offset: 1, label: "cloud dev-db (PGlite)" },
{ envVar: "E2E_WORKOS_EMULATOR_PORT", offset: 2, label: "WorkOS emulator" },
{ envVar: "E2E_AUTUMN_EMULATOR_PORT", offset: 3, label: "Autumn emulator" },
],
async (ports) => {
const publicUrl = `http://localhost:${ports.E2E_CLOUD_PORT!}`;
const cloud = await bootCloud({
cloudPort: ports.E2E_CLOUD_PORT!,
dbPort: ports.E2E_CLOUD_DB_PORT!,
workosPort: ports.E2E_WORKOS_EMULATOR_PORT!,
autumnPort: ports.E2E_AUTUMN_EMULATOR_PORT!,
workosClientId: E2E_WORKOS_CLIENT_ID,
cookiePassword: E2E_COOKIE_PASSWORD,
publicUrl,
logFile: bootLogFile,
// Server + browser spans → the suite's motel. The app's exporter is
// endpoint-agnostic, so the same layer that ships prod traces to
// Axiom ships e2e traces to the suite store — "why was that page
// slow" gets a span waterfall, not a guess.
extraEnv: { ...motelExporterEnv(motel, publicUrl), ...optionalCloudEnv() },
});
return { teardown: cloud.teardown, value: cloud };
},
{ label: "cloud", retryWhen: isBootReadinessTimeout },
);
// Publish the Autumn emulator URL to the test workers (they inherit this
// process's env): scenarios that assert on tracked usage yield the Autumn
// service, which exists only when this is set. No emulator → those scenarios
// skip, never fail. (Cloud-only; selfhost never boots Autumn.)
process.env.E2E_AUTUMN_URL = booted.value.autumnUrl;
} catch (error) {
await motel?.teardown();
throw error;
}
return async () => {
await booted.teardown();
await motel?.teardown();
};
}