Mirrors/blakeblackshear.frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2024-11-21 19:07:46 +01:00
Code Issues Projects Releases Wiki Activity

comments

Browse Source
This commit is contained in:
blakeblackshear 2019-02-17 10:36:09 -06:00
parent 2b0ebfa354
commit a84f88c5a5
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
detect_objects.py
View File

@ -145,11 +145,13 @@ class MqttPublisher(threading.Thread):
if obj['name'] in self.object_classes: if obj['name'] in self.object_classes:
payload[obj['name']].append(obj) payload[obj['name']].append(obj)
# send message for objects
new_payload = json.dumps(payload, sort_keys=True) new_payload = json.dumps(payload, sort_keys=True)
if new_payload != last_sent_payload: if new_payload != last_sent_payload:
last_sent_payload = new_payload last_sent_payload = new_payload
self.client.publish(self.topic_prefix+'/objects', new_payload, retain=False) self.client.publish(self.topic_prefix+'/objects', new_payload, retain=False)
# send message for motion
motion_status = 'OFF' motion_status = 'OFF'
if any(obj.value == 1 for obj in self.motion_flags): if any(obj.value == 1 for obj in self.motion_flags):
motion_status = 'ON' motion_status = 'ON'
@ -157,7 +159,6 @@ class MqttPublisher(threading.Thread):
if motion_status != last_motion: if motion_status != last_motion:
last_motion = motion_status last_motion = motion_status
self.client.publish(self.topic_prefix+'/motion', motion_status, retain=False) self.client.publish(self.topic_prefix+'/motion', motion_status, retain=False)
time.sleep(0.1) time.sleep(0.1)