administrator/frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2026-02-05 18:55:23 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Address feedback

Browse Source
This commit is contained in:
JP Verdejo 2023-07-02 17:21:07 -05:00
parent 0d3d78a695
commit 09bb8857b9
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
frigate/comms/dispatcher.py
View File

@ -83,9 +83,8 @@ class Dispatcher:
return return
elif topic == "restart": elif topic == "restart":
restart_frigate() restart_frigate()
elif "metadata" in topic: else:
# example /cam_name/metadata/dbfs payload=-55.23 self.publish(topic, payload, retain=False)
self.publish(topic, payload, retain=True)
def publish(self, topic: str, payload: Any, retain: bool = False) -> None: def publish(self, topic: str, payload: Any, retain: bool = False) -> None:
"""Handle publishing to communicators.""" """Handle publishing to communicators."""

1
frigate/comms/inter_process.py
View File

@ -15,6 +15,7 @@ class InterProcessCommunicator(Communicator):
self.stop_event: MpEvent = mp.Event() self.stop_event: MpEvent = mp.Event()
def publish(self, topic: str, payload: str, retain: bool) -> None: def publish(self, topic: str, payload: str, retain: bool) -> None:
"""There is no communication back to the processes."""
pass pass
def subscribe(self, receiver: Callable) -> None: def subscribe(self, receiver: Callable) -> None:

4
frigate/events/audio.py
View File

@ -197,10 +197,10 @@ class AudioEventMaintainer(threading.Thread):
dBFS = 20 * np.log10(np.abs(rms) / AUDIO_MAX_BIT_RANGE) dBFS = 20 * np.log10(np.abs(rms) / AUDIO_MAX_BIT_RANGE)
self.inter_process_communicator.queue.put( self.inter_process_communicator.queue.put(
(f"{self.config.name}/metadata/dBFS", float(dBFS)) (f"{self.config.name}/audio/dBFS", float(dBFS))
) )
self.inter_process_communicator.queue.put( self.inter_process_communicator.queue.put(
(f"{self.config.name}/metadata/rms", float(rms)) (f"{self.config.name}/audio/rms", float(rms))
) )
def handle_detection(self, label: str, score: float) -> None: def handle_detection(self, label: str, score: float) -> None: