youtui 0.0.37

A simple TUI YouTube Music player
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

use crate::youtube_downloader::{YoutubeMusicDownload, YoutubeMusicDownloader};
use bytes::Bytes;
use futures::Stream;
use rusty_ytdl::{
    DownloadOptions, RequestOptions, Video, VideoError, VideoFormat, VideoOptions, VideoQuality,
    reqwest,
};
use std::sync::Arc;

#[derive(Clone)]
/// # Note
/// Cheap to clone due to use of Arc to store internals.
pub struct NativeYoutubeDownloader {
    options: Arc<VideoOptions>,
}

impl NativeYoutubeDownloader {
    pub fn new(
        dl_chunk_size: u64,
        quality: VideoQuality,
        po_token: Option<String>,
        client: reqwest::Client,
    ) -> Self {
        // Custom rusty_ytdl filter that downloads audio but prevents downloading webm
        // files - the contained Opus codec is not supported by Symphonia.
        let custom_filter = |video_format: &VideoFormat| {
            video_format.has_audio
                && !video_format.has_video
                && video_format.mime_type.container != "webm"
        };
        let options = Arc::new(VideoOptions {
            quality,
            filter: rusty_ytdl::VideoSearchOptions::Custom(Arc::new(custom_filter)),
            download_options: DownloadOptions {
                dl_chunk_size: Some(dl_chunk_size),
            },
            request_options: RequestOptions {
                client: Some(client),
                po_token,
                ..Default::default()
            },
        });
        Self { options }
    }
}

impl YoutubeMusicDownloader for NativeYoutubeDownloader {
    type Error = rusty_ytdl::VideoError;
    async fn stream_song(
        &self,
        song_video_id: impl AsRef<str> + Send,
    ) -> Result<
        YoutubeMusicDownload<impl Stream<Item = Result<Bytes, Self::Error>> + Send>,
        Self::Error,
    > {
        let options = self.options.clone();
        let song_video_id: String = song_video_id.as_ref().into();
        let video = Video::new_with_options(song_video_id, options.as_ref())?;
        // NOTE: This can ony fail if rusty_ytdl fails to build a reqwest::Client.
        let stream = video.stream().await?;
        let total_size_bytes = stream.content_length();
        let stream = into_futures_stream(stream);
        Ok(YoutubeMusicDownload {
            total_size_bytes,
            song: stream,
        })
    }
}

/// Helper function to use rusty_ytdl::stream::Stream is if it were a
/// futures::Stream.
// NOTE: Potentially could be upstreamed: https://github.com/Mithronn/rusty_ytdl/issues/34.
pub fn into_futures_stream(
    youtube_stream: Box<dyn rusty_ytdl::stream::Stream + Send>,
) -> impl futures::Stream<Item = Result<Bytes, VideoError>> + Send {
    // Second value of initialisation tuple represents if the previous iteration of
    // the stream errored. If so, stream will close, as no future iterations of
    // the stream are expected to return Ok.
    futures::stream::unfold((youtube_stream, false), |(state, err)| async move {
        if err {
            return None;
        };
        let chunk = state.chunk().await;
        match chunk {
            // Return error value on this iteration, on the next iteration return None.
            Err(e) => Some((Err(e), (state, true))),
            // Happy path
            Ok(Some(bytes)) => Some((Ok(bytes), (state, false))),
            // Stream has closed.
            Ok(None) => None,
        }
    })
}