Function injectQueries

packages/angular-query-experimental/src/inject-queries.ts:220–330

(
  optionsFn: () => InjectQueriesOptions<T, TCombinedResult>,
  injector?: Injector,
)

 * @param injector - The Angular injector to use.
 */
export function injectQueries<
  T extends Array<any>,
  TCombinedResult = QueriesResults<T>,
>(
  optionsFn: () => InjectQueriesOptions<T, TCombinedResult>,
  injector?: Injector,
): Signal<TCombinedResult> {
  !injector && assertInInjectionContext(injectQueries)
  return runInInjectionContext(injector ?? inject(Injector), () => {
    const destroyRef = inject(DestroyRef)
    const ngZone = inject(NgZone)
    const queryClient = inject(QueryClient)
    const isRestoring = injectIsRestoring()

    /**
     * Signal that has the default options from query client applied
     * computed() is used so signals can be inserted into the options
     * making it reactive. Wrapping options in a function ensures embedded expressions
     * are preserved and can keep being applied after signal changes
     */
    const optionsSignal = computed(() => {
      return optionsFn()
    })

    const defaultedQueries = computed(() => {
      return optionsSignal().queries.map((opts) => {
        const defaultedOptions = queryClient.defaultQueryOptions(
          opts as QueryObserverOptions,
        )
        // Make sure the results are already in fetching state before subscribing or updating options
        defaultedOptions._optimisticResults = isRestoring()
          ? 'isRestoring'
          : 'optimistic'

        return defaultedOptions as QueryObserverOptions
      })
    })

    const observerSignal = (() => {
      let instance: QueriesObserver<TCombinedResult> | null = null

      return computed(() => {
        return (instance ||= new QueriesObserver<TCombinedResult>(
          queryClient,
          defaultedQueries(),
          optionsSignal() as QueriesObserverOptions<TCombinedResult>,
        ))
      })
    })()

    const optimisticResultSignal = computed(() =>
      observerSignal().getOptimisticResult(
        defaultedQueries(),
        (optionsSignal() as QueriesObserverOptions<TCombinedResult>).combine,
      ),
    )

    // Do not notify on updates because of changes in the options because