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

updates sio_setup to not expect DataService in the parent path

Browse Source
This commit is contained in:
Mose Müller 2023-12-21 10:03:40 +01:00
parent 8e3a1694ce
commit 805e270107
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -156,8 +156,8 @@ def setup_sio_events(sio: socketio.AsyncServer, state_manager: StateManager) ->
@sio.event @sio.event
def set_attribute(sid: str, data: UpdateDict) -> Any: def set_attribute(sid: str, data: UpdateDict) -> Any:
logger.debug("Received frontend update: %s", data) logger.debug("Received frontend update: %s", data)
path_list = [*data["parent_path"].split("."), data["name"]] parent_path = data["parent_path"].split(".")
path_list.remove("DataService") # always at the start, does not do anything path_list = [element for element in parent_path if element] + [data["name"]]
path = ".".join(path_list) path = ".".join(path_list)
return state_manager.set_service_attribute_value_by_path( return state_manager.set_service_attribute_value_by_path(
path=path, value=data["value"] path=path, value=data["value"]
@ -166,8 +166,8 @@ def setup_sio_events(sio: socketio.AsyncServer, state_manager: StateManager) ->
@sio.event @sio.event
def run_method(sid: str, data: RunMethodDict) -> Any: def run_method(sid: str, data: RunMethodDict) -> Any:
logger.debug("Running method: %s", data) logger.debug("Running method: %s", data)
path_list = [*data["parent_path"].split("."), data["name"]] parent_path = data["parent_path"].split(".")
path_list.remove("DataService") # always at the start, does not do anything path_list = [element for element in parent_path if element] + [data["name"]]
method = get_object_attr_from_path_list(state_manager.service, path_list) method = get_object_attr_from_path_list(state_manager.service, path_list)
return process_callable_attribute(method, data["kwargs"]) return process_callable_attribute(method, data["kwargs"])
@ -179,7 +179,6 @@ def setup_sio_events(sio: socketio.AsyncServer, state_manager: StateManager) ->
data["config_option"], data["config_option"],
data["value"], data["value"],
) )
path_list.pop(0) # remove first entry (specifies root object, not needed)
def setup_logging_handler(sio: socketio.AsyncServer) -> None: def setup_logging_handler(sio: socketio.AsyncServer) -> None: