Function createLifecycleManager

services/cloud-agent-next/wrapper/src/lifecycle.ts:38–297

(
  config: LifecycleConfig,
  deps: LifecycleDependencies
)

  onSseEvent: () => void;
};

export function createLifecycleManager(
  config: LifecycleConfig,
  deps: LifecycleDependencies
): LifecycleManager {
  const { state, kiloClient } = deps;
  let sseTransportTimer: ReturnType<typeof setTimeout> | null = null;
  let stableIdleTimer: ReturnType<typeof setTimeout> | null = null;
  let isAborted = false;
  let rootIdleCandidatePresent = false;
  let idleObservedDuringDelivery = false;
  let postProcessingResolve: (() => void) | null = null;
  let drainPromise: Promise<void> | null = null;
  let lifecycleGeneration = 0;
  let postProcessingCompleted = false;

  function clearSseTransportTimer(): void {
    if (!sseTransportTimer) return;
    clearTimeout(sseTransportTimer);
    sseTransportTimer = null;
  }

  function clearStableIdleCandidate(): void {
    rootIdleCandidatePresent = false;
    idleObservedDuringDelivery = false;
    if (!stableIdleTimer) return;
    clearTimeout(stableIdleTimer);
    stableIdleTimer = null;
  }

  function resetSseTransportTimer(): void {
    clearSseTransportTimer();
    // Idle is the last expected SSE event. Reconnecting during drain races
    // auto-commit and used to abort the complete event.
    if (!state.hasSession || drainPromise) return;
    sseTransportTimer = setTimeout(() => {
      logToFile('SSE transport timeout — reconnecting event subscription');
      deps.reconnectEventSubscription();
    }, SSE_TRANSPORT_TIMEOUT_MS);
  }

  function signalCompletion(): void {
    postProcessingCompleted = true;
    postProcessingResolve?.();
    postProcessingResolve = null;
  }

  async function runPostCompletionTasks(): Promise<void> {
    const session = state.currentSession;
    const msgConfig = state.batchFinalizationConfig;
    if (!session || !msgConfig || isAborted) return;

    if (msgConfig.autoCommit) {
      try {
        const autoCommitController = new AbortController();
        let autoCommitTimedOut = false;
        const timeout = setTimeout(() => {
          autoCommitTimedOut = true;