administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2025-12-07 22:05:44 +03:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

add zmq topic

Browse Source
This commit is contained in:
Josh Hawkins 2025-09-26 16:57:54 -05:00
parent 6ba318b297
commit 250565eff6
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
frigate/comms/recordings_updater.py
View File

@ -2,6 +2,7 @@
import logging import logging
from enum import Enum from enum import Enum
from typing import Any
from .zmq_proxy import Publisher, Subscriber from .zmq_proxy import Publisher, Subscriber
@ -11,6 +12,7 @@ logger = logging.getLogger(__name__)
class RecordingsDataTypeEnum(str, Enum): class RecordingsDataTypeEnum(str, Enum):
all = "" all = ""
recordings_available_through = "recordings_available_through" recordings_available_through = "recordings_available_through"
latest_valid_segment = "latest_valid_segment"
class RecordingsDataPublisher(Publisher[tuple[str, float]]): class RecordingsDataPublisher(Publisher[tuple[str, float]]):
@ -18,10 +20,10 @@ class RecordingsDataPublisher(Publisher[tuple[str, float]]):
topic_base = "recordings/" topic_base = "recordings/"
def __init__(self, topic: RecordingsDataTypeEnum) -> None: def __init__(self) -> None:
super().__init__(topic.value) super().__init__()
def publish(self, payload: tuple[str, float], sub_topic: str = "") -> None: def publish(self, payload: Any, sub_topic: str = "") -> None:
super().publish(payload, sub_topic) super().publish(payload, sub_topic)
@ -32,3 +34,11 @@ class RecordingsDataSubscriber(Subscriber):
def __init__(self, topic: RecordingsDataTypeEnum) -> None: def __init__(self, topic: RecordingsDataTypeEnum) -> None:
super().__init__(topic.value) super().__init__(topic.value)
def _return_object(
self, topic: str, payload: tuple | None
) -> tuple[str, Any] | tuple[None, None]:
if payload is None:
return (None, None)
return (topic, payload)