scriptoriumadmin/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui.git synced 2026-10-03 02:23:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

refac

Browse source
This commit is contained in:
Timothy Jaeryang Baek 2026-09-24 00:00:19 -04:00
parent d9dff09c30
commit aea7d34f45
1 changed files with 20 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
src/lib/components/chat/Chat.svelte
View file

@ -2566,19 +2566,31 @@
};
const sendQueuedMessageNow = async (id) => {
if (processingQueueChats.has($chatId)) return;
const queue = $chatRequestQueues[$chatId] ?? [];
const item = queue.find((m) => m.id === id);
if (!item || (item.files ?? []).some((file) => ['uploading', 'error'].includes(file.status))) {
return;
}
chatRequestQueues.update((q) => ({
...q,
[$chatId]: queue.filter((m) => m.id !== id)
}));
await stopResponse(false);
await tick();
await submitPrompt(item.prompt, item.files);
const targetChatId = $chatId;
processingQueueChats.add(targetChatId);
try {
chatRequestQueues.update((q) => ({
...q,
[targetChatId]: queue.filter((m) => m.id !== id)
}));
await stopResponse(false);
await tick();
await submitPrompt(item.prompt, item.files);
} finally {
processingQueueChats.delete(targetChatId);
// Completion can arrive before submitPrompt returns, while the queue is locked.
if ($chatId === targetChatId) {
await processNextInQueue(targetChatId);
}
}
};
const editQueuedMessage = (id) => {
@ -3824,7 +3836,7 @@
}
if (responseMessage) {
history.messages[history.currentId] = responseMessage;
history.messages[responseMessage.id] = responseMessage;
}
if (shouldAutoScrollResponse()) {