prehistoric-systems/FilterLists
1
0
Fork 0
mirror of https://github.com/collinbarrett/FilterLists.git synced 2026-03-11 09:04:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor(archival): ♻ extend IRequest rather than unused IMediator

Browse source
This commit is contained in:
Collin M. Barrett 2020-09-13 21:02:22 -05:00
parent 29db802eba
commit 739268a624
3 changed files with 5 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
services/Archival/FilterLists.Archival.Application/Commands/EnqueueArchiveAllLists.cs
View file

@ -28,7 +28,7 @@ public async Task<Unit> Handle(Command request, CancellationToken cancellationTo
var lists = await _directory.GetListsAsync(cancellationToken);
foreach (var list in lists)
{
_mediator.EnqueueBackgroundJob(new ArchiveList.Command(list.Id));
new ArchiveList.Command(list.Id).EnqueueBackgroundJob();
}
return Unit.Value;

4
services/Archival/FilterLists.Archival.Application/ConfigurationExtensions.cs
View file

@ -33,9 +33,7 @@ public static void UseApplication(this IApplicationBuilder app)
private static void ScheduleArchival(this IApplicationBuilder app)
{
_ = app ?? throw new ArgumentNullException(nameof(app));
var mediator = (IMediator)app.ApplicationServices.GetService(typeof(IMediator));
mediator.AddOrUpdateRecurringJob(new EnqueueArchiveAllLists.Command(), Cron.Daily);
new EnqueueArchiveAllLists.Command().AddOrUpdateRecurringJob(Cron.Daily);
}
}
}

9
services/Archival/FilterLists.Archival.Infrastructure/Scheduling/ScheduleMediator.cs
View file

@ -6,17 +6,14 @@
namespace FilterLists.Archival.Infrastructure.Scheduling
{
/// <remarks>https://codeopinion.com/background-commands-mediatr-hangfire/</remarks>
public static class MediatorExtensions
public static class RequestExtensions
{
public static void EnqueueBackgroundJob(this IMediator _, IRequest request)
public static void EnqueueBackgroundJob(this IRequest request)
{
BackgroundJob.Enqueue<HangfireMediator>(m => m.Send(request));
}
public static void AddOrUpdateRecurringJob(
this IMediator _,
IRequest request,
Func<string> cronExpression)
public static void AddOrUpdateRecurringJob(this IRequest request, Func<string> cronExpression)
{
RecurringJob.AddOrUpdate<HangfireMediator>(m => m.Send(request), cronExpression);
}