Method constructor

packages/angular/src/lib/threads.ts:245–454

(input: InjectThreadsInput, destroyRef: DestroyRef)

  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 =>
      threadEndpoints()?.list !== false;
    const threadMutationsSupported = (): boolean =>
      threadEndpoints()?.mutations !== false;
    const threadEndpointsUnavailable = (): boolean =>
      !!runtimeUrl() &&
      runtimeStatus() === CopilotKitCoreRuntimeConnectionStatus.Connected &&
      !threadListSupported();

    const runtimeError = (): Error | null =>
      runtimeUrl() ? null : new Error("Runtime URL is not configured");
    const endpointsError = (): Error | null =>
      threadEndpointsUnavailable()
        ? new Error(
            "Thread endpoints are not available on this CopilotKit runtime",
          )
        : null;
    const mutationsError = (): Error | null =>
      threadMutationsSupported()
        ? null
        : new Error(
            "Thread mutations are not available on this CopilotKit runtime",
          );

    const preConnectLoading = (): boolean =>
      isEnabled() &&
      !!runtimeUrl() &&
      !threadEndpointsUnavailable() &&
      !this.#hasDispatchedContext();

    // Synthesized error/loading combine configuration-level conditions with
    // the core store's own state; expressed as pure derived signals.
    this.error = computed(
      () => runtimeError() ?? endpointsError() ?? this.#storeError(),
    );
    // listError exposes only genuine fetch/mutation errors, excluding the