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

refac

Browse source
This commit is contained in:
Timothy Jaeryang Baek 2026-10-29 16:37:21 +09:00
parent 63ca4237eb
commit be8ebed784
1 changed files with 15 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
src/lib/components/channel/Thread.svelte
View file

@ -23,7 +23,7 @@
let messages = null;
let searchAnchor = '';
let loadVersion = 0;
let loading = null;
let top = false;
let messagesContainerElement = null;
@ -49,7 +49,7 @@
};
const initHandler = async (anchor = '') => {
const version = ++loadVersion;
loading = null;
searchAnchor = anchor;
messages = null;
top = false;
@ -59,19 +59,16 @@
typingUsersTimeout = {};
if (channel) {
const loaded = await getChannelThreadMessages(
localStorage.token,
channel.id,
threadId,
0,
50,
{ around: anchor }
).catch((error) => {
toast.error(String(error));
loading = getChannelThreadMessages(localStorage.token, channel.id, threadId, 0, 50, {
around: anchor
}).catch((error) => {
if (request === loading) toast.error(String(error));
return [];
});
if (version !== loadVersion) return;
messages = loaded;
const request = loading;
const loaded = await request;
if (request !== loading) return;
messages = loaded ?? [];
if (messages.length < 50) {
top = true;
@ -96,13 +93,10 @@
const type = event?.data?.type ?? null;
const data = event?.data?.data ?? null;
if (
messages === null &&
type !== 'typing' &&
(data?.parent_id === threadId || (data?.id === threadId && type !== 'message:delete'))
) {
// Restart the fetch; loadVersion prevents its stale response from being applied.
return initHandler(searchAnchor);
if (messages === null && type !== 'typing') {
const request = loading;
await request;
if (request !== loading) return;
}
if (type === 'message') {
@ -224,6 +218,7 @@
});
onDestroy(() => {
loading = null;
$socket?.off('events:channel', channelEventHandler);
});
</script>