registered ChannelWriter and ChannelReader

granstel · Mar 27, 2024 · f1fbc06 · f1fbc06
1 parent f9ba831
commit f1fbc06
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/Dodo1000Bot.Api/DependencyModules/JobsRegistration.cs b/Dodo1000Bot.Api/DependencyModules/JobsRegistration.cs
@@ -1,4 +1,6 @@
+using System.Threading.Channels;
 using Dodo1000Bot.Api.Jobs;
+using Dodo1000Bot.Models.Domain;
 using Dodo1000Bot.Services.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 
@@ -11,8 +13,22 @@ internal static void AddJobs(this IServiceCollection services, AppConfiguration
         services.AddHostedService(serviceProvider => new MigrationsJob(appConfiguration.MysqlConnectionString, serviceProvider));
         services.AddHostedService<FirstRunJob>();
         services.AddHostedService<PushNotificationsRepeatableJob>();
+
         services.AddHostedService<UnitsCheckAndNotifyJob>();
         services.AddHostedService<StatisticsCheckAndNotifyJob>();
         services.AddHostedService<YoutubeCheckAndNotifyJob>();
+
+        var channelOptions = new BoundedChannelOptions(1_000)
+        {
+            FullMode = BoundedChannelFullMode.DropWrite,
+            SingleReader = true,
+            SingleWriter = true
+        };
+        var channel = Channel.CreateBounded<Notification>(channelOptions);
+
+        services.AddSingleton<ChannelWriter<Notification>>(channel);
+        services.AddSingleton<ChannelReader<Notification>>(channel);
+
+        services.AddHostedService<PushNotificationsJob>();
     }
 }