72 lines
1.4 KiB
TypeScript
72 lines
1.4 KiB
TypeScript
import { makeVar, useReactiveVar } from '@apollo/client';
|
|
import type { ConnectingStream, Stream } from './types';
|
|
|
|
interface State {
|
|
isConnecting: boolean;
|
|
isConnected: boolean;
|
|
currentVideoPageIndex: number;
|
|
numberOfPages: number;
|
|
pageSize: number;
|
|
userId: string | null;
|
|
}
|
|
|
|
const videoState = makeVar<State>({
|
|
isConnecting: false,
|
|
isConnected: false,
|
|
currentVideoPageIndex: 0,
|
|
numberOfPages: 0,
|
|
pageSize: 0,
|
|
userId: null,
|
|
});
|
|
|
|
const useVideoState = () => useReactiveVar(videoState);
|
|
|
|
const setVideoState = (state: Partial<State>) => {
|
|
videoState({
|
|
...videoState(),
|
|
...state,
|
|
});
|
|
};
|
|
|
|
const getVideoState = () => videoState();
|
|
|
|
const connectingStream = makeVar<ConnectingStream | null>(null);
|
|
|
|
const useConnectingStream = (streams?: Stream[]) => {
|
|
const connecting = useReactiveVar(connectingStream);
|
|
|
|
if (!connecting) return null;
|
|
|
|
const hasStream = streams && streams.find((s) => s.stream === connecting.stream);
|
|
|
|
if (hasStream) {
|
|
return null;
|
|
}
|
|
|
|
return connecting;
|
|
};
|
|
|
|
const setConnectingStream = (stream: ConnectingStream | null) => {
|
|
connectingStream(stream);
|
|
};
|
|
|
|
const getConnectingStream = () => connectingStream();
|
|
|
|
export {
|
|
useVideoState,
|
|
setVideoState,
|
|
getVideoState,
|
|
useConnectingStream,
|
|
getConnectingStream,
|
|
setConnectingStream,
|
|
};
|
|
|
|
export default {
|
|
useVideoState,
|
|
setVideoState,
|
|
getVideoState,
|
|
useConnectingStream,
|
|
getConnectingStream,
|
|
setConnectingStream,
|
|
};
|