zgaetano/deltacast-sdi-recorder
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: add multi-destination SRT support and per-port SCTE35

Browse source
This commit is contained in:
Zac Gaetano 2026-04-14 10:00:46 -04:00
parent 6b3ad13269
commit 7377aee6fa
1 changed files with 26 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
backend/app/models.py
View file

@ -1,7 +1,7 @@
from enum import Enum
from datetime import datetime
from pydantic import BaseModel, Field, ConfigDict
from typing import Optional
from typing import Optional, List
class CodecType(str, Enum):
@ -12,6 +12,15 @@ class CodecType(str, Enum):
H264 = "h264"
class SRTDestination(BaseModel):
"""A single SRT output destination"""
model_config = ConfigDict(use_enum_values=False)
url: str = Field(..., description="SRT destination URL (srt://host:port)")
label: str = Field(default="", description="Human-readable label for this destination")
enabled: bool = Field(default=True, description="Whether this destination is active")
class RecorderConfig(BaseModel):
"""Configuration for a recorder port"""
model_config = ConfigDict(use_enum_values=False)
@ -30,8 +39,13 @@ class RecorderConfig(BaseModel):
srt_enabled: bool = Field(
default=False, description="Enable SRT streaming output"
)
# Legacy single destination (kept for backwards compat)
srt_destination: Optional[str] = Field(
default=None, description="SRT destination address (host:port)"
default=None, description="SRT destination address (host:port) — use srt_destinations for multi"
)
# Multi-destination
srt_destinations: List[SRTDestination] = Field(
default_factory=list, description="List of SRT output destinations"
)
preview_enabled: bool = Field(
default=True, description="Enable live HLS preview"
@ -50,6 +64,9 @@ class PortStatus(BaseModel):
uptime_seconds: int = Field(..., description="Recording uptime in seconds")
current_file: str = Field(..., description="Current output file path")
codec: CodecType = Field(..., description="Codec being used")
srt_destinations: List[str] = Field(
default_factory=list, description="Active SRT destination URLs"
)
class SCTE35Marker(BaseModel):
@ -74,3 +91,9 @@ class SCTE35Marker(BaseModel):
webhook_url: Optional[str] = Field(
default=None, description="Webhook URL to notify on ad break"
)
port_index: Optional[int] = Field(
default=None, description="Port index this marker was injected on (None = global)"
)
srt_destination_url: Optional[str] = Field(
default=None, description="Specific SRT destination URL this marker targets (None = all)"
)