Class AgentSession

src/node/services/agentSession.ts:340–6001

}

export class AgentSession {
  private readonly workspaceId: string;
  private readonly config: Config;
  private readonly historyService: HistoryService;
  private readonly aiService: AIService;
  private readonly initStateManager: InitStateManager;
  private readonly backgroundProcessManager: BackgroundProcessManager;
  private readonly workspaceGoalService?: WorkspaceGoalService;
  private readonly keepBackgroundProcesses: boolean;
  private readonly onPostCompactionStateChange?: () => void;
  private readonly emitter = new EventEmitter();
  private readonly aiListeners: Array<{ event: string; handler: (...args: unknown[]) => void }> =
    [];
  private readonly initListeners: Array<{ event: string; handler: (...args: unknown[]) => void }> =
    [];
  private disposed = false;
  private turnPhase: TurnPhase = TurnPhase.IDLE;
  private activePreparedTurnAbortController: AbortController | null = null;
  // When true, stream-end skips auto-flushing queued messages so an edit can truncate first.
  private deferQueuedFlushUntilAfterEdit = false;
  // A tool-end queued message should preempt the current turn after the next real tool result.
  // We keep this set until the requested stream-abort arrives, so a re-queued replacement
  // can still dispatch even if the original queued draft was edited while the abort was in flight.
  private queuedToolEndAbortInFlight = false;

  private idleWaiters: Array<() => void> = [];
  private pendingExternalManualFollowUps = 0;
  private readonly messageQueue = new MessageQueue();
  private readonly compactionHandler: CompactionHandler;
  private readonly compactionMonitor: CompactionMonitor;

  private autoRetryStarting = false;
  private readonly retryManager: RetryManager;
  private lastAutoRetryResumeRequest?: AutoRetryResumeRequest;
  /** Startup recovery should run once per session to avoid duplicate retry timers on reconnect. */
  private startupRecoveryScheduled = false;
  private startupRecoveryPromise: Promise<void> | null = null;
  private startupAutoRetryCheckScheduled = false;
  private startupAutoRetryCheckPromise: Promise<void> | null = null;
  private startupAutoRetryHistoryReadFailureCount = 0;
  private startupAutoRetryDeferredRetryDelayMs = 0;
  private autoRetryEnabledPreference: boolean | null = null;
  private legacyAutoRetryEnabledHint: boolean | null = null;
  private startupAutoRetryAbandon: { reason: string; userMessageId?: string } | null = null;

  /** Latest context-usage snapshot used for on-send compaction checks. */
  private lastUsageState?: AutoCompactionUsageState;

  /** Prevent duplicate mid-stream compaction interrupts while we are already transitioning. */
  private midStreamCompactionPending = false;

  /** Tracks file state for detecting external edits. */
  private readonly fileChangeTracker = new FileChangeTracker();

  /**
   * Track turns since last post-compaction attachment injection.
   * Start at max to trigger immediate injection on first turn after compaction.
   */