IInServerExecutionScope

Source/Modules/TenantIdentity/Web/Server/Controllers/Aggregates/TenantsController.cs

@@ -32,7 +32,7 @@ public TenantsController(SignInManager<ApplicationUser> signInManager, IServiceP
         public async Task<ActionResult<TenantDTO>> GetTenant()
         {
             var tenantId = ExecutionContext.TenantId;
-            TenantDTO tenant = await queryDispatcher.DispatchAsync<GetTenantByID, TenantDTO>(new GetTenantByID { TenantId = tenantId });
+            TenantDTO tenant = await ExecutionContext.QueryDispatcher.DispatchAsync<GetTenantByID, TenantDTO>(new GetTenantByID { TenantId = tenantId });
 
             return Ok(tenant);
         }

Source/Shared/Features/CQRS/Command/ICommandHandler.cs

@@ -1,12 +1,12 @@
-using Shared.Features.Server.ExecutionContext;
+using Shared.Features.Server;
 
 namespace Shared.Features.CQRS.Command
 {
-    public interface ICommandHandler<in TCommand> : IInServerExecutionContextScope where TCommand : ICommand
+    public interface ICommandHandler<in TCommand> : IInServerExecutionScope where TCommand : ICommand
     {
         Task HandleAsync(TCommand command, CancellationToken cancellationToken);
     }
-    public interface ICommandHandler<in TCommand, TResult> : IInServerExecutionContextScope where TCommand : ICommand<TResult>
+    public interface ICommandHandler<in TCommand, TResult> : IInServerExecutionScope where TCommand : ICommand<TResult>
     {
         Task<TResult> HandleAsync(TCommand command, CancellationToken cancellationToken);
     }

Source/Shared/Features/CQRS/DomainEvent/IDomainEventHandler.cs

@@ -1,9 +1,9 @@
 using Shared.Features.Domain;
-using Shared.Features.Server.ExecutionContext;
+using Shared.Features.Server;
 
 namespace Shared.Features.CQRS.DomainEvent
 {
-    public interface IDomainEventHandler<in TDomainEvent> : IInServerExecutionContextScope where TDomainEvent : IDomainEvent
+    public interface IDomainEventHandler<in TDomainEvent> : IInServerExecutionScope where TDomainEvent : IDomainEvent
     {
         Task HandleAsync(TDomainEvent query, CancellationToken cancellation);
     }

Source/Shared/Features/CQRS/IntegrationEvent/IIntegrationEventHandler.cs

@@ -1,9 +1,9 @@
-using Shared.Features.Server.ExecutionContext;
+using Shared.Features.Server;
 using Shared.Kernel.BuildingBlocks;
 
 namespace Shared.Features.CQRS.IntegrationEvent
 {
-    public interface IIntegrationEventHandler<in TIntegrationEvent> : IInServerExecutionContextScope where TIntegrationEvent : IIntegrationEvent
+    public interface IIntegrationEventHandler<in TIntegrationEvent> : IInServerExecutionScope where TIntegrationEvent : IIntegrationEvent
     {
         Task HandleAsync(TIntegrationEvent integrationEvent, CancellationToken cancellation);
     }

Source/Shared/Features/CQRS/Query/BaseQueryHandler.cs

@@ -0,0 +1,9 @@
+using Shared.Features.Server;
+
+namespace Shared.Features.CQRS.Query
+{
+    public class BaseQueryHandler : IInServerExecutionScope
+    {
+        public IServerExecutionContext ExecutionContext { get; private set; }
+    }
+}

Source/Shared/Features/CQRS/Query/IQueryHandler.cs

@@ -1,8 +1,8 @@
-using Shared.Features.Server.ExecutionContext;
+using Shared.Features.Server;
 
 namespace Shared.Features.CQRS.Query
 {
-    public interface IQueryHandler<in TQuery, TQueryResult> : IInServerExecutionContextScope where TQuery : IQuery<TQueryResult>
+    public interface IQueryHandler<in TQuery, TQueryResult> : IInServerExecutionScope where TQuery : IQuery<TQueryResult>
     {
         Task<TQueryResult> HandleAsync(TQuery query, CancellationToken cancellation);
     }

Source/Shared/Features/Server/BaseController.cs

@@ -1,20 +1,18 @@
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.DependencyInjection;
-using Shared.Features.Server.ExecutionContext;
-using Shared.Kernel.BuildingBlocks;
 using Shared.Kernel.BuildingBlocks.ModelValidation;
 
 namespace Shared.Features.Server
 {
-    public class BaseController : ControllerBase, IInServerExecutionContextScope
+    public class BaseController : ControllerBase, InServerExecutionScopeBase
     {
-        public IExecutionContext ExecutionContext { get; init; }
+        public IServerExecutionContext ExecutionContext { get; }
 
         protected readonly IValidationService validationService;
 
         public BaseController(IServiceProvider serviceProvider)
         {
-            ExecutionContext = serviceProvider.GetRequiredService<IExecutionContext>();
+            ExecutionContext = serviceProvider.GetRequiredService<IServerExecutionContext>();
             validationService = serviceProvider.GetRequiredService<IValidationService>();
         }
     }

Source/Shared/Features/Server/ExecutionContext/ServerExecutionContext.cs

@@ -7,12 +7,13 @@
 using Shared.Features.CQRS.DomainEvent;
 using Shared.Features.CQRS.IntegrationEvent;
 using Shared.Features.CQRS.Query;
+using Shared.Kernel.BuildingBlocks;
 using Shared.Kernel.BuildingBlocks.Auth;
 using Shared.Kernel.Extensions.ClaimsPrincipal;
 
 namespace Shared.Features.Server.ExecutionContext
 {
-    public class ServerExecutionContext : IServerExecutionContext
+    public class ServerExecutionContext : IExecutionContext
     {
         private static ServerExecutionContext executionContext;
         private ServerExecutionContext() { }
@@ -24,10 +25,6 @@ private ServerExecutionContext() { }
         public TenantRole TenantRole { get; private set; }
         public IHostEnvironment HostingEnvironment { get; set; }
         public Uri BaseURI { get; private set; }
-        public ICommandDispatcher CommandDispatcher { get; private set; }
-        public IQueryDispatcher QueryDispatcher { get; private set; }
-        public IIntegrationEventDispatcher IntegrationEventDispatcher { get; private set; }
-        public IDomainEventDispatcher DomainEventDispatcher { get; private set; }
 
         public static ServerExecutionContext CreateInstance(IServiceProvider serviceProvider)
         {

Source/Shared/Features/Server/ExecutionContext/IServerExecutionContext.cs → Source/Shared/Features/Server/IInServerExecutionScope.cs

@@ -3,14 +3,17 @@
 using Shared.Features.CQRS.IntegrationEvent;
 using Shared.Features.CQRS.Query;
 using Shared.Kernel.BuildingBlocks;
+using Shared.Kernel.BuildingBlocks.ModelValidation;
 
-namespace Shared.Features.Server.ExecutionContext
+namespace Shared.Features.Server
 {
-    public interface IServerExecutionContext : IExecutionContext
+    public interface IInServerExecutionScope
     {
+        public IExecutionContext ExecutionContext { get; }
         public ICommandDispatcher CommandDispatcher { get; }
         public IQueryDispatcher QueryDispatcher { get; }
         public IIntegrationEventDispatcher IntegrationEventDispatcher { get; }
         public IDomainEventDispatcher DomainEventDispatcher { get; }
+        public IValidationService ValidationService { get; }
     }
 }

Source/Shared/Features/Server/InServerExecutionScopeBase.cs

@@ -0,0 +1,19 @@
+using Shared.Features.CQRS.Command;
+using Shared.Features.CQRS.DomainEvent;
+using Shared.Features.CQRS.IntegrationEvent;
+using Shared.Features.CQRS.Query;
+using Shared.Kernel.BuildingBlocks;
+using Shared.Kernel.BuildingBlocks.ModelValidation;
+
+namespace Shared.Features.Server
+{
+    public class InServerExecutionScopeBase : IInServerExecutionScope
+    {
+        public IExecutionContext ExecutionContext { get; private set; }
+        public ICommandDispatcher CommandDispatcher { get; private set; }
+        public IQueryDispatcher QueryDispatcher { get; private set; }
+        public IIntegrationEventDispatcher IntegrationEventDispatcher { get; private set; }
+        public IDomainEventDispatcher DomainEventDispatcher { get; private set; }
+        public IValidationService ValidationService { get; private set; }
+    }
+}