administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-03 09:45:22 +03:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Remove references to mqtt in dispatcher

Browse Source
This commit is contained in:
Nick Mowen 2022-11-22 13:53:30 -07:00
parent 2306b73174
commit cd067daf16
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
frigate/communication/dispatcher.py
View File

@ -104,7 +104,7 @@ class Dispatcher:
self.publish(f"{camera_name}/motion/state", payload, retain=True) self.publish(f"{camera_name}/motion/state", payload, retain=True)
elif payload == "OFF": elif payload == "OFF":
if self.camera_metrics[camera_name]["detection_enabled"].value: 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 self.camera_metrics[camera_name]["detection_enabled"].value = False
detect_settings.enabled = False detect_settings.enabled = False
@ -114,7 +114,7 @@ class Dispatcher:
"""Callback for motion topic.""" """Callback for motion topic."""
if payload == "ON": if payload == "ON":
if not self.camera_metrics[camera_name]["motion_enabled"].value: 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 self.camera_metrics[camera_name]["motion_enabled"].value = True
elif payload == "OFF": elif payload == "OFF":
if self.camera_metrics[camera_name]["detection_enabled"].value: if self.camera_metrics[camera_name]["detection_enabled"].value:
@ -124,7 +124,7 @@ class Dispatcher:
return return
if self.camera_metrics[camera_name]["motion_enabled"].value: 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.camera_metrics[camera_name]["motion_enabled"].value = False
self.publish(f"{camera_name}/motion/state", payload, retain=True) self.publish(f"{camera_name}/motion/state", payload, retain=True)

2
frigate/communication/mqtt.py
View File

@ -66,7 +66,7 @@ class MqttClient(Communicator):
return return
self.client.publish( 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: def _set_initial_topics(self) -> None: