Function handleFileBrowserFilesStream

packages/server/reference-watch.ts:126–192

(
	req: Request,
	options?: { disableIdleTimeout?: () => void },
)

}

export function handleFileBrowserFilesStream(
	req: Request,
	options?: { disableIdleTimeout?: () => void },
): Response {
	const url = new URL(req.url);
	const rawDirPaths = url.searchParams.getAll("dirPath");
	if (rawDirPaths.length === 0) {
		return Response.json({ error: "Missing dirPath parameter" }, { status: 400 });
	}

	const dirPaths: string[] = [];
	const clientDirPaths: string[] = [];
	for (const rawDirPath of rawDirPaths) {
		const dirPath = resolveUserPath(rawDirPath);
		if (!isValidDirectory(dirPath)) {
			return Response.json({ error: "Invalid directory path" }, { status: 400 });
		}
		if (!dirPaths.includes(dirPath)) {
			dirPaths.push(dirPath);
			clientDirPaths.push(rawDirPath);
		}
	}

	options?.disableIdleTimeout?.();
	const entries = dirPaths.map((dirPath) => ensureWatcher(dirPath));

	let controllerRef: ReadableStreamDefaultController | null = null;
	let heartbeatTimer: ReturnType<typeof setInterval> | null = null;
	const stream = new ReadableStream({
		start(controller) {
			controllerRef = controller;
			for (let i = 0; i < entries.length; i++) {
				const entry = entries[i]!;
				const clientDirPath = clientDirPaths[i] ?? entry.dirPath;
				entry.subscribers.set(controller, clientDirPath);
				controller.enqueue(serialize({
					type: "ready",
					dirPath: clientDirPath,
					reason: "initial",
					timestamp: Date.now(),
				}));
			}
			heartbeatTimer = setInterval(() => {
				try {
					controller.enqueue(encoder.encode(": heartbeat\n\n"));
				} catch {
					for (const entry of entries) releaseSubscriber(entry, controller);
					if (heartbeatTimer) clearInterval(heartbeatTimer);
				}
			}, HEARTBEAT_MS);
		},
		cancel() {
			if (heartbeatTimer) clearInterval(heartbeatTimer);
			if (controllerRef) {
				for (const entry of entries) releaseSubscriber(entry, controllerRef);
			}
		},
	});