ff-stream 0.14.3

HLS and DASH adaptive streaming output for the ff-* crate family
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

//! Integration tests for `SrtOutput` (feature = "srt").
//!
//! Tests that validate builder configuration without requiring a live SRT server.
//! When the linked `FFmpeg` build does not include libsrt, all connection tests are
//! skipped via the `ProtocolUnavailable` early-return path.

#[cfg(feature = "srt")]
mod srt_tests {
    use ff_format::{AudioCodec, VideoCodec};
    use ff_stream::{SrtOutput, StreamError};

    #[test]
    fn srt_build_without_srt_scheme_should_return_invalid_config() {
        // Skip if libsrt is not available (ProtocolUnavailable would be returned first).
        if !ff_sys::avformat::srt_available() {
            println!("Skipping: libsrt not available in linked FFmpeg");
            return;
        }
        let result = SrtOutput::new("rtmp://example.com/live")
            .video(1280, 720, 30.0)
            .build();
        assert!(
            matches!(result, Err(StreamError::InvalidConfig { .. })),
            "expected InvalidConfig for non-srt URL"
        );
    }

    #[test]
    fn srt_build_without_video_should_return_invalid_config() {
        if !ff_sys::avformat::srt_available() {
            println!("Skipping: libsrt not available in linked FFmpeg");
            return;
        }
        let result = SrtOutput::new("srt://127.0.0.1:9000").build();
        assert!(
            matches!(result, Err(StreamError::InvalidConfig { .. })),
            "expected InvalidConfig when video() not called"
        );
    }

    #[test]
    fn srt_build_with_non_h264_video_codec_should_return_unsupported_codec() {
        if !ff_sys::avformat::srt_available() {
            println!("Skipping: libsrt not available in linked FFmpeg");
            return;
        }
        let result = SrtOutput::new("srt://127.0.0.1:9000")
            .video(1280, 720, 30.0)
            .video_codec(VideoCodec::Vp9)
            .build();
        assert!(
            matches!(result, Err(StreamError::UnsupportedCodec { .. })),
            "expected UnsupportedCodec for VP9"
        );
    }

    #[test]
    fn srt_build_with_non_aac_audio_codec_should_return_unsupported_codec() {
        if !ff_sys::avformat::srt_available() {
            println!("Skipping: libsrt not available in linked FFmpeg");
            return;
        }
        let result = SrtOutput::new("srt://127.0.0.1:9000")
            .video(1280, 720, 30.0)
            .audio_codec(AudioCodec::Mp3)
            .build();
        assert!(
            matches!(result, Err(StreamError::UnsupportedCodec { .. })),
            "expected UnsupportedCodec for MP3"
        );
    }

    #[test]
    fn srt_build_without_libsrt_should_return_protocol_unavailable() {
        if ff_sys::avformat::srt_available() {
            println!("Skipping: libsrt is available; cannot test ProtocolUnavailable path");
            return;
        }
        let result = SrtOutput::new("srt://127.0.0.1:9000")
            .video(1280, 720, 30.0)
            .build();
        assert!(
            matches!(result, Err(StreamError::ProtocolUnavailable { .. })),
            "expected ProtocolUnavailable when libsrt is absent"
        );
    }
}

// Ensure the file compiles even without the srt feature.
#[cfg(not(feature = "srt"))]
#[test]
fn srt_feature_not_enabled_is_expected() {
    println!("srt feature is not enabled; SrtOutput integration tests are skipped");
}