1use super::descriptor_body;
7use crate::error::{Error, Result};
8use crate::text::DvbText;
9use dvb_common::{Parse, Serialize};
10
11pub const TAG: u8 = 0x48;
13const HEADER_LEN: usize = 2;
14
15#[derive(Debug, Clone, Copy, PartialEq, Eq)]
25#[cfg_attr(feature = "serde", derive(serde::Serialize))]
26#[non_exhaustive]
27pub enum ServiceType {
28 DigitalTelevision,
30 DigitalRadioSound,
32 Teletext,
34 NvodReference,
36 NvodTimeShifted,
38 Mosaic,
40 FmRadio,
42 DvbSrm,
44 AdvancedCodecDigitalRadio,
46 AvcMosaic,
48 DataBroadcast,
50 RcsMap,
52 RcsFls,
54 Mhp,
56 HdDigitalTelevision,
58 AvcSdDigitalTelevision,
60 AvcSdNvodTimeShifted,
62 AvcSdNvodReference,
64 AvcHdDigitalTelevision,
66 AvcHdNvodTimeShifted,
68 AvcHdNvodReference,
70 AvcFrameCompatiblePlanoStereoscopicHd,
73 AvcFrameCompatiblePlanoStereoscopicHdNvodTimeShifted,
76 AvcFrameCompatiblePlanoStereoscopicHdNvodReference,
79 HevcDigitalTelevision,
81 HevcUhdDigitalTelevision,
83 VvcDigitalTelevision,
85 Avs3DigitalTelevision,
87 Reserved(u8),
89}
90
91impl ServiceType {
92 #[must_use]
93 pub fn from_u8(v: u8) -> Self {
96 match v {
97 0x01 => Self::DigitalTelevision,
98 0x02 => Self::DigitalRadioSound,
99 0x03 => Self::Teletext,
100 0x04 => Self::NvodReference,
101 0x05 => Self::NvodTimeShifted,
102 0x06 => Self::Mosaic,
103 0x07 => Self::FmRadio,
104 0x08 => Self::DvbSrm,
105 0x0A => Self::AdvancedCodecDigitalRadio,
106 0x0B => Self::AvcMosaic,
107 0x0C => Self::DataBroadcast,
108 0x0E => Self::RcsMap,
109 0x0F => Self::RcsFls,
110 0x10 => Self::Mhp,
111 0x11 => Self::HdDigitalTelevision,
112 0x16 => Self::AvcSdDigitalTelevision,
113 0x17 => Self::AvcSdNvodTimeShifted,
114 0x18 => Self::AvcSdNvodReference,
115 0x19 => Self::AvcHdDigitalTelevision,
116 0x1A => Self::AvcHdNvodTimeShifted,
117 0x1B => Self::AvcHdNvodReference,
118 0x1C => Self::AvcFrameCompatiblePlanoStereoscopicHd,
119 0x1D => Self::AvcFrameCompatiblePlanoStereoscopicHdNvodTimeShifted,
120 0x1E => Self::AvcFrameCompatiblePlanoStereoscopicHdNvodReference,
121 0x1F => Self::HevcDigitalTelevision,
122 0x20 => Self::HevcUhdDigitalTelevision,
123 0x21 => Self::VvcDigitalTelevision,
124 0x22 => Self::Avs3DigitalTelevision,
125 v => Self::Reserved(v),
126 }
127 }
128
129 #[must_use]
130 pub fn to_u8(self) -> u8 {
132 match self {
133 Self::DigitalTelevision => 0x01,
134 Self::DigitalRadioSound => 0x02,
135 Self::Teletext => 0x03,
136 Self::NvodReference => 0x04,
137 Self::NvodTimeShifted => 0x05,
138 Self::Mosaic => 0x06,
139 Self::FmRadio => 0x07,
140 Self::DvbSrm => 0x08,
141 Self::AdvancedCodecDigitalRadio => 0x0A,
142 Self::AvcMosaic => 0x0B,
143 Self::DataBroadcast => 0x0C,
144 Self::RcsMap => 0x0E,
145 Self::RcsFls => 0x0F,
146 Self::Mhp => 0x10,
147 Self::HdDigitalTelevision => 0x11,
148 Self::AvcSdDigitalTelevision => 0x16,
149 Self::AvcSdNvodTimeShifted => 0x17,
150 Self::AvcSdNvodReference => 0x18,
151 Self::AvcHdDigitalTelevision => 0x19,
152 Self::AvcHdNvodTimeShifted => 0x1A,
153 Self::AvcHdNvodReference => 0x1B,
154 Self::AvcFrameCompatiblePlanoStereoscopicHd => 0x1C,
155 Self::AvcFrameCompatiblePlanoStereoscopicHdNvodTimeShifted => 0x1D,
156 Self::AvcFrameCompatiblePlanoStereoscopicHdNvodReference => 0x1E,
157 Self::HevcDigitalTelevision => 0x1F,
158 Self::HevcUhdDigitalTelevision => 0x20,
159 Self::VvcDigitalTelevision => 0x21,
160 Self::Avs3DigitalTelevision => 0x22,
161 Self::Reserved(v) => v,
162 }
163 }
164
165 #[must_use]
166 pub fn name(self) -> &'static str {
168 match self {
169 Self::DigitalTelevision => "digital television service",
170 Self::DigitalRadioSound => "digital radio sound service",
171 Self::Teletext => "teletext service",
172 Self::NvodReference => "NVOD reference service",
173 Self::NvodTimeShifted => "NVOD time-shifted service",
174 Self::Mosaic => "mosaic service",
175 Self::FmRadio => "FM radio service",
176 Self::DvbSrm => "DVB SRM service",
177 Self::AdvancedCodecDigitalRadio => "advanced codec digital radio sound service",
178 Self::AvcMosaic => "H.264/AVC mosaic service",
179 Self::DataBroadcast => "data broadcast service",
180 Self::RcsMap => "RCS Map",
181 Self::RcsFls => "RCS FLS",
182 Self::Mhp => "DVB MHP service",
183 Self::HdDigitalTelevision => "HD digital television service",
184 Self::AvcSdDigitalTelevision => "H.264/AVC SD digital television service",
185 Self::AvcSdNvodTimeShifted => "H.264/AVC SD NVOD time-shifted service",
186 Self::AvcSdNvodReference => "H.264/AVC SD NVOD reference service",
187 Self::AvcHdDigitalTelevision => "H.264/AVC HD digital television service",
188 Self::AvcHdNvodTimeShifted => "H.264/AVC HD NVOD time-shifted service",
189 Self::AvcHdNvodReference => "H.264/AVC HD NVOD reference service",
190 Self::AvcFrameCompatiblePlanoStereoscopicHd => {
191 "H.264/AVC frame compatible plano-stereoscopic HD digital television service"
192 }
193 Self::AvcFrameCompatiblePlanoStereoscopicHdNvodTimeShifted => {
194 "H.264/AVC frame compatible plano-stereoscopic HD NVOD time-shifted service"
195 }
196 Self::AvcFrameCompatiblePlanoStereoscopicHdNvodReference => {
197 "H.264/AVC frame compatible plano-stereoscopic HD NVOD reference service"
198 }
199 Self::HevcDigitalTelevision => "HEVC digital television service",
200 Self::HevcUhdDigitalTelevision => "HEVC UHD digital television service",
201 Self::VvcDigitalTelevision => "VVC digital television service",
202 Self::Avs3DigitalTelevision => "AVS3 digital television service",
203 Self::Reserved(_) => "reserved",
204 }
205 }
206}
207
208#[derive(Debug, Clone, PartialEq, Eq)]
210#[cfg_attr(feature = "serde", derive(serde::Serialize))]
211#[cfg_attr(feature = "yoke", derive(yoke::Yokeable))]
212pub struct ServiceDescriptor<'a> {
213 pub service_type: ServiceType,
215 pub provider_name: DvbText<'a>,
217 pub service_name: DvbText<'a>,
219}
220
221impl<'a> Parse<'a> for ServiceDescriptor<'a> {
222 type Error = crate::error::Error;
223 fn parse(bytes: &'a [u8]) -> Result<Self> {
224 let body = descriptor_body(
225 bytes,
226 TAG,
227 "ServiceDescriptor",
228 "unexpected tag for service_descriptor",
229 )?;
230 if body.len() < 3 {
231 return Err(Error::InvalidDescriptor {
232 tag: TAG,
233 reason: "service_descriptor body too short for service_type + two length fields",
234 });
235 }
236 let service_type = ServiceType::from_u8(body[0]);
237 let provider_len = body[1] as usize;
238 let provider_end = 2 + provider_len;
239 if provider_end + 1 > body.len() {
240 return Err(Error::InvalidDescriptor {
241 tag: TAG,
242 reason: "service_provider_name_length runs past descriptor end",
243 });
244 }
245 let provider_name = DvbText::new(&body[2..provider_end]);
246 let service_len = body[provider_end] as usize;
247 let service_end = provider_end + 1 + service_len;
248 if service_end > body.len() {
249 return Err(Error::InvalidDescriptor {
250 tag: TAG,
251 reason: "service_name_length runs past descriptor end",
252 });
253 }
254 let service_name = DvbText::new(&body[provider_end + 1..service_end]);
255 Ok(Self {
256 service_type,
257 provider_name,
258 service_name,
259 })
260 }
261}
262
263impl Serialize for ServiceDescriptor<'_> {
264 type Error = crate::error::Error;
265 fn serialized_len(&self) -> usize {
266 HEADER_LEN + 1 + 1 + self.provider_name.len() + 1 + self.service_name.len()
267 }
268
269 fn serialize_into(&self, buf: &mut [u8]) -> Result<usize> {
270 let len = self.serialized_len();
271 if buf.len() < len {
272 return Err(Error::OutputBufferTooSmall {
273 need: len,
274 have: buf.len(),
275 });
276 }
277 buf[0] = TAG;
278 buf[1] = (len - HEADER_LEN) as u8;
279 buf[2] = self.service_type.to_u8();
280 buf[3] = self.provider_name.len() as u8;
281 let p_start = 4;
282 let p_end = p_start + self.provider_name.len();
283 buf[p_start..p_end].copy_from_slice(self.provider_name.raw());
284 buf[p_end] = self.service_name.len() as u8;
285 let s_start = p_end + 1;
286 buf[s_start..s_start + self.service_name.len()].copy_from_slice(self.service_name.raw());
287 Ok(len)
288 }
289}
290impl<'a> crate::traits::DescriptorDef<'a> for ServiceDescriptor<'a> {
291 const TAG: u8 = TAG;
292 const NAME: &'static str = "SERVICE";
293}
294
295#[cfg(test)]
296mod tests {
297 use super::*;
298
299 #[test]
300 fn parse_extracts_all_fields() {
301 let bytes = [
303 TAG, 10, 0x01, 4, b'E', b'U', b'T', b'E', 3, b'T', b'F', b'1',
304 ];
305 let d = ServiceDescriptor::parse(&bytes).unwrap();
306 assert_eq!(d.service_type, ServiceType::DigitalTelevision);
307 assert_eq!(d.provider_name.raw(), b"EUTE");
308 assert_eq!(d.service_name.raw(), b"TF1");
309 }
310
311 #[test]
312 fn parse_rejects_wrong_tag() {
313 let err = ServiceDescriptor::parse(&[0x49, 0]).unwrap_err();
314 assert!(matches!(err, Error::InvalidDescriptor { tag: 0x49, .. }));
315 }
316
317 #[test]
318 fn parse_rejects_short_header() {
319 let err = ServiceDescriptor::parse(&[TAG]).unwrap_err();
320 assert!(matches!(err, Error::BufferTooShort { .. }));
321 }
322
323 #[test]
324 fn parse_rejects_truncated_body() {
325 let err = ServiceDescriptor::parse(&[TAG, 5, 0x01, 0xFF]).unwrap_err();
326 assert!(matches!(err, Error::BufferTooShort { .. }));
327 }
328
329 #[test]
330 fn parse_rejects_provider_length_overrun() {
331 let bytes = [TAG, 5, 0x01, 100, b'A', b'B', b'C'];
333 let err = ServiceDescriptor::parse(&bytes).unwrap_err();
334 assert!(matches!(err, Error::InvalidDescriptor { .. }));
335 }
336
337 #[test]
338 fn empty_provider_and_service_names_valid() {
339 let bytes = [TAG, 3, 0x01, 0, 0];
340 let d = ServiceDescriptor::parse(&bytes).unwrap();
341 assert_eq!(d.service_type, ServiceType::DigitalTelevision);
342 assert!(d.provider_name.raw().is_empty());
343 assert!(d.service_name.raw().is_empty());
344 }
345
346 #[test]
347 fn serialize_round_trip() {
348 let d = ServiceDescriptor {
349 service_type: ServiceType::AvcHdDigitalTelevision,
350 provider_name: DvbText::new(b"BBC"),
351 service_name: DvbText::new(b"BBC ONE HD"),
352 };
353 let mut buf = vec![0u8; d.serialized_len()];
354 d.serialize_into(&mut buf).unwrap();
355 let re = ServiceDescriptor::parse(&buf).unwrap();
356 assert_eq!(d, re);
357 }
358
359 #[test]
360 fn descriptor_length_matches_payload() {
361 let d = ServiceDescriptor {
362 service_type: ServiceType::DigitalTelevision,
363 provider_name: DvbText::new(b"AA"),
364 service_name: DvbText::new(b"BBB"),
365 };
366 assert_eq!(d.serialized_len() - 2, 8);
368 }
369
370 #[test]
371 fn service_type_full_range_round_trip() {
372 for b in 0..=0xFF_u8 {
373 let st = ServiceType::from_u8(b);
374 assert_eq!(st.to_u8(), b, "round-trip failed for byte 0x{b:02X}");
375 }
376 }
377
378 #[test]
379 fn service_type_name_for_known() {
380 assert_eq!(
381 ServiceType::DigitalTelevision.name(),
382 "digital television service"
383 );
384 assert_eq!(
385 ServiceType::HevcDigitalTelevision.name(),
386 "HEVC digital television service"
387 );
388 assert_eq!(
389 ServiceType::HevcUhdDigitalTelevision.name(),
390 "HEVC UHD digital television service"
391 );
392 assert_eq!(ServiceType::HevcUhdDigitalTelevision.to_u8(), 0x20);
393 assert_eq!(
394 ServiceType::from_u8(0x20),
395 ServiceType::HevcUhdDigitalTelevision
396 );
397 assert_eq!(ServiceType::Reserved(0x55).name(), "reserved");
398 }
399}