Files
MobilityOps/frontend/e2e/demo.spec.ts
NuklearRabbit 81e3fd63bd
MobilityOps acceptance / backend (push) Failing after 19s
MobilityOps acceptance / frontend (push) Successful in 25s
MobilityOps acceptance / e2e (push) Skipped
M54: harden operations and demo resilience
2026-08-24 03:31:03 +02:00

160 lines
7.4 KiB
TypeScript

import { expect, test, type APIRequestContext } from "@playwright/test";
import type {
AuditEvent,
AutomationRun,
DataQualityIssueDetail,
RegisterReturnResult,
} from "../src/api/types";
async function resetDemoData(request: APIRequestContext) {
const login = await request.post("/api/v1/demo/login", {
data: { role: "operations_manager" },
});
expect(login.ok()).toBeTruthy();
const reset = await request.post("/api/v1/demo/reset");
expect(reset.ok()).toBeTruthy();
}
test.describe.configure({ mode: "serial" });
test("five-minute demo script end to end", async ({ page, request }) => {
const proof: { returned?: RegisterReturnResult } = {};
// Reset via a throwaway API session so the UI test starts from the deterministic seed
// regardless of what earlier test runs mutated (S1 return, S2 merge, etc.).
await resetDemoData(request);
await test.step("1. login as Operations Manager", async () => {
await page.goto("/login");
await expect(page.getByText(/Synthetische demo · geen echte klant-/)).toBeVisible();
await page.getByRole("button", { name: "Verken als Operationsmanager" }).click();
await expect(page).toHaveURL(/\/dashboard$/);
});
await test.step("2. verify dashboard metrics are loaded", async () => {
await expect(page.getByRole("heading", { name: "Wagenparkstatus" })).toBeVisible();
const metricValues = page.locator(".metric-cell dd");
await expect(metricValues.first()).toBeVisible();
const values = await metricValues.allTextContents();
expect(values.length).toBeGreaterThan(0);
expect(values.some((v) => Number(v) > 0)).toBeTruthy();
});
await test.step("3. open active demo booking", async () => {
await page.goto("/bookings/BK-DEMO-RETURN");
await expect(page.getByRole("heading", { name: "BK-DEMO-RETURN" })).toBeVisible();
await expect(page.getByText("actief", { exact: true })).toBeVisible();
});
await test.step("4. register an odometer-regression return (S1)", async () => {
const vehicleOdometerText = await page
.locator(".detail-grid div", { hasText: "Startkilometerstand" })
.locator("dd")
.textContent();
const startOdometer = parseInt((vehicleOdometerText ?? "0").replace(/\D/g, ""), 10);
const lowReading = Math.max(0, startOdometer - 500);
await page.getByLabel("Eindkilometerstand (km)").fill(String(lowReading));
await page.getByLabel("Brandstofniveau (%)").fill("55");
await page.getByRole("button", { name: "Retour nakijken" }).click();
await expect(page.getByRole("heading", { name: "Retourimpact nakijken" })).toBeVisible();
const returnResponsePromise = page.waitForResponse(
(response) =>
response.request().method() === "POST" &&
response.url().endsWith("/api/v1/bookings/BK-DEMO-RETURN/return"),
);
await page.getByRole("button", { name: "Retour bevestigen" }).click();
const returnResponse = await returnResponsePromise;
expect(returnResponse.status()).toBe(201);
proof.returned = (await returnResponse.json()) as RegisterReturnResult;
await expect(page.getByRole("heading", { name: "Retour geregistreerd" })).toBeVisible();
});
await test.step("5. verify the persisted quality issue, outbox event and audit trace", async () => {
const returned = proof.returned;
if (!returned) throw new Error("The return API response was not captured");
expect(returned.odometer_regression).toBe(true);
expect(returned.quality_issue_ref).toMatch(/^DQ-RET-/);
const qualityIssueRef = returned.quality_issue_ref;
if (!qualityIssueRef) throw new Error("The regression return did not create a quality issue");
await expect(page.getByRole("link", { name: qualityIssueRef })).toBeVisible();
await expect(page.getByText(/Klaargezet voor verwerking \(/)).toBeVisible();
// Use the page-bound request context: the throwaway reset session above is
// deliberately invalidated by reset, while this context shares the manager login
// cookie established in step 1.
const issueResponse = await page.request.get(`/api/v1/data-quality/issues/${qualityIssueRef}`);
expect(issueResponse.ok()).toBeTruthy();
const issue = (await issueResponse.json()) as DataQualityIssueDetail;
expect(issue.public_ref).toBe(qualityIssueRef);
expect(issue.rule_type).toBe("odometer_regression");
expect(issue.status).toBe("open");
expect(issue.entity_ref).toBe(returned.vehicle_ref);
const workflowsResponse = await page.request.get("/api/v1/workflows");
expect(workflowsResponse.ok()).toBeTruthy();
const workflows = (await workflowsResponse.json()) as AutomationRun[];
const workflow = workflows.find((run) => run.event_id === returned.workflow_event_id);
expect(workflow).toBeDefined();
expect(workflow).toMatchObject({
event_type: "vehicle.returned.v1",
aggregate_ref: returned.booking_ref,
});
const auditResponse = await page.request.get(
`/api/v1/audit?correlation_id=${encodeURIComponent(returned.correlation_id)}`,
);
expect(auditResponse.ok()).toBeTruthy();
const trace = (await auditResponse.json()) as AuditEvent[];
expect(trace.map((event) => event.action)).toEqual(
expect.arrayContaining([
"data_quality_issue_created",
"return_registered",
"vehicle_status_changed",
]),
);
expect(trace.every((event) => event.correlation_id === returned.correlation_id)).toBe(true);
});
await test.step("6. resolve the duplicate customer scenario (S2)", async () => {
await page.goto("/data-quality/DQ-DEMO-DUPLICATE");
await expect(page.getByRole("heading", { name: "Vergelijken en samenvoegen" })).toBeVisible();
await page.getByRole("button", { name: /Samenvoegen met CUS-0012/ }).click();
await page.getByRole("button", { name: "Ja, samenvoegen" }).click();
await expect(page.locator(".badge.status-resolved")).toBeVisible();
});
await test.step("7. ask the damage question and inspect citations (S6)", async () => {
await page.goto("/knowledge");
await page
.getByPlaceholder(/Wat moet ik doen wanneer een voertuig beschadigd terugkomt/)
.fill("Wat moet ik doen wanneer een voertuig terugkomt met schade?");
await page.getByRole("button", { name: "Vraag stellen" }).click();
await expect(page.getByText("Onderbouwd met geciteerde procedures")).toBeVisible({ timeout: 15_000 });
const damageSource = page.locator(".source-card", { hasText: /zichtbare of gemelde schade/i }).first();
await expect(damageSource).toBeVisible();
await expect(damageSource).toContainText(/zichtbare of gemelde schade/i);
});
await test.step("8. inspect audit entries", async () => {
await page.goto("/audit");
await page.getByLabel("Actie").fill("return_registered");
await expect(page.locator(".audit-group-list li").first()).toBeVisible();
await expect(page.getByText("Voertuigretour geregistreerd").first()).toBeVisible();
});
await test.step("9. verify responsive navigation at mobile width", async () => {
await page.setViewportSize({ width: 360, height: 800 });
await page.goto("/dashboard");
await expect(page.getByRole("button", { name: /Synthetische demo/ })).toBeVisible();
await expect(page.getByRole("link", { name: "Overzicht" }).first()).toBeVisible();
const scrollWidth = await page.evaluate(() => document.documentElement.scrollWidth);
const clientWidth = await page.evaluate(() => document.documentElement.clientWidth);
expect(scrollWidth).toBeLessThanOrEqual(clientWidth + 1);
});
});