From a640703f2da8815dc26ad1600a6f206be1624379 Mon Sep 17 00:00:00 2001 From: ivarlovlie Date: Wed, 1 Jun 2022 22:10:32 +0200 Subject: feat: Initial after clean slate --- server/src/Jobs/JobRegister.cs | 18 ++++++++++++++++++ server/src/Jobs/TokenCleanupJob.cs | 21 +++++++++++++++++++++ 2 files changed, 39 insertions(+) create mode 100644 server/src/Jobs/JobRegister.cs create mode 100644 server/src/Jobs/TokenCleanupJob.cs (limited to 'server/src/Jobs') diff --git a/server/src/Jobs/JobRegister.cs b/server/src/Jobs/JobRegister.cs new file mode 100644 index 0000000..72c2cc7 --- /dev/null +++ b/server/src/Jobs/JobRegister.cs @@ -0,0 +1,18 @@ +using Quartz; + +namespace IOL.GreatOffice.Api.Jobs; + +public static class JobRegister +{ + public static readonly JobKey TokenCleanupKey = new("TokenCleanupJob"); + + public static IServiceCollectionQuartzConfigurator RegisterJobs(this IServiceCollectionQuartzConfigurator configurator) { + configurator.AddJob(TokenCleanupKey); + configurator.AddTrigger(options => { + options.ForJob(TokenCleanupKey) + .WithIdentity(TokenCleanupKey.Name + "-trigger") + .WithCronSchedule(CronScheduleBuilder.DailyAtHourAndMinute(1, 0)); + }); + return configurator; + } +} diff --git a/server/src/Jobs/TokenCleanupJob.cs b/server/src/Jobs/TokenCleanupJob.cs new file mode 100644 index 0000000..22b60d1 --- /dev/null +++ b/server/src/Jobs/TokenCleanupJob.cs @@ -0,0 +1,21 @@ +using Quartz; + +namespace IOL.GreatOffice.Api.Jobs; + +public class TokenCleanupJob : IJob +{ + private readonly ILogger _logger; + private readonly AppDbContext _context; + + public TokenCleanupJob(ILogger logger, AppDbContext context) { + _logger = logger; + _context = context; + } + + public Task Execute(IJobExecutionContext context) { + var staleTokens = _context.AccessTokens.Where(c => c.HasExpired); + _logger.LogInformation("Removing {0} stale tokens", staleTokens.Count()); + _context.AccessTokens.RemoveRange(); + return Task.CompletedTask; + } +} -- cgit v1.3