let shuttingDown = false;

let restartRequested = false;

let watchProcess = null;

let watcher = null;

let lockHandle = null;

let autoDoctorAttempted = false;

let onSigInt;

let onSigTerm;

const watcher = deps.createWatcher(deps.watchPaths, {

ignoreInitial: true,

ignored: (watchPath, stats) =>

isIgnoredWatchPath(watchPath, deps.cwd, deps.watchPaths, stats),

});

const settle = (code) => {

if (settled) {

return;

deps.process.off("SIGTERM", onSigTerm);

}

releaseWatchLock(lockHandle);

watcher.close?.().catch?.(() => {});

watcher?.close?.().catch?.(() => {});

resolve(code);

};

});

};

const handleWatcherError = () => {

shuttingDown = true;

if (watchProcess && typeof watchProcess.kill === "function") {

watchProcess.kill(WATCH_RESTART_SIGNAL);

}

settle(1);

};

const runAutoDoctorAndRestart = () => {

autoDoctorAttempted = true;

logWatcher(

}

};

watcher.on("add", requestRestart);

watcher.on("change", requestRestart);

watcher.on("unlink", requestRestart);

watcher.on("error", () => {

shuttingDown = true;

if (watchProcess && typeof watchProcess.kill === "function") {

watchProcess.kill(WATCH_RESTART_SIGNAL);

}

settle(1);

});

const startWatcher = () => {

watcher = deps.createWatcher(deps.watchPaths, {

ignoreInitial: true,

ignored: (watchPath, stats) =>

isIgnoredWatchPath(watchPath, deps.cwd, deps.watchPaths, stats),

});

watcher.on("add", requestRestart);

watcher.on("change", requestRestart);

watcher.on("unlink", requestRestart);

watcher.on("error", handleWatcherError);

};

onSigInt = () => {

shuttingDown = true;

if (deps.lockDisabled) {

lockHandle = { lockPath: "", pid: deps.process.pid };

startRunner();

startWatcher();

return;

}

}

lockHandle = handle;

startRunner();

startWatcher();

})

.catch((error) => {

logWatcher(`Failed to acquire watcher lock: ${error?.message ?? "unknown error"}`, deps);