import { Box, FormControl, IconButton, InputAdornment, InputBase, SxProps, Theme, Typography, useMediaQuery, useTheme } from "@mui/material"; import { createTicket, getUnauthTicketMessages, sendTicketMessage, subscribeToUnauthTicketMessages } from "@root/api/tickets"; import { GetMessagesRequest, TicketMessage } from "@root/model/ticket"; import { useMessageStore } from "@root/stores/messages"; import { addOrUpdateUnauthMessages, setUnauthTicketFetchState, setUnauthTicketSessionId, useUnauthTicketStore } from "@root/stores/unauthTicket"; import { enqueueSnackbar } from "notistack"; import { useEffect, useRef, useState } from "react"; import ChatMessage from "../ChatMessage"; import SendIcon from "../icons/SendIcon"; import UserCircleIcon from "./UserCircleIcon"; interface Props { sx?: SxProps; } export default function Chat({ sx }: Props) { const theme = useTheme(); const upMd = useMediaQuery(theme.breakpoints.up("md")); const [messageField, setMessageField] = useState(""); const sessionId = useUnauthTicketStore(state => state.sessionId); const messages = useUnauthTicketStore(state => state.messages); const messageApiPage = useUnauthTicketStore(state => state.apiPage); const messagesPerPage = useUnauthTicketStore(state => state.messagesPerPage); const messagesFetchStateRef = useRef(useMessageStore.getState().fetchState); const chatBoxRef = useRef(); useEffect(function fetchTicketMessages() { if (!sessionId) return; const getTicketsBody: GetMessagesRequest = { amt: messagesPerPage, page: messageApiPage, ticket: sessionId, }; const controller = new AbortController(); setUnauthTicketFetchState("fetching"); getUnauthTicketMessages({ body: getTicketsBody, signal: controller.signal, }).then(result => { console.log("GetMessagesResponse", result); if (result?.length > 0) { addOrUpdateUnauthMessages(result); setUnauthTicketFetchState("idle"); } else setUnauthTicketFetchState("all fetched"); }).catch(error => { console.log("Error fetching messages", error); enqueueSnackbar(error.message); }); return () => { controller.abort(); }; }, [messageApiPage, messagesPerPage, sessionId]); useEffect(function subscribeToMessages() { if (!sessionId) return; const unsubscribe = subscribeToUnauthTicketMessages({ sessionId, onMessage(event) { try { const newMessage = JSON.parse(event.data) as TicketMessage; if (!newMessage.id) throw new Error("Bad SSE response"); console.log("SSE: parsed newMessage:", newMessage); addOrUpdateUnauthMessages([newMessage]); } catch (error) { console.log("SSE: couldn't parse:", event.data); console.log("Error parsing SSE message", error); } }, onError(event) { console.log("SSE Error:", event); }, }); return () => { unsubscribe(); // clearUnauthTicketState(); }; }, [sessionId]); useEffect(() => useMessageStore.subscribe(state => (messagesFetchStateRef.current = state.fetchState)), []); async function handleSendMessage() { if (!messageField) return; if (!sessionId) { const response = await createTicket({ Title: "Unauth title", Message: messageField, }, false); setUnauthTicketSessionId(response.sess); } else { sendTicketMessage({ ticket: sessionId, message: messageField, lang: "ru", files: [], }, true); } setMessageField(""); } const handleTextfieldKeyPress: React.KeyboardEventHandler = (e) => { if (e.key === "Enter" && !e.shiftKey) { e.preventDefault(); handleSendMessage(); } }; return ( Мария онлайн-консультант {messages.map((message) => ( ))} setMessageField(e.target.value)} endAdornment={ } /> ); }