BLUE

Navigation

Breadcrumbs

/ / var / www / gtechmarathon2026.bitkit.dk / httpdocs / node_modules / @tanstack / query-core / src

Create

Upload

Tip: You can also drag & drop files anywhere on this page to upload.

Edit File Size: 5.55 KB

/var/www/gtechmarathon2026.bitkit.dk/httpdocs/node_modules/@tanstack/query-core/src/queryCache.ts

Text Base64

import { hashQueryKeyByOptions, matchQuery } from './utils'
import { Query } from './query'
import { notifyManager } from './notifyManager'
import { Subscribable } from './subscribable'
import type { QueryFilters } from './utils'
import type { Action, QueryState } from './query'
import type {
  DefaultError,
  NotifyEvent,
  QueryKey,
  QueryOptions,
  WithRequired,
} from './types'
import type { QueryClient } from './queryClient'
import type { QueryObserver } from './queryObserver'

// TYPES

interface QueryCacheConfig {
  onError?: (
    error: DefaultError,
    query: Query<unknown, unknown, unknown>,
  ) => void
  onSuccess?: (data: unknown, query: Query<unknown, unknown, unknown>) => void
  onSettled?: (
    data: unknown | undefined,
    error: DefaultError | null,
    query: Query<unknown, unknown, unknown>,
  ) => void
}

interface NotifyEventQueryAdded extends NotifyEvent {
  type: 'added'
  query: Query<any, any, any, any>
}

interface NotifyEventQueryRemoved extends NotifyEvent {
  type: 'removed'
  query: Query<any, any, any, any>
}

interface NotifyEventQueryUpdated extends NotifyEvent {
  type: 'updated'
  query: Query<any, any, any, any>
  action: Action<any, any>
}

interface NotifyEventQueryObserverAdded extends NotifyEvent {
  type: 'observerAdded'
  query: Query<any, any, any, any>
  observer: QueryObserver<any, any, any, any, any>
}

interface NotifyEventQueryObserverRemoved extends NotifyEvent {
  type: 'observerRemoved'
  query: Query<any, any, any, any>
  observer: QueryObserver<any, any, any, any, any>
}

interface NotifyEventQueryObserverResultsUpdated extends NotifyEvent {
  type: 'observerResultsUpdated'
  query: Query<any, any, any, any>
}

interface NotifyEventQueryObserverOptionsUpdated extends NotifyEvent {
  type: 'observerOptionsUpdated'
  query: Query<any, any, any, any>
  observer: QueryObserver<any, any, any, any, any>
}

type QueryCacheListener = (event: QueryCacheNotifyEvent) => void

export interface QueryStore {
  has: (queryHash: string) => boolean
  set: (queryHash: string, query: Query) => void
  get: (queryHash: string) => Query | undefined
  delete: (queryHash: string) => void
  values: () => IterableIterator<Query>
}

// CLASS

export class QueryCache extends Subscribable<QueryCacheListener> {
  #queries: QueryStore

constructor(public config: QueryCacheConfig = {}) {
    super()
    this.#queries = new Map<string, Query>()
  }

build<
    TQueryFnData = unknown,
    TError = DefaultError,
    TData = TQueryFnData,
    TQueryKey extends QueryKey = QueryKey,
  >(
    client: QueryClient,
    options: WithRequired<
      QueryOptions<TQueryFnData, TError, TData, TQueryKey>,
      'queryKey'
    >,
    state?: QueryState<TData, TError>,
  ): Query<TQueryFnData, TError, TData, TQueryKey> {
    const queryKey = options.queryKey
    const queryHash =
      options.queryHash ?? hashQueryKeyByOptions(queryKey, options)
    let query = this.get<TQueryFnData, TError, TData, TQueryKey>(queryHash)

if (!query) {
      query = new Query({
        client,
        queryKey,
        queryHash,
        options: client.defaultQueryOptions(options),
        state,
        defaultOptions: client.getQueryDefaults(queryKey),
      })
      this.add(query)
    }

return query
  }

add(query: Query<any, any, any, any>): void {
    if (!this.#queries.has(query.queryHash)) {
      this.#queries.set(query.queryHash, query)

this.notify({
        type: 'added',
        query,
      })
    }
  }

remove(query: Query<any, any, any, any>): void {
    const queryInMap = this.#queries.get(query.queryHash)

if (queryInMap) {
      query.destroy()

if (queryInMap === query) {
        this.#queries.delete(query.queryHash)
      }

this.notify({ type: 'removed', query })
    }
  }

clear(): void {
    notifyManager.batch(() => {
      this.getAll().forEach((query) => {
        this.remove(query)
      })
    })
  }

get<
    TQueryFnData = unknown,
    TError = DefaultError,
    TData = TQueryFnData,
    TQueryKey extends QueryKey = QueryKey,
  >(
    queryHash: string,
  ): Query<TQueryFnData, TError, TData, TQueryKey> | undefined {
    return this.#queries.get(queryHash) as
      | Query<TQueryFnData, TError, TData, TQueryKey>
      | undefined
  }

getAll(): Array<Query> {
    return [...this.#queries.values()]
  }

find<TQueryFnData = unknown, TError = DefaultError, TData = TQueryFnData>(
    filters: WithRequired<QueryFilters, 'queryKey'>,
  ): Query<TQueryFnData, TError, TData> | undefined {
    const defaultedFilters = { exact: true, ...filters }

return this.getAll().find((query) =>
      matchQuery(defaultedFilters, query),
    ) as Query<TQueryFnData, TError, TData> | undefined
  }

findAll(filters: QueryFilters<any> = {}): Array<Query> {
    const queries = this.getAll()
    return Object.keys(filters).length > 0
      ? queries.filter((query) => matchQuery(filters, query))
      : queries
  }

notify(event: QueryCacheNotifyEvent): void {
    notifyManager.batch(() => {
      this.listeners.forEach((listener) => {
        listener(event)
      })
    })
  }

onFocus(): void {
    notifyManager.batch(() => {
      this.getAll().forEach((query) => {
        query.onFocus()
      })
    })
  }

onOnline(): void {
    notifyManager.batch(() => {
      this.getAll().forEach((query) => {
        query.onOnline()
      })
    })
  }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 0 × Files: 22

Sort:

Enable drag-to-move

Name	Size	Perms	Modified	Actions
focusManager.ts	2.06 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
hydration.ts	8.08 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
index.ts	1.52 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
infiniteQueryBehavior.ts	5.27 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
infiniteQueryObserver.ts	4.69 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
mutation.ts	8.98 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
mutationCache.ts	6.86 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
mutationObserver.ts	4.76 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
notifyManager.ts	2.36 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
onlineManager.ts	1.77 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queriesObserver.ts	7.54 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
query.ts	18.48 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queryCache.ts	5.55 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queryClient.ts	16.36 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
queryObserver.ts	22.87 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
removable.ts	851 B	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
retryer.ts	5.50 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
streamedQuery.ts	2.71 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
subscribable.ts	557 B	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
thenable.ts	2.87 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
types.ts	38.76 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive
utils.ts	11.10 KB	lrw-r--r--	2025-07-14 06:33:17	Edit Download recursive recursive