2020-11-02 00:30:49 +00:00
|
|
|
|
using System;
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
|
using Wabbajack.BuildServer;
|
|
|
|
|
using Wabbajack.Server.DataLayer;
|
|
|
|
|
|
2021-10-23 16:51:17 +00:00
|
|
|
|
namespace Wabbajack.Server.Services;
|
|
|
|
|
|
|
|
|
|
public class MirrorQueueService : AbstractService<MirrorQueueService, int>
|
2020-11-02 00:30:49 +00:00
|
|
|
|
{
|
2021-10-23 16:51:17 +00:00
|
|
|
|
private DiscordWebHook _discord;
|
|
|
|
|
private readonly SqlService _sql;
|
2020-11-02 00:30:49 +00:00
|
|
|
|
|
2021-10-23 16:51:17 +00:00
|
|
|
|
public MirrorQueueService(ILogger<MirrorQueueService> logger, AppSettings settings, QuickSync quickSync,
|
|
|
|
|
DiscordWebHook discordWebHook, SqlService sqlService) :
|
|
|
|
|
base(logger, settings, quickSync, TimeSpan.FromMinutes(5))
|
|
|
|
|
{
|
|
|
|
|
_discord = discordWebHook;
|
|
|
|
|
_sql = sqlService;
|
|
|
|
|
}
|
2020-11-02 00:30:49 +00:00
|
|
|
|
|
2021-10-23 16:51:17 +00:00
|
|
|
|
public override async Task<int> Execute()
|
|
|
|
|
{
|
|
|
|
|
await _sql.QueueMirroredFiles();
|
|
|
|
|
return 1;
|
2020-11-02 00:30:49 +00:00
|
|
|
|
}
|
2021-10-23 16:51:17 +00:00
|
|
|
|
}
|