From 47ac77dbb0df088b1d6d6e0e69fd3c26682f8b83 Mon Sep 17 00:00:00 2001 From: Blake Blackshear Date: Sat, 16 Jan 2021 10:22:24 -0600 Subject: [PATCH] mqtt tweaks for switches --- frigate/mqtt.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/frigate/mqtt.py b/frigate/mqtt.py index 98b027972..5f4a3a2e0 100644 --- a/frigate/mqtt.py +++ b/frigate/mqtt.py @@ -107,7 +107,7 @@ def create_mqtt_client(config: FrigateConfig, camera_metrics): for name in config.cameras.keys(): client.message_callback_add(f"{mqtt_config.topic_prefix}/{name}/clips/#", on_clips_command) client.message_callback_add(f"{mqtt_config.topic_prefix}/{name}/snapshots/#", on_snapshots_command) - client.message_callback_add(f"{mqtt_config.topic_prefix}/{name}/detection/#", on_detect_command) + client.message_callback_add(f"{mqtt_config.topic_prefix}/{name}/detect/#", on_detect_command) if not mqtt_config.user is None: client.username_pw_set(mqtt_config.user, password=mqtt_config.password) @@ -118,8 +118,14 @@ def create_mqtt_client(config: FrigateConfig, camera_metrics): raise client.loop_start() + + for name in config.cameras.keys(): + client.publish(f"{mqtt_config.topic_prefix}/{name}/clips/state", 'ON' if config.cameras[name].clips.enabled else 'OFF', retain=True) + client.publish(f"{mqtt_config.topic_prefix}/{name}/snapshots/state", 'ON' if config.cameras[name].clips.enabled else 'OFF', retain=True) + client.publish(f"{mqtt_config.topic_prefix}/{name}/detect/state", 'ON' if config.cameras[name].clips.enabled else 'OFF', retain=True) + client.subscribe(f"{mqtt_config.topic_prefix}/+/clips/#") client.subscribe(f"{mqtt_config.topic_prefix}/+/snapshots/#") - client.subscribe(f"{mqtt_config.topic_prefix}/+/detection/#") + client.subscribe(f"{mqtt_config.topic_prefix}/+/detect/#") return client