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

use crate::errors::AppError;
use crate::options::{CacheOptions, Options};
use crate::queue::Queue;
use crate::queue::QueueSummary;
use crate::spectrogram::SpectrogramStatus;
use crate::transcode::TranscodeStatus;
use crate::upload::UploadStatus;
use crate::verify::VerifyStatus;
use di::{injectable, Ref, RefMut};

/// List the sources in the queue
#[injectable]
pub struct QueueSummaryCommand {
    cache_options: Ref<CacheOptions>,
    queue: RefMut<Queue>,
}

impl QueueSummaryCommand {
    pub async fn execute_cli(&mut self) -> Result<bool, AppError> {
        if !self.cache_options.validate() {
            return Ok(false);
        }
        let summary = self.execute().await?;
        let yaml = serde_yaml::to_string(&summary)
            .or_else(|e| AppError::yaml(e, "serialize queue summary"))?;
        println!("{yaml}");
        Ok(true)
    }

    pub async fn execute(&mut self) -> Result<QueueSummary, AppError> {
        let mut queue = self.queue.write().expect("Queue should be writeable");
        let items = queue.get_all().await?;
        let mut summary = QueueSummary::default();
        for (_, item) in items {
            summary.total += 1;
            match summary.indexer.get_mut(&item.indexer) {
                Some(count) => *count += 1,
                None => {
                    summary.indexer.insert(item.indexer.clone(), 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)
    }
}