Clear ongoing reviews on startup (blakeblackshear#11097)

* Add topic to clear ongoing review segments

* Clear ongoing review items on startup

frigate/comms/dispatcher.py

@@ -1,12 +1,14 @@
 """Handle communication between Frigate and other applications."""
 
+import datetime
 import logging
 from abc import ABC, abstractmethod
 from typing import Any, Callable, Optional
 
 from frigate.comms.config_updater import ConfigPublisher
 from frigate.config import BirdseyeModeEnum, FrigateConfig
 from frigate.const import (
+ CLEAR_ONGOING_REVIEW_SEGMENTS,
  INSERT_MANY_RECORDINGS,
  INSERT_PREVIEW,
  REQUEST_REGION_GRID,
@@ -116,6 +118,10 @@ def _receive(self, topic: str, payload: str) -> Optional[Any]:
  )
  .execute()
  )
+ elif topic == CLEAR_ONGOING_REVIEW_SEGMENTS:
+ ReviewSegment.update(end_time=datetime.datetime.now().timestamp()).where(
+ ReviewSegment.end_time == None
+ ).execute()
  else:
  self.publish(topic, payload, retain=False)
 

frigate/const.py

@@ -79,6 +79,7 @@
 INSERT_PREVIEW = "insert_preview"
 REQUEST_REGION_GRID = "request_region_grid"
 UPSERT_REVIEW_SEGMENT = "upsert_review_segment"
+CLEAR_ONGOING_REVIEW_SEGMENTS = "clear_ongoing_review_segments"
 
 # Autotracking
 

frigate/review/maintainer.py

@@ -19,7 +19,12 @@
 from frigate.comms.detections_updater import DetectionSubscriber, DetectionTypeEnum
 from frigate.comms.inter_process import InterProcessRequestor
 from frigate.config import CameraConfig, FrigateConfig
-from frigate.const import ALL_ATTRIBUTE_LABELS, CLIPS_DIR, UPSERT_REVIEW_SEGMENT
+from frigate.const import (
+ ALL_ATTRIBUTE_LABELS,
+ CLEAR_ONGOING_REVIEW_SEGMENTS,
+ CLIPS_DIR,
+ UPSERT_REVIEW_SEGMENT,
+)
 from frigate.events.external import ManualEventState
 from frigate.models import ReviewSegment
 from frigate.object_processing import TrackedObject
@@ -146,6 +151,9 @@ def __init__(self, config: FrigateConfig, stop_event: MpEvent):
 
  self.stop_event = stop_event
 
+ # clear ongoing review segments from last instance
+ self.requestor.send_data(CLEAR_ONGOING_REVIEW_SEGMENTS, "")
+
  def new_segment(
  self,
  segment: PendingReviewSegment,