From 6c4deed37a7a4d7888be344139677eaa26594b41 Mon Sep 17 00:00:00 2001 From: Timothy Jaeryang Baek Date: Thu, 2 Oct 2025 02:21:21 -0500 Subject: [PATCH] refac/fix: direct connection floating action buttons --- backend/open_webui/utils/chat.py | 6 +++++- .../chat/ContentRenderer/FloatingButtons.svelte | 16 +++++++++++----- 2 files changed, 16 insertions(+), 6 deletions(-) diff --git a/backend/open_webui/utils/chat.py b/backend/open_webui/utils/chat.py index 83483f391b..8b6a0b9da2 100644 --- a/backend/open_webui/utils/chat.py +++ b/backend/open_webui/utils/chat.py @@ -80,6 +80,7 @@ async def generate_direct_chat_completion( event_caller = get_event_call(metadata) channel = f"{user_id}:{session_id}:{request_id}" + logging.info(f"WebSocket channel: {channel}") if form_data.get("stream"): q = asyncio.Queue() @@ -121,7 +122,10 @@ async def generate_direct_chat_completion( yield f"data: {json.dumps(data)}\n\n" elif isinstance(data, str): - yield data + if "data:" in data: + yield f"{data}\n\n" + else: + yield f"data: {data}\n\n" except Exception as e: log.debug(f"Error in event generator: {e}") pass diff --git a/src/lib/components/chat/ContentRenderer/FloatingButtons.svelte b/src/lib/components/chat/ContentRenderer/FloatingButtons.svelte index 389e17adc0..03c9429588 100644 --- a/src/lib/components/chat/ContentRenderer/FloatingButtons.svelte +++ b/src/lib/components/chat/ContentRenderer/FloatingButtons.svelte @@ -13,6 +13,7 @@ import LightBulb from '$lib/components/icons/LightBulb.svelte'; import Markdown from '../Messages/Markdown.svelte'; import Skeleton from '../Messages/Skeleton.svelte'; + import { chatId, models, socket } from '$lib/stores'; export let id = ''; export let messageId = ''; @@ -118,6 +119,9 @@ let res; [res, controller] = await chatCompletion(localStorage.token, { model: model, + model_item: $models.find((m) => m.id === model), + session_id: $socket?.id, + chat_id: $chatId, messages: [ ...messages, { @@ -246,11 +250,11 @@ {#if responseContent === null} {#if !floatingInput}
{#each actions as action}
{/if} {:else} -
+
@@ -331,7 +337,7 @@
{#if !responseContent || responseContent?.trim() === ''}