feat: pass signal to query

src/query-options.ts

@@ -37,7 +37,7 @@ export interface UseQueryOptions<TResult = unknown> {
   /**
    * The function that will be called to fetch the data. It **must** be async.
    */
-  query: () => Promise<TResult>
+  query: (context: UseQueryFnContext) => Promise<TResult>
 
   /**
    * Time in ms after which the data is considered stale and will be refreshed on next read

src/query-store.ts

@@ -20,6 +20,7 @@ import { type EntryNodeKey, TreeMapNode } from './tree-map'
 import {
   type UseQueryOptionsWithDefaults,
   type UseQueryKey,
+  _UseQueryKeyWithDataType,
 } from './query-options'
 
 /**
@@ -229,11 +230,13 @@ export const useQueryCache = defineStore(QUERY_STORE_ID, () => {
 
     // we create an object and verify we are the most recent pending request
     // before doing anything
+    const signalController = new AbortController()
+    const { signal } = signalController
     const pendingCall = (entry.pending = {
       refreshCall: entry
-        .options!.query()
+        .options!.query({ signal })
         .then((data) => {
-          if (pendingCall === entry.pending) {
+          if (pendingCall === entry.pending && !signal.aborted) {
             entry.error.value = null
             entry.data.value = data
             entry.status.value = 'success'

src/use-mutation.ts

@@ -99,11 +99,7 @@ export function useMutation<
                 : options.keys
             for (const key of keys) {
               // TODO: find a way to pass a source of the invalidation, could be a symbol associated with the mutation, the parameters
-              store.invalidateEntry(key, {
-                // default
-                // refetch: true,
-                exact: true,
-              })
+              store.invalidateEntry(key)
             }
           }
         }