Class PRStatusStore

src/browser/stores/PRStatusStore.ts:164–664

 * Store for GitHub PR status. Fetches status via gh CLI and caches results.
 */
export class PRStatusStore {
  private client: RouterClient<AppRouter> | null = null;
  private readonly refreshController: RefreshController;
  private isActive = true;

  // Workspace-based PR detection (keyed by workspaceId)
  private workspacePRSubscriptions = new MapStore<string, WorkspacePRCacheEntry>();
  private workspacePRCache = new Map<string, WorkspacePRCacheEntry>();
  private runtimeRetryUnsubscribers = new Map<string, () => void>();

  // Track active subscriptions per workspace so we only refresh workspaces that are actually visible.
  private workspaceSubscriptionCounts = new Map<string, number>();

  // Track latest merge queue enrichment request while an in-flight fetch is running.
  private mergeQueueRefreshPending = new Map<string, MergeQueueRefreshRequest>();

  // Track per-workspace async merge queue enrichment to avoid overlapping gh api calls.
  private mergeQueueRefreshInFlight = new Map<string, Promise<void>>();

  // Like GitStatusStore: batch immediate refreshes triggered by subscriptions.
  private immediateUpdateQueued = false;
  private workspaceMetadata = new Map<string, FrontendWorkspaceMetadata>();
  private readonly runtimeStatusStore: PassiveRuntimeDeps;

  constructor(runtimeStatusStore?: PassiveRuntimeDeps);
  constructor(runtimeStatusStore?: Pick<RuntimeStatusStore, "getStatus">);
  constructor(
    runtimeStatusStore:
      | PassiveRuntimeDeps
      | Pick<RuntimeStatusStore, "getStatus"> = getRuntimeStatusStore()
  ) {
    this.runtimeStatusStore = {
      getStatus: (workspaceId) => runtimeStatusStore.getStatus(workspaceId),
      subscribeKey:
        "subscribeKey" in runtimeStatusStore
          ? (workspaceId, listener) => runtimeStatusStore.subscribeKey(workspaceId, listener)
          : () => () => undefined,
    };
    this.refreshController = new RefreshController({
      onRefresh: () => this.refreshAll(),
      onRefreshError: (failure) => {
        console.error("[PRStatusStore] refresh failed:", failure.errorMessage);
      },
      debounceMs: 5000,
      refreshOnFocus: true,
      focusDebounceMs: 1000,
    });
  }

  setClient(client: RouterClient<AppRouter> | null): void {
    this.client = client;

    if (!client) {
      return;
    }

    // If hooks subscribed before the client was ready, ensure we refresh once it is.
    if (this.workspaceSubscriptionCounts.size > 0) {