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

use crate::core::{
    calc_dew_point, calc_heat_index, calc_wind_chill, wind_dir_to_cardinal, RetryManager,
    WeatherReading, WeatherReadingSource, Writer,
};

pub struct Station {
    pub weather_reading: WeatherReading,
    pub retry_manager: RetryManager,
}

impl Station {
    pub fn new() -> Self {
        Self {
            weather_reading: WeatherReading::new(),
            retry_manager: RetryManager::new(),
        }
    }

    pub async fn start<R: Iterator<Item = WeatherReadingSource>, W: Writer>(
        &mut self,
        reader: R,
        writer: &mut W,
    ) -> Result<&WeatherReading, ()> {
        for reading in reader {
            self.weather_reading.device_id = reading.device_id;
            self.weather_reading.time = reading.time;
            self.weather_reading.wind_speed = reading.wind_speed;

            // be sure not to clear temp
            if let Some(out_temp) = reading.out_temp {
                self.weather_reading.out_temp = Some(out_temp);
            }

            // Calculate wind chill if a temp has already been recorded
            if let Some(out_temp) = self.weather_reading.out_temp {
                if let Some(wind_speed) = reading.wind_speed {
                    self.weather_reading.wind_chill = Some(calc_wind_chill(wind_speed, out_temp));
                }
            }

            // update humidity
            if let Some(out_humid) = reading.out_humid {
                self.weather_reading.out_humid = Some(out_humid);

                // update heat index and dew point
                if let Some(out_temp) = reading.out_temp {
                    self.weather_reading.heat_index = Some(calc_heat_index(out_temp, out_humid));
                    self.weather_reading.dew_point = Some(calc_dew_point(out_temp, out_humid));
                }
            }

            // update rain totals
            self.weather_reading.rain_delta = Some(0.0); // Always clear rain_delta. (Will reassign if available)

            // update rain totals
            if let Some(new_rain_total) = reading.rain {
                // Update the rain delta if the new rain total is greater then the previously recorded
                if let Some(prev_rain_total) = self.weather_reading.rain {
                    if new_rain_total >= prev_rain_total {
                        self.weather_reading.rain_delta = Some(new_rain_total - prev_rain_total);
                    }
                }

                self.weather_reading.rain = Some(new_rain_total);
            }

            // update wind direction
            if let Some(wind_direction) = reading.wind_dir {
                self.weather_reading.wind_dir = Some(wind_direction);

                let wind_dir_cardinal = wind_dir_to_cardinal(wind_direction);
                self.weather_reading.wind_dir_cardinal = Some(wind_dir_cardinal.to_string())
            }

            // write the result to the database
            let write_result = writer.write(&self.weather_reading).await;

            if write_result.is_ok() {
                self.retry_manager.replay_failed_writes(writer).await;
            } else {
                println!("There was a problem when calling writer.write()");

                self.retry_manager.add(self.weather_reading.clone());
            }
        }

        Result::Ok(&self.weather_reading)
    }
}