wehub-resource-sync
54 lines
1.8 KiB
TypeScript
54 lines
1.8 KiB
TypeScript
import { describe, expect, it } from "bun:test";
|
|
import type { ReadyInfo, WorkerInbound, WorkerOutbound } from "@oh-my-pi/pi-coding-agent/tools/browser/tab-protocol";
|
|
import { initializeTabWorkerForTest } from "@oh-my-pi/pi-coding-agent/tools/browser/tab-supervisor";
|
|
|
|
class FakeStartupWorker {
|
|
#errorHandlers = new Set<(error: Error) => void>();
|
|
#messageHandlers = new Set<(msg: WorkerOutbound) => void>();
|
|
readonly sent: WorkerInbound[] = [];
|
|
readonly mode = "worker" as const;
|
|
|
|
send(msg: WorkerInbound): void {
|
|
this.sent.push(msg);
|
|
}
|
|
|
|
onMessage(handler: (msg: WorkerOutbound) => void): () => void {
|
|
this.#messageHandlers.add(handler);
|
|
return () => this.#messageHandlers.delete(handler);
|
|
}
|
|
|
|
onError(handler: (error: Error) => void): () => void {
|
|
this.#errorHandlers.add(handler);
|
|
return () => this.#errorHandlers.delete(handler);
|
|
}
|
|
|
|
async terminate(): Promise<void> {}
|
|
|
|
emitReady(info: ReadyInfo): void {
|
|
for (const handler of this.#messageHandlers) handler({ type: "ready", info });
|
|
}
|
|
|
|
emitError(error: Error): void {
|
|
for (const handler of this.#errorHandlers) handler(error);
|
|
}
|
|
}
|
|
|
|
const initPayload = {
|
|
mode: "headless" as const,
|
|
browserWSEndpoint: "ws://127.0.0.1/devtools/browser/test",
|
|
safeDir: "/tmp/omp-puppeteer",
|
|
timeoutMs: 1_000,
|
|
};
|
|
|
|
describe("browser tab worker startup", () => {
|
|
it("surfaces worker startup errors instead of waiting for the generic init timeout", async () => {
|
|
const worker = new FakeStartupWorker();
|
|
const pending = initializeTabWorkerForTest(worker, initPayload, 1_000);
|
|
|
|
worker.emitError(new Error("Cannot find tab-worker-entry.ts"));
|
|
|
|
await expect(pending).rejects.toThrow("Tab worker failed during startup: Cannot find tab-worker-entry.ts");
|
|
expect(worker.sent).toEqual([{ type: "init", payload: initPayload }]);
|
|
});
|
|
});
|