use crate::profile::typedef::{self, FitBaseType};
use crate::proto::*;
use alloc::vec::Vec;
#[cfg(feature = "serde")]
use serde::{Deserialize, Serialize, Serializer, ser::SerializeStruct};
#[cfg_attr(feature = "serde", derive(Deserialize), serde(from = "De"))]
#[derive(Debug, Clone)]
pub struct NapEvent {
pub message_index: typedef::MessageIndex,
pub timestamp: typedef::DateTime,
pub start_time: typedef::DateTime,
pub start_timezone_offset: i16,
pub end_time: typedef::DateTime,
pub end_timezone_offset: i16,
pub feedback: typedef::NapPeriodFeedback,
pub is_deleted: typedef::Bool,
pub source: typedef::NapSource,
pub update_timestamp: typedef::DateTime,
pub unknown_fields: Vec<Field>,
pub developer_fields: Vec<DeveloperField>,
}
impl NapEvent {
pub const MESSAGE_INDEX: u8 = 254;
pub const TIMESTAMP: u8 = 253;
pub const START_TIME: u8 = 0;
pub const START_TIMEZONE_OFFSET: u8 = 1;
pub const END_TIME: u8 = 2;
pub const END_TIMEZONE_OFFSET: u8 = 3;
pub const FEEDBACK: u8 = 4;
pub const IS_DELETED: u8 = 5;
pub const SOURCE: u8 = 6;
pub const UPDATE_TIMESTAMP: u8 = 7;
pub const fn new() -> Self {
Self {
message_index: typedef::MessageIndex(u16::MAX),
timestamp: typedef::DateTime(u32::MAX),
start_time: typedef::DateTime(u32::MAX),
start_timezone_offset: i16::MAX,
end_time: typedef::DateTime(u32::MAX),
end_timezone_offset: i16::MAX,
feedback: typedef::NapPeriodFeedback(u8::MAX),
is_deleted: typedef::Bool(u8::MAX),
source: typedef::NapSource(u8::MAX),
update_timestamp: typedef::DateTime(u32::MAX),
unknown_fields: Vec::new(),
developer_fields: Vec::new(),
}
}
fn count_valid_fields(&self) -> usize {
(self.message_index.0 != u16::MAX) as usize
+ (self.timestamp.0 != u32::MAX) as usize
+ (self.start_time.0 != u32::MAX) as usize
+ (self.start_timezone_offset != i16::MAX) as usize
+ (self.end_time.0 != u32::MAX) as usize
+ (self.end_timezone_offset != i16::MAX) as usize
+ (self.feedback.0 != u8::MAX) as usize
+ (self.is_deleted.0 != u8::MAX) as usize
+ (self.source.0 != u8::MAX) as usize
+ (self.update_timestamp.0 != u32::MAX) as usize
}
}
impl Default for NapEvent {
fn default() -> Self {
Self::new()
}
}
impl From<&Message> for NapEvent {
fn from(mesg: &Message) -> Self {
const KNOWN_NUMS: [u64; 4] = [255, 0, 0, 6917529027641081856];
let mut n = 0u64;
for field in &mesg.fields {
n += (KNOWN_NUMS[field.num as usize >> 6] >> (field.num & 63)) & 1 ^ 1
}
let mut v = Self::new();
v.unknown_fields = Vec::<Field>::with_capacity(n as usize);
v.developer_fields = mesg.developer_fields.clone();
for field in &mesg.fields {
match field.num {
254 => v.message_index = typedef::MessageIndex(field.value.as_u16()),
253 => v.timestamp = typedef::DateTime(field.value.as_u32()),
0 => v.start_time = typedef::DateTime(field.value.as_u32()),
1 => v.start_timezone_offset = field.value.as_i16(),
2 => v.end_time = typedef::DateTime(field.value.as_u32()),
3 => v.end_timezone_offset = field.value.as_i16(),
4 => v.feedback = typedef::NapPeriodFeedback(field.value.as_u8()),
5 => v.is_deleted = typedef::Bool(field.value.as_u8()),
6 => v.source = typedef::NapSource(field.value.as_u8()),
7 => v.update_timestamp = typedef::DateTime(field.value.as_u32()),
_ => v.unknown_fields.push(field.clone()),
};
}
v
}
}
impl From<NapEvent> for Message {
fn from(m: NapEvent) -> Self {
let mut fields =
Vec::<Field>::with_capacity(m.count_valid_fields() + m.unknown_fields.len());
if m.message_index.0 != u16::MAX {
fields.push(Field {
num: 254,
base_type: FitBaseType::UINT16,
value: Value::Uint16(m.message_index.0),
is_expanded: false,
});
};
if m.timestamp.0 != u32::MAX {
fields.push(Field {
num: 253,
base_type: FitBaseType::UINT32,
value: Value::Uint32(m.timestamp.0),
is_expanded: false,
});
};
if m.start_time.0 != u32::MAX {
fields.push(Field {
num: 0,
base_type: FitBaseType::UINT32,
value: Value::Uint32(m.start_time.0),
is_expanded: false,
});
};
if m.start_timezone_offset != i16::MAX {
fields.push(Field {
num: 1,
base_type: FitBaseType::SINT16,
value: Value::Int16(m.start_timezone_offset),
is_expanded: false,
});
};
if m.end_time.0 != u32::MAX {
fields.push(Field {
num: 2,
base_type: FitBaseType::UINT32,
value: Value::Uint32(m.end_time.0),
is_expanded: false,
});
};
if m.end_timezone_offset != i16::MAX {
fields.push(Field {
num: 3,
base_type: FitBaseType::SINT16,
value: Value::Int16(m.end_timezone_offset),
is_expanded: false,
});
};
if m.feedback.0 != u8::MAX {
fields.push(Field {
num: 4,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.feedback.0),
is_expanded: false,
});
};
if m.is_deleted.0 != u8::MAX {
fields.push(Field {
num: 5,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.is_deleted.0),
is_expanded: false,
});
};
if m.source.0 != u8::MAX {
fields.push(Field {
num: 6,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.source.0),
is_expanded: false,
});
};
if m.update_timestamp.0 != u32::MAX {
fields.push(Field {
num: 7,
base_type: FitBaseType::UINT32,
value: Value::Uint32(m.update_timestamp.0),
is_expanded: false,
});
};
fields.extend_from_slice(&m.unknown_fields);
Self {
header: 0,
num: typedef::MesgNum::NAP_EVENT,
fields,
developer_fields: m.developer_fields,
}
}
}
#[cfg(feature = "serde")]
impl Serialize for NapEvent {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
let n = self.count_valid_fields() + 2;
let mut state = serializer.serialize_struct("NapEvent", n)?;
if self.message_index.0 != u16::MAX {
state.serialize_field("message_index", &self.message_index)?;
}
if let Some(v) = self.timestamp.unix_timestamp() {
state.serialize_field("timestamp", &v)?;
}
if let Some(v) = self.start_time.unix_timestamp() {
state.serialize_field("start_time", &v)?;
}
if self.start_timezone_offset != i16::MAX {
state.serialize_field("start_timezone_offset", &self.start_timezone_offset)?;
}
if let Some(v) = self.end_time.unix_timestamp() {
state.serialize_field("end_time", &v)?;
}
if self.end_timezone_offset != i16::MAX {
state.serialize_field("end_timezone_offset", &self.end_timezone_offset)?;
}
if self.feedback.0 != u8::MAX {
state.serialize_field("feedback", &self.feedback)?;
}
if self.is_deleted.0 != u8::MAX {
state.serialize_field("is_deleted", &self.is_deleted)?;
}
if self.source.0 != u8::MAX {
state.serialize_field("source", &self.source)?;
}
if let Some(v) = self.update_timestamp.unix_timestamp() {
state.serialize_field("update_timestamp", &v)?;
}
if !self.unknown_fields.is_empty() {
state.serialize_field("unknown_fields", &self.unknown_fields)?;
}
if !self.developer_fields.is_empty() {
state.serialize_field("developer_fields", &self.developer_fields)?;
}
state.end()
}
}
#[cfg(feature = "serde")]
#[cfg_attr(feature = "serde", derive(Deserialize), serde(default))]
struct De {
message_index: typedef::MessageIndex,
timestamp: Option<i64>,
start_time: Option<i64>,
start_timezone_offset: i16,
end_time: Option<i64>,
end_timezone_offset: i16,
feedback: typedef::NapPeriodFeedback,
is_deleted: typedef::Bool,
source: typedef::NapSource,
update_timestamp: Option<i64>,
unknown_fields: Vec<Field>,
developer_fields: Vec<DeveloperField>,
}
#[cfg(feature = "serde")]
impl From<De> for NapEvent {
fn from(m: De) -> Self {
Self {
message_index: m.message_index,
timestamp: m.timestamp.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
start_time: m.start_time.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
start_timezone_offset: m.start_timezone_offset,
end_time: m.end_time.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
end_timezone_offset: m.end_timezone_offset,
feedback: m.feedback,
is_deleted: m.is_deleted,
source: m.source,
update_timestamp: m.update_timestamp.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
unknown_fields: m.unknown_fields,
developer_fields: m.developer_fields,
}
}
}
#[cfg(feature = "serde")]
impl Default for De {
fn default() -> Self {
Self {
message_index: typedef::MessageIndex(u16::MAX),
timestamp: None,
start_time: None,
start_timezone_offset: i16::MAX,
end_time: None,
end_timezone_offset: i16::MAX,
feedback: typedef::NapPeriodFeedback(u8::MAX),
is_deleted: typedef::Bool(u8::MAX),
source: typedef::NapSource(u8::MAX),
update_timestamp: None,
unknown_fields: Vec::new(),
developer_fields: Vec::new(),
}
}
}