tytd-server/TYTD.Api/Server/Models/InfomationQueueItem.cs

using Dasync.Collections;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

using YoutubeExplode.Channels;
using YoutubeExplode.Playlists;
using YoutubeExplode.Videos;

namespace TYTD.Server.Models
{
    public class InfomationQueueItem
    {
        public InfomationQueueItem(VideoId id,Resolution res,bool download = true)
        {
            Data = id.Value;
            DownloadActualDataAfterwards = download;
            Type = InfoType.Video;
            this.res = res;
        }
        public InfomationQueueItem(VideoId id)
        {
            Data = id.Value;
            DownloadActualDataAfterwards = false;
            Type = InfoType.ClosedCaptions;
            this.res = 0;
        }
        public InfomationQueueItem(IDResolutionTypeTriplet triplet)
        {
            Data = triplet.Id;
            DownloadActualDataAfterwards = true;
            Type = triplet.Type;
            this.res = triplet.Resolution;
        }
        public InfomationQueueItem(PlaylistId id,Resolution res,bool download = true)
        {
            Data = id.Value;
            DownloadActualDataAfterwards = download;
            Type = InfoType.Playlist;
            this.res = res;
        }
        public InfomationQueueItem(Uri url)
        {
            Data = url.ToString();
            DownloadActualDataAfterwards = true;
            Type = InfoType.FileDownload;
            this.res = 0;
        }
        public InfomationQueueItem(ChannelId id, Resolution res, bool download = true)
        {
            Data = id.Value;
            DownloadActualDataAfterwards = download;
            Type = InfoType.Channel;
            this.res = res;
        }
        public InfomationQueueItem(UserName id, Resolution res, bool download = true)
        {
            Data = id.Value;
            DownloadActualDataAfterwards = download;
            Type = InfoType.User;
            this.res = res;
        }
        Resolution res;
        /// <summary>
        /// Download it afterwards
        /// </summary>
        public bool DownloadActualDataAfterwards { get; set; }
        /// <summary>
        /// Kind
        /// </summary>
        public InfoType Type { get; set; }
        /// <summary>
        /// ID for item
        /// </summary>
        public string Data { get; set; }

        public async Task<SavedVideoObject[]> DownloadData()
        {
            await Task.Delay(100);
            switch (Type)
            {
                case InfoType.FileDownload:
                    return new SavedVideoObject[] { new SavedVideoObject(Data) };
                case InfoType.ClosedCaptions:
                    string path =  $"ClosedCaptions/{Data}";
                    if (!Directory.Exists(path))
                    {
                        Directory.CreateDirectory(path);
                        var cc0 = await Functions.Downloader.DL.ytc.Videos.ClosedCaptions.GetManifestAsync(Data);
                        string trackInfo = $"ClosedCaptions/{Data}/track_info.json";
                        File.WriteAllText(trackInfo, JsonConvert.SerializeObject(cc0.Tracks));
                        foreach (var track in cc0.Tracks)
                        {
                            string trackType = track.IsAutoGenerated ? "auto" : "manu";
                            string langFileName = $"{trackType}_{track.Language.Code}.srt";
                            string track2 = $"ClosedCaptions/{Data}/{langFileName}";

                            await Functions.Downloader.DL.ytc.Videos.ClosedCaptions.DownloadAsync(track, track2);
                            await Task.Delay(10);
                        }

                    }
                    break;
                case InfoType.Video:
                    { 
                        string infPath = $"Info/{Data}.json";
                        SavedVideoObject sv;
                        bool exist = File.Exists(infPath);
                        if (exist)
                        {
                            sv = new SavedVideoObject();
                            sv.Resolution = res;
                            sv.Video = JsonConvert.DeserializeObject<SavedVideo>(File.ReadAllText(infPath));
                            foreach(var tn in sv.Video.Thumbnails)
                            {
                                Functions.Downloader.DL._DownloadThumbnail2(tn.Item1, tn.Item2, sv.Video.Id, tn.Item3);
                                await Task.Delay(10);
                            }
                        }
                        else{
                            var vinfo = await Functions.Downloader.DL.ytc.Videos.GetAsync(Data);


                            sv = SavedVideo.CreateFrom(res, vinfo, Functions.Downloader.DL._DownloadThumbnail);
                            DownloadInfoStartEventArgs info = new DownloadInfoStartEventArgs();
                            info.Video = sv.Video;
                            ApiLoader.DownloadInfoStart(this, info);
                        }

                        if (!exist)
                        {
                            File.WriteAllText(infPath, JsonConvert.SerializeObject(sv.Video));
                        }
                        return new SavedVideoObject[] { sv };
                     }
                case InfoType.Playlist:
                    { List<SavedVideoObject> video2 = new List<SavedVideoObject>();

                        List<string> vo = new List<string>();
                        SavedPlaylist pl = await SavedPlaylist.FromPlaylistId(res, Functions.Downloader.DL.ytc, Data, (e, f) => { vo.Add(e); }, Functions.Downloader.DL._DownloadThumbnail);
                        string infpath = $"Playlist/{Data}.json";
                        File.WriteAllText(infpath, JsonConvert.SerializeObject(pl));
                        foreach(var str in vo)
                        {
                            string infPath = $"Info/{str}.json";
                            SavedVideoObject sv;
                            bool exist = File.Exists(infPath);
                            if (exist)
                            {
                                sv = new SavedVideoObject();
                                sv.Resolution = res;
                                sv.Video = JsonConvert.DeserializeObject<SavedVideo>(File.ReadAllText(infPath));
                                foreach (var tn in sv.Video.Thumbnails)
                                {
                                    Functions.Downloader.DL._DownloadThumbnail2(tn.Item1, tn.Item2, sv.Video.Id, tn.Item3);
                                    await Task.Delay(10);
                                }
                            }
                            else
                            {
                                try
                                {
                                    var vinfo = await Functions.Downloader.DL.ytc.Videos.GetAsync(str);

                                    await Task.Delay(10);
                                    sv = SavedVideo.CreateFrom(res, vinfo, Functions.Downloader.DL._DownloadThumbnail);
                                }catch(Exception ex)
                                {
                                    Console.WriteLine(ex.Message);

                                    sv = null;
                                    _ = ex;
                                }
                            }

                            if (!exist)
                            {
                                File.WriteAllText(infPath, JsonConvert.SerializeObject(sv.Video));
                            }
                            if(sv != null)
                            {
                                video2.Add(sv);
                            }
                        }
                        return video2.ToArray();

                    }
                case InfoType.Channel:
                    {
                        List<SavedVideoObject> video = new List<SavedVideoObject>();
                        try
                        {
                            var c = Functions.Downloader.DL.ytc.Channels.GetAsync(Data).GetAwaiter().GetResult();
                            SavedChannel c2 = SavedChannel.FromChannel(c, Functions.Downloader.DL._DownloadThumbnail);
                            string infpath = $"Channel/{Data}.json";
                            File.WriteAllText(infpath, JsonConvert.SerializeObject(c2));

                            try
                            {
                                Functions.Downloader.DL.ytc.Channels.GetUploadsAsync(c.Id).ForEachAsync(async (v) =>
                                {
                                    string infPath = $"Info/{v.Id}.json";
                                  
                                    bool exist = File.Exists(infPath);
                                    if (exist)
                                    {
                                       SavedVideoObject sv = new SavedVideoObject();
                                        sv.Resolution = res;
                                        sv.Video = JsonConvert.DeserializeObject<SavedVideo>(File.ReadAllText(infPath));
                                        foreach (var tn in sv.Video.Thumbnails)
                                        {
                                            Functions.Downloader.DL._DownloadThumbnail2(tn.Item1, tn.Item2, sv.Video.Id, tn.Item3);
                                            await Task.Delay(10);
                                        }
                                        video.Add(sv);
                                    }
                                    else
                                    {
                                        try
                                        {
                                            var vinfo = await Functions.Downloader.DL.ytc.Videos.GetAsync(v.Id);


                                          SavedVideoObject  sv = SavedVideo.CreateFrom(res, vinfo, Functions.Downloader.DL._DownloadThumbnail);
                                            video.Add(sv);
                                        }
                                        catch (Exception ex)
                                        {
                                            Console.WriteLine(ex.Message);

                                            _ = ex;
                                        }
                                    }
                                }).Wait();
                            }
                            catch (Exception ex)
                            {
                                Console.WriteLine(ex.Message);

                                _ = ex;
                            }
                        }
                        catch (Exception ex2)
                        {
                            Console.WriteLine(ex2.Message);

                            _ = ex2;
                        }
                        return video.ToArray();
                    }
                case InfoType.User:
                    {
                        List<SavedVideoObject> video = new List<SavedVideoObject>();
                        try
                        {
                            var c = Functions.Downloader.DL.ytc.Channels.GetByUserAsync(Data).GetAwaiter().GetResult();
                            SavedChannel c2 = SavedChannel.FromChannel(c, Functions.Downloader.DL._DownloadThumbnail);
                            string infpath = $"Channel/{Data}.json";
                            File.WriteAllText(infpath, JsonConvert.SerializeObject(c2));

                            try
                            {
                                Functions.Downloader.DL.ytc.Channels.GetUploadsAsync(c.Id).ForEachAsync(async (v) =>
                                {
                                    string infPath = $"Info/{v.Id}.json";

                                    bool exist = File.Exists(infPath);
                                    if (exist)
                                    {
                                        SavedVideoObject sv = new SavedVideoObject();
                                        sv.Resolution = res;
                                        sv.Video = JsonConvert.DeserializeObject<SavedVideo>(File.ReadAllText(infPath));
                                        foreach (var tn in sv.Video.Thumbnails)
                                        {
                                            Functions.Downloader.DL._DownloadThumbnail2(tn.Item1, tn.Item2, sv.Video.Id, tn.Item3);
                                            await Task.Delay(10);
                                        }
                                        video.Add(sv);
                                    }
                                    else
                                    {
                                        try
                                        {
                                            var vinfo = await Functions.Downloader.DL.ytc.Videos.GetAsync(v.Id);


                                            SavedVideoObject sv = SavedVideo.CreateFrom(res, vinfo, Functions.Downloader.DL._DownloadThumbnail);
                                            video.Add(sv);
                                            await Task.Delay(10);
                                        }
                                        catch (Exception ex)
                                        {
                                            Console.WriteLine(ex.Message);


                                            _ = ex;
                                        }
                                    }
                                }).Wait();
                            }
                            catch (Exception ex)
                            {
                                Console.WriteLine(ex.Message);

                                _ = ex;
                            }
                        }
                        catch (Exception ex2)
                        {
                            Console.WriteLine(ex2.Message);

                            _ = ex2;
                        }
                        return video.ToArray();
                    }
            }
            return new SavedVideoObject[0];
        }
    }
}