Separate CRUDControllerBase mit Fehlerbehandlung hinzugefügt.

DigitalData.Core.API/CRUDControllerBase.cs

@@ -46,27 +46,19 @@ namespace DigitalData.Core.API
         [HttpPost]
         public virtual async Task<IActionResult> Create(TCreateDto createDto)
         {
-            try
+            return await _service.CreateAsync(createDto).ThenAsync<TId, IActionResult>(
-            {
+                Success: id =>
-                return await _service.CreateAsync(createDto).ThenAsync<TId, IActionResult>(
+                {
-                                Success: id =>
+                    var createdResource = new { Id = id };
-                                {
+                    var actionName = nameof(GetById);
-                                    var createdResource = new { Id = id };
+                    var routeValues = new { id = createdResource.Id };
-                                    var actionName = nameof(GetById);
+                    return CreatedAtAction(actionName, routeValues, createdResource);
-                                    var routeValues = new { id = createdResource.Id };
+                },
-                                    return CreatedAtAction(actionName, routeValues, createdResource);
+                Fail: (messages, notices) =>
-                                },
+                {
-                                Fail: (messages, notices) =>
+                    _logger.LogNotice(notices);
-                                {
+                    return BadRequest(messages);
-                                    _logger.LogNotice(notices);
+                });
-                                    return BadRequest(messages);
-                                });
-            }
-            catch (Exception ex)
-            {
-                _logger.LogError(ex, "{Message}", ex.Message);
-                return StatusCode(StatusCodes.Status500InternalServerError);
-            }
         }
 
         /// <summary>
@@ -77,21 +69,13 @@ namespace DigitalData.Core.API
         [HttpGet("{id}")]
         public virtual async Task<IActionResult> GetById([FromRoute] TId id)
         {
-            try
+            return await _service.ReadByIdAsync(id).ThenAsync(
-            {
+                Success: Ok,
-                return await _service.ReadByIdAsync(id).ThenAsync(
+                Fail: IActionResult (messages, notices) =>
-                    Success: Ok,
+                {
-                    Fail: IActionResult (messages, notices) =>
+                    _logger.LogNotice(notices);
-                    {
+                    return NotFound(messages);
-                        _logger.LogNotice(notices);
+                });
-                        return NotFound(messages);
-                    });
-            }
-            catch (Exception ex)
-            {
-                _logger.LogError(ex, "{Message}", ex.Message);
-                return StatusCode(StatusCodes.Status500InternalServerError);
-            }
         }
 
         /// <summary>
@@ -101,21 +85,13 @@ namespace DigitalData.Core.API
         [HttpGet]
         public virtual async Task<IActionResult> GetAll()
         {
-            try
+            return await _service.ReadAllAsync().ThenAsync(
-            {
+                Success: Ok,
-                return await _service.ReadAllAsync().ThenAsync(
+                Fail: IActionResult (messages, notices) =>
-                    Success: Ok,
+                {
-                    Fail: IActionResult (messages, notices) =>
+                    _logger.LogNotice(notices);
-                    {
+                    return NotFound(messages);
-                        _logger.LogNotice(notices);
+                });
-                        return NotFound(messages);
-                    });
-            }
-            catch (Exception ex)
-            {
-                _logger.LogError(ex, "{Message}", ex.Message);
-                return StatusCode(StatusCodes.Status500InternalServerError);
-            }
         }
 
         /// <summary>
@@ -126,21 +102,13 @@ namespace DigitalData.Core.API
         [HttpPut]
         public virtual async Task<IActionResult> Update(TUpdateDto updateDto)
         {
-            try
+            return await _service.UpdateAsync(updateDto).ThenAsync(
-            {
+                Success: Ok,
-                return await _service.UpdateAsync(updateDto).ThenAsync(
+                Fail: IActionResult (messages, notices) =>
-                                Success: Ok,
+                {
-                                Fail: IActionResult (messages, notices) =>
+                    _logger.LogNotice(notices);
-                                {
+                    return BadRequest(messages);
-                                    _logger.LogNotice(notices);
+                });
-                                    return BadRequest(messages);
-                                });
-            }
-            catch(Exception ex)
-            {
-                _logger.LogError(ex, "{Message}", ex.Message);
-                return StatusCode(StatusCodes.Status500InternalServerError);
-            }
         }
 
         /// <summary>
@@ -151,21 +119,13 @@ namespace DigitalData.Core.API
         [HttpDelete("{id}")]
         public virtual async Task<IActionResult> Delete([FromRoute] TId id)
         {
-            try
+            return await _service.DeleteAsyncById(id).ThenAsync(
-            {
+                Success: Ok,
-                return await _service.DeleteAsyncById(id).ThenAsync(
+                Fail: IActionResult (messages, notices) =>
-                                Success: Ok,
+                {
-                                Fail: IActionResult (messages, notices) =>
+                    _logger.LogNotice(notices);
-                                {
+                    return BadRequest(messages);
-                                    _logger.LogNotice(notices);
+                });
-                                    return BadRequest(messages);
-                                });
-            }
-            catch (Exception ex)
-            {
-                _logger.LogError(ex, "{Message}", ex.Message);
-                return StatusCode(StatusCodes.Status500InternalServerError);
-            }
         }
     }
 }

DigitalData.Core.API/CRUDControllerBaseWithErrorHandling.cs

@@ -0,0 +1,172 @@
+using DigitalData.Core.Abstractions.Application;
+using DigitalData.Core.DTO;
+using Microsoft.AspNetCore.Mvc;
+
+namespace DigitalData.Core.API
+{
+    /// <summary>
+    /// A base controller class that provides generic CRUD (Create, Read, Update, Delete) operations for a specified entity type,
+    /// with enhanced error handling to ensure robust and reliable API endpoints.
+    /// </summary>
+    /// <typeparam name="TCRUDService">The derived CRUD service type implementing ICRUDService<TCreateDto, TReadDto, TUpdateDto, TEntity, TId>.</typeparam>
+    /// <typeparam name="TCreateDto">The Data Transfer Object type for create operations.</typeparam>
+    /// <typeparam name="TReadDto">The Data Transfer Object type for read operations.</typeparam>
+    /// <typeparam name="TUpdateDto">The Data Transfer Object type for update operations.</typeparam>
+    /// <typeparam name="TEntity">The entity type CRUD operations will be performed on.</typeparam>
+    /// <typeparam name="TId">The type of the entity's identifier.</typeparam>
+    [ApiController]
+    [Route("api/[controller]")]
+    public class CRUDControllerBaseWithErrorHandling<TCRUDService, TCreateDto, TReadDto, TUpdateDto, TEntity, TId> : ControllerBase
+        where TCRUDService : ICRUDService<TCreateDto, TReadDto, TUpdateDto, TEntity, TId>
+        where TCreateDto : class
+        where TReadDto : class
+        where TUpdateDto : class
+        where TEntity : class
+    {
+        protected readonly ILogger _logger;
+        protected readonly TCRUDService _service;
+
+        /// <summary>
+        /// Initializes a new instance of the CRUDControllerBase class with specified logger and CRUD service.
+        /// </summary>
+        /// <param name="logger">The logger to be used by the controller.</param>
+        /// <param name="service">The CRUD service handling business logic for the entity.</param>
+        public CRUDControllerBaseWithErrorHandling(
+            ILogger logger,
+            TCRUDService service)
+        {
+            _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+            _service = service ?? throw new ArgumentNullException(nameof(service));
+        }
+
+        /// <summary>
+        /// Creates a new entity based on the provided DTO.
+        /// </summary>
+        /// <param name="createDto">The DTO from which to create the entity.</param>
+        /// <returns>A task that represents the asynchronous create operation. The task result contains the action result.</returns>
+        [HttpPost]
+        public virtual async Task<IActionResult> Create(TCreateDto createDto)
+        {
+            try
+            {
+                return await _service.CreateAsync(createDto).ThenAsync<TId, IActionResult>(
+                                Success: id =>
+                                {
+                                    var createdResource = new { Id = id };
+                                    var actionName = nameof(GetById);
+                                    var routeValues = new { id = createdResource.Id };
+                                    return CreatedAtAction(actionName, routeValues, createdResource);
+                                },
+                                Fail: (messages, notices) =>
+                                {
+                                    _logger.LogNotice(notices);
+                                    return BadRequest(messages);
+                                });
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "{Message}", ex.Message);
+                return StatusCode(StatusCodes.Status500InternalServerError);
+            }
+        }
+
+        /// <summary>
+        /// Retrieves an entity by its identifier.
+        /// </summary>
+        /// <param name="id">The identifier of the entity to retrieve.</param>
+        /// <returns>A task that represents the asynchronous read operation. The task result contains the action result.</returns>
+        [HttpGet("{id}")]
+        public virtual async Task<IActionResult> GetById([FromRoute] TId id)
+        {
+            try
+            {
+                return await _service.ReadByIdAsync(id).ThenAsync(
+                    Success: Ok,
+                    Fail: IActionResult (messages, notices) =>
+                    {
+                        _logger.LogNotice(notices);
+                        return NotFound(messages);
+                    });
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "{Message}", ex.Message);
+                return StatusCode(StatusCodes.Status500InternalServerError);
+            }
+        }
+
+        /// <summary>
+        /// Retrieves all entities.
+        /// </summary>
+        /// <returns>A task that represents the asynchronous read-all operation. The task result contains the action result.</returns>
+        [HttpGet]
+        public virtual async Task<IActionResult> GetAll()
+        {
+            try
+            {
+                return await _service.ReadAllAsync().ThenAsync(
+                    Success: Ok,
+                    Fail: IActionResult (messages, notices) =>
+                    {
+                        _logger.LogNotice(notices);
+                        return NotFound(messages);
+                    });
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "{Message}", ex.Message);
+                return StatusCode(StatusCodes.Status500InternalServerError);
+            }
+        }
+
+        /// <summary>
+        /// Updates an existing entity based on the provided DTO.
+        /// </summary>
+        /// <param name="updateDto">The DTO containing the updated data for the entity.</param>
+        /// <returns>A task that represents the asynchronous update operation. The task result contains the action result.</returns>
+        [HttpPut]
+        public virtual async Task<IActionResult> Update(TUpdateDto updateDto)
+        {
+            try
+            {
+                return await _service.UpdateAsync(updateDto).ThenAsync(
+                                Success: Ok,
+                                Fail: IActionResult (messages, notices) =>
+                                {
+                                    _logger.LogNotice(notices);
+                                    return BadRequest(messages);
+                                });
+            }
+            catch(Exception ex)
+            {
+                _logger.LogError(ex, "{Message}", ex.Message);
+                return StatusCode(StatusCodes.Status500InternalServerError);
+            }
+        }
+
+        /// <summary>
+        /// Deletes an entity by its identifier.
+        /// </summary>
+        /// <param name="id">The identifier of the entity to delete.</param>
+        /// <returns>A task that represents the asynchronous delete operation. The task result contains the action result.</returns>
+        [HttpDelete("{id}")]
+        public virtual async Task<IActionResult> Delete([FromRoute] TId id)
+        {
+            try
+            {
+                return await _service.DeleteAsyncById(id).ThenAsync(
+                                Success: Ok,
+                                Fail: IActionResult (messages, notices) =>
+                                {
+                                    _logger.LogNotice(notices);
+                                    return BadRequest(messages);
+                                });
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "{Message}", ex.Message);
+                return StatusCode(StatusCodes.Status500InternalServerError);
+            }
+        }
+    }
+}