eureka-mmanager 0.2.2

An Actix actor collection for downloading manga, chapters, covers from Mangadex
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

use std::ops::{Deref, DerefMut};

use actix::prelude::*;

use crate::{
    history::{service::HistoryActorService, AsyncIsIn, HistoryEntry, IsIn},
    MailBoxResult,
};

#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub struct IsInMessage(pub HistoryEntry);

impl Deref for IsInMessage {
    type Target = HistoryEntry;
    fn deref(&self) -> &Self::Target {
        &self.0
    }
}

impl DerefMut for IsInMessage {
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.0
    }
}

impl From<IsInMessage> for HistoryEntry {
    fn from(value: IsInMessage) -> Self {
        value.0
    }
}

impl From<HistoryEntry> for IsInMessage {
    fn from(value: HistoryEntry) -> Self {
        IsInMessage(value)
    }
}

impl Message for IsInMessage {
    type Result = bool;
}

impl Handler<IsInMessage> for HistoryActorService {
    type Result = bool;
    fn handle(&mut self, msg: IsInMessage, _ctx: &mut Self::Context) -> Self::Result {
        self.is_in(msg.0)
    }
}

impl<'a, T> AsyncIsIn<'a, T> for Addr<HistoryActorService>
where
    T: Into<HistoryEntry>,
{
    type Output = MailBoxResult<bool>;
    fn is_in(&'a self, to_use: T) -> impl std::future::Future<Output = Self::Output> + Send {
        self.send(Into::<IsInMessage>::into(to_use.into()))
    }
}