feat(core): add _type field to the serialized immutable instances

Author: sassanh

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## Version 0.16.1
+
+- feat(core): add `_type` field to the serialized immutable instances
+
 ## Version 0.16.0
 
 - feat(core): add blocking `wait_for_event_handlers` method to `Store` to wait for all event handlers to finish

poetry.lock

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "python-redux"
-version = "0.16.0"
+version = "0.16.1"
 description = "Redux implementation for Python"
 authors = ["Sassan Haradji <sassanh@gmail.com>"]
 license = "Apache-2.0"
@@ -14,14 +14,16 @@ packages = [{ include = "redux" }, { include = "redux_pytest" }]
 python = "^3.11"
 python-immutable = "^1.1.1"
 python-strtobool = "^1.0.0"
+pyright = "^1.1.378"
+ruff = "^0.6.3"
 
 [tool.poetry.group.dev]
 optional = true
 
 [tool.poetry.group.dev.dependencies]
 poethepoet = "^0.24.4"
 pyright = "^1.1.376"
-ruff = "^0.5.7"
+ruff = "^0.6.0"
 pytest = "^8.1.1"
 pytest-cov = "^4.1.0"
 pytest-timeout = "^2.3.1"

pyproject.toml

@@ -37,7 +37,7 @@ def _serialize_dataclass_to_dict(
         cls: type[SerializationMixin],
         obj: Immutable,
     ) -> dict[str, Any]:
-        result = {}
+        result: dict[str, object] = {'_type': obj.__class__.__name__}
         for field in dataclasses.fields(obj):
             value = cls.serialize_value(getattr(obj, field.name))
             result[field.name] = value

redux/serialization_mixin.py

@@ -25,7 +25,7 @@ def create_task(self: LoopThread, coro: Coroutine) -> None:
         self.loop.call_soon_threadsafe(self.loop.create_task, coro)
 
 
-@pytest.fixture()
+@pytest.fixture
 def event_loop() -> LoopThread:
     loop_thread = LoopThread()
     loop_thread.start()

redux_pytest/fixtures/event_loop.py

@@ -39,7 +39,7 @@ def monitor(self: StoreMonitor, store: Store) -> None:
         self.store.register_event_middleware(self._event_middleware)
 
 
-@pytest.fixture()
+@pytest.fixture
 def store_monitor(store: Store, mocker: MockerFixture) -> StoreMonitor:
     """Fixture to check if an action was dispatched."""
     monitor = StoreMonitor(mocker)

redux_pytest/fixtures/monitor.py

@@ -145,13 +145,13 @@ def close(self: StoreSnapshot[State]) -> None:
             assert not json_path.exists(), f'Snapshot {filename} not taken'
 
 
-@pytest.fixture()
+@pytest.fixture
 def snapshot_prefix() -> str | None:
     """Return the prefix for the snapshots."""
     return None
 
 
-@pytest.fixture()
+@pytest.fixture
 def store_snapshot(
     request: SubRequest,
     store: Store,

redux_pytest/fixtures/snapshot.py

@@ -10,14 +10,14 @@
     from redux.main import Store
 
 
-@pytest.fixture()
-def store() -> Store:  # noqa: PT004 # pragma: no cover
+@pytest.fixture
+def store() -> Store:  # pragma: no cover
     """Provide current store (this is a placeholder returning None)."""
     msg = 'This fixture should be overridden.'
     raise NotImplementedError(msg)
 
 
-@pytest.fixture()
+@pytest.fixture
 def needs_finish(store: Store) -> Generator:
     """Dispatch a finish action after the test."""
     yield None

redux_pytest/fixtures/store.py

@@ -157,7 +157,7 @@ def wrapper(*args: WaitForArgs.args, **kwargs: WaitForArgs.kwargs) -> None:
         return decorator(check) if check else decorator
 
 
-@pytest.fixture()
+@pytest.fixture
 def wait_for() -> Generator[WaitFor, None, None]:
     """Provide `wait_for` decorator."""
     context = WaitFor()

redux_pytest/fixtures/wait_for.py

@@ -1,4 +1,5 @@
 // store-000
 {
+  "_type": "StateType",
   "value": 0
 }