yngvi 0.1.0

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

use crate::core::{WeatherReading, Writer};

pub struct RetryManager {
    pub failed_writes: Vec<WeatherReading>,
}

impl RetryManager {
    pub fn new() -> Self {
        Self {
            failed_writes: vec![],
        }
    }

    pub fn add(&mut self, reading: WeatherReading) {
        self.failed_writes.push(reading);
    }

    pub async fn replay_failed_writes<T: Writer>(&mut self, writer: &mut T) {
        if self.failed_writes.len() > 0 {
            println!("Replaying previously failed writes");

            let mut writes_to_clear: Vec<WeatherReading> = vec![];

            for r in &self.failed_writes {
                let res = writer.write(r).await;

                if res.is_ok() {
                    writes_to_clear.push(r.clone());
                }
            }

            for r in writes_to_clear {
                self.failed_writes
                    .retain(|x: &WeatherReading| x.time != r.time)
            }
        }
    }
}