42 lines
1.3 KiB
C#
42 lines
1.3 KiB
C#
using Microsoft.Extensions.DependencyInjection;
|
|
using Microsoft.Extensions.Hosting;
|
|
using Microsoft.Extensions.Logging;
|
|
using RdtClient.Service.Services;
|
|
|
|
namespace RdtClient.Service.BackgroundServices;
|
|
|
|
public class WebsocketsUpdater(ILogger<WebsocketsUpdater> logger, IServiceProvider serviceProvider) : BackgroundService
|
|
{
|
|
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
|
{
|
|
while (!Startup.Ready)
|
|
{
|
|
await Task.Delay(1000, stoppingToken);
|
|
}
|
|
|
|
logger.LogInformation("WebsocketsUpdater started.");
|
|
|
|
while (!stoppingToken.IsCancellationRequested)
|
|
{
|
|
try
|
|
{
|
|
using var scope = serviceProvider.CreateScope();
|
|
var remoteService = scope.ServiceProvider.GetRequiredService<RemoteService>();
|
|
|
|
await remoteService.Update();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
logger.LogError(ex, $"Unexpected error occurred in WebsocketsUpdater: {ex.Message}");
|
|
}
|
|
|
|
var delay = RdtHub.HasConnections
|
|
? TimeSpan.FromSeconds(1)
|
|
: TimeSpan.FromSeconds(5);
|
|
|
|
await Task.Delay(delay, stoppingToken);
|
|
}
|
|
|
|
logger.LogInformation("WebsocketsUpdater stopped.");
|
|
}
|
|
}
|