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

use crate::prelude::*;
use qbittorrent_api::get_torrents::{FilterOptions, Torrent};

/// Discover torrents via the qBittorrent API and add them to the queue.
///
/// - Query the API once per category (HTTP call, fast)
/// - Filter to fully downloaded torrents (in-memory, fast)
/// - Dedupe by hash and exclude torrents already in the queue (in-memory, fast)
/// - Build queue items directly from API response data (in-memory, fast)
///
/// On subsequent runs, only newly added torrents are inserted.
#[injectable]
pub(crate) struct QueueFetchCommand {
    qbit_options: Ref<QbitOptions>,
    queue_fetch_options: Ref<QueueFetchOptions>,
    qbit: Ref<QbitClient>,
    queue: Ref<Queue>,
}

impl QueueFetchCommand {
    /// Execute [`QueueFetchCommand`] from the CLI.
    pub(crate) async fn execute_cli(&self) -> Result<bool, Failure<QueueAction>> {
        self.qbit_options
            .check_connection_or(QueueAction::FetchTorrents)?;
        let status = self.execute().await?;
        info!("{} {} items to the queue", "Added".bold(), status.added);
        trace!(
            "{} {} items already in the queue",
            "Excluded".bold(),
            status.excluded
        );
        Ok(true)
    }

    async fn execute(&self) -> Result<QueueStatus, Failure<QueueAction>> {
        let categories = &self.queue_fetch_options.qbit_fetch_categories;
        let mut torrents: Vec<Torrent> = Vec::new();
        for category in categories {
            let filters = FilterOptions {
                category: Some(category.clone()),
                ..FilterOptions::default()
            };
            let response = self
                .qbit
                .get_torrents(filters)
                .await
                .map_err(Failure::wrap(QueueAction::FetchTorrents))?;
            let result = response
                .get_result("get torrents")
                .map_err(Failure::wrap(QueueAction::FetchTorrents))?;
            torrents.extend(result);
        }
        let total_from_api = torrents.len();
        torrents.retain(|t| t.amount_left == 0);
        let downloaded = torrents.len();
        trace!(
            "{} {} torrents from API ({} fully downloaded)",
            "Fetched".bold(),
            total_from_api,
            downloaded
        );
        let existing = self.queue.get_all().await?;
        let mut seen: HashSet<Hash<20>> = existing.keys().copied().collect();
        let items: BTreeMap<Hash<20>, QueueItem> = torrents
            .iter()
            .filter_map(QueueItem::from_qbit_torrent)
            .filter(|item| seen.insert(item.hash))
            .map(|item| (item.hash, item))
            .collect();
        let new_count = items.len();
        info!("{} {} new torrents", "Found".bold(), new_count);
        if new_count == 0 {
            return Ok(QueueStatus {
                success: true,
                added: 0,
                excluded: total_from_api,
            });
        }
        let added = self.queue.set_many(items, false).await?;
        Ok(QueueStatus {
            success: true,
            added,
            excluded: total_from_api - added,
        })
    }
}