From 874955a88074d1b3f0669e61be08ebee0aaa7254 Mon Sep 17 00:00:00 2001 From: Nicolas Mowen Date: Fri, 1 Aug 2025 12:22:17 -0600 Subject: [PATCH] Add review item data transmission --- frigate/comms/review_updater.py | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 frigate/comms/review_updater.py diff --git a/frigate/comms/review_updater.py b/frigate/comms/review_updater.py new file mode 100644 index 000000000..a7d441bc6 --- /dev/null +++ b/frigate/comms/review_updater.py @@ -0,0 +1,28 @@ +"""Facilitates communication between processes.""" + +import logging + +from .zmq_proxy import Publisher, Subscriber + +logger = logging.getLogger(__name__) + + +class RecordingsDataPublisher(Publisher[tuple[str, float]]): + """Publishes review item data.""" + + topic_base = "review/" + + def __init__(self, topic: str) -> None: + super().__init__(topic) + + def publish(self, payload: tuple[str, float], sub_topic: str = "") -> None: + super().publish(payload, sub_topic) + + +class RecordingsDataSubscriber(Subscriber): + """Receives review item data.""" + + topic_base = "review/" + + def __init__(self, topic: str) -> None: + super().__init__(topic) \ No newline at end of file