From 2a4d14bd655df29c81c6888856148b603e3b1e6b Mon Sep 17 00:00:00 2001 From: "Denis V. Dedkov" Date: Tue, 25 Apr 2023 12:20:41 +0200 Subject: [PATCH] Fixed bug with broadcast --- routes.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/routes.py b/routes.py index 39e6d63..261b3ce 100644 --- a/routes.py +++ b/routes.py @@ -35,7 +35,7 @@ class Routes(): data = self.__get_data(event) if name and data: self.__storage(name).create(data) - await broadcast(websocket, self.__get_event(name, "created", data)) + await self._broadcast(websocket, self.__get_event(name, "created", data)) async def _get_entity(self, websocket, event): name = self.__get_entity(event) @@ -48,13 +48,13 @@ class Routes(): data = self.__get_data(event) if name and data: self.__storage(name).update(data) - await broadcast(websocket, self.__get_event(name, "modified", data)) + await self._broadcast(websocket, self.__get_event(name, "modified", data)) async def _del_entity(self, websocket, event): name = self.__get_entity(event) entity_id = self.__get_data(event).get("id", None) if self.__storage(name).delete(entity_id): - await broadcast(websocket, self.__get_event(name, "deleted", entity_id )) + await self._broadcast(websocket, self.__get_event(name, "deleted", entity_id )) async def _describe(self, websocket, event): data = {}