Function processFrameBytesSync

apps/desktop/src/utils/frame-worker.ts:981–1128

(
	bytes: Uint8Array,
	releaseCallback?: () => void,
)

type DecodeResult = FrameQueuedMessage | DecodedFrame | ErrorMessage;

function processFrameBytesSync(
	bytes: Uint8Array,
	releaseCallback?: () => void,
): DecodeResult {
	if (bytes.byteLength < 24) {
		releaseCallback?.();
		return {
			type: "error",
			message: "Received frame too small to contain metadata",
		};
	}

	const meta = parseFrameMetadata(bytes);
	if (!meta) {
		releaseCallback?.();
		return {
			type: "error",
			message: "Failed to parse frame metadata",
		};
	}

	const { width, height, frameNumber, targetTimeNs } = meta;
	const timing: FrameTiming = { frameNumber, targetTimeNs };

	if (renderMode === "webgpu" || renderMode === "pending") {
		while (frameQueue.length >= FRAME_QUEUE_SIZE) {
			const dropped = frameQueue.shift();
			if (dropped?.mode === "webgpu" && dropped.releaseCallback) {
				dropped.releaseCallback();
			}
		}

		if (meta.format === "nv12") {
			const frameData = new Uint8ClampedArray(
				bytes.buffer,
				bytes.byteOffset,
				meta.totalSize,
			);
			frameQueue.push({
				mode: "webgpu",
				pixelFormat: "nv12",
				data: frameData,
				width,
				height,
				yStride: meta.yStride,
				fullRange: meta.fullRange,
				timing,
				releaseCallback,
			});
		} else {
			const frameData = new Uint8ClampedArray(
				bytes.buffer,
				bytes.byteOffset,
				bytes.byteLength - 24,
			);
			frameQueue.push({
				mode: "webgpu",
				pixelFormat: "rgba",