use super::descriptor_body;
use crate::error::{Error, Result};
use broadcast_common::len::need_out;
use broadcast_common::{Parse, Serialize};
pub const TAG: u8 = 0x0B;
const HEADER_LEN: usize = 2;
const BODY_LEN: u8 = 2;
pub const RESERVED_1_DEFAULT: u8 = 0b1;
pub const RESERVED_5_DEFAULT: u8 = 0b1_1111;
const RESERVED_1_MASK: u8 = 0x01;
const RESERVED_5_MASK: u8 = 0x1F;
#[derive(Debug, Clone, PartialEq, Eq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize))]
#[cfg_attr(feature = "yoke", derive(yoke::Yokeable))]
#[non_exhaustive]
pub struct SystemClockDescriptor {
pub external_clock_reference_indicator: bool,
pub clock_accuracy_integer: u8,
pub clock_accuracy_exponent: u8,
pub reserved_1: u8,
pub reserved_5: u8,
}
impl SystemClockDescriptor {
#[must_use]
pub const fn new(
external_clock_reference_indicator: bool,
clock_accuracy_integer: u8,
clock_accuracy_exponent: u8,
) -> Self {
Self {
external_clock_reference_indicator,
clock_accuracy_integer,
clock_accuracy_exponent,
reserved_1: RESERVED_1_DEFAULT,
reserved_5: RESERVED_5_DEFAULT,
}
}
}
impl<'a> Parse<'a> for SystemClockDescriptor {
type Error = crate::error::Error;
fn parse(bytes: &'a [u8]) -> Result<Self> {
let body = descriptor_body(
bytes,
TAG,
"SystemClockDescriptor",
"unexpected tag for system_clock_descriptor",
)?;
if body.len() != BODY_LEN as usize {
return Err(Error::InvalidDescriptor {
tag: TAG,
reason: "system_clock_descriptor length must equal 2",
});
}
let b0 = body[0];
let external_clock_reference_indicator = (b0 & 0x80) != 0;
let clock_accuracy_integer = b0 & 0x3F;
let b1 = body[1];
let clock_accuracy_exponent = b1 >> 5;
Ok(Self {
external_clock_reference_indicator,
clock_accuracy_integer,
clock_accuracy_exponent,
reserved_1: (b0 >> 6) & RESERVED_1_MASK,
reserved_5: b1 & RESERVED_5_MASK,
})
}
}
impl Serialize for SystemClockDescriptor {
type Error = crate::error::Error;
fn serialized_len(&self) -> usize {
HEADER_LEN + (BODY_LEN as usize)
}
fn serialize_into(&self, buf: &mut [u8]) -> Result<usize> {
let len = self.serialized_len();
need_out(buf, len)?;
buf[0] = TAG;
buf[1] = BODY_LEN;
buf[HEADER_LEN] = ((self.external_clock_reference_indicator as u8) << 7)
| (broadcast_common::len::fit_mask(self.reserved_1, RESERVED_1_MASK, "reserved_1")?
<< 6)
| broadcast_common::len::fit_mask(
self.clock_accuracy_integer,
0x3F,
"clock_accuracy_integer",
)?;
buf[HEADER_LEN + 1] = (broadcast_common::len::fit_mask(
self.clock_accuracy_exponent,
0x07,
"clock_accuracy_exponent",
)? << 5)
| broadcast_common::len::fit_mask(self.reserved_5, RESERVED_5_MASK, "reserved_5")?;
Ok(len)
}
}
impl crate::traits::DescriptorDef<'_> for SystemClockDescriptor {
const TAG: u8 = TAG;
const NAME: &'static str = "SYSTEM_CLOCK";
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn parse() {
let bytes = [
TAG,
2,
0b1011_1111, 0b101_00000, ];
let d = SystemClockDescriptor::parse(&bytes).unwrap();
assert!(d.external_clock_reference_indicator);
assert_eq!(d.clock_accuracy_integer, 63);
assert_eq!(d.clock_accuracy_exponent, 5);
}
#[test]
fn serialize_round_trip() {
let d = SystemClockDescriptor::new(false, 42, 2);
let mut buf = vec![0u8; d.serialized_len()];
d.serialize_into(&mut buf).unwrap();
let reparsed = SystemClockDescriptor::parse(&buf).unwrap();
assert_eq!(d, reparsed);
}
#[test]
fn parse_rejects_wrong_tag() {
let err = SystemClockDescriptor::parse(&[0x0C, 2, 0, 0]).unwrap_err();
assert!(matches!(err, Error::InvalidDescriptor { tag: 0x0C, .. }));
}
#[test]
fn parse_rejects_wrong_length() {
let err = SystemClockDescriptor::parse(&[TAG, 3, 0, 0, 0]).unwrap_err();
assert!(matches!(err, Error::InvalidDescriptor { tag: TAG, .. }));
}
#[test]
fn serialize_rejects_small_buffer() {
let d = SystemClockDescriptor::new(false, 0, 0);
let mut tiny = vec![0u8; 2];
let err = d.serialize_into(&mut tiny).unwrap_err();
assert!(matches!(err, Error::OutputBufferTooSmall(..)));
}
#[test]
fn system_clock_reserved_preserved() {
for r1 in 0u8..=1 {
for r5 in [0u8, 1, 0x0A, 0x15, 0x1F] {
let bytes = [TAG, 2, 0x80 | (r1 << 6) | 0x3F, 0xA0 | r5];
let d = SystemClockDescriptor::parse(&bytes).unwrap();
assert_eq!((d.reserved_1, d.reserved_5), (r1, r5));
let mut out = vec![0u8; d.serialized_len()];
d.serialize_into(&mut out).unwrap();
assert_eq!(out, bytes);
}
}
}
#[test]
fn system_clock_default_is_spec_value() {
let d = SystemClockDescriptor::new(true, 63, 5);
let mut out = vec![0u8; d.serialized_len()];
d.serialize_into(&mut out).unwrap();
assert_eq!(out, [TAG, 2, 0xFF, 0xBF]);
let dz = SystemClockDescriptor::parse(&[TAG, 2, 0xBF, 0xA0]).unwrap();
assert_eq!(dz.reserved_1, 0);
assert_ne!(dz, d);
}
}