yngvi 0.4.3

Read, calculate and write weather data
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

use crate::core::WeatherReading;

pub trait LineProtocol {
    fn to_line_protocol(&self) -> String;
}

impl LineProtocol for WeatherReading {
    fn to_line_protocol(&self) -> String {
        let mut fields: Vec<String> = vec![];

        if let Some(value) = self.device_id {
            fields.push(format!("device_id={}i", value));
        }

        if let Some(value) = self.rain {
            fields.push(format!("rain={}", value));
        }

        if let Some(value) = self.rain_delta {
            fields.push(format!("rain_delta={}", value));
        }

        if let Some(value) = self.wind_speed {
            fields.push(format!("wind_speed={}", value));
        }

        if let Some(value) = self.wind_dir {
            fields.push(format!("wind_dir={}", value));
        }

        if let Some(value) = &self.wind_dir_cardinal {
            fields.push(format!("wind_dir_cardinal=\"{}\"", value));
        }

        if let Some(value) = self.out_temp {
            let res = (value.as_f() * 1000.).round() / 1000.;

            fields.push(format!("out_temp={}", res));
        }

        if let Some(value) = self.out_humid {
            fields.push(format!("out_humid={}i", value));
        }

        if let Some(value) = self.wind_chill {
            let res = (value.as_f() * 1000.).round() / 1000.;

            fields.push(format!("wind_chill={}", res));
        }

        if let Some(value) = self.heat_index {
            let res = (value.as_f() * 1000.).round() / 1000.;

            fields.push(format!("heat_index={}", res));
        }

        if let Some(value) = self.dew_point {
            let res = (value.as_f() * 1000.).round() / 1000.;

            fields.push(format!("dew_point={}", res));
        }

        format!(
            "weather {} {}",
            fields.join(","),
            self.time.timestamp_millis()
        )
    }
}

#[cfg(test)]
mod tests {
    use metrum::Temp;

    use super::*;

    #[test]
    fn to_line_protocol_0() {
        let reading = WeatherReading {
            device_id: Some(100),
            time: chrono::Utc::now(),
            rain: Some(100.),
            rain_delta: Some(0.5),
            wind_speed: Some(4.),
            wind_dir: Some(180.),
            wind_dir_cardinal: Some("S".to_string()),
            out_temp: Some(Temp::from_f(60.5)),
            out_humid: Some(50),
            wind_chill: Some(Temp::from_f(50.)),
            heat_index: Some(Temp::from_f(60.)),
            dew_point: Some(Temp::from_f(90.)),
        };

        assert_eq!(reading.to_line_protocol(), format!("weather device_id=100i,rain=100,rain_delta=0.5,wind_speed=4,wind_dir=180,wind_dir_cardinal=\"S\",out_temp=60.5,out_humid=50i,wind_chill=50,heat_index=60,dew_point=90 {}", reading.time.timestamp_millis()));
    }

    #[test]
    fn should_handle_empty_values() {
        let mut reading = WeatherReading::new();

        reading.out_temp = Some(Temp::from_f(60.));

        assert_eq!(
            reading.to_line_protocol(),
            format!("weather out_temp=60 {}", reading.time.timestamp_millis())
        );
    }
}