Class QueryController

packages/lit-query/src/createQueryController.ts:91–315

}

class QueryController<
  TQueryFnData,
  TError,
  TData,
  TQueryData,
  TQueryKey extends QueryKey,
> extends BaseController<QueryObserverResult<TData, TError>> {
  private readonly options: Accessor<
    CreateQueryOptions<TQueryFnData, TError, TData, TQueryData, TQueryKey>
  >
  private observer:
    | QueryObserver<TQueryFnData, TError, TData, TQueryData, TQueryKey>
    | undefined
  private readonly resultTracker = new QueryObserverResultTracker<
    QueryObserverResult<TData, TError>
  >()
  private unsubscribe: (() => void) | undefined
  private queryClient: QueryClient | undefined

  constructor(
    host: ReactiveControllerHost,
    options: Accessor<
      CreateQueryOptions<TQueryFnData, TError, TData, TQueryData, TQueryKey>
    >,
    queryClient?: QueryClient,
  ) {
    const initialClient = queryClient
    super(host, createPendingQueryResult(), queryClient)
    this.options = options

    if (!initialClient) {
      return
    }

    if (typeof options === 'function') {
      return
    }

    const defaulted = this.defaultOptions(initialClient)
    const observer = new QueryObserver(initialClient, defaulted)
    this.queryClient = initialClient
    this.observer = observer
    this.assignObserverResult(observer.getOptimisticResult(defaulted))
  }

  protected onConnected(): void {
    if (!this.syncClient()) {
      return
    }

    this.refreshOptions()
    this.subscribe()
    this.observer?.updateResult()
    if (this.observer) {
      this.setObserverResult(this.observer.getCurrentResult())
    }
  }