|
| 1 | +import { useDebouncedValue } from '@rocket.chat/fuselage-hooks'; |
| 2 | +import { keepPreviousData, useQuery } from '@tanstack/react-query'; |
| 3 | +import { createContext, useContext, useState } from 'react'; |
| 4 | + |
| 5 | +import type { PeerAutocompleteOptions } from './components'; |
| 6 | + |
| 7 | +type InternalPeerInfo = { |
| 8 | + name: string; |
| 9 | + avatarUrl: string; |
| 10 | + identifier: string; |
| 11 | +}; |
| 12 | + |
| 13 | +type ExternalPeerInfo = { |
| 14 | + number: string; |
| 15 | +}; |
| 16 | + |
| 17 | +export type PeerInfo = InternalPeerInfo | ExternalPeerInfo; |
| 18 | + |
| 19 | +export type State = 'closed' | 'new' | 'calling' | 'ringing' | 'ongoing'; |
| 20 | + |
| 21 | +type MediaCallContextType = { |
| 22 | + state: State; |
| 23 | + |
| 24 | + peerInfo: PeerInfo | undefined; |
| 25 | + |
| 26 | + muted: boolean; |
| 27 | + held: boolean; |
| 28 | + onMute: () => void; |
| 29 | + onHold: () => void; |
| 30 | + |
| 31 | + onDeviceChange: (device: string) => void; |
| 32 | + onForward: () => void; |
| 33 | + onTone: (tone: string) => void; |
| 34 | + |
| 35 | + // onCall and onEndCall are used to start/accept and reject/end a call |
| 36 | + onEndCall: () => void; |
| 37 | + // TODO: Not sure if we need to pass the peerId to the callback, or if it should be a state stored somewhere else in the context. |
| 38 | + onCall: (peerId?: string) => void; |
| 39 | + |
| 40 | + onToggleWidget: () => void; |
| 41 | + |
| 42 | + getAutocompleteOptions: (filter: string) => Promise<PeerAutocompleteOptions[]>; |
| 43 | + // This is used to get the peer info from the server in case it's not available in the autocomplete options. |
| 44 | + getPeerInfo: (id: string) => Promise<PeerInfo | undefined>; |
| 45 | +}; |
| 46 | + |
| 47 | +const MediaCallContext = createContext<MediaCallContextType>({ |
| 48 | + state: 'closed', |
| 49 | + |
| 50 | + peerInfo: undefined, |
| 51 | + |
| 52 | + muted: false, |
| 53 | + held: false, |
| 54 | + onMute: () => undefined, |
| 55 | + onHold: () => undefined, |
| 56 | + |
| 57 | + onDeviceChange: () => undefined, |
| 58 | + onForward: () => undefined, |
| 59 | + onTone: () => undefined, |
| 60 | + |
| 61 | + onEndCall: () => undefined, |
| 62 | + onCall: () => undefined, |
| 63 | + |
| 64 | + onToggleWidget: () => undefined, |
| 65 | + |
| 66 | + getAutocompleteOptions: () => Promise.resolve([]), |
| 67 | + getPeerInfo: () => Promise.resolve(undefined), |
| 68 | +}); |
| 69 | + |
| 70 | +export const useMediaCallContext = (): MediaCallContextType => { |
| 71 | + return useContext(MediaCallContext); |
| 72 | +}; |
| 73 | + |
| 74 | +const PREFIX_FIRST_OPTION = 'rcx-first-option-'; |
| 75 | + |
| 76 | +export const isFirstPeerAutocompleteOption = (value: string) => { |
| 77 | + return value.startsWith(PREFIX_FIRST_OPTION); |
| 78 | +}; |
| 79 | + |
| 80 | +const getFirstOption = (filter: string): PeerAutocompleteOptions => { |
| 81 | + return { value: `${PREFIX_FIRST_OPTION}${filter}`, label: filter, avatarUrl: '' }; |
| 82 | +}; |
| 83 | + |
| 84 | +export const usePeerAutocomplete = () => { |
| 85 | + const { getAutocompleteOptions, getPeerInfo } = useMediaCallContext(); |
| 86 | + const [selected, setSelected] = useState<string | undefined>(); |
| 87 | + const [filter, setFilter] = useState(''); |
| 88 | + |
| 89 | + const debouncedFilter = useDebouncedValue(filter, 400); |
| 90 | + |
| 91 | + const { data: options } = useQuery({ |
| 92 | + queryKey: ['mediaCall/peerAutocomplete', debouncedFilter], |
| 93 | + queryFn: async () => { |
| 94 | + const options = await getAutocompleteOptions(debouncedFilter); |
| 95 | + |
| 96 | + if (debouncedFilter.length > 0) { |
| 97 | + return [getFirstOption(debouncedFilter), ...options]; |
| 98 | + } |
| 99 | + |
| 100 | + return options; |
| 101 | + }, |
| 102 | + placeholderData: keepPreviousData, |
| 103 | + initialData: [], |
| 104 | + }); |
| 105 | + |
| 106 | + const { data: peerInfo } = useQuery({ |
| 107 | + queryKey: ['mediaCall/peerInfo', selected], |
| 108 | + queryFn: async () => { |
| 109 | + if (!selected) { |
| 110 | + return undefined; |
| 111 | + } |
| 112 | + |
| 113 | + const localInfo = options.find((option) => option.value === selected); |
| 114 | + |
| 115 | + if (localInfo) { |
| 116 | + return { |
| 117 | + name: localInfo.label, |
| 118 | + avatarUrl: localInfo.avatarUrl || '', |
| 119 | + identifier: localInfo.value, |
| 120 | + }; |
| 121 | + } |
| 122 | + |
| 123 | + const peerInfo = await getPeerInfo(selected); |
| 124 | + |
| 125 | + return peerInfo; |
| 126 | + }, |
| 127 | + enabled: !!selected, |
| 128 | + }); |
| 129 | + |
| 130 | + return { |
| 131 | + options, |
| 132 | + peerInfo, |
| 133 | + onChangeFilter: setFilter, |
| 134 | + onChangeValue: (value: string | string[]) => { |
| 135 | + if (Array.isArray(value)) { |
| 136 | + return; |
| 137 | + } |
| 138 | + |
| 139 | + setSelected(value); |
| 140 | + }, |
| 141 | + value: selected, |
| 142 | + filter, |
| 143 | + onKeypadPress: (key: string) => setFilter((filter) => filter + key), |
| 144 | + }; |
| 145 | +}; |
| 146 | + |
| 147 | +export default MediaCallContext; |
0 commit comments