fix: notify query cache on stale

Author: boschni

src/core/config.ts

@@ -66,6 +66,14 @@ export const DEFAULT_CONFIG: ReactQueryConfig = {
   },
 }
 
+export function getDefaultReactQueryConfig() {
+  return {
+    shared: { ...DEFAULT_CONFIG.shared },
+    queries: { ...DEFAULT_CONFIG.queries },
+    mutations: { ...DEFAULT_CONFIG.mutations },
+  }
+}
+
 export function mergeReactQueryConfigs(
   a: ReactQueryConfig,
   b: ReactQueryConfig

src/core/index.ts

@@ -1,3 +1,4 @@
+export { getDefaultReactQueryConfig } from './config'
 export { queryCache, queryCaches, makeQueryCache } from './queryCache'
 export { setFocusHandler } from './setFocusHandler'
 export { setOnlineHandler } from './setOnlineHandler'

src/core/query.ts

@@ -32,16 +32,15 @@ export interface QueryState<TResult, TError> {
   data?: TResult
   error: TError | null
   failureCount: number
-  fetchedCount: number
   isError: boolean
-  isFetched: boolean
   isFetching: boolean
   isFetchingMore: IsFetchingMoreValue
   isIdle: boolean
   isLoading: boolean
   isSuccess: boolean
   status: QueryStatus
   throwInErrorBoundary?: boolean
+  updateCount: number
   updatedAt: number
 }
 
@@ -594,12 +593,11 @@ function getDefaultState<TResult, TError>(
   return {
     ...getStatusProps(initialStatus),
     error: null,
-    isFetched: Boolean(config.initialFetched),
     isFetching: initialStatus === QueryStatus.Loading,
     isFetchingMore: false,
     failureCount: 0,
-    fetchedCount: config.initialFetched ? 1 : 0,
     data: initialData,
+    updateCount: 0,
     updatedAt: Date.now(),
     canFetchMore: hasMorePages(config, initialData),
   }
@@ -633,11 +631,10 @@ export function queryReducer<TResult, TError>(
         ...getStatusProps(QueryStatus.Success),
         data: action.data,
         error: null,
-        fetchedCount: state.fetchedCount + 1,
-        isFetched: true,
         isFetching: false,
         isFetchingMore: false,
         canFetchMore: action.canFetchMore,
+        updateCount: state.updateCount + 1,
         updatedAt: action.updatedAt ?? Date.now(),
         failureCount: 0,
       }
@@ -646,10 +643,9 @@ export function queryReducer<TResult, TError>(
         ...state,
         ...getStatusProps(QueryStatus.Error),
         error: action.error,
-        fetchedCount: state.fetchedCount + 1,
-        isFetched: true,
         isFetching: false,
         isFetchingMore: false,
+        updateCount: state.updateCount + 1,
         failureCount: state.failureCount + 1,
         throwInErrorBoundary: true,
       }

src/core/queryCache.ts

@@ -1,7 +1,6 @@
 import {
   Updater,
   deepIncludes,
-  functionalUpdate,
   getQueryArgs,
   isDocumentVisible,
   isPlainObject,
@@ -336,19 +335,7 @@ export class QueryCache {
     updater: Updater<TResult | undefined, TResult>,
     config?: QueryConfig<TResult, TError>
   ) {
-    const resolvedConfig = this.getResolvedQueryConfig(queryKey, config)
-    const query = this.getQueryByHash<TResult, TError>(resolvedConfig.queryHash)
-
-    if (query) {
-      query.setData(updater)
-      return
-    }
-
-    this.createQuery({
-      initialFetched: true,
-      initialData: functionalUpdate(updater, undefined),
-      ...resolvedConfig,
-    })
+    this.buildQuery(queryKey, config).setData(updater)
   }
 }
 

src/core/queryObserver.ts

@@ -18,13 +18,13 @@ export class QueryObserver<TResult, TError> {
   private currentResult!: QueryResult<TResult, TError>
   private previousQueryResult?: QueryResult<TResult, TError>
   private listener?: UpdateListener<TResult, TError>
-  private initialFetchedCount: number
+  private initialUpdateCount: number
   private staleTimeoutId?: number
   private refetchIntervalId?: number
 
   constructor(config: ResolvedQueryConfig<TResult, TError>) {
     this.config = config
-    this.initialFetchedCount = 0
+    this.initialUpdateCount = 0
 
     // Bind exposed methods
     this.clear = this.clear.bind(this)
@@ -161,6 +161,7 @@ export class QueryObserver<TResult, TError> {
       if (!this.currentResult.isStale) {
         this.currentResult = { ...this.currentResult, isStale: true }
         this.notify()
+        this.config.queryCache.notifyGlobalListeners(this.currentQuery)
       }
     }, timeout)
   }
@@ -229,7 +230,7 @@ export class QueryObserver<TResult, TError> {
 
     // When the query has not been fetched yet and this is the initial render,
     // determine the staleness based on the initialStale or existence of initial data.
-    if (!currentResult && !state.isFetched) {
+    if (!currentResult && state.updateCount === 0) {
       if (typeof config.initialStale === 'function') {
         isStale = config.initialStale()
       } else if (typeof config.initialStale === 'boolean') {
@@ -249,8 +250,8 @@ export class QueryObserver<TResult, TError> {
       error: state.error,
       failureCount: state.failureCount,
       fetchMore: this.fetchMore,
-      isFetched: state.isFetched,
-      isFetchedAfterMount: state.fetchedCount > this.initialFetchedCount,
+      isFetched: state.updateCount > 0,
+      isFetchedAfterMount: state.updateCount > this.initialUpdateCount,
       isFetching: state.isFetching,
       isFetchingMore: state.isFetchingMore,
       isPreviousData,
@@ -284,7 +285,7 @@ export class QueryObserver<TResult, TError> {
 
     this.previousQueryResult = this.currentResult
     this.currentQuery = query
-    this.initialFetchedCount = query.state.fetchedCount
+    this.initialUpdateCount = query.state.updateCount
     this.updateResult()
 
     if (this.listener) {

src/core/tests/queryCache.test.tsx

@@ -544,7 +544,7 @@ describe('queryCache', () => {
       expect(query.state).toMatchObject({
         data: 'data',
         isLoading: false,
-        isFetched: true,
+        updateCount: 1,
       })
     })
 
@@ -578,7 +578,7 @@ describe('queryCache', () => {
       expect(query.state).toMatchObject({
         data: undefined,
         isLoading: false,
-        isFetched: true,
+        updateCount: 1,
       })
     })
 

src/core/types.ts

@@ -49,7 +49,6 @@ export interface BaseQueryConfig<TResult, TError = unknown, TData = TResult> {
   queryKeySerializerFn?: QueryKeySerializerFunction
   queryFnParamsFilter?: (args: ArrayQueryKey) => ArrayQueryKey
   initialData?: TResult | InitialDataFunction<TResult>
-  initialFetched?: boolean
   infinite?: true
   /**
    * Set this to `false` to disable structural sharing between query results.

src/react/tests/useQuery.test.tsx

@@ -829,6 +829,28 @@ describe('useQuery', () => {
     )
   })
 
+  it('should notify query cache when a query becomes stale', async () => {
+    const key = queryKey()
+    const states: QueryResult<string>[] = []
+    const fn = jest.fn()
+
+    const unsubscribe = queryCache.subscribe(fn)
+
+    function Page() {
+      const state = useQuery(key, () => 'test', {
+        staleTime: 10,
+      })
+      states.push(state)
+      return null
+    }
+
+    render(<Page />)
+
+    await waitForMs(20)
+    unsubscribe()
+    expect(fn).toHaveBeenCalledTimes(3)
+  })
+
   it('should not re-render when a query status changes and notifyOnStatusChange is false', async () => {
     const key = queryKey()
     const states: QueryResult<string>[] = []