cleanup

Author: benedikt-bartscher

packages/reflex-base/src/reflex_base/utils/format.py

@@ -685,8 +685,9 @@ def orjson_dumps(obj: Any, **kwargs) -> str:
     """Serialize obj to a JSON string, using orjson when available.
 
     Translates common json.dumps kwargs (indent, sort_keys) into orjson
-    option flags.  Falls back to stdlib json if orjson is not installed,
-    an unsupported kwarg is passed, or orjson raises TypeError.
+    option flags.  Falls back to ``json_dumps`` (which has the
+    ``serializers.serialize`` default) if orjson is not installed, an
+    unsupported kwarg is passed, or orjson raises TypeError.
 
     Args:
         obj: The object to serialize.
@@ -698,7 +699,7 @@ def orjson_dumps(obj: Any, **kwargs) -> str:
     try:
         import orjson  # pyright: ignore[reportMissingImports]
     except ImportError:
-        return json.dumps(obj, **kwargs)
+        return json_dumps(obj, **kwargs)
 
     option = 0
     if kwargs.pop("indent", None):
@@ -709,13 +710,14 @@ def orjson_dumps(obj: Any, **kwargs) -> str:
 
     if kwargs:
         # Fall back to stdlib json for unsupported kwargs.
-        return json.dumps(obj, **kwargs)
+        return json_dumps(obj, **kwargs)
 
     try:
         return orjson.dumps(obj, option=option or None).decode()
     except TypeError:
-        # Fallback for types orjson can't handle (e.g. int > 64-bit).
-        return json.dumps(obj)
+        # Fallback for types orjson can't handle (e.g. int > 64-bit, or
+        # custom types). ``json_dumps`` carries the serializer default.
+        return json_dumps(obj)
 
 
 def orjson_loads(data: str | bytes) -> Any:

packages/reflex-base/src/reflex_base/utils/pyi_generator.py

@@ -1763,7 +1763,7 @@ def scan_all(
 
                 pyi_hashes_file = pyi_hashes_parent / PYI_HASHES
                 if pyi_hashes_file.exists():
-                    pyi_hashes = orjson_loads(pyi_hashes_file.read_text())
+                    pyi_hashes = orjson_loads(pyi_hashes_file.read_bytes())
                     for file_path, hashed_content in zip(
                         file_paths, hashes, strict=False
                     ):

reflex/utils/prerequisites.py

@@ -113,7 +113,7 @@ def get_or_set_last_reflex_version_check_datetime():
     if not reflex_json_file.exists():
         return None
     # Open and read the file
-    data = orjson_loads(reflex_json_file.read_text())
+    data = orjson_loads(reflex_json_file.read_bytes())
     last_version_check_datetime = data.get("last_version_check_datetime")
     if not last_version_check_datetime:
         data.update({"last_version_check_datetime": str(datetime.now())})
@@ -496,7 +496,7 @@ def get_project_hash(raise_on_fail: bool = False) -> int | None:
     json_file = get_web_dir() / constants.Reflex.JSON
     if not json_file.exists() and not raise_on_fail:
         return None
-    data = orjson_loads(json_file.read_text())
+    data = orjson_loads(json_file.read_bytes())
     return data.get("project_hash")
 
 
@@ -566,7 +566,7 @@ def _is_app_compiled_with_same_reflex_version() -> bool:
     json_file = get_web_dir() / constants.Reflex.JSON
     if not json_file.exists():
         return False
-    app_version = orjson_loads(json_file.read_text()).get("version")
+    app_version = orjson_loads(json_file.read_bytes()).get("version")
     return app_version == constants.Reflex.VERSION
 
 

reflex/utils/telemetry.py

@@ -111,7 +111,9 @@ def get_cpu_info() -> CpuInfo | None:
         The CPU info.
     """
     cpu_info_file = environment.REFLEX_DIR.get() / "cpu_info.json"
-    if cpu_info_file.exists() and (cpu_info := orjson_loads(cpu_info_file.read_text())):
+    if cpu_info_file.exists() and (
+        cpu_info := orjson_loads(cpu_info_file.read_bytes())
+    ):
         return CpuInfo(**cpu_info)
     cpu_info = _retrieve_cpu_info()
     if cpu_info: