feat: structured file manager (#1423)

## Description

## Linear Ticket

## What type of PR is this? (check all applicable)

- [ ] 💡 (feat) - A new feature (non-breaking change which adds
functionality)
- [ ] 🔄 (refactor) - Code Refactoring - A code change that neither fixes
a bug nor adds a feature
- [ ] 🐞 (fix) - Bug Fix (non-breaking change which fixes an issue)
- [ ] 🏎 (perf) - Optimization
- [ ] 📄 (docs) - Documentation - Documentation only changes
- [ ] 📄 (test) - Tests - Adding missing tests or correcting existing
tests
- [ ] ⚙️ (ci) - Continuous Integrations - Changes to our CI
configuration files and scripts (example scopes: Travis, Circle,
BrowserStack, SauceLabs)
- [ ] ☑️ (chore) - Chores - Other changes that don't modify src or test
files
- [ ] ↩️ (revert) - Reverts - Reverts a previous commit(s).

<!--
     For a timely review/response, please avoid force-pushing additional
     commits if your PR already received reviews or comments.
Before submitting a Pull Request, please ensure you've done the
following:
     - 👷‍♀️ Create small PRs. In most cases this will be possible.
     - ✅ Provide tests for your changes.
     - 📝 Use descriptive commit messages (as described below).
- 📗 Update any related documentation and include any relevant
screenshots.
     Commit Message Structure (all lower-case):
     <type>(optional ticket number): <description>
     [optional body]
-->

Author: RonenMars

.gitignore

@@ -53,8 +53,8 @@ directory_contents.json
 # MCPs
 .vscode/mcp.json
 .serena/
+.taskmaster/
 
 # ACT Run github workflows locally
 .vars
 .secrets
-

.vscode/settings.json

@@ -17,9 +17,9 @@
 		"source.fixAll.eslint": "always"
 	},
 	"editor.formatOnSave": true,
+	"window.title": "${rootName}${separator}${activeRepositoryBranchName}${separator}[Branch: ronen/fix/landing]",
 	"i18n-ally.localesPaths": [
 		"src/i18n",
 		"src/locales"
-	],
-	"window.title": "${rootName}${separator}${activeRepositoryBranchName}${separator}[Branch: ronen/fix/landing]"
+	]
 }

e2e/fixtures/test-file.txt

@@ -0,0 +1 @@
+This is a test file for E2E testing

e2e/pages/project.ts

@@ -14,17 +14,37 @@ export class ProjectPage {
 		await this.page.locator('button[aria-label="Project additional actions"]').hover();
 		await this.page.locator('button[aria-label="Delete project"]').click();
 		await this.page.locator('button[aria-label="Ok"]').click();
-		const successToast = await waitForToast(this.page, "Project deletion completed successfully");
-		await expect(successToast).toBeVisible();
-		await successToast
-			.locator("button[aria-label=\"Close 'Project deletion completed successfully' toast\"]")
-			.click();
+
+		let successToast;
+		try {
+			successToast = await waitForToast(
+				this.page,
+				`Close "Success Project deletion completed successfully" toast`
+			);
+			if (await successToast.isVisible()) {
+				await successToast
+					.locator("button[aria-label=\"Close 'Project deletion completed successfully' toast\"]")
+					.click();
+			} else {
+				// eslint-disable-next-line no-console
+				console.warn("Success toast was found but is not visible. Continuing test without closing toast.");
+			}
+		} catch (error) {
+			// eslint-disable-next-line no-console
+			console.warn(
+				`Success toast not found: ${error instanceof Error ? error.message : String(error)}. Continuing test without closing toast.`
+			);
+		}
+
+		await this.page.mouse.move(0, 0);
 
 		const loaders = this.page.locator(".loader-cycle-disks").all();
 		const loadersArray = await loaders;
 		await Promise.all(loadersArray.map((loader) => loader.waitFor({ state: "detached" })));
 
-		await expect(successToast).not.toBeVisible({ timeout: 10000 });
+		if (successToast) {
+			await expect(successToast).not.toBeVisible({ timeout: 2000 });
+		}
 
 		const deletedProjectNameCell = this.page.getByRole("cell", { name: projectName });
 

e2e/pages/webhookSession.ts

@@ -2,7 +2,7 @@ import { expect, type APIRequestContext, type Page } from "@playwright/test";
 import randomatic from "randomatic";
 
 import { DashboardPage } from "./dashboard";
-import { waitForToast } from "e2e/utils";
+import { createNetworkListeners, logNetworkDiagnostics, waitForToast, type NetworkCapture } from "e2e/utils";
 import { waitForLoadingOverlayGone } from "e2e/utils/waitForLoadingOverlayToDisappear";
 
 export class WebhookSessionPage {
@@ -18,27 +18,74 @@ export class WebhookSessionPage {
 		this.projectName = `test_${randomatic("Aa", 4)}`;
 	}
 
-	async waitForFirstCompletedSession(timeoutMs = 120000) {
-		await expect(async () => {
-			const refreshButton = this.page.locator('button[aria-label="Refresh"]');
-			const isDisabled = await refreshButton.evaluate((element) => (element as HTMLButtonElement).disabled);
+	async waitForFirstCompletedSession(timeoutMs = 180000) {
+		const allNetworkData: NetworkCapture[] = [];
+		let attemptCounter = 0;
+		let timePassed = 0;
 
-			if (!isDisabled) {
-				await refreshButton.click();
-			}
-
-			const completedSession = await this.page.getByRole("button", { name: "1 Completed" }).isVisible();
-
-			expect(completedSession).toBe(true);
-
-			return true;
-		}).toPass({
-			timeout: timeoutMs,
-			intervals: [3000],
-		});
+		try {
+			await expect(async () => {
+				attemptCounter++;
+				const refreshButton = this.page.locator('button[aria-label="Refresh"]');
+				const isDisabled = await refreshButton.evaluate((element) => (element as HTMLButtonElement).disabled);
+
+				if (!isDisabled) {
+					const { requests, responses, startListening, stopListening } = createNetworkListeners(this.page);
+
+					startListening();
+
+					try {
+						const clickTimestamp = Date.now();
+
+						await refreshButton.click();
+
+						try {
+							await Promise.race([
+								this.page.waitForResponse(() => true, { timeout: 3000 }),
+								new Promise((resolve) => setTimeout(resolve, 2000)),
+							]);
+						} catch (e) {
+							// eslint-disable-next-line no-console
+							console.error(
+								`No response received after ${timePassed} milliseconds, ${attemptCounter} attempt. Error:`,
+								e
+							);
+							timePassed += 3000;
+						}
+
+						await new Promise((resolve) => setTimeout(resolve, 1000));
+
+						allNetworkData.push({
+							attemptNumber: attemptCounter,
+							clickTimestamp,
+							requests: [...requests],
+							responses: [...responses],
+						});
+					} finally {
+						stopListening();
+					}
+				}
+
+				const completedSessionDeploymentColumn = this.page.getByRole("button", { name: "1 Completed" });
+				await expect(completedSessionDeploymentColumn).toBeVisible();
+				await expect(completedSessionDeploymentColumn).toBeEnabled();
+				await completedSessionDeploymentColumn.click();
+
+				const sessionCompletedLog = this.page.getByText("The session has finished with completed state");
+				await expect(sessionCompletedLog).toBeVisible();
+
+				return true;
+			}).toPass({
+				timeout: timeoutMs,
+				intervals: [3000],
+			});
+		} catch (error) {
+			logNetworkDiagnostics(allNetworkData, attemptCounter, error);
+			throw error;
+		}
 	}
 
-	async setupProjectAndTriggerSession() {
+	async setupProjectAndTriggerSession(skipSessionToBeCompleted = false) {
 		await this.page.goto("/welcome");
 
 		try {
@@ -91,7 +138,7 @@ export class WebhookSessionPage {
 		await expect(toast).toBeVisible();
 
 		const response = await this.request.get(webhookUrl, {
-			timeout: 5000,
+			timeout: 1000,
 		});
 
 		if (!response.ok()) {
@@ -108,6 +155,8 @@ export class WebhookSessionPage {
 		const deploymentId = this.page.getByText(/bld_*/);
 		await expect(deploymentId).toBeVisible();
 
-		await this.waitForFirstCompletedSession();
+		if (!skipSessionToBeCompleted) {
+			await this.waitForFirstCompletedSession();
+		}
 	}
 }