Merge candidate 20260907T201522Z-web-product

Change-source: pulse-maintainer
2026-09-10 02:25:56 +00:00 · 2026-09-07 21:47:29 +01:00
parent 916de59433 6feddfebee
commit 1502a8506c
1 changed files with 179 additions and 0 deletions
@@ -0,0 +1,179 @@
+import { expect, test, type WebSocketRoute } from "@playwright/test";
+
+// Synthetic canonical API/socket snapshots; not a live poller or FreeBSD proof.
+test("hybrid guest memory follows canonical snapshots in the browser", async ({
+  page,
+}, testInfo) => {
+  test.skip(
+    testInfo.project.name !== "chromium",
+    "Desktop synthetic memory acceptance",
+  );
+  const errors: string[] = [];
+  page.on("pageerror", (error) => errors.push(error.message));
+  const vm = (instance: string, percent?: number) => ({
+    id: `${instance}-pve1-101`,
+    type: "vm",
+    name: `${instance}-vm`,
+    status: "running",
+    platformType: "proxmox-pve",
+    platformScopes: ["proxmox"],
+    sourceType: "hybrid",
+    sources: ["proxmox", "agent"],
+    lastSeen: new Date().toISOString(),
+    proxmox: { vmid: 101, nodeName: "pve1", instance },
+    memory:
+      percent === undefined
+        ? undefined
+        : {
+            current: percent,
+            used: percent * 1024 * 1024,
+            total: 100 * 1024 * 1024,
+          },
+    agent: {
+      memory: { used: 35 * 1024 * 1024, total: 100 * 1024 * 1024, usage: 35 },
+    },
+  });
+  let resources = [vm("cluster-a", 100), vm("cluster-b", 80)];
+  let socket: WebSocketRoute | undefined;
+  const send = () =>
+    socket?.send(
+      JSON.stringify({
+        type: "rawData",
+        data: { resources },
+        timestamp: Date.now(),
+      }),
+    );
+  await page.routeWebSocket("**/ws*", (ws) => {
+    socket = ws;
+    send();
+  });
+  await page.route("**/api/**", async (route) => {
+    const url = new URL(route.request().url());
+    if (!url.pathname.startsWith("/api/")) {
+      await route.continue();
+      return;
+    }
+    let body: unknown = {};
+    if (url.pathname === "/api/security/status")
+      body = {
+        hasAuthentication: true,
+        hasProxyAuth: true,
+        proxyAuthUsername: "synthetic-browser",
+        requiresAuth: false,
+      };
+    if (url.pathname === "/api/orgs" || url.pathname === "/api/alerts/active")
+      body = [];
+    if (url.pathname === "/api/metrics-store/history")
+      body = {
+        metrics: {
+          cpu: [],
+          memory: [],
+          disk: [],
+          netin: [],
+          netout: [],
+          diskread: [],
+          diskwrite: [],
+        },
+      };
+    if (url.pathname.startsWith("/api/charts"))
+      body = {
+        data: {},
+        nodeData: {},
+        storageData: {},
+        dockerData: {},
+        stats: {},
+      };
+    if (url.pathname === "/api/version")
+      body = { version: "6.4.1", channel: "stable" };
+    if (url.pathname === "/api/updates/check")
+      body = {
+        currentVersion: "6.4.1",
+        latestVersion: "6.4.1",
+        updateAvailable: false,
+      };
+    if (url.pathname === "/api/resources") {
+      const types = url.searchParams.get("type");
+      const data =
+        !types || types.split(",").includes("vm")
+          ? resources.map(({ memory, ...resource }) => ({
+              ...resource,
+              metrics: {
+                memory: memory && { ...memory, percent: memory.current },
+              },
+            }))
+          : [];
+      body = {
+        data,
+        meta: { page: 1, limit: 100, total: data.length, totalPages: 1 },
+        aggregations: {
+          total: 2,
+          byType: { vm: 2 },
+          byPlatform: { "proxmox-pve": 2 },
+          platformAdmission: {
+            proxmox: true,
+            docker: false,
+            kubernetes: false,
+            truenas: false,
+            vmware: false,
+            standalone: false,
+          },
+        },
+        links: { next: null },
+      };
+    }
+    await route.fulfill({ json: body });
+  });
+  await page.goto("/proxmox");
+  const row = page.locator(".workload-row").filter({ hasText: "cluster-a-vm" });
+  await expect(row).toBeVisible({ timeout: 45_000 });
+  await expect(row).toContainText("100%");
+  resources = [vm("cluster-a", 35), vm("cluster-b", 80)];
+  send();
+  await expect(row).toContainText("35%");
+  await expect(
+    page.locator(".workload-row").filter({ hasText: "cluster-b-vm" }),
+  ).toContainText("80%");
+  await row.click();
+  const drawer = page.getByRole("region", {
+    name: "cluster-a-vm",
+    exact: true,
+  });
+  await expect(drawer).toBeVisible();
+  await expect(drawer).toContainText("100 MB");
+  await expect(drawer).toContainText("65.0 MB");
+  await testInfo.attach("hybrid-memory-35-percent", {
+    body: await page.screenshot(),
+    contentType: "image/png",
+  });
+  const memoryCell = row.locator('[data-workload-col="memory"]');
+  // TestCorrelatedGuestMemoryNextPoll retains status-mem (100%) when
+  // agent evidence is unavailable/stale/offline. Do not revive nested 35%.
+  for (const status of ["unavailable", "stale", "offline"]) {
+    resources = [
+      {
+        ...vm("cluster-a", 100),
+        sourceStatus: { agent: { status } },
+      } as ReturnType<typeof vm>,
+      vm("cluster-b", 80),
+    ];
+    send();
+    await expect(memoryCell).toContainText("100%");
+    await expect(drawer).not.toContainText("65.0 MB");
+    await expect(
+      page.locator(".workload-row").filter({ hasText: "cluster-b-vm" }),
+    ).toContainText("80%");
+  }
+  resources = [vm("cluster-a", 0), vm("cluster-b", 80)];
+  send();
+  await expect(memoryCell).toContainText("0%");
+  await expect(memoryCell).not.toContainText("N/A");
+  await expect(drawer).toContainText("100 MB");
+  await expect(
+    page.locator(".workload-row").filter({ hasText: "cluster-b-vm" }),
+  ).toContainText("80%");
+  expect(errors).toEqual([]);
+  await testInfo.attach("hybrid-memory-measured-zero", {
+    body: await page.screenshot(),
+    contentType: "image/png",
+  });
+});