scriptoriumadmin/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui.git synced 2026-11-13 09:11:19 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

refac

Browse source
This commit is contained in:
Timothy Jaeryang Baek 2026-10-21 09:19:18 +09:00
parent b4a58be193
commit 7708ee851a
2 changed files with 20 additions and 45 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -3210,29 +3210,8 @@
const chatActionHandler = async (_chatId, actionId, modelId, responseMessageId, event = null) => {
const messages = createMessagesList(history, responseMessageId);
let changed = false;
const actionSocket = $socket;
const onEvent = (event) => {
if (event.chat_id !== _chatId || event.message_id !== responseMessageId) return;
const { type, data } = event.data ?? {};
// These events are UI-only or already persisted by get_event_emitter.
if (
[
'notification',
'confirmation',
'input',
'status',
'message',
'replace',
'files',
'embeds'
].includes(type) ||
(['source', 'citation'].includes(type) && data?.type == null)
)
return;
changed = true;
};
actionSocket?.on('events', onEvent);
// Actions can also update this message through events.
const original = structuredClone(history.messages[responseMessageId]);
const res = await chatAction(localStorage.token, actionId, {
model: modelId,
@ -3249,19 +3228,17 @@
chat_id: _chatId,
session_id: $socket?.id,
id: responseMessageId
})
.catch((error) => {
toast.error(`${error}`);
if ($chatId === _chatId && history.messages[responseMessageId]) {
history.messages[responseMessageId].error = { content: error };
changed = true;
}
return null;
})
.finally(() => actionSocket?.off('events', onEvent));
}).catch((error) => {
toast.error(`${error}`);
if ($chatId === _chatId && history.messages[responseMessageId]) {
history.messages[responseMessageId].error = { content: error };
}
return null;
});
if ($chatId !== _chatId) return;
let changed = !equal(original, history.messages[responseMessageId]);
if (res?.messages) {
// Update chat history with the new messages
for (const message of res.messages) {
@ -3282,17 +3259,15 @@
}
}
if (changed) {
if (!$temporaryChatEnabled) {
chat = await updateChatById(localStorage.token, _chatId, {
models: selectedModels,
messages: createMessagesList(history, responseMessageId),
history: history,
files: chatFiles
});
if (changed && !$temporaryChatEnabled) {
chat = await updateChatById(localStorage.token, _chatId, {
models: selectedModels,
messages: createMessagesList(history, responseMessageId),
history: history,
files: chatFiles
});
await refreshChatList(localStorage.token);
}
await refreshChatList(localStorage.token);
}
};

4
src/lib/components/chat/FileNav/FileEntryRow.svelte
View file

@ -318,10 +318,10 @@
<input
bind:this={renameInput}
bind:value={renameValue}
class="flex-1 text-xs bg-transparent outline-none text-gray-800 dark:text-gray-200 min-w-0 {variant ===
class="flex-1 text-xs bg-transparent outline-hidden text-gray-800 dark:text-gray-200 min-w-0 {variant ===
'workspace'
? 'h-4 p-0 leading-4'
: 'border border-gray-100 dark:border-white/[0.06] rounded px-1.5 py-0.5 focus:border-blue-400 dark:focus:border-blue-500'}"
: 'py-0.5'}"
on:keydown={(e) => {
if (e.key === 'Enter') {
e.preventDefault();