diff --git a/modules/core/core.py b/modules/core/core.py index 60a6045..f61bb9e 100644 --- a/modules/core/core.py +++ b/modules/core/core.py @@ -224,9 +224,7 @@ class CraftBeerPi(ActorAPI, SensorAPI): def notify(self, headline, message, type="success", timeout=5000): self.beep() msg = {"id": str(uuid.uuid1()), "type": type, "headline": headline, "message": message, "timeout": timeout} - if timeout is None: - self.cache["messages"].append(msg) - self.emit("NOTIFY", msg) + self.emit_message(msg) def beep(self): if self.buzzer is not None: diff --git a/modules/notification/__init__.py b/modules/notification/__init__.py index 158beef..6276ef4 100644 --- a/modules/notification/__init__.py +++ b/modules/notification/__init__.py @@ -25,17 +25,16 @@ class NotificationView(FlaskView): return ('', 204) @cbpi.event("MESSAGE", async=True) -def messageEvent(message, **kwargs): +def messageEvent(message): """ React on message event. add the message to the cache and push the message to the clients :param message: the message :param kwargs: other parameter :return: None """ - - msg = {"id": len(cbpi.cache["messages"]), "type": "info", "message": message, "read": False} - cbpi.cache["messages"].append(msg) - cbpi.emit('MESSAGE', msg,) + if message["timeout"] is None: + cbpi.cache["messages"].append(message) + cbpi.emit("NOTIFY", message) @cbpi.initalizer(order=2) def init(cbpi):