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

webserver sio callback emits serialized value to frontend clients now

Browse Source
This commit is contained in:
Mose Müller 2023-11-16 09:13:37 +01:00
parent f5116607b9
commit 9820bda4b5
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/pydase/server/server.py
View File

@ -4,7 +4,7 @@ import os
import signal import signal
import threading import threading
from concurrent.futures import ThreadPoolExecutor from concurrent.futures import ThreadPoolExecutor
from enum import Enum from copy import deepcopy
from pathlib import Path from pathlib import Path
from types import FrameType from types import FrameType
from typing import Any, Optional, Protocol, TypedDict from typing import Any, Optional, Protocol, TypedDict
@ -13,9 +13,9 @@ import uvicorn
from rpyc import ForkingServer, ThreadedServer # type: ignore from rpyc import ForkingServer, ThreadedServer # type: ignore
from uvicorn.server import HANDLED_SIGNALS from uvicorn.server import HANDLED_SIGNALS
import pydase.units as u
from pydase import DataService from pydase import DataService
from pydase.data_service.state_manager import StateManager from pydase.data_service.state_manager import StateManager
from pydase.utils.serializer import dump, get_nested_dict_by_path
from pydase.version import __version__ from pydase.version import __version__
from .web_server import WebAPI from .web_server import WebAPI
@ -306,11 +306,13 @@ class Server:
# > File "/usr/lib64/python3.11/json/encoder.py", line 180, in default # > File "/usr/lib64/python3.11/json/encoder.py", line 180, in default
# > raise TypeError(f'Object of type {o.__class__.__name__} ' # > raise TypeError(f'Object of type {o.__class__.__name__} '
# > TypeError: Object of type list is not JSON serializable # > TypeError: Object of type list is not JSON serializable
notify_value = value full_access_path = ".".join([*parent_path.split(".")[:-1], name])
if isinstance(value, Enum): cached_value_dict = deepcopy(
notify_value = value.name get_nested_dict_by_path(self._state_manager.cache, full_access_path)
if isinstance(value, u.Quantity): )
notify_value = {"magnitude": value.m, "unit": str(value.u)} serialized_value = dump(value)
cached_value_dict["value"] = serialized_value["value"]
cached_value_dict["type"] = serialized_value["type"]
async def notify() -> None: async def notify() -> None:
try: try:
@ -320,7 +322,7 @@ class Server:
"data": { "data": {
"parent_path": parent_path, "parent_path": parent_path,
"name": name, "name": name,
"value": notify_value, "value": cached_value_dict,
} }
}, },
) )