registering configuration

Source/Modules/Subscription/Web/Server/SubscriptionsModuleStartup.cs

@@ -2,7 +2,11 @@
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
+using Modules.Subscriptions.Features.Infrastructure.Configuration;
+using Modules.Subscriptions.Features.Infrastructure.EFCore;
+using Shared.Features.EFCore;
 using Shared.Features.Modules;
+using Shared.Features.Modules.Configuration;
 using Stripe;
 using System.Reflection;
 
@@ -14,11 +18,9 @@ public class SubscriptionsModuleStartup : IModuleStartup
         public void ConfigureServices(IServiceCollection services, IConfiguration configuration)
         {
             StripeConfiguration.ApiKey = configuration["Stripe:StripeKey"];
-            //services.Configure<StripeOptions>(configuration);
-            //services.AddScoped<IStripeSubscriptionService, StripeSubscriptionTypeService>();
 
-            services.AddControllers()
-                .AddApplicationPart(typeof(SubscriptionsModuleStartup).Assembly);
+            services.RegisterDbContext<SubscriptionsDbContext>("subscriptions");
+            services.RegisterModuleConfiguration<SubscriptionsConfiguration, SubscriptionsConfigurationValidator>(configuration);
         }
 
         public void Configure(IApplicationBuilder app, IHostEnvironment env)

Source/Modules/TenantIdentity/Web/Server/Controllers/ExternalLoginCallbackController.cs

@@ -8,7 +8,7 @@
 using Modules.TenantIdentity.Features.DomainFeatures.UserAggregate.Application.Commands;
 using Shared.Features.Server;
 
-namespace Web.Server.Controllers.Identity
+namespace Modules.TenantIdentity.Web.Server
 {
     [Route("api/[controller]")]
     [AllowAnonymous]

Source/Shared/Features/Registrator.cs

@@ -0,0 +1,35 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Shared.Features.Messaging;
+using Shared.Features.EFCore;
+using Shared.Features.Modules;
+using Shared.Features.Server.ExecutionContext;
+
+namespace Shared.Features
+{
+    public static class Registrator
+    {
+        public static IServiceCollection AddSharedFeatures(this IServiceCollection services)
+        {
+            var serviceProvider = services.BuildServiceProvider();
+            var configuration = serviceProvider.GetRequiredService<IConfiguration>();
+
+            services.AddMessaging();
+            services.AddEFCore(configuration);
+            services.AddServerExecutionContext();
+
+            return services;
+        }
+
+        public static IApplicationBuilder UseSharedFeaturesMiddleware(this IApplicationBuilder app, IWebHostEnvironment env)
+        {
+            app.UseEFCoreMiddleware();
+            app.UseServerExecutionContextMiddleware();
+            app.UseModulesMiddleware(env);
+
+            return app;
+        }
+    }
+}

Source/Shared/Features/SignalR/NotificationHub.cs

@@ -0,0 +1,8 @@
+using Microsoft.AspNetCore.SignalR;
+
+namespace Shared.Features.SignalR
+{
+    public class NotificationHub : Hub
+    {
+    }
+}

Source/Shared/Features/SignalR/NotificationHubService.cs

@@ -0,0 +1,26 @@
+using Microsoft.AspNetCore.SignalR;
+using Shared.Kernel.Constants;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Shared.Features.SignalR
+{
+    public class NotificationHubService
+    {
+        private readonly IHubContext<NotificationHub> notificationHubContext;
+
+        public NotificationHubService(IHubContext<NotificationHub> notificationHubContext)
+        {
+            this.notificationHubContext = notificationHubContext;
+        }
+
+        public async Task SendNotificationAsync(Guid userId, string triggeredMethodName)
+        {
+            await notificationHubContext.Clients.User(userId.ToString()).SendAsync(triggeredMethodName);
+        }
+    }
+}

Source/Shared/Features/SignalR/Registrator.cs

@@ -0,0 +1,27 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.SignalR;
+using Microsoft.Extensions.DependencyInjection;
+using Shared.Kernel.Constants;
+
+namespace Shared.Features.SignalR
+{
+    public static class Registrator
+    {
+        public static IServiceCollection Add_SignalR(this IServiceCollection services)
+        {
+            services.AddSingleton<IUserIdProvider, UserIdProvider>();
+            services.AddScoped<NotificationHubService>();
+            return services;
+        }
+
+        public static IApplicationBuilder UseSignalRMiddleware(this IApplicationBuilder app)
+        {
+            app.UseEndpoints(endpoints =>
+            {
+                endpoints.MapHub<NotificationHub>(NotificationHubConstants.Hub);
+            });
+
+            return app;
+        }
+    }
+}

Source/Shared/Features/SignalR/UserIdProvider.cs

@@ -0,0 +1,15 @@
+using Microsoft.AspNetCore.SignalR;
+using Shared.Kernel.Extensions.ClaimsPrincipal;
+
+namespace Shared.Features.SignalR
+{
+    public class UserIdProvider : IUserIdProvider
+    {
+        public string GetUserId(HubConnectionContext connection)
+        {
+            return connection.User.Identity.IsAuthenticated 
+                ? connection.User?.GetUserId<string>()
+                : string.Empty;
+        }
+    }
+}

Source/Shared/Kernel/Constants/NotificationHubConstants.cs

@@ -0,0 +1,7 @@
+namespace Shared.Kernel.Constants
+{
+    public class NotificationHubConstants
+    {
+        public const string Hub = "NotificationHub";
+    }
+}

Source/Web/Server/Properties/launchSettings.json

@@ -23,7 +23,7 @@
       },
       "applicationUrl": "https://localhost:5001",
       "dotnetRunMessages": "true",
-      "launchUrl": "/"
+      "launchUrl": ""
     },
     "Docker": {
       "commandName": "Docker",

Source/Web/Server/Startup.cs

@@ -10,6 +10,7 @@
 using Web.Server.BuildingBlocks;
 using Modules.Subscriptions.Features;
 using Modules.TenantIdentity.Features;
+using Shared.Features;
 
 namespace Web.Server
 {
@@ -22,9 +23,15 @@ public Startup(IConfiguration configuration, IWebHostEnvironment webHostEnvironm
             Configuration = configuration;
             WebHostEnvironment = webHostEnvironment;
         }
+
         // This method gets called by the runtime. Use this method to add services to the container.
         public void ConfigureServices(IServiceCollection services)
         {
+            services.AddControllers();
+            services.AddRazorPages();
+            services.AddServerSideBlazor();
+
+            services.AddSharedFeatures();
             services.AddBuildingBlocks();
 
             services.AddModule<ChannelsModuleStartup>(Configuration);
@@ -46,6 +53,7 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
             app.UseAuthentication();
             app.UseAuthorization();
 
+            app.UseSharedFeaturesMiddleware(env);
             app.UseBuildingBlocks();
 
             app.UseEndpoints(endpoints =>