use crate::profile::typedef::{self, FitBaseType};
use crate::proto::*;
use crate::semconv;
use alloc::borrow::ToOwned;
use alloc::string::String;
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 WeatherConditions {
pub timestamp: typedef::DateTime,
pub weather_report: typedef::WeatherReport,
pub temperature: i8,
pub condition: typedef::WeatherStatus,
pub wind_direction: u16,
pub wind_speed: u16,
pub precipitation_probability: u8,
pub temperature_feels_like: i8,
pub relative_humidity: u8,
pub location: String,
pub observed_at_time: typedef::DateTime,
pub observed_location_lat: i32,
pub observed_location_long: i32,
pub day_of_week: typedef::DayOfWeek,
pub high_temperature: i8,
pub low_temperature: i8,
pub unknown_fields: Vec<Field>,
pub developer_fields: Vec<DeveloperField>,
}
impl WeatherConditions {
pub const TIMESTAMP: u8 = 253;
pub const WEATHER_REPORT: u8 = 0;
pub const TEMPERATURE: u8 = 1;
pub const CONDITION: u8 = 2;
pub const WIND_DIRECTION: u8 = 3;
pub const WIND_SPEED: u8 = 4;
pub const PRECIPITATION_PROBABILITY: u8 = 5;
pub const TEMPERATURE_FEELS_LIKE: u8 = 6;
pub const RELATIVE_HUMIDITY: u8 = 7;
pub const LOCATION: u8 = 8;
pub const OBSERVED_AT_TIME: u8 = 9;
pub const OBSERVED_LOCATION_LAT: u8 = 10;
pub const OBSERVED_LOCATION_LONG: u8 = 11;
pub const DAY_OF_WEEK: u8 = 12;
pub const HIGH_TEMPERATURE: u8 = 13;
pub const LOW_TEMPERATURE: u8 = 14;
pub const fn new() -> Self {
Self {
timestamp: typedef::DateTime(u32::MAX),
weather_report: typedef::WeatherReport(u8::MAX),
temperature: i8::MAX,
condition: typedef::WeatherStatus(u8::MAX),
wind_direction: u16::MAX,
wind_speed: u16::MAX,
precipitation_probability: u8::MAX,
temperature_feels_like: i8::MAX,
relative_humidity: u8::MAX,
location: String::new(),
observed_at_time: typedef::DateTime(u32::MAX),
observed_location_lat: i32::MAX,
observed_location_long: i32::MAX,
day_of_week: typedef::DayOfWeek(u8::MAX),
high_temperature: i8::MAX,
low_temperature: i8::MAX,
unknown_fields: Vec::new(),
developer_fields: Vec::new(),
}
}
pub fn observed_location_lat_degrees(&self) -> Option<f64> {
semconv::to_degrees(self.observed_location_lat)
}
pub fn set_observed_location_lat_degrees(&mut self, v: f64) -> &mut Self {
self.observed_location_lat = semconv::to_semicircles(v).unwrap_or(i32::MAX);
self
}
pub fn observed_location_long_degrees(&self) -> Option<f64> {
semconv::to_degrees(self.observed_location_long)
}
pub fn set_observed_location_long_degrees(&mut self, v: f64) -> &mut Self {
self.observed_location_long = semconv::to_semicircles(v).unwrap_or(i32::MAX);
self
}
pub fn wind_speed_scaled(&self) -> Option<f64> {
if self.wind_speed == u16::MAX {
return None;
}
Some(self.wind_speed as f64 / 1000.0 - 0.0)
}
pub fn set_wind_speed_scaled(&mut self, v: f64) -> &mut Self {
let unscaled = (v + 0.0) * 1000.0;
if unscaled.is_nan() || unscaled.is_infinite() || unscaled > u16::MAX as f64 {
self.wind_speed = u16::MAX;
return self;
}
self.wind_speed = unscaled as u16;
self
}
fn count_valid_fields(&self) -> usize {
(self.timestamp.0 != u32::MAX) as usize
+ (self.weather_report.0 != u8::MAX) as usize
+ (self.temperature != i8::MAX) as usize
+ (self.condition.0 != u8::MAX) as usize
+ (self.wind_direction != u16::MAX) as usize
+ (self.wind_speed != u16::MAX) as usize
+ (self.precipitation_probability != u8::MAX) as usize
+ (self.temperature_feels_like != i8::MAX) as usize
+ (self.relative_humidity != u8::MAX) as usize
+ (!self.location.is_empty()) as usize
+ (self.observed_at_time.0 != u32::MAX) as usize
+ (self.observed_location_lat != i32::MAX) as usize
+ (self.observed_location_long != i32::MAX) as usize
+ (self.day_of_week.0 != u8::MAX) as usize
+ (self.high_temperature != i8::MAX) as usize
+ (self.low_temperature != i8::MAX) as usize
}
}
impl Default for WeatherConditions {
fn default() -> Self {
Self::new()
}
}
impl From<&Message> for WeatherConditions {
fn from(mesg: &Message) -> Self {
const KNOWN_NUMS: [u64; 4] = [32767, 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.weather_report = typedef::WeatherReport(field.value.as_u8()),
1 => v.temperature = field.value.as_i8(),
2 => v.condition = typedef::WeatherStatus(field.value.as_u8()),
3 => v.wind_direction = field.value.as_u16(),
4 => v.wind_speed = field.value.as_u16(),
5 => v.precipitation_probability = field.value.as_u8(),
6 => v.temperature_feels_like = field.value.as_i8(),
7 => v.relative_humidity = field.value.as_u8(),
8 => v.location = field.value.as_str().to_owned(),
9 => v.observed_at_time = typedef::DateTime(field.value.as_u32()),
10 => v.observed_location_lat = field.value.as_i32(),
11 => v.observed_location_long = field.value.as_i32(),
12 => v.day_of_week = typedef::DayOfWeek(field.value.as_u8()),
13 => v.high_temperature = field.value.as_i8(),
14 => v.low_temperature = field.value.as_i8(),
_ => v.unknown_fields.push(field.clone()),
};
}
v
}
}
impl From<WeatherConditions> for Message {
fn from(m: WeatherConditions) -> 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.weather_report.0 != u8::MAX {
fields.push(Field {
num: 0,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.weather_report.0),
is_expanded: false,
});
};
if m.temperature != i8::MAX {
fields.push(Field {
num: 1,
base_type: FitBaseType::SINT8,
value: Value::Int8(m.temperature),
is_expanded: false,
});
};
if m.condition.0 != u8::MAX {
fields.push(Field {
num: 2,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.condition.0),
is_expanded: false,
});
};
if m.wind_direction != u16::MAX {
fields.push(Field {
num: 3,
base_type: FitBaseType::UINT16,
value: Value::Uint16(m.wind_direction),
is_expanded: false,
});
};
if m.wind_speed != u16::MAX {
fields.push(Field {
num: 4,
base_type: FitBaseType::UINT16,
value: Value::Uint16(m.wind_speed),
is_expanded: false,
});
};
if m.precipitation_probability != u8::MAX {
fields.push(Field {
num: 5,
base_type: FitBaseType::UINT8,
value: Value::Uint8(m.precipitation_probability),
is_expanded: false,
});
};
if m.temperature_feels_like != i8::MAX {
fields.push(Field {
num: 6,
base_type: FitBaseType::SINT8,
value: Value::Int8(m.temperature_feels_like),
is_expanded: false,
});
};
if m.relative_humidity != u8::MAX {
fields.push(Field {
num: 7,
base_type: FitBaseType::UINT8,
value: Value::Uint8(m.relative_humidity),
is_expanded: false,
});
};
if !m.location.is_empty() {
fields.push(Field {
num: 8,
base_type: FitBaseType::STRING,
value: Value::String(m.location),
is_expanded: false,
});
};
if m.observed_at_time.0 != u32::MAX {
fields.push(Field {
num: 9,
base_type: FitBaseType::UINT32,
value: Value::Uint32(m.observed_at_time.0),
is_expanded: false,
});
};
if m.observed_location_lat != i32::MAX {
fields.push(Field {
num: 10,
base_type: FitBaseType::SINT32,
value: Value::Int32(m.observed_location_lat),
is_expanded: false,
});
};
if m.observed_location_long != i32::MAX {
fields.push(Field {
num: 11,
base_type: FitBaseType::SINT32,
value: Value::Int32(m.observed_location_long),
is_expanded: false,
});
};
if m.day_of_week.0 != u8::MAX {
fields.push(Field {
num: 12,
base_type: FitBaseType::ENUM,
value: Value::Uint8(m.day_of_week.0),
is_expanded: false,
});
};
if m.high_temperature != i8::MAX {
fields.push(Field {
num: 13,
base_type: FitBaseType::SINT8,
value: Value::Int8(m.high_temperature),
is_expanded: false,
});
};
if m.low_temperature != i8::MAX {
fields.push(Field {
num: 14,
base_type: FitBaseType::SINT8,
value: Value::Int8(m.low_temperature),
is_expanded: false,
});
};
fields.extend_from_slice(&m.unknown_fields);
Self {
header: 0,
num: typedef::MesgNum::WEATHER_CONDITIONS,
fields,
developer_fields: m.developer_fields,
}
}
}
#[cfg(feature = "serde")]
impl Serialize for WeatherConditions {
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("WeatherConditions", n)?;
if let Some(v) = self.timestamp.unix_timestamp() {
state.serialize_field("timestamp", &v)?;
}
if self.weather_report.0 != u8::MAX {
state.serialize_field("weather_report", &self.weather_report)?;
}
if self.temperature != i8::MAX {
state.serialize_field("temperature", &self.temperature)?;
}
if self.condition.0 != u8::MAX {
state.serialize_field("condition", &self.condition)?;
}
if self.wind_direction != u16::MAX {
state.serialize_field("wind_direction", &self.wind_direction)?;
}
if let Some(v) = self.wind_speed_scaled() {
state.serialize_field("wind_speed", &v)?;
}
if self.precipitation_probability != u8::MAX {
state.serialize_field("precipitation_probability", &self.precipitation_probability)?;
}
if self.temperature_feels_like != i8::MAX {
state.serialize_field("temperature_feels_like", &self.temperature_feels_like)?;
}
if self.relative_humidity != u8::MAX {
state.serialize_field("relative_humidity", &self.relative_humidity)?;
}
if !self.location.is_empty() {
state.serialize_field("location", &self.location)?;
}
if let Some(v) = self.observed_at_time.unix_timestamp() {
state.serialize_field("observed_at_time", &v)?;
}
if let Some(v) = self.observed_location_lat_degrees() {
state.serialize_field("observed_location_lat", &v)?;
}
if let Some(v) = self.observed_location_long_degrees() {
state.serialize_field("observed_location_long", &v)?;
}
if self.day_of_week.0 != u8::MAX {
state.serialize_field("day_of_week", &self.day_of_week)?;
}
if self.high_temperature != i8::MAX {
state.serialize_field("high_temperature", &self.high_temperature)?;
}
if self.low_temperature != i8::MAX {
state.serialize_field("low_temperature", &self.low_temperature)?;
}
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>,
weather_report: typedef::WeatherReport,
temperature: i8,
condition: typedef::WeatherStatus,
wind_direction: u16,
wind_speed: f64,
precipitation_probability: u8,
temperature_feels_like: i8,
relative_humidity: u8,
location: String,
observed_at_time: Option<i64>,
observed_location_lat: f64,
observed_location_long: f64,
day_of_week: typedef::DayOfWeek,
high_temperature: i8,
low_temperature: i8,
unknown_fields: Vec<Field>,
developer_fields: Vec<DeveloperField>,
}
#[cfg(feature = "serde")]
impl From<De> for WeatherConditions {
fn from(m: De) -> Self {
Self {
timestamp: m.timestamp.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
weather_report: m.weather_report,
temperature: m.temperature,
condition: m.condition,
wind_direction: m.wind_direction,
wind_speed: {
let unscaled = (m.wind_speed + 0.0) * 1000.0;
if unscaled.is_nan() || unscaled.is_infinite() || unscaled > u16::MAX as f64 {
u16::MAX
} else {
unscaled as u16
}
},
precipitation_probability: m.precipitation_probability,
temperature_feels_like: m.temperature_feels_like,
relative_humidity: m.relative_humidity,
location: m.location,
observed_at_time: m.observed_at_time.map_or_else(
|| typedef::DateTime(u32::MAX),
typedef::DateTime::from_unix_timestamp,
),
observed_location_lat: semconv::to_semicircles(m.observed_location_lat)
.unwrap_or(i32::MAX),
observed_location_long: semconv::to_semicircles(m.observed_location_long)
.unwrap_or(i32::MAX),
day_of_week: m.day_of_week,
high_temperature: m.high_temperature,
low_temperature: m.low_temperature,
unknown_fields: m.unknown_fields,
developer_fields: m.developer_fields,
}
}
}
#[cfg(feature = "serde")]
impl Default for De {
fn default() -> Self {
Self {
timestamp: None,
weather_report: typedef::WeatherReport(u8::MAX),
temperature: i8::MAX,
condition: typedef::WeatherStatus(u8::MAX),
wind_direction: u16::MAX,
wind_speed: f64::from_bits(u64::MAX),
precipitation_probability: u8::MAX,
temperature_feels_like: i8::MAX,
relative_humidity: u8::MAX,
location: String::new(),
observed_at_time: None,
observed_location_lat: f64::from_bits(u64::MAX),
observed_location_long: f64::from_bits(u64::MAX),
day_of_week: typedef::DayOfWeek(u8::MAX),
high_temperature: i8::MAX,
low_temperature: i8::MAX,
unknown_fields: Vec::new(),
developer_fields: Vec::new(),
}
}
}