blakeblackshear.frigate/frigate/record/record.py

"""Run recording maintainer and cleanup."""

import logging
import multiprocessing as mp
import signal
import threading
from types import FrameType
from typing import Optional

from playhouse.sqliteq import SqliteQueueDatabase
from setproctitle import setproctitle

from frigate.config import FrigateConfig
from frigate.models import Event, Recordings, RecordingsToDelete, Timeline
from frigate.record.cleanup import RecordingCleanup
from frigate.record.maintainer import RecordingMaintainer
from frigate.types import FeatureMetricsTypes
from frigate.util.services import listen

logger = logging.getLogger(__name__)


def manage_recordings(
    config: FrigateConfig,
    object_recordings_info_queue: mp.Queue,
    audio_recordings_info_queue: mp.Queue,
    process_info: dict[str, FeatureMetricsTypes],
) -> None:
    stop_event = mp.Event()

    def receiveSignal(signalNumber: int, frame: Optional[FrameType]) -> None:
        stop_event.set()

    signal.signal(signal.SIGTERM, receiveSignal)
    signal.signal(signal.SIGINT, receiveSignal)

    threading.current_thread().name = "process:recording_manager"
    setproctitle("frigate.recording_manager")
    listen()

    db = SqliteQueueDatabase(
        config.database.path,
        pragmas={
            "auto_vacuum": "FULL",  # Does not defragment database
            "cache_size": -512 * 1000,  # 512MB of cache
            "synchronous": "NORMAL",  # Safe when using WAL https://www.sqlite.org/pragma.html#pragma_synchronous
        },
        timeout=60,
    )
    models = [Event, Recordings, Timeline, RecordingsToDelete]
    db.bind(models)

    maintainer = RecordingMaintainer(
        config,
        object_recordings_info_queue,
        audio_recordings_info_queue,
        process_info,
        stop_event,
    )
    maintainer.start()

    cleanup = RecordingCleanup(config, stop_event)
    cleanup.start()