eureka-mmanager 0.1.3

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

use std::{fs::read_dir, ops::Deref, path::Path};

use actix::prelude::*;
use uuid::Uuid;

use crate::{
    data_pulls::{chapter::images::ChapterImagesData, Pull},
    files_dirs::FileExtension,
    DirsOptions, ManagerCoreResult,
};

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

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

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

impl Message for ChapterImagesPullMessage {
    type Result = ManagerCoreResult<ChapterImagesData>;
}

impl Pull<ChapterImagesData, ChapterImagesPullMessage> for DirsOptions {
    fn pull(&self, id: ChapterImagesPullMessage) -> ManagerCoreResult<ChapterImagesData> {
        self.deref()
            .pull(Into::<Uuid>::into(id))
            .map_err(|e: api_core::Error| e.into())
    }

    type Error = crate::Error;
}

fn get_data<P: AsRef<Path>>(p: P) -> Vec<String> {
    read_dir(p)
        .map(|read| {
            read.flatten()
                .map(|p| p.path())
                .filter(|p| p.is_image())
                .flat_map(|p| Some(String::from(p.as_os_str().to_str()?)))
                .collect::<Vec<_>>()
        })
        .unwrap_or_default()
}

impl Handler<ChapterImagesPullMessage> for DirsOptions {
    type Result = <ChapterImagesPullMessage as Message>::Result;
    fn handle(&mut self, msg: ChapterImagesPullMessage, _ctx: &mut Self::Context) -> Self::Result {
        let data = get_data(self.chapters_id_data_add(msg.0));
        let data_saver = get_data(self.chapters_id_data_saver_add(msg.0));
        Ok(ChapterImagesData { data, data_saver })
    }
}