OpenWebUI/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui synced 2025-05-17 12:03:41 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

refac

Browse Source
This commit is contained in:
Timothy Jaeryang Baek 2025-03-26 01:25:01 -07:00
parent c062353a3f
commit a650d77af4
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
backend/open_webui/routers/chats.py
View File

@ -416,7 +416,7 @@ async def update_chat_message_by_id(
) )
if event_emitter: if event_emitter:
event_emitter( await event_emitter(
{ {
"type": "chat:message", "type": "chat:message",
"data": { "data": {

10
backend/open_webui/socket/main.py
View File

@ -272,8 +272,16 @@ async def disconnect(sid):
def get_event_emitter(request_info, update_db=True): def get_event_emitter(request_info, update_db=True):
async def __event_emitter__(event_data): async def __event_emitter__(event_data):
user_id = request_info["user_id"] user_id = request_info["user_id"]
session_ids = list( session_ids = list(
set(USER_POOL.get(user_id, []) + [request_info["session_id"]]) set(
USER_POOL.get(user_id, [])
+ (
[request_info.get("session_id")]
if request_info.get("session_id")
else []
)
)
) )
for session_id in session_ids: for session_id in session_ids: