use crate::error::PfcpError;
use crate::ie::{Ie, IeType};
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct StartTime {
pub timestamp: u32,
}
impl StartTime {
pub fn new(timestamp: u32) -> Self {
Self { timestamp }
}
pub fn marshal_len(&self) -> usize {
4 }
pub fn marshal(&self) -> Vec<u8> {
self.timestamp.to_be_bytes().to_vec()
}
pub fn marshal_to(&self, buf: &mut Vec<u8>) {
buf.extend_from_slice(&self.timestamp.to_be_bytes());
}
pub fn unmarshal(data: &[u8]) -> Result<Self, PfcpError> {
if data.len() < 4 {
return Err(PfcpError::invalid_length(
"Start Time",
IeType::StartTime,
4,
data.len(),
));
}
let bytes: [u8; 4] = data[0..4].try_into().unwrap();
let timestamp = u32::from_be_bytes(bytes);
Ok(Self { timestamp })
}
pub fn to_ie(&self) -> Ie {
Ie::new(IeType::StartTime, self.marshal())
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_start_time_new() {
let timestamp = 0x12345678;
let st = StartTime::new(timestamp);
assert_eq!(st.timestamp, timestamp);
}
#[test]
fn test_start_time_marshal_unmarshal() {
let timestamp = 0xABCDEF01;
let st = StartTime::new(timestamp);
let data = st.marshal();
assert_eq!(data.len(), 4);
let unmarshaled = StartTime::unmarshal(&data).unwrap();
assert_eq!(st, unmarshaled);
assert_eq!(unmarshaled.timestamp, timestamp);
}
#[test]
fn test_start_time_marshal_zero() {
let st = StartTime::new(0);
let data = st.marshal();
let unmarshaled = StartTime::unmarshal(&data).unwrap();
assert_eq!(st, unmarshaled);
assert_eq!(unmarshaled.timestamp, 0);
}
#[test]
fn test_start_time_marshal_max_value() {
let st = StartTime::new(u32::MAX);
let data = st.marshal();
let unmarshaled = StartTime::unmarshal(&data).unwrap();
assert_eq!(st, unmarshaled);
assert_eq!(unmarshaled.timestamp, u32::MAX);
}
#[test]
fn test_start_time_to_ie() {
let timestamp = 0x87654321;
let st = StartTime::new(timestamp);
let ie = st.to_ie();
assert_eq!(ie.ie_type, IeType::StartTime);
}
#[test]
fn test_start_time_unmarshal_insufficient_data() {
let data = [0x00, 0x01, 0x02]; let result = StartTime::unmarshal(&data);
assert!(result.is_err());
let err = result.unwrap_err();
assert!(matches!(err, PfcpError::InvalidLength { .. }));
}
#[test]
fn test_start_time_unmarshal_empty_data() {
let data = [];
let result = StartTime::unmarshal(&data);
assert!(result.is_err());
let err = result.unwrap_err();
assert!(matches!(err, PfcpError::InvalidLength { .. }));
}
#[test]
fn test_start_time_marshal_len() {
let st = StartTime::new(42);
assert_eq!(st.marshal_len(), 4);
}
#[test]
fn test_start_time_round_trip_various_values() {
let test_values = [
0,
1,
0x12345678,
0xABCDEF01,
0x87654321,
0xFFFFFFFF,
u32::MAX,
];
for &value in &test_values {
let st = StartTime::new(value);
let data = st.marshal();
let unmarshaled = StartTime::unmarshal(&data).unwrap();
assert_eq!(st, unmarshaled);
}
}
#[test]
fn test_start_time_byte_order() {
let st = StartTime::new(0x12345678);
let data = st.marshal();
assert_eq!(data, vec![0x12, 0x34, 0x56, 0x78]);
}
#[test]
fn test_start_time_3gpp_timestamps() {
let current_time = StartTime::new(0x60000000); let future_time = StartTime::new(0x70000000);
let past_time = StartTime::new(0x50000000);
for time in [current_time, future_time, past_time] {
let data = time.marshal();
let unmarshaled = StartTime::unmarshal(&data).unwrap();
assert_eq!(time, unmarshaled);
}
}
}