From: Benjamin Braatz <bb@bbraatz.eu>
Date: Tue, 27 Jul 2021 03:38:51 +0000 (+0200)
Subject: Bugfix
X-Git-Tag: v0.3.0~30
X-Git-Url: http://git.graph-it.com/?a=commitdiff_plain;h=c85171f618a1889d904a9e28f67b8a37814ba1a4;p=graphit%2Fcontrolpi.git

Bugfix
---

diff --git a/controlpi/messagebus.py b/controlpi/messagebus.py
index d6b9cc8..a3299cf 100644
--- a/controlpi/messagebus.py
+++ b/controlpi/messagebus.py
@@ -1187,11 +1187,11 @@ class MessageBus:
                     except (IndexError, FileNotFoundError, json.decoder.JSONDecodeError):
                         pass
                     if conf == message['conf']:
-                        await self.bus.send(Message(self.name, {'event': 'unchanged'}))
+                        await self._queue.put(Message('', {'event': 'conf unchanged'}))
                     else:
                         with open(sys.argv[1], 'w') as conf_file:
                             json.dump(message['conf'], conf_file)
-                        await self.bus.send(Message(self.name, {'event': 'changed'}))
+                        await self._queue.put(Message('', {'event': 'conf changed'}))
             for client in self._recv_reg.get(message):
                 await self._callbacks[client](message)
             self._queue.task_done()