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
94
95
96
97

use crate::prelude::*;

/// Factory for creating [`TranscodeJob`] instances.
#[injectable]
pub(crate) struct TranscodeJobFactory {
    paths: Ref<PathManager>,
    copy_options: Ref<CopyOptions>,
    target_options: Ref<TargetOptions>,
    sox: Ref<SoxFactory>,
}

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>, Failure<TranscodeAction>> {
        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, Failure<TranscodeAction>> {
        let info = flac.get_stream_info().map_err(Failure::wrap_with_path(
            TranscodeAction::ReadFlac,
            &flac.path,
        ))?;
        let id = format!("Transcode {:<4}{index:>3}", format.to_string());
        let output_path = self.paths.get_transcode_path(source, format, flac);
        let repeatable = !self.target_options.sox_random_dither;
        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).map_err(
                            Failure::wrap_with_path(TranscodeAction::GetSampleRate, &flac.path),
                        )?,
                        repeatable,
                        sox: self.sox.clone(),
                    })
                } else {
                    Variant::Include(Include {
                        input: flac.path.clone(),
                        output: output_path.clone(),
                        hard_link: self.copy_options.hard_link,
                    })
                }
            }
            TargetFormat::_320 | TargetFormat::V0 => {
                let resample_rate = is_resample_required(&info)
                    .then(|| get_resample_rate(&info))
                    .transpose()
                    .map_err(Failure::wrap_with_path(
                        TranscodeAction::GetSampleRate,
                        &flac.path,
                    ))?;
                Variant::Transcode(
                    Decode {
                        input: flac.path.clone(),
                        resample_rate,
                        repeatable,
                        sox: self.sox.clone(),
                    },
                    Encode {
                        format,
                        output: output_path.clone(),
                    },
                )
            }
        };
        let tags = if matches!(format, TargetFormat::_320 | TargetFormat::V0) {
            Some(flac.id3_tags()?.clone())
        } else {
            None
        };
        let exclude_vorbis_comments = self.target_options.exclude_vorbis_comments.clone();
        Ok(Job::Transcode(TranscodeJob {
            id,
            variant,
            tags,
            exclude_vorbis_comments,
        }))
    }
}