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

use super::album_generator::AlbumGenerator;
use crate::testing_prelude::*;
use std::sync::Mutex;

/// Per-config cache of album generation results.
///
/// - `LazyLock`: initialized on first access
/// - `Mutex`: thread-safe access to the map
/// - `HashMap<String, ...>`: keyed by [`AlbumConfig::dir_name`]
/// - `Arc<OnceCell>`: shared across clones so concurrent callers await the same cell
/// - `Result<AlbumConfig, String>`: caches success or error message
#[expect(
    clippy::type_complexity,
    reason = "type alias would obscure cache structure"
)]
static ALBUM_CACHE: LazyLock<Mutex<HashMap<String, Arc<OnceCell<Result<AlbumConfig, String>>>>>> =
    LazyLock::new(|| Mutex::new(HashMap::new()));

/// Cached provider for generated test albums.
pub struct AlbumProvider;

impl AlbumProvider {
    /// Generate sample files for the given format and return the album configuration.
    ///
    /// Convenience wrapper around [`Self::get_advanced`] for the common single-format case.
    pub async fn get(format: SampleFormat) -> AlbumConfig {
        Self::get_advanced(AlbumConfig::with_format(format)).await
    }

    /// Generate sample files for an arbitrary album configuration.
    ///
    /// - Returns a cached result if this config's [`AlbumConfig::dir_name`] was already generated
    /// - Otherwise generates FLAC files, cover image, and torrent
    /// - Panics with a descriptive message if generation fails
    #[expect(
        clippy::panic,
        reason = "sample generation is unrecoverable. clear message is rendered"
    )]
    pub async fn get_advanced(config: AlbumConfig) -> AlbumConfig {
        let key = config.dir_name();
        let cell = {
            let mut map = ALBUM_CACHE
                .lock()
                .expect("album cache mutex should not be poisoned");
            Arc::clone(map.entry(key).or_insert_with(|| Arc::new(OnceCell::new())))
        };
        cell.get_or_init(|| async {
            let source_dir = SAMPLE_SOURCES_DIR.join(config.dir_name());
            if !is_generated(&source_dir) {
                AlbumGenerator::generate_files(&config, &source_dir)
                    .await
                    .map_err(|e| e.render())?;
                mark_generated(&source_dir)?;
            }
            Ok(config)
        })
        .await
        .clone()
        .unwrap_or_else(|e| panic!("Sample generation failed\n{e}"))
    }
}

/// Check whether the `.generated` marker exists for a directory.
fn is_generated(dir: &Path) -> bool {
    dir.join(".generated").exists()
}

/// Create the `.generated` marker indicating successful generation.
fn mark_generated(dir: &Path) -> Result<(), String> {
    let path = dir.join(".generated");
    File::create(&path).map_err(|e| format!("failed to create {}: {e}", path.display()))?;
    Ok(())
}