import * as React from 'react'; import { useState, useEffect, useRef } from 'react'; import { Alert, Center, Container, Stack, px } from '@mantine/core'; import { ScrollArea } from '@mantine/core'; import { Button } from '@mantine/core'; import { useListState, useResizeObserver, useTimeout, useViewportSize } from '@mantine/hooks'; import { IconPlayerStop, IconRotateDot } from '@tabler/icons-react'; import messageUtil from '../../util/MessageUtil'; import { useSelector, useDispatch } from 'react-redux'; import { setValue } from './inputSlice'; import { reGenerating, stopGenerating, startResponsing, happendError, newMessage, updateMessage, shiftMessage, selectGenerating, selectCurrentMessage, selectErrorMessage, selectMessages, } from './chatSlice'; import InputMessage from './InputMessage'; import MessageContainer from './MessageContainer'; const RegenerationButton = () => { const dispatch = useDispatch(); return (); }; const StopButton = () => { const dispatch = useDispatch(); return ( ); }; const chatPanel = () => { const dispatch = useDispatch(); const generating = useSelector(selectGenerating); const currentMessage = useSelector(selectCurrentMessage); const errorMessage = useSelector(selectErrorMessage); const messages = useSelector(selectMessages); const [chatContainerRef, chatContainerRect] = useResizeObserver(); const scrollViewport = useRef(null); const { height, width } = useViewportSize(); const [scrollPosition, onScrollPositionChange] = useState({ x: 0, y: 0 }); const [stopScrolling, setStopScrolling] = useState(false); const messageCount = 10; const scrollToBottom = () => scrollViewport?.current?.scrollTo({ top: scrollViewport.current.scrollHeight, behavior: 'smooth' }); const timer = useTimeout(() => { // console.log(`stopScrolling:${stopScrolling}`); if (!stopScrolling) { scrollToBottom(); } }, 1000); useEffect(() => { messageUtil.sendMessage({ command: 'regContextList' }); messageUtil.sendMessage({ command: 'regCommandList' }); messageUtil.sendMessage({ command: 'historyMessages' }); messageUtil.registerHandler('receiveMessagePartial', (message: { text: string; }) => { dispatch(startResponsing(message.text)); }); messageUtil.registerHandler('receiveMessage', (message: { text: string; isError: boolean }) => { dispatch(stopGenerating()); if (message.isError) { dispatch(happendError(message.text)); } }); messageUtil.registerHandler('loadHistoryMessages', (message: { command: string; entries: [{ hash: '', user: '', date: '', request: '', response: '', context: [{ content: '', role: '' }] }] }) => { message.entries?.forEach(({ hash, user, date, request, response, context }, index) => { if (index < message.entries.length - messageCount) return; const contexts = context.map(({ content, role }) => ({ context: JSON.parse(content) })); dispatch(newMessage({ type: 'user', message: request, contexts: contexts })); dispatch(newMessage({ type: 'bot', message: response })); }); }); timer.start(); return () => { timer.clear(); }; }, []); useEffect(() => { const sh = scrollViewport.current?.scrollHeight || 0; const vh = scrollViewport.current?.clientHeight || 0; const isBottom = sh < vh ? true : sh - vh - scrollPosition.y < 3; if (isBottom) { setStopScrolling(false); } else { setStopScrolling(true); } }, [scrollPosition]); useEffect(() => { if (generating) { // new a bot message dispatch(newMessage({ type: 'bot', message: currentMessage })); } }, [generating]); // Add the received message to the chat UI as a bot message useEffect(() => { const lastIndex = messages?.length - 1; const lastMessage = messages[lastIndex]; if (currentMessage && lastMessage?.type === 'bot') { // update the last one bot message // messageHandlers.setItem(); dispatch(updateMessage({ index: lastIndex, newMessage: { type: 'bot', message: currentMessage } })); } timer.start(); }, [currentMessage]); useEffect(() => { if (messages.length > messageCount * 2) { dispatch(shiftMessage()); } timer.start(); }, [messages]); return ( {errorMessage && {errorMessage} } {generating &&
} {errorMessage &&
}
); }; export default chatPanel;