wehub-resource-sync
070959e133
landing-page-staging / Deploy landing page to staging (push) Has been skipped
landing-page-ci / Validate landing page (push) Failing after 4s
visual-baseline / Capture visual baselines (push) Has been cancelled
bake-plugin-previews / Bake plugin previews (push) Has been cancelled
70 lines
2.4 KiB
TypeScript
70 lines
2.4 KiB
TypeScript
import { spawn } from "node:child_process";
|
|
import { resolve } from "node:path";
|
|
|
|
import { describe, expect, it } from "vitest";
|
|
|
|
function runReservationCheck(options: { releaseRunId?: string }): Promise<string> {
|
|
const repoRoot = resolve(import.meta.dirname, "../../..");
|
|
const script = `
|
|
const { validateVersionReservation } = await import("./tools/release/src/storage/beta-version-reservation.ts");
|
|
const reservation = {
|
|
baseVersion: "1.2.3",
|
|
channel: "beta",
|
|
createdAt: "2026-06-09T07:00:00.000Z",
|
|
kind: "version-reservation",
|
|
lane: "release-beta-s",
|
|
owner: {
|
|
branch: "codex/release-stable-launcher",
|
|
commit: "abc123",
|
|
repository: "nexu-io/open-design",
|
|
runAttempt: 1,
|
|
runId: 42,
|
|
workflow: "release-beta-s"
|
|
},
|
|
releaseNumber: 4,
|
|
releaseVersion: "1.2.3-beta.4",
|
|
state: "reserved",
|
|
version: 1
|
|
};
|
|
const result = validateVersionReservation(reservation, "1.2.3-beta.4");
|
|
process.stdout.write(result == null ? "ok" : result);
|
|
`;
|
|
return new Promise((resolveRun, rejectRun) => {
|
|
const child = spawn(process.execPath, ["--experimental-strip-types", "--input-type=module", "--eval", script], {
|
|
cwd: repoRoot,
|
|
env: {
|
|
...process.env,
|
|
RELEASE_BRANCH: "codex/release-stable-launcher",
|
|
RELEASE_COMMIT: "abc123",
|
|
RELEASE_REPOSITORY: "nexu-io/open-design",
|
|
RELEASE_RUN_ATTEMPT: "2",
|
|
RELEASE_RUN_ID: options.releaseRunId ?? "42",
|
|
RELEASE_WORKFLOW: "release-beta-s",
|
|
},
|
|
});
|
|
let stdout = "";
|
|
let stderr = "";
|
|
child.stdout.on("data", (chunk: Buffer) => {
|
|
stdout += chunk.toString("utf8");
|
|
});
|
|
child.stderr.on("data", (chunk: Buffer) => {
|
|
stderr += chunk.toString("utf8");
|
|
});
|
|
child.on("error", rejectRun);
|
|
child.on("close", (code) => {
|
|
if (code === 0) resolveRun(stdout);
|
|
else rejectRun(new Error(`reservation check exited ${String(code)}\n${stdout}\n${stderr}`));
|
|
});
|
|
});
|
|
}
|
|
|
|
describe("beta version reservation ownership", () => {
|
|
it("allows a later rerun attempt from the same workflow run to reuse the lock", async () => {
|
|
await expect(runReservationCheck({})).resolves.toBe("ok");
|
|
});
|
|
|
|
it("rejects a reservation owned by a different workflow run", async () => {
|
|
await expect(runReservationCheck({ releaseRunId: "43" })).resolves.toContain("owner=");
|
|
});
|
|
});
|