danvics/zerobyte
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

test: fix e2e assertions in sync snapshots

Browse source
This commit is contained in:
Nicolas Meienberger 2026-04-20 22:00:38 +02:00
parent c95cc305f8
commit c0a3e9bfd3
No known key found for this signature in database
1 changed files with 57 additions and 30 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

87
e2e/0004-mirror-sync.spec.ts
View file

@ -7,6 +7,11 @@ import { gotoAndWaitForAppReady } from "./helpers/page";
const testDataPath = path.join(process.cwd(), "playwright", "temp"); const testDataPath = path.join(process.cwd(), "playwright", "temp");
type RepositorySummary = {
name: string;
shortId: string;
};
function getRunId(testInfo: TestInfo) { function getRunId(testInfo: TestInfo) {
return `${testInfo.parallelIndex}-${testInfo.retry}-${randomUUID().slice(0, 8)}`; return `${testInfo.parallelIndex}-${testInfo.retry}-${randomUUID().slice(0, 8)}`;
} }
@ -16,6 +21,19 @@ function getWorkerTestDataPath() {
return testDataPath; return testDataPath;
} }
async function listRepositories(page: Page) {
const response = await page.request.get("/api/v1/repositories");
expect(response.ok()).toBe(true);
return (await response.json()) as RepositorySummary[];
}
async function getRepositoryShortId(page: Page, name: string) {
const repositories = await listRepositories(page);
const repository = repositories.find((entry) => entry.name === name);
expect(repository).toBeDefined();
return repository!.shortId;
}
async function createRepository(page: Page, name: string) { async function createRepository(page: Page, name: string) {
await gotoAndWaitForAppReady(page, "/repositories"); await gotoAndWaitForAppReady(page, "/repositories");
await page.getByRole("button", { name: "Create repository" }).click(); await page.getByRole("button", { name: "Create repository" }).click();
@ -85,10 +103,20 @@ test("can sync missing snapshots to a mirror repository", async ({ page }, testI
await createRepository(page, mirrorRepoName); await createRepository(page, mirrorRepoName);
await createBackupJob(page, backupName, volumeName, primaryRepoName); await createBackupJob(page, backupName, volumeName, primaryRepoName);
// Run a backup to create a snapshot const backupPageUrl = page.url();
const primaryRepoShortId = await getRepositoryShortId(page, primaryRepoName);
const mirrorRepoShortId = await getRepositoryShortId(page, mirrorRepoName);
// Run a backup to create a snapshot and wait for it to persist.
await page.getByRole("button", { name: "Backup now" }).click(); await page.getByRole("button", { name: "Backup now" }).click();
await expect(page.getByText("Backup started successfully")).toBeVisible(); await gotoAndWaitForAppReady(page, `/repositories/${primaryRepoShortId}`);
await expect(page.getByText(/Success|Warning/).first()).toBeVisible({ timeout: 30000 }); await page.getByRole("tab", { name: "Snapshots" }).click();
await expect(page.getByText("Backup snapshots stored in this repository.")).toBeVisible();
await expect(async () => {
await page.getByRole("button", { name: "Refresh" }).click();
await expect(page.getByRole("checkbox", { name: /Select snapshot/ })).toHaveCount(1);
}).toPass({ timeout: 30000 });
await gotoAndWaitForAppReady(page, backupPageUrl);
// Add mirror repository // Add mirror repository
await page.getByRole("button", { name: "Add mirror" }).click(); await page.getByRole("button", { name: "Add mirror" }).click();
@ -96,44 +124,43 @@ test("can sync missing snapshots to a mirror repository", async ({ page }, testI
await mirrorSelect.click(); await mirrorSelect.click();
await page.getByRole("option", { name: mirrorRepoName }).click(); await page.getByRole("option", { name: mirrorRepoName }).click();
await page.getByRole("button", { name: "Save changes" }).click(); await page.getByRole("button", { name: "Save changes" }).click();
await expect(page.getByText("Mirror settings saved successfully")).toBeVisible(); await expect(page.getByRole("button", { name: "Save changes" })).toHaveCount(0);
// Click sync button on the mirror row (first icon button in the actions cell) // Click sync button on the mirror row (first icon button in the actions cell)
const mirrorRow = page.getByRole("row").filter({ hasText: mirrorRepoName }); const mirrorRow = page.getByRole("row").filter({ hasText: mirrorRepoName });
await expect(mirrorRow).toBeVisible();
await mirrorRow.getByRole("button").first().click(); await mirrorRow.getByRole("button").first().click();
// Verify the sync dialog shows missing snapshots // Verify the sync dialog shows missing snapshots
await expect(page.getByRole("heading", { name: "Sync snapshots" })).toBeVisible(); const syncDialog = page.getByRole("dialog");
await expect(page.getByText(/1 of 1 snapshots are missing/)).toBeVisible({ timeout: 15000 }); await expect(syncDialog.getByRole("heading", { name: "Sync snapshots" })).toBeVisible();
await expect(syncDialog.getByText(/1 of 1 snapshots are missing/)).toBeVisible({ timeout: 15000 });
// Verify there is a checkbox and a snapshot row // Select the missing snapshots explicitly before syncing.
const snapshotCheckbox = page.getByRole("dialog").getByRole("checkbox").first(); await expect(syncDialog.getByRole("button", { name: "Sync 0 snapshots" })).toBeDisabled();
await expect(snapshotCheckbox).toBeChecked(); await syncDialog.getByRole("checkbox").first().click();
const syncButton = syncDialog.getByRole("button", { name: "Sync 1 snapshots" });
await expect(syncButton).toBeEnabled();
// Click sync button // Click sync button and wait for the mirror repository to contain the snapshot.
await page.getByRole("button", { name: "Sync 1 snapshots" }).click(); await syncButton.click();
await expect(page.getByText("Full sync started")).toBeVisible(); await gotoAndWaitForAppReady(page, `/repositories/${mirrorRepoShortId}`);
await page.getByRole("tab", { name: "Snapshots" }).click();
// Wait for sync to complete await expect(page.getByText("Backup snapshots stored in this repository.")).toBeVisible();
await expect(page.getByText("Syncing...")).toBeVisible({ timeout: 10000 }); await expect(async () => {
await expect(page.getByText("Syncing...")).not.toBeVisible({ timeout: 30000 }); await page.getByRole("button", { name: "Refresh" }).click();
await expect(page.getByRole("checkbox", { name: /Select snapshot/ })).toHaveCount(1);
}).toPass({ timeout: 30000 });
await gotoAndWaitForAppReady(page, backupPageUrl);
// Open sync dialog again and verify all snapshots are synced // Open sync dialog again and verify all snapshots are synced
await mirrorRow.getByRole("button").first().click(); await mirrorRow.getByRole("button").first().click();
await expect(page.getByRole("heading", { name: "Sync snapshots" })).toBeVisible(); await expect(syncDialog.getByRole("heading", { name: "Sync snapshots" })).toBeVisible();
await expect(page.getByText(/All 1 snapshots are already synced/)).toBeVisible({ timeout: 15000 }); await expect(syncDialog.getByText(/All 1 snapshots are already synced/)).toBeVisible({ timeout: 15000 });
await page.getByRole("button", { name: "Cancel" }).click(); await syncDialog.getByRole("button", { name: "Cancel" }).click();
// Verify snapshot appears in the mirror repository's snapshots tab // Verify the synced snapshot remains visible in the mirror repository UI.
const response = await page.request.get("/api/v1/repositories"); await gotoAndWaitForAppReady(page, `/repositories/${mirrorRepoShortId}`);
expect(response.ok()).toBe(true);
const repositories = (await response.json()) as Array<{ name: string; shortId: string }>;
const mirrorRepo = repositories.find((r) => r.name === mirrorRepoName);
expect(mirrorRepo).toBeDefined();
await gotoAndWaitForAppReady(page, `/repositories/${mirrorRepo!.shortId}`);
await page.getByRole("tab", { name: "Snapshots" }).click(); await page.getByRole("tab", { name: "Snapshots" }).click();
await expect(page.getByText("Backup snapshots stored in this repository.")).toBeVisible(); await expect(page.getByRole("checkbox", { name: /Select snapshot/ })).toHaveCount(1);
await page.getByRole("button", { name: "Refresh" }).click();
await expect(page.getByRole("checkbox", { name: /Select snapshot/ })).toHaveCount(1, { timeout: 15000 });
}); });