Alex-Devera/v2rayN
1
0
Fork 0
mirror of https://github.com/2dust/v2rayN.git synced 2025-04-20 06:02:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update TaskHandler.cs

Browse source
This commit is contained in:
sshcomm 2025-01-29 23:24:19 +03:30 committed by GitHub
parent f71125d8f3
commit 5867c51a03
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 67 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

68
v2rayN/ServiceLib/Handler/TaskHandler.cs
View file

@ -1,4 +1,4 @@
namespace ServiceLib.Handler namespace ServiceLib.Handler
{ {
public class TaskHandler public class TaskHandler
{ {
@ -9,6 +9,8 @@
{ {
Task.Run(() => UpdateTaskRunSubscription(config, updateFunc)); Task.Run(() => UpdateTaskRunSubscription(config, updateFunc));
Task.Run(() => UpdateTaskRunGeo(config, updateFunc)); Task.Run(() => UpdateTaskRunGeo(config, updateFunc));
Task.Run(() => UpdateTaskRunCore(config, updateFunc));
Task.Run(() => UpdateTaskRunGui(config, updateFunc));
} }
private async Task UpdateTaskRunSubscription(Config config, Action<bool, string> updateFunc) private async Task UpdateTaskRunSubscription(Config config, Action<bool, string> updateFunc)
@ -46,7 +48,6 @@
{ {
var autoUpdateGeoTime = DateTime.Now; var autoUpdateGeoTime = DateTime.Now;
//await Task.Delay(1000 * 120);
Logging.SaveLog("UpdateTaskRunGeo"); Logging.SaveLog("UpdateTaskRunGeo");
var updateHandle = new UpdateService(); var updateHandle = new UpdateService();
@ -68,5 +69,68 @@
} }
} }
} }
private async Task UpdateTaskRunCore(Config config, Action<bool, string> updateFunc)
{
var autoUpdateCoreTime = DateTime.Now;
Logging.SaveLog("UpdateTaskRunCore");
var updateHandle = new UpdateService();
while (true)
{
await Task.Delay(1000 * 3600);
var dtNow = DateTime.Now;
if (config.GuiItem.AutoUpdateCoreInterval > 0)
{
if ((dtNow - autoUpdateCoreTime).Hours % config.GuiItem.AutoUpdateCoreInterval == 0)
{
await updateHandle.CheckUpdateCore(ECoreType.Xray, config, (bool success, string msg) =>
{
updateFunc?.Invoke(success, msg);
}, false);
await updateHandle.CheckUpdateCore(ECoreType.sing_box, config, (bool success, string msg) =>
{
updateFunc?.Invoke(success, msg);
}, false);
await updateHandle.CheckUpdateCore(ECoreType.mihomo, config, (bool success, string msg) =>
{
updateFunc?.Invoke(success, msg);
}, false);
autoUpdateCoreTime = dtNow;
}
}
}
}
private async Task UpdateTaskRunGui(Config config, Action<bool, string> updateFunc)
{
var autoUpdateGuiTime = DateTime.Now;
Logging.SaveLog("UpdateTaskRunGui");
var updateHandle = new UpdateService();
while (true)
{
await Task.Delay(1000 * 3600);
var dtNow = DateTime.Now;
if (config.GuiItem.AutoUpdateCoreInterval > 0)
{
if ((dtNow - autoUpdateGuiTime).Hours % config.GuiItem.AutoUpdateCoreInterval == 0)
{
await updateHandle.CheckUpdateGuiN(config, (bool success, string msg) =>
{
updateFunc?.Invoke(success, msg);
}, false);
autoUpdateGuiTime = dtNow;
}
}
}
}
} }
} }