Add Helper folder

2026-10-12 00:04:58 +03:00 · 2025-08-17 16:26:13 +08:00
parent 5201dd5ad0
commit c9c1cd8cbb
8 changed files with 11 additions and 10 deletions
@@ -0,0 +1,180 @@
+using System.Net;
+using Downloader;
+
+namespace ServiceLib.Helper;
+
+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 (url.IsNullOrEmpty())
+        {
+            return null;
+        }
+
+        Uri uri = new(url);
+        //Authorization Header
+        var headers = new WebHeaderCollection();
+        if (uri.UserInfo.IsNotEmpty())
+        {
+            headers.Add(HttpRequestHeader.Authorization, "Basic " + Utils.Base64Encode(uri.UserInfo));
+        }
+
+        var downloadOpt = new DownloadConfiguration()
+        {
+            Timeout = timeout * 1000,
+            MaxTryAgainOnFailure = 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 (url.IsNullOrEmpty())
+        {
+            throw new ArgumentNullException(nameof(url));
+        }
+
+        var downloadOpt = new DownloadConfiguration()
+        {
+            Timeout = timeout * 1000,
+            MaxTryAgainOnFailure = 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 (url.IsNullOrEmpty())
+        {
+            throw new ArgumentNullException(nameof(url));
+        }
+        if (fileName.IsNullOrEmpty())
+        {
+            throw new ArgumentNullException(nameof(fileName));
+        }
+        if (File.Exists(fileName))
+        {
+            File.Delete(fileName);
+        }
+
+        var downloadOpt = new DownloadConfiguration()
+        {
+            Timeout = timeout * 1000,
+            MaxTryAgainOnFailure = 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;
+    }
+}
@@ -0,0 +1,205 @@
+using System.Net.Http.Headers;
+using System.Net.Mime;
+using System.Text;
+
+namespace ServiceLib.Helper;
+
+/// <summary>
+/// </summary>
+public class HttpClientHelper
+{
+    private static readonly Lazy<HttpClientHelper> _instance = new(() =>
+    {
+        SocketsHttpHandler handler = new() { UseCookies = false };
+        HttpClientHelper helper = new(new HttpClient(handler));
+        return helper;
+    });
+
+    public static HttpClientHelper Instance => _instance.Value;
+    private readonly HttpClient httpClient;
+
+    private HttpClientHelper(HttpClient httpClient)
+    {
+        this.httpClient = httpClient;
+    }
+
+    public async Task<string?> TryGetAsync(string url)
+    {
+        if (url.IsNullOrEmpty())
+        {
+            return null;
+        }
+
+        try
+        {
+            var response = await httpClient.GetAsync(url);
+            return await response.Content.ReadAsStringAsync();
+        }
+        catch
+        {
+            return null;
+        }
+    }
+
+    public async Task<string?> GetAsync(string url)
+    {
+        if (url.IsNullOrEmpty())
+        {
+            return null;
+        }
+        return await httpClient.GetStringAsync(url);
+    }
+
+    public async Task<string?> GetAsync(HttpClient client, string url, CancellationToken token = default)
+    {
+        if (url.IsNullOrEmpty())
+        {
+            return null;
+        }
+        return await client.GetStringAsync(url, token);
+    }
+
+    public async Task PutAsync(string url, Dictionary<string, string> headers)
+    {
+        var jsonContent = JsonUtils.Serialize(headers);
+        var content = new StringContent(jsonContent, Encoding.UTF8, MediaTypeNames.Application.Json);
+
+        await httpClient.PutAsync(url, content);
+    }
+
+    public async Task PatchAsync(string url, Dictionary<string, string> headers)
+    {
+        var myContent = JsonUtils.Serialize(headers);
+        var buffer = Encoding.UTF8.GetBytes(myContent);
+        var byteContent = new ByteArrayContent(buffer);
+        byteContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");
+
+        await httpClient.PatchAsync(url, byteContent);
+    }
+
+    public async Task DeleteAsync(string url)
+    {
+        await httpClient.DeleteAsync(url);
+    }
+
+    public static async Task DownloadFileAsync(HttpClient client, string url, string fileName, IProgress<double>? progress, CancellationToken token = default)
+    {
+        ArgumentNullException.ThrowIfNull(url);
+        ArgumentNullException.ThrowIfNull(fileName);
+        if (File.Exists(fileName))
+        {
+            File.Delete(fileName);
+        }
+
+        using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, token);
+
+        if (!response.IsSuccessStatusCode)
+        {
+            throw new Exception(response.StatusCode.ToString());
+        }
+
+        var total = response.Content.Headers.ContentLength ?? -1L;
+        var canReportProgress = total != -1 && progress != null;
+
+        await using var stream = await response.Content.ReadAsStreamAsync(token);
+        await using var file = File.Create(fileName);
+        var totalRead = 0L;
+        var buffer = new byte[1024 * 1024];
+        var progressPercentage = 0;
+
+        while (true)
+        {
+            token.ThrowIfCancellationRequested();
+
+            var read = await stream.ReadAsync(buffer, token);
+            totalRead += read;
+
+            if (read == 0)
+            {
+                break;
+            }
+            await file.WriteAsync(buffer.AsMemory(0, read), token);
+
+            if (canReportProgress)
+            {
+                var percent = (int)(100.0 * totalRead / total);
+                //if (progressPercentage != percent && percent % 10 == 0)
+                {
+                    progressPercentage = percent;
+                    progress?.Report(percent);
+                }
+            }
+        }
+        if (canReportProgress)
+        {
+            progress?.Report(101);
+        }
+    }
+
+    public async Task DownloadDataAsync4Speed(HttpClient client, string url, IProgress<string> progress, CancellationToken token = default)
+    {
+        if (url.IsNullOrEmpty())
+        {
+            throw new ArgumentNullException(nameof(url));
+        }
+
+        var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead, token);
+
+        if (!response.IsSuccessStatusCode)
+        {
+            throw new Exception(response.StatusCode.ToString());
+        }
+
+        //var total = response.Content.Headers.ContentLength.HasValue ? response.Content.Headers.ContentLength.Value : -1L;
+        //var canReportProgress = total != -1 && progress != null;
+
+        await using var stream = await response.Content.ReadAsStreamAsync(token);
+        var totalRead = 0L;
+        var buffer = new byte[1024 * 64];
+        var isMoreToRead = true;
+        var progressSpeed = string.Empty;
+        var totalDatetime = DateTime.Now;
+        var totalSecond = 0;
+
+        do
+        {
+            if (token.IsCancellationRequested)
+            {
+                if (totalRead > 0)
+                {
+                    return;
+                }
+                else
+                {
+                    token.ThrowIfCancellationRequested();
+                }
+            }
+
+            var read = await stream.ReadAsync(buffer, token);
+
+            if (read == 0)
+            {
+                isMoreToRead = false;
+            }
+            else
+            {
+                var data = new byte[read];
+                buffer.ToList().CopyTo(0, data, 0, read);
+
+                totalRead += read;
+
+                var ts = DateTime.Now - totalDatetime;
+                if (progress != null && ts.Seconds > totalSecond)
+                {
+                    totalSecond = ts.Seconds;
+                    var speed = (totalRead * 1d / ts.TotalMilliseconds / 1000).ToString("#0.0");
+                    if (progressSpeed != speed)
+                    {
+                        progressSpeed = speed;
+                        progress.Report(speed);
+                    }
+                }
+            }
+        } while (isMoreToRead);
+    }
+}
@@ -0,0 +1,90 @@
+using System.Collections;
+using SQLite;
+
+namespace ServiceLib.Helper;
+
+public sealed class SQLiteHelper
+{
+    private static readonly Lazy<SQLiteHelper> _instance = new(() => new());
+    public static SQLiteHelper Instance => _instance.Value;
+    private readonly string _connstr;
+    private SQLiteConnection _db;
+    private SQLiteAsyncConnection _dbAsync;
+    private readonly string _configDB = "guiNDB.db";
+
+    public SQLiteHelper()
+    {
+        _connstr = Utils.GetConfigPath(_configDB);
+        _db = new SQLiteConnection(_connstr, false);
+        _dbAsync = new SQLiteAsyncConnection(_connstr, false);
+    }
+
+    public CreateTableResult CreateTable<T>()
+    {
+        return _db.CreateTable<T>();
+    }
+
+    public async Task<int> InsertAllAsync(IEnumerable models)
+    {
+        return await _dbAsync.InsertAllAsync(models);
+    }
+
+    public async Task<int> InsertAsync(object model)
+    {
+        return await _dbAsync.InsertAsync(model);
+    }
+
+    public async Task<int> ReplaceAsync(object model)
+    {
+        return await _dbAsync.InsertOrReplaceAsync(model);
+    }
+
+    public async Task<int> UpdateAsync(object model)
+    {
+        return await _dbAsync.UpdateAsync(model);
+    }
+
+    public async Task<int> UpdateAllAsync(IEnumerable models)
+    {
+        return await _dbAsync.UpdateAllAsync(models);
+    }
+
+    public async Task<int> DeleteAsync(object model)
+    {
+        return await _dbAsync.DeleteAsync(model);
+    }
+
+    public async Task<int> DeleteAllAsync<T>()
+    {
+        return await _dbAsync.DeleteAllAsync<T>();
+    }
+
+    public async Task<int> ExecuteAsync(string sql)
+    {
+        return await _dbAsync.ExecuteAsync(sql);
+    }
+
+    public async Task<List<T>> QueryAsync<T>(string sql) where T : new()
+    {
+        return await _dbAsync.QueryAsync<T>(sql);
+    }
+
+    public AsyncTableQuery<T> TableAsync<T>() where T : new()
+    {
+        return _dbAsync.Table<T>();
+    }
+
+    public async Task DisposeDbConnectionAsync()
+    {
+        await Task.Factory.StartNew(() =>
+        {
+            _db?.Close();
+            _db?.Dispose();
+            _db = null;
+
+            _dbAsync?.GetConnection()?.Close();
+            _dbAsync?.GetConnection()?.Dispose();
+            _dbAsync = null;
+        });
+    }
+}