felicia 0.5.1

service for accessing and sharing lists of bad actors
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

use std::time::Instant;

use tokio::sync::{mpsc, oneshot};

use crate::models::List;

use super::Source;

pub async fn spawn<S>(source: S) -> Result<SourceManagerHandle, Error>
where
    S: Source + Send + Sync + 'static,
{
    let mut list = match source.fetch().await {
        Ok(ls) => ls,
        Err(err) => {
            tracing::error!(
                "could not fetch from source -- {err} -- retrying during next request after {} seconds",
                source.lifetime()
            );
            List::empty()
        }
    };
    let mut last_updated = Instant::now();

    let (tx, mut rx) = mpsc::channel(128);
    tokio::spawn(async move {
        while let Some(msg) = rx.recv().await {
            match msg {
                Message::Fetch(sender) => {
                    if Instant::now().duration_since(last_updated).as_secs() > source.lifetime() {
                        match source.fetch().await {
                            Ok(res) => {
                                list = res;
                                last_updated = Instant::now();

                                let _ = sender.send(Ok(list.clone()));
                            }
                            Err(err) => {
                                tracing::error!(
                                    "could not fetch from source -- {err} -- retrying during next request after {} seconds",
                                    source.lifetime()
                                );
                                let _ = sender.send(Err(Error::Fetch));
                            }
                        }
                    } else {
                        let _ = sender.send(Ok(list.clone()));
                    }
                }
                Message::Update => match source.fetch().await {
                    Ok(res) => {
                        list = res;
                        last_updated = Instant::now();
                    }
                    Err(err) => tracing::error!("failed to refresh list: {err}"),
                },
            }
        }
    });

    Ok(SourceManagerHandle { sender: tx })
}

#[derive(Debug, Clone)]
pub struct SourceManagerHandle {
    sender: mpsc::Sender<Message>,
}

impl SourceManagerHandle {
    pub async fn fetch(&self) -> Result<List, Error> {
        let (tx, rx) = oneshot::channel();
        self.sender.send(Message::Fetch(tx)).await.map_err(|err| {
            tracing::error!("failed to contact actor: {err}");
            Error::Channel
        })?;

        rx.await.map_err(|err| {
            tracing::error!("failed to receive response from actor: {err}");
            Error::Channel
        })?
    }

    pub async fn refresh(&self) -> Result<(), Error> {
        self.sender.send(Message::Update).await.map_err(|err| {
            tracing::error!("failed to contact actor: {err}");
            Error::Channel
        })?;

        Ok(())
    }
}

#[derive(Debug)]
pub enum Message {
    Fetch(oneshot::Sender<Result<List, Error>>),
    Update,
}

#[derive(Debug, thiserror::Error)]
pub enum Error {
    #[error("could not fetch from source")]
    Fetch,

    #[error("channel error")]
    Channel,
}