ITQC/pydase
24
0
Fork 0
mirror of https://github.com/tiqi-group/pydase.git synced 2025-07-06 18:14:47 +02:00
Code Issues Packages Projects Releases Wiki Activity

StateManager: replaces _data_service_cache with cache_manager

Browse Source 
- _data_service_cache -> cache_manager
- removes cache property
- replaces get_nested_dict_by_path with cache_manager.get_value_dict_from_cache where possible
This commit is contained in:
Mose Müller
2024-07-29 13:49:12 +02:00
parent ad0f9420d9
commit 817afc610a
5 changed files with 20 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/pydase/data_service/data_service_observer.py
View File

@ -37,7 +37,7 @@ class DataServiceObserver(PropertyObserver):
try:
cached_value_dict = deepcopy(
self.state_manager._data_service_cache.get_value_dict_from_cache(
self.state_manager.cache_manager.get_value_dict_from_cache(
full_access_path
)
)
@ -60,7 +60,7 @@ class DataServiceObserver(PropertyObserver):
self._update_cache_value(full_access_path, value, cached_value_dict)
cached_value_dict = deepcopy(
self.state_manager._data_service_cache.get_value_dict_from_cache(
self.state_manager.cache_manager.get_value_dict_from_cache(
full_access_path
)
)
@ -93,7 +93,7 @@ class DataServiceObserver(PropertyObserver):
value_dict["type"],
cached_value_dict["type"],
)
self.state_manager._data_service_cache.update_cache(
self.state_manager.cache_manager.update_cache(
full_access_path,
value,
)

23
src/pydase/data_service/state_manager.py
View File

@ -113,19 +113,12 @@ class StateManager:
self.filename = filename
self.service = service
self._data_service_cache = DataServiceCache(self.service)
@property
def cache(self) -> SerializedObject:
"""Returns the cached DataService state."""
return self._data_service_cache.cache
self.cache_manager = DataServiceCache(self.service)
@property
def cache_value(self) -> dict[str, SerializedObject]:
"""Returns the "value" value of the DataService serialization."""
return cast(
dict[str, SerializedObject], self._data_service_cache.cache["value"]
)
return cast(dict[str, SerializedObject], self.cache_manager.cache["value"])
def save_state(self) -> None:
"""
@ -158,8 +151,8 @@ class StateManager:
if self.__is_loadable_state_attribute(path):
nested_json_dict = get_nested_dict_by_path(json_dict, path)
try:
nested_class_dict = (
self._data_service_cache.get_value_dict_from_cache(path)
nested_class_dict = self.cache_manager.get_value_dict_from_cache(
path
)
except (SerializationPathError, KeyError):
nested_class_dict = {
@ -211,7 +204,7 @@ class StateManager:
value: The new value to set for the attribute.
"""
current_value_dict = get_nested_dict_by_path(self.cache_value, path)
current_value_dict = self.cache_manager.get_value_dict_from_cache(path)
# This will also filter out methods as they are 'read-only'
if current_value_dict["readonly"]:
@ -249,7 +242,7 @@ class StateManager:
path_parts = parse_full_access_path(path)
target_obj = get_object_by_path_parts(self.service, path_parts[:-1])
attr_cache_type = get_nested_dict_by_path(self.cache_value, path)["type"]
attr_cache_type = self.cache_manager.get_value_dict_from_cache(path)["type"]
# De-serialize the value
if attr_cache_type in ("ColouredEnum", "Enum"):
@ -296,8 +289,8 @@ class StateManager:
return has_decorator
try:
cached_serialization_dict = get_nested_dict_by_path(
self.cache_value, full_access_path
cached_serialization_dict = self.cache_manager.get_value_dict_from_cache(
full_access_path
)
if cached_serialization_dict["value"] == "method":