Spaces:
Paused
Paused
File size: 1,876 Bytes
fb4d8fe | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 | import { describe, it } from "vitest";
import { isTruthyEnvValue } from "../infra/env.js";
const LIVE = isTruthyEnvValue(process.env.LIVE) || isTruthyEnvValue(process.env.OPENCLAW_LIVE_TEST);
const CDP_URL = process.env.OPENCLAW_LIVE_BROWSER_CDP_URL?.trim() || "";
const describeLive = LIVE && CDP_URL ? describe : describe.skip;
async function waitFor(
fn: () => Promise<boolean>,
opts: { timeoutMs: number; intervalMs: number },
): Promise<void> {
const deadline = Date.now() + opts.timeoutMs;
while (Date.now() < deadline) {
if (await fn()) {
return;
}
await new Promise((r) => setTimeout(r, opts.intervalMs));
}
throw new Error("timed out");
}
describeLive("browser (live): remote CDP tab persistence", () => {
it("creates, lists, focuses, and closes tabs via Playwright", { timeout: 60_000 }, async () => {
const pw = await import("./pw-ai.js");
await pw.closePlaywrightBrowserConnection().catch(() => {});
const created = await pw.createPageViaPlaywright({ cdpUrl: CDP_URL, url: "about:blank" });
try {
await waitFor(
async () => {
const pages = await pw.listPagesViaPlaywright({ cdpUrl: CDP_URL });
return pages.some((p) => p.targetId === created.targetId);
},
{ timeoutMs: 10_000, intervalMs: 250 },
);
await pw.focusPageByTargetIdViaPlaywright({ cdpUrl: CDP_URL, targetId: created.targetId });
await pw.closePageByTargetIdViaPlaywright({ cdpUrl: CDP_URL, targetId: created.targetId });
await waitFor(
async () => {
const pages = await pw.listPagesViaPlaywright({ cdpUrl: CDP_URL });
return !pages.some((p) => p.targetId === created.targetId);
},
{ timeoutMs: 10_000, intervalMs: 250 },
);
} finally {
await pw.closePlaywrightBrowserConnection().catch(() => {});
}
});
});
|