ITQC/pydase
24
0
Fork 0
mirror of https://github.com/tiqi-group/pydase.git synced 2025-04-22 01:00:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

removes processing of value from sio_callback (cached value is up-to-date already)

Browse Source
This commit is contained in:
Mose Müller 2024-03-05 13:54:24 +01:00
parent 8787cb0509
commit 7aacc21010
1 changed files with 1 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/pydase/server/web_server/sio_setup.py
View File

@ -9,7 +9,6 @@ from pydase.data_service.data_service_observer import DataServiceObserver
from pydase.data_service.state_manager import StateManager from pydase.data_service.state_manager import StateManager
from pydase.utils.helpers import get_object_attr_from_path_list from pydase.utils.helpers import get_object_attr_from_path_list
from pydase.utils.logging import SocketIOHandler from pydase.utils.logging import SocketIOHandler
from pydase.utils.serializer import dump
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -62,7 +61,7 @@ class RunMethodDict(TypedDict):
kwargs: dict[str, Any] kwargs: dict[str, Any]
def setup_sio_server( # noqa: C901 def setup_sio_server(
observer: DataServiceObserver, observer: DataServiceObserver,
enable_cors: bool, enable_cors: bool,
loop: asyncio.AbstractEventLoop, loop: asyncio.AbstractEventLoop,
@ -97,15 +96,6 @@ def setup_sio_server( # noqa: C901
full_access_path: str, value: Any, cached_value_dict: dict[str, Any] full_access_path: str, value: Any, cached_value_dict: dict[str, Any]
) -> None: ) -> None:
if cached_value_dict != {}: if cached_value_dict != {}:
serialized_value = dump(value)
if cached_value_dict["type"] != "method":
cached_value_dict["type"] = serialized_value["type"]
cached_value_dict["value"] = serialized_value["value"]
# Check if the serialized value contains an "enum" key, and if so, copy it
if "enum" in serialized_value:
cached_value_dict["enum"] = serialized_value["enum"]
async def notify() -> None: async def notify() -> None:
try: try: