MindWorkAI/AI-Studio
MindWorkAI/AI-Studio
1
0
Fork 0
mirror of https://github.com/MindWorkAI/AI-Studio.git synced 2025-04-28 10:39:47 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Fixed background update service

Browse Source
This commit is contained in:
Thorsten Sommer 2024-07-12 13:08:57 +02:00
parent 7b5d2df873
commit 718beb85ac
Signed by: tsommer
GPG Key ID: 371BBA77A02C0108
1 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
app/MindWork AI Studio/Tools/UpdateService.cs
View File

@ -14,10 +14,11 @@ public sealed class UpdateService : BackgroundService, IMessageBusReceiver
private static ISnackbar? SNACKBAR; private static ISnackbar? SNACKBAR;
private readonly SettingsManager settingsManager; private readonly SettingsManager settingsManager;
private readonly TimeSpan updateInterval;
private readonly MessageBus messageBus; private readonly MessageBus messageBus;
private readonly Rust rust; private readonly Rust rust;
private TimeSpan updateInterval;
public UpdateService(MessageBus messageBus, SettingsManager settingsManager, Rust rust) public UpdateService(MessageBus messageBus, SettingsManager settingsManager, Rust rust)
{ {
this.settingsManager = settingsManager; this.settingsManager = settingsManager;
@ -26,8 +27,16 @@ public sealed class UpdateService : BackgroundService, IMessageBusReceiver
this.messageBus.RegisterComponent(this); this.messageBus.RegisterComponent(this);
this.ApplyFilters([], [ Event.USER_SEARCH_FOR_UPDATE ]); this.ApplyFilters([], [ Event.USER_SEARCH_FOR_UPDATE ]);
}
this.updateInterval = settingsManager.ConfigurationData.UpdateBehavior switch
#region Overrides of BackgroundService
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
while (!stoppingToken.IsCancellationRequested && !IS_INITIALIZED)
await Task.Delay(TimeSpan.FromSeconds(3), stoppingToken);
this.updateInterval = this.settingsManager.ConfigurationData.UpdateBehavior switch
{ {
UpdateBehavior.NO_CHECK => Timeout.InfiniteTimeSpan, UpdateBehavior.NO_CHECK => Timeout.InfiniteTimeSpan,
UpdateBehavior.ONCE_STARTUP => Timeout.InfiniteTimeSpan, UpdateBehavior.ONCE_STARTUP => Timeout.InfiniteTimeSpan,
@ -38,21 +47,11 @@ public sealed class UpdateService : BackgroundService, IMessageBusReceiver
_ => TimeSpan.FromHours(1) _ => TimeSpan.FromHours(1)
}; };
}
#region Overrides of BackgroundService
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
while (!stoppingToken.IsCancellationRequested && !IS_INITIALIZED)
{
await Task.Delay(TimeSpan.FromSeconds(1), stoppingToken);
}
await this.settingsManager.LoadSettings();
if(this.settingsManager.ConfigurationData.UpdateBehavior != UpdateBehavior.NO_CHECK)
await this.CheckForUpdate();
if(this.settingsManager.ConfigurationData.UpdateBehavior is UpdateBehavior.NO_CHECK)
return;
await this.CheckForUpdate();
while (!stoppingToken.IsCancellationRequested) while (!stoppingToken.IsCancellationRequested)
{ {
await Task.Delay(this.updateInterval, stoppingToken); await Task.Delay(this.updateInterval, stoppingToken);