import useOverlayScroller from '@/hooks/use-overlay-scroller'; import useRequestToken from '@/hooks/use-request-token'; import { ClearOutlined, InboxOutlined } from '@ant-design/icons'; import { useIntl, useSearchParams } from '@umijs/max'; import { Button, Spin } from 'antd'; import classNames from 'classnames'; import 'overlayscrollbars/overlayscrollbars.css'; import { forwardRef, memo, useEffect, useImperativeHandle, useRef, useState } from 'react'; import { rerankerQuery } from '../apis'; import { MessageItem } from '../config/types'; import '../style/ground-left.less'; import '../style/system-message-wrap.less'; import FileList from './file-list'; import InputList from './input-list'; import MessageInput from './message-input'; import ReferenceParams from './reference-params'; import RerankMessage from './rerank-message'; import RerankerParams from './reranker-params'; import UploadFile from './upload-file'; import ViewCodeModal from './view-code-modal'; interface MessageProps { modelList: Global.BaseOption[]; loaded?: boolean; ref?: any; } const GroundReranker: React.FC = forwardRef((props, ref) => { const { modelList } = props; const messageId = useRef(0); const [messageList, setMessageList] = useState([]); const intl = useIntl(); const requestSource = useRequestToken(); const [searchParams] = useSearchParams(); const selectModel = searchParams.get('model') || ''; const [parameters, setParams] = useState({}); const [systemMessage, setSystemMessage] = useState(''); const [show, setShow] = useState(false); const [loading, setLoading] = useState(false); const [tokenResult, setTokenResult] = useState(null); const [collapse, setCollapse] = useState(false); const contentRef = useRef(''); const controllerRef = useRef(null); const scroller = useRef(null); const currentMessageRef = useRef(null); const paramsRef = useRef(null); const messageListLengthCache = useRef(0); const requestToken = useRef(null); const [fileList, setFileList] = useState< { text: string; name: string; uid: number | string }[] >([]); const [textList, setTextList] = useState< { text: string; uid: number | string; name: string }[] >([]); const { initialize, updateScrollerPosition } = useOverlayScroller(); const { initialize: innitializeParams } = useOverlayScroller(); useImperativeHandle(ref, () => { return { viewCode() { setShow(true); }, setCollapse() { setCollapse(!collapse); } }; }); const setMessageId = () => { messageId.current = messageId.current + 1; }; const handleStopConversation = () => { requestToken.current?.cancel?.(); setLoading(false); }; const submitMessage = async (current?: { role: string; content: string }) => { if (!parameters.model) return; try { setLoading(true); setMessageId(); setTokenResult(null); requestToken.current?.cancel?.(); requestToken.current = requestSource(); controllerRef.current?.abort?.(); controllerRef.current = new AbortController(); const signal = controllerRef.current.signal; currentMessageRef.current = current ? [ { content: current.content, title: 'Query', uid: messageId.current } ] : []; contentRef.current = ''; setMessageList((pre) => { return [...currentMessageRef.current]; }); const documentList: any[] = [...textList, ...fileList]; console.log('documentList:', documentList); const result: any = await rerankerQuery( { model: parameters.model, top_n: parameters.top_n, query: current?.content || '', documents: [ ...textList.map((item) => item.text), ...fileList.map((item) => item.text) ] }, { token: requestToken.current.token } ); console.log('result:', result); setMessageId(); setTokenResult(result.usage); setMessageList([ ...currentMessageRef.current, { title: 'Results', content: result.results?.map((item: any) => { return { uid: item.index, text: `${item.document?.text?.slice(0, 100) || ''}`, docIndex: item.index, title: documentList[item.index]?.name || '', score: item.relevance_score }; }), uid: messageId.current } ]); } catch (error: any) { setTokenResult({ error: true, errorMessage: error.response?.data?.error?.message }); } finally { setLoading(false); } }; const handleClear = () => { if (!messageList.length) { return; } setMessageId(); setMessageList([]); setTokenResult(null); }; const handleSendMessage = (message: Omit) => { const currentMessage = message.content || message.imgs?.length ? message : undefined; submitMessage(currentMessage); }; const handleCloseViewCode = () => { setShow(false); }; const handleUpdateFileList = ( files: { text: string; name: string; uid: number | string }[] ) => { console.log('files:', files); setFileList((preList) => { return [...preList, ...files]; }); }; const handleDeleteFile = (uid: number | string) => { setFileList((preList) => { return preList.filter((item) => item.uid !== uid); }); }; const handleTextListChange = ( list: { text: string; uid: number | string; name: string }[] ) => { setTextList(list); }; const handleClearDocuments = () => { setTextList([]); setFileList([]); }; useEffect(() => { setMessageId(); setMessageList([]); setTokenResult(null); }, [parameters.model]); useEffect(() => { if (scroller.current) { initialize(scroller.current); } }, [scroller.current, initialize]); useEffect(() => { if (paramsRef.current) { innitializeParams(paramsRef.current); } }, [paramsRef.current, innitializeParams]); useEffect(() => { if (loading) { updateScrollerPosition(); } }, [messageList, loading]); useEffect(() => { if (messageList.length > messageListLengthCache.current) { updateScrollerPosition(); } messageListLengthCache.current = messageList.length; }, [messageList.length]); return (
<>
{loading && (
)}
{tokenResult && (
)}

Documents

Click or drag file to this area to upload
support .txt, .doc, .docx, .xls, .xlsx
); }); export default memo(GroundReranker);