Class GitStateManager

src/web-ui/src/tools/git/state/GitStateManager.ts:60–809

}

export class GitStateManager {
  private static instance: GitStateManager;

  private states = new Map<string, GitState>();
  private subscribers = new Map<string, Set<SubscriberEntry>>();
  private windowFocusRefreshCounts = new Map<string, number>();
  private refreshDebounceTimers = new Map<string, ReturnType<typeof setTimeout>>();
  private refreshLocks = new Map<string, Promise<void>>();
  private pendingRefreshes = new Map<string, PendingRefresh>();
  private cacheConfig: CacheConfig = { ...DEFAULT_CACHE_CONFIG };
  private readonly DEBOUNCE_DELAY = 100;
  private globalListenersInitialized = false;

  private constructor() {
    this.setupGlobalListeners();
  }

  static getInstance(): GitStateManager {
    if (!GitStateManager.instance) {
      GitStateManager.instance = new GitStateManager();
    }
    return GitStateManager.instance;
  }

  /**
   * Reset instance (for testing only)
   */
  static resetInstance(): void {
    if (GitStateManager.instance) {
      GitStateManager.instance.dispose();
      GitStateManager.instance = undefined as any;
    }
  }

  /**
   * Subscribe to repository state changes.
   * @returns Unsubscribe function.
   */
  subscribe(
    repositoryPath: string,
    callback: GitStateSubscriber,
    options: SubscribeOptions = {}
  ): () => void {
    const normalizedPath = this.normalizePath(repositoryPath);

    if (!this.subscribers.has(normalizedPath)) {
      this.subscribers.set(normalizedPath, new Set());
    }

    const entry: SubscriberEntry = { callback, options };
    this.subscribers.get(normalizedPath)!.add(entry);

    if (options.immediate !== false) {
      const currentState = this.states.get(normalizedPath);
      if (currentState) {
        callback(currentState, null, ['basic', 'status', 'detailed']);
      }
    }