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 = {}