From cd067daf16046d24d20f70cce4a44a24457c294a Mon Sep 17 00:00:00 2001 From: Nick Mowen Date: Tue, 22 Nov 2022 13:53:30 -0700 Subject: [PATCH] Remove references to mqtt in dispatcher --- frigate/communication/dispatcher.py | 6 +++--- frigate/communication/mqtt.py | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/frigate/communication/dispatcher.py b/frigate/communication/dispatcher.py index 381b4c508..ae8e738b9 100644 --- a/frigate/communication/dispatcher.py +++ b/frigate/communication/dispatcher.py @@ -104,7 +104,7 @@ class Dispatcher: self.publish(f"{camera_name}/motion/state", payload, retain=True) elif payload == "OFF": if self.camera_metrics[camera_name]["detection_enabled"].value: - logger.info(f"Turning off detection for {camera_name} via mqtt") + logger.info(f"Turning off detection for {camera_name}") self.camera_metrics[camera_name]["detection_enabled"].value = False detect_settings.enabled = False @@ -114,7 +114,7 @@ class Dispatcher: """Callback for motion topic.""" if payload == "ON": if not self.camera_metrics[camera_name]["motion_enabled"].value: - logger.info(f"Turning on motion for {camera_name} via mqtt") + logger.info(f"Turning on motion for {camera_name}") self.camera_metrics[camera_name]["motion_enabled"].value = True elif payload == "OFF": if self.camera_metrics[camera_name]["detection_enabled"].value: @@ -124,7 +124,7 @@ class Dispatcher: return if self.camera_metrics[camera_name]["motion_enabled"].value: - logger.info(f"Turning off motion for {camera_name} via mqtt") + logger.info(f"Turning off motion for {camera_name}") self.camera_metrics[camera_name]["motion_enabled"].value = False self.publish(f"{camera_name}/motion/state", payload, retain=True) diff --git a/frigate/communication/mqtt.py b/frigate/communication/mqtt.py index 1bd676058..ed2790598 100644 --- a/frigate/communication/mqtt.py +++ b/frigate/communication/mqtt.py @@ -66,7 +66,7 @@ class MqttClient(Communicator): return self.client.publish( - f"{self.mqtt_config.topic_prefix}/topic", payload, retain=retain + f"{self.mqtt_config.topic_prefix}/{topic}", payload, retain=retain ) def _set_initial_topics(self) -> None: