Function createSupervisor

services/kiloclaw/controller/src/supervisor.ts:61–339

(options: SupervisorOptions)

  /**
   * Runs immediately before every spawn, including restarts. Use for
   * self-healing work that must happen on each attempt rather than once at
   * bootstrap. Failures are logged and ignored so the spawn still proceeds.
   */
  beforeSpawn?: () => void | Promise<void>;
};

export function createSupervisor(options: SupervisorOptions): Supervisor {
  const {
    args,
    command = 'openclaw',
    backoffInitialMs = BACKOFF_INITIAL_MS,
    backoffMaxMs = BACKOFF_MAX_MS,
    backoffMultiplier = BACKOFF_MULTIPLIER,
    healthyThresholdMs = HEALTHY_THRESHOLD_MS,
    shutdownTimeoutMs = SHUTDOWN_TIMEOUT_MS,
    now = () => Date.now(),
    spawnImpl = spawn,
    setTimeoutImpl = setTimeout,
    clearTimeoutImpl = clearTimeout,
    onStdoutLine,
    beforeSpawn,
  } = options;

  let state: SupervisorState = 'stopped';
  let child: ReturnType<SpawnLike> | null = null;
  let restartTimer: TimerLike | null = null;
  let backoffMs = backoffInitialMs;
  let runningSinceMs: number | null = null;
  let restarts = 0;
  let lastExit: SupervisorLastExit | null = null;
  let stopRequested = false;
  let manualStop = false;
  let shuttingDown = false;

  let childExitPromise: Promise<void> | null = null;
  let resolveChildExit: (() => void) | null = null;
  let opQueue: Promise<void> = Promise.resolve();
  let lineBuf = '';

  const clearRestartTimer = () => {
    if (restartTimer) {
      clearTimeoutImpl(restartTimer);
      restartTimer = null;
    }
  };

  const resetBackoff = () => {
    backoffMs = backoffInitialMs;
  };

  const resolveExitWaiters = () => {
    if (resolveChildExit) {
      resolveChildExit();
      resolveChildExit = null;
    }
    childExitPromise = null;
  };