Method refreshAll

src/browser/stores/PRStatusStore.ts:597–649

* Refresh PR status for all subscribed workspaces. * Called via RefreshController (focus + debounced refresh).

()

   * Called via RefreshController (focus + debounced refresh).
   */
  private async refreshAll(): Promise<void> {
    if (!this.client || !this.isActive) return;

    const workspaceIds = Array.from(this.workspaceSubscriptionCounts.keys());
    if (workspaceIds.length === 0) {
      return;
    }

    const now = Date.now();
    const refreshes: Array<Promise<void>> = [];

    for (const workspaceId of workspaceIds) {
      const cached = this.workspacePRCache.get(workspaceId);
      if (this.shouldFetchWorkspace(cached, now)) {
        // Skip passive PR refresh for devcontainer workspaces whose runtime is
        // not already running, to avoid waking stopped containers.
        const metadata = this.workspaceMetadata.get(workspaceId);
        if (
          metadata &&
          !canRunPassiveRuntimeCommand(
            metadata.runtimeConfig,
            this.runtimeStatusStore.getStatus(workspaceId)
          )
        ) {
          // Arm a one-shot retry so the workspace gets a PR refresh once the
          // runtime becomes passively runnable again.
          if (!this.runtimeRetryUnsubscribers.has(workspaceId)) {
            let firedSynchronously = false;
            const unsubscribe = onPassiveRuntimeEligible(
              workspaceId,
              metadata.runtimeConfig,
              this.runtimeStatusStore,
              () => {
                firedSynchronously = true;
                this.runtimeRetryUnsubscribers.delete(workspaceId);
                // Clear PR cache so TTL doesn't suppress the deferred retry.
                this.workspacePRCache.delete(workspaceId);
                this.refreshController.requestImmediate();
              }
            );
            if (!firedSynchronously) {
              this.runtimeRetryUnsubscribers.set(workspaceId, unsubscribe);
            }
          }
          continue;
        }

        refreshes.push(this.detectWorkspacePR(workspaceId));
      }
    }

    await Promise.all(refreshes);
  }

  /**
   * Dispose the store.