Function createBaseQuery

packages/svelte-query/src/createBaseQuery.ts:18–85

(
  options: StoreOrVal<
    CreateBaseQueryOptions<TQueryFnData, TError, TData, TQueryData, TQueryKey>
  >,
  Observer: typeof QueryObserver,
  queryClient?: QueryClient,
)

} from './types.js'

export function createBaseQuery<
  TQueryFnData,
  TError,
  TData,
  TQueryData,
  TQueryKey extends QueryKey,
>(
  options: StoreOrVal<
    CreateBaseQueryOptions<TQueryFnData, TError, TData, TQueryData, TQueryKey>
  >,
  Observer: typeof QueryObserver,
  queryClient?: QueryClient,
): CreateBaseQueryResult<TData, TError> {
  /** Load query client */
  const client = useQueryClient(queryClient)
  const isRestoring = useIsRestoring()
  /** Converts options to a svelte store if not already a store object */
  const optionsStore = isSvelteStore(options) ? options : readable(options)

  /** Creates a store that has the default options applied */
  const defaultedOptionsStore = derived(
    [optionsStore, isRestoring],
    ([$optionsStore, $isRestoring]) => {
      const defaultedOptions = client.defaultQueryOptions($optionsStore)
      defaultedOptions._optimisticResults = $isRestoring
        ? 'isRestoring'
        : 'optimistic'
      return defaultedOptions
    },
  )

  /** Creates the observer */
  const observer = new Observer<
    TQueryFnData,
    TError,
    TData,
    TQueryData,
    TQueryKey
  >(client, get(defaultedOptionsStore))

  defaultedOptionsStore.subscribe(($defaultedOptions) => {
    observer.setOptions($defaultedOptions)
  })

  const result = derived<
    typeof isRestoring,
    QueryObserverResult<TData, TError>
  >(isRestoring, ($isRestoring, set) => {
    const unsubscribe = $isRestoring
      ? noop
      : observer.subscribe(notifyManager.batchCalls(set))
    observer.updateResult()
    return unsubscribe
  })

  /** Subscribe to changes in result and defaultedOptionsStore */
  const { subscribe } = derived(
    [result, defaultedOptionsStore],