Method getActivityList

src/node/services/workspaceService.ts:8201–8253

()

  }

  async getActivityList(): Promise<Record<string, WorkspaceActivitySnapshot>> {
    try {
      const snapshots = await this.extensionMetadata.getAllSnapshots();
      const workspaceIds = new Set(snapshots.keys());
      for (const workspaceId of this.activeWorkflowRunIdsByWorkspace.keys()) {
        workspaceIds.add(workspaceId);
      }
      try {
        for (const metadata of await this.config.getAllWorkspaceMetadata()) {
          workspaceIds.add(metadata.id);
        }
      } catch (error) {
        log.debug("Failed to include all workspaces while listing activity", { error });
      }

      const entries = await Promise.all(
        Array.from(
          workspaceIds,
          async (workspaceId): Promise<readonly [string, WorkspaceActivitySnapshot] | null> => {
            const snapshot = snapshots.get(workspaceId) ?? null;
            const hadWorkflowActivityCache = this.activeWorkflowRunIdsByWorkspace.has(workspaceId);
            const activeWorkflowRunCount = await this.getActiveWorkflowRunCount(workspaceId);
            // Keep a zero-count tombstone for workspaces whose workflow-only activity
            // was cleared while a frontend activity subscription was disconnected.
            if (snapshot == null && activeWorkflowRunCount === 0 && !hadWorkflowActivityCache) {
              return null;
            }
            return [
              workspaceId,
              // Overlay the optimistic mid-stream goal here too: the renderer
              // bootstraps via this list (the subscription does not replay
              // historical snapshots), and `getAllSnapshots()` returns the
              // still-pre-stream persisted goal. Without this, a reconnect/reload
              // during a mid-stream goal set would seed the UI with the stale
              // goal until the next live emit or goal read.
              mergeActiveWorkflowRunCount(
                this.overlayPendingGoal(workspaceId, snapshot),
                activeWorkflowRunCount
              ),
            ] as const;
          }
        )
      );
      return Object.fromEntries(
        entries.filter(
          (entry): entry is readonly [string, WorkspaceActivitySnapshot] => entry != null
        )
      );
    } catch (error) {
      log.error("Failed to list activity:", error);
      return {};
    }
  }
  async getChatHistory(workspaceId: string): Promise<MuxMessage[]> {
    try {
      // Only return messages from the latest compaction boundary onward.