Something went wrong. Try again.
Bluesky app fork with some witchin' additions 💫 forked from jollywhoppers.com/witchsky.app
Something went wrong. Try again.
6.0 kB · 201 lines
TSX
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202import {useEffect, useRef, useState} from 'react'import {AppState, type AppStateStatus} from 'react-native'import AsyncStorage from '@react-native-async-storage/async-storage'import {createAsyncStoragePersister} from '@tanstack/query-async-storage-persister'import {focusManager, onlineManager, QueryClient} from '@tanstack/react-query'import { PersistQueryClientProvider, type PersistQueryClientProviderProps,} from '@tanstack/react-query-persist-client'import type React from 'react'
import {listenNetworkConfirmed, listenNetworkLost} from '#/state/events'import {IS_NATIVE, IS_WEB} from '#/env'
declare global { interface Window { __TANSTACK_QUERY_CLIENT__: import('@tanstack/query-core').QueryClient }}
// any query keys in this array will be persisted to AsyncStorageexport const labelersDetailedInfoQueryKeyRoot = 'labelers-detailed-info'const STORED_CACHE_QUERY_KEY_ROOTS = [labelersDetailedInfoQueryKeyRoot]
async function checkIsOnline(): Promise<boolean> { try { const controller = new AbortController() setTimeout(() => { controller.abort() }, 15e3) const res = await fetch('https://public.api.bsky.app/xrpc/_health', { cache: 'no-store', signal: controller.signal, }) const json = await res.json() if (json.version) { return true } else { return false } } catch (e) { return false }}
let receivedNetworkLost = falselet receivedNetworkConfirmed = falselet isNetworkStateUnclear = false
listenNetworkLost(() => { receivedNetworkLost = true onlineManager.setOnline(false)})
listenNetworkConfirmed(() => { receivedNetworkConfirmed = true onlineManager.setOnline(true)})
let checkPromise: Promise<void> | undefinedfunction checkIsOnlineIfNeeded() { if (checkPromise) { return } receivedNetworkLost = false receivedNetworkConfirmed = false checkPromise = checkIsOnline().then(nextIsOnline => { checkPromise = undefined if (nextIsOnline && receivedNetworkLost) { isNetworkStateUnclear = true } if (!nextIsOnline && receivedNetworkConfirmed) { isNetworkStateUnclear = true } if (!isNetworkStateUnclear) { onlineManager.setOnline(nextIsOnline) } })}
setInterval(() => { if (AppState.currentState === 'active') { if (!onlineManager.isOnline() || isNetworkStateUnclear) { checkIsOnlineIfNeeded() } }}, 2000)
focusManager.setEventListener(onFocus => { if (IS_NATIVE) { const subscription = AppState.addEventListener( 'change', (status: AppStateStatus) => { focusManager.setFocused(status === 'active') }, )
return () => subscription.remove() } else if (typeof window !== 'undefined' && window.addEventListener) { // these handlers are a bit redundant but focus catches when the browser window // is blurred/focused while visibilitychange seems to only handle when the // window minimizes (both of them catch tab changes) // there's no harm to redundant fires because refetchOnWindowFocus is only // used with queries that employ stale data times const handler = () => onFocus() window.addEventListener('focus', handler, false) window.addEventListener('visibilitychange', handler, false) return () => { window.removeEventListener('visibilitychange', handler) window.removeEventListener('focus', handler) } }})
const createQueryClient = () => new QueryClient({ defaultOptions: { queries: { // NOTE // refetchOnWindowFocus breaks some UIs (like feeds) // so we only selectively want to enable this // -prf refetchOnWindowFocus: false, // Structural sharing between responses makes it impossible to rely on // "first seen" timestamps on objects to determine if they're fresh. // Disable this optimization so that we can rely on "first seen" timestamps. structuralSharing: false, // We don't want to retry queries by default, because in most cases we // want to fail early and show a response to the user. There are // exceptions, and those can be made on a per-query basis. For others, we // should give users controls to retry. retry: false, }, }, })
const dehydrateOptions: PersistQueryClientProviderProps['persistOptions']['dehydrateOptions'] = { shouldDehydrateMutation: (_: any) => false, shouldDehydrateQuery: query => { return STORED_CACHE_QUERY_KEY_ROOTS.includes(String(query.queryKey[0])) }, }
export function QueryProvider({ children, currentDid,}: { children: React.ReactNode currentDid: string | undefined}) { return ( <QueryProviderInner // Enforce we never reuse cache between users. // These two props MUST stay in sync. key={currentDid} currentDid={currentDid}> {children} </QueryProviderInner> )}
function QueryProviderInner({ children, currentDid,}: { children: React.ReactNode currentDid: string | undefined}) { const initialDid = useRef(currentDid) if (currentDid !== initialDid.current) { throw Error( 'Something is very wrong. Expected did to be stable due to key above.', ) } // We create the query client here so that it's scoped to a specific DID. // Do not move the query client creation outside of this component. const [queryClient, _setQueryClient] = useState(() => createQueryClient()) const [persistOptions, _setPersistOptions] = useState(() => { const asyncPersister = createAsyncStoragePersister({ storage: AsyncStorage, key: 'queryClient-' + (currentDid ?? 'logged-out'), }) return { persister: asyncPersister, dehydrateOptions, } }) useEffect(() => { if (IS_WEB) { window.__TANSTACK_QUERY_CLIENT__ = queryClient } }, [queryClient]) return ( <PersistQueryClientProvider client={queryClient} persistOptions={persistOptions}> {children} </PersistQueryClientProvider> )}