xinyin025/LangBot
1
0
Fork 0
mirror of https://github.com/langbot-app/LangBot.git synced 2026-06-13 01:06:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix:lsome bug

Browse Source
This commit is contained in:
fdc
2025-07-31 10:28:43 +08:00
parent e4d951b174
commit 5560a4f52d
2 changed files with 38 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
web/src/app/home/pipelines/components/debug-dialog/DebugDialog.tsx
View File

@@ -46,6 +46,18 @@ export default function DebugDialog({
messagesEndRef.current?.scrollIntoView({ behavior: 'smooth' });
};
const loadMessages = async (pipelineId: string) => {
try {
const response = await httpClient.getWebChatHistoryMessages(
pipelineId,
sessionType,
);
setMessages(response.messages);
} catch (error) {
console.error('Failed to load messages:', error);
}
};
useEffect(() => {
scrollToBottom();
}, [messages]);
@@ -61,7 +73,7 @@ export default function DebugDialog({
if (open) {
loadMessages(selectedPipelineId);
}
}, [sessionType, selectedPipelineId]);
}, [sessionType, selectedPipelineId, open, loadMessages]);
useEffect(() => {
const handleClickOutside = (event: MouseEvent) => {
@@ -86,18 +98,6 @@ export default function DebugDialog({
}
}, [showAtPopover]);
const loadMessages = async (pipelineId: string) => {
try {
const response = await httpClient.getWebChatHistoryMessages(
pipelineId,
sessionType,
);
setMessages(response.messages);
} catch (error) {
console.error('Failed to load messages:', error);
}
};
const handleInputChange = (e: React.ChangeEvent<HTMLInputElement>) => {
const value = e.target.value;
if (sessionType === 'group') {
@@ -179,12 +179,16 @@ export default function DebugDialog({
// 添加用户消息和初始bot消息到状态
setMessages((prevMessages) => [...prevMessages, userMessage, botMessage]);
setMessages((prevMessages) => [
...prevMessages,
userMessage,
botMessage,
]);
setInputValue('');
setHasAt(false);
try {
let botMessageId = botMessage.id;
const botMessageId = botMessage.id;
let accumulatedContent = '';
await httpClient.sendStreamingWebChatMessage(
@@ -200,14 +204,17 @@ export default function DebugDialog({
setMessages((prevMessages) => {
const updatedMessages = [...prevMessages];
const botMessageIndex = updatedMessages.findIndex(
(msg) => msg.id === botMessageId && msg.role === 'assistant'
(msg) =>
msg.id === botMessageId && msg.role === 'assistant',
);
if (botMessageIndex !== -1) {
const updatedBotMessage = {
...updatedMessages[botMessageIndex],
content: accumulatedContent,
message_chain: [{ type: 'Plain', text: accumulatedContent }],
message_chain: [
{ type: 'Plain', text: accumulatedContent },
]
};
updatedMessages[botMessageIndex] = updatedBotMessage;
}
@@ -226,7 +233,7 @@ export default function DebugDialog({
if (sessionType === 'person') {
toast.error(t('pipelines.debugDialog.sendFailed'));
}
}
},
);
} catch (error) {
console.error('Failed to send streaming message:', error);
@@ -378,7 +385,9 @@ export default function DebugDialog({
<div className="p-4 pb-0 bg-white flex gap-2">
<div className="flex items-center gap-2">
<span className="text-sm text-gray-600">{t('pipelines.debugDialog.streaming')}</span>
<span className="text-sm text-gray-600">
{t('pipelines.debugDialog.streaming')}
</span>
<Switch
checked={isStreaming}
onCheckedChange={setIsStreaming}