From f892a821f5f79e51ee33b89247d7bbb1a59890a1 Mon Sep 17 00:00:00 2001 From: Blake Blackshear Date: Tue, 6 Jul 2021 07:22:17 -0500 Subject: [PATCH] no need to worry about payload here --- frigate/mqtt.py | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/frigate/mqtt.py b/frigate/mqtt.py index dddbf4767..ee8aee6cb 100644 --- a/frigate/mqtt.py +++ b/frigate/mqtt.py @@ -90,12 +90,7 @@ def create_mqtt_client(config: FrigateConfig, camera_metrics): client.publish(state_topic, payload, retain=True) def on_restart_command(client, userdata, message): - payload = message.payload.decode() - if payload == "container": - logger.warning(f"Restart container received via mqtt") - restart_frigate() - else: - logger.warning(f"Received unsupported value at {message.topic}: {payload}") + restart_frigate() def on_connect(client, userdata, flags, rc): threading.current_thread().name = "mqtt" @@ -197,7 +192,7 @@ class MqttSocketRelay: json_message = json.loads(message.data.decode("utf-8")) json_message = { "topic": f"{self.topic_prefix}/{json_message['topic']}", - "payload": json_message["payload"], + "payload": json_message.get("payload"), "retain": json_message.get("retain", False), } except Exception as e: