Kweri Class

new Kweri(options: KweriOptions, timer?: TimerAdapter)

interface KweriOptions {
  // Required
  baseURL: string

  // Optional — HTTP
  fetcher?: Fetcher          // custom HTTP transport (default: global fetch)

  // Optional — caching
  staleTime?: number         // ms data is fresh (default: 0)
  cacheTime?: number         // ms to keep stale data in memory (default: 300_000)
  maxRetries?: number        // retries for network/server errors (default: 0)

  // Optional — garbage collection
  gcInterval?: number        // ms between GC sweeps (default: no GC)

  // Optional — persistence
  persistence?: PersistenceAdapter

  // Optional — devtools
  enableDevTools?: boolean
  devtools?: MountKweriDevToolsOptions
}

import { Kweri } from 'kweri'

export const kweri = new Kweri({
  baseURL: 'https://api.example.com',
  staleTime: 30_000,
  cacheTime: 300_000,
  gcInterval: 60_000,
  maxRetries: 3,
  enableDevTools: true,
  devtools: { position: 'bottom-right' }
})

async query<E extends Endpoint>(
  endpoint: E,
  params: InferParams<E>
): Promise<InferResponse<E>>

const users = await kweri.query(getUsers, {})
const user  = await kweri.query(getUserById, { path: { id: 1 } })

async mutate<E extends Endpoint, TContext = unknown>(
  endpoint: E,
  params: InferParams<E>,
  options?: MutationOptions<...>
): Promise<InferResponse<E>>

getCachedData<E extends Endpoint>(
  endpoint: E,
  params: InferParams<E>
): InferResponse<E> | undefined

setCachedData<E extends Endpoint>(
  endpoint: E,
  params: InferParams<E>,
  data: InferResponse<E>
): void

invalidateQuery<E extends Endpoint>(endpoint: E, params: InferParams<E>): void

invalidateByPath(pattern: string | RegExp): void

kweri.invalidateByPath('/users')         // matches /users, /users/1, /users?page=2
kweri.invalidateByPath(/\/users\/\d+/)   // matches /users/1, /users/42, etc.

invalidateQueryByKey(key: string): void

removeQuery<E extends Endpoint>(endpoint: E, params: InferParams<E>): void

removeQueryByKey(key: string): void

subscribe<E extends Endpoint>(
  endpoint: E,
  params: InferParams<E>,
  callback: (entry: CacheEntry) => void
): () => void

const unsubscribe = kweri.subscribe(getUsers, {}, (entry) => {
  console.log(entry.status, entry.data)
})

// Later:
unsubscribe()

onCacheChange(callback: (key: string, entry: CacheEntry) => void): () => void

isInFlight<E extends Endpoint>(endpoint: E, params: InferParams<E>): boolean

getQueryKey<E extends Endpoint>(endpoint: E, params: InferParams<E>): string

kweri.startGC(60_000)  // sweep every 60 seconds
kweri.stopGC()

getDevToolsSnapshot(): KweriDevToolsSnapshot

interface KweriDevToolsSnapshot {
  cache:     Array<{ key: string; entry: CacheEntry }>
  observers: Array<{ key: string; count: number }>
  inFlight:  string[]
}

kweri.destroy()

readonly queryClient: QueryClient  // direct access to cache operations
readonly apiClient:   ApiClient    // direct access to HTTP execution