diff --git a/src/DigitalData.ActiveDirectory.API/Middleware/ExceptionHandlingMiddleware.cs b/src/DigitalData.ActiveDirectory.API/Middleware/ExceptionHandlingMiddleware.cs new file mode 100644 index 0000000..fd8f528 --- /dev/null +++ b/src/DigitalData.ActiveDirectory.API/Middleware/ExceptionHandlingMiddleware.cs @@ -0,0 +1,84 @@ +using DigitalData.Core.Exceptions; +using System.Net; +using System.Text.Json; + +namespace DigitalData.ActiveDirectory.API.Middleware; + +//TODO: Fix and use DigitalData.Core.Exceptions.Middleware +/// +/// Middleware for handling exceptions globally in the application. +/// Captures exceptions thrown during the request pipeline execution, +/// logs them, and returns an appropriate HTTP response with a JSON error message. +/// +[Obsolete("Use DigitalData.Core.Exceptions.Middleware")] +public class ExceptionHandlingMiddleware +{ + private readonly RequestDelegate _next; + private readonly ILogger _logger; + + /// + /// Initializes a new instance of the class. + /// + /// The next middleware in the request pipeline. + /// The logger instance for logging exceptions. + public ExceptionHandlingMiddleware(RequestDelegate next, ILogger logger) + { + _next = next; + _logger = logger; + } + + /// + /// Invokes the middleware to handle the HTTP request. + /// + /// The HTTP context of the current request. + /// A task that represents the asynchronous operation. + public async Task InvokeAsync(HttpContext context) + { + try + { + await _next(context); // Continue down the pipeline + } + catch (Exception ex) + { + await HandleExceptionAsync(context, ex, _logger); + } + } + + /// + /// Handles exceptions by logging them and writing an appropriate JSON response. + /// + /// The HTTP context of the current request. + /// The exception that occurred. + /// The logger instance for logging the exception. + /// A task that represents the asynchronous operation. + private static async Task HandleExceptionAsync(HttpContext context, Exception exception, ILogger logger) + { + context.Response.ContentType = "application/json"; + + string message; + + switch (exception) + { + case BadRequestException badRequestEx: + context.Response.StatusCode = (int)HttpStatusCode.BadRequest; + message = badRequestEx.Message; + break; + + case NotFoundException notFoundEx: + context.Response.StatusCode = (int)HttpStatusCode.NotFound; + message = notFoundEx.Message; + break; + + default: + logger.LogError(exception, "Unhandled exception occurred."); + context.Response.StatusCode = (int)HttpStatusCode.InternalServerError; + message = "An unexpected error occurred."; + break; + } + + await context.Response.WriteAsync(JsonSerializer.Serialize(new + { + message + })); + } +} diff --git a/src/DigitalData.ActiveDirectory.API/Program.cs b/src/DigitalData.ActiveDirectory.API/Program.cs index 48863a6..9a33468 100644 --- a/src/DigitalData.ActiveDirectory.API/Program.cs +++ b/src/DigitalData.ActiveDirectory.API/Program.cs @@ -1,3 +1,5 @@ +using DigitalData.ActiveDirectory.API.Middleware; + var builder = WebApplication.CreateBuilder(args); // Add services to the container. @@ -9,6 +11,8 @@ builder.Services.AddSwaggerGen(); var app = builder.Build(); +app.UseMiddleware(); + // Configure the HTTP request pipeline. if (app.Environment.IsDevelopment()) { diff --git a/src/DigitalData.ActiveDirectory/DigitalData.ActiveDirectory.csproj b/src/DigitalData.ActiveDirectory/DigitalData.ActiveDirectory.csproj index 7a36560..ebf8c96 100644 --- a/src/DigitalData.ActiveDirectory/DigitalData.ActiveDirectory.csproj +++ b/src/DigitalData.ActiveDirectory/DigitalData.ActiveDirectory.csproj @@ -7,8 +7,9 @@ + - +