From 8191ac30dd79b4a39130fe83ffc16035776be484 Mon Sep 17 00:00:00 2001
From: Timothy Jaeryang Baek <tim@openwebui.com>
Date: Fri, 16 Oct 2026 01:43:50 +0400
Subject: [PATCH] refac

---
 backend/open_webui/socket/main.py                 | 14 ++++++++++----
 src/lib/components/common/ChatParticipants.svelte |  2 +-
 2 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/backend/open_webui/socket/main.py b/backend/open_webui/socket/main.py
index dfbc1d18c0..3d8cf7db8d 100644
--- a/backend/open_webui/socket/main.py
+++ b/backend/open_webui/socket/main.py
@@ -235,9 +235,11 @@ def get_session_pool_batches():
 async def publish_chat_presence(chat_id: str):
     # Room maps only contain this worker's sockets; the session pool spans workers.
     lock = (
-        REDIS.lock(f'{REDIS_KEY_PREFIX}:chat:{chat_id}:presence:lock',
+        REDIS.lock(
+            f'{REDIS_KEY_PREFIX}:chat:{chat_id}:presence:lock',
             timeout=WEBSOCKET_REDIS_LOCK_TIMEOUT,
-            blocking_timeout=WEBSOCKET_REDIS_LOCK_TIMEOUT)
+            blocking_timeout=WEBSOCKET_REDIS_LOCK_TIMEOUT,
+        )
         if REDIS is not None
         else SOCKET_EVENT_LOCKS.setdefault(('chat', chat_id), asyncio.Lock())
     )
@@ -298,7 +300,10 @@ async def periodic_session_pool_cleanup():
                         if expired:
                             log.warning('Reaping %d orphaned session(s) from the session pool', len(expired))
                             chat_ids = {
-                                chat_id for sid, entry in batch if sid in expired for chat_id in entry.get('chat_ids', [])
+                                chat_id
+                                for sid, entry in batch
+                                if sid in expired
+                                for chat_id in entry.get('chat_ids', [])
                             }
                             if WEBSOCKET_MANAGER == 'redis':
                                 SESSION_POOL.delete_many(*expired)
@@ -634,7 +639,8 @@ async def refresh_chat_access(chat_id=None):
                     current = SESSION_POOL.get(sid)
                     if current:
                         SESSION_POOL[sid] = {
-                            **current, 'chat_ids': [id for id in current.get('chat_ids', []) if id != cid]
+                            **current,
+                            'chat_ids': [id for id in current.get('chat_ids', []) if id != cid],
                         }
                 await sio.emit(
                     'events', {'chat_id': cid, 'shared': True, 'data': {'type': 'chat:access', 'data': {}}}, to=sid
diff --git a/src/lib/components/common/ChatParticipants.svelte b/src/lib/components/common/ChatParticipants.svelte
index 910f3b8551..a0e42e6329 100644
--- a/src/lib/components/common/ChatParticipants.svelte
+++ b/src/lib/components/common/ChatParticipants.svelte
@@ -48,7 +48,7 @@
 {/snippet}
 
 <div class="flex shrink-0 items-center gap-1" data-chat-participants draggable="false">
-	<div class="flex items-center -space-x-1 rtl:space-x-reverse">
+	<div class="flex items-center {mode === 'presence' ? '-space-x-2' : '-space-x-1'} rtl:space-x-reverse">
 		{#each people.slice(0, 3) as person (person.id)}
 			<div class="relative rounded-full hover:z-10 focus-within:z-10">
 				<ProfilePreview