Function ensureStrideWorker

apps/desktop/src/utils/socket.ts:649–686

()

	}

	function ensureStrideWorker(): Worker {
		if (strideWorker) return strideWorker;
		strideWorker = new StrideCorrectionWorker();
		strideWorker.onmessage = (e: MessageEvent<StrideCorrectionResponse>) => {
			if (e.data.type !== "corrected" || !directCanvas || !directCtx) return;

			const { buffer, width, height } = e.data;
			const renderStart = performance.now();
			if (directCanvas.width !== width || directCanvas.height !== height) {
				directCanvas.width = width;
				directCanvas.height = height;
			}

			const frameData = new Uint8ClampedArray(buffer);
			if (
				!cachedStrideImageData ||
				cachedStrideWidth !== width ||
				cachedStrideHeight !== height
			) {
				cachedStrideImageData = new ImageData(width, height);
				cachedStrideWidth = width;
				cachedStrideHeight = height;
			}
			cachedStrideImageData.data.set(frameData);
			directCtx.putImageData(cachedStrideImageData, 0, 0);

			storeRenderedFrame(
				cachedStrideImageData.data,
				width,
				height,
				width * 4,
				false,
			);
			recordRender(performance.now() - renderStart, "canvas2d");
			onmessage({ width, height });
		};
		return strideWorker;
	}

	function renderRgbaFrameCanvas2D(buffer: ArrayBuffer, receivedAt: number) {
		if (!directCanvas || !directCtx) return;