caesura 0.31.0

An all-in-one command line tool to transcode FLAC audio files and upload to gazelle based indexers/trackers
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

use crate::prelude::*;

/// Services for interacting with the cross indexer during `cross`.
pub struct CrossServices {
    /// Torrent file provider configured for the cross indexer.
    pub(crate) torrent_files: Ref<TorrentFileProvider>,
    /// Checker that looks up matching torrents on the cross indexer.
    pub(crate) checker: Ref<CrossSeedChecker>,
}

impl CrossServices {
    /// Create a new [`CrossServices`] from the main and cross indexer options.
    ///
    /// - Returns `None` if the cross indexer config is missing or invalid.
    pub(crate) fn create(
        main_options: Ref<SharedOptions>,
        cache_options: Ref<CacheOptions>,
        file_options: Ref<FileOptions>,
        cross_config_options: Ref<CrossConfigOptions>,
    ) -> Option<Self> {
        let shared_options = Ref::new(cross_config_options.load_shared_options().ok()?);
        let paths = Ref::new(PathManager {
            shared_options: shared_options.clone(),
            cache_options,
            file_options,
        });
        let api = create_api(shared_options.clone());
        let torrent_files = Ref::new(TorrentFileProvider {
            paths,
            api: api.clone(),
        });
        let checker = Ref::new(CrossSeedChecker {
            api,
            main: main_options.get_indexer(),
            cross: shared_options.get_indexer(),
        });
        Some(Self {
            torrent_files,
            checker,
        })
    }
}

#[cfg(test)]
impl CrossServices {
    /// Create a [`CrossServices`] using a caller-supplied API client.
    ///
    /// - Mirrors [`CrossServices::create`] but skips the live API construction so tests
    ///   can inject a [`MockGazelleClient`].
    pub(crate) fn mock(
        main_options: Ref<SharedOptions>,
        cache_options: Ref<CacheOptions>,
        file_options: Ref<FileOptions>,
        cross_config_options: Ref<CrossConfigOptions>,
        api: Ref<GazelleClient>,
    ) -> Option<Self> {
        let shared_options = Ref::new(cross_config_options.load_shared_options().ok()?);
        let paths = Ref::new(PathManager {
            shared_options: shared_options.clone(),
            cache_options,
            file_options,
        });
        let torrent_files = Ref::new(TorrentFileProvider {
            paths,
            api: api.clone(),
        });
        let checker = Ref::new(CrossSeedChecker {
            api,
            main: main_options.get_indexer(),
            cross: shared_options.get_indexer(),
        });
        Some(Self {
            torrent_files,
            checker,
        })
    }
}

fn create_api(shared: Ref<SharedOptions>) -> Ref<GazelleClient> {
    let indexer = shared.get_indexer();
    let (num, per) = indexer.gazelle_rate_limit();
    let factory = GazelleClientFactory {
        options: GazelleClientOptions {
            url: shared.indexer_url.clone(),
            key: shared.api_key.clone(),
            user_agent: app_user_agent(true),
            requests_allowed_per_duration: Some(num),
            request_limit_duration: Some(per),
            retry_delays: indexer.gazelle_retry_delays(),
        },
    };
    Ref::new(Box::new(factory.create()))
}