Handle internal server errors

.gitignore

@@ -672,3 +672,4 @@ fabric.properties
 **/wwwroot/bundled
 ocelot.json
 /src/2-Services/Identity/Api/Identity.Api/keys
+/src/6-Docker/mssqldata/Entropy.bin

src/1-BuildingBlocks/Application/Behaviors/BehaviorsExtensions.cs → src/1-BuildingBlocks/Application/Behaviors/BehaviorExtensions.cs

@@ -6,7 +6,7 @@
 
 namespace TaskoMask.BuildingBlocks.Application.Behaviors
 {
-    public static class BehaviorsExtensions
+    public static class BehaviorExtensions
     {
 
 

src/1-BuildingBlocks/Application/Exceptions/ApplicationException.cs

@@ -1,12 +1,12 @@
-using TaskoMask.BuildingBlocks.Domain.Exceptions;
+using TaskoMask.BuildingBlocks.Contracts.Exceptions;
 
 namespace TaskoMask.BuildingBlocks.Application.Exceptions
 {
 
     /// <summary>
     /// 
     /// </summary>
-    public class ApplicationException : DomainException
+    public class ApplicationException : ManagedException
     {
         #region Ctors
 

src/1-BuildingBlocks/Application/Exceptions/ExceptionExtensions.cs

@@ -0,0 +1,38 @@
+using MediatR.Pipeline;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace TaskoMask.BuildingBlocks.Application.Exceptions
+{
+    public static class ExceptionExtensions
+    {
+
+        /// <summary>
+        /// 
+        /// </summary>
+        public static void AddApplicationExceptionHandlers(this IServiceCollection services)
+        {
+            services.AddManagedExceptionsHandler();
+            services.AddUnmanagedExceptionsHandler();
+        }
+
+
+
+        /// <summary>
+        /// 
+        /// </summary>
+        private static void AddManagedExceptionsHandler(this IServiceCollection services)
+        {
+            services.AddScoped(typeof(IRequestExceptionHandler<,,>), typeof(ManagedExceptionHandler<,,>));
+        }
+
+
+        /// <summary>
+        /// 
+        /// </summary>
+        private static void AddUnmanagedExceptionsHandler(this IServiceCollection services)
+        {
+            services.AddScoped(typeof(IRequestExceptionHandler<,,>), typeof(UnmanagedExceptionHandler<,,>));
+        }
+
+    }
+}

src/1-BuildingBlocks/Application/Exceptions/ApplicationExceptionsHandler.cs → src/1-BuildingBlocks/Application/Exceptions/ManagedExceptionHandler.cs

@@ -1,39 +1,39 @@
 using TaskoMask.BuildingBlocks.Application.Notifications;
-using MediatR;
 using MediatR.Pipeline;
 using System.Threading;
 using System.Threading.Tasks;
-using TaskoMask.BuildingBlocks.Domain.Exceptions;
+using Microsoft.Extensions.Logging;
+using TaskoMask.BuildingBlocks.Contracts.Exceptions;
+using System.Text.Json;
 
 namespace TaskoMask.BuildingBlocks.Application.Exceptions
 {
     /// <summary>
-    /// 
+    /// Handle all managed exceptions (DomainException,ApplicationException,ValidationException)
     /// </summary>
-    public class ApplicationExceptionsHandler<TRequest, TResponse, TException>
-        : IRequestExceptionHandler<TRequest, TResponse, TException> where TException : DomainException
+    public class ManagedExceptionHandler<TRequest, TResponse, TException>
+        : IRequestExceptionHandler<TRequest, TResponse, TException> where TException : ManagedException
     {
         #region Fields
 
 
         private readonly INotificationHandler _notifications;
-
+        private readonly ILogger<ManagedExceptionHandler<TRequest, TResponse, TException>> _logger;
 
         #endregion
 
-
         #region Ctors
 
 
-        public ApplicationExceptionsHandler(INotificationHandler notifications)
+        public ManagedExceptionHandler(INotificationHandler notifications, ILogger<ManagedExceptionHandler<TRequest, TResponse, TException>> logger)
         {
             _notifications = notifications;
+            this._logger = logger;
         }
 
 
         #endregion
 
-
         #region Handler
 
 
@@ -45,25 +45,11 @@ public Task Handle(TRequest request, TException exception, RequestExceptionHandl
         {
             var exceptionType = exception.GetType();
 
-            //notification exception error message if exist
+            //notify exception message if any
             if (!string.IsNullOrEmpty(exception.Message))
                 _notifications.Add(exceptionType.Name, exception.Message);
 
-
-            if (exceptionType == typeof(ApplicationException))
-            {
-                //log ApplicationException ...
-            }
-
-            else if (exceptionType == typeof(ValidationException))
-            {
-                //log ValidationException ...
-            }
-
-            else if (exceptionType == typeof(DomainException))
-            {
-                //log DomainException ...
-            }
+            _logger.LogWarning(exception, $"request : {JsonSerializer.Serialize(request)}");
 
             state.SetHandled(default);
 

src/1-BuildingBlocks/Application/Exceptions/UnmanagedExceptionHandler.cs

@@ -0,0 +1,58 @@
+using TaskoMask.BuildingBlocks.Application.Notifications;
+using MediatR.Pipeline;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Text.Json;
+
+namespace TaskoMask.BuildingBlocks.Application.Exceptions
+{
+    /// <summary>
+    /// Handle all unmanaged exceptions
+    /// </summary>
+    public class UnmanagedExceptionHandler<TRequest, TResponse, TException>
+        : IRequestExceptionHandler<TRequest, TResponse, TException> where TException : Exception
+    {
+        #region Fields
+
+
+        private readonly INotificationHandler _notifications;
+        private readonly ILogger<UnmanagedExceptionHandler<TRequest, TResponse, TException>> _logger;
+
+        #endregion
+
+        #region Ctors
+
+
+        public UnmanagedExceptionHandler(INotificationHandler notifications, ILogger<UnmanagedExceptionHandler<TRequest, TResponse, TException>> logger)
+        {
+            _notifications = notifications;
+            this._logger = logger;
+        }
+
+
+        #endregion
+
+        #region Handler
+
+
+
+        /// <summary>
+        /// 
+        /// </summary>
+        public Task Handle(TRequest request, TException exception, RequestExceptionHandlerState<TResponse> state, CancellationToken cancellationToken)
+        {
+            _notifications.Add("Unknown Exception", "Unknown exception happened");
+
+            _logger.LogError(exception, $"request : {JsonSerializer.Serialize(request)}");
+
+            state.SetHandled(default);
+
+            return Task.CompletedTask;
+        }
+
+
+        #endregion
+    }
+}

src/1-BuildingBlocks/Application/Exceptions/ValidationException.cs

@@ -1,12 +1,12 @@
-using TaskoMask.BuildingBlocks.Domain.Exceptions;
+using TaskoMask.BuildingBlocks.Contracts.Exceptions;
 
 namespace TaskoMask.BuildingBlocks.Application.Exceptions
 {
 
     /// <summary>
     /// 
     /// </summary>
-    public class ValidationException : DomainException
+    public class ValidationException : ManagedException
     {
         #region Ctors
 

src/1-BuildingBlocks/Application/Services/ApplicationExtensions.cs

@@ -17,7 +17,7 @@ public static void AddBuildingBlocksApplication(this IServiceCollection services
             if (services == null)
                 throw new ArgumentNullException(nameof(services));
 
-            services.AddApplicationExceptionsHandler();
+            services.AddApplicationExceptionHandlers();
             services.AddApplicationBehaviors(validatorAssemblyMarkerType);
             services.AddDomainNotificationHandler();
         }

src/1-BuildingBlocks/Contracts/Exceptions/DomainException.cs

@@ -0,0 +1,14 @@
+using System;
+namespace TaskoMask.BuildingBlocks.Contracts.Exceptions
+{
+    /// <summary>
+    /// 
+    /// </summary>
+    public class ManagedException : Exception
+    {
+        public ManagedException(string message): base(message)
+        {
+        }
+
+    }
+}

src/1-BuildingBlocks/Domain/Exceptions/DomainException.cs

@@ -1,10 +1,11 @@
-using System;
+using TaskoMask.BuildingBlocks.Contracts.Exceptions;
+
 namespace TaskoMask.BuildingBlocks.Domain.Exceptions
 {
     /// <summary>
     /// 
     /// </summary>
-    public class DomainException : Exception
+    public class DomainException : ManagedException
     {
         public DomainException(string message): base(message)
         {

src/1-BuildingBlocks/Web.MVC/Configuration/Grpc/GrpcConfiguration.cs

@@ -0,0 +1,30 @@
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using TaskoMask.BuildingBlocks.Web.MVC.Exceptions;
+
+namespace TaskoMask.BuildingBlocks.Web.Grpc.Configuration
+{
+
+    /// <summary>
+    /// 
+    /// </summary>
+    public static class GrpcConfiguration
+    {
+
+
+        /// <summary>
+        /// 
+        /// </summary>
+        public static void AddGrpcPreConfigured(this IServiceCollection services)
+        {
+            if (services == null) throw new ArgumentNullException(nameof(services));
+
+            services.AddGrpc(options =>
+            {
+                options.Interceptors.Add<GrpcGlobalExceptionHandler>();
+            });
+        }
+
+
+    }
+}

src/1-BuildingBlocks/Web.MVC/Configuration/MVC/WebApiConfiguration.cs

@@ -1,9 +1,9 @@
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
-using Microsoft.AspNetCore.Server.Kestrel.Core;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
+using MonoApi.Services.Afrr.Activations.Api.Helpers;
 using TaskoMask.BuildingBlocks.Web.MVC.Configuration.Jwt;
 using TaskoMask.BuildingBlocks.Web.MVC.Configuration.Swagger;
 using TaskoMask.BuildingBlocks.Web.MVC.Services.AuthenticatedUser;
@@ -55,6 +55,9 @@ public static void UseWebApiPreConfigured(this IApplicationBuilder app, IWebHost
             if (env.IsDevelopment())
                 app.UseDeveloperExceptionPage();
 
+            app.UseGlobalExceptionHandler();
+
+
             app.UseSwaggerPreConfigured();
 
             app.UseHttpsRedirection();
@@ -76,12 +79,20 @@ public static void UseWebApiPreConfigured(this IApplicationBuilder app, IWebHost
         /// <summary>
         /// Prevent auto validate on model binding
         /// </summary>
-        private static IMvcBuilder WithPreventAutoValidation(this IMvcBuilder builder)
+        private static void WithPreventAutoValidation(this IMvcBuilder builder)
         {
-            return builder.ConfigureApiBehaviorOptions(options =>
+            builder.ConfigureApiBehaviorOptions(options =>
                   {
                       options.SuppressModelStateInvalidFilter = true;
                   });
         }
+
+        /// <summary>
+        /// 
+        /// </summary>
+        private static void UseGlobalExceptionHandler(this IApplicationBuilder app)
+        {
+            app.UseMiddleware<HttpGlobalExceptionHandler>();
+        }
     }
 }

src/1-BuildingBlocks/Web.MVC/Exceptions/GrpcExceptionInterceptor.cs → src/1-BuildingBlocks/Web.MVC/Exceptions/GrpcGlobalExceptionHandler.cs

@@ -1,13 +1,21 @@
 using Grpc.Core;
 using Grpc.Core.Interceptors;
+using Microsoft.Extensions.Logging;
 
 namespace TaskoMask.BuildingBlocks.Web.MVC.Exceptions
 {
     /// <summary>
     /// Global exception handler for gRPC services
     /// </summary>
-    public class GrpcExceptionInterceptor : Interceptor
+    public class GrpcGlobalExceptionHandler : Interceptor
     {
+        private readonly ILogger _logger;
+
+        public GrpcGlobalExceptionHandler(ILogger logger)
+        {
+            this._logger = logger;
+        }
+
         public override async Task<TResponse> UnaryServerHandler<TRequest, TResponse>(
             TRequest request,
             ServerCallContext context,
@@ -19,6 +27,8 @@ public override async Task<TResponse> UnaryServerHandler<TRequest, TResponse>(
             }
             catch (Exception exception)
             {
+                _logger.LogError(exception, exception.Message);
+
                 throw new RpcException(new Status(StatusCode.Cancelled, exception.Message));
             }
         }