Push 'connection opened' message to graph.
authorBenjamin Braatz <benjamin.braatz@graph-it.com>
Wed, 20 Oct 2021 14:26:23 +0000 (16:26 +0200)
committerBenjamin Braatz <benjamin.braatz@graph-it.com>
Wed, 20 Oct 2021 14:26:23 +0000 (16:26 +0200)
controlpi_plugins/graph.py

index b10d33e312d634e7f881eb0ecdb60407ec706104..9071f8463508bc52c21acc2fd8fa218ae4c5c2d8 100644 (file)
@@ -111,4 +111,13 @@ class Graph(BasePlugin):
         self._coroot_guid = await self._call('attributsknoten',
                                              ['coroot_name',
                                               self.conf['name']])
+        comessage_guid = await self._call('erzeuge', ['comessage'])
+        if comessage_guid:
+            await self._call('verknuepfe', [comessage_guid,
+                                            self._coroot_guid])
+            messages = [Message(self.name, {'event': 'connection opened'})]
+            await self._call('setze', [comessage_guid, 'comessage_json',
+                                       json.dumps(messages)])
+            await self._call('setze', [comessage_guid, 'comessage_ready',
+                                       True])
         await self._close()