using System;
using System.Diagnostics.CodeAnalysis;
using System.Threading;
using System.Threading.Tasks;
using Hangfire;
using Microsoft.Extensions.Hosting;
using StardewModdingAPI.Toolkit;
using StardewModdingAPI.Toolkit.Framework.Clients.Wiki;
using StardewModdingAPI.Web.Framework.Caching.Mods;
using StardewModdingAPI.Web.Framework.Caching.Wiki;
namespace StardewModdingAPI.Web
{
/// A hosted service which runs background data updates.
/// Task methods need to be static, since otherwise Hangfire will try to serialize the entire instance.
internal class BackgroundService : IHostedService, IDisposable
{
/*********
** Fields
*********/
/// The background task server.
private static BackgroundJobServer JobServer;
/// The cache in which to store wiki metadata.
private static IWikiCacheRepository WikiCache;
/// The cache in which to store mod data.
private static IModCacheRepository ModCache;
/*********
** Public methods
*********/
/****
** Hosted service
****/
/// Construct an instance.
/// The cache in which to store wiki metadata.
/// The cache in which to store mod data.
/// The Hangfire storage implementation.
[SuppressMessage("ReSharper", "UnusedParameter.Local", Justification = "The Hangfire reference forces it to initialize first, since it's needed by the background service.")]
public BackgroundService(IWikiCacheRepository wikiCache, IModCacheRepository modCache, JobStorage hangfireStorage)
{
BackgroundService.WikiCache = wikiCache;
BackgroundService.ModCache = modCache;
}
/// Start the service.
/// Tracks whether the start process has been aborted.
public Task StartAsync(CancellationToken cancellationToken)
{
this.TryInit();
// set startup tasks
BackgroundJob.Enqueue(() => BackgroundService.UpdateWikiAsync());
BackgroundJob.Enqueue(() => BackgroundService.RemoveStaleModsAsync());
// set recurring tasks
RecurringJob.AddOrUpdate(() => BackgroundService.UpdateWikiAsync(), "*/10 * * * *"); // every 10 minutes
RecurringJob.AddOrUpdate(() => BackgroundService.RemoveStaleModsAsync(), "0 * * * *"); // hourly
return Task.CompletedTask;
}
/// Triggered when the application host is performing a graceful shutdown.
/// Tracks whether the shutdown process should no longer be graceful.
public async Task StopAsync(CancellationToken cancellationToken)
{
if (BackgroundService.JobServer != null)
await BackgroundService.JobServer.WaitForShutdownAsync(cancellationToken);
}
/// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
public void Dispose()
{
BackgroundService.JobServer?.Dispose();
}
/****
** Tasks
****/
/// Update the cached wiki metadata.
[AutomaticRetry(Attempts = 3, DelaysInSeconds = new[] { 30, 60, 120 })]
public static async Task UpdateWikiAsync()
{
WikiModList wikiCompatList = await new ModToolkit().GetWikiCompatibilityListAsync();
BackgroundService.WikiCache.SaveWikiData(wikiCompatList.StableVersion, wikiCompatList.BetaVersion, wikiCompatList.Mods, out _, out _);
}
/// Remove mods which haven't been requested in over 48 hours.
public static Task RemoveStaleModsAsync()
{
BackgroundService.ModCache.RemoveStaleMods(TimeSpan.FromHours(48));
return Task.CompletedTask;
}
/*********
** Private method
*********/
/// Initialize the background service if it's not already initialized.
/// The background service is already initialized.
private void TryInit()
{
if (BackgroundService.JobServer != null)
throw new InvalidOperationException("The scheduler service is already started.");
BackgroundService.JobServer = new BackgroundJobServer();
}
}
}