|
|
@@ -0,0 +1,109 @@
|
|
|
+import { expect, test, type Page, type Route } from "@playwright/test"
|
|
|
+import { base64Encode } from "@opencode-ai/core/util/encode"
|
|
|
+
|
|
|
+const serverA = "http://127.0.0.1:4096"
|
|
|
+const serverB = "http://127.0.0.1:4097"
|
|
|
+const sessionA = session("ses_server_a", "C:/server-a", "Server A session")
|
|
|
+const sessionB = session("ses_server_b", "/home/server-b", "Server B session")
|
|
|
+
|
|
|
+test("tab busy indicator reflects the tab server's own session status", async ({ page }) => {
|
|
|
+ await mockServers(page)
|
|
|
+ await page.addInitScript(
|
|
|
+ ({ serverA, serverB, sessionA, sessionB }) => {
|
|
|
+ localStorage.setItem("settings.v3", JSON.stringify({ general: { newLayoutDesigns: true } }))
|
|
|
+ localStorage.setItem("opencode.global.dat:server", JSON.stringify({ list: [serverB] }))
|
|
|
+ localStorage.setItem(
|
|
|
+ "opencode.window.browser.dat:tabs",
|
|
|
+ JSON.stringify([
|
|
|
+ { type: "session", server: serverA, sessionId: sessionA },
|
|
|
+ { type: "session", server: serverB, sessionId: sessionB },
|
|
|
+ ]),
|
|
|
+ )
|
|
|
+ },
|
|
|
+ { serverA, serverB, sessionA: sessionA.id, sessionB: sessionB.id },
|
|
|
+ )
|
|
|
+
|
|
|
+ const hrefA = `/server/${base64Encode(serverA)}/session/${sessionA.id}`
|
|
|
+ const hrefB = `/server/${base64Encode(serverB)}/session/${sessionB.id}`
|
|
|
+ await page.goto(hrefA)
|
|
|
+ await expect(page.getByText(sessionA.title).first()).toBeVisible()
|
|
|
+
|
|
|
+ // Session B is busy on server B while server A stays the active server, so the
|
|
|
+ // busy indicator must come from the tab server's status, not the active server's.
|
|
|
+ const tabB = page.locator(`[data-titlebar-tab-slot]:has(a[href="${hrefB}"])`)
|
|
|
+ await expect(tabB.locator('[data-component="session-progress-indicator-v2"]')).toBeVisible()
|
|
|
+
|
|
|
+ const tabA = page.locator(`[data-titlebar-tab-slot]:has(a[href="${hrefA}"])`)
|
|
|
+ await expect(tabA.locator('[data-titlebar-tab-title]')).toHaveText(sessionA.title)
|
|
|
+ await expect(tabA.locator('[data-component="session-progress-indicator-v2"]')).toHaveCount(0)
|
|
|
+})
|
|
|
+
|
|
|
+function session(id: string, directory: string, title: string) {
|
|
|
+ return {
|
|
|
+ id,
|
|
|
+ slug: id,
|
|
|
+ projectID: `project-${id}`,
|
|
|
+ directory,
|
|
|
+ title,
|
|
|
+ version: "dev",
|
|
|
+ time: { created: 1, updated: 1 },
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+async function mockServers(page: Page) {
|
|
|
+ await page.route("**/*", async (route) => {
|
|
|
+ const url = new URL(route.request().url())
|
|
|
+ if (url.origin !== serverA && url.origin !== serverB) return route.fallback()
|
|
|
+ const current = url.origin === serverA ? sessionA : sessionB
|
|
|
+ const directory = url.searchParams.get("directory")
|
|
|
+ if (directory && directory !== current.directory) return json(route, { name: "InvalidDirectory" }, 500)
|
|
|
+ if (url.pathname === "/global/event" || url.pathname === "/event") return sse(route)
|
|
|
+ if (url.pathname === "/global/health") return json(route, { healthy: true })
|
|
|
+ if (url.pathname === "/session/status")
|
|
|
+ return json(route, url.origin === serverB ? { [sessionB.id]: { type: "busy" } } : {})
|
|
|
+ if (url.pathname === "/session") return json(route, [current])
|
|
|
+ if (url.pathname === `/session/${current.id}`) return json(route, current)
|
|
|
+ if (/^\/session\/[^/]+$/.test(url.pathname)) return json(route, { name: "NotFoundError" }, 404)
|
|
|
+ if (url.pathname === `/session/${current.id}/message`) return json(route, [])
|
|
|
+ if (/^\/session\/[^/]+\/(children|todo|diff)$/.test(url.pathname)) return json(route, [])
|
|
|
+ if (["/skill", "/command", "/lsp", "/formatter", "/permission", "/question", "/vcs/diff"].includes(url.pathname))
|
|
|
+ return json(route, [])
|
|
|
+ if (["/global/config", "/config", "/provider/auth", "/mcp"].includes(url.pathname)) return json(route, {})
|
|
|
+ if (url.pathname === "/provider")
|
|
|
+ return json(route, { all: [], connected: [], default: { providerID: "", modelID: "" } })
|
|
|
+ if (url.pathname === "/agent") return json(route, [{ name: "build", mode: "primary" }])
|
|
|
+ if (url.pathname === "/project" || url.pathname === "/project/current") {
|
|
|
+ const project = {
|
|
|
+ id: current.projectID,
|
|
|
+ worktree: current.directory,
|
|
|
+ vcs: "git",
|
|
|
+ time: { created: 1, updated: 1 },
|
|
|
+ sandboxes: [],
|
|
|
+ }
|
|
|
+ return json(route, url.pathname === "/project" ? [project] : project)
|
|
|
+ }
|
|
|
+ if (url.pathname === "/path")
|
|
|
+ return json(route, {
|
|
|
+ state: current.directory,
|
|
|
+ config: current.directory,
|
|
|
+ worktree: current.directory,
|
|
|
+ directory: current.directory,
|
|
|
+ home: current.directory,
|
|
|
+ })
|
|
|
+ if (url.pathname === "/vcs") return json(route, { branch: "main", default_branch: "main" })
|
|
|
+ return json(route, {})
|
|
|
+ })
|
|
|
+}
|
|
|
+
|
|
|
+function json(route: Route, body: unknown, status = 200) {
|
|
|
+ return route.fulfill({
|
|
|
+ status,
|
|
|
+ contentType: "application/json",
|
|
|
+ headers: { "access-control-allow-origin": "*" },
|
|
|
+ body: JSON.stringify(body),
|
|
|
+ })
|
|
|
+}
|
|
|
+
|
|
|
+function sse(route: Route) {
|
|
|
+ return route.fulfill({ status: 200, contentType: "text/event-stream", body: ": ok\n\n" })
|
|
|
+}
|
Luke Parker