Function createHotStateReload

packages/node/src/dev/hotStateReload.ts:295–551

(opts: HotStateReloadOptions<S>)

}

export function createHotStateReload<S>(opts: HotStateReloadOptions<S>): HotStateReloadController {
  const reloadAdapter = createReloadAdapter(opts);
  const entryLabel = isViewReloadOptions(opts) ? "viewModule" : "routesModule";
  const entryPath = toAbsolutePath(reloadAdapter.entryModule, entryLabel);
  const moduleRoot = toAbsolutePath(opts.moduleRoot ?? dirname(entryPath), "moduleRoot");
  if (!isWithinOrEqual(moduleRoot, entryPath)) {
    throw new Error(`${entryLabel} must be inside moduleRoot`);
  }

  const watchTargets = new Set<string>([moduleRoot]);
  for (const pathInput of opts.watchPaths ?? []) {
    watchTargets.add(toAbsolutePath(pathInput, "watchPaths[]"));
  }
  const debounceMs = ensurePositiveInt("debounceMs", opts.debounceMs ?? DEFAULT_DEBOUNCE_MS);
  const log = makeLogSink(opts.log);
  const onError = opts.onError;
  const targetLabel = reloadAdapter.targetLabel;
  const hostNodeModulesPath = findNearestNodeModules(moduleRoot);

  let sessionRoot: string | null = null;
  const watchers = new Map<string, FSWatcher>();
  let running = false;
  let revision = 0;
  let pendingChangePath: string | undefined;
  let debounceTimer: ReturnType<typeof setTimeout> | null = null;
  let refreshTimer: ReturnType<typeof setTimeout> | null = null;
  let reloadChain: Promise<boolean> = Promise.resolve(false);

  function getSessionRoot(): string {
    if (sessionRoot === null) {
      sessionRoot = mkdtempSync(join(tmpdir(), "rezi-hsr-"));
    }
    return sessionRoot;
  }

  function cleanupSessionRoot(): void {
    if (sessionRoot === null) return;
    rmSync(sessionRoot, { recursive: true, force: true });
    sessionRoot = null;
  }

  function clearDebounce(): void {
    if (debounceTimer === null) return;
    clearTimeout(debounceTimer);
    debounceTimer = null;
  }

  function clearRefresh(): void {
    if (refreshTimer === null) return;
    clearTimeout(refreshTimer);
    refreshTimer = null;
  }

  function closeAllWatchers(): void {
    for (const watcher of watchers.values()) {
      try {
        watcher.close();
      } catch {