dash-mpd 0.20.2

Parse, serialize, download an MPD manifest for MPEG-DASH or WebM-DASH media streaming
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

// Tests for the role_preference functionality
//
// To run tests while enabling printing to stdout/stderr
//
//    cargo test --test role -- --show-output
//
// https://testassets.dashif.org/#feature/details/5a1c4bd87cccbb15567e567e

pub mod common;
use std::fs;
use std::env;
use ffprobe::ffprobe;
use file_format::FileFormat;
use dash_mpd::fetch::DashDownloader;
use common::{check_file_size_approx, setup_logging};


// This manifest has role=main and role=alternate but segments are timing out as of May 2024
// https://dash.akamaized.net/microsoft/multiple-adaptation-test.mpd


// This manifest has role=main (HEVC 10 bit) and role=alternate (HEVC 8 bit) streams in different
// AdaptationSets.
#[tokio::test]
async fn test_role_main() {
    setup_logging();
    if env::var("CI").is_ok() {
        return;
    }
    let mpd_url = "https://dash.akamaized.net/dash264/TestCasesIOP41/MultiTrack/alternative_content/2/manifest_alternative_content_ondemand.mpd";
    let tmpd = tempfile::tempdir().unwrap();
    let out = tmpd.path().join("role-main.mp4");
    DashDownloader::new(mpd_url)
        .worst_quality()
        .prefer_roles(vec!["main".to_string()])
        .download_to(&out).await
        .unwrap();
    check_file_size_approx(&out, 189_121_991);
    let format = FileFormat::from_file(&out).unwrap();
    assert_eq!(format, FileFormat::Mpeg4Part14Video);
    let meta = ffprobe(out).unwrap();
    assert_eq!(meta.streams.len(), 2);
    let video = meta.streams.iter()
        .find(|s| s.codec_type.eq(&Some(String::from("video"))))
        .expect("finding video stream");
    assert_eq!(video.pix_fmt, Some(String::from("yuv420p10le")));
    let entries = fs::read_dir(tmpd.path()).unwrap();
    let count = entries.count();
    assert_eq!(count, 1, "Expecting a single output file, got {count}");
    let _ = fs::remove_dir_all(tmpd);
}

#[tokio::test]
async fn test_role_alternate() {
    if env::var("CI").is_ok() {
        return;
    }
    let mpd_url = "https://dash.akamaized.net/dash264/TestCasesIOP41/MultiTrack/alternative_content/2/manifest_alternative_content_ondemand.mpd";
    let tmpd = tempfile::tempdir().unwrap();
    let out = tmpd.path().join("role-alternate.mp4");
    DashDownloader::new(mpd_url)
        .worst_quality()
        .prefer_roles(vec!["alternate".to_string(), "imaginary".to_string()])
        .download_to(&out).await
        .unwrap();
    check_file_size_approx(&out, 196_041_016);
    let meta = ffprobe(&out).unwrap();
    assert_eq!(meta.streams.len(), 2);
    let video = meta.streams.iter()
        .find(|s| s.codec_type.eq(&Some(String::from("video"))))
        .expect("finding video stream");
    assert_eq!(video.pix_fmt, Some(String::from("yuv420p")));
    let format = FileFormat::from_file(&out).unwrap();
    assert_eq!(format, FileFormat::Mpeg4Part14Video);
    let entries = fs::read_dir(tmpd.path()).unwrap();
    let count = entries.count();
    assert_eq!(count, 1, "Expecting a single output file, got {count}");
    let _ = fs::remove_dir_all(tmpd);
}