This commit is contained in:
parent
28ba4f887d
commit
5631372e58
@ -8,6 +8,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
|
|||||||
|
|
||||||
# [unreleased]
|
# [unreleased]
|
||||||
|
|
||||||
|
# [v0.2.0] 13.09.2022
|
||||||
|
|
||||||
## Added
|
## Added
|
||||||
|
|
||||||
- Basic support for ECSS enumeration types for u8, u16, u32 and u64
|
- Basic support for ECSS enumeration types for u8, u16, u32 and u64
|
||||||
@ -15,6 +17,9 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
|
|||||||
## Changed
|
## Changed
|
||||||
|
|
||||||
- Better names for generic error enumerations: `PacketError` renamed to `ByteConversionError`
|
- Better names for generic error enumerations: `PacketError` renamed to `ByteConversionError`
|
||||||
|
- `ssc` abbreviations fully replaced by better name `seq_count`
|
||||||
|
- Time module: `CcsdsTimeProvider::date_time` now has `Option<DateTime<Utc>>` as
|
||||||
|
a returnvalue instead of `DateTime<Utc>`
|
||||||
|
|
||||||
# [v0.1.0] 16.08.2022
|
# [v0.1.0] 16.08.2022
|
||||||
|
|
||||||
|
25
src/ecss.rs
25
src/ecss.rs
@ -33,6 +33,22 @@ impl TryFrom<u8> for PusVersion {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(Debug, Copy, Clone, PartialEq, Eq)]
|
||||||
|
pub enum PacketTypeCodes {
|
||||||
|
Boolean = 1,
|
||||||
|
Enumerated = 2,
|
||||||
|
UnsignedInt = 3,
|
||||||
|
SignedInt = 4,
|
||||||
|
Real = 5,
|
||||||
|
BitString = 6,
|
||||||
|
OctetString = 7,
|
||||||
|
CharString = 8,
|
||||||
|
AbsoluteTime = 9,
|
||||||
|
RelativeTime = 10,
|
||||||
|
Deduced = 11,
|
||||||
|
Packet = 12,
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Debug, Copy, Clone, PartialEq, Eq)]
|
#[derive(Debug, Copy, Clone, PartialEq, Eq)]
|
||||||
pub enum PusError {
|
pub enum PusError {
|
||||||
VersionNotSupported(PusVersion),
|
VersionNotSupported(PusVersion),
|
||||||
@ -142,7 +158,12 @@ macro_rules! sp_header_impls {
|
|||||||
pub(crate) use ccsds_impl;
|
pub(crate) use ccsds_impl;
|
||||||
pub(crate) use sp_header_impls;
|
pub(crate) use sp_header_impls;
|
||||||
|
|
||||||
|
/// Generic trait for ECSS enumeration which consist of a PFC field denoting their length
|
||||||
|
/// and an unsigned value. The trait makes no assumptions about the actual type of the unsigned
|
||||||
|
/// value and only requires implementors to implement a function which writes the enumeration into
|
||||||
|
/// a raw byte format.
|
||||||
pub trait EcssEnumeration {
|
pub trait EcssEnumeration {
|
||||||
|
/// Packet Format Code, which denotes the number of bits of the enumeration
|
||||||
fn pfc(&self) -> u8;
|
fn pfc(&self) -> u8;
|
||||||
fn byte_width(&self) -> usize {
|
fn byte_width(&self) -> usize {
|
||||||
(self.pfc() / 8) as usize
|
(self.pfc() / 8) as usize
|
||||||
@ -192,6 +213,10 @@ pub struct GenericEcssEnumWrapper<TYPE> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl<TYPE> GenericEcssEnumWrapper<TYPE> {
|
impl<TYPE> GenericEcssEnumWrapper<TYPE> {
|
||||||
|
pub const fn ptc() -> PacketTypeCodes {
|
||||||
|
PacketTypeCodes::Enumerated
|
||||||
|
}
|
||||||
|
|
||||||
pub fn new(val: TYPE) -> Self {
|
pub fn new(val: TYPE) -> Self {
|
||||||
Self { val }
|
Self { val }
|
||||||
}
|
}
|
||||||
|
54
src/time.rs
54
src/time.rs
@ -91,9 +91,24 @@ pub trait CcsdsTimeProvider {
|
|||||||
fn p_field(&self) -> (usize, [u8; 2]);
|
fn p_field(&self) -> (usize, [u8; 2]);
|
||||||
fn ccdsd_time_code(&self) -> CcsdsTimeCodes;
|
fn ccdsd_time_code(&self) -> CcsdsTimeCodes;
|
||||||
fn unix_seconds(&self) -> i64;
|
fn unix_seconds(&self) -> i64;
|
||||||
fn date_time(&self) -> DateTime<Utc>;
|
fn date_time(&self) -> Option<DateTime<Utc>>;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// This object is the abstraction for the CCSDS Day Segmented Time Code (CDS).
|
||||||
|
///
|
||||||
|
/// It has the capability to generate and read timestamps as specified in the CCSDS 301.0-B-4
|
||||||
|
/// section 3.3
|
||||||
|
///
|
||||||
|
/// # Example
|
||||||
|
///
|
||||||
|
/// ```
|
||||||
|
/// use spacepackets::time::{CdsShortTimeProvider, TimeWriter};
|
||||||
|
/// use spacepackets::time::CcsdsTimeCodes::Cds;
|
||||||
|
/// let timestamp_now = CdsShortTimeProvider::from_now().unwrap();
|
||||||
|
/// let mut raw_stamp = [0; 7];
|
||||||
|
/// timestamp_now.write_to_bytes(&mut raw_stamp).unwrap();
|
||||||
|
/// assert_eq!((raw_stamp[0] >> 4) & 0b111, Cds as u8);
|
||||||
|
/// ```
|
||||||
#[derive(Debug, Copy, Clone, Default)]
|
#[derive(Debug, Copy, Clone, Default)]
|
||||||
pub struct CdsShortTimeProvider {
|
pub struct CdsShortTimeProvider {
|
||||||
pfield: u8,
|
pfield: u8,
|
||||||
@ -106,7 +121,7 @@ pub struct CdsShortTimeProvider {
|
|||||||
impl CdsShortTimeProvider {
|
impl CdsShortTimeProvider {
|
||||||
pub fn new(ccsds_days: u16, ms_of_day: u32) -> Self {
|
pub fn new(ccsds_days: u16, ms_of_day: u32) -> Self {
|
||||||
let provider = Self {
|
let provider = Self {
|
||||||
pfield: (CcsdsTimeCodes::Cds as u8) << 4,
|
pfield: (Cds as u8) << 4,
|
||||||
ccsds_days,
|
ccsds_days,
|
||||||
ms_of_day,
|
ms_of_day,
|
||||||
unix_seconds: 0,
|
unix_seconds: 0,
|
||||||
@ -192,15 +207,15 @@ impl CcsdsTimeProvider for CdsShortTimeProvider {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fn ccdsd_time_code(&self) -> CcsdsTimeCodes {
|
fn ccdsd_time_code(&self) -> CcsdsTimeCodes {
|
||||||
CcsdsTimeCodes::Cds
|
Cds
|
||||||
}
|
}
|
||||||
|
|
||||||
fn unix_seconds(&self) -> i64 {
|
fn unix_seconds(&self) -> i64 {
|
||||||
self.unix_seconds
|
self.unix_seconds
|
||||||
}
|
}
|
||||||
|
|
||||||
fn date_time(&self) -> DateTime<Utc> {
|
fn date_time(&self) -> Option<DateTime<Utc>> {
|
||||||
self.date_time.expect("Invalid date time")
|
self.date_time
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -235,19 +250,9 @@ impl TimeReader for CdsShortTimeProvider {
|
|||||||
match CcsdsTimeCodes::try_from(pfield >> 4 & 0b111) {
|
match CcsdsTimeCodes::try_from(pfield >> 4 & 0b111) {
|
||||||
Ok(cds_type) => match cds_type {
|
Ok(cds_type) => match cds_type {
|
||||||
Cds => (),
|
Cds => (),
|
||||||
_ => {
|
_ => return Err(TimestampError::InvalidTimeCode(Cds, cds_type as u8)),
|
||||||
return Err(TimestampError::InvalidTimeCode(
|
|
||||||
CcsdsTimeCodes::Cds,
|
|
||||||
cds_type as u8,
|
|
||||||
))
|
|
||||||
}
|
|
||||||
},
|
},
|
||||||
_ => {
|
_ => return Err(TimestampError::InvalidTimeCode(Cds, pfield >> 4 & 0b111)),
|
||||||
return Err(TimestampError::InvalidTimeCode(
|
|
||||||
CcsdsTimeCodes::Cds,
|
|
||||||
pfield >> 4 & 0b111,
|
|
||||||
))
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
let ccsds_days: u16 = u16::from_be_bytes(buf[1..3].try_into().unwrap());
|
let ccsds_days: u16 = u16::from_be_bytes(buf[1..3].try_into().unwrap());
|
||||||
let ms_of_day: u32 = u32::from_be_bytes(buf[3..7].try_into().unwrap());
|
let ms_of_day: u32 = u32::from_be_bytes(buf[3..7].try_into().unwrap());
|
||||||
@ -283,12 +288,9 @@ mod tests {
|
|||||||
time_stamper.unix_seconds(),
|
time_stamper.unix_seconds(),
|
||||||
(DAYS_CCSDS_TO_UNIX * SECONDS_PER_DAY as i32) as i64
|
(DAYS_CCSDS_TO_UNIX * SECONDS_PER_DAY as i32) as i64
|
||||||
);
|
);
|
||||||
assert_eq!(time_stamper.ccdsd_time_code(), CcsdsTimeCodes::Cds);
|
assert_eq!(time_stamper.ccdsd_time_code(), Cds);
|
||||||
assert_eq!(
|
assert_eq!(time_stamper.p_field(), (1, [(Cds as u8) << 4, 0]));
|
||||||
time_stamper.p_field(),
|
let date_time = time_stamper.date_time().unwrap();
|
||||||
(1, [(CcsdsTimeCodes::Cds as u8) << 4, 0])
|
|
||||||
);
|
|
||||||
let date_time = time_stamper.date_time();
|
|
||||||
assert_eq!(date_time.year(), 1958);
|
assert_eq!(date_time.year(), 1958);
|
||||||
assert_eq!(date_time.month(), 1);
|
assert_eq!(date_time.month(), 1);
|
||||||
assert_eq!(date_time.day(), 1);
|
assert_eq!(date_time.day(), 1);
|
||||||
@ -301,7 +303,7 @@ mod tests {
|
|||||||
fn test_time_stamp_unix_epoch() {
|
fn test_time_stamp_unix_epoch() {
|
||||||
let time_stamper = CdsShortTimeProvider::new((-DAYS_CCSDS_TO_UNIX) as u16, 0);
|
let time_stamper = CdsShortTimeProvider::new((-DAYS_CCSDS_TO_UNIX) as u16, 0);
|
||||||
assert_eq!(time_stamper.unix_seconds(), 0);
|
assert_eq!(time_stamper.unix_seconds(), 0);
|
||||||
let date_time = time_stamper.date_time();
|
let date_time = time_stamper.date_time().unwrap();
|
||||||
assert_eq!(date_time.year(), 1970);
|
assert_eq!(date_time.year(), 1970);
|
||||||
assert_eq!(date_time.month(), 1);
|
assert_eq!(date_time.month(), 1);
|
||||||
assert_eq!(date_time.day(), 1);
|
assert_eq!(date_time.day(), 1);
|
||||||
@ -392,7 +394,7 @@ mod tests {
|
|||||||
let err = res.unwrap_err();
|
let err = res.unwrap_err();
|
||||||
match err {
|
match err {
|
||||||
InvalidTimeCode(code, raw) => {
|
InvalidTimeCode(code, raw) => {
|
||||||
assert_eq!(code, CcsdsTimeCodes::Cds);
|
assert_eq!(code, Cds);
|
||||||
assert_eq!(raw, 0);
|
assert_eq!(raw, 0);
|
||||||
}
|
}
|
||||||
OtherPacketError(_) => {}
|
OtherPacketError(_) => {}
|
||||||
@ -425,7 +427,7 @@ mod tests {
|
|||||||
fn test_time_now() {
|
fn test_time_now() {
|
||||||
let timestamp_now = CdsShortTimeProvider::from_now().unwrap();
|
let timestamp_now = CdsShortTimeProvider::from_now().unwrap();
|
||||||
let compare_stamp = Utc::now();
|
let compare_stamp = Utc::now();
|
||||||
let dt = timestamp_now.date_time();
|
let dt = timestamp_now.date_time().unwrap();
|
||||||
if compare_stamp.year() > dt.year() {
|
if compare_stamp.year() > dt.year() {
|
||||||
assert_eq!(compare_stamp.year() - dt.year(), 1);
|
assert_eq!(compare_stamp.year() - dt.year(), 1);
|
||||||
} else {
|
} else {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user