add change type to events topic

#476
This commit is contained in:
Blake Blackshear 2021-01-15 22:14:15 -06:00
parent 1be91ed3f2
commit f1c3087775

View File

@ -430,7 +430,7 @@ class TrackedObjectProcessor(threading.Thread):
def update(camera, obj: TrackedObject, current_frame_time): def update(camera, obj: TrackedObject, current_frame_time):
after = obj.to_dict() after = obj.to_dict()
message = { 'before': obj.previous, 'after': after } message = { 'before': obj.previous, 'after': after, 'type': 'new' if obj.previous['false_positive'] else 'update' }
self.client.publish(f"{self.topic_prefix}/events", json.dumps(message), retain=False) self.client.publish(f"{self.topic_prefix}/events", json.dumps(message), retain=False)
obj.previous = after obj.previous = after
@ -439,7 +439,7 @@ class TrackedObjectProcessor(threading.Thread):
event_data = obj.to_dict(include_thumbnail=True) event_data = obj.to_dict(include_thumbnail=True)
event_data['has_snapshot'] = False event_data['has_snapshot'] = False
if not obj.false_positive: if not obj.false_positive:
message = { 'before': obj.previous, 'after': obj.to_dict() } message = { 'before': obj.previous, 'after': obj.to_dict(), 'type': 'end' }
self.client.publish(f"{self.topic_prefix}/events", json.dumps(message), retain=False) self.client.publish(f"{self.topic_prefix}/events", json.dumps(message), retain=False)
# write snapshot to disk if enabled # write snapshot to disk if enabled
if snapshot_config.enabled: if snapshot_config.enabled: