Hangfire added

src/Tinkoff.ISA.API/Program.cs

@@ -1,16 +1,17 @@
-using Microsoft.AspNetCore;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore;
 using Microsoft.AspNetCore.Hosting;
 
 namespace Tinkoff.ISA.API
 {
     public class Program
     {
-        public static void Main(string[] args)
+        public static Task Main(string[] args)
         {
-            CreateWebHostBuilder(args).UseUrls("http://*:5000").Build().Run();
+            return CreateWebHostBuilder(args).UseUrls("http://*:5000").Build().RunAsync();
         }
 
-        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
+        private static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
             WebHost.CreateDefaultBuilder(args)
                 .UseStartup<Startup>();
     }

src/Tinkoff.ISA.API/Startup.cs

@@ -1,16 +1,21 @@
 using System.IO;
 using AutoMapper;
+using Hangfire;
+using Hangfire.Common;
+using Hangfire.Mongo;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using Tinkoff.ISA.AppLayer;
+using Tinkoff.ISA.AppLayer.Jobs;
 using Tinkoff.ISA.Infrastructure.Settings;
 using Tinkoff.ISA.DAL;
 using Tinkoff.ISA.DAL.Common;
 using Tinkoff.ISA.Infrastructure.Configuration;
 using Tinkoff.ISA.Infrastructure.Extensions;
+using Tinkoff.ISA.Infrastructure.MongoDb;
 using IHostingEnvironment = Microsoft.AspNetCore.Hosting.IHostingEnvironment;
 
 namespace Tinkoff.ISA.API
@@ -40,10 +45,31 @@ public void ConfigureServices(IServiceCollection services)
             services.AddAppDependencies();
             services.AddMvc();
             services.AddAutoMapper();
+            services.AddHangfire((serviceProvider, config) =>
+            {
+                var mongoContext = serviceProvider
+                    .GetService<IMongoContext>();
+
+                config.UseMongoStorage(
+                    mongoContext.MongoClient.Settings,
+                    "Jobs",
+                    new MongoStorageOptions
+                    {
+                        MigrationOptions = new MongoMigrationOptions
+                        {
+                            Strategy = MongoMigrationStrategy.Drop,
+                            BackupStrategy = MongoBackupStrategy.Collections
+                        }
+                    });
+            });
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
-        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
+        public void Configure(
+            IApplicationBuilder app, 
+            IHostingEnvironment env, 
+            ILoggerFactory loggerFactory, 
+            IRecurringJobManager recurringJobManager)
         {
             var logSettings = _configuration.GetSection("Logging").Get<LoggingSettings>();
 
@@ -60,6 +86,22 @@ public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerF
             }
 
             app.UseMvc();
+
+            recurringJobManager.AddOrUpdate<JiraJob>(
+                nameof(JiraJob), 
+                job => job.StartJob(), 
+                Cron.Minutely
+            );
+            recurringJobManager.AddOrUpdate<ConfluenceJob>(
+                nameof(ConfluenceJob), 
+                job => job.StartJob(), 
+                Cron.Minutely
+            );
+            recurringJobManager.AddOrUpdate<MongoIndexingForElasticJob>(
+                nameof(MongoIndexingForElasticJob), 
+                job => job.StartJob(), 
+                Cron.Minutely
+            );
         }
     }
 }

src/Tinkoff.ISA.API/Tinkoff.ISA.API.csproj

@@ -12,6 +12,8 @@
   <ItemGroup>
     <PackageReference Include="AutoMapper" Version="8.0.0" />
     <PackageReference Include="AutoMapper.Extensions.Microsoft.DependencyInjection" Version="6.0.0" />
+    <PackageReference Include="Hangfire.AspNetCore" Version="1.7.6" />
+    <PackageReference Include="Hangfire.Mongo" Version="0.6.3" />
     <PackageReference Include="Microsoft.AspNetCore.App" />
     <PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="2.2.0" />
     <PackageReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Design" Version="2.2.3" />

src/Tinkoff.ISA.AppLayer/Jobs/ConfluenceJob.cs

@@ -16,7 +16,7 @@
 
 namespace Tinkoff.ISA.AppLayer.Jobs
 {
-    internal class ConfluenceJob : IJob
+    public class ConfluenceJob : IJob
     {
         private readonly IConfluenceHttpClient _confluenceHttpClient;
         private readonly IElasticsearchClient _elasticsearchClient;

src/Tinkoff.ISA.Infrastructure/MongoDb/IMongoContext.cs

@@ -4,6 +4,7 @@ namespace Tinkoff.ISA.Infrastructure.MongoDb
 {
     public interface IMongoContext
     {
+        IMongoClient MongoClient { get; }
         IMongoCollection<TEntity> For<TEntity>();
     }
 }

src/Tinkoff.ISA.Infrastructure/MongoDb/MongoContext.cs

@@ -15,6 +15,8 @@ public class MongoContext : IMongoContext
         private readonly Lazy<MongoClient> _isaMongoClient;
         private readonly string _isaDbName;
 
+        public IMongoClient MongoClient => _isaMongoClient.Value;
+
         static MongoContext()
         {
             BsonDefaults.GuidRepresentation = GuidRepresentation.Standard;