#![allow(clippy::manual_range_patterns)]
use crate::profile::typedef::{self, FitBaseType};
use crate::proto::*;
use alloc::vec::Vec;
#[cfg(feature = "serde")]
use serde::{Deserialize, Serialize, Serializer, ser::SerializeStruct};
fn is_expanded(state: &[u8], num: u8) -> bool {
match num {
3 | 7 | 8 | 9 | 10 | 11 | 12 | 21 | 22 | 23 | 24 => {
(state[num as usize >> 3] >> (num & 7)) & 1 == 1
}
_ => false,
}
}
#[cfg_attr(feature = "serde", derive(Deserialize), serde(from = "De"))]
#[derive(Debug, Clone)]
pub struct Event {
pub timestamp: typedef::DateTime,
pub event: typedef::Event,
pub event_type: typedef::EventType,
pub data16: u16,
pub data: u32,
pub event_group: u8,
pub score: u16,
pub opponent_score: u16,
pub front_gear_num: u8,
pub front_gear: u8,
pub rear_gear_num: u8,
pub rear_gear: u8,
pub device_index: typedef::DeviceIndex,
pub activity_type: typedef::ActivityType,
pub start_timestamp: typedef::DateTime,
pub radar_threat_level_max: typedef::RadarThreatLevelType,
pub radar_threat_count: u8,
pub radar_threat_avg_approach_speed: u8,
pub radar_threat_max_approach_speed: u8,
state: [u8; 4], pub unknown_fields: Vec<Field>,
pub developer_fields: Vec<DeveloperField>,
}
impl Event {
pub const TIMESTAMP: u8 = 253;
pub const EVENT: u8 = 0;
pub const EVENT_TYPE: u8 = 1;
pub const DATA16: u8 = 2;
pub const DATA: u8 = 3;
pub const EVENT_GROUP: u8 = 4;
pub const SCORE: u8 = 7;
pub const OPPONENT_SCORE: u8 = 8;
pub const FRONT_GEAR_NUM: u8 = 9;
pub const FRONT_GEAR: u8 = 10;
pub const REAR_GEAR_NUM: u8 = 11;
pub const REAR_GEAR: u8 = 12;
pub const DEVICE_INDEX: u8 = 13;
pub const ACTIVITY_TYPE: u8 = 14;
pub const START_TIMESTAMP: u8 = 15;
pub const RADAR_THREAT_LEVEL_MAX: u8 = 21;
pub const RADAR_THREAT_COUNT: u8 = 22;
pub const RADAR_THREAT_AVG_APPROACH_SPEED: u8 = 23;
pub const RADAR_THREAT_MAX_APPROACH_SPEED: u8 = 24;
pub const fn new() -> Self {
Self {
timestamp: typedef::DateTime(u32::MAX),
event: typedef::Event(u8::MAX),
event_type: typedef::EventType(u8::MAX),
data16: u16::MAX,
data: u32::MAX,
event_group: u8::MAX,
score: u16::MAX,
opponent_score: u16::MAX,
front_gear_num: u8::MIN,
front_gear: u8::MIN,
rear_gear_num: u8::MIN,
rear_gear: u8::MIN,
device_index: typedef::DeviceIndex(u8::MAX),
activity_type: typedef::ActivityType(u8::MAX),
start_timestamp: typedef::DateTime(u32::MAX),
radar_threat_level_max: typedef::RadarThreatLevelType(u8::MAX),
radar_threat_count: u8::MAX,
radar_threat_avg_approach_speed: u8::MAX,
radar_threat_max_approach_speed: u8::MAX,
state: [0u8; 4],
unknown_fields: Vec::new(),
developer_fields: Vec::new(),
}
}
pub fn radar_threat_avg_approach_speed_scaled(&self) -> Option<f64> {
if self.radar_threat_avg_approach_speed == u8::MAX {
return None;
}
Some(self.radar_threat_avg_approach_speed as f64 / 10.0 - 0.0)
}
pub fn set_radar_threat_avg_approach_speed_scaled(&mut self, v: f64) -> &mut Self {
let unscaled = (v + 0.0) * 10.0;
if unscaled.is_nan() || unscaled.is_infinite() || unscaled > u8::MAX as f64 {
self.radar_threat_avg_approach_speed = u8::MAX;
return self;
}
self.radar_threat_avg_approach_speed = unscaled as u8;
self
}
pub fn radar_threat_max_approach_speed_scaled(&self) -> Option<f64> {
if self.radar_threat_max_approach_speed == u8::MAX {
return None;
}
Some(self.radar_threat_max_approach_speed as f64 / 10.0 - 0.0)
}
pub fn set_radar_threat_max_approach_speed_scaled(&mut self, v: f64) -> &mut Self {
let unscaled = (v + 0.0) * 10.0;
if unscaled.is_nan() || unscaled.is_infinite() || unscaled > u8::MAX as f64 {
self.radar_threat_max_approach_speed = u8::MAX;
return self;
}
self.radar_threat_max_approach_speed = unscaled as u8;
self
}
pub fn mark_as_expanded(&mut self, num: u8, flag: bool) -> bool {
match num {
3 | 7 | 8 | 9 | 10 | 11 | 12 | 21 | 22 | 23 | 24 => {
if flag {
self.state[num as usize >> 3] |= 1 << (num & 7)
} else {
self.state[num as usize >> 3] &= !(1 << (num & 7))
}
true
}
_ => false,
}
}
pub fn is_expanded(&self, num: u8) -> bool {
is_expanded(&self.state, num)
}
fn count_valid_fields(&self) -> usize {
(self.timestamp.0 != u32::MAX) as usize
+ (self.event.0 != u8::MAX) as usize
+ (self.event_type.0 != u8::MAX) as usize
+ (self.data16 != u16::MAX) as usize
+ (self.data != u32::MAX) as usize
+ (self.event_group != u8::MAX) as usize
+ (self.score != u16::MAX) as usize
+ (self.opponent_score != u16::MAX) as usize
+ (self.front_gear_num != u8::MIN) as usize
+ (self.front_gear != u8::MIN) as usize
+ (self.rear_gear_num != u8::MIN) as usize
+ (self.rear_gear != u8::MIN) as usize
+ (self.device_index.0 != u8::MAX) as usize
+ (self.activity_type.0 != u8::MAX) as usize
+ (self.start_timestamp.0 != u32::MAX) as usize
+ (self.radar_threat_level_max.0 != u8::MAX) as usize
+ (self.radar_threat_count != u8::MAX) as usize
+ (self.radar_threat_avg_approach_speed != u8::MAX) as usize
+ (self.radar_threat_max_approach_speed != u8::MAX) as usize
}
}
impl Default for Event {
fn default() -> Self {
Self::new()
}
}
impl From<&Message> for Event {
fn from(mesg: &Message) -> Self {
const KNOWN_NUMS: [u64; 4] = [31522719, 0, 0, 2305843009213693952];
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 {
253 => v.timestamp = typedef::DateTime(field.value.as_u32()),
0 => v.event = typedef::Event(field.value.as_u8()),
1 => v.event_type = typedef::EventType(field.value.as_u8()),
2 => v.data16 = field.value.as_u16(),
3 => v.data = field.value.as_u32(),
4 => v.event_group = field.value.as_u8(),
7 => v.score = field.value.as_u16(),
8 => v.opponent_score = field.value.as_u16(),
9 => v.front_gear_num = field.value.as_u8z(),
10 => v.front_gear = field.value.as_u8z(),
11 => v.rear_gear_num = field.value.as_u8z(),
12 => v.rear_gear = field.value.as_u8z(),
13 => v.device_index = typedef::DeviceIndex(field.value.as_u8()),
14 => v.activity_type = typedef::ActivityType(field.value.as_u8()),
15 => v.start_timestamp = typedef::DateTime(field.value.as_u32()),
21 => v.radar_threat_level_max = typedef::RadarThreatLevelType(field.value.as_u8()),
22 => v.radar_threat_count = field.value.as_u8(),
23 => v.radar_threat_avg_approach_speed = field.value.as_u8(),
24 => v.radar_threat_max_approach_speed = field.value.as_u8(),
_ => {
v.unknown_fields.push(field.clone());
continue;
}
};
if field.is_expanded && field.num < 25 {
v.state[field.num as usize >> 3] |= 1 << (field.num & 7)
}
}
v
}
}
impl From<Event> for Message {
fn from(m: Event) -> Self {
let mut fields =
Vec::<Field>::with_capacity(m.count_valid_fields() + m.unknown_fields.len());
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.event.0 != u8::MAX {
fields.push(Field {
num: 0,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.event.0),
is_expanded: false,
});
};
if m.event_type.0 != u8::MAX {
fields.push(Field {
num: 1,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.event_type.0),
is_expanded: false,
});
};
if m.data16 != u16::MAX {
fields.push(Field {
num: 2,
base_type: FitBaseType::UINT16,
value: Value::Uint16(m.data16),
is_expanded: false,
});
};
if m.data != u32::MAX {
fields.push(Field {
num: 3,
base_type: FitBaseType::UINT32,
value: Value::Uint32(m.data),
is_expanded: is_expanded(&m.state, 3),
});
};
if m.event_group != u8::MAX {
fields.push(Field {
num: 4,
base_type: FitBaseType::UINT8,
value: Value::Uint8(m.event_group),
is_expanded: false,
});
};
if m.score != u16::MAX {
fields.push(Field {
num: 7,
base_type: FitBaseType::UINT16,
value: Value::Uint16(m.score),
is_expanded: is_expanded(&m.state, 7),
});
};
if m.opponent_score != u16::MAX {
fields.push(Field {
num: 8,
base_type: FitBaseType::UINT16,
value: Value::Uint16(m.opponent_score),
is_expanded: is_expanded(&m.state, 8),
});
};
if m.front_gear_num != u8::MIN {
fields.push(Field {
num: 9,
base_type: FitBaseType::UINT8Z,
value: Value::Uint8(m.front_gear_num),
is_expanded: is_expanded(&m.state, 9),
});
};
if m.front_gear != u8::MIN {
fields.push(Field {
num: 10,
base_type: FitBaseType::UINT8Z,
value: Value::Uint8(m.front_gear),
is_expanded: is_expanded(&m.state, 10),
});
};
if m.rear_gear_num != u8::MIN {
fields.push(Field {
num: 11,
base_type: FitBaseType::UINT8Z,
value: Value::Uint8(m.rear_gear_num),
is_expanded: is_expanded(&m.state, 11),
});
};
if m.rear_gear != u8::MIN {
fields.push(Field {
num: 12,
base_type: FitBaseType::UINT8Z,
value: Value::Uint8(m.rear_gear),
is_expanded: is_expanded(&m.state, 12),
});
};
if m.device_index.0 != u8::MAX {
fields.push(Field {
num: 13,
base_type: FitBaseType::UINT8,
value: Value::Uint8(m.device_index.0),
is_expanded: false,
});
};
if m.activity_type.0 != u8::MAX {
fields.push(Field {
num: 14,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.activity_type.0),
is_expanded: false,
});
};
if m.start_timestamp.0 != u32::MAX {
fields.push(Field {
num: 15,
base_type: FitBaseType::UINT32,
value: Value::Uint32(m.start_timestamp.0),
is_expanded: false,
});
};
if m.radar_threat_level_max.0 != u8::MAX {
fields.push(Field {
num: 21,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.radar_threat_level_max.0),
is_expanded: is_expanded(&m.state, 21),
});
};
if m.radar_threat_count != u8::MAX {
fields.push(Field {
num: 22,
base_type: FitBaseType::UINT8,
value: Value::Uint8(m.radar_threat_count),
is_expanded: is_expanded(&m.state, 22),
});
};
if m.radar_threat_avg_approach_speed != u8::MAX {
fields.push(Field {
num: 23,
base_type: FitBaseType::UINT8,
value: Value::Uint8(m.radar_threat_avg_approach_speed),
is_expanded: is_expanded(&m.state, 23),
});
};
if m.radar_threat_max_approach_speed != u8::MAX {
fields.push(Field {
num: 24,
base_type: FitBaseType::UINT8,
value: Value::Uint8(m.radar_threat_max_approach_speed),
is_expanded: is_expanded(&m.state, 24),
});
};
fields.extend_from_slice(&m.unknown_fields);
Self {
header: 0,
num: typedef::MesgNum::EVENT,
fields,
developer_fields: m.developer_fields,
}
}
}
#[cfg(feature = "serde")]
impl Serialize for Event {
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("Event", n)?;
if let Some(v) = self.timestamp.unix_timestamp() {
state.serialize_field("timestamp", &v)?;
}
if self.event.0 != u8::MAX {
state.serialize_field("event", &self.event)?;
}
if self.event_type.0 != u8::MAX {
state.serialize_field("event_type", &self.event_type)?;
}
if self.data16 != u16::MAX {
state.serialize_field("data16", &self.data16)?;
}
if self.data != u32::MAX {
state.serialize_field("data", &self.data)?;
}
if self.event_group != u8::MAX {
state.serialize_field("event_group", &self.event_group)?;
}
if self.score != u16::MAX {
state.serialize_field("score", &self.score)?;
}
if self.opponent_score != u16::MAX {
state.serialize_field("opponent_score", &self.opponent_score)?;
}
if self.front_gear_num != u8::MIN {
state.serialize_field("front_gear_num", &self.front_gear_num)?;
}
if self.front_gear != u8::MIN {
state.serialize_field("front_gear", &self.front_gear)?;
}
if self.rear_gear_num != u8::MIN {
state.serialize_field("rear_gear_num", &self.rear_gear_num)?;
}
if self.rear_gear != u8::MIN {
state.serialize_field("rear_gear", &self.rear_gear)?;
}
if self.device_index.0 != u8::MAX {
state.serialize_field("device_index", &self.device_index)?;
}
if self.activity_type.0 != u8::MAX {
state.serialize_field("activity_type", &self.activity_type)?;
}
if let Some(v) = self.start_timestamp.unix_timestamp() {
state.serialize_field("start_timestamp", &v)?;
}
if self.radar_threat_level_max.0 != u8::MAX {
state.serialize_field("radar_threat_level_max", &self.radar_threat_level_max)?;
}
if self.radar_threat_count != u8::MAX {
state.serialize_field("radar_threat_count", &self.radar_threat_count)?;
}
if let Some(v) = self.radar_threat_avg_approach_speed_scaled() {
state.serialize_field("radar_threat_avg_approach_speed", &v)?;
}
if let Some(v) = self.radar_threat_max_approach_speed_scaled() {
state.serialize_field("radar_threat_max_approach_speed", &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 {
timestamp: Option<i64>,
event: typedef::Event,
event_type: typedef::EventType,
data16: u16,
data: u32,
event_group: u8,
score: u16,
opponent_score: u16,
front_gear_num: u8,
front_gear: u8,
rear_gear_num: u8,
rear_gear: u8,
device_index: typedef::DeviceIndex,
activity_type: typedef::ActivityType,
start_timestamp: Option<i64>,
radar_threat_level_max: typedef::RadarThreatLevelType,
radar_threat_count: u8,
radar_threat_avg_approach_speed: f64,
radar_threat_max_approach_speed: f64,
unknown_fields: Vec<Field>,
developer_fields: Vec<DeveloperField>,
}
#[cfg(feature = "serde")]
impl From<De> for Event {
fn from(m: De) -> Self {
Self {
timestamp: m.timestamp.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
event: m.event,
event_type: m.event_type,
data16: m.data16,
data: m.data,
event_group: m.event_group,
score: m.score,
opponent_score: m.opponent_score,
front_gear_num: m.front_gear_num,
front_gear: m.front_gear,
rear_gear_num: m.rear_gear_num,
rear_gear: m.rear_gear,
device_index: m.device_index,
activity_type: m.activity_type,
start_timestamp: m.start_timestamp.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
radar_threat_level_max: m.radar_threat_level_max,
radar_threat_count: m.radar_threat_count,
radar_threat_avg_approach_speed: {
let unscaled = (m.radar_threat_avg_approach_speed + 0.0) * 10.0;
if unscaled.is_nan() || unscaled.is_infinite() || unscaled > u8::MAX as f64 {
u8::MAX
} else {
unscaled as u8
}
},
radar_threat_max_approach_speed: {
let unscaled = (m.radar_threat_max_approach_speed + 0.0) * 10.0;
if unscaled.is_nan() || unscaled.is_infinite() || unscaled > u8::MAX as f64 {
u8::MAX
} else {
unscaled as u8
}
},
state: [0u8; 4],
unknown_fields: m.unknown_fields,
developer_fields: m.developer_fields,
}
}
}
#[cfg(feature = "serde")]
impl Default for De {
fn default() -> Self {
Self {
timestamp: None,
event: typedef::Event(u8::MAX),
event_type: typedef::EventType(u8::MAX),
data16: u16::MAX,
data: u32::MAX,
event_group: u8::MAX,
score: u16::MAX,
opponent_score: u16::MAX,
front_gear_num: u8::MIN,
front_gear: u8::MIN,
rear_gear_num: u8::MIN,
rear_gear: u8::MIN,
device_index: typedef::DeviceIndex(u8::MAX),
activity_type: typedef::ActivityType(u8::MAX),
start_timestamp: None,
radar_threat_level_max: typedef::RadarThreatLevelType(u8::MAX),
radar_threat_count: u8::MAX,
radar_threat_avg_approach_speed: f64::from_bits(u64::MAX),
radar_threat_max_approach_speed: f64::from_bits(u64::MAX),
unknown_fields: Vec::new(),
developer_fields: Vec::new(),
}
}
}