A self-hosted orchestration system crafted for power users. composia.xyz
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142import { assertEquals } from "jsr:@std/assert@1.0.19/equals";
import { hasActiveOperations, startPolling } from "./refresh.ts";
Deno.test("active operations only include non-terminal statuses", () => { assertEquals( hasActiveOperations(["succeeded", "failed", "cancelled"]), false, ); assertEquals(hasActiveOperations(["succeeded", "running"]), true); assertEquals(hasActiveOperations(["awaiting_confirmation"]), true);});
Deno.test("polling skips work while the document is hidden", async () => { const documentDescriptor = Object.getOwnPropertyDescriptor( globalThis, "document", ); Object.defineProperty(globalThis, "document", { configurable: true, value: { hidden: true }, });
let ticks = 0; const stop = startPolling( () => { ticks += 1; }, { intervalMs: 5, runImmediately: true }, );
await new Promise((resolve) => setTimeout(resolve, 20)); stop();
if (documentDescriptor) { Object.defineProperty(globalThis, "document", documentDescriptor); } else { Reflect.deleteProperty(globalThis, "document"); } assertEquals(ticks, 0);});