From 2d1d7019cbe051d2a42350a6f9d50e1f4ed8bd11 Mon Sep 17 00:00:00 2001 From: ivarlovlie Date: Sun, 23 Jan 2022 18:42:59 +0100 Subject: feat: Remove stale tokens on a regular basis --- src/server/Jobs/JobRegister.cs | 18 ++++++++++++++++++ src/server/Jobs/TokenCleanupJob.cs | 19 +++++++++++++++++++ 2 files changed, 37 insertions(+) create mode 100644 src/server/Jobs/JobRegister.cs create mode 100644 src/server/Jobs/TokenCleanupJob.cs (limited to 'src/server/Jobs') diff --git a/src/server/Jobs/JobRegister.cs b/src/server/Jobs/JobRegister.cs new file mode 100644 index 0000000..98eac97 --- /dev/null +++ b/src/server/Jobs/JobRegister.cs @@ -0,0 +1,18 @@ +using Quartz; + +namespace IOL.BookmarkThing.Server.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/src/server/Jobs/TokenCleanupJob.cs b/src/server/Jobs/TokenCleanupJob.cs new file mode 100644 index 0000000..99e7d0d --- /dev/null +++ b/src/server/Jobs/TokenCleanupJob.cs @@ -0,0 +1,19 @@ +namespace IOL.BookmarkThing.Server.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