url2audio 0.4.4

A simple-to-use lib for playing audio streams
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
105
106
107
108
109

use std::io::{Read, Seek, SeekFrom};
use symphonia::core::io::MediaSource;

/// Wrapper which impl `Read`, `Seek`, `Send`, `Sync` and `MediaSource`
/// for reader returned by `ureq` request.
pub struct UrlSource {
    url: String,
    reader: Box<dyn Read + Sync + Send>
}

impl UrlSource {
    pub fn new(url: &str) -> Self {
        let r = ureq::get(url).call();
        let r = r.unwrap().into_reader();
        UrlSource {
            reader: Box::new(r),
            url: url.to_string()
        }
    }
}

unsafe impl Send for UrlSource {}
unsafe impl Sync for UrlSource {}

impl MediaSource for UrlSource {
    fn is_seekable(&self) -> bool {
        true
    }

    fn byte_len(&self) -> Option<u64> {
        if let Ok(r) = ureq::get(&self.url).call() {
            let cl = r.header("content-length");
            match cl {
                Some(len_str) => {
                    let len: Result<u64, _> = len_str.to_string().parse();
                    match len {
                        Ok(l) => Some(l),
                        Err(_) => None,
                    }
                },
                None => None,
            }
        } else {
            None
        }
    }
}


impl Read for UrlSource {
    fn read(&mut self, buf: &mut [u8]) -> std::result::Result<usize, std::io::Error> {
        self.reader.read(buf)
    }
}

impl Seek for UrlSource {
    fn seek(&mut self, pos: SeekFrom) -> std::result::Result<u64, std::io::Error> {
        match pos {
            SeekFrom::Start(p) => {
                let res = ureq::get(&self.url).set("Range", &format!("bytes={}-", p)).call();
                let r = res.unwrap().into_reader();
                self.reader = Box::new(r);
                Ok(u64::from_ne_bytes(p.to_ne_bytes()))
            },
            SeekFrom::End(p) => {
                let res = ureq::get(&self.url).set("Range", &format!("bytes=-{}", p)).call();
                let r = res.unwrap().into_reader();
                self.reader = Box::new(r);
                Ok(u64::from_ne_bytes(p.to_ne_bytes()))
            },
            SeekFrom::Current(p) => {
                let res = ureq::get(&self.url).set("Range", &format!("bytes={}-", p)).call();
                let r = res.unwrap().into_reader();
                self.reader = Box::new(r);
                Ok(u64::from_ne_bytes(p.to_ne_bytes()))
            },
        }
    }
}


#[test]
fn ureq_range() {
    let url = "https://podcast.daskoimladja.com/media/2024-05-27-PONEDELJAK_27.05.2024.mp3";
    let r = ureq::get(url).set("Range", "bytes=0-20").call();
    let mut r = r.unwrap().into_reader();
    let mut buf: [u8; 20] = [0; 20];
    let r = r.read_exact(&mut buf);
    println!("r1: {:#?},,, {:#?}", r, buf);
}

#[test]
fn ureq_range2() {
    let url = "https://podcast.daskoimladja.com/media/2024-05-27-PONEDELJAK_27.05.2024.mp3";
    let r = ureq::get(url).set("Range", "bytes=10-").call();
    let mut r = r.unwrap().into_reader();
    let mut buf: [u8; 10] = [0; 10];
    let r = r.read_exact(&mut buf);
    println!("r2: {:#?},,, {:#?}", r, buf);
}

#[test]
fn ureq_content_length() {
    let url = "https://podcast.daskoimladja.com/media/2024-05-27-PONEDELJAK_27.05.2024.mp3";
    let r = ureq::get(url).call().unwrap();
    let headers = r.headers_names();
    let cl = r.header("content-length");
    println!("r3: {:#?},,, {:#?}", headers, cl);
}