caesura 0.29.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

use crate::prelude::*;

/// Summarize the status of all items in the queue.
#[injectable]
pub(crate) struct QueueSummaryCommand {
    queue: Ref<Queue>,
}

impl QueueSummaryCommand {
    /// Print a YAML summary of queue status to stdout.
    pub(crate) async fn execute_cli(&self) -> Result<bool, Failure<QueueAction>> {
        let summary = self.execute().await?;
        let yaml = serde_yaml::to_string(&summary).expect("should be able to serialize summary");
        println!("{yaml}");
        Ok(true)
    }

    /// Aggregate queue items into a [`QueueSummary`].
    pub(crate) async fn execute(&self) -> Result<QueueSummary, Failure<QueueAction>> {
        let items = self.queue.get_all().await?;
        let mut summary = QueueSummary::default();
        for (_, item) in items {
            summary.total += 1;
            match &item.indexer {
                Some(indexer) => *summary.indexer.entry(indexer.clone()).or_insert(0) += 1,
                None => summary.indexer_unknown += 1,
            }
            match item.verify {
                None => summary.verify_none += 1,
                Some(VerifyStatus { verified: true, .. }) => summary.verify_verified_true += 1,
                Some(VerifyStatus {
                    verified: false, ..
                }) => summary.verify_verified_false += 1,
            }
            match item.spectrogram {
                None => summary.spectrogram_none += 1,
                Some(SpectrogramStatus { success: true, .. }) => {
                    summary.spectrogram_success_true += 1;
                }
                Some(SpectrogramStatus { success: false, .. }) => {
                    summary.spectrogram_success_false += 1;
                }
            }
            match item.transcode {
                None => summary.transcode_none += 1,
                Some(TranscodeStatus { success: true, .. }) => summary.transcode_success_true += 1,
                Some(TranscodeStatus { success: false, .. }) => {
                    summary.transcode_success_false += 1;
                }
            }
            match item.upload {
                None => summary.upload_none += 1,
                Some(UploadStatus { success: true, .. }) => summary.upload_success_true += 1,
                Some(UploadStatus { success: false, .. }) => summary.upload_success_false += 1,
            }
        }
        Ok(summary)
    }
}