Something went wrong. Try again.
Monorepo for Tangled tangled.org
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153import type { FileContents, FileDiffMetadata } from "@pierre/diffs";import DiffWorker from "#lib/components/repo/diffWorker.ts?worker";import type { DiffWorkerRequest, DiffWorkerResponse } from "#lib/components/repo/diffWorker.ts";
// Strip Svelte 5 reactive proxies; postMessage throws DataCloneError.let diffWorkerInstance: Worker | undefined;let nextTaskId = 1;interface PendingTask { resolve: (response: DiffWorkerResponse) => void; reject: (err: unknown) => void; /** set for streamed patches, which answer many times before they finish */ partial?: (files: FileDiffMetadata[]) => void;}const pendingTasks = new Map<number, PendingTask>();
const DIFF_WORKER_TIMEOUT_MS = 30_000;const DIFF_WORKER_IDLE_MS = 1000;let idleTimer: ReturnType<typeof setTimeout> | undefined;
const retireWhenIdle = () => { if (pendingTasks.size > 0) return; clearTimeout(idleTimer); idleTimer = setTimeout(() => { if (pendingTasks.size > 0) return; diffWorkerInstance?.terminate(); diffWorkerInstance = undefined; }, DIFF_WORKER_IDLE_MS);};
const failPending = (error: Error) => { for (const [id, task] of pendingTasks) { pendingTasks.delete(id); task.reject(error); }};
const serializeFileContents = (file: FileContents): FileContents => ({ name: file.name, contents: typeof file.contents === "string" ? file.contents : "", ...(file.cacheKey !== undefined ? { cacheKey: file.cacheKey } : {})});
const diffWorker = (): Worker => { clearTimeout(idleTimer); if (diffWorkerInstance) return diffWorkerInstance; const worker = new DiffWorker(); worker.onmessage = (e: MessageEvent<DiffWorkerResponse>) => { const task = pendingTasks.get(e.data.id); if (!task) return; if (task.partial && !e.data.done) { if (e.data.files) task.partial(e.data.files); return; } pendingTasks.delete(e.data.id); task.resolve(e.data); retireWhenIdle(); }; worker.onerror = () => { failPending(new Error("diff worker failed")); diffWorkerInstance?.terminate(); diffWorkerInstance = undefined; }; diffWorkerInstance = worker; return worker;};
const runInDiffWorker = (build: (id: number) => DiffWorkerRequest): Promise<DiffWorkerResponse> => { const worker = diffWorker(); const id = nextTaskId++; return new Promise((resolve, reject) => { const timer = setTimeout(() => { if (!pendingTasks.delete(id)) return; reject(new Error("diff worker timed out")); retireWhenIdle(); }, DIFF_WORKER_TIMEOUT_MS); pendingTasks.set(id, { resolve: (response) => { clearTimeout(timer); resolve(response); }, reject: (err) => { clearTimeout(timer); reject(err); } }); worker.postMessage(build(id)); });};
export const parseDiffInWorker = async ( oldFile: FileContents, newFile: FileContents): Promise<FileDiffMetadata> => { const response = await runInDiffWorker((id) => ({ id, kind: "file", oldFile: serializeFileContents(oldFile), newFile: serializeFileContents(newFile) })); if (response.fileDiff) return response.fileDiff; throw new Error(response.error ?? "diff worker returned no diff");};
export const streamPatchInWorker = async ( url: string, onFiles: (files: FileDiffMetadata[]) => void, signal?: AbortSignal): Promise<void> => { // Fetch on main thread to reuse <link rel="preload"> cache (worker has separate cache). let body: ReadableStream<Uint8Array> | undefined; try { const response = await fetch(url, { signal }); if (!response.ok) throw new Error(`patch ${response.status}`); body = response.body ?? undefined; } catch (cause) { // a failed handover is worth one retry from inside the worker, which has // its own fetch and no preload to match if (body === undefined && cause instanceof Error && cause.message.startsWith("patch ")) throw cause; }
const worker = diffWorker(); const id = nextTaskId++; await new Promise<void>((resolve, reject) => { pendingTasks.set(id, { partial: onFiles, resolve: (response) => { if (response.error) return reject(new Error(response.error)); if (response.files?.length) onFiles(response.files); resolve(); }, reject }); const request: DiffWorkerRequest = body ? { id, kind: "stream", body } : { id, kind: "stream", url }; worker.postMessage(request, body ? [body] : []);
// leaving the page stops the parse too: without this the worker keeps // chewing through megabytes for a component that no longer exists signal?.addEventListener( "abort", () => { if (!pendingTasks.delete(id)) return; worker.postMessage({ id, kind: "cancel" } satisfies DiffWorkerRequest); resolve(); retireWhenIdle(); }, { once: true } ); });};