farcasclaudiu/Flowise
1
0
Fork 0
mirror of https://github.com/farcasclaudiu/Flowise.git synced 2026-06-22 07:01:07 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix/import-missing-chat-data (#4401)

Browse Source 
fix: add missing imports for messages and feedbacks in AgentFlow and AssistantFlow
This commit is contained in:
Ong Chung Yau
2025-05-08 18:43:28 +08:00
committed by GitHub
parent e467d0615c
commit 82e6f43b5c
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/services/export-import/index.ts
+10 -2
View File
@@ -178,7 +178,11 @@ async function replaceDuplicateIdsForChatMessage(queryRunner: QueryRunner, origi
const chatmessageChatflowIds = chatMessages.map((chatMessage) => { const chatmessageChatflowIds = chatMessages.map((chatMessage) => {
return { id: chatMessage.chatflowid, qty: 0 } return { id: chatMessage.chatflowid, qty: 0 }
}) })
const originalDataChatflowIds = originalData.ChatFlow.map((chatflow) => chatflow.id) const originalDataChatflowIds = [
...originalData.AssistantFlow.map((assistantFlow) => assistantFlow.id),
...originalData.AgentFlow.map((agentflow) => agentflow.id),
...originalData.ChatFlow.map((chatflow) => chatflow.id)
]
chatmessageChatflowIds.forEach((item) => { chatmessageChatflowIds.forEach((item) => {
if (originalDataChatflowIds.includes(item.id)) { if (originalDataChatflowIds.includes(item.id)) {
item.qty += 1 item.qty += 1
@@ -229,7 +233,11 @@ async function replaceDuplicateIdsForChatMessageFeedback(
const feedbackChatflowIds = chatMessageFeedbacks.map((feedback) => { const feedbackChatflowIds = chatMessageFeedbacks.map((feedback) => {
return { id: feedback.chatflowid, qty: 0 } return { id: feedback.chatflowid, qty: 0 }
}) })
const originalDataChatflowIds = originalData.ChatFlow.map((chatflow) => chatflow.id) const originalDataChatflowIds = [
...originalData.AssistantFlow.map((assistantFlow) => assistantFlow.id),
...originalData.AgentFlow.map((agentflow) => agentflow.id),
...originalData.ChatFlow.map((chatflow) => chatflow.id)
]
feedbackChatflowIds.forEach((item) => { feedbackChatflowIds.forEach((item) => {
if (originalDataChatflowIds.includes(item.id)) { if (originalDataChatflowIds.includes(item.id)) {
item.qty += 1 item.qty += 1