Class RuntimeStatusStore

src/browser/stores/RuntimeStatusStore.ts:10–134

export type RuntimeStatus = "running" | "stopped" | "unknown" | "unsupported";

export class RuntimeStatusStore {
  private statuses = new MapStore<string, RuntimeStatus | null>();
  private statusCache = new Map<string, RuntimeStatus | null>();
  private client: APIClient | null = null;
  private immediateUpdateQueued = false;
  private workspaceMetadata = new Map<string, FrontendWorkspaceMetadata>();
  private isActive = true;
  private readonly refreshController: RefreshController;

  constructor() {
    this.refreshController = new RefreshController({
      onRefresh: () => this.updateRuntimeStatuses(),
      onRefreshError: (failure) => {
        console.error("[RuntimeStatusStore] refresh failed:", failure.errorMessage);
      },
      refreshOnFocus: true,
      focusDebounceMs: 500,
    });
  }

  setClient(client: APIClient | null): void {
    this.client = client;

    if (!client) {
      return;
    }

    if (this.workspaceMetadata.size > 0) {
      this.refreshController.requestImmediate();
    }
  }

  subscribe = this.statuses.subscribeAny;

  subscribeKey = (workspaceId: string, listener: () => void) => {
    const unsubscribe = this.statuses.subscribeKey(workspaceId, listener);

    if (!this.immediateUpdateQueued && this.isActive && this.client) {
      this.immediateUpdateQueued = true;
      queueMicrotask(() => {
        this.immediateUpdateQueued = false;
        this.refreshController.requestImmediate();
      });
    }

    return unsubscribe;
  };

  getStatus(workspaceId: string): RuntimeStatus | null {
    if (!this.statuses.has(workspaceId)) {
      return null;
    }

    return this.statuses.get(workspaceId, () => {
      return this.statusCache.get(workspaceId) ?? null;
    });
  }