Something went wrong. Try again.
Explore blocks, labels, lists, and posts on Bluesky. skytrace.aly.town
typescript react bluesky atproto
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566import { QueryObserver, queryOptions, type QueryClient } from '@tanstack/react-query'import { deadlineSignal, throwIfAborted } from '../../lib/abort'
export type DataRequestContext = { queryClient: QueryClient sharedRequests: SharedQueryRequests requestTimeoutMs: number}
export class SharedQueryRequests { constructor( private readonly queryClient: QueryClient, private readonly requestTimeoutMs: number, ) {}
query<T>({ queryKey, staleTime, load, consumerSignal, }: { queryKey: readonly unknown[] staleTime: number load: (signal: AbortSignal) => Promise<T> consumerSignal?: AbortSignal }): Promise<T> { throwIfAborted(consumerSignal) const options = queryOptions({ queryKey, queryFn: ({ signal }) => load(deadlineSignal(signal, this.requestTimeoutMs)), staleTime, }) // Imperative callers share the same lifetime accounting as mounted queries. const observer = new QueryObserver(this.queryClient, { ...options, enabled: false }) const unsubscribe = observer.subscribe(() => {}) const promise = this.queryClient.query(options)
return new Promise<T>((resolve, reject) => { let finished = false const cleanup = () => { if (finished) return finished = true consumerSignal?.removeEventListener('abort', abort) unsubscribe() } const resolveConsumer = (value: T) => { if (finished) return cleanup() resolve(value) } const rejectConsumer = (error: unknown) => { if (finished) return cleanup() reject(error) } const abort = () => { const reason = consumerSignal?.reason ?? new DOMException('The request was aborted.', 'AbortError') rejectConsumer(reason) } promise.then(resolveConsumer, rejectConsumer) consumerSignal?.addEventListener('abort', abort, { once: true }) if (consumerSignal?.aborted) abort() }) }}