Move CheckTraktToken to a Job

Shoko.Server/Scheduling/Jobs/Trakt/CheckTraktTokenJob.cs

@@ -0,0 +1,68 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using Shoko.Server.Scheduling.Acquisition.Attributes;
+using Shoko.Server.Scheduling.Attributes;
+using Shoko.Server.Scheduling.Concurrency;
+using Shoko.Server.Settings;
+using Shoko.Server.Providers.TraktTV;
+
+namespace Shoko.Server.Scheduling.Jobs.Trakt;
+
+[DatabaseRequired]
+[NetworkRequired]
+[DisallowConcurrencyGroup(ConcurrencyGroups.Trakt)]
+[JobKeyGroup(JobKeyGroup.Trakt)]
+public class CheckTraktTokenJob : BaseJob
+{
+    private readonly ISettingsProvider _settingsProvider;
+    private readonly TraktTVHelper _traktHelper;
+
+    public bool ForceRefresh;
+    public override string TypeName => "Check and Refresh Trakt Token";
+    public override string Title => "Checking and Refreshing Trakt Token";
+
+    public override Task Process()
+    {
+        try
+        {
+            _logger.LogInformation("Processing {Job}", nameof(CheckTraktTokenJob));
+            var settings = _settingsProvider.GetSettings();
+            if (!settings.TraktTv.Enabled || string.IsNullOrEmpty(settings.TraktTv.TokenExpirationDate))
+            {
+                _logger.LogInformation("Trakt is not enabled or no token expiration date is set");
+                return Task.CompletedTask;
+            }
+
+            // Convert the Unix timestamp to DateTime
+            var expirationDate = DateTimeOffset.FromUnixTimeSeconds(long.Parse(settings.TraktTv.TokenExpirationDate)).DateTime;
+
+            // Check if the token needs refreshing
+            if (ForceRefresh || DateTime.Now.Add(TimeSpan.FromDays(45)) >= expirationDate)
+            {
+                _traktHelper.RefreshAuthToken();
+                var newExpirationDate = DateTimeOffset.FromUnixTimeSeconds(long.Parse(settings.TraktTv.TokenExpirationDate)).DateTime;
+                _logger.LogInformation("Trakt token refreshed successfully. New expiry date: {Date}", newExpirationDate);
+            }
+            else
+            {
+                _logger.LogInformation("Trakt token is still valid. Expiry date: {Date}", expirationDate);
+            }
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Error in {Job}: {Ex}", nameof(CheckTraktTokenJob), ex);
+        }
+
+        return Task.CompletedTask;
+    }
+
+    public CheckTraktTokenJob(ISettingsProvider settingsProvider, TraktTVHelper traktHelper)
+    {
+        _settingsProvider = settingsProvider;
+        _traktHelper = traktHelper;
+    }
+
+    protected CheckTraktTokenJob() { }
+}

Shoko.Server/Scheduling/QuartzStartup.cs

@@ -17,6 +17,7 @@
 using Shoko.Server.Scheduling.Jobs;
 using Shoko.Server.Scheduling.Jobs.Actions;
 using Shoko.Server.Scheduling.Jobs.Shoko;
+using Shoko.Server.Scheduling.Jobs.Trakt;
 using Shoko.Server.Server;
 using Shoko.Server.Utilities;
 
@@ -31,6 +32,8 @@ public static async Task ScheduleRecurringJobs(bool replace)
         // StartJobNow gives a priority of 10. We'll give it 20 to be even higher priority
         await ScheduleRecurringJob<CheckNetworkAvailabilityJob>(
             triggerConfig: t => t.WithPriority(20).WithSimpleSchedule(tr => tr.WithIntervalInMinutes(30).RepeatForever()).StartNow(), replace: true, keepSchedule: false);
+        await ScheduleRecurringJob<CheckTraktTokenJob>(
+            triggerConfig: t => t.WithPriority(20).WithSimpleSchedule(tr => tr.WithIntervalInMinutes(720).RepeatForever()).StartNow(), replace: true, keepSchedule: false);
 
         // TODO the other schedule-based jobs that are on timers
     }

Shoko.Server/Server/ShokoServer.cs

@@ -412,7 +412,6 @@ private static void AutoUpdateTimer_Elapsed(object sender, ElapsedEventArgs e)
         actionService.CheckForAnimeUpdate().GetAwaiter().GetResult();
         actionService.CheckForMyListSyncUpdate(false).GetAwaiter().GetResult();
         actionService.CheckForTraktAllSeriesUpdate(false).GetAwaiter().GetResult();
-        actionService.CheckForTraktTokenUpdate(false);
         actionService.CheckForAniDBFileUpdate(false).GetAwaiter().GetResult();
     }
 

Shoko.Server/Services/ActionService.cs

@@ -1018,41 +1018,6 @@ public async Task CheckForTraktAllSeriesUpdate(bool forceRefresh)
         _traktHelper.ScanForMatches();
     }
 
-    public void CheckForTraktTokenUpdate(bool forceRefresh)
-    {
-        try
-        {
-            var settings = _settingsProvider.GetSettings();
-            if (!settings.TraktTv.Enabled || string.IsNullOrEmpty(settings.TraktTv.TokenExpirationDate)) return;
-
-            // Convert the Unix timestamp to DateTime directly
-            var expirationDate = DateTimeOffset.FromUnixTimeSeconds(long.Parse(settings.TraktTv.TokenExpirationDate)).DateTime;
-
-            // Check if force refresh is requested or the token is expired
-            if (forceRefresh || DateTime.Now.Add(TimeSpan.FromDays(45)) >= expirationDate)
-            {
-                _traktHelper.RefreshAuthToken();
-
-                // Update the last token refresh timestamp
-                var schedule = RepoFactory.ScheduledUpdate.GetByUpdateType((int)ScheduledUpdateType.TraktToken)
-                            ?? new ScheduledUpdate { UpdateType = (int)ScheduledUpdateType.TraktToken, UpdateDetails = string.Empty };
-
-                schedule.LastUpdate = DateTime.Now;
-                RepoFactory.ScheduledUpdate.Save(schedule);
-
-                _logger.LogInformation("Trakt token refreshed successfully. Expiry date: {Date}", expirationDate);
-            }
-            else
-            {
-                _logger.LogInformation("Trakt token is still valid. Expiry date: {Date}", expirationDate);
-            }
-        }
-        catch (Exception ex)
-        {
-            _logger.LogError(ex, "Error in CheckForTraktTokenUpdate: {Ex}", ex);
-        }
-    }
-
     public async Task CheckForAniDBFileUpdate(bool forceRefresh)
     {
         var settings = _settingsProvider.GetSettings();