tytd/Tesses.YouTubeDownloader/TYTDClient.cs

using Newtonsoft.Json;
using YoutubeExplode.Videos.Streams;
using System.Linq;
using System;
using System.Threading.Tasks;
using YoutubeExplode.Videos;
using System.Threading;
using YoutubeExplode.Exceptions;
using System.Collections.Generic;
using System.IO;
using YoutubeExplode.Channels;
using YoutubeExplode.Playlists;
using System.Net.Http;
using System.Net;

using System.Diagnostics.CodeAnalysis;
using YoutubeExplode.Utils.Extensions;
using System.Net.Http.Headers;
using System.Web;

namespace Tesses.YouTubeDownloader
{

//From YouTubeExplode
internal static class Helpers
{
     public static async ValueTask<HttpResponseMessage> HeadAsync(
        this HttpClient http,
        string requestUri,
        CancellationToken cancellationToken = default)
    {
        using var request = new HttpRequestMessage(HttpMethod.Head, requestUri);
        return await http.SendAsync(
            request,
            HttpCompletionOption.ResponseHeadersRead,
            cancellationToken
        );
    }
     public static async ValueTask<Stream> GetStreamAsync(
        this HttpClient http,
        string requestUri,
        long? from = null,
        long? to = null,
        bool ensureSuccess = true,
        CancellationToken cancellationToken = default)
    {
        using var request = new HttpRequestMessage(HttpMethod.Get, requestUri);
        request.Headers.Range = new RangeHeaderValue(from, to);

        var response = await http.SendAsync(
            request,
            HttpCompletionOption.ResponseHeadersRead,
            cancellationToken
        );

        if (ensureSuccess)
            response.EnsureSuccessStatusCode();
        
        return await response.Content.ReadAsStreamAsync();
    }

    public static async ValueTask<long?> TryGetContentLengthAsync(
        this HttpClient http,
        string requestUri,
        bool ensureSuccess = true,
        CancellationToken cancellationToken = default)
    {
        using var response = await http.HeadAsync(requestUri, cancellationToken);

        if (ensureSuccess)
            response.EnsureSuccessStatusCode();

        return response.Content.Headers.ContentLength;
    }
}


// Special abstraction that works around YouTube's stream throttling
// and provides seeking support.
// From YouTubeExplode
internal class SegmentedHttpStream : Stream
{
    private readonly HttpClient _http;
    private readonly string _url;
    private readonly long? _segmentSize;

    private Stream _segmentStream;
    private long _actualPosition;

    [ExcludeFromCodeCoverage]
    public override bool CanRead => true;

    [ExcludeFromCodeCoverage]
    public override bool CanSeek => true;

    [ExcludeFromCodeCoverage]
    public override bool CanWrite => false;

    public override long Length { get; }

    public override long Position { get; set; }

    public SegmentedHttpStream(HttpClient http, string url, long length, long? segmentSize)
    {
        _url = url;
        _http = http;
        Length = length;
        _segmentSize = segmentSize;
    }

    private void ResetSegmentStream()
    {
        _segmentStream?.Dispose();
        _segmentStream = null;
    }

    private async ValueTask<Stream> ResolveSegmentStreamAsync(
        CancellationToken cancellationToken = default)
    {
        if (_segmentStream != null)
            return _segmentStream;

        var from = Position;

        var to = _segmentSize != null
            ? Position + _segmentSize - 1
            : null;

        var stream = await _http.GetStreamAsync(_url, from, to, true, cancellationToken);

        return _segmentStream = stream;
    }

    public async ValueTask PreloadAsync(CancellationToken cancellationToken = default) =>
        await ResolveSegmentStreamAsync(cancellationToken);

    public override async Task<int> ReadAsync(byte[] buffer, int offset, int count, CancellationToken cancellationToken)
    {
        while (true)
        {
            // Check if consumer changed position between reads
            if (_actualPosition != Position)
                ResetSegmentStream();

            // Check if finished reading (exit condition)
            if (Position >= Length)
                return 0;

            var stream = await ResolveSegmentStreamAsync(cancellationToken);
            var bytesRead = await stream.ReadAsync(buffer, offset, count, cancellationToken);
            _actualPosition = Position += bytesRead;

            if (bytesRead != 0)
                return bytesRead;

            // Reached the end of the segment, try to load the next one
            ResetSegmentStream();
        }
    }

    [ExcludeFromCodeCoverage]
    public override int Read(byte[] buffer, int offset, int count) =>
        ReadAsync(buffer, offset, count).GetAwaiter().GetResult();

    [ExcludeFromCodeCoverage]
    public override long Seek(long offset, SeekOrigin origin) => Position = origin switch
    {
        SeekOrigin.Begin => offset,
        SeekOrigin.Current => Position + offset,
        SeekOrigin.End => Length + offset,
        _ => throw new ArgumentOutOfRangeException(nameof(origin))
    };

    [ExcludeFromCodeCoverage]
    public override void Flush() =>
        throw new NotSupportedException();

    [ExcludeFromCodeCoverage]
    public override void SetLength(long value) =>
        throw new NotSupportedException();

    [ExcludeFromCodeCoverage]
    public override void Write(byte[] buffer, int offset, int count) =>
        throw new NotSupportedException();

    protected override void Dispose(bool disposing)
    {
        base.Dispose(disposing);

        if (disposing)
        {
            ResetSegmentStream();
        }
    }
}
    public class TYTDClient : TYTDBase,IDownloader
    {
        ExtraData data=null;
        public override async Task<byte[]> ReadThumbnailAsync(VideoId videoId, string res, CancellationToken token = default)
        {
            if(CanReadThumbnailFromUrl())
            {
                return await client.GetByteArrayAsync($"{url}api/v2/Thumbnail?v={videoId.Value}&res={res}");
            }
            return await base.ReadThumbnailAsync(videoId,res,token);
        }
        private bool CanReadThumbnailFromUrl()
        {
            var data=GetExtraDataOnce();
            Version v=new Version(data.TYTDServerVersion);
            return v.Major >= 2;
        }
        string url;
        public string Url {get{return url;}}
        public TYTDClient(string url)
        {
            client=new HttpClient();
            this.url = url.TrimEnd('/') + '/';
        }
       
        public TYTDClient(HttpClient clt,string url)
        {
            client = clt;
            this.url = url.TrimEnd('/') + '/';
        }
        public TYTDClient(HttpClient clt, Uri uri)
        {
            client=clt;
           this.url = url.ToString().TrimEnd('/') + '/';
        }
        public TYTDClient(Uri uri)
        {
            client=new HttpClient();
            this.url = url.ToString().TrimEnd('/') + '/';
        }
        HttpClient client;
        public async Task AddChannelAsync(ChannelId id, Resolution resolution = Resolution.PreMuxed)
        {
            try{
            await client.GetStringAsync($"{url}api/v2/AddChannel?v={id.Value}&res={resolution.ToString()}");
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }

        public async Task AddPlaylistAsync(PlaylistId id, Resolution resolution = Resolution.PreMuxed)
        {
           try{
            await client.GetStringAsync($"{url}api/v2/AddPlaylist?v={id.Value}&res={resolution.ToString()}");
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }

        public async Task AddUserAsync(UserName userName, Resolution resolution = Resolution.PreMuxed)
        {
            try{
            await client.GetStringAsync($"{url}api/v2/AddUser?id={userName.Value}&res={resolution.ToString()}");
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }

        public async Task AddVideoAsync(VideoId id, Resolution resolution = Resolution.PreMuxed)
        {
            try{
            await client.GetStringAsync($"{url}api/v2/AddVideo?v={id.Value}&res={resolution.ToString()}");
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public async Task AddFileAsync(string url,bool download=true)
        {
            try{
                await client.GetStringAsync($"{url}api/v2/AddFile?url={WebUtility.UrlEncode(url)}&download={download}");
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public override async Task<bool> DirectoryExistsAsync(string path)
        {
           try{
            string v=await client.GetStringAsync($"{url}api/Storage/DirectoryExists/{path}");
            return v=="true";
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
            return false;
        }

        public async override IAsyncEnumerable<string> EnumerateDirectoriesAsync(string path)
        {
            List<string> items=null;
             try{
            string v=await client.GetStringAsync($"{url}api/Storage/GetDirectory/{path}");
            items=JsonConvert.DeserializeObject<List<string>>(v);
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }

            if(items==null)
            {
                yield break;
            }else{
                foreach(var item in items)
                {
                    yield return await Task.FromResult(item);
                }
            }
        }
        public override async Task<(string Path,bool Delete)> GetRealUrlOrPathAsync(string path)
        {
            return await Task.FromResult(($"{url}api/Storage/File/{path.TrimStart('/')}",false));
        }
        public async IAsyncEnumerable<Subscription> GetSubscriptionsAsync()
        {
            
            string v="[]";
            try{
                   v=await client.GetStringAsync($"{url}api/v2/subscriptions");
               }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }    
            foreach(var item in JsonConvert.DeserializeObject<List<Subscription>>(v))
            {
                      yield return await Task.FromResult(item);
            }
            
           
        }
        public async Task UnsubscribeAsync(ChannelId id)
        {
            try{
                  string v=await client.GetStringAsync($"{url}api/v2/unsubscribe?id={id.Value}");
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public async Task SubscribeAsync(ChannelId id,ChannelBellInfo bellInfo = ChannelBellInfo.NotifyAndDownload)
        {
              try{
                 
                  string v=await client.GetStringAsync($"{url}api/v2/subscribe?id={id.Value}&conf={bellInfo.ToString()}");
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public async Task SubscribeAsync(UserName name,ChannelBellInfo info=ChannelBellInfo.NotifyAndDownload)
        {
             try{
                
                  
                  string v=await client.GetStringAsync($"{url}api/v2/subscribe?id={ WebUtility.UrlEncode(name.Value)}&conf={info.ToString()}");
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public async Task ResubscribeAsync(ChannelId id,ChannelBellInfo info=ChannelBellInfo.NotifyAndDownload)
        {
             try{
                
                  
                  string v=await client.GetStringAsync($"{url}api/v2/resubscribe?id={id.Value}&conf={info.ToString()}");
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public async override IAsyncEnumerable<string> EnumerateFilesAsync(string path)
        {
            List<string> items=null;
             try{
            string v=await client.GetStringAsync($"{url}api/Storage/GetFiles/{path}");
            items=JsonConvert.DeserializeObject<List<string>>(v);
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }

            if(items==null)
            {
                yield break;
            }else{
                foreach(var item in items)
                {
                    yield return await Task.FromResult(item);
                }
            }
        }

        public async override Task<bool> FileExistsAsync(string path)
        {
           try{
            string v=await client.GetStringAsync($"{url}api/Storage/FileExists/{path}");
            return v=="true";
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
            return false;
        }
        public async Task<IReadOnlyList<(SavedVideo Video, Resolution Resolution)>> GetQueueListAsync()
        {
               
             try{
            string v=await client.GetStringAsync($"{url}api/v2/QueueList");
            return JsonConvert.DeserializeObject<List<(SavedVideo Video,Resolution res)>>(v);
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }

           return new List<(SavedVideo video,Resolution resolution)>();
        }
        public async Task<SavedVideoProgress> GetProgressAsync()
        {
               
             try{
            string v=await client.GetStringAsync($"{url}api/v2/Progress");
            return JsonConvert.DeserializeObject<SavedVideoProgress>(v);
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }

           return null;
        }
        public SavedVideoProgress GetProgress()
        {
            if(hadBeenListeningToEvents)
            {
                return progress;
            }else{
                return Task.Run(GetProgressAsync).GetAwaiter().GetResult();
            }
        }
        
        public IReadOnlyList<(SavedVideo Video, Resolution Resolution)> GetQueueList()
        {
            return Task.Run(GetQueueListAsync).GetAwaiter().GetResult();
        }

       

        public async override Task<Stream> OpenReadAsync(string path)
        {
               
             try{
                var strmLen= await client.TryGetContentLengthAsync($"{url}api/Storage/File/{path}",true);
            SegmentedHttpStream v=new SegmentedHttpStream(client,$"{url}api/Storage/File/{path}",strmLen.GetValueOrDefault(),null);
            return v;
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }

           return Stream.Null;
        }

        public async Task AddToPersonalPlaylistAsync(string name, IEnumerable<ListContentItem> items)
        {
             foreach(var item in items)
             {
                var response = await client.GetStringAsync($"{url}api/v2/AddToList?name={WebUtility.UrlEncode(name)}&v={item.Id}&res={item.Resolution.ToString()}");
            }
        }

        public async Task ReplacePersonalPlaylistAsync(string name, IEnumerable<ListContentItem> items)
        {
            var content = new MultipartFormDataContent();
            content.Add(new StringContent(name), "name");
            content.Add(new StringContent(JsonConvert.SerializeObject(items.ToList())), "data");
            await client.PostAsync($"{url}api/v2/ReplaceList",content);
        }

        public async Task RemoveItemFromPersonalPlaylistAsync(string name, VideoId id)
        {
             try{
                
                  
                  await client.GetStringAsync($"{url}api/v2/DeleteFromList?name={WebUtility.UrlEncode(name)}&v={id.Value}");
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }

        public async Task SetResolutionForItemInPersonalPlaylistAsync(string name, VideoId id, Resolution resolution)
        {
              try{
                
                  
                  await client.GetStringAsync($"{url}api/v2/SetResolutionInList?name={WebUtility.UrlEncode(name)}&v={id.Value}&res={resolution.ToString()}");
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public void DeletePersonalPlaylist(string name)
        {
             try{
                
                  
                  Task.Run(()=>client.GetStringAsync($"{url}api/v2/DeleteList?name={WebUtility.UrlEncode(name)}")).GetAwaiter().GetResult();
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }

        public void CancelDownload(bool restart = false)
        {
             try{
                
                  
                  client.GetStringAsync($"{url}api/v2/CancelDownload?restart={restart}").GetAwaiter().GetResult();
            
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        
        SavedVideoProgress progress=new SavedVideoProgress();
        CancellationTokenSource src=new CancellationTokenSource();
        bool hadBeenListeningToEvents=false;
        private async Task _startEventStreamAsync()
        {
            try{
                src=new CancellationTokenSource();
            hadBeenListeningToEvents=true;
           var sse=await client.GetSSEClientAsync($"{url}api/v2/event");
           sse.Event += sse_Event;
           await sse.ReadEventsAsync(src.Token);
        
            }catch(Exception ex){
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
               public void ResetEvents()
        {
            if(src != null) {
            src.Cancel();
            src.Dispose();

            }
           
            if(hadBeenListeningToEvents)
            {
                hadBeenListeningToEvents=false;
                _startEventStream();
            }
            
            
        }
        public void CancelEvents()
        {
            if(src!= null){
            src.Cancel();
            src.Dispose();
            }
            src=null;
            hadBeenListeningToEvents=false;
        }
        private event EventHandler<VideoStartedEventArgs> _started_video;
        private event EventHandler<VideoFinishedEventArgs> _ended_video;
        private event EventHandler<VideoProgressEventArgs> _progress_video;
        private event EventHandler<TYTDErrorEventArgs> _error;
        private event EventHandler<BellEventArgs> _bell;
        public event EventHandler<VideoStartedEventArgs> VideoStarted
        {
            add{
                _started_video += value;
                _startEventStream();
                

            }
            remove 
            {
                _started_video-=value;
            }
        }
        
        public event EventHandler<VideoProgressEventArgs> VideoProgress
        {
            add{
                _progress_video += value;
                _startEventStream();
                
            }
            remove
            {
                _progress_video -=value;
            }
        }
        public event EventHandler<VideoFinishedEventArgs> VideoFinished
        {
            add
            {
                _ended_video+=value;
                _startEventStream();
                
            }
            remove 
            {
                _ended_video -= value;
            }
        }
        public event EventHandler<TYTDErrorEventArgs> Error
        {
            add 
            {
                _error += value;
                _startEventStream();
            }
            remove
            {
                _error-=value;
            }
        }
        public event EventHandler<BellEventArgs> Bell
        {
            add
            {
                _bell+=value;
                _startEventStream();
            }
            remove
            {
                _bell-=value;
            }
        }

        private void sse_Event(object sender,SSEEvent evt)
        {
            bool started=false;bool ended=false;bool error=false;bool bell=false;
            try{
                ProgressItem item = evt.ParseJson<ProgressItem>();
                if(item != null)
                {
                    if(item.Video != null)
                    {
                        progress.Video = item.Video;
                    }
                    if(item.StartEvent)
                    {
                        started =  true;
                    }
                    if(item.StopEvent)
                    {
                        ended =true;
                    }
                    if(item.BellEvent)
                    {
                        bell=true;
                    }
                    progress.Length = item.Length;
                    progress.ProgressRaw=item.Percent;
                    progress.Progress = ((int)(item.Percent * 100) % 101);
                    if(started)
                    {
                        VideoStartedEventArgs evt0=new VideoStartedEventArgs();
                        evt0.EstimatedLength=item.Length;
                        evt0.Resolution=Resolution.PreMuxed;
                        evt0.VideoInfo=progress.Video;

                        _started_video?.Invoke(this,evt0);   

                    }else if(ended)
                    {
                        VideoFinishedEventArgs evt0=new VideoFinishedEventArgs();
                        evt0.Resolution=Resolution.PreMuxed;
                        evt0.VideoInfo=progress.Video;
                        _ended_video?.Invoke(this,evt0);
                    }else if(error)
                    {
                        TYTDErrorEventArgs evt0=new TYTDErrorEventArgs(item.Id,new TYTDException(item.Message,item.Error,item.ExceptionName));
                        _error?.Invoke(this,evt0);
                    }else if(bell)
                    {
                        BellEventArgs evt0=new BellEventArgs();
                        evt0.Id = item.Id; 
                        _bell?.Invoke(this,evt0);
                    }
                    else{  
                        VideoProgressEventArgs evt0=new VideoProgressEventArgs();
                        evt0.Progress = item.Percent;
                        evt0.VideoInfo = progress.Video;
                        _progress_video?.Invoke(this,evt0);
                    }
                }
            }
            catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        private void _startEventStream()
        {
           
                Task.Run(_startEventStreamAsync).Wait(0);
            
        }  
        public ExtraData GetExtraDataOnce()
        {
            if(data ==null){
            data= Task.Run<ExtraData>(async()=>{
               string text= await client.GetStringAsync($"{url}api/v2/extra_data.json");
               return JsonConvert.DeserializeObject<ExtraData>(text);
           }).GetAwaiter().GetResult();
            }
           return data;
        }
        public async Task<ExtraData> GetExtraDataOnceAsync()
        {
            if(data ==null)
            {
                string text= await client.GetStringAsync($"{url}api/v2/extra_data.json");
                data = JsonConvert.DeserializeObject<ExtraData>(text);
            }
            return data;
        }
        public async Task<ExtraData> GetExtraDataAsync()
        {
             string text= await client.GetStringAsync($"{url}api/v2/extra_data.json");
                return JsonConvert.DeserializeObject<ExtraData>(text);
        }
        public override ExtraData GetExtraData()
        {
            return Task.Run<ExtraData>(async()=>{
               string text= await client.GetStringAsync($"{url}api/v2/extra_data.json");
               return JsonConvert.DeserializeObject<ExtraData>(text);
           }).GetAwaiter().GetResult();
            
           
        }

        public async Task AddHandleAsync(ChannelHandle handle, Resolution resolution = Resolution.PreMuxed)
        {
            try{
            await client.GetStringAsync($"{url}api/v2/AddHandle?id={handle.Value}&res={resolution.ToString()}");
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
        public async Task AddSlugAsync(ChannelSlug handle, Resolution resolution = Resolution.PreMuxed)
        {
            try{
            await client.GetStringAsync($"{url}api/v2/AddSlug?id={handle.Value}&res={resolution.ToString()}");
            }catch(Exception ex)
            {
                _error.Invoke(this,new TYTDErrorEventArgs("jNQXAC9IVRw",ex));
            }
        }
    }
}