Merge pull request #62 from konikoni428/fix/mqtt-sample-not-working

MQTT sample can't work properly
mochipon · Aug 1, 2022 · 4ca3826 · 4ca3826
2 parents e15fe11 + 0181b40
commit 4ca3826
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/example/mqtt2sesame/mqtt2sesame.py b/example/mqtt2sesame/mqtt2sesame.py
@@ -177,7 +177,7 @@ def onMQTTMessage(client, userdata, msg: MQTTMessage) -> None:
 
     if not isinstance(uuid, str):
         raise TypeError("Failed to parse the device uuid from topic")
-    if cmd not in ["LOCK, UNLOCK"]:
+    if cmd not in ["LOCK", "UNLOCK"]:
         raise TypeError("Failed to parse command: {}".format(cmd))
 
     if cmd == "LOCK" or cmd == "UNLOCK":
@@ -187,6 +187,8 @@ def onMQTTMessage(client, userdata, msg: MQTTMessage) -> None:
 async def runner():
     global mqtt_client, config, cmd_queue, connected_devices
 
+    cmd_queue = asyncio.Queue()
+
     lwt_topic = "{}/LWT".format(config["mqtt"]["topic_prefix"])
     mqtt_client.will_set(lwt_topic, payload="offline", qos=1, retain=True)
     mqtt_client.on_message = onMQTTMessage