fix(mqtt): add condition in case payload is not in the MQTT data event

related to #82
xaviml · Jun 7, 2020 · f9f42f2 · f9f42f2
1 parent 2e5b9cf
commit f9f42f2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/apps/controllerx/core/integration/mqtt.py b/apps/controllerx/core/integration/mqtt.py
@@ -22,4 +22,6 @@ def listen_changes(self, controller_id: str) -> None:
         )
 
     async def event_callback(self, event_name: str, data: dict, kwargs: dict) -> None:
-        await self.controller.handle_action(data["payload"])
+        self.controller.log(f"MQTT data event: {data}", level="DEBUG")
+        if "payload" in data:
+            await self.controller.handle_action(data["payload"])