+
+
+
+
diff --git a/video-feed/videofeed/templates/recordings.html b/video-feed/videofeed/templates/recordings.html
index 1aa62cb..1f88e46 100644
--- a/video-feed/videofeed/templates/recordings.html
+++ b/video-feed/videofeed/templates/recordings.html
@@ -175,10 +175,8 @@
+
+
+
+
+
+ SpectraX
+Sign in to the dashboard
+ + +Detection Details:
function loadRecordings(resetContent = true) { showLoading(true); - // Prepare API URL with filters - let apiUrl = `/recordings?limit=${currentLimit}&offset=${currentOffset}`; + let apiUrl = `/api/recordings?limit=${currentLimit}&offset=${currentOffset}`; - // Add date filters if specified if (startDateInput.value) { apiUrl += `&start_date=${startDateInput.value}T00:00:00`; } @@ -187,8 +185,12 @@Detection Details:
apiUrl += `&end_date=${endDateInput.value}T23:59:59`; } - fetch(apiUrl) + fetch(apiUrl, { credentials: 'include' }) .then(response => { + if (response.status === 401) { + window.location.href = '/login'; + throw new Error('Unauthorized'); + } if (!response.ok) { throw new Error('Failed to load recordings'); } @@ -198,30 +200,28 @@Detection Details:
showLoading(false); if (resetContent) { - recordingsContainer.innerHTML = ''; + recordingsContainer.replaceChildren(); recordingsMap = {}; } - const recordings = data.recordings; + const recordings = data.recordings || []; if (recordings.length === 0 && currentOffset === 0) { - recordingsContainer.innerHTML = ` -
-
- `;
+ const empty = document.createElement('div');
+ empty.className = 'col-12 text-center';
+ const p = document.createElement('p');
+ p.textContent = 'No recordings found matching your criteria.';
+ empty.appendChild(p);
+ recordingsContainer.appendChild(empty);
loadMoreBtn.classList.add('d-none');
return;
}
- // Hide the "no recordings" message if we have recordings
noRecordings.classList.add('d-none');
- // Determine if we should show "load more" button
hasMoreRecordings = recordings.length === currentLimit;
loadMoreBtn.classList.toggle('d-none', !hasMoreRecordings);
- // Render recordings
recordings.forEach(recording => {
recordingsMap[recording.id] = recording;
renderRecordingCard(recording);
@@ -230,70 +230,90 @@ No recordings found matching your criteria.
-Detection Details:
.catch(error => { showLoading(false); console.error('Error:', error); - alert('Failed to load recordings. See console for details.'); + if (error.message !== 'Unauthorized') { + alert('Failed to load recordings. See console for details.'); + } }); } - // Render a recording card + // Render a recording card without interpolating untrusted data into HTML function renderRecordingCard(recording) { const dateTime = new Date(recording.timestamp); const formattedDate = dateTime.toLocaleDateString(); const formattedTime = dateTime.toLocaleTimeString(); - // Extract object types for labels - const objects = JSON.parse(typeof recording.objects_detected === 'string' - ? recording.objects_detected - : JSON.stringify(recording.objects_detected)); + let objects = []; + try { + objects = JSON.parse(typeof recording.objects_detected === 'string' + ? recording.objects_detected + : JSON.stringify(recording.objects_detected || [])); + } catch (e) { + objects = []; + } - // Count occurrences of each object type const objectCounts = {}; objects.forEach(obj => { - const className = obj.class; + const className = obj.class || 'unknown'; objectCounts[className] = (objectCounts[className] || 0) + 1; }); - // Create labels for each object type - const objectLabels = Object.entries(objectCounts) - .map(([className, count]) => ` - - ${className} (${count}) - - `).join(''); - - // Generate card HTML const card = document.createElement('div'); card.className = 'col-lg-4 col-md-6'; - card.innerHTML = ` -
-
- `;
- // Add click event to the "Watch" button
- card.querySelector('.watch-btn').addEventListener('click', () => {
- openVideoModal(recording.id);
+ const cardInner = document.createElement('div');
+ cardInner.className = 'card recording-card shadow-sm';
+
+ const thumbWrap = document.createElement('div');
+ thumbWrap.className = 'position-relative';
+ const img = document.createElement('img');
+ img.className = 'thumbnail';
+ img.alt = 'Recording thumbnail';
+ const thumbName = (recording.thumbnail_path || recording.thumbnail_url || '').split('/').pop();
+ if (thumbName) {
+ img.src = recording.thumbnail_url || `/recordings/${thumbName}`;
+ }
+ thumbWrap.appendChild(img);
+ const durationBadge = document.createElement('div');
+ durationBadge.className = 'position-absolute bottom-0 end-0 p-2 bg-dark text-white rounded-start';
+ durationBadge.textContent = `${Math.round(recording.duration || 0)}s`;
+ thumbWrap.appendChild(durationBadge);
+ cardInner.appendChild(thumbWrap);
+
+ const body = document.createElement('div');
+ body.className = 'card-body';
+ const title = document.createElement('h5');
+ title.className = 'card-title';
+ title.textContent = recording.stream_name || 'Unknown stream';
+ body.appendChild(title);
+
+ const meta = document.createElement('p');
+ meta.className = 'card-text';
+ const small = document.createElement('small');
+ small.className = 'text-muted';
+ small.textContent = `${formattedDate} at ${formattedTime}`;
+ meta.appendChild(small);
+ body.appendChild(meta);
+
+ const labels = document.createElement('div');
+ labels.className = 'mb-2';
+ Object.entries(objectCounts).forEach(([className, count]) => {
+ const pill = document.createElement('span');
+ pill.className = 'label-pill';
+ pill.style.backgroundColor = '#007bff';
+ pill.textContent = `${className} (${count})`;
+ labels.appendChild(pill);
});
+ body.appendChild(labels);
+
+ const watchBtn = document.createElement('button');
+ watchBtn.className = 'btn btn-primary btn-sm w-100 mt-2 watch-btn';
+ watchBtn.dataset.recordingId = String(recording.id);
+ watchBtn.textContent = 'Watch';
+ watchBtn.addEventListener('click', () => openVideoModal(recording.id));
+ body.appendChild(watchBtn);
- // Add card to container
+ cardInner.appendChild(body);
+ card.appendChild(cardInner);
recordingsContainer.appendChild(card);
}
@@ -308,21 +328,22 @@
- .pop()})
-
-
- ${Math.round(recording.duration)}s
-
-
-
- ${recording.stream_name}
-- ${formattedDate} at ${formattedTime} -
-
- ${objectLabels}
-
-
- ${recording.stream_name}
currentRecordingId = recordingId; - // Set video source - const fileName = recording.file_path.split('/').pop(); - videoPlayer.src = `/recordings/${fileName}`; + const fileName = (recording.file_path || recording.file_url || '').split('/').pop(); + videoPlayer.src = recording.file_url || `/recordings/${fileName}`; videoPlayer.load(); - // Update modal title document.getElementById('videoModalLabel').textContent = - `${recording.stream_name} - ${new Date(recording.timestamp).toLocaleString()}`; + `${recording.stream_name || 'Recording'} - ${new Date(recording.timestamp).toLocaleString()}`; - // Display detection details - const objects = JSON.parse(typeof recording.objects_detected === 'string' - ? recording.objects_detected - : JSON.stringify(recording.objects_detected)); + let objects = []; + try { + objects = JSON.parse(typeof recording.objects_detected === 'string' + ? recording.objects_detected + : JSON.stringify(recording.objects_detected || [])); + } catch (e) { + objects = []; + } - // Group by class and show confidence const detectionsByClass = {}; objects.forEach(obj => { if (!detectionsByClass[obj.class]) { @@ -331,24 +352,22 @@${recording.stream_name}
detectionsByClass[obj.class].push(obj.confidence); }); - // Format detection details HTML - let detailsHtml = '- ';
+ modalDetectionDetails.replaceChildren();
+ const ul = document.createElement('ul');
+ ul.className = 'list-group';
Object.entries(detectionsByClass).forEach(([className, confidences]) => {
- // Get max confidence for this class
const maxConfidence = Math.max(...confidences);
- detailsHtml += `
-
- - ${className} - - ${confidences.length}× (max conf: ${maxConfidence.toFixed(2)}) - - - `; + const li = document.createElement('li'); + li.className = 'list-group-item d-flex justify-content-between align-items-center'; + li.appendChild(document.createTextNode(className)); + const badge = document.createElement('span'); + badge.className = 'badge bg-primary rounded-pill'; + badge.textContent = `${confidences.length}× (max conf: ${maxConfidence.toFixed(2)})`; + li.appendChild(badge); + ul.appendChild(li); }); - detailsHtml += '
${recording.stream_name}
return; } - fetch(`/recordings/${currentRecordingId}`, { - method: 'DELETE' + fetch(`/api/recordings/${currentRecordingId}`, { + method: 'DELETE', + credentials: 'include', }) .then(response => { + if (response.status === 401) { + window.location.href = '/login'; + throw new Error('Unauthorized'); + } if (!response.ok) { throw new Error('Failed to delete recording'); } return response.json(); }) .then(data => { - // Close modal and reload recordings videoModal.hide(); - // Remove the deleted recording from the DOM const elements = document.querySelectorAll(`[data-recording-id="${currentRecordingId}"]`); elements.forEach(el => { const card = el.closest('.col-lg-4.col-md-6'); @@ -382,13 +404,13 @@${recording.stream_name}
} }); - // Check if we need to load more or show "no recordings" message if (recordingsContainer.children.length === 0) { - recordingsContainer.innerHTML = ` -
-
- `;
+ const empty = document.createElement('div');
+ empty.className = 'col-12 text-center';
+ const p = document.createElement('p');
+ p.textContent = 'No recordings available.';
+ empty.appendChild(p);
+ recordingsContainer.appendChild(empty);
loadMoreBtn.classList.add('d-none');
}
@@ -396,7 +418,9 @@ No recordings available.
-${recording.stream_name}
}) .catch(error => { console.error('Error:', error); - alert('Failed to delete recording'); + if (error.message !== 'Unauthorized') { + alert('Failed to delete recording'); + } }); } diff --git a/video-feed/videofeed/templates/viewer.html b/video-feed/videofeed/templates/viewer.html index 8b97e02..51386be 100644 --- a/video-feed/videofeed/templates/viewer.html +++ b/video-feed/videofeed/templates/viewer.html @@ -240,9 +240,13 @@Status Information
// Fetch status info every 2 seconds setInterval(async function() { try { - const response = await fetch('/status'); + const response = await fetch('/status', { credentials: 'include' }); + if (response.status === 401) { window.location.href = '/login'; return; } const data = await response.json(); - document.getElementById('statusInfo').innerHTML = `${JSON.stringify(data, null, 2)}`;
+ const pre = document.createElement('pre');
+ pre.textContent = JSON.stringify(data, null, 2);
+ const statusEl = document.getElementById('statusInfo');
+ statusEl.replaceChildren(pre);
// Update current feed info if we have active feed
const currentFeedId = new URLSearchParams(window.location.search).get('feed');
diff --git a/video-feed/videofeed/utils.py b/video-feed/videofeed/utils.py
index 3d5513c..1da7a5e 100644
--- a/video-feed/videofeed/utils.py
+++ b/video-feed/videofeed/utils.py
@@ -3,6 +3,7 @@
import socket
import shutil
import subprocess
+import sys
import typer
from pathlib import Path
from typing import Dict, List, Optional
@@ -12,51 +13,37 @@
def resolve_model_path(model_name: str) -> str:
"""Resolve YOLO model path to use package models directory.
-
+
Args:
model_name: Model filename (e.g., 'yolov8n.pt') or full path
-
+
Returns:
Full path to model file, or original if it's already a full path
"""
model_path = Path(model_name)
-
- # If it's already an absolute path or exists as-is, use it
+
if model_path.is_absolute() or model_path.exists():
return str(model_path)
-
- # Check in package models directory
+
package_models_dir = Path(__file__).parent.parent / "models"
package_model_path = package_models_dir / model_name
-
+
if package_model_path.exists():
return str(package_model_path)
-
- # If not found in package, return original (will trigger download)
+
return model_name
def launch_mediamtx(cfg_path: Path) -> subprocess.Popen:
- """Launch the MediaMTX server with the given configuration.
-
- Args:
- cfg_path: Path to mediamtx.yml configuration file
-
- Returns:
- Process object for the running server
- """
- # Silent launch - config path not needed in output
- # typer.echo(f"🔧 Launching MediaMTX with config: {cfg_path}")
-
- # Verify config file exists
+ """Launch the MediaMTX server with the given configuration."""
if not cfg_path.exists():
typer.secho(f"❌ Config file not found: {cfg_path}", fg=typer.colors.RED)
raise typer.Exit(1)
-
+
return subprocess.Popen(
[MEDIAMTX_BIN, str(cfg_path)],
- stdout=subprocess.PIPE,
- stderr=subprocess.PIPE
+ stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE,
)
@@ -73,60 +60,86 @@ def detect_host_ip(prefer_iface: Optional[str] = None) -> str:
def check_mediamtx_installed(binary_name: str = MEDIAMTX_BIN) -> None:
"""Check if mediamtx binary is available and exit if not."""
if shutil.which(binary_name) is None:
- typer.secho(f"Error: '{binary_name}' binary not found.", fg=typer.colors.RED, bold=True)
- typer.echo("Please install MediaMTX from: https://github.com/bluenviron/mediamtx/releases")
+ typer.secho(
+ f"Error: '{binary_name}' binary not found.",
+ fg=typer.colors.RED,
+ bold=True,
+ )
+ typer.echo(
+ "Please install MediaMTX from: https://github.com/bluenviron/mediamtx/releases"
+ )
raise typer.Exit(1)
-def print_urls(host: str, paths: List[str], creds: Dict[str, str], rtsps: bool = False) -> None:
- """Print connection URLs for RTSP/HLS streams."""
+def print_urls(
+ host: str, paths: List[str], creds: Dict[str, str], rtsps: bool = False
+) -> None:
+ """Print connection URLs for RTSP/HLS streams without embedding passwords.
+
+ Passwords are never printed here. Operators retrieve them via:
+ `surveillance credentials show-stream`
+ """
for i, path in enumerate(paths):
if i > 0:
typer.echo("\n" + "-" * 50 + "\n")
-
+
typer.secho(f"\n📹 Stream Path: {path}", fg=typer.colors.YELLOW, bold=True)
base_url = f"rtsp://{host}:8554/{path}"
if rtsps:
- # For secure publishers like Larix
publish_url = f"rtsps://{host}:8322/{path}"
- typer.secho("\n📲 Encrypted RTSPS Publishing:", fg=typer.colors.CYAN, bold=True)
- typer.secho("Use in phone apps (e.g. Larix Broadcaster) or other cameras - encrypted", fg=typer.colors.CYAN, bold=True)
+ typer.secho(
+ "\n📲 Encrypted RTSPS Publishing:", fg=typer.colors.CYAN, bold=True
+ )
typer.echo(f" URL: {publish_url}")
typer.echo(f" User: {creds['publish_user']}")
- typer.echo(f" Pass: {creds['publish_pass']}")
+ typer.echo(" Pass: (use: surveillance credentials show-stream)")
else:
- # Standard RTSP publishing
typer.secho("\n📲 RTSP Publishing:", fg=typer.colors.CYAN, bold=True)
- typer.secho("Use in phone apps (e.g. Larix Broadcaster) or other cameras - unencrypted", fg=typer.colors.CYAN, bold=True)
typer.echo(f" URL: {base_url}")
typer.echo(f" User: {creds['publish_user']}")
- typer.echo(f" Pass: {creds['publish_pass']}")
+ typer.echo(" Pass: (use: surveillance credentials show-stream)")
- # Show viewing URLs - always the same regardless of rtsps/rtsp for publishing
typer.secho("\n📺 Encrypted RTSPS Viewing:", fg=typer.colors.GREEN, bold=True)
- typer.secho("Use in OBS or other video platform- encrypted", fg=typer.colors.GREEN, bold=True)
- view_url = f"rtsps://{creds['read_user']}:{creds['read_pass']}@{host}:8322/{path}"
+ view_url = f"rtsps://{host}:8322/{path}"
typer.echo(f" URL: {view_url}")
+ typer.echo(f" User: {creds['read_user']}")
+ typer.echo(" Pass: (use: surveillance credentials show-stream)")
typer.echo(f" • VLC: File > Open Network > {view_url}")
- typer.echo(f" • OBS: Souces > + > Media Source > Uncheck local File > add RTSP URL to input >\n {view_url}")
+ typer.echo(
+ " • OBS: Sources > + > Media Source > uncheck local file > paste URL"
+ )
typer.secho("\n🌐 HLS Viewing (browser):", fg=typer.colors.MAGENTA, bold=True)
- typer.secho("Use in OBS or other video platform- encrypted", fg=typer.colors.MAGENTA, bold=True)
hls_url = f"http://{host}:8888/{path}/index.m3u8"
- hls_auth_url = f"http://{creds['read_user']}:{creds['read_pass']}@{host}:8888/{path}/index.m3u8"
typer.echo(f" URL: {hls_url}")
- typer.echo(f" Auth: {creds['read_user']} / {creds['read_pass']}")
- typer.echo(f" Direct URL: {hls_auth_url}")
-
- # Unencrypted RTSP Connection Settings
- typer.secho("\n🎥 Unencrypted RTSP Connection Settings:", fg=typer.colors.GREEN, bold=True)
- typer.secho("Use in phone apps (e.g. Larix Broadcaster) or other cameras - unencrypted", fg=typer.colors.GREEN, bold=True)
+ typer.echo(f" Auth user: {creds['read_user']}")
+ typer.echo(" Auth pass: (use: surveillance credentials show-stream)")
+
+ typer.secho(
+ "\n🎥 Unencrypted RTSP Connection Settings:",
+ fg=typer.colors.GREEN,
+ bold=True,
+ )
typer.echo(f" URL: {base_url}")
typer.echo(f" Username: {creds['publish_user']}")
- typer.echo(f" Password: {creds['publish_pass']}")
+ typer.echo(" Password: (use: surveillance credentials show-stream)")
+
+
+def show_stream_credentials(force: bool = False) -> None:
+ """Print publisher/viewer stream passwords once (TTY only unless --force)."""
+ from .credentials import get_credentials
+
+ if not force and not sys.stdout.isatty():
+ typer.secho(
+ "Refusing to print secrets to a non-TTY. Pass --force to override.",
+ fg=typer.colors.RED,
+ )
+ raise typer.Exit(1)
- # Viewer URL (embedded credentials)
- typer.secho("\n👀 Viewer URL (embedded credentials):", fg=typer.colors.BLUE, bold=True)
- typer.secho("Use in OBS or other video platform- unencrypted", fg=typer.colors.BLUE, bold=True)
- typer.echo(f" {view_url}")
+ creds = get_credentials()
+ typer.secho("Stream credentials (MediaMTX) — treat as secrets", fg=typer.colors.YELLOW)
+ typer.echo(f" Publisher user: {creds['publish_user']}")
+ typer.echo(f" Publisher pass: {creds['publish_pass']}")
+ typer.echo(f" Viewer user: {creds['read_user']}")
+ typer.echo(f" Viewer pass: {creds['read_pass']}")
diff --git a/video-feed/videofeed/visualizer.py b/video-feed/videofeed/visualizer.py
index 6de3619..ab7797e 100644
--- a/video-feed/videofeed/visualizer.py
+++ b/video-feed/videofeed/visualizer.py
@@ -7,14 +7,20 @@
import time
from typing import List, Optional
-from fastapi import FastAPI, HTTPException
+from fastapi import Depends, FastAPI, HTTPException, Request
from fastapi.middleware.cors import CORSMiddleware
+from fastapi.responses import JSONResponse
import uvicorn
from videofeed.detector import DetectorManager
from videofeed.recorder import RecordingManager
from videofeed.api import RecordingsAPI
from videofeed.utils import detect_host_ip
+from videofeed.auth_gate import (
+ AuthMiddleware,
+ AuthPrincipal,
+ require_read,
+)
# Import route modules
from videofeed.routes import (
@@ -38,29 +44,43 @@
# Create FastAPI app
app = FastAPI(title="Video Feed API")
+# Phase 0: Secure=False on plain HTTP (trusted LAN). Set True when TLS terminates here.
+app.state.secure_cookies = False
+
# Get host IP for CORS configuration
host_ip = detect_host_ip()
-# Configure CORS middleware with restricted origins
+# Configure CORS middleware with restricted origins (same-origin dashboard primary)
allowed_origins = [
"http://localhost:8080",
"http://127.0.0.1:8080",
f"http://{host_ip}:8080",
- "http://localhost:3000", # If you have a separate frontend
- "http://127.0.0.1:3000",
]
app.add_middleware(
CORSMiddleware,
- allow_origins=allowed_origins, # ✅ Restricted to specific origins
+ allow_origins=allowed_origins,
allow_credentials=True,
- allow_methods=["GET", "POST", "DELETE", "PUT"], # ✅ Specific methods only
- allow_headers=["Content-Type", "Authorization", "Cookie"], # ✅ Specific headers
- max_age=3600, # Cache preflight requests for 1 hour
+ allow_methods=["GET", "POST", "DELETE", "PUT"],
+ allow_headers=["Content-Type", "Authorization", "Cookie"],
+ max_age=3600,
)
-# CORS configured silently - no need to log on every startup
-# logger.info(f"CORS configured for origins: {allowed_origins}")
+# Auth gate (outermost after CORS — added last so it runs first on request)
+app.add_middleware(AuthMiddleware)
+
+
+@app.exception_handler(Exception)
+async def unhandled_exception_handler(request: Request, exc: Exception):
+ """Never leak stack traces or paths to clients (H2)."""
+ if isinstance(exc, HTTPException):
+ return JSONResponse(status_code=exc.status_code, content={"detail": exc.detail})
+ logger.error("Unhandled error on %s: %s", request.url.path, exc, exc_info=True)
+ return JSONResponse(
+ status_code=500,
+ content={"error": {"code": "internal", "message": "Internal server error"}},
+ )
+
# Include all route modules
app.include_router(video_router)
@@ -69,7 +89,6 @@
app.include_router(recordings_router)
app.include_router(statistics_router)
app.include_router(auth_router)
-
# Global instances
detector_manager = None
recordings_api = None
@@ -94,32 +113,36 @@ def set_detector_manager(manager):
@app.get("/status")
-async def get_status(feed: Optional[str] = None):
+async def get_status(
+ feed: Optional[str] = None,
+ _principal: AuthPrincipal = Depends(require_read),
+):
"""Get the detector status for one or all feeds."""
global detector_manager
if detector_manager is None:
raise HTTPException(status_code=503, detail="Detector manager not initialized")
-
+
return detector_manager.get_detector_status(feed)
@app.get("/feeds")
-async def get_feeds():
+async def get_feeds(
+ _principal: AuthPrincipal = Depends(require_read),
+):
"""Get information about all available feeds."""
global detector_manager
if detector_manager is None:
raise HTTPException(status_code=503, detail="Detector manager not initialized")
-
+
feeds = {}
for detector_id, detector in detector_manager.get_all_detectors().items():
feeds[detector_id] = {
"id": detector_id,
"name": detector.get_name(),
- "source": detector._mask_credentials(detector.source_url)
+ "source": detector._mask_credentials(detector.source_url),
}
-
- return {"feeds": feeds, "default": detector_manager.default_detector_id}
+ return {"feeds": feeds, "default": detector_manager.default_detector_id}
# Create a shutdown event to coordinate graceful shutdown
shutdown_requested = threading.Event()
@@ -144,7 +167,7 @@ def force_exit():
def start_visualizer(
rtsp_urls: List[str],
- host: str = "0.0.0.0",
+ host: str = "127.0.0.1",
port: int = 8000,
model_path: str = "yolov8n.pt",
confidence: float = 0.4,
From 9827201b5f0561646a383bdb44371d4db084d0e7 Mon Sep 17 00:00:00 2001
From: Soos3D <99700157+soos3d@users.noreply.github.com>
Date: Mon, 10 Aug 2026 13:21:47 -0400
Subject: [PATCH 2/2] fix: drop cv2-dependent DB tests from slim CI job
test_db_connection imports RecordingManager which requires opencv;
the API CI job only installs the web-test stack (no torch/cv2).
---
.github/workflows/ci.yml | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index a011a63..0a15d1a 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -48,10 +48,9 @@ jobs:
env:
PYTHONPATH: .
run: |
+ # Only Phase 0 API tests: test_db*.py import recorder → cv2 (full stack)
pytest \
tests/test_api_characterization.py \
tests/test_auth.py \
tests/test_config_security.py \
- tests/test_db.py \
- tests/test_db_connection.py \
- -m "not slow and not requires_mediamtx"
+ -m "not slow and not requires_mediamtx"
\ No newline at end of file