syncthing 0.6.0

A Rust library for controlling syncthing file synchronization through its REST interface
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

use crate::{Client, Fallible};
use std::iter::Iterator;
use syncthing_types::events::{Event, EventType};

//TODO:self correction mechanism see: https://docs.syncthing.net/rest/events-get.html#events-get
pub struct EventStream {
    client: Client,
    events: Vec<EventType>,
    buffer: Option<Vec<Event>>,
    since: Option<u64>,
}

impl EventStream {
    pub(crate) fn new(client: Client, events: Vec<EventType>) -> Self {
        Self {
            client,
            events,
            buffer: None,
            since: None,
        }
    }
}

impl Iterator for EventStream {
    type Item = Fallible<Event>;

    fn next(&mut self) -> Option<Self::Item> {
        loop {
            match self.buffer {
                Some(ref mut data) => {
                    if let Some(event) = data.pop() {
                        self.since = Some(event.id);
                        return Some(Ok(event));
                    } else {
                        self.buffer = None;
                    }
                }
                None => match self.client.get_events(self.since, None, &self.events) {
                    Ok(mut data) => {
                        data.reverse();
                        self.buffer = Some(data);
                    }
                    Err(err) => return Some(Err(err)),
                },
            }
        }
    }
}