Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
1.5 kB · 50 lines
TSX
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051import { createContext, useContext, useEffect, useState, useSyncExternalStore, type OctaneNode,} from "octane";import { focusManager, QueryClientProvider } from "@octanejs/tanstack-query";import { connectPublisherProgress } from "./publisher-progress";import { PublisherQuerySession } from "./publisher-query-session";
const Context = createContext<PublisherQuerySession | null>(null);export function PublisherQueryProvider({ children }: { children: OctaneNode }) { const [session] = useState(() => new PublisherQuerySession()); const { ownerSubject, epoch } = useSyncExternalStore( session.subscribe, session.getSnapshot, session.getSnapshot, ); useEffect( () => connectPublisherProgress(session), [session, ownerSubject, epoch], ); useEffect(() => { const focus = () => focusManager.onFocus(); window.addEventListener("focus", focus); return () => { window.removeEventListener("focus", focus); session.client.clear(); }; }, [session]); return ( <Context.Provider value={session}> <QueryClientProvider client={session.client}> {children} </QueryClientProvider> </Context.Provider> );}export function usePublisherSession() { const session = useContext(Context); if (!session) throw new Error("Publisher Query provider is missing"); useSyncExternalStore( session.subscribe, session.getSnapshot, session.getSnapshot, ); return session;}