mirror of
https://github.com/blakeblackshear/frigate.git
synced 2026-09-28 19:06:52 +03:00
Josh Hawkins
dd5ba8bd8e
`swap_runtime_config` rebound the stats emitter to the new config but not its `HardwareStats`, which kept polling hardware for the old config and applied camera updates to the discarded object. It now follows the swap along with its camera update subscriber.
65 lines
2.2 KiB
Python
65 lines
2.2 KiB
Python
"""Shared helpers for applying a freshly parsed config to the running app."""
|
|
|
|
from fastapi import FastAPI
|
|
|
|
from frigate.config import FrigateConfig
|
|
from frigate.config.camera.updater import (
|
|
CameraConfigUpdateEnum,
|
|
CameraConfigUpdateTopic,
|
|
)
|
|
|
|
|
|
def publish_camera_section_updates(
|
|
app: FastAPI, config: FrigateConfig, update_type: CameraConfigUpdateEnum
|
|
) -> None:
|
|
"""Broadcast every camera's re-resolved value for a global section.
|
|
|
|
Global sections are folded into each camera at parse time and the camera
|
|
copies are what workers read, so send them rather than leave a worker to
|
|
guess which cameras were inheriting.
|
|
"""
|
|
for camera_name, camera_config in config.cameras.items():
|
|
settings = getattr(camera_config, update_type.name, None)
|
|
|
|
if settings is None:
|
|
continue
|
|
|
|
app.config_publisher.publish_update(
|
|
CameraConfigUpdateTopic(update_type, camera_name), settings
|
|
)
|
|
|
|
|
|
def swap_runtime_config(app: FastAPI, config: FrigateConfig) -> None:
|
|
"""Point every long-lived collaborator at a newly parsed config object.
|
|
|
|
Both /api/config/set and camera deletion re-parse yaml into a fresh
|
|
FrigateConfig and must rebind the same set of references, or the API and
|
|
the dispatcher drift onto different objects (the API reports one camera
|
|
state while the dispatcher acts on another). Runtime toggle overrides are
|
|
re-layered last: the swap rebuilt every camera from yaml, so without this a
|
|
camera the user turned off would silently come back on.
|
|
"""
|
|
app.frigate_config = config
|
|
|
|
if app.config_holder is not None:
|
|
app.config_holder.set(config)
|
|
|
|
app.genai_manager.update_config(config)
|
|
|
|
if app.profile_manager is not None:
|
|
app.profile_manager.update_config(config)
|
|
|
|
if app.stats_emitter is not None:
|
|
app.stats_emitter.config = config
|
|
app.stats_emitter.hardware_stats.set_config(config)
|
|
|
|
if app.dispatcher is not None:
|
|
app.dispatcher.config = config
|
|
|
|
for comm in app.dispatcher.comms:
|
|
comm.config = config
|
|
|
|
# workers still hold the live toggle values, so correct only the
|
|
# config object here rather than re-broadcasting every override
|
|
app.dispatcher.reapply_runtime_state_to_config()
|