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
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
98
99
100
101
102
103
104

use crate::testing_prelude::*;

/// Test that `QueueAddCommand` adds torrent files from a directory.
#[tokio::test]
async fn queue_add_command_adds_torrent_from_directory() -> Result<(), TestError> {
    let album = AlbumProvider::get(SampleFormat::default()).await;
    let torrent_dir = album.single_torrent_dir();
    let (_test_dir, command, queue) = queue_add_test_helper(torrent_dir.to_path_buf()).await;

    let result = command.execute_cli().await;

    assert!(matches!(result, Ok(true)));
    let items = get_items(queue).await;
    assert_yaml_snapshot!(items);
    Ok(())
}

/// Test that `QueueAddCommand` skips duplicate torrents.
#[tokio::test]
async fn queue_add_command_skips_duplicate() -> Result<(), TestError> {
    let album = AlbumProvider::get(SampleFormat::default()).await;
    let torrent_dir = album.single_torrent_dir();
    let (_test_dir, command, queue) = queue_add_test_helper(torrent_dir.to_path_buf()).await;

    command.execute_cli().await?;
    let items = get_items(queue.clone()).await;
    assert_yaml_snapshot!(items);

    command.execute_cli().await?;
    let items = get_items(queue).await;
    assert_yaml_snapshot!(items);
    Ok(())
}

/// Test that `QueueAddCommand` returns an error for non-existent path.
#[tokio::test]
async fn queue_add_command_nonexistent_path_fails() -> Result<(), TestError> {
    let (_test_dir, command, _queue) =
        queue_add_test_helper(PathBuf::from("/nonexistent/path")).await;

    let result = command.execute_cli().await;

    let error = result.expect_err("should fail for nonexistent path");
    assert_eq!(error.action(), &QueueAction::MatchPath);
    Ok(())
}

/// Test that `QueueAddCommand` handles empty directory.
#[tokio::test]
async fn queue_add_command_empty_directory() -> Result<(), TestError> {
    let temp = TempDirectory::create("empty_torrents");
    let (_test_dir, command, queue) = queue_add_test_helper(temp.to_path_buf()).await;

    let result = command.execute_cli().await;

    assert!(matches!(result, Ok(true)));
    let items = get_items(queue).await;
    assert_yaml_snapshot!(items);
    Ok(())
}

/// Create a host configured for `QueueAddCommand` testing.
///
/// Returns `TestDirectory` to keep it alive for the test duration.
///
/// Callers must bind it to a named variable like `_test_dir`, not a bare `_`:
///
/// ```ignore
/// let (_test_dir, command, queue) = queue_add_test_helper(...).await;
/// ```
///
/// NOT a bare `_` as this discards immediately, deleting the directory mid-test:
///
/// ```ignore
/// let (_, command, queue) = queue_add_test_helper(...).await;
/// ```
async fn queue_add_test_helper(
    queue_add_path: PathBuf,
) -> (TestDirectory, Ref<QueueAddCommand>, Ref<Queue>) {
    init_logger();
    let album = AlbumProvider::get(SampleFormat::default()).await;
    let test_dir = TestDirectory::new();
    let host = HostBuilder::new()
        .with_mock_api(album)
        .with_test_options(&test_dir)
        .await
        .with_options(QueueAddArgs {
            queue_add_path: Some(queue_add_path),
        })
        .expect_build();
    let command = host.services.get_required::<QueueAddCommand>();
    let queue = host.services.get_required::<Queue>();
    (test_dir, command, queue)
}

async fn get_items(queue: Ref<Queue>) -> Vec<String> {
    queue
        .get_all()
        .await
        .expect("should be able to get all items")
        .into_values()
        .map(|item| item.name)
        .collect()
}