rename reflex_delta_token to client_token

reflex/middleware/hydrate_middleware.py

@@ -45,7 +45,7 @@ class HydrateMiddleware(Middleware):
         delta = await _resolve_delta(
             StateDelta(
                 state.dict(),
-                reflex_delta_token=state.router.session.client_token,
+                client_token=state.router.session.client_token,
                 flush=True,
             )
         )

reflex/state.py

@@ -117,7 +117,7 @@ class StateDelta:
     """A dictionary representing the state delta."""
 
     data: dict[str, Any] = dataclasses.field(default_factory=dict)
-    reflex_delta_token: str | None = dataclasses.field(default=None)
+    client_token: str | None = dataclasses.field(default=None)
     flush: bool = dataclasses.field(default=False)
 
     def __getitem__(self, key: str) -> Any:
@@ -221,11 +221,11 @@ def serialize_state_delta(delta: StateDelta) -> dict[str, Any]:
     Returns:
         The serialized state delta.
     """
-    if delta.reflex_delta_token is not None and environment.REFLEX_USE_JSON_PATCH.get():
+    if delta.client_token is not None and environment.REFLEX_USE_JSON_PATCH.get():
         full_delta = {}
         for state_name, new_state_value in delta.items():
             new_state_value = json.loads(format.json_dumps(new_state_value))
-            key = delta.reflex_delta_token + state_name
+            key = delta.client_token + state_name
             previous_delta = LAST_DELTA_CACHE.get(key)
             LAST_DELTA_CACHE[key] = new_state_value
             if previous_delta is not None and not delta.flush:
@@ -2018,7 +2018,7 @@ class BaseState(Base, ABC, extra=pydantic.Extra.allow):
         """Get the delta for the state.
 
         Args:
-            token: The reflex delta
+            token: The client token.
 
         Returns:
             The delta for the state.
@@ -2051,7 +2051,7 @@ class BaseState(Base, ABC, extra=pydantic.Extra.allow):
             delta.update(substates[substate].get_delta())
 
         # Return the delta.
-        return StateDelta(delta, reflex_delta_token=token)
+        return StateDelta(delta, client_token=token)
 
     def _mark_dirty(self):
         """Mark the substate and all parent states as dirty."""

tests/units/test_app.py

@@ -1060,7 +1060,7 @@ async def test_dynamic_route_var_route_change_completed_on_load(
                         "router": exp_router,
                     }
                 },
-                reflex_delta_token=token,
+                client_token=token,
             ),
             events=[
                 _dynamic_state_event(
@@ -1103,7 +1103,7 @@ async def test_dynamic_route_var_route_change_completed_on_load(
                         "loaded": exp_index + 1,
                     },
                 },
-                reflex_delta_token=token,
+                client_token=token,
             ),
             events=[],
         )
@@ -1127,7 +1127,7 @@ async def test_dynamic_route_var_route_change_completed_on_load(
                         "is_hydrated": True,
                     },
                 },
-                reflex_delta_token=token,
+                client_token=token,
             ),
             events=[],
         )
@@ -1151,7 +1151,7 @@ async def test_dynamic_route_var_route_change_completed_on_load(
                         "counter": exp_index + 1,
                     }
                 },
-                reflex_delta_token=token,
+                client_token=token,
             ),
             events=[],
         )

tests/units/test_state.py

@@ -2022,7 +2022,7 @@ async def test_state_proxy(grandchild_state: GrandchildState, mock_app: rx.App):
                     "computed": "",
                 },
             },
-            reflex_delta_token="_" + grandchild_state.get_full_name(),
+            client_token="_" + grandchild_state.get_full_name(),
         )
     )
     assert mcall.kwargs["to"] == grandchild_state.router.session.session_id
@@ -2191,7 +2191,7 @@ async def test_background_task_no_block(mock_app: rx.App, token: str):
                         ],
                     }
                 },
-                reflex_delta_token=token,
+                client_token=token,
             )
         )
 
@@ -2230,7 +2230,7 @@ async def test_background_task_no_block(mock_app: rx.App, token: str):
                     "computed_order": ["background_task:start"],
                 }
             },
-            reflex_delta_token=token + "_" + BackgroundTaskState.get_full_name(),
+            client_token=token + "_" + BackgroundTaskState.get_full_name(),
         ),
         events=[],
         final=True,
@@ -2243,7 +2243,7 @@ async def test_background_task_no_block(mock_app: rx.App, token: str):
                         "computed_order": ["background_task:start"],
                     }
                 },
-                reflex_delta_token=token + "_" + BackgroundTaskState.get_full_name(),
+                client_token=token + "_" + BackgroundTaskState.get_full_name(),
             ),
             events=[],
             final=True,
@@ -2257,7 +2257,7 @@ async def test_background_task_no_block(mock_app: rx.App, token: str):
                     "dict_list": {},
                 }
             },
-            reflex_delta_token=token + "_" + BackgroundTaskState.get_full_name(),
+            client_token=token + "_" + BackgroundTaskState.get_full_name(),
         ),
         events=[],
         final=True,
@@ -2269,7 +2269,7 @@ async def test_background_task_no_block(mock_app: rx.App, token: str):
                     "computed_order": exp_order,
                 },
             },
-            reflex_delta_token=token,
+            client_token=token,
         ),
         events=[],
         final=True,