ded/beerlog-srv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed bug with broadcast

Browse Source
This commit is contained in:
Denis V. Dedkov
2023-04-25 12:20:41 +02:00
parent 18b95fa62f
commit 2a4d14bd65
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
routes.py
View File

@@ -35,7 +35,7 @@ class Routes():
data = self.__get_data(event) data = self.__get_data(event)
if name and data: if name and data:
self.__storage(name).create(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): async def _get_entity(self, websocket, event):
name = self.__get_entity(event) name = self.__get_entity(event)
@@ -48,13 +48,13 @@ class Routes():
data = self.__get_data(event) data = self.__get_data(event)
if name and data: if name and data:
self.__storage(name).update(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): async def _del_entity(self, websocket, event):
name = self.__get_entity(event) name = self.__get_entity(event)
entity_id = self.__get_data(event).get("id", None) entity_id = self.__get_data(event).get("id", None)
if self.__storage(name).delete(entity_id): 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): async def _describe(self, websocket, event):
data = {} data = {}