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

check frontend version on connect

Browse Source
This commit is contained in:
Khaleel Al-Adhami 2025-01-08 17:14:17 -08:00
parent 4c97072a3c
commit 7be5fe4242
3 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
reflex/.templates/web/utils/state.js
View File

@ -407,6 +407,7 @@ export const connect = async (
socket.current = io(endpoint.href, { socket.current = io(endpoint.href, {
path: endpoint["pathname"], path: endpoint["pathname"],
transports: transports, transports: transports,
protocols: [env.REFLEX_VERSION],
autoUnref: false, autoUnref: false,
}); });
// Ensure undefined fields in events are sent as null instead of removed // Ensure undefined fields in events are sent as null instead of removed

6
reflex/app.py
View File

@ -1535,7 +1535,11 @@ class EventNamespace(AsyncNamespace):
sid: The Socket.IO session id. sid: The Socket.IO session id.
environ: The request information, including HTTP headers. environ: The request information, including HTTP headers.
""" """
pass subprotocol = environ.get("HTTP_SEC_WEBSOCKET_PROTOCOL", None)
if subprotocol and subprotocol != constants.Reflex.VERSION:
console.warn(
f"Frontend version {subprotocol} for session {sid} does not match the backend version {constants.Reflex.VERSION}."
)
def on_disconnect(self, sid): def on_disconnect(self, sid):
"""Event for when the websocket disconnects. """Event for when the websocket disconnects.

5
reflex/utils/build.py
View File

@ -19,7 +19,10 @@ def set_env_json():
"""Write the upload url to a REFLEX_JSON.""" """Write the upload url to a REFLEX_JSON."""
path_ops.update_json_file( path_ops.update_json_file(
str(prerequisites.get_web_dir() / constants.Dirs.ENV_JSON), str(prerequisites.get_web_dir() / constants.Dirs.ENV_JSON),
{endpoint.name: endpoint.get_url() for endpoint in constants.Endpoint}, {
**{endpoint.name: endpoint.get_url() for endpoint in constants.Endpoint},
"REFLEX_VERSION": constants.Reflex.VERSION,
},
) )