v2rayN/v2rayN/ServiceLib/Common/DownloaderHelper.cs

using System.Net;
using Downloader;

namespace ServiceLib.Common
{
    public class DownloaderHelper
    {
        private static readonly Lazy<DownloaderHelper> _instance = new(() => new());
        public static DownloaderHelper Instance => _instance.Value;

        public async Task<string?> DownloadStringAsync(IWebProxy? webProxy, string url, string? userAgent, int timeout)
        {
            if (Utils.IsNullOrEmpty(url))
            {
                return null;
            }

            Uri uri = new(url);
            //Authorization Header
            var headers = new WebHeaderCollection();
            if (Utils.IsNotEmpty(uri.UserInfo))
            {
                headers.Add(HttpRequestHeader.Authorization, "Basic " + Utils.Base64Encode(uri.UserInfo));
            }

            var downloadOpt = new DownloadConfiguration()
            {
                Timeout = timeout * 1000,
                MaxTryAgainOnFailover = 2,
                RequestConfiguration =
                {
                    Headers = headers,
                    UserAgent = userAgent,
                    Timeout = timeout * 1000,
                    Proxy = webProxy
                }
            };

            await using var downloader = new Downloader.DownloadService(downloadOpt);
            downloader.DownloadFileCompleted += (sender, value) =>
            {
                if (value.Error != null)
                {
                    throw value.Error;
                }
            };

            using var cts = new CancellationTokenSource();
            await using var stream = await downloader.DownloadFileTaskAsync(address: url, cts.Token).WaitAsync(TimeSpan.FromSeconds(timeout), cts.Token);
            using StreamReader reader = new(stream);

            downloadOpt = null;

            return await reader.ReadToEndAsync(cts.Token);
        }

        public async Task DownloadDataAsync4Speed(IWebProxy webProxy, string url, IProgress<string> progress, int timeout)
        {
            if (Utils.IsNullOrEmpty(url))
            {
                throw new ArgumentNullException(nameof(url));
            }

            var downloadOpt = new DownloadConfiguration()
            {
                Timeout = timeout * 1000,
                MaxTryAgainOnFailover = 2,
                RequestConfiguration =
                {
                    Timeout= timeout * 1000,
                    Proxy = webProxy
                }
            };

            var totalDatetime = DateTime.Now;
            var totalSecond = 0;
            var hasValue = false;
            double maxSpeed = 0;
            await using var downloader = new Downloader.DownloadService(downloadOpt);
            //downloader.DownloadStarted += (sender, value) =>
            //{
            //    if (progress != null)
            //    {
            //        progress.Report("Start download data...");
            //    }
            //};
            downloader.DownloadProgressChanged += (sender, value) =>
            {
                var ts = (DateTime.Now - totalDatetime);
                if (progress != null && ts.Seconds > totalSecond)
                {
                    hasValue = true;
                    totalSecond = ts.Seconds;
                    if (value.BytesPerSecondSpeed > maxSpeed)
                    {
                        maxSpeed = value.BytesPerSecondSpeed;
                        var speed = (maxSpeed / 1000 / 1000).ToString("#0.0");
                        progress.Report(speed);
                    }
                }
            };
            downloader.DownloadFileCompleted += (sender, value) =>
            {
                if (progress != null)
                {
                    if (!hasValue && value.Error != null)
                    {
                        progress.Report(value.Error?.Message);
                    }
                }
            };
            //progress.Report("......");
            using var cts = new CancellationTokenSource();
            cts.CancelAfter(timeout * 1000);
            await using var stream = await downloader.DownloadFileTaskAsync(address: url, cts.Token);

            downloadOpt = null;
        }

        public async Task DownloadFileAsync(IWebProxy? webProxy, string url, string fileName, IProgress<double> progress, int timeout)
        {
            if (Utils.IsNullOrEmpty(url))
            {
                throw new ArgumentNullException(nameof(url));
            }
            if (Utils.IsNullOrEmpty(fileName))
            {
                throw new ArgumentNullException(nameof(fileName));
            }
            if (File.Exists(fileName))
            {
                File.Delete(fileName);
            }

            var downloadOpt = new DownloadConfiguration()
            {
                Timeout = timeout * 1000,
                MaxTryAgainOnFailover = 2,
                RequestConfiguration =
                {
                    Timeout= timeout * 1000,
                    Proxy = webProxy
                }
            };

            var progressPercentage = 0;
            var hasValue = false;
            await using var downloader = new Downloader.DownloadService(downloadOpt);
            downloader.DownloadStarted += (sender, value) =>
            {
                progress?.Report(0);
            };
            downloader.DownloadProgressChanged += (sender, value) =>
            {
                hasValue = true;
                var percent = (int)value.ProgressPercentage;//   Convert.ToInt32((totalRead * 1d) / (total * 1d) * 100);
                if (progressPercentage != percent && percent % 10 == 0)
                {
                    progressPercentage = percent;
                    progress.Report(percent);
                }
            };
            downloader.DownloadFileCompleted += (sender, value) =>
            {
                if (progress != null)
                {
                    if (hasValue && value.Error == null)
                    {
                        progress.Report(101);
                    }
                    else if (value.Error != null)
                    {
                        throw value.Error;
                    }
                }
            };

            using var cts = new CancellationTokenSource();
            await downloader.DownloadFileTaskAsync(url, fileName, cts.Token);

            downloadOpt = null;
        }
    }
}