eureka-mmanager 0.1.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
58
59
60
61
62
63
64
65
66

use std::ops::Deref;

use actix::prelude::*;
use mangadex_api_schema_rust::v5::MangaObject;
use mangadex_api_types_rust::Language;
use tokio_stream::StreamExt;
use uuid::Uuid;

use crate::{
    data_pulls::Pull,
    files_dirs::messages::pull::chapter::ChapterListDataPullMessage,
    prelude::{ChapterListDataPullFilterParams, IntoParamedFilteredStream},
    DirsOptions, ManagerCoreResult,
};

#[derive(Debug, Clone, Hash, Default)]
pub struct MangaDataPullMessage(pub Uuid);

impl From<Uuid> for MangaDataPullMessage {
    fn from(value: Uuid) -> Self {
        Self(value)
    }
}

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

impl Message for MangaDataPullMessage {
    type Result = ManagerCoreResult<MangaObject>;
}

impl Handler<MangaDataPullMessage> for DirsOptions {
    type Result = ResponseFuture<<MangaDataPullMessage as Message>::Result>;

    fn handle(&mut self, msg: MangaDataPullMessage, ctx: &mut Self::Context) -> Self::Result {
        let manga: ManagerCoreResult<MangaObject> = self
            .deref()
            .deref()
            .pull(msg.into())
            .map_err(|e: api_core::Error| e.into());
        let chapter_pull = self.handle(ChapterListDataPullMessage, ctx);
        Box::pin(async move {
            let mut manga = manga?;
            if let Ok(pull) = chapter_pull {
                let langs = pull
                    .to_filtered(ChapterListDataPullFilterParams {
                        manga_ids: vec![manga.id],
                        ..Default::default()
                    })
                    .fold(Vec::<Language>::new(), |mut acc, chapter| {
                        let lang = chapter.attributes.translated_language;
                        if !acc.contains(&lang) {
                            acc.push(lang);
                        }
                        acc
                    })
                    .await;
                manga.attributes.available_translated_languages = langs;
            }
            Ok(manga)
        })
    }
}