moq-mux 0.5.5

Media muxers and demuxers for MoQ
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

//! SCTE-35 application catalog extension for ingesting MPEG-TS splice cues.

use std::collections::BTreeMap;

use serde::{Deserialize, Serialize};

use crate::catalog::hang::CatalogExt;

/// SCTE-35 splice cue tracks: a map of renditions (one per MPEG-TS PID), each
/// carried as the verbatim `splice_info_section` bytes.
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Default)]
#[serde(rename_all = "camelCase")]
pub struct Cues {
	pub renditions: BTreeMap<String, Config>,
}

impl Cues {
	/// Omitted from the catalog when empty, so a broadcast without cues stays byte-identical.
	pub fn is_empty(&self) -> bool {
		self.renditions.is_empty()
	}
}

/// One SCTE-35 cue track. Records how the verbatim section was framed; the
/// stream_type (0x86) and CUEI signaling are implicit to SCTE-35.
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Default)]
#[serde(rename_all = "camelCase")]
#[non_exhaustive]
pub struct Config {
	#[serde(default)]
	pub container: hang::catalog::Container,
}

impl Config {
	pub fn new() -> Self {
		Self::default()
	}
}

/// The application catalog extension carrying the `scte35` section. Empty by
/// default, so the section is omitted until a cue track is added.
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Default)]
pub struct Ext {
	#[serde(default, skip_serializing_if = "Cues::is_empty")]
	pub scte35: Cues,
}

impl CatalogExt for Ext {}

/// An extension that can carry an SCTE-35 catalog section.
///
/// Implement this for an application extension to compose SCTE-35 with
/// additional sections.
pub trait Catalog: CatalogExt {
	/// The section to write cues into, or `None` for an extension that doesn't carry them.
	///
	/// Keep this stable per catalog: an importer samples support once at construction, so a
	/// result that flips between `Some` and `None` mid-stream would disable cues or fail.
	fn scte35_mut(&mut self) -> Option<&mut Cues>;
}

impl Catalog for () {
	fn scte35_mut(&mut self) -> Option<&mut Cues> {
		None
	}
}

impl Catalog for Ext {
	fn scte35_mut(&mut self) -> Option<&mut Cues> {
		Some(&mut self.scte35)
	}
}