From 31a179e64778a9d9cfe578d091887a60ccb2a443 Mon Sep 17 00:00:00 2001 From: 2dust <31833384+2dust@users.noreply.github.com> Date: Sun, 9 Feb 2025 20:17:56 +0800 Subject: [PATCH] Code clean --- v2rayN/ServiceLib/Handler/ClashApiHandler.cs | 92 +++++++++---------- .../Statistics/StatisticsSingboxService.cs | 8 +- .../Statistics/StatisticsXrayService.cs | 2 +- 3 files changed, 51 insertions(+), 51 deletions(-) diff --git a/v2rayN/ServiceLib/Handler/ClashApiHandler.cs b/v2rayN/ServiceLib/Handler/ClashApiHandler.cs index 81d92b04..7ba04885 100644 --- a/v2rayN/ServiceLib/Handler/ClashApiHandler.cs +++ b/v2rayN/ServiceLib/Handler/ClashApiHandler.cs @@ -1,4 +1,4 @@ -using static ServiceLib.Models.ClashProxies; +using static ServiceLib.Models.ClashProxies; namespace ServiceLib.Handler { @@ -38,63 +38,63 @@ namespace ServiceLib.Handler public void ClashProxiesDelayTest(bool blAll, List lstProxy, Action updateFunc) { Task.Run(() => - { - if (blAll) { - for (int i = 0; i < 5; i++) + if (blAll) { - if (_proxies != null) + for (var i = 0; i < 5; i++) { - break; + if (_proxies != null) + { + break; + } + Task.Delay(5000).Wait(); + } + if (_proxies == null) + { + return; + } + lstProxy = new List(); + foreach (KeyValuePair kv in _proxies) + { + if (Global.notAllowTestType.Contains(kv.Value.type.ToLower())) + { + continue; + } + lstProxy.Add(new ClashProxyModel() + { + Name = kv.Value.name, + Type = kv.Value.type.ToLower(), + }); } - Task.Delay(5000).Wait(); } - if (_proxies == null) + + if (lstProxy == null) { return; } - lstProxy = new List(); - foreach (KeyValuePair kv in _proxies) + var urlBase = $"{GetApiUrl()}/proxies"; + urlBase += @"/{0}/delay?timeout=10000&url=" + AppHandler.Instance.Config.SpeedTestItem.SpeedPingTestUrl; + + var tasks = new List(); + foreach (var it in lstProxy) { - if (Global.notAllowTestType.Contains(kv.Value.type.ToLower())) + if (Global.notAllowTestType.Contains(it.Type.ToLower())) { continue; } - lstProxy.Add(new ClashProxyModel() + var name = it.Name; + var url = string.Format(urlBase, name); + tasks.Add(Task.Run(async () => { - Name = kv.Value.name, - Type = kv.Value.type.ToLower(), - }); + var result = await HttpClientHelper.Instance.TryGetAsync(url); + updateFunc?.Invoke(it, result); + })); } - } + Task.WaitAll(tasks.ToArray()); - if (lstProxy == null) - { - return; - } - var urlBase = $"{GetApiUrl()}/proxies"; - urlBase += @"/{0}/delay?timeout=10000&url=" + AppHandler.Instance.Config.SpeedTestItem.SpeedPingTestUrl; - - List tasks = new List(); - foreach (var it in lstProxy) - { - if (Global.notAllowTestType.Contains(it.Type.ToLower())) - { - continue; - } - var name = it.Name; - var url = string.Format(urlBase, name); - tasks.Add(Task.Run(async () => - { - var result = await HttpClientHelper.Instance.TryGetAsync(url); - updateFunc?.Invoke(it, result); - })); - } - Task.WaitAll(tasks.ToArray()); - - Task.Delay(1000).Wait(); - updateFunc?.Invoke(null, ""); - }); + Task.Delay(1000).Wait(); + updateFunc?.Invoke(null, ""); + }); } public List? GetClashProxyGroups() @@ -120,7 +120,7 @@ namespace ServiceLib.Handler try { var url = $"{GetApiUrl()}/proxies/{name}"; - Dictionary headers = new Dictionary(); + var headers = new Dictionary(); headers.Add("name", nameNode); await HttpClientHelper.Instance.PutAsync(url, headers); } @@ -148,7 +148,7 @@ namespace ServiceLib.Handler try { var url = $"{GetApiUrl()}/configs?force=true"; - Dictionary headers = new Dictionary(); + var headers = new Dictionary(); headers.Add("path", filePath); await HttpClientHelper.Instance.PutAsync(url, headers); } @@ -194,4 +194,4 @@ namespace ServiceLib.Handler return $"{Global.HttpProtocol}{Global.Loopback}:{AppHandler.Instance.StatePort2}"; } } -} \ No newline at end of file +} diff --git a/v2rayN/ServiceLib/Services/Statistics/StatisticsSingboxService.cs b/v2rayN/ServiceLib/Services/Statistics/StatisticsSingboxService.cs index 300bad1a..3eecee26 100644 --- a/v2rayN/ServiceLib/Services/Statistics/StatisticsSingboxService.cs +++ b/v2rayN/ServiceLib/Services/Statistics/StatisticsSingboxService.cs @@ -21,7 +21,7 @@ namespace ServiceLib.Services.Statistics Task.Run(Run); } - private async void Init() + private async Task Init() { await Task.Delay(5000); @@ -53,9 +53,9 @@ namespace ServiceLib.Services.Statistics } } - private async void Run() + private async Task Run() { - Init(); + await Init(); while (!_exitFlag) { @@ -73,7 +73,7 @@ namespace ServiceLib.Services.Statistics { webSocket.Abort(); webSocket = null; - Init(); + await Init(); continue; } diff --git a/v2rayN/ServiceLib/Services/Statistics/StatisticsXrayService.cs b/v2rayN/ServiceLib/Services/Statistics/StatisticsXrayService.cs index 5ee38717..92ced15e 100644 --- a/v2rayN/ServiceLib/Services/Statistics/StatisticsXrayService.cs +++ b/v2rayN/ServiceLib/Services/Statistics/StatisticsXrayService.cs @@ -23,7 +23,7 @@ namespace ServiceLib.Services.Statistics _exitFlag = true; } - private async void Run() + private async Task Run() { while (!_exitFlag) {