Medplum

// SPDX-FileCopyrightText: Copyright Orangebot, Inc. and Medplum contributors // SPDX-License-Identifier: Apache-2.0 import type { ProfileResource } from '@medplum/core'; import { createReference, formatCodeableConcept, getReferenceString } from '@medplum/core'; import type { Communication } from '@medplum/fhirtypes'; import { useMedplum, useMedplumProfile, usePrevious } from '@medplum/react-hooks'; import type { JSX } from 'react'; import { useCallback, useEffect, useMemo, useState } from 'react'; import { BaseChat } from '../BaseChat/BaseChat'; export interface ThreadChatProps { readonly thread: Communication; readonly title?: string; readonly onMessageSent?: (message: Communication) => void; readonly inputDisabled?: boolean; readonly excludeHeader?: boolean; readonly onError?: (err: Error) => void; } export function ThreadChat(props: ThreadChatProps): JSX.Element | null { const { thread, title, onMessageSent, inputDisabled, excludeHeader, onError } = props; const medplum = useMedplum(); const profile = useMedplumProfile(); const prevThreadId = usePrevious<string | undefined>(thread?.id); const [communications, setCommunications] = useState<Communication[]>([]); const profileRef = useMemo(() => (profile ? createReference(profile as ProfileResource) : undefined), [profile]); const threadRef = useMemo(() => createReference(thread), [thread]); useEffect(() => { if (thread?.id !== prevThreadId) { setCommunications([]); } }, [thread?.id, prevThreadId]); const sendMessage = useCallback( (message: string) => { const profileRefStr = profileRef ? getReferenceString(profileRef) : undefined; if (!profileRefStr) { return; } medplum .createResource<Communication>({ resourceType: 'Communication', status: 'in-progress', sender: profileRef, recipient: thread.recipient?.filter((ref) => getReferenceString(ref) !== profileRefStr) ?? [], sent: new Date().toISOString(), payload: [{ contentString: message }], partOf: [threadRef], }) .then((communication) => { setCommunications([...communications, communication]); onMessageSent?.(communication); }) .catch(console.error); }, [medplum, profileRef, thread, threadRef, communications, onMessageSent] ); // Currently we only support `delivered` on chats with 2 participants // Normally we would use `useCallback` to memoize a function // But in this case we only want to conditionally pass a function if the thread has 2 participants... // If the thread has 3 or more participants, we do not pass this function; instead we pass undefined const onMessageReceived = useMemo( () => thread.recipient?.length === 2 ? (message: Communication): void => { if (!(message.received && message.status === 'completed')) { medplum .updateResource({ ...message, received: message.received ?? new Date().toISOString(), // Mark as received if needed status: 'completed', // Mark as 'read' // See: https://www.medplum.com/docs/communications/organizing-communications#:~:text=THE%20Communication%20LIFECYCLE // for more info about recommended `Communication` lifecycle }) .catch(console.error); } } : undefined, [medplum, thread.recipient?.length] ); if (!profile) { return null; } return ( <BaseChat title={title ?? (thread?.topic ? formatCodeableConcept(thread.topic) : '[No thread title]')} communications={communications} setCommunications={setCommunications} query={`part-of=Communication/${thread.id as string}`} sendMessage={sendMessage} onMessageReceived={onMessageReceived} inputDisabled={inputDisabled} excludeHeader={excludeHeader} onError={onError} /> ); }