From a430284aa21e3ae1f0d5654e55b2ad2852519cc2 Mon Sep 17 00:00:00 2001
From: wwf <yearningwang@iqtogether.com>
Date: 星期三, 04 六月 2025 15:17:49 +0800
Subject: [PATCH] 初始化
---
app/components/base/chat/chat/hooks.ts | 61 +++---------------------------
1 files changed, 7 insertions(+), 54 deletions(-)
diff --git a/app/components/base/chat/chat/hooks.ts b/app/components/base/chat/chat/hooks.ts
index fde4674..bcd08c8 100644
--- a/app/components/base/chat/chat/hooks.ts
+++ b/app/components/base/chat/chat/hooks.ts
@@ -34,7 +34,6 @@
getProcessedFiles,
getProcessedFilesFromResponse,
} from '@/app/components/base/file-uploader/utils'
-import { noop } from 'lodash-es'
type GetAbortController = (abortController: AbortController) => void
type SendCallback = {
@@ -52,8 +51,6 @@
},
prevChatTree?: ChatItemInTree[],
stopChat?: (taskId: string) => void,
- clearChatList?: boolean,
- clearChatListCallback?: (state: boolean) => void,
) => {
const { t } = useTranslation()
const { formatTime } = useTimestamp()
@@ -93,7 +90,7 @@
}
else {
ret.unshift({
- id: 'opening-statement',
+ id: `${Date.now()}`,
content: getIntroduction(config.opening_statement),
isAnswer: true,
isOpeningStatement: true,
@@ -166,13 +163,12 @@
suggestedQuestionsAbortControllerRef.current.abort()
}, [stopChat, handleResponding])
- const handleRestart = useCallback((cb?: any) => {
+ const handleRestart = useCallback(() => {
conversationId.current = ''
taskIdRef.current = ''
handleStop()
setChatTree([])
setSuggestQuestions([])
- cb?.()
}, [handleStop])
const updateCurrentQAOnTree = useCallback(({
@@ -309,7 +305,7 @@
else
ttsUrl = `/apps/${params.appId}/text-to-audio`
}
- const player = AudioPlayerManager.getInstance().getAudioPlayer(ttsUrl, ttsIsPublic, uuidV4(), 'none', 'none', noop)
+ const player = AudioPlayerManager.getInstance().getAudioPlayer(ttsUrl, ttsIsPublic, uuidV4(), 'none', 'none', (_: any): any => {})
ssePost(
url,
{
@@ -401,7 +397,6 @@
)
setSuggestQuestions(data)
}
- // eslint-disable-next-line unused-imports/no-unused-vars
catch (e) {
setSuggestQuestions([])
}
@@ -424,8 +419,6 @@
const response = responseItem as any
if (thought.message_id && !hasSetResponseId)
response.id = thought.message_id
- if (thought.conversation_id)
- response.conversationId = thought.conversation_id
if (response.agent_thoughts.length === 0) {
response.agent_thoughts.push(thought)
@@ -514,7 +507,7 @@
responseItem.workflowProcess!.tracing!.push({
...iterationStartedData,
status: WorkflowRunningStatus.Running,
- })
+ } as any)
updateCurrentQAOnTree({
placeholderQuestionId,
questionItem,
@@ -530,7 +523,7 @@
...tracing[iterationIndex],
...iterationFinishedData,
status: WorkflowRunningStatus.Succeeded,
- }
+ } as any
updateCurrentQAOnTree({
placeholderQuestionId,
@@ -543,13 +536,10 @@
if (nodeStartedData.iteration_id)
return
- if (data.loop_id)
- return
-
responseItem.workflowProcess!.tracing!.push({
...nodeStartedData,
status: WorkflowRunningStatus.Running,
- })
+ } as any)
updateCurrentQAOnTree({
placeholderQuestionId,
questionItem,
@@ -561,14 +551,11 @@
if (nodeFinishedData.iteration_id)
return
- if (data.loop_id)
- return
-
const currentIndex = responseItem.workflowProcess!.tracing!.findIndex((item) => {
if (!item.execution_metadata?.parallel_id)
return item.node_id === nodeFinishedData.node_id
- return item.node_id === nodeFinishedData.node_id && (item.execution_metadata?.parallel_id === nodeFinishedData.execution_metadata?.parallel_id)
+ return item.node_id === nodeFinishedData.node_id && (item.execution_metadata?.parallel_id === nodeFinishedData.execution_metadata.parallel_id)
})
responseItem.workflowProcess!.tracing[currentIndex] = nodeFinishedData as any
@@ -587,35 +574,6 @@
},
onTTSEnd: (messageId: string, audio: string) => {
player.playAudioWithAudio(audio, false)
- },
- onLoopStart: ({ data: loopStartedData }) => {
- responseItem.workflowProcess!.tracing!.push({
- ...loopStartedData,
- status: WorkflowRunningStatus.Running,
- })
- updateCurrentQAOnTree({
- placeholderQuestionId,
- questionItem,
- responseItem,
- parentId: data.parent_message_id,
- })
- },
- onLoopFinish: ({ data: loopFinishedData }) => {
- const tracing = responseItem.workflowProcess!.tracing!
- const loopIndex = tracing.findIndex(item => item.node_id === loopFinishedData.node_id
- && (item.execution_metadata?.parallel_id === loopFinishedData.execution_metadata?.parallel_id || item.parallel_id === loopFinishedData.execution_metadata?.parallel_id))!
- tracing[loopIndex] = {
- ...tracing[loopIndex],
- ...loopFinishedData,
- status: WorkflowRunningStatus.Succeeded,
- }
-
- updateCurrentQAOnTree({
- placeholderQuestionId,
- questionItem,
- responseItem,
- parentId: data.parent_message_id,
- })
},
})
return true
@@ -687,11 +645,6 @@
} as Annotation,
})
}, [chatList, updateChatTreeNode])
-
- useEffect(() => {
- if (clearChatList)
- handleRestart(() => clearChatListCallback?.(false))
- }, [clearChatList, clearChatListCallback, handleRestart])
return {
chatList,
--
Gitblit v1.8.0