Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
1.3 kB · 35 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536// Fetches live streams via React Query with automatic 30s polling.// Only active while a component that calls this hook is mounted,// so navigating away from the home screen stops the requests.import { useQuery } from "@tanstack/react-query";import { useCallback } from "react";import { place } from "streamplace";import { useStore } from "../lib/store";
export type LivestreamView = place.stream.livestream.LivestreamView;
const REFETCH_INTERVAL = 30_000;
export function useLiveUsers() { const anonPDSAgent = useStore((state) => state.anonPDSAgent); const streamplaceUrl = useStore((state) => state.url);
const getAgent = useCallback(async () => { if (anonPDSAgent) return anonPDSAgent; const { StreamplaceAgent } = await import("streamplace"); return new StreamplaceAgent(streamplaceUrl); }, [anonPDSAgent, streamplaceUrl]);
return useQuery({ queryKey: ["liveUsers"], queryFn: async (): Promise<LivestreamView[]> => { const agent = await getAgent(); const result = await agent.client.call(place.stream.live.getLiveUsers, { limit: 50, }); return (result.streams ?? []) as LivestreamView[]; }, refetchInterval: REFETCH_INTERVAL, refetchIntervalInBackground: false, });}