Handle SqlException in UpdateObjectProcedureHandler

Wrap stored procedure execution in try-catch to handle SqlException.
Throw BadRequestException for configured SQL error numbers.
Update constructor to accept SqlExceptionOptions.
Add necessary using directives for new exception handling.

src/ReC.API/Controllers/ResultController.cs

@@ -12,7 +12,7 @@ namespace ReC.API.Controllers;
 
 [Route("api/[controller]")]
 [ApiController]
-public class ResultController(IMediator mediator, IConfiguration config) : ControllerBase
+public class ResultController(IMediator mediator) : ControllerBase
 {
     /// <summary>
     /// Gets output results based on the provided query parameters.

src/ReC.API/Middleware/ExceptionHandlingMiddleware.cs

@@ -63,6 +63,13 @@ public class ExceptionHandlingMiddleware
         switch (exception)
         {
             case BadRequestException badRequestEx:
+                if (badRequestEx.InnerException is not null)
+                {
+                    logger.LogError(
+                        badRequestEx.InnerException,
+                        "BadRequestException inner exception captured.");
+                }
+
                 context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
                 details = new() 
                 { 

src/ReC.API/Program.cs

@@ -37,6 +37,7 @@ try
     {
         options.LuckyPennySoftwareLicenseKey = builder.Configuration["LuckyPennySoftwareLicenseKey"];
         options.ConfigureRecActions(config.GetSection("RecAction"));
+        options.ConfigureSqlException(config.GetSection("SqlException"));
     });
 
     builder.Services.AddRecInfrastructure(options =>

src/ReC.API/appsettings.json

@@ -8,6 +8,12 @@
   "RecAction": {
     "MaxConcurrentInvocations": 5
   },
+  "SqlException": {
+    "ErrorMessages": {
+      // https://learn.microsoft.com/en-us/dotnet/api/system.data.sqlclient.sqlexception.number
+      "SqlExceptionNumber": [ 515 , 547, 2601, 2627]
+    }
+  },
   "AddedWho": "ReC.API",
   "FakeProfileId": 2
 }

src/ReC.Application/Common/Options/SqlExceptionOptions.cs

@@ -0,0 +1,6 @@
+namespace ReC.Application.Common.Options;
+
+public class SqlExceptionOptions
+{
+    public HashSet<int> SqlExceptionNumber { get; set; } = [];
+}

src/ReC.Application/Common/Procedures/DeleteProcedure/DeleteObjectProcedure.cs

@@ -1,7 +1,9 @@
 using DigitalData.Core.Abstraction.Application.Repository;
+using DigitalData.Core.Exceptions;
 using MediatR;
 using Microsoft.Data.SqlClient;
 using ReC.Application.Common.Exceptions;
+using ReC.Application.Common.Options;
 
 namespace ReC.Application.Common.Procedures.DeleteProcedure;
 
@@ -47,7 +49,7 @@ public static class DeleteObjectProcedureExtensions
     }
 }
 
-public class DeleteObjectProcedureHandler(IRepository repo) : IRequestHandler<DeleteObjectProcedure, int>
+public class DeleteObjectProcedureHandler(IRepository repo, SqlExceptionOptions sqlExceptionOptions) : IRequestHandler<DeleteObjectProcedure, int>
 {
     public async Task<int> Handle(DeleteObjectProcedure request, CancellationToken cancel)
     {
@@ -59,20 +61,30 @@ public class DeleteObjectProcedureHandler(IRepository repo) : IRequestHandler<De
             new SqlParameter("@pFORCE", (object?)request.Force ?? DBNull.Value)
         };
 
-        var result = await repo.ExecuteQueryRawAsync(
+        try
-            "DECLARE @RC SMALLINT = 0; " +
-            "EXEC @RC = [dbo].[PRREC_DELETE_OBJECT] " +
-            "@pENTITY, @pSTART, @pEND, @pFORCE; " +
-            "SELECT @RC;",
-            parameters,
-            cancel);
-
-        // The stored procedure returns 0 on success, error codes > 0 on failure
-        if (result > 0)
         {
-            throw new DeleteObjectFailedException(request, $"DeleteObject stored procedure failed with error code: {result}");
+            var result = await repo.ExecuteQueryRawAsync(
-        }
+                "DECLARE @RC SMALLINT = 0; " +
+                "EXEC @RC = [dbo].[PRREC_DELETE_OBJECT] " +
+                "@pENTITY, @pSTART, @pEND, @pFORCE; " +
+                "SELECT @RC;",
+                parameters,
+                cancel);
 
-        return result;
+            // The stored procedure returns 0 on success, error codes > 0 on failure
+            if (result > 0)
+            {
+                throw new DeleteObjectFailedException(request, $"DeleteObject stored procedure failed with error code: {result}");
+            }
+
+            return result;
+        }
+        catch (SqlException ex)
+        {
+            if (sqlExceptionOptions.SqlExceptionNumber.Contains(ex.Number))
+                throw new BadRequestException(ex.Message, ex);
+            else
+                throw;
+        }
     }
 }

src/ReC.Application/Common/Procedures/InsertProcedure/InsertObjectProcedure.cs

@@ -1,4 +1,5 @@
 using DigitalData.Core.Abstraction.Application.Repository;
+using DigitalData.Core.Exceptions;
 using MediatR;
 using Microsoft.Data.SqlClient;
 using ReC.Application.Common.Exceptions;
@@ -7,6 +8,7 @@ using ReC.Application.EndpointParams.Commands;
 using ReC.Application.Endpoints.Commands;
 using ReC.Application.Results.Commands;
 using ReC.Application.Profile.Commands;
+using ReC.Application.Common.Options;
 
 namespace ReC.Application.Common.Procedures.InsertProcedure;
 
@@ -41,7 +43,7 @@ public static class InsertObjectProcedureExtensions
     }
 }
 
-public class InsertObjectProcedureHandler(IRepository repo) : IRequestHandler<InsertObjectProcedure, long>
+public class InsertObjectProcedureHandler(IRepository repo, SqlExceptionOptions sqlExceptionOptions) : IRequestHandler<InsertObjectProcedure, long>
 {
     public async Task<long> Handle(InsertObjectProcedure request, CancellationToken cancel)
     {
@@ -110,18 +112,28 @@ public class InsertObjectProcedureHandler(IRepository repo) : IRequestHandler<In
             }
         };
 
-        await repo.ExecuteQueryRawAsync(
+        try
-            "EXEC [dbo].[PRREC_INSERT_OBJECT] " +
+        {
-            "@pENTITY, @pADDED_WHO, @pADDED_WHEN, " +
+            await repo.ExecuteQueryRawAsync(
-            "@pACTION_PROFILE_ID, @pACTION_ACTIVE, @pACTION_SEQUENCE, @pACTION_ENDPOINT_ID, @pACTION_ENDPOINT_AUTH_ID, @pACTION_ENDPOINT_PARAMS_ID, @pACTION_SQL_CONNECTION_ID, @pACTION_TYPE_ID, @pACTION_PRE_SQL, @pACTION_HEADER_SQL, @pACTION_BODY_SQL, @pACTION_POST_SQL, @pACTION_ERROR_ACTION_ID, " +
+                "EXEC [dbo].[PRREC_INSERT_OBJECT] " +
-            "@pENDPOINT_ACTIVE, @pENDPOINT_DESCRIPTION, @pENDPOINT_URI, " +
+                "@pENTITY, @pADDED_WHO, @pADDED_WHEN, " +
-            "@pENDPOINT_AUTH_ACTIVE, @pENDPOINT_AUTH_DESCRIPTION, @pENDPOINT_AUTH_TYPE_ID, @pENDPOINT_AUTH_API_KEY, @pENDPOINT_AUTH_API_VALUE, @pENDPOINT_AUTH_API_KEY_ADD_TO_ID, @pENDPOINT_AUTH_TOKEN, @pENDPOINT_AUTH_USERNAME, @pENDPOINT_AUTH_PASSWORD, @pENDPOINT_AUTH_DOMAIN, @pENDPOINT_AUTH_WORKSTATION, " +
+                "@pACTION_PROFILE_ID, @pACTION_ACTIVE, @pACTION_SEQUENCE, @pACTION_ENDPOINT_ID, @pACTION_ENDPOINT_AUTH_ID, @pACTION_ENDPOINT_PARAMS_ID, @pACTION_SQL_CONNECTION_ID, @pACTION_TYPE_ID, @pACTION_PRE_SQL, @pACTION_HEADER_SQL, @pACTION_BODY_SQL, @pACTION_POST_SQL, @pACTION_ERROR_ACTION_ID, " +
-            "@pPROFILE_ACTIVE, @pPROFILE_TYPE_ID, @pPROFILE_MANDANTOR, @pPROFILE_NAME, @pPROFILE_DESCRIPTION, @pPROFILE_LOG_LEVEL_ID, @pPROFILE_LANGUAGE_ID, " +
+                "@pENDPOINT_ACTIVE, @pENDPOINT_DESCRIPTION, @pENDPOINT_URI, " +
-            "@pRESULT_ACTION_ID, @pRESULT_STATUS_ID, @pRESULT_HEADER, @pRESULT_BODY, " +
+                "@pENDPOINT_AUTH_ACTIVE, @pENDPOINT_AUTH_DESCRIPTION, @pENDPOINT_AUTH_TYPE_ID, @pENDPOINT_AUTH_API_KEY, @pENDPOINT_AUTH_API_VALUE, @pENDPOINT_AUTH_API_KEY_ADD_TO_ID, @pENDPOINT_AUTH_TOKEN, @pENDPOINT_AUTH_USERNAME, @pENDPOINT_AUTH_PASSWORD, @pENDPOINT_AUTH_DOMAIN, @pENDPOINT_AUTH_WORKSTATION, " +
-            "@pENDPOINT_PARAMS_ACTIVE, @pENDPOINT_PARAMS_DESCRIPTION, @pENDPOINT_PARAMS_GROUP_ID, @pENDPOINT_PARAMS_SEQUENCE, @pENDPOINT_PARAMS_KEY, @pENDPOINT_PARAMS_VALUE, " +
+                "@pPROFILE_ACTIVE, @pPROFILE_TYPE_ID, @pPROFILE_MANDANTOR, @pPROFILE_NAME, @pPROFILE_DESCRIPTION, @pPROFILE_LOG_LEVEL_ID, @pPROFILE_LANGUAGE_ID, " +
-            "@oGUID OUTPUT",
+                "@pRESULT_ACTION_ID, @pRESULT_STATUS_ID, @pRESULT_HEADER, @pRESULT_BODY, " +
-            parameters,
+                "@pENDPOINT_PARAMS_ACTIVE, @pENDPOINT_PARAMS_DESCRIPTION, @pENDPOINT_PARAMS_GROUP_ID, @pENDPOINT_PARAMS_SEQUENCE, @pENDPOINT_PARAMS_KEY, @pENDPOINT_PARAMS_VALUE, " +
-            cancel);
+                "@oGUID OUTPUT",
+                parameters,
+                cancel);
+        }
+        catch (SqlException ex)
+        {
+            if (sqlExceptionOptions.SqlExceptionNumber.Contains(ex.Number))
+                throw new BadRequestException(ex.Message, ex);
+            else
+                throw;
+        }
 
         var guidParam = parameters.Last();
 

src/ReC.Application/Common/Procedures/UpdateProcedure/UpdateObjectProcedure.cs

@@ -1,13 +1,15 @@
 using DigitalData.Core.Abstraction.Application.Repository;
+using DigitalData.Core.Exceptions;
 using MediatR;
 using Microsoft.Data.SqlClient;
 using ReC.Application.Common.Exceptions;
+using ReC.Application.Common.Options;
 using ReC.Application.EndpointAuth.Commands;
 using ReC.Application.EndpointParams.Commands;
 using ReC.Application.Endpoints.Commands;
-using ReC.Application.Results.Commands;
 using ReC.Application.Profile.Commands;
 using ReC.Application.RecActions.Commands;
+using ReC.Application.Results.Commands;
 
 namespace ReC.Application.Common.Procedures.UpdateProcedure;
 
@@ -47,7 +49,7 @@ public static class UpdateObjectProcedureExtensions
     }
 }
 
-public class UpdateObjectProcedureHandler(IRepository repo) : IRequestHandler<UpdateObjectProcedure, int>
+public class UpdateObjectProcedureHandler(IRepository repo, SqlExceptionOptions sqlExceptionOptions) : IRequestHandler<UpdateObjectProcedure, int>
 {
     public async Task<int> Handle(UpdateObjectProcedure request, CancellationToken cancel)
     {
@@ -113,26 +115,36 @@ public class UpdateObjectProcedureHandler(IRepository repo) : IRequestHandler<Up
             new SqlParameter("@pRESULT_BODY", (object?)request.Result.Body ?? DBNull.Value)
         };
 
-        var result = await repo.ExecuteQueryRawAsync(
+        try
-            "DECLARE @RC SMALLINT = 0; " +
-            "EXEC @RC = [dbo].[PRREC_UPDATE_OBJECT] " +
-            "@pENTITY, @pGUID, @pCHANGED_WHO, @pCHANGED_WHEN, " +
-            "@pACTION_PROFILE_ID, @pACTION_ACTIVE, @pACTION_SEQUENCE, @pACTION_ENDPOINT_ID, @pACTION_ENDPOINT_AUTH_ID, @pACTION_ENDPOINT_PARAMS_ID, @pACTION_SQL_CONNECTION_ID, @pACTION_TYPE_ID, @pACTION_PRE_SQL, @pACTION_HEADER_SQL, @pACTION_BODY_SQL, @pACTION_POST_SQL, @pACTION_ERROR_ACTION_ID, " +
-            "@pENDPOINT_ACTIVE, @pENDPOINT_DESCRIPTION, @pENDPOINT_URI, " +
-            "@pENDPOINT_AUTH_ACTIVE, @pENDPOINT_AUTH_DESCRIPTION, @pENDPOINT_AUTH_TYPE_ID, @pENDPOINT_AUTH_API_KEY, @pENDPOINT_AUTH_API_VALUE, @pENDPOINT_AUTH_API_KEY_ADD_TO_ID, @pENDPOINT_AUTH_TOKEN, @pENDPOINT_AUTH_USERNAME, @pENDPOINT_AUTH_PASSWORD, @pENDPOINT_AUTH_DOMAIN, @pENDPOINT_AUTH_WORKSTATION, " +
-            "@pENDPOINT_PARAMS_ACTIVE, @pENDPOINT_PARAMS_DESCRIPTION, @pENDPOINT_PARAMS_GROUP_ID, @pENDPOINT_PARAMS_SEQUENCE, @pENDPOINT_PARAMS_KEY, @pENDPOINT_PARAMS_VALUE, " +
-            "@pPROFILE_ACTIVE, @pPROFILE_TYPE_ID, @pPROFILE_MANDANTOR, @pPROFILE_NAME, @pPROFILE_DESCRIPTION, @pPROFILE_LOG_LEVEL_ID, @pPROFILE_LANGUAGE_ID, @pPROFILE_FIRST_RUN, @pPROFILE_LAST_RUN, @pPROFILE_LAST_RESULT, " +
-            "@pRESULT_ACTION_ID, @pRESULT_STATUS_ID, @pRESULT_HEADER, @pRESULT_BODY; " +
-            "SELECT @RC;",
-            parameters,
-            cancel);
-
-        // The stored procedure returns 0 on success, error codes > 0 on failure
-        if (result > 0)
         {
-            throw new UpdateObjectFailedException(request, $"UpdateObject stored procedure failed with error code: {result}");
+            var result = await repo.ExecuteQueryRawAsync(
-        }
+                "DECLARE @RC SMALLINT = 0; " +
+                "EXEC @RC = [dbo].[PRREC_UPDATE_OBJECT] " +
+                "@pENTITY, @pGUID, @pCHANGED_WHO, @pCHANGED_WHEN, " +
+                "@pACTION_PROFILE_ID, @pACTION_ACTIVE, @pACTION_SEQUENCE, @pACTION_ENDPOINT_ID, @pACTION_ENDPOINT_AUTH_ID, @pACTION_ENDPOINT_PARAMS_ID, @pACTION_SQL_CONNECTION_ID, @pACTION_TYPE_ID, @pACTION_PRE_SQL, @pACTION_HEADER_SQL, @pACTION_BODY_SQL, @pACTION_POST_SQL, @pACTION_ERROR_ACTION_ID, " +
+                "@pENDPOINT_ACTIVE, @pENDPOINT_DESCRIPTION, @pENDPOINT_URI, " +
+                "@pENDPOINT_AUTH_ACTIVE, @pENDPOINT_AUTH_DESCRIPTION, @pENDPOINT_AUTH_TYPE_ID, @pENDPOINT_AUTH_API_KEY, @pENDPOINT_AUTH_API_VALUE, @pENDPOINT_AUTH_API_KEY_ADD_TO_ID, @pENDPOINT_AUTH_TOKEN, @pENDPOINT_AUTH_USERNAME, @pENDPOINT_AUTH_PASSWORD, @pENDPOINT_AUTH_DOMAIN, @pENDPOINT_AUTH_WORKSTATION, " +
+                "@pENDPOINT_PARAMS_ACTIVE, @pENDPOINT_PARAMS_DESCRIPTION, @pENDPOINT_PARAMS_GROUP_ID, @pENDPOINT_PARAMS_SEQUENCE, @pENDPOINT_PARAMS_KEY, @pENDPOINT_PARAMS_VALUE, " +
+                "@pPROFILE_ACTIVE, @pPROFILE_TYPE_ID, @pPROFILE_MANDANTOR, @pPROFILE_NAME, @pPROFILE_DESCRIPTION, @pPROFILE_LOG_LEVEL_ID, @pPROFILE_LANGUAGE_ID, @pPROFILE_FIRST_RUN, @pPROFILE_LAST_RUN, @pPROFILE_LAST_RESULT, " +
+                "@pRESULT_ACTION_ID, @pRESULT_STATUS_ID, @pRESULT_HEADER, @pRESULT_BODY; " +
+                "SELECT @RC;",
+                parameters,
+                cancel);
 
-        return result;
+            // The stored procedure returns 0 on success, error codes > 0 on failure
+            if (result > 0)
+            {
+                throw new UpdateObjectFailedException(request, $"UpdateObject stored procedure failed with error code: {result}");
+            }
+
+            return result;
+        }
+        catch (SqlException ex)
+        {
+            if (sqlExceptionOptions.SqlExceptionNumber.Contains(ex.Number))
+                throw new BadRequestException(ex.Message, ex);
+            else
+                throw;
+        }
     }
 }

src/ReC.Application/DependencyInjection.cs

@@ -2,9 +2,11 @@
 using MediatR;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
 using ReC.Application.Common.Behaviors;
 using ReC.Application.Common.Constants;
 using ReC.Application.Common.Options;
+using ReC.Application.Common.Procedures;
 using System.Reflection;
 
 namespace ReC.Application;
@@ -116,5 +118,23 @@ public static class DependencyInjection
             return this;
         }
         #endregion ConfigureRecActions
+
+        #region ConfigureSqlException
+        public ConfigurationOptions ConfigureSqlException(Action<SqlExceptionOptions> configure)
+        {
+            _configActions.Enqueue(services => services.Configure(configure));
+            return this;
+        }
+
+        public ConfigurationOptions ConfigureSqlException(IConfiguration configuration)
+        {
+            _configActions.Enqueue(services =>
+            {
+                services.Configure<SqlExceptionOptions>(configuration);
+            });
+
+            return this;
+        }
+        #endregion ConfigureSqlException
     }
 }

src/ReC.Application/ReC.Application.csproj

@@ -10,7 +10,7 @@
     <PackageReference Include="AutoMapper" Version="15.1.0" />
     <PackageReference Include="DigitalData.Core.Abstraction.Application" Version="1.6.0" />
     <PackageReference Include="DigitalData.Core.Application" Version="3.4.0" />
-    <PackageReference Include="DigitalData.Core.Exceptions" Version="1.1.0" />
+    <PackageReference Include="DigitalData.Core.Exceptions" Version="1.1.1" />
     <PackageReference Include="FluentValidation" Version="12.1.0" />
     <PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="12.1.0" />
     <PackageReference Include="MediatR" Version="13.1.0" />

tests/ReC.Tests/Application/RecApplicationTestBase.cs

@@ -40,6 +40,7 @@ public abstract class RecApplicationTestBase : IDisposable
         {
             options.LuckyPennySoftwareLicenseKey = configuration["LuckyPennySoftwareLicenseKey"];
             options.ConfigureRecActions(configuration.GetSection("RecAction"));
+            options.ConfigureSqlException(configuration.GetSection("SqlException"));
         });
 
         services.AddRecInfrastructure(opt =>