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

use di::{Ref, injectable};

use crate::commands::*;
use crate::utils::*;

use crate::options::CopyOptions;
use rogue_logging::Error;

/// Create a [`TranscodeJob`] for each [`FlacFile`] in the [`Vec<FlacFile>`].
#[injectable]
pub(crate) struct TranscodeJobFactory {
    paths: Ref<PathManager>,
    copy_options: Ref<CopyOptions>,
}

impl TranscodeJobFactory {
    /// Create a [`TranscodeJob`] for each [`FlacFile`] in the [`Vec<FlacFile>`].
    pub(crate) fn create(
        &self,
        flacs: &[FlacFile],
        source: &Source,
        format: TargetFormat,
    ) -> Result<Vec<Job>, Error> {
        let mut jobs = Vec::new();
        for (index, flac) in flacs.iter().enumerate() {
            jobs.push(self.create_single(index, flac, source, format)?);
        }
        Ok(jobs)
    }

    /// Create a single [`TranscodeJob`] from a `flac_file`.
    pub(crate) fn create_single(
        &self,
        index: usize,
        flac: &FlacFile,
        source: &Source,
        format: TargetFormat,
    ) -> Result<Job, Error> {
        let info = flac
            .get_stream_info()
            .map_err(|e| claxon_error(e, "read FLAC"))?;
        let id = format!("Transcode {:<4}{index:>3}", format.to_string());
        let output_path = self.paths.get_transcode_path(source, format, flac);
        let variant = match format {
            TargetFormat::Flac => {
                if is_resample_required(&info) {
                    Variant::Resample(Resample {
                        input: flac.path.clone(),
                        output: output_path.clone(),
                        resample_rate: get_resample_rate(&info)?,
                    })
                } else {
                    Variant::Include(Include {
                        input: flac.path.clone(),
                        output: output_path.clone(),
                        hard_link: self
                            .copy_options
                            .hard_link
                            .expect("hard_link should be set"),
                    })
                }
            }
            TargetFormat::_320 | TargetFormat::V0 => {
                let resample_rate = is_resample_required(&info)
                    .then(|| get_resample_rate(&info))
                    .transpose()?;
                Variant::Transcode(
                    Decode {
                        input: flac.path.clone(),
                        resample_rate,
                    },
                    Encode {
                        format,
                        output: output_path.clone(),
                    },
                )
            }
        };
        let tags = if matches!(format, TargetFormat::_320 | TargetFormat::V0) {
            let mut tags = get_vorbis_tags(flac)?;
            convert_to_id3v2(&mut tags);
            let _ = fix_track_numbering(&mut tags);
            Some(tags)
        } else {
            None
        };
        Ok(Job::Transcode(TranscodeJob { id, variant, tags }))
    }
}