EventBus: вынести конфигурирование в клиент

Author: DedSec256

HwProj.AuthService/HwProj.AuthService.API/Startup.cs

@@ -7,6 +7,7 @@
 using Microsoft.AspNetCore.Identity;
 using Microsoft.EntityFrameworkCore;
 using HwProj.AuthService.API.Services;
+using HwProj.EventBus.Client;
 using HwProj.EventBus.Client.Interfaces;
 using Microsoft.IdentityModel.Tokens;
 using Microsoft.AspNetCore.Authentication.JwtBearer;

HwProj.Common/HwProj.Utils/Configuration/StartupExtensions.cs

@@ -1,28 +1,19 @@
 using System;
 using System.Collections.Generic;
-using System.Linq;
-using System.Net.Sockets;
 using System.Threading;
 using AutoMapper;
-using HwProj.EventBus.Client;
-using HwProj.EventBus.Client.Implementations;
-using HwProj.EventBus.Client.Interfaces;
 using HwProj.Utils.Auth;
 using HwProj.Utils.Configuration.Middleware;
 using Microsoft.AspNetCore.Authentication.JwtBearer;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.EntityFrameworkCore;
-using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using Microsoft.IdentityModel.Tokens;
 using Microsoft.OpenApi.Models;
 using Newtonsoft.Json;
-using Polly;
-using RabbitMQ.Client;
-using RabbitMQ.Client.Exceptions;
 
 namespace HwProj.Utils.Configuration
 {
@@ -106,48 +97,6 @@ private static void ConfigureHwProjServiceSwaggerGen(this IServiceCollection ser
             });
         }
 
-        public static IServiceCollection AddEventBus(this IServiceCollection services, IConfiguration configuration)
-        {
-            var eventBusSection = configuration.GetSection("EventBus");
-
-            var retryCount = 5;
-            if (!string.IsNullOrEmpty(eventBusSection["EventBusRetryCount"]))
-            {
-                retryCount = int.Parse(eventBusSection["EventBusRetryCount"]);
-            }
-
-            services.AddSingleton(sp => Policy.Handle<SocketException>()
-                .Or<BrokerUnreachableException>()
-                .WaitAndRetry(retryCount, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt))));
-
-            services.AddSingleton<IConnectionFactory, ConnectionFactory>(sp => new ConnectionFactory
-            {
-                HostName = eventBusSection["EventBusHostName"],
-                UserName = eventBusSection["EventBusUserName"],
-                Password = eventBusSection["EventBusPassword"],
-                VirtualHost = eventBusSection["EventBusVirtualHost"]
-            });
-
-            services.AddSingleton<IDefaultConnection, DefaultConnection>();
-            services.AddSingleton<IEventBus, EventBusRabbitMq>();
-
-            var types = AppDomain.CurrentDomain.GetAssemblies().SelectMany(x => x.GetTypes()).ToList();
-            var eventTypes = types.Where(x => typeof(Event).IsAssignableFrom(x));
-            foreach (var eventType in eventTypes)
-            {
-                var fullTypeInterface = typeof(IEventHandler<>).MakeGenericType(eventType);
-                var handlersTypes = types.Where(x =>
-                    fullTypeInterface.IsAssignableFrom(x) && !x.IsInterface && !x.IsAbstract);
-
-                foreach (var handlerType in handlersTypes)
-                {
-                    services.AddTransient(handlerType);
-                }
-            }
-
-            return services;
-        }
-
         public static IApplicationBuilder ConfigureHwProj(this IApplicationBuilder app, IHostingEnvironment env,
             string serviceName, DbContext? context = null)
         {

HwProj.CoursesService/HwProj.CoursesService.API/Startup.cs

@@ -5,6 +5,7 @@
 using HwProj.CoursesService.API.Repositories;
 using HwProj.CoursesService.API.Repositories.Groups;
 using HwProj.CoursesService.API.Services;
+using HwProj.EventBus.Client;
 using HwProj.Utils.Configuration;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;

HwProj.EventBus/HwProj.EventBus.Client/ConfigurationExtensions.cs

@@ -0,0 +1,59 @@
+using System;
+using System.Linq;
+using System.Net.Sockets;
+using HwProj.EventBus.Client.Implementations;
+using HwProj.EventBus.Client.Interfaces;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Polly;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Exceptions;
+
+namespace HwProj.EventBus.Client
+{
+    public static class ConfigurationExtensions
+    {
+        public static IServiceCollection AddEventBus(this IServiceCollection services, IConfiguration configuration)
+        {
+            var eventBusSection = configuration.GetSection("EventBus");
+
+            var retryCount = 5;
+            if (!string.IsNullOrEmpty(eventBusSection["EventBusRetryCount"]))
+            {
+                retryCount = int.Parse(eventBusSection["EventBusRetryCount"]);
+            }
+
+            services.AddSingleton(sp => Policy.Handle<SocketException>()
+                .Or<BrokerUnreachableException>()
+                .WaitAndRetry(retryCount, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt))));
+
+            services.AddSingleton<IConnectionFactory, ConnectionFactory>(sp => new ConnectionFactory
+            {
+                HostName = eventBusSection["EventBusHostName"],
+                UserName = eventBusSection["EventBusUserName"],
+                Password = eventBusSection["EventBusPassword"],
+                VirtualHost = eventBusSection["EventBusVirtualHost"]
+            });
+
+            services.AddSingleton<IDefaultConnection, DefaultConnection>();
+            services.AddSingleton<IEventBus, EventBusRabbitMq>();
+
+            var types = AppDomain.CurrentDomain.GetAssemblies().SelectMany(x => x.GetTypes()).ToList();
+            var eventTypes = types.Where(x => typeof(Event).IsAssignableFrom(x));
+            foreach (var eventType in eventTypes)
+            {
+                var fullTypeInterface = typeof(IEventHandler<>).MakeGenericType(eventType);
+                var handlersTypes = types.Where(x =>
+                    fullTypeInterface.IsAssignableFrom(x) && !x.IsInterface && !x.IsAbstract);
+
+                foreach (var handlerType in handlersTypes)
+                {
+                    services.AddTransient(handlerType);
+                }
+            }
+
+            return services;
+        }
+
+    }
+}

HwProj.NotificationsService/HwProj.NotificationsService.API/Startup.cs

@@ -12,6 +12,7 @@
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using HwProj.CoursesService.API.Events;
+using HwProj.EventBus.Client;
 using HwProj.SolutionsService.API.Events;
 using UpdateTaskMaxRatingEvent = HwProj.CoursesService.API.Events.UpdateTaskMaxRatingEvent;
 

HwProj.SolutionsService/HwProj.SolutionsService.API/Startup.cs

@@ -1,5 +1,6 @@
 using HwProj.AuthService.Client;
 using HwProj.CoursesService.Client;
+using HwProj.EventBus.Client;
 using HwProj.EventBus.Client.Interfaces;
 using HwProj.SolutionsService.API.Models;
 using HwProj.SolutionsService.API.Repositories;