Socket.IO session state and role-check callsites:
- backend/open_webui/socket/main.py (lines 330-351, connect handler — role snapshotted into SESSIONPOOL)
- backend/open_webui/socket/main.py (lines 393-398, heartbeat handler — does not refresh role)
- backend/open_webui/socket/main.py (line 538, ydoc:document:join — uses cached role for admin check)
- backend/open_webui/socket/main.py (line 611, document_save_handler — uses cached role for admin check)
- backend/open_webui/routers/users.py (lines 557-633, role update — does not invalidate SESSIONPOOL)
- backend/open_webui/routers/users.py (line 641, user delete — does not invalidate SESSION_POOL)
Current main branch (commit 6fdd19bf1) and likely all versions with the collaborative document (Yjs) Socket.IO handlers.
When a user connects via Socket.IO, the connect handler authenticates them via JWT and stores their user record (including role) in the in-memory SESSION_POOL dictionary keyed by session ID. The heartbeat handler keeps the session alive indefinitely but only refreshes the last_seen_at timestamp — never the role.
Role checks in the Yjs collaborative document handlers (ydoc:document:join, document_save_handler) consult the cached SESSION_POOL role rather than the database. Meanwhile, administrative role changes and user deletions do not iterate SESSION_POOL to disconnect affected sessions. As a result, a user whose admin role has been revoked retains admin privileges within their existing Socket.IO session for as long as they keep the connection alive (via automatic heartbeats).
HTTP endpoints are not affected — get_current_user at utils/auth.py refetches the user record from the database on every request. The gap is exclusive to the Socket.IO session cache.
# socket/main.py:330-351 — role snapshotted at connect time
async def connect(sid, environ, auth):
user = None
if auth and 'token' in auth:
data = decode_token(auth['token'])
if data is not None and 'id' in data:
user = Users.get_user_by_id(data['id'])
if user:
SESSION_POOL[sid] = {
'id': user.id,
'role': user.role, # ← snapshotted, never refreshed
...
}
# socket/main.py:393-398 — heartbeat refreshes last_seen_at only
async def heartbeat(sid, data):
user = SESSION_POOL.get(sid)
if user:
SESSION_POOL[sid] = {**user, 'last_seen_at': int(time.time())}
# role is carried forward unchanged
# socket/main.py:538 — admin check against cached role
if user.get('role') != 'admin' and not has_access(user_id, 'note', note_id, 'read', db=db):
return
SESSION_POOL[sid] records role='admin'.POST /api/v1/users/{B_id}/update. The DB user.role becomes 'user'.heartbeat events every few seconds; these are accepted and only refresh last_seen_at.ydoc:document:join with document_id = 'note:<victim_note_id>' for any note they do not own.user.get('role') != 'admin' — returns False because SESSION_POOL still holds the stale admin role. Access check is bypassed, User B joins the document room, receives full document state and live updates.ydoc:document:update for the same note. The handler at line 611 performs the same cached-admin check, bypasses authorization, and persists attacker-controlled content to the victim's note via Notes.update_note_by_id.The same bypass occurs if the user is deleted entirely (delete_user_by_id) — the deleted user retains admin privileges on their live socket until disconnection.
{
"github_reviewed": true,
"github_reviewed_at": "2026-05-08T19:43:49Z",
"cwe_ids": [
"CWE-384",
"CWE-863"
],
"severity": "HIGH",
"nvd_published_at": null
}