Merge pull request #48 from skni-kod/feature/#47-hangfire-implementation

Hangfire implementation

Author: Comply5000

skit.API/Program.cs

@@ -1,4 +1,5 @@
 using FluentValidation.AspNetCore;
+using Hangfire;
 using skit.API.Extensions;
 using skit.API.Filters;
 using skit.Application;
@@ -50,6 +51,8 @@
 app.UseAuthentication();
 app.UseAuthorization();
 
+app.UseHangfireDashboard();
+
 app.MapControllers();
 
 app.Run();

skit.Core/BackgroundProcessing/Services/IHangfireService.cs

@@ -0,0 +1,10 @@
+using System.Linq.Expressions;
+
+namespace skit.Core.BackgroundProcessing.Services;
+
+public interface IHangfireService
+{ 
+    void ScheduleEveryMinute(string jobId, Expression<Action> methodCall);
+    void ScheduleEveryDay(string jobId, Expression<Action> methodCall);
+    void RemoveIfExists(string jobId);
+}

skit.Infrastructure/Common/Extension.cs

@@ -1,5 +1,5 @@
-using Microsoft.Extensions.Configuration;
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
+using skit.Core.BackgroundProcessing.Services;
 using skit.Core.Common.Services;
 using skit.Infrastructure.Common.Services;
 
@@ -11,6 +11,7 @@ public static IServiceCollection AddCommonInfrastructure(this IServiceCollection
     {
         services.AddScoped<IDateService, DateService>();
         services.AddScoped<ICurrentUserService, CurrentUserService>();
+        services.AddScoped<IHangfireService, HangfireService>();
 
         return services;
     }

skit.Infrastructure/Common/Services/HangfireService.cs

@@ -0,0 +1,30 @@
+using System.Linq.Expressions;
+using Hangfire;
+using Hangfire.Common;
+using skit.Core.BackgroundProcessing.Services;
+
+namespace skit.Infrastructure.Common.Services;
+
+public sealed class HangfireService : IHangfireService
+{
+    private const string RecurringEveryMinute = "* * * * *";
+    private const string RecurringEveryDay = "0 0 * * *";
+    
+    public void ScheduleEveryMinute(string jobId, Expression<Action> methodCall)
+    {
+        var manager = new RecurringJobManager();
+        manager.AddOrUpdate(jobId, Job.FromExpression(methodCall), RecurringEveryMinute);
+    }
+    
+    public void ScheduleEveryDay(string jobId, Expression<Action> methodCall)
+    {
+        var manager = new RecurringJobManager();
+        manager.AddOrUpdate(jobId, Job.FromExpression(methodCall), RecurringEveryDay);
+    }
+
+    public void RemoveIfExists(string jobId)
+    {
+        var manager = new RecurringJobManager();
+        manager.RemoveIfExists(jobId);
+    }
+}

skit.Infrastructure/DAL/Extension.cs

@@ -1,6 +1,4 @@
-using System.Reflection;
-using FluentValidation;
-using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using skit.Core.Addresses.Repositories;
@@ -16,7 +14,6 @@
 using skit.Infrastructure.DAL.Identity.Services;
 using skit.Infrastructure.DAL.Offers.Repositories;
 using skit.Infrastructure.DAL.Technologies.Repositories;
-using skit.Infrastructure.Integrations.Emails.Configuration;
 
 namespace skit.Infrastructure.DAL;
 

skit.Infrastructure/Extensions.cs

@@ -1,23 +1,12 @@
 using System.Reflection;
 using FluentValidation;
-using MediatR;
-using Microsoft.EntityFrameworkCore;
+using Hangfire;
+using Hangfire.PostgreSql;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Logging;
-using skit.Core.Addresses.Repositories;
-using skit.Core.Common.Services;
-using skit.Core.Companies.Repositories;
-using skit.Core.Identity.Services;
 using skit.Infrastructure.Common;
-using skit.Infrastructure.Common.Services;
 using skit.Infrastructure.DAL;
-using skit.Infrastructure.DAL.Companies;
-using skit.Infrastructure.DAL.Companies.Repositories;
-using skit.Infrastructure.DAL.EF.Context;
-using skit.Infrastructure.DAL.Identity.Services;
 using skit.Infrastructure.Integrations;
-using skit.Infrastructure.Integrations.Emails.Configuration;
 
 namespace skit.Infrastructure;
 
@@ -27,6 +16,12 @@ public static IServiceCollection AddInfrastructure(this IServiceCollection servi
     {
         services.AddMediatR(cfg=>cfg.RegisterServicesFromAssemblies(Assembly.GetExecutingAssembly()));
         services.AddValidatorsFromAssembly(Assembly.GetExecutingAssembly());
+        services.AddHangfire(config => config
+            .SetDataCompatibilityLevel(CompatibilityLevel.Version_180)
+            .UseSimpleAssemblyNameTypeSerializer()
+            .UseRecommendedSerializerSettings()
+            .UsePostgreSqlStorage(configuration.GetConnectionString("DatabaseConnection")));
+        services.AddHangfireServer();
 
         services.AddCommonInfrastructure();
         services.AddDal(configuration);

skit.Infrastructure/Integrations/Extension.cs

@@ -1,6 +1,4 @@
-using System.Reflection;
-using FluentValidation;
-using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using skit.Core.Emails.Services;
 using skit.Core.Files.Services;

skit.Infrastructure/skit.Infrastructure.csproj

@@ -9,6 +9,8 @@
     <ItemGroup>
       <PackageReference Include="AWSSDK.S3" Version="3.7.304.7" />
       <PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="11.5.1" />
+      <PackageReference Include="Hangfire" Version="1.8.6" />
+      <PackageReference Include="Hangfire.PostgreSql" Version="1.20.4" />
       <PackageReference Include="MailKit" Version="4.3.0" />
       <PackageReference Include="MediatR" Version="12.1.1" />
       <PackageReference Include="MediatR.Extensions.Microsoft.DependencyInjection" Version="11.1.0" />