laipeng/reflex
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix issue

Browse Source
This commit is contained in:
Lendemor 2025-01-09 16:21:35 +01:00
parent 2825500e26
commit 2f215a350e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
reflex/app.py
View File

@ -1538,7 +1538,7 @@ class EventNamespace(AsyncNamespace):
environ: The request information, including HTTP headers. environ: The request information, including HTTP headers.
""" """
query_params = urllib.parse.parse_qs(environ.get("QUERY_STRING")) query_params = urllib.parse.parse_qs(environ.get("QUERY_STRING"))
await self.link_token_to_sid(sid, query_params.get("token")) await self.link_token_to_sid(sid, query_params.get("token", [])[0])
def on_disconnect(self, sid): def on_disconnect(self, sid):
"""Event for when the websocket disconnects. """Event for when the websocket disconnects.
@ -1611,7 +1611,7 @@ class EventNamespace(AsyncNamespace):
# Emit the test event. # Emit the test event.
await self.emit(str(constants.SocketEvent.PING), "pong", to=sid) await self.emit(str(constants.SocketEvent.PING), "pong", to=sid)
async def link_token_to_sid(self, sid, token): async def link_token_to_sid(self, sid: str, token: str):
"""Link a token to a session id. """Link a token to a session id.
Args: Args: