eureka-mmanager 0.3.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

pub mod client;
pub mod dir_options;
pub mod history;

use std::future::Future;

use actix::Addr;
use mangadex_api::MangaDexClient;

use crate::{
    download::{messages::state::GetManagerState, state::DownloadManagerState},
    history::service::HistoryActorService,
    DirsOptions, MailBoxResult,
};

pub use self::{
    client::GetClientMessage, dir_options::GetDirsOptionsMessage, history::GetHistoryMessage,
};

pub trait GetManagerStateData: Sync {
    fn get_client(&self) -> impl Future<Output = MailBoxResult<MangaDexClient>> + Send;
    fn get_dir_options(&self) -> impl Future<Output = MailBoxResult<Addr<DirsOptions>>> + Send;
    fn get_history(&self) -> impl Future<Output = MailBoxResult<Addr<HistoryActorService>>> + Send;
}

impl GetManagerStateData for Addr<DownloadManagerState> {
    fn get_client(&self) -> impl Future<Output = MailBoxResult<MangaDexClient>> + Send {
        self.send(GetClientMessage)
    }
    fn get_dir_options(&self) -> impl Future<Output = MailBoxResult<Addr<DirsOptions>>> + Send {
        self.send(GetDirsOptionsMessage)
    }
    fn get_history(&self) -> impl Future<Output = MailBoxResult<Addr<HistoryActorService>>> + Send {
        self.send(GetHistoryMessage)
    }
}

impl<A> GetManagerStateData for A
where
    A: GetManagerState + Sync,
{
    async fn get_client(&self) -> MailBoxResult<MangaDexClient> {
        self.get_manager_state().await?.get_client().await
    }
    async fn get_dir_options(&self) -> MailBoxResult<Addr<DirsOptions>> {
        self.get_manager_state().await?.get_dir_options().await
    }
    async fn get_history(&self) -> MailBoxResult<Addr<HistoryActorService>> {
        self.get_manager_state().await?.get_history().await
    }
}