mirror of
https://github.com/blakeblackshear/frigate.git
synced 2026-01-22 20:18:30 +03:00
Re-organize recordings apis
This commit is contained in:
Nicolas Mowen
parent
33e042b4ca
commit
4fc323a1f8
@ -8,9 +8,8 @@ import os
|
|||||||
import subprocess as sp
|
import subprocess as sp
|
||||||
import time
|
import time
|
||||||
from datetime import datetime, timedelta, timezone
|
from datetime import datetime, timedelta, timezone
|
||||||
from functools import reduce
|
|
||||||
from pathlib import Path as FilePath
|
from pathlib import Path as FilePath
|
||||||
from typing import Any, List
|
from typing import Any
|
||||||
from urllib.parse import unquote
|
from urllib.parse import unquote
|
||||||
|
|
||||||
import cv2
|
import cv2
|
||||||
@ -19,12 +18,11 @@ import pytz
|
|||||||
from fastapi import APIRouter, Depends, Path, Query, Request, Response
|
from fastapi import APIRouter, Depends, Path, Query, Request, Response
|
||||||
from fastapi.responses import FileResponse, JSONResponse, StreamingResponse
|
from fastapi.responses import FileResponse, JSONResponse, StreamingResponse
|
||||||
from pathvalidate import sanitize_filename
|
from pathvalidate import sanitize_filename
|
||||||
from peewee import DoesNotExist, fn, operator
|
from peewee import DoesNotExist, fn
|
||||||
from tzlocal import get_localzone_name
|
from tzlocal import get_localzone_name
|
||||||
|
|
||||||
from frigate.api.auth import (
|
from frigate.api.auth import (
|
||||||
allow_any_authenticated,
|
allow_any_authenticated,
|
||||||
get_allowed_cameras_for_filter,
|
|
||||||
require_camera_access,
|
require_camera_access,
|
||||||
)
|
)
|
||||||
from frigate.api.defs.query.media_query_parameters import (
|
from frigate.api.defs.query.media_query_parameters import (
|
||||||
@ -32,8 +30,6 @@ from frigate.api.defs.query.media_query_parameters import (
|
|||||||
MediaEventsSnapshotQueryParams,
|
MediaEventsSnapshotQueryParams,
|
||||||
MediaLatestFrameQueryParams,
|
MediaLatestFrameQueryParams,
|
||||||
MediaMjpegFeedQueryParams,
|
MediaMjpegFeedQueryParams,
|
||||||
MediaRecordingsAvailabilityQueryParams,
|
|
||||||
MediaRecordingsSummaryQueryParams,
|
|
||||||
)
|
)
|
||||||
from frigate.api.defs.tags import Tags
|
from frigate.api.defs.tags import Tags
|
||||||
from frigate.camera.state import CameraState
|
from frigate.camera.state import CameraState
|
||||||
@ -44,13 +40,11 @@ from frigate.const import (
|
|||||||
INSTALL_DIR,
|
INSTALL_DIR,
|
||||||
MAX_SEGMENT_DURATION,
|
MAX_SEGMENT_DURATION,
|
||||||
PREVIEW_FRAME_TYPE,
|
PREVIEW_FRAME_TYPE,
|
||||||
RECORD_DIR,
|
|
||||||
)
|
)
|
||||||
from frigate.models import Event, Previews, Recordings, Regions, ReviewSegment
|
from frigate.models import Event, Previews, Recordings, Regions, ReviewSegment
|
||||||
from frigate.track.object_processing import TrackedObjectProcessor
|
from frigate.track.object_processing import TrackedObjectProcessor
|
||||||
from frigate.util.file import get_event_thumbnail_bytes
|
from frigate.util.file import get_event_thumbnail_bytes
|
||||||
from frigate.util.image import get_image_from_recording
|
from frigate.util.image import get_image_from_recording
|
||||||
from frigate.util.time import get_dst_transitions
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
@ -397,333 +391,6 @@ async def submit_recording_snapshot_to_plus(
|
|||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
@router.get("/recordings/storage", dependencies=[Depends(allow_any_authenticated())])
|
|
||||||
def get_recordings_storage_usage(request: Request):
|
|
||||||
recording_stats = request.app.stats_emitter.get_latest_stats()["service"][
|
|
||||||
"storage"
|
|
||||||
][RECORD_DIR]
|
|
||||||
|
|
||||||
if not recording_stats:
|
|
||||||
return JSONResponse({})
|
|
||||||
|
|
||||||
total_mb = recording_stats["total"]
|
|
||||||
|
|
||||||
camera_usages: dict[str, dict] = (
|
|
||||||
request.app.storage_maintainer.calculate_camera_usages()
|
|
||||||
)
|
|
||||||
|
|
||||||
for camera_name in camera_usages.keys():
|
|
||||||
if camera_usages.get(camera_name, {}).get("usage"):
|
|
||||||
camera_usages[camera_name]["usage_percent"] = (
|
|
||||||
camera_usages.get(camera_name, {}).get("usage", 0) / total_mb
|
|
||||||
) * 100
|
|
||||||
|
|
||||||
return JSONResponse(content=camera_usages)
|
|
||||||
|
|
||||||
|
|
||||||
@router.get("/recordings/summary", dependencies=[Depends(allow_any_authenticated())])
|
|
||||||
def all_recordings_summary(
|
|
||||||
request: Request,
|
|
||||||
params: MediaRecordingsSummaryQueryParams = Depends(),
|
|
||||||
allowed_cameras: List[str] = Depends(get_allowed_cameras_for_filter),
|
|
||||||
):
|
|
||||||
"""Returns true/false by day indicating if recordings exist"""
|
|
||||||
|
|
||||||
cameras = params.cameras
|
|
||||||
if cameras != "all":
|
|
||||||
requested = set(unquote(cameras).split(","))
|
|
||||||
filtered = requested.intersection(allowed_cameras)
|
|
||||||
if not filtered:
|
|
||||||
return JSONResponse(content={})
|
|
||||||
camera_list = list(filtered)
|
|
||||||
else:
|
|
||||||
camera_list = allowed_cameras
|
|
||||||
|
|
||||||
time_range_query = (
|
|
||||||
Recordings.select(
|
|
||||||
fn.MIN(Recordings.start_time).alias("min_time"),
|
|
||||||
fn.MAX(Recordings.start_time).alias("max_time"),
|
|
||||||
)
|
|
||||||
.where(Recordings.camera << camera_list)
|
|
||||||
.dicts()
|
|
||||||
.get()
|
|
||||||
)
|
|
||||||
|
|
||||||
min_time = time_range_query.get("min_time")
|
|
||||||
max_time = time_range_query.get("max_time")
|
|
||||||
|
|
||||||
if min_time is None or max_time is None:
|
|
||||||
return JSONResponse(content={})
|
|
||||||
|
|
||||||
dst_periods = get_dst_transitions(params.timezone, min_time, max_time)
|
|
||||||
|
|
||||||
days: dict[str, bool] = {}
|
|
||||||
|
|
||||||
for period_start, period_end, period_offset in dst_periods:
|
|
||||||
hours_offset = int(period_offset / 60 / 60)
|
|
||||||
minutes_offset = int(period_offset / 60 - hours_offset * 60)
|
|
||||||
period_hour_modifier = f"{hours_offset} hour"
|
|
||||||
period_minute_modifier = f"{minutes_offset} minute"
|
|
||||||
|
|
||||||
period_query = (
|
|
||||||
Recordings.select(
|
|
||||||
fn.strftime(
|
|
||||||
"%Y-%m-%d",
|
|
||||||
fn.datetime(
|
|
||||||
Recordings.start_time,
|
|
||||||
"unixepoch",
|
|
||||||
period_hour_modifier,
|
|
||||||
period_minute_modifier,
|
|
||||||
),
|
|
||||||
).alias("day")
|
|
||||||
)
|
|
||||||
.where(
|
|
||||||
(Recordings.camera << camera_list)
|
|
||||||
& (Recordings.end_time >= period_start)
|
|
||||||
& (Recordings.start_time <= period_end)
|
|
||||||
)
|
|
||||||
.group_by(
|
|
||||||
fn.strftime(
|
|
||||||
"%Y-%m-%d",
|
|
||||||
fn.datetime(
|
|
||||||
Recordings.start_time,
|
|
||||||
"unixepoch",
|
|
||||||
period_hour_modifier,
|
|
||||||
period_minute_modifier,
|
|
||||||
),
|
|
||||||
)
|
|
||||||
)
|
|
||||||
.order_by(Recordings.start_time.desc())
|
|
||||||
.namedtuples()
|
|
||||||
)
|
|
||||||
|
|
||||||
for g in period_query:
|
|
||||||
days[g.day] = True
|
|
||||||
|
|
||||||
return JSONResponse(content=dict(sorted(days.items())))
|
|
||||||
|
|
||||||
|
|
||||||
@router.get(
|
|
||||||
"/{camera_name}/recordings/summary", dependencies=[Depends(require_camera_access)]
|
|
||||||
)
|
|
||||||
async def recordings_summary(camera_name: str, timezone: str = "utc"):
|
|
||||||
"""Returns hourly summary for recordings of given camera"""
|
|
||||||
|
|
||||||
time_range_query = (
|
|
||||||
Recordings.select(
|
|
||||||
fn.MIN(Recordings.start_time).alias("min_time"),
|
|
||||||
fn.MAX(Recordings.start_time).alias("max_time"),
|
|
||||||
)
|
|
||||||
.where(Recordings.camera == camera_name)
|
|
||||||
.dicts()
|
|
||||||
.get()
|
|
||||||
)
|
|
||||||
|
|
||||||
min_time = time_range_query.get("min_time")
|
|
||||||
max_time = time_range_query.get("max_time")
|
|
||||||
|
|
||||||
days: dict[str, dict] = {}
|
|
||||||
|
|
||||||
if min_time is None or max_time is None:
|
|
||||||
return JSONResponse(content=list(days.values()))
|
|
||||||
|
|
||||||
dst_periods = get_dst_transitions(timezone, min_time, max_time)
|
|
||||||
|
|
||||||
for period_start, period_end, period_offset in dst_periods:
|
|
||||||
hours_offset = int(period_offset / 60 / 60)
|
|
||||||
minutes_offset = int(period_offset / 60 - hours_offset * 60)
|
|
||||||
period_hour_modifier = f"{hours_offset} hour"
|
|
||||||
period_minute_modifier = f"{minutes_offset} minute"
|
|
||||||
|
|
||||||
recording_groups = (
|
|
||||||
Recordings.select(
|
|
||||||
fn.strftime(
|
|
||||||
"%Y-%m-%d %H",
|
|
||||||
fn.datetime(
|
|
||||||
Recordings.start_time,
|
|
||||||
"unixepoch",
|
|
||||||
period_hour_modifier,
|
|
||||||
period_minute_modifier,
|
|
||||||
),
|
|
||||||
).alias("hour"),
|
|
||||||
fn.SUM(Recordings.duration).alias("duration"),
|
|
||||||
fn.SUM(Recordings.motion).alias("motion"),
|
|
||||||
fn.SUM(Recordings.objects).alias("objects"),
|
|
||||||
)
|
|
||||||
.where(
|
|
||||||
(Recordings.camera == camera_name)
|
|
||||||
& (Recordings.end_time >= period_start)
|
|
||||||
& (Recordings.start_time <= period_end)
|
|
||||||
)
|
|
||||||
.group_by((Recordings.start_time + period_offset).cast("int") / 3600)
|
|
||||||
.order_by(Recordings.start_time.desc())
|
|
||||||
.namedtuples()
|
|
||||||
)
|
|
||||||
|
|
||||||
event_groups = (
|
|
||||||
Event.select(
|
|
||||||
fn.strftime(
|
|
||||||
"%Y-%m-%d %H",
|
|
||||||
fn.datetime(
|
|
||||||
Event.start_time,
|
|
||||||
"unixepoch",
|
|
||||||
period_hour_modifier,
|
|
||||||
period_minute_modifier,
|
|
||||||
),
|
|
||||||
).alias("hour"),
|
|
||||||
fn.COUNT(Event.id).alias("count"),
|
|
||||||
)
|
|
||||||
.where(Event.camera == camera_name, Event.has_clip)
|
|
||||||
.where(
|
|
||||||
(Event.start_time >= period_start) & (Event.start_time <= period_end)
|
|
||||||
)
|
|
||||||
.group_by((Event.start_time + period_offset).cast("int") / 3600)
|
|
||||||
.namedtuples()
|
|
||||||
)
|
|
||||||
|
|
||||||
event_map = {g.hour: g.count for g in event_groups}
|
|
||||||
|
|
||||||
for recording_group in recording_groups:
|
|
||||||
parts = recording_group.hour.split()
|
|
||||||
hour = parts[1]
|
|
||||||
day = parts[0]
|
|
||||||
events_count = event_map.get(recording_group.hour, 0)
|
|
||||||
hour_data = {
|
|
||||||
"hour": hour,
|
|
||||||
"events": events_count,
|
|
||||||
"motion": recording_group.motion,
|
|
||||||
"objects": recording_group.objects,
|
|
||||||
"duration": round(recording_group.duration),
|
|
||||||
}
|
|
||||||
if day in days:
|
|
||||||
# merge counts if already present (edge-case at DST boundary)
|
|
||||||
days[day]["events"] += events_count or 0
|
|
||||||
days[day]["hours"].append(hour_data)
|
|
||||||
else:
|
|
||||||
days[day] = {
|
|
||||||
"events": events_count or 0,
|
|
||||||
"hours": [hour_data],
|
|
||||||
"day": day,
|
|
||||||
}
|
|
||||||
|
|
||||||
return JSONResponse(content=list(days.values()))
|
|
||||||
|
|
||||||
|
|
||||||
@router.get("/{camera_name}/recordings", dependencies=[Depends(require_camera_access)])
|
|
||||||
async def recordings(
|
|
||||||
camera_name: str,
|
|
||||||
after: float = (datetime.now() - timedelta(hours=1)).timestamp(),
|
|
||||||
before: float = datetime.now().timestamp(),
|
|
||||||
):
|
|
||||||
"""Return specific camera recordings between the given 'after'/'end' times. If not provided the last hour will be used"""
|
|
||||||
recordings = (
|
|
||||||
Recordings.select(
|
|
||||||
Recordings.id,
|
|
||||||
Recordings.start_time,
|
|
||||||
Recordings.end_time,
|
|
||||||
Recordings.segment_size,
|
|
||||||
Recordings.motion,
|
|
||||||
Recordings.objects,
|
|
||||||
Recordings.duration,
|
|
||||||
)
|
|
||||||
.where(
|
|
||||||
Recordings.camera == camera_name,
|
|
||||||
Recordings.end_time >= after,
|
|
||||||
Recordings.start_time <= before,
|
|
||||||
)
|
|
||||||
.order_by(Recordings.start_time)
|
|
||||||
.dicts()
|
|
||||||
.iterator()
|
|
||||||
)
|
|
||||||
|
|
||||||
return JSONResponse(content=list(recordings))
|
|
||||||
|
|
||||||
|
|
||||||
@router.get(
|
|
||||||
"/recordings/unavailable",
|
|
||||||
response_model=list[dict],
|
|
||||||
dependencies=[Depends(allow_any_authenticated())],
|
|
||||||
)
|
|
||||||
async def no_recordings(
|
|
||||||
request: Request,
|
|
||||||
params: MediaRecordingsAvailabilityQueryParams = Depends(),
|
|
||||||
allowed_cameras: List[str] = Depends(get_allowed_cameras_for_filter),
|
|
||||||
):
|
|
||||||
"""Get time ranges with no recordings."""
|
|
||||||
cameras = params.cameras
|
|
||||||
if cameras != "all":
|
|
||||||
requested = set(unquote(cameras).split(","))
|
|
||||||
filtered = requested.intersection(allowed_cameras)
|
|
||||||
if not filtered:
|
|
||||||
return JSONResponse(content=[])
|
|
||||||
cameras = ",".join(filtered)
|
|
||||||
else:
|
|
||||||
cameras = allowed_cameras
|
|
||||||
|
|
||||||
before = params.before or datetime.datetime.now().timestamp()
|
|
||||||
after = (
|
|
||||||
params.after
|
|
||||||
or (datetime.datetime.now() - datetime.timedelta(hours=1)).timestamp()
|
|
||||||
)
|
|
||||||
scale = params.scale
|
|
||||||
|
|
||||||
clauses = [(Recordings.end_time >= after) & (Recordings.start_time <= before)]
|
|
||||||
if cameras != "all":
|
|
||||||
camera_list = cameras.split(",")
|
|
||||||
clauses.append((Recordings.camera << camera_list))
|
|
||||||
else:
|
|
||||||
camera_list = allowed_cameras
|
|
||||||
|
|
||||||
# Get recording start times
|
|
||||||
data: list[Recordings] = (
|
|
||||||
Recordings.select(Recordings.start_time, Recordings.end_time)
|
|
||||||
.where(reduce(operator.and_, clauses))
|
|
||||||
.order_by(Recordings.start_time.asc())
|
|
||||||
.dicts()
|
|
||||||
.iterator()
|
|
||||||
)
|
|
||||||
|
|
||||||
# Convert recordings to list of (start, end) tuples
|
|
||||||
recordings = [(r["start_time"], r["end_time"]) for r in data]
|
|
||||||
|
|
||||||
# Iterate through time segments and check if each has any recording
|
|
||||||
no_recording_segments = []
|
|
||||||
current = after
|
|
||||||
current_gap_start = None
|
|
||||||
|
|
||||||
while current < before:
|
|
||||||
segment_end = min(current + scale, before)
|
|
||||||
|
|
||||||
# Check if this segment overlaps with any recording
|
|
||||||
has_recording = any(
|
|
||||||
rec_start < segment_end and rec_end > current
|
|
||||||
for rec_start, rec_end in recordings
|
|
||||||
)
|
|
||||||
|
|
||||||
if not has_recording:
|
|
||||||
# This segment has no recordings
|
|
||||||
if current_gap_start is None:
|
|
||||||
current_gap_start = current # Start a new gap
|
|
||||||
else:
|
|
||||||
# This segment has recordings
|
|
||||||
if current_gap_start is not None:
|
|
||||||
# End the current gap and append it
|
|
||||||
no_recording_segments.append(
|
|
||||||
{"start_time": int(current_gap_start), "end_time": int(current)}
|
|
||||||
)
|
|
||||||
current_gap_start = None
|
|
||||||
|
|
||||||
current = segment_end
|
|
||||||
|
|
||||||
# Append the last gap if it exists
|
|
||||||
if current_gap_start is not None:
|
|
||||||
no_recording_segments.append(
|
|
||||||
{"start_time": int(current_gap_start), "end_time": int(before)}
|
|
||||||
)
|
|
||||||
|
|
||||||
return JSONResponse(content=no_recording_segments)
|
|
||||||
|
|
||||||
|
|
||||||
@router.get(
|
@router.get(
|
||||||
"/{camera_name}/start/{start_ts}/end/{end_ts}/clip.mp4",
|
"/{camera_name}/start/{start_ts}/end/{end_ts}/clip.mp4",
|
||||||
dependencies=[Depends(require_camera_access)],
|
dependencies=[Depends(require_camera_access)],
|
||||||
|
|||||||
@ -1,31 +1,368 @@
|
|||||||
"""Recording APIs."""
|
"""Recording APIs."""
|
||||||
|
|
||||||
import logging
|
import logging
|
||||||
|
from datetime import datetime, timedelta
|
||||||
from functools import reduce
|
from functools import reduce
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from typing import List
|
from typing import List
|
||||||
|
from urllib.parse import unquote
|
||||||
|
|
||||||
from fastapi import APIRouter, Depends
|
from fastapi import APIRouter, Depends
|
||||||
from fastapi import Path as PathParam
|
from fastapi import Path as PathParam
|
||||||
from fastapi.responses import JSONResponse
|
from fastapi.responses import JSONResponse, Request
|
||||||
from peewee import operator
|
from peewee import fn, operator
|
||||||
|
|
||||||
from frigate.api.auth import (
|
from frigate.api.auth import (
|
||||||
|
allow_any_authenticated,
|
||||||
get_allowed_cameras_for_filter,
|
get_allowed_cameras_for_filter,
|
||||||
|
require_camera_access,
|
||||||
require_role,
|
require_role,
|
||||||
)
|
)
|
||||||
|
from frigate.api.defs.query.media_query_parameters import (
|
||||||
|
MediaRecordingsAvailabilityQueryParams,
|
||||||
|
)
|
||||||
from frigate.api.defs.query.recordings_query_parameters import (
|
from frigate.api.defs.query.recordings_query_parameters import (
|
||||||
|
MediaRecordingsSummaryQueryParams,
|
||||||
RecordingsDeleteQueryParams,
|
RecordingsDeleteQueryParams,
|
||||||
)
|
)
|
||||||
from frigate.api.defs.response.generic_response import GenericResponse
|
from frigate.api.defs.response.generic_response import GenericResponse
|
||||||
from frigate.api.defs.tags import Tags
|
from frigate.api.defs.tags import Tags
|
||||||
from frigate.models import Recordings
|
from frigate.const import RECORD_DIR
|
||||||
|
from frigate.models import Event, Recordings
|
||||||
|
from frigate.util.time import get_dst_transitions
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
router = APIRouter(tags=[Tags.recordings])
|
router = APIRouter(tags=[Tags.recordings])
|
||||||
|
|
||||||
|
|
||||||
|
@router.get("/recordings/storage", dependencies=[Depends(allow_any_authenticated())])
|
||||||
|
def get_recordings_storage_usage(request: Request):
|
||||||
|
recording_stats = request.app.stats_emitter.get_latest_stats()["service"][
|
||||||
|
"storage"
|
||||||
|
][RECORD_DIR]
|
||||||
|
|
||||||
|
if not recording_stats:
|
||||||
|
return JSONResponse({})
|
||||||
|
|
||||||
|
total_mb = recording_stats["total"]
|
||||||
|
|
||||||
|
camera_usages: dict[str, dict] = (
|
||||||
|
request.app.storage_maintainer.calculate_camera_usages()
|
||||||
|
)
|
||||||
|
|
||||||
|
for camera_name in camera_usages.keys():
|
||||||
|
if camera_usages.get(camera_name, {}).get("usage"):
|
||||||
|
camera_usages[camera_name]["usage_percent"] = (
|
||||||
|
camera_usages.get(camera_name, {}).get("usage", 0) / total_mb
|
||||||
|
) * 100
|
||||||
|
|
||||||
|
return JSONResponse(content=camera_usages)
|
||||||
|
|
||||||
|
|
||||||
|
@router.get("/recordings/summary", dependencies=[Depends(allow_any_authenticated())])
|
||||||
|
def all_recordings_summary(
|
||||||
|
request: Request,
|
||||||
|
params: MediaRecordingsSummaryQueryParams = Depends(),
|
||||||
|
allowed_cameras: List[str] = Depends(get_allowed_cameras_for_filter),
|
||||||
|
):
|
||||||
|
"""Returns true/false by day indicating if recordings exist"""
|
||||||
|
|
||||||
|
cameras = params.cameras
|
||||||
|
if cameras != "all":
|
||||||
|
requested = set(unquote(cameras).split(","))
|
||||||
|
filtered = requested.intersection(allowed_cameras)
|
||||||
|
if not filtered:
|
||||||
|
return JSONResponse(content={})
|
||||||
|
camera_list = list(filtered)
|
||||||
|
else:
|
||||||
|
camera_list = allowed_cameras
|
||||||
|
|
||||||
|
time_range_query = (
|
||||||
|
Recordings.select(
|
||||||
|
fn.MIN(Recordings.start_time).alias("min_time"),
|
||||||
|
fn.MAX(Recordings.start_time).alias("max_time"),
|
||||||
|
)
|
||||||
|
.where(Recordings.camera << camera_list)
|
||||||
|
.dicts()
|
||||||
|
.get()
|
||||||
|
)
|
||||||
|
|
||||||
|
min_time = time_range_query.get("min_time")
|
||||||
|
max_time = time_range_query.get("max_time")
|
||||||
|
|
||||||
|
if min_time is None or max_time is None:
|
||||||
|
return JSONResponse(content={})
|
||||||
|
|
||||||
|
dst_periods = get_dst_transitions(params.timezone, min_time, max_time)
|
||||||
|
|
||||||
|
days: dict[str, bool] = {}
|
||||||
|
|
||||||
|
for period_start, period_end, period_offset in dst_periods:
|
||||||
|
hours_offset = int(period_offset / 60 / 60)
|
||||||
|
minutes_offset = int(period_offset / 60 - hours_offset * 60)
|
||||||
|
period_hour_modifier = f"{hours_offset} hour"
|
||||||
|
period_minute_modifier = f"{minutes_offset} minute"
|
||||||
|
|
||||||
|
period_query = (
|
||||||
|
Recordings.select(
|
||||||
|
fn.strftime(
|
||||||
|
"%Y-%m-%d",
|
||||||
|
fn.datetime(
|
||||||
|
Recordings.start_time,
|
||||||
|
"unixepoch",
|
||||||
|
period_hour_modifier,
|
||||||
|
period_minute_modifier,
|
||||||
|
),
|
||||||
|
).alias("day")
|
||||||
|
)
|
||||||
|
.where(
|
||||||
|
(Recordings.camera << camera_list)
|
||||||
|
& (Recordings.end_time >= period_start)
|
||||||
|
& (Recordings.start_time <= period_end)
|
||||||
|
)
|
||||||
|
.group_by(
|
||||||
|
fn.strftime(
|
||||||
|
"%Y-%m-%d",
|
||||||
|
fn.datetime(
|
||||||
|
Recordings.start_time,
|
||||||
|
"unixepoch",
|
||||||
|
period_hour_modifier,
|
||||||
|
period_minute_modifier,
|
||||||
|
),
|
||||||
|
)
|
||||||
|
)
|
||||||
|
.order_by(Recordings.start_time.desc())
|
||||||
|
.namedtuples()
|
||||||
|
)
|
||||||
|
|
||||||
|
for g in period_query:
|
||||||
|
days[g.day] = True
|
||||||
|
|
||||||
|
return JSONResponse(content=dict(sorted(days.items())))
|
||||||
|
|
||||||
|
|
||||||
|
@router.get(
|
||||||
|
"/{camera_name}/recordings/summary", dependencies=[Depends(require_camera_access)]
|
||||||
|
)
|
||||||
|
async def recordings_summary(camera_name: str, timezone: str = "utc"):
|
||||||
|
"""Returns hourly summary for recordings of given camera"""
|
||||||
|
|
||||||
|
time_range_query = (
|
||||||
|
Recordings.select(
|
||||||
|
fn.MIN(Recordings.start_time).alias("min_time"),
|
||||||
|
fn.MAX(Recordings.start_time).alias("max_time"),
|
||||||
|
)
|
||||||
|
.where(Recordings.camera == camera_name)
|
||||||
|
.dicts()
|
||||||
|
.get()
|
||||||
|
)
|
||||||
|
|
||||||
|
min_time = time_range_query.get("min_time")
|
||||||
|
max_time = time_range_query.get("max_time")
|
||||||
|
|
||||||
|
days: dict[str, dict] = {}
|
||||||
|
|
||||||
|
if min_time is None or max_time is None:
|
||||||
|
return JSONResponse(content=list(days.values()))
|
||||||
|
|
||||||
|
dst_periods = get_dst_transitions(timezone, min_time, max_time)
|
||||||
|
|
||||||
|
for period_start, period_end, period_offset in dst_periods:
|
||||||
|
hours_offset = int(period_offset / 60 / 60)
|
||||||
|
minutes_offset = int(period_offset / 60 - hours_offset * 60)
|
||||||
|
period_hour_modifier = f"{hours_offset} hour"
|
||||||
|
period_minute_modifier = f"{minutes_offset} minute"
|
||||||
|
|
||||||
|
recording_groups = (
|
||||||
|
Recordings.select(
|
||||||
|
fn.strftime(
|
||||||
|
"%Y-%m-%d %H",
|
||||||
|
fn.datetime(
|
||||||
|
Recordings.start_time,
|
||||||
|
"unixepoch",
|
||||||
|
period_hour_modifier,
|
||||||
|
period_minute_modifier,
|
||||||
|
),
|
||||||
|
).alias("hour"),
|
||||||
|
fn.SUM(Recordings.duration).alias("duration"),
|
||||||
|
fn.SUM(Recordings.motion).alias("motion"),
|
||||||
|
fn.SUM(Recordings.objects).alias("objects"),
|
||||||
|
)
|
||||||
|
.where(
|
||||||
|
(Recordings.camera == camera_name)
|
||||||
|
& (Recordings.end_time >= period_start)
|
||||||
|
& (Recordings.start_time <= period_end)
|
||||||
|
)
|
||||||
|
.group_by((Recordings.start_time + period_offset).cast("int") / 3600)
|
||||||
|
.order_by(Recordings.start_time.desc())
|
||||||
|
.namedtuples()
|
||||||
|
)
|
||||||
|
|
||||||
|
event_groups = (
|
||||||
|
Event.select(
|
||||||
|
fn.strftime(
|
||||||
|
"%Y-%m-%d %H",
|
||||||
|
fn.datetime(
|
||||||
|
Event.start_time,
|
||||||
|
"unixepoch",
|
||||||
|
period_hour_modifier,
|
||||||
|
period_minute_modifier,
|
||||||
|
),
|
||||||
|
).alias("hour"),
|
||||||
|
fn.COUNT(Event.id).alias("count"),
|
||||||
|
)
|
||||||
|
.where(Event.camera == camera_name, Event.has_clip)
|
||||||
|
.where(
|
||||||
|
(Event.start_time >= period_start) & (Event.start_time <= period_end)
|
||||||
|
)
|
||||||
|
.group_by((Event.start_time + period_offset).cast("int") / 3600)
|
||||||
|
.namedtuples()
|
||||||
|
)
|
||||||
|
|
||||||
|
event_map = {g.hour: g.count for g in event_groups}
|
||||||
|
|
||||||
|
for recording_group in recording_groups:
|
||||||
|
parts = recording_group.hour.split()
|
||||||
|
hour = parts[1]
|
||||||
|
day = parts[0]
|
||||||
|
events_count = event_map.get(recording_group.hour, 0)
|
||||||
|
hour_data = {
|
||||||
|
"hour": hour,
|
||||||
|
"events": events_count,
|
||||||
|
"motion": recording_group.motion,
|
||||||
|
"objects": recording_group.objects,
|
||||||
|
"duration": round(recording_group.duration),
|
||||||
|
}
|
||||||
|
if day in days:
|
||||||
|
# merge counts if already present (edge-case at DST boundary)
|
||||||
|
days[day]["events"] += events_count or 0
|
||||||
|
days[day]["hours"].append(hour_data)
|
||||||
|
else:
|
||||||
|
days[day] = {
|
||||||
|
"events": events_count or 0,
|
||||||
|
"hours": [hour_data],
|
||||||
|
"day": day,
|
||||||
|
}
|
||||||
|
|
||||||
|
return JSONResponse(content=list(days.values()))
|
||||||
|
|
||||||
|
|
||||||
|
@router.get("/{camera_name}/recordings", dependencies=[Depends(require_camera_access)])
|
||||||
|
async def recordings(
|
||||||
|
camera_name: str,
|
||||||
|
after: float = (datetime.now() - timedelta(hours=1)).timestamp(),
|
||||||
|
before: float = datetime.now().timestamp(),
|
||||||
|
):
|
||||||
|
"""Return specific camera recordings between the given 'after'/'end' times. If not provided the last hour will be used"""
|
||||||
|
recordings = (
|
||||||
|
Recordings.select(
|
||||||
|
Recordings.id,
|
||||||
|
Recordings.start_time,
|
||||||
|
Recordings.end_time,
|
||||||
|
Recordings.segment_size,
|
||||||
|
Recordings.motion,
|
||||||
|
Recordings.objects,
|
||||||
|
Recordings.duration,
|
||||||
|
)
|
||||||
|
.where(
|
||||||
|
Recordings.camera == camera_name,
|
||||||
|
Recordings.end_time >= after,
|
||||||
|
Recordings.start_time <= before,
|
||||||
|
)
|
||||||
|
.order_by(Recordings.start_time)
|
||||||
|
.dicts()
|
||||||
|
.iterator()
|
||||||
|
)
|
||||||
|
|
||||||
|
return JSONResponse(content=list(recordings))
|
||||||
|
|
||||||
|
|
||||||
|
@router.get(
|
||||||
|
"/recordings/unavailable",
|
||||||
|
response_model=list[dict],
|
||||||
|
dependencies=[Depends(allow_any_authenticated())],
|
||||||
|
)
|
||||||
|
async def no_recordings(
|
||||||
|
request: Request,
|
||||||
|
params: MediaRecordingsAvailabilityQueryParams = Depends(),
|
||||||
|
allowed_cameras: List[str] = Depends(get_allowed_cameras_for_filter),
|
||||||
|
):
|
||||||
|
"""Get time ranges with no recordings."""
|
||||||
|
cameras = params.cameras
|
||||||
|
if cameras != "all":
|
||||||
|
requested = set(unquote(cameras).split(","))
|
||||||
|
filtered = requested.intersection(allowed_cameras)
|
||||||
|
if not filtered:
|
||||||
|
return JSONResponse(content=[])
|
||||||
|
cameras = ",".join(filtered)
|
||||||
|
else:
|
||||||
|
cameras = allowed_cameras
|
||||||
|
|
||||||
|
before = params.before or datetime.datetime.now().timestamp()
|
||||||
|
after = (
|
||||||
|
params.after
|
||||||
|
or (datetime.datetime.now() - datetime.timedelta(hours=1)).timestamp()
|
||||||
|
)
|
||||||
|
scale = params.scale
|
||||||
|
|
||||||
|
clauses = [(Recordings.end_time >= after) & (Recordings.start_time <= before)]
|
||||||
|
if cameras != "all":
|
||||||
|
camera_list = cameras.split(",")
|
||||||
|
clauses.append((Recordings.camera << camera_list))
|
||||||
|
else:
|
||||||
|
camera_list = allowed_cameras
|
||||||
|
|
||||||
|
# Get recording start times
|
||||||
|
data: list[Recordings] = (
|
||||||
|
Recordings.select(Recordings.start_time, Recordings.end_time)
|
||||||
|
.where(reduce(operator.and_, clauses))
|
||||||
|
.order_by(Recordings.start_time.asc())
|
||||||
|
.dicts()
|
||||||
|
.iterator()
|
||||||
|
)
|
||||||
|
|
||||||
|
# Convert recordings to list of (start, end) tuples
|
||||||
|
recordings = [(r["start_time"], r["end_time"]) for r in data]
|
||||||
|
|
||||||
|
# Iterate through time segments and check if each has any recording
|
||||||
|
no_recording_segments = []
|
||||||
|
current = after
|
||||||
|
current_gap_start = None
|
||||||
|
|
||||||
|
while current < before:
|
||||||
|
segment_end = min(current + scale, before)
|
||||||
|
|
||||||
|
# Check if this segment overlaps with any recording
|
||||||
|
has_recording = any(
|
||||||
|
rec_start < segment_end and rec_end > current
|
||||||
|
for rec_start, rec_end in recordings
|
||||||
|
)
|
||||||
|
|
||||||
|
if not has_recording:
|
||||||
|
# This segment has no recordings
|
||||||
|
if current_gap_start is None:
|
||||||
|
current_gap_start = current # Start a new gap
|
||||||
|
else:
|
||||||
|
# This segment has recordings
|
||||||
|
if current_gap_start is not None:
|
||||||
|
# End the current gap and append it
|
||||||
|
no_recording_segments.append(
|
||||||
|
{"start_time": int(current_gap_start), "end_time": int(current)}
|
||||||
|
)
|
||||||
|
current_gap_start = None
|
||||||
|
|
||||||
|
current = segment_end
|
||||||
|
|
||||||
|
# Append the last gap if it exists
|
||||||
|
if current_gap_start is not None:
|
||||||
|
no_recording_segments.append(
|
||||||
|
{"start_time": int(current_gap_start), "end_time": int(before)}
|
||||||
|
)
|
||||||
|
|
||||||
|
return JSONResponse(content=no_recording_segments)
|
||||||
|
|
||||||
|
|
||||||
@router.delete(
|
@router.delete(
|
||||||
"/recordings/start/{start}/end/{end}",
|
"/recordings/start/{start}/end/{end}",
|
||||||
response_model=GenericResponse,
|
response_model=GenericResponse,
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user