Class ThreadsStore

packages/angular/src/lib/threads.ts:210–530

 * {@link DestroyRef}.
 */
export class ThreadsStore implements InjectThreadsResult {
  readonly #copilotkit = inject(CopilotKit);
  readonly #store: ɵThreadStore = ɵcreateThreadStore({
    // Cast to `typeof fetch`: the wrapper preserves correct `this` binding for
    // globalThis.fetch but does not re-expose static members (e.g. `preconnect`)
    // that newer DOM libs add and that the store never calls.
    fetch: ((...args: Parameters<typeof fetch>) =>
      globalThis.fetch(...args)) as typeof fetch,
  });
  readonly #subscriptions: Subscription[] = [];

  readonly #threads = signal<Thread[]>([]);
  readonly #storeIsLoading = signal<boolean>(false);
  readonly #storeError = signal<Error | null>(null);
  readonly #hasMoreThreads = signal<boolean>(false);
  readonly #isFetchingMoreThreads = signal<boolean>(false);
  readonly #isMutating = signal<boolean>(false);

  /**
   * Tracks whether a real runtime context has been dispatched to the store
   * yet. The store itself starts `isLoading: false`, so before the first
   * dispatch consumers would otherwise see an empty, non-loading list (the
   * empty-list flash). While a runtime URL is configured and the endpoints
   * are available but no context has been dispatched, we synthesize loading.
   */
  readonly #hasDispatchedContext = signal<boolean>(false);

  readonly threads = this.#threads.asReadonly();
  readonly error: Signal<Error | null>;
  readonly listError: Signal<Error | null>;
  readonly isLoading: Signal<boolean>;
  readonly hasMoreThreads = this.#hasMoreThreads.asReadonly();
  readonly isFetchingMoreThreads = this.#isFetchingMoreThreads.asReadonly();
  readonly isMutating = this.#isMutating.asReadonly();

  constructor(input: InjectThreadsInput, destroyRef: DestroyRef) {
    const agentId = toAccessor(input.agentId);
    const includeArchived = toAccessor(input.includeArchived);
    const limit = toAccessor(input.limit);
    const enabled = toAccessor(input.enabled);
    // `enabled` defaults to `true`; only an explicit `false` keeps the store
    // inert. An unset/`undefined` input is treated as enabled.
    const isEnabled = (): boolean => enabled() !== false;

    this.#bridgeSelectors();
    this.#store.start();

    // Synthesized error/loading reconcile the core store's internal state with
    // configuration-level conditions (no runtime URL, unavailable endpoints),
    // mirroring react-core's useThreads.
    const runtimeUrl = this.#copilotkit.runtimeUrl;
    const runtimeStatus = this.#copilotkit.runtimeConnectionStatus;
    // Read `threadEndpoints`/`intelligence.wsUrl` through the CopilotKit
    // signals (not plain `core.*` getters) so the computeds/effect re-run when
    // `/info` populates them — even if it lands without a connection-status
    // transition. This mirrors react-core, which lists both in its effect deps.
    const threadEndpoints = this.#copilotkit.threadEndpoints;
    const threadListSupported = (): boolean =>