Bump version to 2.2.1-beta

Updated Version, AssemblyVersion, and FileVersion in ReC.API.csproj from 2.2.0-beta/2.2.0.0 to 2.2.1-beta/2.2.1.0. No other changes made.

src/ReC.API/Controllers/RecActionController.cs

@@ -13,14 +13,19 @@ public class RecActionController(IMediator mediator) : ControllerBase
     /// <summary>
     /// Invokes a batch of RecActions for a given profile.
     /// </summary>
-    /// <param name="command">The command containing the profile ID.</param>
+    /// <param name="profileId">The identifier of the profile whose RecActions should be invoked.</param>
+    /// <param name="references">Optional reference values that are passed through to all result records.</param>
     /// <param name="cancel">A token to cancel the operation.</param>
     /// <returns>An HTTP 202 Accepted response indicating the process has been started.</returns>
-    [HttpPost("invoke/{command}")]
+    [HttpPost("invoke/{profileId}")]
     [ProducesResponseType(StatusCodes.Status202Accepted)]
-    public async Task<IActionResult> Invoke([FromRoute] InvokeBatchRecActionViewsCommand command, CancellationToken cancel)
+    public async Task<IActionResult> Invoke([FromRoute] long profileId, [FromBody] InvokeReferences references, CancellationToken cancel = default)
     {
-        await mediator.Send(command, cancel);
+        await mediator.Send(new InvokeBatchRecActionViewsCommand
+        {
+            ProfileId = profileId,
+            References = references
+        }, cancel);
         return Accepted();
     }
 

src/ReC.API/Middleware/ExceptionHandlingMiddleware.cs

@@ -7,13 +7,11 @@ using System.Text.Json;
 
 namespace ReC.API.Middleware;
 
-//TODO: Fix and use DigitalData.Core.Exceptions.Middleware
 /// <summary>
 /// 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 details.
 /// </summary>
-[Obsolete("Use DigitalData.Core.Exceptions.Middleware")]
 public class ExceptionHandlingMiddleware
 {
     private readonly RequestDelegate _next;
@@ -164,6 +162,22 @@ public class ExceptionHandlingMiddleware
                 };
                 break;
 
+            case RecActionException recActionEx:
+                logger.LogWarning(
+                    recActionEx,
+                    "Rec action failed. ActionId: {ActionId}, ProfileId: {ProfileId}",
+                    recActionEx.ActionId,
+                    recActionEx.ProfileId);
+
+                context.Response.StatusCode = (int)HttpStatusCode.UnprocessableEntity;
+                details = new()
+                {
+                    Title = "Rec Action Failed",
+                    Detail = recActionEx.InnerException?.Message
+                        ?? "An error occurred while executing the rec action. Check the logs for more details."
+                };
+                break;
+
             default:
                 logger.LogError(exception, "Unhandled exception occurred.");
                 context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;

src/ReC.API/Models/FakeRequest.cs

@@ -1,8 +0,0 @@
-namespace ReC.API.Models;
-
-public class FakeRequest
-{
-    public Dictionary<string, object>? Body { get; init; }
-
-    public Dictionary<string, object>? Header { get; init; }
-}

src/ReC.API/Models/ResultType.cs

@@ -1,17 +0,0 @@
-namespace ReC.API.Models;
-
-public enum ResultType
-{
-    /// <summary>
-    /// Return the full result object.
-    /// </summary>
-    Full,
-    /// <summary>
-    /// Return only the header part of the result.
-    /// </summary>
-    OnlyHeader,
-    /// <summary>
-    /// Return only the body part of the result.
-    /// </summary>
-    OnlyBody
-}

src/ReC.API/Program.cs

@@ -70,9 +70,7 @@ try
 
     var app = builder.Build();
 
-#pragma warning disable CS0618
     app.UseMiddleware<ExceptionHandlingMiddleware>();
-#pragma warning restore CS0618
 
     // Configure the HTTP request pipeline.
     if (app.Environment.IsDevelopment() || config.GetValue<bool>("UseSwagger"))

src/ReC.API/Properties/PublishProfiles/IISProfile.pubxml

@@ -9,7 +9,7 @@
     <LaunchSiteAfterPublish>true</LaunchSiteAfterPublish>
     <ExcludeApp_Data>false</ExcludeApp_Data>
     <ProjectGuid>420218ad-3c27-4003-9a84-36c92352f175</ProjectGuid>
-    <DesktopBuildPackageLocation>P:\Install .Net\0 DD - Smart UP\ReC\API\$(Version)\Rec.API.zip</DesktopBuildPackageLocation>	  
+    <DesktopBuildPackageLocation>M:\App&amp;Service\0 DD - Smart UP\ReC\API\$(Version)\Rec.API.zip</DesktopBuildPackageLocation>	  
     <PackageAsSingleFile>true</PackageAsSingleFile>
     <DeployIisAppPath>Rec.API</DeployIisAppPath>
     <_TargetId>IISWebDeployPackage</_TargetId>

src/ReC.API/ReC.API.csproj

@@ -10,10 +10,10 @@
 	<Product>ReC.API</Product>
 	<PackageIcon>Assets\icon.ico</PackageIcon>
 	<PackageTags>digital data rest-caller rec api</PackageTags>
-	<Version>2.0.2-beta</Version>
-	<AssemblyVersion>2.0.2.0</AssemblyVersion>
-	<FileVersion>2.0.2.0</FileVersion>
-	<InformationalVersion>2.0.1-beta</InformationalVersion>
+	<Version>2.2.1-beta</Version>
+	<AssemblyVersion>2.2.1.0</AssemblyVersion>
+	<FileVersion>2.2.1.0</FileVersion>
+	<InformationalVersion>2.2.0-beta</InformationalVersion>
 	<Copyright>Copyright © 2025 Digital Data GmbH. All rights reserved.</Copyright>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <NoWarn>$(NoWarn);1591</NoWarn>

src/ReC.Application/Common/Behaviors/Action/BodyQueryBehavior.cs

@@ -0,0 +1,54 @@
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using ReC.Application.Common.Dto;
+using ReC.Application.Common.Exceptions;
+using ReC.Application.Common.Interfaces;
+
+namespace ReC.Application.Common.Behaviors.Action;
+
+public class BodyQueryBehavior<TRequest, TResponse>(IRecDbContext dbContext) : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : notnull
+    where TResponse : IEnumerable<RecActionViewDto>
+{
+    public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancel)
+    {
+        var actions = await next(cancel);
+
+        foreach (var action in actions)
+            await SetBody(action, cancel);
+
+        return actions;
+    }
+
+    private async Task SetBody(RecActionViewDto action, CancellationToken cancel)
+    {
+        if (action.BodyQuery is not string bodyQuery)
+            return;
+
+        await using var command = dbContext.Database.GetDbConnection().CreateCommand();
+        command.CommandText = bodyQuery;
+
+        await dbContext.Database.OpenConnectionAsync(cancel);
+        try
+        {
+            object? scalar;
+            try
+            {
+                scalar = await command.ExecuteScalarAsync(cancel);
+            }
+            catch (Exception ex)
+            {
+                throw new DataIntegrityException(
+                    $"Body query execution failed. The stored SQL may be malformed. ActionId: {action.Id}, ProfileId: {action.ProfileId}, Error: {ex.Message}");
+            }
+
+            action.Body = scalar as string
+                ?? throw new DataIntegrityException(
+                    $"Body query returned no result or a null value. ActionId: {action.Id}, ProfileId: {action.ProfileId}");
+        }
+        finally
+        {
+            await dbContext.Database.CloseConnectionAsync();
+        }
+    }
+}

src/ReC.Application/Common/Behaviors/Action/HeaderQueryBehavior.cs

@@ -0,0 +1,61 @@
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using ReC.Application.Common.Dto;
+using ReC.Application.Common.Exceptions;
+using ReC.Application.Common.Interfaces;
+using System.Text.Json;
+
+namespace ReC.Application.Common.Behaviors.Action;
+
+public class HeaderQueryBehavior<TRequest, TResponse>(IRecDbContext dbContext) : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : notnull
+    where TResponse : IEnumerable<RecActionViewDto>
+{
+    public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancel)
+    {
+        var actions = await next(cancel);
+
+        foreach (var action in actions)
+            await SetHeader(action, cancel);
+
+        return actions;
+    }
+
+    private async Task SetHeader(RecActionViewDto action, CancellationToken cancel)
+    {
+        if (action.HeaderQuery is not string headerQuery)
+            return;
+
+        await using var command = dbContext.Database.GetDbConnection().CreateCommand();
+        command.CommandText = headerQuery;
+
+        await dbContext.Database.OpenConnectionAsync(cancel);
+        try
+        {
+            object? scalar;
+            try
+            {
+                scalar = await command.ExecuteScalarAsync(cancel);
+            }
+            catch (Exception ex)
+            {
+                throw new DataIntegrityException(
+                    $"Header query execution failed. The stored SQL may be malformed. ActionId: {action.Id}, ProfileId: {action.ProfileId}, Error: {ex.Message}");
+            }
+
+            if (scalar is not string rawHeader)
+                throw new DataIntegrityException(
+                    $"Header query returned no result or a null value. ActionId: {action.Id}, ProfileId: {action.ProfileId}");
+
+            var headerDict = JsonSerializer.Deserialize<Dictionary<string, JsonElement>>(rawHeader)
+                ?? throw new DataIntegrityException(
+                    $"Header query returned invalid JSON. ActionId: {action.Id}, ProfileId: {action.ProfileId}");
+
+            action.Headers = headerDict.ToDictionary(header => header.Key, kvp => kvp.Value.ToString());
+        }
+        finally
+        {
+            await dbContext.Database.CloseConnectionAsync();
+        }
+    }
+}

src/ReC.Application/Common/Behaviors/BodyQueryBehavior.cs

@@ -1,23 +0,0 @@
-using MediatR;
-using ReC.Application.Common.Dto;
-using ReC.Application.Common.Interfaces;
-using Microsoft.EntityFrameworkCore;
-
-namespace ReC.Application.Common.Behaviors;
-
-public class BodyQueryBehavior<TRequest, TResponse>(IRecDbContext dbContext) : IPipelineBehavior<TRequest, TResponse>
-    where TRequest : RecActionViewDto
-    where TResponse : notnull
-{
-    public async Task<TResponse> Handle(TRequest action, RequestHandlerDelegate<TResponse> next, CancellationToken cancel)
-    {
-        if (action.BodyQuery is null)
-            return await next(cancel);
-
-        var result = await dbContext.BodyQueryResults.FromSqlRaw(action.BodyQuery).SingleOrDefaultAsync(cancel);
-
-        action.Body = result?.RawBody;
-
-        return await next(cancel);
-    }
-}

src/ReC.Application/Common/Behaviors/HeaderQueryBehavior.cs

@@ -1,43 +0,0 @@
-using MediatR;
-using Microsoft.EntityFrameworkCore;
-using Microsoft.Extensions.Logging;
-using ReC.Application.Common.Dto;
-using ReC.Application.Common.Interfaces;
-using System.Text.Json;
-
-namespace ReC.Application.Common.Behaviors;
-
-public class HeaderQueryBehavior<TRequest, TResponse>(IRecDbContext dbContext, ILogger<HeaderQueryBehavior<TRequest, TResponse>>? logger = null) : IPipelineBehavior<TRequest, TResponse>
-    where TRequest : RecActionViewDto
-    where TResponse : notnull
-{
-    public async Task<TResponse> Handle(TRequest action, RequestHandlerDelegate<TResponse> next, CancellationToken cancel)
-    {
-        if (action.HeaderQuery is null)
-            return await next(cancel);
-
-        var result = await dbContext.HeaderQueryResults.FromSqlRaw(action.HeaderQuery).SingleOrDefaultAsync(cancel);
-
-        if (result?.RawHeader is null)
-        {
-            logger?.LogWarning("Header query did not return a result or returned a null REQUEST_HEADER. Profile ID: {ProfileId}, Action ID: {Id}", action.ProfileId, action.Id);
-
-            return await next(cancel);
-        }
-
-        var headerDict = JsonSerializer.Deserialize<Dictionary<string, JsonElement>>(result.RawHeader);
-
-        if(headerDict is null)
-        {
-            logger?.LogWarning(
-                "Header JSON deserialization returned null. RawHeader: {RawHeader}, ProfileId: {ProfileId}, Id: {Id}",
-                result.RawHeader, action.ProfileId, action.Id);
-
-            return await next(cancel);
-        }
-
-        action.Headers = headerDict.ToDictionary(header => header.Key, kvp => kvp.Value.ToString());
-
-        return await next(cancel);
-    }
-}

src/ReC.Application/Common/Behaviors/InvokeAction/PostprocessingBehavior.cs

@@ -1,11 +1,12 @@
 using MediatR;
+using ReC.Application.Common.Exceptions;
 using ReC.Application.Common.Interfaces;
 using ReC.Application.RecActions.Commands;
 using ReC.Application.Results.Commands;
 using ReC.Domain.Constants;
 using System.Text.Json;
 
-namespace ReC.Application.Common.Behaviors.Action;
+namespace ReC.Application.Common.Behaviors.InvokeAction;
 
 public class PostprocessingBehavior(IRecDbContext context, ISender sender) : IPipelineBehavior<InvokeRecActionViewCommand, Unit>
 {
@@ -22,8 +23,11 @@ public class PostprocessingBehavior(IRecDbContext context, ISender sender) : IPi
 
                 await sender.Send(new InsertResultCommand()
                 {
+                    Status = RecStatus.OK,
                     ActionId = request.Action.Id,
-                    Info = info
+                    InfoDetail = info,
+                    Type = ResultType.Post,
+                    References = request.References
                 }, cancel);
             }
         }
@@ -33,12 +37,15 @@ public class PostprocessingBehavior(IRecDbContext context, ISender sender) : IPi
 
             await sender.Send(new InsertResultCommand()
             {
+                Status = RecStatus.Error,
                 ActionId = request.Action.Id,
-                Error = error
+                Error = error,
+                Type = ResultType.Post,
+                References = request.References
             }, cancel);
 
             if (request.Action.ErrorAction == ErrorAction.Stop)
-                throw;
+                throw new RecActionException(request.Action.Id, request.Action.ProfileId, ex);
         }
 
         return Unit.Value;

src/ReC.Application/Common/Behaviors/InvokeAction/PreprocessingBehavior.cs

@@ -1,11 +1,12 @@
 using MediatR;
+using ReC.Application.Common.Exceptions;
 using ReC.Application.Common.Interfaces;
 using ReC.Application.RecActions.Commands;
 using ReC.Application.Results.Commands;
 using ReC.Domain.Constants;
 using System.Text.Json;
 
-namespace ReC.Application.Common.Behaviors.Action;
+namespace ReC.Application.Common.Behaviors.InvokeAction;
 
 public class PreprocessingBehavior(IRecDbContext context, ISender sender) : IPipelineBehavior<InvokeRecActionViewCommand, Unit>
 {
@@ -19,8 +20,11 @@ public class PreprocessingBehavior(IRecDbContext context, ISender sender) : IPip
 
                 await sender.Send(new InsertResultCommand()
                 {
+                    Status = RecStatus.OK,
                     ActionId = request.Action.Id,
-                    Info = JsonSerializer.Serialize(result)
+                    InfoDetail = JsonSerializer.Serialize(result),
+                    Type = ResultType.Pre,
+                    References = request.References
                 }, cancel);
             }
         }
@@ -28,12 +32,15 @@ public class PreprocessingBehavior(IRecDbContext context, ISender sender) : IPip
         {
             await sender.Send(new InsertResultCommand()
             {
+                Status = RecStatus.Error,
                 ActionId = request.Action.Id,
-                Error = ex.ToString()
+                Error = ex.ToString(),
+                Type = ResultType.Pre,
+                References = request.References
             }, cancel);
 
             if (request.Action.ErrorAction == ErrorAction.Stop)
-                throw;
+                throw new RecActionException(request.Action.Id, request.Action.ProfileId, ex);
         }
 
         return await next(cancel);

src/ReC.Application/Common/Dto/ConnectionDto.cs

@@ -1,32 +0,0 @@
-namespace ReC.Application.Common.Dto;
-
-public record ConnectionDto
-{
-    public short? Id { get; set; }
-
-    public string? Bezeichnung { get; set; }
-
-    public string? SqlProvider { get; set; }
-
-    public string? Server { get; set; }
-
-    public string? Datenbank { get; set; }
-
-    public string? Username { get; set; }
-
-    public string? Password { get; set; }
-
-    public string? Bemerkung { get; set; }
-
-    public bool? Aktiv { get; set; }
-
-    public string? ErstelltWer { get; set; }
-
-    public DateTime? ErstelltWann { get; set; }
-
-    public string? GeandertWer { get; set; }
-
-    public DateTime? GeaendertWann { get; set; }
-
-    public bool? SysConnection { get; set; }
-}

src/ReC.Application/Common/Dto/DtoMappingProfile.cs

@@ -1,4 +1,4 @@
-using ReC.Domain.Views;
+using ReC.Domain.Views;
 
 namespace ReC.Application.Common.Dto;
 
@@ -6,7 +6,12 @@ public class DtoMappingProfile : AutoMapper.Profile
 {
     public DtoMappingProfile()
     {
-        CreateMap<RecActionView, RecActionViewDto>();
+        CreateMap<RecActionView, RecActionViewDto>()
+            .ForMember(dest => dest.PreprocessingQuery, opt => opt.MapFrom((src, _) =>
+                src.PreprocessingQuery?.ReplacePlaceholders(src)))
+            .ForMember(dest => dest.PostprocessingQuery, opt => opt.MapFrom((src, _) =>
+                src.PostprocessingQuery?.ReplacePlaceholders(src)));
+
         CreateMap<ResultView, ResultViewDto>();
         CreateMap<ProfileView, ProfileViewDto>();
     }

src/ReC.Application/Common/Dto/EndpointAuthDto.cs

@@ -1,39 +0,0 @@
-using ReC.Domain.Constants;
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace ReC.Application.Common.Dto;
-
-public record EndpointAuthDto
-{
-    public long? Id { get; set; }
-
-    public bool? Active { get; set; }
-
-    public string? Description { get; set; }
-
-    public EndpointAuthType? Type { get; set; }
-
-    public string? ApiKey { get; set; }
-
-    public string? ApiValue { get; set; }
-
-    public ApiKeyLocation? ApiKeyAddTo { get; set; }
-
-    public string? Token { get; set; }
-
-    public string? Username { get; set; }
-
-    public string? Password { get; set; }
-
-    public string? Domain { get; set; }
-
-    public string? Workstation { get; set; }
-
-    public string? AddedWho { get; set; }
-
-    public DateTime? AddedWhen { get; set; }
-
-    public string? ChangedWho { get; set; }
-
-    public DateTime? ChangedWhen { get; set; }
-}

src/ReC.Application/Common/Dto/EndpointDto.cs

@@ -1,22 +0,0 @@
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace ReC.Application.Common.Dto;
-
-public record EndpointDto
-{
-    public long Id { get; set; }
-
-    public bool? Active { get; set; }
-
-    public string? Description { get; set; }
-
-    public string? Uri { get; set; }
-
-    public string? AddedWho { get; set; }
-
-    public DateTime? AddedWhen { get; set; }
-
-    public string? ChangedWho { get; set; }
-
-    public DateTime? ChangedWhen { get; set; }
-}

src/ReC.Application/Common/Dto/EndpointParamDto.cs

@@ -1,33 +0,0 @@
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace ReC.Application.Common.Dto;
-
-/// <summary>
-/// Represents the TBREC_CFG_ENDPOINT_PARAMS table.
-/// All properties are nullable to provide flexibility on the database side,
-/// preventing breaking changes if columns are altered to be nullable in production.
-/// </summary>
-public record EndpointParamDto
-{
-    public long? Id { get; set; }
-
-    public bool? Active { get; set; }
-
-    public string? Description { get; set; }
-
-    public short? GroupId { get; set; }
-
-    public byte? Sequence { get; set; }
-
-    public string? Key { get; set; }
-
-    public string? Value { get; set; }
-
-    public string? AddedWho { get; set; }
-
-    public DateTime? AddedWhen { get; set; }
-
-    public string? ChangedWho { get; set; }
-
-    public DateTime? ChangedWhen { get; set; }
-}

src/ReC.Application/Common/Dto/OutResDto.cs

@@ -1,24 +0,0 @@
-namespace ReC.Application.Common.Dto;
-
-public record OutResDto
-{
-    public long Id { get; set; }
-
-    public long ActionId { get; set; }
-
-    public string? Header { get; set; }
-
-    public string? Body { get; set; }
-
-    public string? Info { get; set; }
-
-    public string? Error { get; set; }
-
-    public string AddedWho { get; set; } = null!;
-
-    public DateTime AddedWhen { get; set; }
-
-    public string? ChangedWho { get; set; }
-
-    public DateTime? ChangedWhen { get; set; }
-}

src/ReC.Application/Common/Dto/PlaceholderExtensions.cs

@@ -0,0 +1,60 @@
+using System.ComponentModel.DataAnnotations.Schema;
+using System.Reflection;
+using System.Text.RegularExpressions;
+
+namespace ReC.Application.Common.Dto;
+
+public static partial class PlaceholderExtensions
+{
+    [GeneratedRegex(@"\{#[^#]+#[^}]+\}")]
+    private static partial Regex PlaceholderRegex();
+
+    /// <summary>
+    /// Replaces placeholders in the format <c>{#ANY_STRING#COLUMN_NAME}</c> with the corresponding
+    /// property value resolved via <see cref="GetValueByColumnName{T}"/> from the provided objects.
+    /// Values are converted to SQL-compatible string representations.
+    /// If a placeholder cannot be resolved, it is replaced with <c>NULL</c>.
+    /// </summary>
+    public static string ReplacePlaceholders(this string str, params object?[] objects)
+    {
+        return PlaceholderRegex().Replace(str, match =>
+        {
+            var placeholder = match.Value;
+            var inner = placeholder[2..^1]; // remove {# and }
+            var lastHash = inner.LastIndexOf('#');
+            var columnName = inner[(lastHash + 1)..];
+
+            foreach (var obj in objects)
+            {
+                if (obj is null)
+                    continue;
+
+                var value = obj.GetValueByColumnName(columnName);
+                if (value is not null)
+                    return ToSqlLiteral(value);
+            }
+
+            return "NULL";
+        });
+    }
+
+    private static string ToSqlLiteral(object value) => value switch
+    {
+        bool b => b ? "TRUE" : "FALSE",
+        DateTime dt => dt.ToString("yyyy-MM-dd HH:mm:ss"),
+        DateTimeOffset dto => dto.ToString("yyyy-MM-dd HH:mm:ss zzz"),
+        _ => value.ToString() ?? string.Empty
+    };
+
+    /// <summary>
+    /// Gets the value of a property by its column name defined in <see cref="ColumnAttribute"/>.
+    /// Returns <c>null</c> if no property with the given column name exists.
+    /// </summary>
+    public static object? GetValueByColumnName<T>(this T obj, string columnName) where T : class
+    {
+        var property = obj.GetType().GetProperties(BindingFlags.Public | BindingFlags.Instance)
+            .FirstOrDefault(p => p.GetCustomAttribute<ColumnAttribute>()?.Name == columnName);
+
+        return property?.GetValue(obj);
+    }
+}

src/ReC.Application/Common/Dto/ProfileDto.cs

@@ -1,30 +0,0 @@
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace ReC.Application.Common.Dto;
-
-public record ProfileDto
-{
-    public long Id { get; set; }
-
-    public bool? Active { get; set; }
-
-    public string? Type { get; set; }
-
-    public string? Mandantor { get; set; }
-
-    public string? Name { get; set; }
-
-    public string? Description { get; set; }
-
-    public string? LogLevel { get; set; }
-
-    public string? Language { get; set; }
-
-    public string? AddedWho { get; set; }
-
-    public DateTime? AddedWhen { get; set; }
-
-    public string? ChangedWho { get; set; }
-
-    public DateTime? ChangedWhen { get; set; }
-}

src/ReC.Application/Common/Dto/RecActionDto.cs

@@ -1,53 +0,0 @@
-using ReC.Domain.Constants;
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace ReC.Application.Common.Dto;
-
-public record RecActionDto
-{
-    public long? Id { get; set; }
-
-    public long? ProfileId { get; set; }
-
-    public ProfileDto? Profile { get; set; }
-
-    public bool? Active { get; set; }
-
-    public byte? Sequence { get; set; }
-
-    public long? EndpointId { get; set; }
-
-    public EndpointDto? Endpoint { get; set; }
-
-    public long? EndpointAuthId { get; set; }
-
-    public EndpointAuthDto? EndpointAuth { get; set; }
-
-    public short? EndpointParamsId { get; set; }
-
-    public short? SqlConnectionId { get; set; }
-
-    public ConnectionDto? SqlConnection { get; set; }
-
-    public string? Type { get; set; }
-
-    public string? PreprocessingQuery { get; set; }
-
-    public string? HeaderQuery { get; set; }
-
-    public string? BodyQuery { get; set; }
-
-    public string? PostprocessingQuery { get; set; }
-
-    public ErrorAction? ErrorAction { get; set; }
-
-    public string? AddedWho { get; set; }
-
-    public DateTime? AddedWhen { get; set; }
-
-    public string? ChangedWho { get; set; }
-
-    public DateTime? ChangedWhen { get; set; }
-
-    public OutResDto? OutRes { get; set; }
-}

src/ReC.Application/Common/Dto/RecActionViewDto.cs

@@ -8,6 +8,8 @@ public record RecActionViewDto
 
     public long? ProfileId { get; init; }
 
+    public ProfileViewDto? Profile { get; init; }
+
     public string? ProfileName { get; init; }
 
     public ProfileType? ProfileType { get; init; }

src/ReC.Application/Common/Dto/ResultViewDto.cs

@@ -1,11 +1,11 @@
-namespace ReC.Application.Common.Dto;
+using ReC.Domain.Constants;
+
+namespace ReC.Application.Common.Dto;
 
 public record ResultViewDto
 {
     public long Id { get; init; }
 
-    public OutResDto? Root { get; init; }
-
     public long? ActionId { get; init; }
 
     public RecActionViewDto? Action { get; init; }
@@ -16,7 +16,7 @@ public record ResultViewDto
 
     public string? ProfileName { get; init; }
 
-    public short? StatusCode { get; init; }
+    public RecStatus Status { get; set; }
 
     public string? StatusName { get; init; }
 
@@ -24,6 +24,14 @@ public record ResultViewDto
 
     public string? Body { get; init; }
 
+    public string? Info { get; set; }
+
+    public string? InfoDetail { get; set; }
+
+    public string? Error { get; set; }
+
+    public string? BatchId { get; set; }
+
     public string? AddedWho { get; init; }
 
     public DateTime? AddedWhen { get; init; }

src/ReC.Application/Common/Exceptions/RecActionException.cs

@@ -0,0 +1,9 @@
+namespace ReC.Application.Common.Exceptions;
+
+public class RecActionException(long actionId, long? profileId, Exception innerException) 
+    : Exception($"Rec action failed. ActionId: {actionId}, ProfileId: {profileId}", innerException)
+{
+    public long ActionId { get; } = actionId;
+
+    public long? ProfileId { get; } = profileId;
+}

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

@@ -2,7 +2,5 @@
 
 public class RecActionOptions
 {
-    public string AddedWho { get; set; } = null!;
-
     public bool UseHttp1ForNtlm { get; set; } = false;
 }

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

@@ -11,9 +11,9 @@ namespace ReC.Application.Common.Procedures.DeleteProcedure;
 public record DeleteObjectProcedure : IRequest<int>
 {
     /// <summary>
-    /// Target entity: ACTION, ENDPOINT, ENDPOINT_AUTH, ENDPOINT_PARAMS, PROFILE, RESULT
+    /// Target entity for the delete operation.
     /// </summary>
-    public string Entity { get; set; } = null!;
+    public required EntityType Entity { get; set; }
 
     /// <summary>
     /// Start GUID/ID (inclusive)
@@ -35,25 +35,16 @@ public class DeleteObjectProcedureHandler(IRepository repo, IOptionsMonitor<SqlE
 {
     public async Task<int> Handle(DeleteObjectProcedure request, CancellationToken cancel)
     {
-        var parameters = new[]
-        {
-            new SqlParameter("@pENTITY", request.Entity ?? (object)DBNull.Value),
-            new SqlParameter("@pSTART", request.Start.ToString()),
-            new SqlParameter("@pEND", request.End.ToString()),
-            new SqlParameter("@pFORCE", (object?)request.Force ?? DBNull.Value)
-        };
+        var sp = new StoredProcedureBuilder("[dbo].[PRREC_DELETE_OBJECT]", "RC")
+            .Add("pENTITY", request.Entity)
+            .Add("pSTART", request.Start.ToString())
+            .Add("pEND", request.End.ToString())
+            .Add("pFORCE", request.Force);
 
         try
         {
-            var result = await repo.ExecuteQueryRawAsync(
-                "DECLARE @RC SMALLINT = 0; " +
-                "EXEC @RC = [dbo].[PRREC_DELETE_OBJECT] " +
-                "@pENTITY, @pSTART, @pEND, @pFORCE; " +
-                "SELECT @RC;",
-                parameters,
-                cancel);
+            var result = await repo.ExecuteQueryRawAsync(sp.BuildSql(), sp.BuildParameters(), 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}");

src/ReC.Application/Common/Procedures/EntityType.cs

@@ -0,0 +1,51 @@
+namespace ReC.Application.Common.Procedures;
+
+/// <summary>
+/// Represents the target entity type for stored procedure operations (Insert, Update, Delete).
+/// </summary>
+public enum EntityType
+{
+    /// <summary>
+    /// A scheduled or configured action within a profile that invokes an endpoint (maps to TBREC_CFG_ACTION).
+    /// </summary>
+    Action,
+
+    /// <summary>
+    /// A REST endpoint URI configuration (maps to TBREC_CFG_ENDPOINT).
+    /// </summary>
+    Endpoint,
+
+    /// <summary>
+    /// Authentication credentials for an endpoint such as API key, Bearer token, or NTLM (maps to TBREC_CFG_ENDPOINT_AUTH).
+    /// </summary>
+    EndpointAuth,
+
+    /// <summary>
+    /// Key-value parameters attached to an endpoint (maps to TBREC_CFG_ENDPOINT_PARAMS).
+    /// </summary>
+    EndpointParams,
+
+    /// <summary>
+    /// A profile that groups one or more actions and defines execution settings (maps to TBREC_CFG_PROFILE).
+    /// </summary>
+    Profile,
+
+    /// <summary>
+    /// The outcome of an action invocation including HTTP status, headers, body, and error details (maps to TBREC_OUT_RESULT).
+    /// </summary>
+    Result
+}
+
+public static class EntityTypeExtensions
+{
+    public static string ToDbString(this EntityType entityType) => entityType switch
+    {
+        EntityType.Action => "ACTION",
+        EntityType.Endpoint => "ENDPOINT",
+        EntityType.EndpointAuth => "ENDPOINT_AUTH",
+        EntityType.EndpointParams => "ENDPOINT_PARAMS",
+        EntityType.Profile => "PROFILE",
+        EntityType.Result => "RESULT",
+        _ => throw new ArgumentOutOfRangeException(nameof(entityType), $"Not expected entity type value: {entityType}")
+    };
+}

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

@@ -11,112 +11,95 @@ using ReC.Application.Endpoints.Commands;
 using ReC.Application.Profile.Commands;
 using ReC.Application.RecActions.Commands;
 using ReC.Application.Results.Commands;
+using System.Data;
 
 namespace ReC.Application.Common.Procedures.InsertProcedure;
 
 public record InsertObjectProcedure : IRequest<long>
 {
     /// <summary>
-    /// Target entity: ACTION, ENDPOINT, ENDPOINT_AUTH, ENDPOINT_PARAMS, PROFILE, RESULT
+    /// Target entity for the insert operation.
     /// </summary>
-    public string Entity { get; set; } = null!;
+    public required EntityType Entity { get; set; }
 
     //TODO: update to set in authentication middleware or similar, and remove from procedure properties
     internal string? AddedWho { get; private set; } = "ReC.API";
 
-    public InsertActionCommand Action { get; set; } = new();
-    public InsertEndpointCommand Endpoint { get; set; } = new();
-    public InsertEndpointAuthCommand EndpointAuth { get; set; } = new();
-    public InsertProfileCommand Profile { get; set; } = new();
-    public InsertResultCommand Result { get; set; } = new();
-    public InsertEndpointParamsCommand EndpointParams { get; set; } = new();
+    public InsertActionCommand? Action { get; set; }
+    public InsertEndpointCommand? Endpoint { get; set; }
+    public InsertEndpointAuthCommand? EndpointAuth { get; set; }
+    public InsertProfileCommand? Profile { get; set; }
+    public InsertResultCommand? Result { get; set; }
+    public InsertEndpointParamsCommand? EndpointParams { get; set; }
 }
 
 public class InsertObjectProcedureHandler(IRepository repo, IOptionsMonitor<SqlExceptionOptions> sqlExOpt) : IRequestHandler<InsertObjectProcedure, long>
 {
     public async Task<long> Handle(InsertObjectProcedure request, CancellationToken cancel)
     {
-        var parameters = new[]
-        {
-            new SqlParameter("@pENTITY", request.Entity ?? (object)DBNull.Value),
-
-            new SqlParameter("@pADDED_WHO", (object?)request.AddedWho ?? DBNull.Value),
-            new SqlParameter("@pADDED_WHEN", (object?)DateTime.UtcNow ?? DBNull.Value),
-
-            new SqlParameter("@pACTION_PROFILE_ID", (object?)request.Action.ProfileId ?? DBNull.Value),
-            new SqlParameter("@pACTION_ACTIVE", (object?)request.Action.Active ?? DBNull.Value),
-            new SqlParameter("@pACTION_SEQUENCE", (object?)request.Action.Sequence ?? DBNull.Value),
-            new SqlParameter("@pACTION_ENDPOINT_ID", (object?)request.Action.EndpointId ?? DBNull.Value),
-            new SqlParameter("@pACTION_ENDPOINT_AUTH_ID", (object?)request.Action.EndpointAuthId ?? DBNull.Value),
-            new SqlParameter("@pACTION_ENDPOINT_PARAMS_ID", (object?)request.Action.EndpointParamsId ?? DBNull.Value),
-            new SqlParameter("@pACTION_SQL_CONNECTION_ID", (object?)request.Action.SqlConnectionId ?? DBNull.Value),
-            new SqlParameter("@pACTION_TYPE_ID", (object?)(byte?)request.Action.TypeId ?? DBNull.Value),
-            new SqlParameter("@pACTION_PRE_SQL", (object?)request.Action.PreSql ?? DBNull.Value),
-            new SqlParameter("@pACTION_HEADER_SQL", (object?)request.Action.HeaderSql ?? DBNull.Value),
-            new SqlParameter("@pACTION_BODY_SQL", (object?)request.Action.BodySql ?? DBNull.Value),
-            new SqlParameter("@pACTION_POST_SQL", (object?)request.Action.PostSql ?? DBNull.Value),
-            new SqlParameter("@pACTION_ERROR_ACTION_ID", (object?)request.Action.ErrorActionId ?? DBNull.Value),
-
-            new SqlParameter("@pENDPOINT_ACTIVE", (object?)request.Endpoint.Active ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_DESCRIPTION", (object?)request.Endpoint.Description ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_URI", (object?)request.Endpoint.Uri ?? DBNull.Value),
-
-            new SqlParameter("@pENDPOINT_AUTH_ACTIVE", (object?)request.EndpointAuth.Active ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_DESCRIPTION", (object?)request.EndpointAuth.Description ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_TYPE_ID", (object?)request.EndpointAuth.TypeId ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_API_KEY", (object?)request.EndpointAuth.ApiKey ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_API_VALUE", (object?)request.EndpointAuth.ApiValue ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_API_KEY_ADD_TO_ID", (object?)request.EndpointAuth.ApiKeyAddToId ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_TOKEN", (object?)request.EndpointAuth.Token ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_USERNAME", (object?)request.EndpointAuth.Username ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_PASSWORD", (object?)request.EndpointAuth.Password ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_DOMAIN", (object?)request.EndpointAuth.Domain ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_WORKSTATION", (object?)request.EndpointAuth.Workstation ?? DBNull.Value),
-
-            new SqlParameter("@pPROFILE_ACTIVE", (object?)request.Profile.Active ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_TYPE_ID", (object?)request.Profile.TypeId ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_MANDANTOR", (object?)request.Profile.Mandantor ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_NAME", (object?)request.Profile.Name ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_DESCRIPTION", (object?)request.Profile.Description ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_LOG_LEVEL_ID", (object?)request.Profile.LogLevelId ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_LANGUAGE_ID", (object?)request.Profile.LanguageId ?? DBNull.Value),
-
-            new SqlParameter("@pRESULT_ACTION_ID", (object?)request.Result.ActionId ?? DBNull.Value),
-            new SqlParameter("@pRESULT_STATUS_ID", (object?)request.Result.StatusId ?? DBNull.Value),
-            new SqlParameter("@pRESULT_HEADER", (object?)request.Result.Header ?? DBNull.Value),
-            new SqlParameter("@pRESULT_BODY", (object?)request.Result.Body ?? DBNull.Value),
-            new SqlParameter("@pRESULT_INFO", (object?)request.Result.Info ?? DBNull.Value),
-            new SqlParameter("@pRESULT_ERROR", (object?)request.Result.Error ?? DBNull.Value),
-
-            new SqlParameter("@pENDPOINT_PARAMS_ACTIVE", (object?)request.EndpointParams.Active ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_DESCRIPTION", (object?)request.EndpointParams.Description ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_GROUP_ID", (object?)request.EndpointParams.GroupId ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_SEQUENCE", (object?)request.EndpointParams.Sequence ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_KEY", (object?)request.EndpointParams.Key ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_VALUE", (object?)request.EndpointParams.Value ?? DBNull.Value),
-
-            new SqlParameter
-            {
-                ParameterName = "@oGUID",
-                SqlDbType = System.Data.SqlDbType.BigInt,
-                Direction = System.Data.ParameterDirection.Output
-            }
-        };
+        var sp = new StoredProcedureBuilder("[dbo].[PRREC_INSERT_OBJECT]")
+            .Add("pENTITY", request.Entity)
+            .Add("pADDED_WHO", request.AddedWho)
+            .Add("pADDED_WHEN", DateTime.UtcNow)
+            .Add("pACTION_PROFILE_ID", request.Action?.ProfileId)
+            .Add("pACTION_ACTIVE", request.Action?.Active)
+            .Add("pACTION_SEQUENCE", request.Action?.Sequence, SqlDbType.TinyInt)
+            .Add("pACTION_ENDPOINT_ID", request.Action?.EndpointId)
+            .Add("pACTION_ENDPOINT_AUTH_ID", request.Action?.EndpointAuthId)
+            .Add("pACTION_ENDPOINT_PARAMS_ID", request.Action?.EndpointParamsId, SqlDbType.SmallInt)
+            .Add("pACTION_SQL_CONNECTION_ID", request.Action?.SqlConnectionId, SqlDbType.SmallInt)
+            .Add("pACTION_TYPE_ID", request.Action?.TypeId is not null ? (byte)request.Action.TypeId : null, SqlDbType.TinyInt)
+            .Add("pACTION_PRE_SQL", request.Action?.PreSql)
+            .Add("pACTION_HEADER_SQL", request.Action?.HeaderSql)
+            .Add("pACTION_BODY_SQL", request.Action?.BodySql)
+            .Add("pACTION_POST_SQL", request.Action?.PostSql)
+            .Add("pACTION_ERROR_ACTION_ID", request.Action?.ErrorActionId, SqlDbType.TinyInt)
+            .Add("pENDPOINT_ACTIVE", request.Endpoint?.Active)
+            .Add("pENDPOINT_DESCRIPTION", request.Endpoint?.Description)
+            .Add("pENDPOINT_URI", request.Endpoint?.Uri)
+            .Add("pENDPOINT_AUTH_ACTIVE", request.EndpointAuth?.Active)
+            .Add("pENDPOINT_AUTH_DESCRIPTION", request.EndpointAuth?.Description)
+            .Add("pENDPOINT_AUTH_TYPE_ID", request.EndpointAuth?.TypeId, SqlDbType.TinyInt)
+            .Add("pENDPOINT_AUTH_API_KEY", request.EndpointAuth?.ApiKey)
+            .Add("pENDPOINT_AUTH_API_VALUE", request.EndpointAuth?.ApiValue)
+            .Add("pENDPOINT_AUTH_API_KEY_ADD_TO_ID", request.EndpointAuth?.ApiKeyAddToId)
+            .Add("pENDPOINT_AUTH_TOKEN", request.EndpointAuth?.Token)
+            .Add("pENDPOINT_AUTH_USERNAME", request.EndpointAuth?.Username)
+            .Add("pENDPOINT_AUTH_PASSWORD", request.EndpointAuth?.Password)
+            .Add("pENDPOINT_AUTH_DOMAIN", request.EndpointAuth?.Domain)
+            .Add("pENDPOINT_AUTH_WORKSTATION", request.EndpointAuth?.Workstation)
+            .Add("pPROFILE_ACTIVE", request.Profile?.Active)
+            .Add("pPROFILE_TYPE_ID", request.Profile?.TypeId, SqlDbType.TinyInt)
+            .Add("pPROFILE_MANDANTOR", request.Profile?.Mandantor)
+            .Add("pPROFILE_NAME", request.Profile?.Name)
+            .Add("pPROFILE_DESCRIPTION", request.Profile?.Description)
+            .Add("pPROFILE_LOG_LEVEL_ID", request.Profile?.LogLevelId, SqlDbType.TinyInt)
+            .Add("pPROFILE_LANGUAGE_ID", request.Profile?.LanguageId, SqlDbType.SmallInt)
+            .Add("pRESULT_ACTION_ID", request.Result?.ActionId)
+            .Add("pRESULT_STATUS_ID", request.Result?.Status, SqlDbType.TinyInt)
+            .Add("pRESULT_TYPE_ID", request.Result?.Type is not null ? (byte)request.Result.Type : null, SqlDbType.TinyInt)
+            .Add("pRESULT_HEADER", request.Result?.Header)
+            .Add("pRESULT_BODY", request.Result?.Body)
+            .Add("pRESULT_INFO_ID", request.Result?.Info, SqlDbType.SmallInt)
+            .Add("pRESULT_INFO_DETAIL", request.Result?.InfoDetail)
+            .Add("pRESULT_ERROR", request.Result?.Error)
+            .Add("pRESULT_BATCH_ID", request.Result?.References?.BatchId)
+            .Add("pRESULT_REFERENCE1", request.Result?.References?.Reference1)
+            .Add("pRESULT_REFERENCE2", request.Result?.References?.Reference2)
+            .Add("pRESULT_REFERENCE3", request.Result?.References?.Reference3)
+            .Add("pRESULT_REFERENCE4", request.Result?.References?.Reference4)
+            .Add("pRESULT_REFERENCE5", request.Result?.References?.Reference5)
+            .Add("pENDPOINT_PARAMS_ACTIVE", request.EndpointParams?.Active)
+            .Add("pENDPOINT_PARAMS_DESCRIPTION", request.EndpointParams?.Description)
+            .Add("pENDPOINT_PARAMS_GROUP_ID", request.EndpointParams?.GroupId, SqlDbType.SmallInt)
+            .Add("pENDPOINT_PARAMS_SEQUENCE", request.EndpointParams?.Sequence, SqlDbType.TinyInt)
+            .Add("pENDPOINT_PARAMS_KEY", request.EndpointParams?.Key)
+            .Add("pENDPOINT_PARAMS_VALUE", request.EndpointParams?.Value)
+            .AddOutput("oGUID", SqlDbType.BigInt);
 
         try
         {
-            await repo.ExecuteQueryRawAsync(
-                "EXEC [dbo].[PRREC_INSERT_OBJECT] " +
-                "@pENTITY, @pADDED_WHO, @pADDED_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, " +
-                "@pPROFILE_ACTIVE, @pPROFILE_TYPE_ID, @pPROFILE_MANDANTOR, @pPROFILE_NAME, @pPROFILE_DESCRIPTION, @pPROFILE_LOG_LEVEL_ID, @pPROFILE_LANGUAGE_ID, " +
-                "@pRESULT_ACTION_ID, @pRESULT_STATUS_ID, @pRESULT_HEADER, @pRESULT_BODY, " +
-                "@pENDPOINT_PARAMS_ACTIVE, @pENDPOINT_PARAMS_DESCRIPTION, @pENDPOINT_PARAMS_GROUP_ID, @pENDPOINT_PARAMS_SEQUENCE, @pENDPOINT_PARAMS_KEY, @pENDPOINT_PARAMS_VALUE, " +
-                "@oGUID OUTPUT",
-                parameters,
-                cancel);
+            await repo.ExecuteQueryRawAsync(sp.BuildSql(), sp.BuildParameters(), cancel);
         }
         catch (SqlException ex)
         {
@@ -126,12 +109,12 @@ public class InsertObjectProcedureHandler(IRepository repo, IOptionsMonitor<SqlE
                 throw;
         }
 
-        var guidParam = parameters.Last();
+        var guidParam = sp.GetParameter("oGUID");
 
-        if (guidParam.Value != DBNull.Value)
-            if (guidParam.Value is long longValue)
+        if (guidParam?.Value != DBNull.Value)
+            if (guidParam!.Value is long longValue)
                 return longValue;
-            else if (long.TryParse(guidParam.Value.ToString(), out var guid))
+            else if (long.TryParse(guidParam.Value?.ToString(), out var guid))
                 return guid;
 
         throw new InsertObjectFailedException(request, "InsertObject stored procedure did not return a valid identifier.");

src/ReC.Application/Common/Procedures/StoredProcedureBuilder.cs

@@ -0,0 +1,81 @@
+using Microsoft.Data.SqlClient;
+using Microsoft.EntityFrameworkCore.Metadata.Internal;
+using System.Data;
+using System.Text;
+
+namespace ReC.Application.Common.Procedures;
+
+internal sealed class StoredProcedureBuilder(string procedureName, string? returnVariable = null)
+{
+    private readonly StringBuilder _execSql = returnVariable is not null
+            ? new StringBuilder($"EXEC @{returnVariable} = {procedureName}")
+            : new StringBuilder($"EXEC {procedureName}");
+    private readonly List<SqlParameter> _parameters = [];
+    private char _separator = ' ';
+
+    public StoredProcedureBuilder Add(string name, object? value, SqlDbType? dbType = null)
+    {
+        if (value is null) return this;
+
+        _execSql.AppendLine($"{_separator}@{name} = @{name}");
+        _separator = ',';
+
+        if (!dbType.HasValue && value is DateTime)
+            dbType = SqlDbType.DateTime;
+
+        if (dbType.HasValue)
+            _parameters.Add(new SqlParameter($"@{name}", dbType.Value) { Value = value });
+        else
+            _parameters.Add(new SqlParameter($"@{name}", value));
+
+        return this;
+    }
+
+    public StoredProcedureBuilder Add(string name, EntityType entityType)
+    {
+        var entityTypeStr = entityType switch
+        {
+            EntityType.Action => "ACTION",
+            EntityType.Endpoint => "ENDPOINT",
+            EntityType.EndpointAuth => "ENDPOINT_AUTH",
+            EntityType.EndpointParams => "ENDPOINT_PARAMS",
+            EntityType.Profile => "PROFILE",
+            EntityType.Result => "RESULT",
+            _ => throw new ArgumentOutOfRangeException(nameof(entityType), $"Not expected entity type value: {entityType}")
+        };
+
+        return Add(name, entityTypeStr);
+    }
+
+    public StoredProcedureBuilder AddOutput(string name, SqlDbType dbType)
+    {
+        _execSql.AppendLine($"{_separator}@{name} = @{name} OUTPUT");
+        _separator = ',';
+
+        _parameters.Add(new SqlParameter
+        {
+            ParameterName = $"@{name}",
+            SqlDbType = dbType,
+            Direction = ParameterDirection.Output
+        });
+
+        return this;
+    }
+
+    public string BuildSql()
+    {
+        if (returnVariable is null)
+            return _execSql.ToString();
+
+        return new StringBuilder()
+            .AppendLine($"DECLARE @{returnVariable} SMALLINT = 0;")
+            .Append(_execSql).AppendLine(";")
+            .AppendLine($"SELECT @{returnVariable};")
+            .ToString();
+    }
+
+    public SqlParameter[] BuildParameters() => [.. _parameters];
+
+    public SqlParameter? GetParameter(string name) =>
+        _parameters.Find(p => p.ParameterName == $"@{name}");
+}

src/ReC.Application/Common/Procedures/UpdateProcedure/Dto/UpdateResultDto.cs

@@ -1,4 +1,6 @@
-namespace ReC.Application.Common.Procedures.UpdateProcedure.Dto;
+using ReC.Application.RecActions.Commands;
+
+namespace ReC.Application.Common.Procedures.UpdateProcedure.Dto;
 
 public record UpdateResultDto
 {
@@ -6,4 +8,8 @@ public record UpdateResultDto
     public short? StatusId { get; set; }
     public string? Header { get; set; }
     public string? Body { get; set; }
+    public short? Info { get; set; }
+    public string? InfoDetail { get; set; }
+    public string? Error { get; set; }
+    public InvokeReferences? References { get; set; }
 }

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

@@ -6,21 +6,16 @@ using Microsoft.Extensions.Options;
 using ReC.Application.Common.Exceptions;
 using ReC.Application.Common.Options;
 using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
-using ReC.Application.EndpointAuth.Commands;
-using ReC.Application.EndpointParams.Commands;
-using ReC.Application.Endpoints.Commands;
-using ReC.Application.Profile.Commands;
-using ReC.Application.RecActions.Commands;
-using ReC.Application.Results.Commands;
+using System.Data;
 
 namespace ReC.Application.Common.Procedures.UpdateProcedure;
 
 public record UpdateObjectProcedure : IRequest<int>
 {
     /// <summary>
-    /// Target entity: ACTION, ENDPOINT, ENDPOINT_AUTH, ENDPOINT_PARAMS, PROFILE, RESULT
+    /// Target entity for the update operation.
     /// </summary>
-    public string Entity { get; set; } = null!;
+    public required EntityType Entity { get; set; }
 
     /// <summary>
     /// Target GUID to update (required)
@@ -42,85 +37,72 @@ public class UpdateObjectProcedureHandler(IRepository repo, IOptionsMonitor<SqlE
 {
     public async Task<int> Handle(UpdateObjectProcedure request, CancellationToken cancel)
     {
-        var parameters = new[]
-        {
-            new SqlParameter("@pENTITY", request.Entity ?? (object)DBNull.Value),
-            new SqlParameter("@pGUID", (object?)request.Id ?? DBNull.Value),
-
-            new SqlParameter("@pCHANGED_WHO", (object?)request.ChangedWho ?? DBNull.Value),
-            new SqlParameter("@pCHANGED_WHEN", (object?)DateTime.UtcNow ?? DBNull.Value),
-
-            new SqlParameter("@pACTION_PROFILE_ID", (object?)request.Action.ProfileId ?? DBNull.Value),
-            new SqlParameter("@pACTION_ACTIVE", (object?)request.Action.Active ?? DBNull.Value),
-            new SqlParameter("@pACTION_SEQUENCE", (object?)request.Action.Sequence ?? DBNull.Value),
-            new SqlParameter("@pACTION_ENDPOINT_ID", (object?)request.Action.EndpointId ?? DBNull.Value),
-            new SqlParameter("@pACTION_ENDPOINT_AUTH_ID", (object?)request.Action.EndpointAuthId ?? DBNull.Value),
-            new SqlParameter("@pACTION_ENDPOINT_PARAMS_ID", (object?)request.Action.EndpointParamsId ?? DBNull.Value),
-            new SqlParameter("@pACTION_SQL_CONNECTION_ID", (object?)request.Action.SqlConnectionId ?? DBNull.Value),
-            new SqlParameter("@pACTION_TYPE_ID", (object?)request.Action.TypeId ?? DBNull.Value),
-            new SqlParameter("@pACTION_PRE_SQL", (object?)request.Action.PreSql ?? DBNull.Value),
-            new SqlParameter("@pACTION_HEADER_SQL", (object?)request.Action.HeaderSql ?? DBNull.Value),
-            new SqlParameter("@pACTION_BODY_SQL", (object?)request.Action.BodySql ?? DBNull.Value),
-            new SqlParameter("@pACTION_POST_SQL", (object?)request.Action.PostSql ?? DBNull.Value),
-            new SqlParameter("@pACTION_ERROR_ACTION_ID", (object?)request.Action.ErrorActionId ?? DBNull.Value),
-
-            new SqlParameter("@pENDPOINT_ACTIVE", (object?)request.Endpoint.Active ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_DESCRIPTION", (object?)request.Endpoint.Description ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_URI", (object?)request.Endpoint.Uri ?? DBNull.Value),
-
-            new SqlParameter("@pENDPOINT_AUTH_ACTIVE", (object?)request.EndpointAuth.Active ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_DESCRIPTION", (object?)request.EndpointAuth.Description ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_TYPE_ID", (object?)request.EndpointAuth.TypeId ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_API_KEY", (object?)request.EndpointAuth.ApiKey ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_API_VALUE", (object?)request.EndpointAuth.ApiValue ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_API_KEY_ADD_TO_ID", (object?)request.EndpointAuth.ApiKeyAddToId ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_TOKEN", (object?)request.EndpointAuth.Token ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_USERNAME", (object?)request.EndpointAuth.Username ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_PASSWORD", (object?)request.EndpointAuth.Password ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_DOMAIN", (object?)request.EndpointAuth.Domain ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_AUTH_WORKSTATION", (object?)request.EndpointAuth.Workstation ?? DBNull.Value),
-
-            new SqlParameter("@pENDPOINT_PARAMS_ACTIVE", (object?)request.EndpointParams.Active ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_DESCRIPTION", (object?)request.EndpointParams.Description ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_GROUP_ID", (object?)request.EndpointParams.GroupId ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_SEQUENCE", (object?)request.EndpointParams.Sequence ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_KEY", (object?)request.EndpointParams.Key ?? DBNull.Value),
-            new SqlParameter("@pENDPOINT_PARAMS_VALUE", (object?)request.EndpointParams.Value ?? DBNull.Value),
-
-            new SqlParameter("@pPROFILE_ACTIVE", (object?)request.Profile.Active ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_TYPE_ID", (object?)request.Profile.TypeId ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_MANDANTOR", (object?)request.Profile.Mandantor ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_NAME", (object?)request.Profile.Name ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_DESCRIPTION", (object?)request.Profile.Description ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_LOG_LEVEL_ID", (object?)request.Profile.LogLevelId ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_LANGUAGE_ID", (object?)request.Profile.LanguageId ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_FIRST_RUN", (object?)request.Profile.FirstRun ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_LAST_RUN", (object?)request.Profile.LastRun ?? DBNull.Value),
-            new SqlParameter("@pPROFILE_LAST_RESULT", (object?)request.Profile.LastResult ?? DBNull.Value),
-
-            new SqlParameter("@pRESULT_ACTION_ID", (object?)request.Result.ActionId ?? DBNull.Value),
-            new SqlParameter("@pRESULT_STATUS_ID", (object?)request.Result.StatusId ?? DBNull.Value),
-            new SqlParameter("@pRESULT_HEADER", (object?)request.Result.Header ?? DBNull.Value),
-            new SqlParameter("@pRESULT_BODY", (object?)request.Result.Body ?? DBNull.Value)
-        };
+        var sp = new StoredProcedureBuilder("[dbo].[PRREC_UPDATE_OBJECT]", "RC")
+            .Add("pENTITY", request.Entity)
+            .Add("pGUID", request.Id)
+            .Add("pCHANGED_WHO", request.ChangedWho)
+            .Add("pCHANGED_WHEN", DateTime.UtcNow)
+            .Add("pACTION_PROFILE_ID", request.Action.ProfileId)
+            .Add("pACTION_ACTIVE", request.Action.Active)
+            .Add("pACTION_SEQUENCE", request.Action.Sequence, SqlDbType.TinyInt)
+            .Add("pACTION_ENDPOINT_ID", request.Action.EndpointId)
+            .Add("pACTION_ENDPOINT_AUTH_ID", request.Action.EndpointAuthId)
+            .Add("pACTION_ENDPOINT_PARAMS_ID", request.Action.EndpointParamsId, SqlDbType.SmallInt)
+            .Add("pACTION_SQL_CONNECTION_ID", request.Action.SqlConnectionId, SqlDbType.SmallInt)
+            .Add("pACTION_TYPE_ID", request.Action.TypeId, SqlDbType.TinyInt)
+            .Add("pACTION_PRE_SQL", request.Action.PreSql)
+            .Add("pACTION_HEADER_SQL", request.Action.HeaderSql)
+            .Add("pACTION_BODY_SQL", request.Action.BodySql)
+            .Add("pACTION_POST_SQL", request.Action.PostSql)
+            .Add("pACTION_ERROR_ACTION_ID", request.Action.ErrorActionId, SqlDbType.TinyInt)
+            .Add("pENDPOINT_ACTIVE", request.Endpoint.Active)
+            .Add("pENDPOINT_DESCRIPTION", request.Endpoint.Description)
+            .Add("pENDPOINT_URI", request.Endpoint.Uri)
+            .Add("pENDPOINT_AUTH_ACTIVE", request.EndpointAuth.Active)
+            .Add("pENDPOINT_AUTH_DESCRIPTION", request.EndpointAuth.Description)
+            .Add("pENDPOINT_AUTH_TYPE_ID", request.EndpointAuth.TypeId, SqlDbType.TinyInt)
+            .Add("pENDPOINT_AUTH_API_KEY", request.EndpointAuth.ApiKey)
+            .Add("pENDPOINT_AUTH_API_VALUE", request.EndpointAuth.ApiValue)
+            .Add("pENDPOINT_AUTH_API_KEY_ADD_TO_ID", request.EndpointAuth.ApiKeyAddToId)
+            .Add("pENDPOINT_AUTH_TOKEN", request.EndpointAuth.Token)
+            .Add("pENDPOINT_AUTH_USERNAME", request.EndpointAuth.Username)
+            .Add("pENDPOINT_AUTH_PASSWORD", request.EndpointAuth.Password)
+            .Add("pENDPOINT_AUTH_DOMAIN", request.EndpointAuth.Domain)
+            .Add("pENDPOINT_AUTH_WORKSTATION", request.EndpointAuth.Workstation)
+            .Add("pENDPOINT_PARAMS_ACTIVE", request.EndpointParams.Active)
+            .Add("pENDPOINT_PARAMS_DESCRIPTION", request.EndpointParams.Description)
+            .Add("pENDPOINT_PARAMS_GROUP_ID", request.EndpointParams.GroupId, SqlDbType.SmallInt)
+            .Add("pENDPOINT_PARAMS_SEQUENCE", request.EndpointParams.Sequence, SqlDbType.TinyInt)
+            .Add("pENDPOINT_PARAMS_KEY", request.EndpointParams.Key)
+            .Add("pENDPOINT_PARAMS_VALUE", request.EndpointParams.Value)
+            .Add("pPROFILE_ACTIVE", request.Profile.Active)
+            .Add("pPROFILE_TYPE_ID", request.Profile.TypeId, SqlDbType.TinyInt)
+            .Add("pPROFILE_MANDANTOR", request.Profile.Mandantor)
+            .Add("pPROFILE_NAME", request.Profile.Name)
+            .Add("pPROFILE_DESCRIPTION", request.Profile.Description)
+            .Add("pPROFILE_LOG_LEVEL_ID", request.Profile.LogLevelId, SqlDbType.TinyInt)
+            .Add("pPROFILE_LANGUAGE_ID", request.Profile.LanguageId, SqlDbType.SmallInt)
+            .Add("pPROFILE_FIRST_RUN", request.Profile.FirstRun)
+            .Add("pPROFILE_LAST_RUN", request.Profile.LastRun)
+            .Add("pPROFILE_LAST_RESULT", request.Profile.LastResult)
+            .Add("pRESULT_ACTION_ID", request.Result.ActionId)
+            .Add("pRESULT_STATUS_ID", request.Result.StatusId, SqlDbType.TinyInt)
+            .Add("pRESULT_HEADER", request.Result.Header)
+            .Add("pRESULT_BODY", request.Result.Body)
+            .Add("pRESULT_INFO_ID", request.Result.Info, SqlDbType.SmallInt)
+            .Add("pRESULT_INFO_DETAIL", request.Result.InfoDetail)
+            .Add("pRESULT_ERROR", request.Result.Error)
+            .Add("pRESULT_BATCH_ID", request.Result.References?.BatchId)
+            .Add("pRESULT_REFERENCE1", request.Result.References?.Reference1)
+            .Add("pRESULT_REFERENCE2", request.Result.References?.Reference2)
+            .Add("pRESULT_REFERENCE3", request.Result.References?.Reference3)
+            .Add("pRESULT_REFERENCE4", request.Result.References?.Reference4)
+            .Add("pRESULT_REFERENCE5", request.Result.References?.Reference5);
 
         try
         {
-            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);
+            var result = await repo.ExecuteQueryRawAsync(sp.BuildSql(), sp.BuildParameters(), 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}");

src/ReC.Application/Common/Validations/DeleteObjectProcedureValidator.cs

@@ -0,0 +1,22 @@
+using FluentValidation;
+using ReC.Application.Common.Procedures.DeleteProcedure;
+
+namespace ReC.Application.Common.Validations;
+
+public class DeleteObjectProcedureValidator : AbstractValidator<DeleteObjectProcedure>
+{
+    public DeleteObjectProcedureValidator()
+    {
+        RuleFor(x => x.Entity)
+            .IsInEnum()
+            .WithMessage("ENTITY must be a valid EntityType value.");
+
+        RuleFor(x => x.Start)
+            .GreaterThan(0)
+            .WithMessage("Start GUID/ID must be greater than 0.");
+
+        RuleFor(x => x.End)
+            .GreaterThanOrEqualTo(x => x.Start)
+            .WithMessage("End GUID/ID must be greater than or equal to Start GUID/ID.");
+    }
+}

src/ReC.Application/Common/Validations/InsertObjectProcedureValidator.cs

@@ -7,66 +7,60 @@ public class InsertObjectProcedureValidator : AbstractValidator<InsertObjectProc
 {
     public InsertObjectProcedureValidator()
     {
-        // ENTITY must be one of the allowed values
         RuleFor(x => x.Entity)
-            .NotEmpty()
-            .Must(e => e is "ACTION" or "ENDPOINT" or "ENDPOINT_AUTH" or "ENDPOINT_PARAMS" or "PROFILE" or "RESULT")
-            .WithMessage("ENTITY must be one of: ACTION, ENDPOINT, ENDPOINT_AUTH, ENDPOINT_PARAMS, PROFILE, RESULT.");
+            .IsInEnum()
+            .WithMessage("ENTITY must be a valid EntityType value.");
 
         // ACTION validation
-        When(x => x.Entity == "ACTION", () =>
+        When(x => x.Action != null, () =>
         {
-            RuleFor(x => x.Action.ProfileId)
+            RuleFor(x => x.Action!.ProfileId)
                 .NotNull()
                 .WithMessage("ACTION requires ActionProfileId (maps to @pACTION_PROFILE_ID).");
 
-            RuleFor(x => x.Action.EndpointId)
+            RuleFor(x => x.Action!.EndpointId)
                 .NotNull()
                 .WithMessage("ACTION requires ActionEndpointId (maps to @pACTION_ENDPOINT_ID).");
         });
 
         // ENDPOINT validation
-        When(x => x.Entity == "ENDPOINT", () =>
+        When(x => x.Endpoint != null, () =>
         {
-            RuleFor(x => x.Endpoint.Uri)
+            RuleFor(x => x.Endpoint!.Uri)
                 .NotEmpty()
                 .WithMessage("ENDPOINT requires EndpointUri (maps to @pENDPOINT_URI).")
                 .MaximumLength(2000);
         });
 
         // PROFILE validation
-        When(x => x.Entity == "PROFILE", () =>
+        When(x => x.Profile != null, () =>
         {
-            RuleFor(x => x.Profile.Name)
+            RuleFor(x => x.Profile!.Name)
                 .NotEmpty()
                 .WithMessage("PROFILE requires ProfileName (maps to @pPROFILE_NAME).")
                 .MaximumLength(50);
 
-            RuleFor(x => x.Profile.Mandantor)
+            RuleFor(x => x.Profile!.Mandantor)
                 .MaximumLength(50)
-                .When(x => x.Profile.Mandantor != null);
+                .When(x => x.Profile!.Mandantor != null);
 
-            RuleFor(x => x.Profile.Description)
+            RuleFor(x => x.Profile!.Description)
                 .MaximumLength(250)
-                .When(x => x.Profile.Description != null);
+                .When(x => x.Profile!.Description != null);
         });
 
         // RESULT validation
-        When(x => x.Entity == "RESULT", () =>
+        When(x => x.Result != null, () =>
         {
-            RuleFor(x => x.Result.ActionId)
+            RuleFor(x => x.Result!.ActionId)
                 .NotNull()
                 .WithMessage("RESULT requires ResultActionId (maps to @pRESULT_ACTION_ID).");
-
-            RuleFor(x => x.Result.StatusId)
-                .NotNull()
-                .WithMessage("RESULT requires ResultStatusId (maps to @pRESULT_STATUS_ID).");
         });
 
         // ENDPOINT_PARAMS validation
-        When(x => x.Entity == "ENDPOINT_PARAMS", () =>
+        When(x => x.EndpointParams != null, () =>
         {
-            RuleFor(x => x.EndpointParams.GroupId)
+            RuleFor(x => x.EndpointParams!.GroupId)
                 .NotNull()
                 .WithMessage("ENDPOINT_PARAMS requires EndpointParamsGroupId (maps to @pENDPOINT_PARAMS_GROUP_ID).");
         });
@@ -76,12 +70,12 @@ public class InsertObjectProcedureValidator : AbstractValidator<InsertObjectProc
             .MaximumLength(50)
             .When(x => x.AddedWho != null);
 
-        RuleFor(x => x.Endpoint.Description)
+        RuleFor(x => x.Endpoint!.Description)
             .MaximumLength(250)
-            .When(x => x.Endpoint.Description != null);
+            .When(x => x.Endpoint is { Description: not null });
 
-        RuleFor(x => x.EndpointAuth.Description)
+        RuleFor(x => x.EndpointAuth!.Description)
             .MaximumLength(250)
-            .When(x => x.EndpointAuth.Description != null);
+            .When(x => x.EndpointAuth is { Description: not null });
     }
 }

src/ReC.Application/Common/Validations/InsertResultCommandValidator.cs

@@ -0,0 +1,21 @@
+using FluentValidation;
+using ReC.Application.Results.Commands;
+
+namespace ReC.Application.Common.Validations;
+
+public class InsertResultCommandValidator : AbstractValidator<InsertResultCommand>
+{
+    public InsertResultCommandValidator()
+    {
+        RuleFor(x => x.ActionId)
+            .NotNull()
+            .WithMessage("ActionId is required.")
+            .GreaterThan(0L)
+            .When(x => x.ActionId.HasValue)
+            .WithMessage("ActionId must be greater than 0.");
+
+        RuleFor(x => x.References.BatchId)
+            .NotEmpty()
+            .WithMessage("BatchId is required.");
+    }
+}

src/ReC.Application/Common/Validations/InvokeBatchRecActionViewsCommandValidator.cs

@@ -0,0 +1,22 @@
+using FluentValidation;
+using MediatR;
+using ReC.Application.RecActions.Commands;
+using ReC.Application.Results.Queries;
+
+namespace ReC.Application.Common.Validations;
+
+public class InvokeBatchRecActionViewsCommandValidator : AbstractValidator<InvokeBatchRecActionViewsCommand>
+{
+    public InvokeBatchRecActionViewsCommandValidator(ISender sender)
+    {
+        RuleFor(x => x.References.BatchId)
+            .NotEmpty()
+            .WithMessage("BatchId is required.")
+            .MustAsync(async (batchId, cancel) =>
+            {
+                var any = await sender.Send(new AnyResultViewQuery(BatchId: batchId), cancel);
+                return !any;
+            })
+            .WithMessage(x => $"Cannot invoke rec actions for batch '{x.References.BatchId}' because there are already results associated with it.");
+    }
+}

src/ReC.Application/Common/Validations/ReadProfileViewQueryValidator.cs

@@ -0,0 +1,15 @@
+using FluentValidation;
+using ReC.Application.Profile.Queries;
+
+namespace ReC.Application.Common.Validations;
+
+public class ReadProfileViewQueryValidator : AbstractValidator<ReadProfileViewQuery>
+{
+    public ReadProfileViewQueryValidator()
+    {
+        RuleFor(x => x.Id)
+            .GreaterThan(0)
+            .When(x => x.Id.HasValue)
+            .WithMessage("Id must be greater than 0.");
+    }
+}

src/ReC.Application/Common/Validations/ReadRecActionViewQueryValidator.cs

@@ -0,0 +1,15 @@
+using FluentValidation;
+using ReC.Application.RecActions.Queries;
+
+namespace ReC.Application.Common.Validations;
+
+public class ReadRecActionViewQueryValidator : AbstractValidator<ReadRecActionViewQuery>
+{
+    public ReadRecActionViewQueryValidator()
+    {
+        RuleFor(x => x.ProfileId)
+            .GreaterThan(0)
+            .When(x => x.ProfileId.HasValue)
+            .WithMessage("ProfileId must be greater than 0.");
+    }
+}

src/ReC.Application/Common/Validations/ReadResultViewQueryValidator.cs

@@ -0,0 +1,34 @@
+using FluentValidation;
+using ReC.Application.Results.Queries;
+
+namespace ReC.Application.Common.Validations;
+
+public class ReadResultViewQueryValidator : AbstractValidator<ReadResultViewQuery>
+{
+    public ReadResultViewQueryValidator()
+    {
+        RuleFor(x => x)
+            .Must(x => x.Id.HasValue || x.ActionId.HasValue || x.ProfileId.HasValue || x.BatchId is not null)
+            .WithMessage("At least one filter (Id, ActionId, ProfileId or BatchId) must be provided.");
+
+        RuleFor(x => x.Id)
+            .GreaterThan(0)
+            .When(x => x.Id.HasValue)
+            .WithMessage("Id must be greater than 0.");
+
+        RuleFor(x => x.ActionId)
+            .GreaterThan(0)
+            .When(x => x.ActionId.HasValue)
+            .WithMessage("ActionId must be greater than 0.");
+
+        RuleFor(x => x.ProfileId)
+            .GreaterThan(0)
+            .When(x => x.ProfileId.HasValue)
+            .WithMessage("ProfileId must be greater than 0.");
+
+        RuleFor(x => x.BatchId)
+            .NotEmpty()
+            .When(x => x.BatchId is not null)
+            .WithMessage("BatchId must not be empty when provided.");
+    }
+}

src/ReC.Application/Common/Validations/UpdateObjectProcedureValidator.cs

@@ -0,0 +1,52 @@
+using FluentValidation;
+using ReC.Application.Common.Procedures.UpdateProcedure;
+
+namespace ReC.Application.Common.Validations;
+
+public class UpdateObjectProcedureValidator : AbstractValidator<UpdateObjectProcedure>
+{
+    public UpdateObjectProcedureValidator()
+    {
+        RuleFor(x => x.Entity)
+            .IsInEnum()
+            .WithMessage("ENTITY must be a valid EntityType value.");
+
+        RuleFor(x => x.Id)
+            .GreaterThan(0)
+            .WithMessage("Target GUID/ID must be greater than 0.");
+
+        RuleFor(x => x.ChangedWho)
+            .MaximumLength(50)
+            .When(x => x.ChangedWho != null);
+
+        When(x => x.Endpoint is { Description: not null }, () =>
+        {
+            RuleFor(x => x.Endpoint.Description)
+                .MaximumLength(250);
+        });
+
+        When(x => x.EndpointAuth is { Description: not null }, () =>
+        {
+            RuleFor(x => x.EndpointAuth.Description)
+                .MaximumLength(250);
+        });
+
+        When(x => x.Profile is { Name: not null }, () =>
+        {
+            RuleFor(x => x.Profile.Name)
+                .MaximumLength(50);
+        });
+
+        When(x => x.Profile is { Mandantor: not null }, () =>
+        {
+            RuleFor(x => x.Profile.Mandantor)
+                .MaximumLength(50);
+        });
+
+        When(x => x.Profile is { Description: not null }, () =>
+        {
+            RuleFor(x => x.Profile.Description)
+                .MaximumLength(250);
+        });
+    }
+}

src/ReC.Application/DependencyInjection.cs

@@ -4,6 +4,7 @@ using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using ReC.Application.Common.Behaviors;
 using ReC.Application.Common.Behaviors.Action;
+using ReC.Application.Common.Behaviors.InvokeAction;
 using ReC.Application.Common.Constants;
 using ReC.Application.Common.Options;
 using ReC.Application.RecActions.Commands;

src/ReC.Application/EndpointAuth/Commands/DeleteEndpointAuthCommand.cs

@@ -1,5 +1,6 @@
 using MediatR;
 using ReC.Application.Common.Procedures.DeleteProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.EndpointAuth.Commands;
 
@@ -27,7 +28,7 @@ public class DeleteEndpointAuthProcedureHandler(ISender sender) : IRequestHandle
     {
         return await sender.Send(new DeleteObjectProcedure
         {
-            Entity = "ENDPOINT_AUTH",
+            Entity = EntityType.EndpointAuth,
             Start = request.Start,
             End = request.End,
             Force = request.Force

src/ReC.Application/EndpointAuth/Commands/InsertEndpointAuthCommand.cs

@@ -1,5 +1,6 @@
-using MediatR;
+using MediatR;
 using ReC.Application.Common.Procedures.InsertProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.EndpointAuth.Commands;
 
@@ -24,7 +25,7 @@ public class InsertEndpointAuthProcedureHandler(ISender sender) : IRequestHandle
     {
         return await sender.Send(new InsertObjectProcedure
         {
-            Entity = "ENDPOINT_AUTH",
+            Entity = EntityType.EndpointAuth,
             EndpointAuth = request
         }, cancel);
     }

src/ReC.Application/EndpointAuth/Commands/UpdateEndpointAuthCommand.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using ReC.Application.Common.Procedures.UpdateProcedure;
 using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.EndpointAuth.Commands;
 
@@ -17,7 +18,7 @@ public class UpdateEndpointAuthProcedureHandler(ISender sender) : IRequestHandle
     {
         return await sender.Send(new UpdateObjectProcedure
         {
-            Entity = "ENDPOINT_AUTH",
+            Entity = EntityType.EndpointAuth,
             Id = request.Id,
             EndpointAuth = request.Data
         }, cancel);

src/ReC.Application/EndpointParams/Commands/DeleteEndpointParamsCommand.cs

@@ -1,5 +1,6 @@
 using MediatR;
 using ReC.Application.Common.Procedures.DeleteProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.EndpointParams.Commands;
 
@@ -27,7 +28,7 @@ public class DeleteEndpointParamsProcedureHandler(ISender sender) : IRequestHand
     {
         return await sender.Send(new DeleteObjectProcedure
         {
-            Entity = "ENDPOINT_PARAMS",
+            Entity = EntityType.EndpointParams,
             Start = request.Start,
             End = request.End,
             Force = request.Force

src/ReC.Application/EndpointParams/Commands/InsertEndpointParamsCommand.cs

@@ -1,5 +1,6 @@
-using MediatR;
+using MediatR;
 using ReC.Application.Common.Procedures.InsertProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.EndpointParams.Commands;
 
@@ -19,7 +20,7 @@ public class InsertEndpointParamsProcedureHandler(ISender sender) : IRequestHand
     {
         return await sender.Send(new InsertObjectProcedure
         {
-            Entity = "ENDPOINT_PARAMS",
+            Entity = EntityType.EndpointParams,
             EndpointParams = request
         }, cancel);
     }

src/ReC.Application/EndpointParams/Commands/UpdateEndpointParamsCommand.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using ReC.Application.Common.Procedures.UpdateProcedure;
 using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.EndpointParams.Commands;
 
@@ -17,7 +18,7 @@ public class UpdateEndpointParamsProcedureHandler(ISender sender) : IRequestHand
     {
         return await sender.Send(new UpdateObjectProcedure
         {
-            Entity = "ENDPOINT_PARAMS",
+            Entity = EntityType.EndpointParams,
             Id = request.Id,
             EndpointParams = request.Data
         }, cancel);

src/ReC.Application/Endpoints/Commands/DeleteEndpointCommand.cs

@@ -1,5 +1,6 @@
 using MediatR;
 using ReC.Application.Common.Procedures.DeleteProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Endpoints.Commands;
 
@@ -27,7 +28,7 @@ public class DeleteEndpointProcedureHandler(ISender sender) : IRequestHandler<De
     {
         return await sender.Send(new DeleteObjectProcedure
         {
-            Entity = "ENDPOINT",
+            Entity = EntityType.Endpoint,
             Start = request.Start,
             End = request.End,
             Force = request.Force

src/ReC.Application/Endpoints/Commands/InsertEndpointCommand.cs

@@ -1,5 +1,6 @@
-using MediatR;
+using MediatR;
 using ReC.Application.Common.Procedures.InsertProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Endpoints.Commands;
 
@@ -16,7 +17,7 @@ public class InsertEndpointProcedureHandler(ISender sender) : IRequestHandler<In
     {
         return await sender.Send(new InsertObjectProcedure
         {
-            Entity = "ENDPOINT",
+            Entity = EntityType.Endpoint,
             Endpoint = request
         }, cancel);
     }

src/ReC.Application/Endpoints/Commands/UpdateEndpointCommand.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using ReC.Application.Common.Procedures.UpdateProcedure;
 using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Endpoints.Commands;
 
@@ -17,7 +18,7 @@ public class UpdateEndpointProcedureHandler(ISender sender) : IRequestHandler<Up
     {
         return await sender.Send(new UpdateObjectProcedure
         {
-            Entity = "ENDPOINT",
+            Entity = EntityType.Endpoint,
             Id = request.Id,
             Endpoint = request.Data
         }, cancel);

src/ReC.Application/Profile/Commands/DeleteProfileCommand.cs

@@ -1,5 +1,6 @@
 using MediatR;
 using ReC.Application.Common.Procedures.DeleteProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Profile.Commands;
 
@@ -27,7 +28,7 @@ public class DeleteProfileProcedureHandler(ISender sender) : IRequestHandler<Del
     {
         return await sender.Send(new DeleteObjectProcedure
         {
-            Entity = "PROFILE",
+            Entity = EntityType.Profile,
             Start = request.Start,
             End = request.End,
             Force = request.Force

src/ReC.Application/Profile/Commands/InsertProfileCommand.cs

@@ -1,5 +1,6 @@
-using MediatR;
+using MediatR;
 using ReC.Application.Common.Procedures.InsertProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Profile.Commands;
 
@@ -20,7 +21,7 @@ public class InsertProfileProcedureHandler(ISender sender) : IRequestHandler<Ins
     {
         return await sender.Send(new InsertObjectProcedure
         {
-            Entity = "PROFILE",
+            Entity = EntityType.Profile,
             Profile = request
         }, cancel);
     }

src/ReC.Application/Profile/Commands/UpdateProfileCommand.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using ReC.Application.Common.Procedures.UpdateProcedure;
 using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Profile.Commands;
 
@@ -17,7 +18,7 @@ public class UpdateProfileProcedureHandler(ISender sender) : IRequestHandler<Upd
     {
         return await sender.Send(new UpdateObjectProcedure
         {
-            Entity = "PROFILE",
+            Entity = EntityType.Profile,
             Id = request.Id,
             Profile = request.Data
         }, cancel);

src/ReC.Application/ReC.Application.csproj

@@ -7,7 +7,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="AutoMapper" Version="15.1.0" />
+    <PackageReference Include="AutoMapper" Version="16.1.1" />
     <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.1" />

src/ReC.Application/RecActions/Commands/DeleteActionCommand.cs

@@ -1,5 +1,6 @@
 using MediatR;
 using ReC.Application.Common.Procedures.DeleteProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.RecActions.Commands;
 
@@ -27,7 +28,7 @@ public class DeleteActionProcedureHandler(ISender sender) : IRequestHandler<Dele
     {
         return await sender.Send(new DeleteObjectProcedure
         {
-            Entity = "ACTION",
+            Entity = EntityType.Action,
             Start = request.Start,
             End = request.End,
             Force = request.Force

src/ReC.Application/RecActions/Commands/InsertActionCommand.cs

@@ -1,6 +1,7 @@
-using MediatR;
+using MediatR;
 using ReC.Application.Common.Procedures.InsertProcedure;
 using ReC.Domain.Constants;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.RecActions.Commands;
 
@@ -27,7 +28,7 @@ public class InsertActionProcedureHandler(ISender sender) : IRequestHandler<Inse
     {
         return await sender.Send(new InsertObjectProcedure
         {
-            Entity = "ACTION",
+            Entity = EntityType.Action,
             Action = request
         }, cancel);
     }

src/ReC.Application/RecActions/Commands/InvokeBatchRecActionViewsCommand.cs

@@ -1,5 +1,6 @@
-using DigitalData.Core.Abstractions.Interfaces;
-using MediatR;
+using MediatR;
+using Microsoft.Extensions.Logging;
+using ReC.Application.Common.Exceptions;
 using ReC.Application.RecActions.Queries;
 using ReC.Domain.Constants;
 
@@ -8,15 +9,10 @@ namespace ReC.Application.RecActions.Commands;
 public record InvokeBatchRecActionViewsCommand : IRequest
 {
     public long ProfileId { get; init; }
+    public required InvokeReferences References { get; init; }
 }
 
-public static class InvokeBatchRecActionViewsCommandExtensions
-{
-    public static Task InvokeBatchRecActionView(this ISender sender, long profileId, CancellationToken cancel = default)
-        => sender.Send(new InvokeBatchRecActionViewsCommand { ProfileId = profileId }, cancel);
-}
-
-public class InvokeRecActionViewsCommandHandler(ISender sender) : IRequestHandler<InvokeBatchRecActionViewsCommand>
+public class InvokeRecActionViewsCommandHandler(ISender sender, ILogger<InvokeRecActionViewsCommandHandler>? logger = null) : IRequestHandler<InvokeBatchRecActionViewsCommand>
 {
     public async Task Handle(InvokeBatchRecActionViewsCommand request, CancellationToken cancel)
     {
@@ -26,13 +22,30 @@ public class InvokeRecActionViewsCommandHandler(ISender sender) : IRequestHandle
         {
             try
             {
-                await sender.Send(new InvokeRecActionViewCommand() { Action = action }, cancel);
+                await sender.Send(new InvokeRecActionViewCommand()
+                {
+                    Action = action,
+                    References = request.References
+                }, cancel);
             }
-            catch
+            catch (RecActionException ex)
             {
                 switch (action.ErrorAction)
                 {
                     case ErrorAction.Continue:
+                        logger?.LogWarning(ex, "Rec action failed but continuing. ActionId: {ActionId}, ProfileId: {ProfileId}", ex.ActionId, ex.ProfileId);
+                        break;
+                    default:
+                        // Rethrow the exception to stop processing further actions
+                        throw;
+                }
+            }
+            catch (Exception ex)
+            {
+                switch (action.ErrorAction)
+                {
+                    case ErrorAction.Continue:
+                        logger?.LogError(ex, "Unexpected error during rec action. ActionId: {ActionId}, ProfileId: {ProfileId}", action.Id, action.ProfileId);
                         break;
                     default:
                         // Rethrow the exception to stop processing further actions

src/ReC.Application/RecActions/Commands/InvokeRecActionViewCommand.cs

@@ -7,6 +7,7 @@ using ReC.Application.Common.Exceptions;
 using ReC.Application.Common.Options;
 using ReC.Application.Results.Commands;
 using ReC.Domain.Constants;
+using ReC.Domain.Views;
 using System.Net;
 using System.Net.Http.Headers;
 using System.Text;
@@ -17,6 +18,17 @@ namespace ReC.Application.RecActions.Commands;
 public record InvokeRecActionViewCommand : IRequest
 {
     public RecActionViewDto Action { get; set; } = null!;
+    public required InvokeReferences References { get; set; }
+}
+
+public record InvokeReferences
+{
+    public required string BatchId { get; init; }
+    public string? Reference1 { get; init; }
+    public string? Reference2 { get; init; }
+    public string? Reference3 { get; init; }
+    public string? Reference4 { get; init; }
+    public string? Reference5 { get; init; }
 }
 
 public class InvokeRecActionViewCommandHandler(
@@ -142,26 +154,30 @@ public class InvokeRecActionViewCommandHandler(
             var resBody = await response.Content.ReadAsStringAsync(cancel);
             var resHeaders = response.Headers.ToDictionary();
 
-            var statusCode = (short)response.StatusCode;
-
             await sender.Send(new InsertResultCommand()
             {
-                StatusId = statusCode,
+                Status = response.StatusCode.ToRecStatus(),
                 ActionId = action.Id,
                 Header = JsonSerializer.Serialize(resHeaders, options: new() { WriteIndented = false }),
-                Body = resBody
+                Body = resBody,
+                Info = (short)response.StatusCode,
+                Type = ResultType.Main,
+                References = request.References
             }, cancel);
         }
         catch(Exception ex)
         {
             await sender.Send(new InsertResultCommand()
             {
+                Status = RecStatus.Error,
                 ActionId = action.Id,
-                Error = ex.ToString()
+                Error = ex.ToString(),
+                Type = ResultType.Main,
+                References = request.References
             }, cancel);
 
             if (action.ErrorAction == ErrorAction.Stop)
-                throw;
+                throw new RecActionException(action.Id, action.ProfileId, ex);
         }
         finally
         {

src/ReC.Application/RecActions/Commands/UpdateActionCommand.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using ReC.Application.Common.Procedures.UpdateProcedure;
 using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.RecActions.Commands;
 
@@ -17,7 +18,7 @@ public class UpdateActionProcedureHandler(ISender sender) : IRequestHandler<Upda
     {
         return await sender.Send(new UpdateObjectProcedure
         {
-            Entity = "ACTION",
+            Entity = EntityType.Action,
             Id = request.Id,
             Action = request.Data
         }, cancel);

src/ReC.Application/Results/Commands/DeleteResultCommand.cs

@@ -1,5 +1,6 @@
 using MediatR;
 using ReC.Application.Common.Procedures.DeleteProcedure;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Results.Commands;
 
@@ -27,7 +28,7 @@ public class DeleteResultProcedureHandler(ISender sender) : IRequestHandler<Dele
     {
         return await sender.Send(new DeleteObjectProcedure
         {
-            Entity = "RESULT",
+            Entity = EntityType.Result,
             Start = request.Start,
             End = request.End,
             Force = request.Force

src/ReC.Application/Results/Commands/InsertResultCommand.cs

@@ -1,16 +1,22 @@
-using MediatR;
+using MediatR;
 using ReC.Application.Common.Procedures.InsertProcedure;
+using ReC.Application.RecActions.Commands;
+using ReC.Domain.Constants;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Results.Commands;
 
 public record InsertResultCommand : IInsertProcedure
 {
     public long? ActionId { get; set; }
-    public short? StatusId { get; set; }
+    public required RecStatus Status { get; set; }
     public string? Header { get; set; }
     public string? Body { get; set; }
-    public string? Info { get; set; }
+    public short Info { get; set; }
+    public string? InfoDetail { get; set; }
     public string? Error { get; set; }
+    public required ResultType Type { get; set; }
+    public required InvokeReferences References { get; set; }
 }
 
 public class InsertResultProcedureHandler(ISender sender) : IRequestHandler<InsertResultCommand, long>
@@ -19,7 +25,7 @@ public class InsertResultProcedureHandler(ISender sender) : IRequestHandler<Inse
     {
         return await sender.Send(new InsertObjectProcedure
         {
-            Entity = "RESULT",
+            Entity = EntityType.Result,
             Result = request
         }, cancel);
     }

src/ReC.Application/Results/Commands/UpdateResultCommand.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using ReC.Application.Common.Procedures.UpdateProcedure;
 using ReC.Application.Common.Procedures.UpdateProcedure.Dto;
+using ReC.Application.Common.Procedures;
 
 namespace ReC.Application.Results.Commands;
 
@@ -17,7 +18,7 @@ public class UpdateResultProcedureHandler(ISender sender) : IRequestHandler<Upda
     {
         return await sender.Send(new UpdateObjectProcedure
         {
-            Entity = "RESULT",
+            Entity = EntityType.Result,
             Id = request.Id,
             Result = request.Data
         }, cancel);

src/ReC.Application/Results/Queries/AnyResultViewQuery.cs

@@ -0,0 +1,35 @@
+using DigitalData.Core.Abstraction.Application.Repository;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using ReC.Domain.Views;
+
+namespace ReC.Application.Results.Queries;
+
+public record AnyResultViewQuery(
+    long? Id = null,
+    long? ActionId = null,
+    long? ProfileId = null,
+    string? BatchId = null
+) : IRequest<bool>;
+
+public class AnyResultViewQueryHandler(IRepository<ResultView> repo) : IRequestHandler<AnyResultViewQuery, bool>
+{
+    public Task<bool> Handle(AnyResultViewQuery request, CancellationToken cancel)
+    {
+        var q = repo.Query;
+
+        if(request.Id is long id)
+            q = q.Where(rv => rv.Id == id);
+
+        if(request.ActionId is long actionId)
+            q = q.Where(rv => rv.ActionId == actionId);
+
+        if(request.ProfileId is long profileId)
+            q = q.Where(rv => rv.ProfileId == profileId);
+
+        if(request.BatchId is string batchId)
+            q = q.Where(rv => rv.BatchId == batchId);
+
+        return q.AnyAsync(cancel);
+    }
+}

src/ReC.Application/Results/Queries/ReadResultViewQuery.cs

@@ -17,11 +17,13 @@ public record ReadResultViewQuery : IRequest<IEnumerable<ResultViewDto>>
 
     public long? ProfileId { get; init; } = null;
 
+    public string? BatchId { get; init; } = null;
+
     public bool IncludeAction { get; init; } = true;
 
     public bool IncludeProfile { get; init; } = false;
 
-    public bool Last { get; init; } = false;
+    public bool LastBatch { get; init; } = false;
 }
 
 public class ReadResultViewQueryHandler(IRepository<ResultView> repo, IMapper mapper) : IRequestHandler<ReadResultViewQuery, IEnumerable<ResultViewDto>>
@@ -39,13 +41,18 @@ public class ReadResultViewQueryHandler(IRepository<ResultView> repo, IMapper ma
         if(request.ProfileId is long profileId)
             q = q.Where(rv => rv.ProfileId == profileId);
 
-        if(request.IncludeAction)
+        if(request.BatchId is string batchId)
+            q = q.Where(rv => rv.BatchId == batchId);
+
+        if (request.IncludeAction)
             q = q.Include(rv => rv.Action);
 
         if(request.IncludeProfile)
             q = q.Include(rv => rv.Profile);
 
-        var entities = request.Last ? [await q.OrderBy(rv => rv.AddedWhen).LastOrDefaultAsync(cancel)] : await q.ToListAsync(cancel);
+        var entities = request.LastBatch
+            ? await GetLastBatchEntitiesAsync(q, cancel)
+            : await q.ToListAsync(cancel);
 
         if (entities.Count == 0)
             throw new NotFoundException($"No result views found for the given criteria. Criteria: {
@@ -58,4 +65,20 @@ public class ReadResultViewQueryHandler(IRepository<ResultView> repo, IMapper ma
 
         return mapper.Map<IEnumerable<ResultViewDto>>(entities);
     }
+
+    private static async Task<List<ResultView>> GetLastBatchEntitiesAsync(IQueryable<ResultView> q, CancellationToken cancel)
+    {
+        var lastBatchId = await q
+            .Where(rv => rv.BatchId != null)
+            .OrderByDescending(rv => rv.AddedWhen)
+            .Select(rv => rv.BatchId)
+            .FirstOrDefaultAsync(cancel);
+
+        if (lastBatchId is null)
+            return [];
+
+        return await q
+            .Where(rv => rv.BatchId == lastBatchId)
+            .ToListAsync(cancel);
+    }
 }

src/ReC.Client/Api/InvokeReferences.cs

@@ -0,0 +1,50 @@
+namespace ReC.Client.Api
+{
+    /// <summary>
+    /// Optional reference values that are passed through to all result records when invoking a profile.
+    /// </summary>
+    public class InvokeReferences
+    {
+        /// <summary>Batch identifier.</summary>
+        public string
+#if NET
+            ?
+#endif
+            BatchId { get; set; }
+
+        /// <summary>Reference value 1.</summary>
+        public string
+#if NET
+            ?
+#endif
+            Reference1 { get; set; }
+
+        /// <summary>Reference value 2.</summary>
+        public string
+#if NET
+            ?
+#endif
+            Reference2 { get; set; }
+
+        /// <summary>Reference value 3.</summary>
+        public string
+#if NET
+            ?
+#endif
+            Reference3 { get; set; }
+
+        /// <summary>Reference value 4.</summary>
+        public string
+#if NET
+            ?
+#endif
+            Reference4 { get; set; }
+
+        /// <summary>Reference value 5.</summary>
+        public string
+#if NET
+            ?
+#endif
+            Reference5 { get; set; }
+    }
+}

src/ReC.Client/Api/RecActionApi.cs

@@ -21,14 +21,28 @@ namespace ReC.Client.Api
         /// Invokes a ReC action for the specified profile.
         /// </summary>
         /// <param name="profileId">The profile identifier.</param>
+        /// <param name="references">Optional reference values to pass through to all result records.</param>
         /// <param name="cancellationToken">A token to cancel the operation.</param>
         /// <returns><see langword="true"/> if the request succeeds; otherwise, <see langword="false"/>.</returns>
-        public async Task<bool> InvokeAsync(int profileId, CancellationToken cancellationToken = default)
+        public async Task<bool> InvokeAsync(int profileId, InvokeReferences references, CancellationToken cancellationToken = default)
         {
-            var resp = await Http.PostAsync($"{ResourcePath}/invoke/{profileId}", content: null, cancellationToken);
+            var content = references != null ? ReCClientHelpers.ToJsonContent(references) : null;
+            var resp = await Http.PostAsync($"{ResourcePath}/invoke/{profileId}", content, cancellationToken);
             return resp.IsSuccessStatusCode;
         }
 
+        /// <summary>
+        /// Invokes a ReC action for the specified profile.
+        /// </summary>
+        /// <param name="profileId">The profile identifier.</param>
+        /// <param name="batchId">Batch identifier.</param>
+        /// <param name="cancellationToken">A token to cancel the operation.</param>
+        /// <returns><see langword="true"/> if the request succeeds; otherwise, <see langword="false"/>.</returns>
+        public Task<bool> InvokeAsync(int profileId, string batchId, CancellationToken cancellationToken = default)
+        {
+            return InvokeAsync(profileId, new InvokeReferences() { BatchId = batchId }, cancellationToken);
+        }
+
         /// <summary>
         /// Retrieves Rec actions.
         /// </summary>

src/ReC.Domain/Constants/RecStatus.cs

@@ -0,0 +1,23 @@
+namespace ReC.Domain.Constants;
+
+/// <summary>
+/// Represents the general outcome of an operation, independent of any specific technology or protocol.
+/// <para>
+/// Technology-specific details (e.g., HTTP status codes) are stored separately
+/// in the <c>RESULT_INFO</c> and <c>RESULT_INFO_DETAIL</c> fields.
+/// </para>
+/// </summary>
+/// <seealso cref="RecStatusExtensions"/>
+public enum RecStatus : byte
+{
+    /// <summary>
+    /// Indicates that the operation completed successfully (value 0).
+    /// </summary>
+    OK = 0,
+
+    /// <summary>
+    /// Indicates that the operation failed (value 1).
+    /// When set, the <c>RESULT_ERROR</c> field should contain the error details.
+    /// </summary>
+    Error = 1
+}

src/ReC.Domain/Constants/RecStatusExtensions.cs

@@ -0,0 +1,16 @@
+using System.Net;
+
+namespace ReC.Domain.Constants;
+
+public static class RecStatusExtensions
+{
+    /// <summary>
+    /// Converts an <see cref="HttpStatusCode"/> to a general <see cref="RecStatus"/>
+    /// based on whether the HTTP status represents a success (2xx) or an error.
+    /// </summary>
+    public static RecStatus ToRecStatus(this HttpStatusCode code)
+    {
+        int value = (int)code;
+        return value >= 200 && value <= 299 ? RecStatus.OK : RecStatus.Error;
+    }
+}

src/ReC.Domain/Constants/ResultType.cs

@@ -0,0 +1,8 @@
+namespace ReC.Domain.Constants;
+
+public enum ResultType : byte
+{
+    Pre = 1,
+    Main,
+    Post
+}

src/ReC.Domain/QueryOutput/BodyQueryResult.cs.cs

@@ -1,6 +1,9 @@
-namespace ReC.Domain.QueryOutput;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace ReC.Domain.QueryOutput;
 
 public class BodyQueryResult
 {
+    [Column("REQUEST_BODY")]
     public string? RawBody { get; init; }
 }

src/ReC.Domain/QueryOutput/HeaderQueryResult.cs

@@ -1,6 +1,9 @@
-namespace ReC.Domain.QueryOutput;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace ReC.Domain.QueryOutput;
 
 public class HeaderQueryResult
 {
+    [Column("REQUEST_HEADER")]
     public string? RawHeader { get; init; }
 }

src/ReC.Domain/QueryOutput/InsertObjectResult.cs

@@ -4,5 +4,6 @@ namespace ReC.Domain.QueryOutput;
 
 public class InsertObjectResult
 {
+    [Column("oGUID")]
     public required long NewObjectId { get; set; }
 }

src/ReC.Domain/Views/ProfileView.cs

@@ -1,4 +1,5 @@
 using ReC.Domain.Constants;
+using System.ComponentModel.DataAnnotations;
 using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Views;
@@ -8,39 +9,58 @@ public record ProfileView
 {
     public virtual IEnumerable<RecActionView>? Actions { get; init; }
 
+    [Key]
+    [Column("PROFILE_GUID")]
     public long Id { get; init; }
-    
+
+    [Column("ACTIVE")]
     public bool Active { get; init; }
-    
+
+    [Column("TYPE_ID")]
     public ProfileType TypeId { get; init; }
-    
+
+    [Column("TYPE")]
     public string? Type { get; init; }
-    
+
+    [Column("MANDANTOR")]
     public string? Mandantor { get; init; }
 
+    [Column("PROFILE_NAME")]
     public string? ProfileName { get; init; }
 
+    [Column("DESCRIPTION")]
     public string? Description { get; init; }
 
+    [Column("LOG_LEVEL_ID")]
     public byte LogLevelId { get; init; }
 
+    [Column("LOG_LEVEL")]
     public string? LogLevel { get; init; }
 
+    [Column("LANGUAGE_ID")]
     public short LanguageId { get; init; }
 
+    [Column("LANGUAGE")]
     public string? Language { get; init; }
 
+    [Column("ADDED_WHO")]
     public string? AddedWho { get; init; }
 
+    [Column("ADDED_WHEN")]
     public DateTime AddedWhen { get; init; }
 
+    [Column("CHANGED_WHO")]
     public string? ChangedWho { get; init; }
 
+    [Column("CHANGED_WHEN")]
     public DateTime? ChangedWhen { get; init; }
 
+    [Column("FIRST_RUN")]
     public DateTime? FirstRun { get; init; }
 
+    [Column("LAST_RUN")]
     public DateTime? LastRun { get; init; }
 
+    [Column("LAST_RESULT")]
     public string? LastResult { get; init; }
 }

src/ReC.Domain/Views/RecActionView.cs

@@ -1,4 +1,5 @@
 using ReC.Domain.Constants;
+using System.ComponentModel.DataAnnotations;
 using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Views;
@@ -16,72 +17,109 @@ public class RecActionView
 {
     public virtual IEnumerable<ResultView>? Results { get; set; }
 
+    [Key]
+    [Column("ACTION_GUID")]
     public required long Id { get; set; }
 
+    [Column("PROFILE_ID")]
     public long? ProfileId { get; set; }
 
     [ForeignKey("ProfileId")]
     public ProfileView? Profile { get; set; }
 
+    [Column("PROFILE_NAME")]
     public string? ProfileName { get; set; }
 
+    [Column("PROFILE_TYPE_ID")]
     public ProfileType? ProfileType { get; set; }
 
+    [Column("PROFILE_TYPE")]
+    public string? ProfileTypeName { get; set; }
+
+    [Column("SEQUENCE")]
     public byte? Sequence { get; set; }
 
+    [Column("ENDPOINT_ID")]
     public long? EndpointId { get; set; }
 
+    [Column("ENDPOINT_URI")]
     public string? EndpointUri { get; set; }
 
+    [Column("ENDPOINT_AUTH_ID")]
     public long? EndpointAuthId { get; set; }
 
+    [Column("ENDPOINT_AUTH_TYPE_ID")]
     public EndpointAuthType? EndpointAuthType { get; set; }
 
+    [Column("ENDPOINT_AUTH_TYPE")]
     public string? EndpointAuthTypeName { get; set; }
 
+    [Column("ENDPOINT_AUTH_API_KEY")]
     public string? EndpointAuthApiKey { get; set; }
 
+    [Column("ENDPOINT_AUTH_API_VALUE")]
     public string? EndpointAuthApiValue { get; set; }
 
+    [Column("ENDPOINT_AUTH_API_KEY_ADD_TO_ID")]
     public ApiKeyLocation? EndpointAuthApiKeyAddTo { get; set; }
 
+    [Column("ENDPOINT_AUTH_API_KEY_ADD_TO")]
     public string? EndpointAuthApiKeyAddToName { get; set; }
 
+    [Column("ENDPOINT_AUTH_TOKEN")]
     public string? EndpointAuthToken { get; set; }
 
+    [Column("ENDPOINT_AUTH_USERNAME")]
     public string? EndpointAuthUsername { get; set; }
 
+    [Column("ENDPOINT_AUTH_PASSWORD")]
     public string? EndpointAuthPassword { get; set; }
 
+    [Column("ENDPOINT_AUTH_DOMAIN")]
     public string? EndpointAuthDomain { get; set; }
 
+    [Column("ENDPOINT_AUTH_WORKSTATION")]
     public string? EndpointAuthWorkstation { get; set; }
 
+    [Column("ENDPOINT_PARAMS_ID")]
     public short? EndpointParamsId { get; set; }
 
+    [Column("SQL_CONNECTION_ID")]
     public short? SqlConnectionId { get; set; }
 
+    [Column("SQL_CONNECTION_SERVER")]
     public string? SqlConnectionServer { get; set; }
 
+    [Column("SQL_CONNECTION_DB")]
     public string? SqlConnectionDb { get; set; }
 
+    [Column("SQL_CONNECTION_USERNAME")]
     public string? SqlConnectionUsername { get; set; }
 
+    [Column("SQL_CONNECTION_PASSWORD")]
     public string? SqlConnectionPassword { get; set; }
 
+    [Column("REST_TYPE_ID")]
     public RestType? RestType { get; set; }
 
+    [Column("REST_TYPE")]
     public string? RestTypeName { get; set; }
 
+    [Column("PREPROCESSING_QUERY")]
     public string? PreprocessingQuery { get; set; }
 
+    [Column("HEADER_QUERY")]
     public string? HeaderQuery { get; set; }
 
+    [Column("BODY_QUERY")]
     public string? BodyQuery { get; set; }
 
+    [Column("POSTPROCESSING_QUERY")]
     public string? PostprocessingQuery { get; set; }
 
+    [Column("ERROR_ACTION_ID")]
     public ErrorAction? ErrorAction { get; set; }
 
+    [Column("ERROR_ACTION")]
     public string? ErrorActionName { get; set; }
 }

src/ReC.Domain/Views/ResultView.cs

@@ -1,39 +1,86 @@
-using System.ComponentModel.DataAnnotations.Schema;
+using ReC.Domain.Constants;
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Views;
 
 [Table("VWREC_RESULT", Schema = "dbo")]
 public class ResultView
 {
+    [Key]
+    [Column("RESULT_GUID")]
     public long Id { get; set; }
 
+    [Column("ACTION_ID")]
     public long? ActionId { get; set; }
 
     public RecActionView? Action { get; set; }
 
+    [Column("PROFILE_ID")]
     public long? ProfileId { get; set; }
 
     public ProfileView? Profile { get; set; }
 
+    [Column("PROFILE_NAME")]
     public string? ProfileName { get; set; }
 
-    public short? StatusCode { get; set; }
+    [Column("STATUS_ID")]
+    public RecStatus Status { get; set; }
 
+    [Column("STATUS")]
     public string? StatusName { get; set; }
 
+    [Column("RESULT_TYPE_ID")]
+    public ResultType? Type { get; set; }
+
+    [Column("RESULT_TYPE")]
+    public string? TypeName { get; set; }
+
+    [Column("RESULT_HEADER")]
     public string? Header { get; set; }
 
+    [Column("RESULT_BODY")]
     public string? Body { get; set; }
 
+    [Column("RESULT_INFO_ID")]
+    public short? InfoId { get; set; }
+
+    [Column("RESULT_INFO")]
     public string? Info { get; set; }
 
+    [Column("RESULT_INFO_DETAIL")]
+    public string? InfoDetail { get; set; }
+
+    [Column("RESULT_ERROR")]
     public string? Error { get; set; }
 
+    [Column("BATCH_ID")]
+    public string? BatchId { get; set; }
+
+    [Column("REFERENCE1")]
+    public string? Reference1 { get; set; }
+
+    [Column("REFERENCE2")]
+    public string? Reference2 { get; set; }
+
+    [Column("REFERENCE3")]
+    public string? Reference3 { get; set; }
+
+    [Column("REFERENCE4")]
+    public string? Reference4 { get; set; }
+
+    [Column("REFERENCE5")]
+    public string? Reference5 { get; set; }
+
+    [Column("ADDED_WHO")]
     public string? AddedWho { get; set; }
 
+    [Column("ADDED_WHEN")]
     public DateTime? AddedWhen { get; set; }
 
+    [Column("CHANGED_WHO")]
     public string? ChangedWho { get; set; }
 
+    [Column("CHANGED_WHEN")]
     public DateTime? ChangedWhen { get; set; }
 }

src/ReC.Infrastructure/DependencyInjection.cs

@@ -29,7 +29,7 @@ public static class DependencyInjection
             opt.RegisterDefaultRepository<TRecDbContext>();
         });
 
-        services.AddValidatorsFromAssembly(typeof(AuthScopedValidator).Assembly);
+        services.AddValidatorsFromAssembly(typeof(InsertObjectProcedureValidator).Assembly);
 
         return services;
     }

src/ReC.Infrastructure/Exceptions/DbModelConfigurationException.cs

@@ -1,12 +0,0 @@
-namespace ReC.Infrastructure.Exceptions;
-
-public class DbModelConfigurationException : Exception
-{
-    public DbModelConfigurationException(string message) : base(message)
-    {
-    }
-
-    public DbModelConfigurationException()
-    {
-    }
-}

src/ReC.Infrastructure/Options/DbModelOptions.cs

@@ -1,23 +0,0 @@
-using ReC.Infrastructure.Exceptions;
-using ReC.Infrastructure.Options.Shared;
-
-namespace ReC.Infrastructure.Options;
-
-public record DbModelOptions
-{
-    public Dictionary<string, EntityOptions> Entities { get; init; } = [];
-
-    public Dictionary<string, VirtualEntityOptions> VirtualEntities { get; init; } = [];
-
-    public void EnsureEntity<T>(bool isVirtual)
-    {
-        var entities = isVirtual
-            ? VirtualEntities.ToDictionary(kvp => kvp.Key, kvp => kvp.Value as EntityBaseOptions)
-            : Entities.ToDictionary(kvp => kvp.Key, kvp => kvp.Value as EntityBaseOptions);
-
-        if(entities.TryGetValue(nameof(T), out var entityOptions))
-            entityOptions.EnsureProperties<T>();
-        else
-            throw new DbModelConfigurationException($"Entity options for type '{typeof(T).FullName}' not found.");
-    }
-}

src/ReC.Infrastructure/Options/Shared/EntityBaseOptions.cs

@@ -1,33 +0,0 @@
-using ReC.Domain.Attributes;
-using ReC.Infrastructure.Exceptions;
-
-namespace ReC.Infrastructure.Options.Shared;
-
-public record EntityBaseOptions()
-{
-    public Dictionary<string, string> ColumnMappings { get; init; } = [];
-
-    public IEnumerable<string> PropertyNames => ColumnMappings.Select(col => col.Key);
-
-    public IEnumerable<string> ColumnNames => ColumnMappings.Select(col => col.Value);
-
-    public void EnsureProperties(IEnumerable<string> propertyNames)
-    {
-        var missingProperties = propertyNames.Except(PropertyNames).ToList();
-
-        if (missingProperties.Count != 0)
-            throw new DbModelConfigurationException($"The following properties are not configured: {string.Join(", ", missingProperties)}");
-    }
-
-    public void EnsureProperties(params string[] propertyNames) 
-        => EnsureProperties(propertyNames.AsEnumerable());
-
-    public void EnsureProperties<T>()
-    {
-        var propertyNames = typeof(T)
-            .GetProperties()
-            .Where(prop => Attribute.IsDefined(prop, typeof(MustConfiguredAttribute)))
-            .Select(prop => prop.Name);
-        EnsureProperties(propertyNames);
-    }
-}

src/ReC.Infrastructure/Options/Shared/EntityOptions.cs

@@ -1,3 +0,0 @@
-namespace ReC.Infrastructure.Options.Shared;
-
-public record EntityOptions(TableOptions Table) : EntityBaseOptions;

src/ReC.Infrastructure/Options/Shared/TableOptions.cs

@@ -1,3 +0,0 @@
-namespace ReC.Infrastructure.Options.Shared;
-
-public record TableOptions(string Name, string? Schema = null);

src/ReC.Infrastructure/Options/Shared/VirtualEntityOptions.cs

@@ -1,3 +0,0 @@
-namespace ReC.Infrastructure.Options.Shared;
-
-public record VirtualEntityOptions : EntityBaseOptions;

src/ReC.Infrastructure/RecDbContext.cs

@@ -21,7 +21,6 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
     public DbSet<InsertObjectResult> RecResults { get; set; }
     #endregion DB Sets
 
-    // TODO: Update to configure via appsettings.json
     protected override void OnModelCreating(ModelBuilder modelBuilder)
     {
         base.OnModelCreating(modelBuilder);
@@ -29,41 +28,6 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
         modelBuilder.Entity<RecActionView>(b =>
         {
             b.ToView("VWREC_ACTION", "dbo");
-            b.HasKey(e => e.Id);
-
-            b.Property(e => e.Id).HasColumnName("ACTION_GUID");
-            b.Property(e => e.ProfileId).HasColumnName("PROFILE_ID");
-            b.Property(e => e.ProfileName).HasColumnName("PROFILE_NAME");
-            b.Property(e => e.ProfileType).HasColumnName("PROFILE_TYPE_ID");
-            b.Property(e => e.Sequence).HasColumnName("SEQUENCE");
-            b.Property(e => e.EndpointId).HasColumnName("ENDPOINT_ID");
-            b.Property(e => e.EndpointUri).HasColumnName("ENDPOINT_URI");
-            b.Property(e => e.EndpointAuthId).HasColumnName("ENDPOINT_AUTH_ID");
-            b.Property(e => e.EndpointAuthType).HasColumnName("ENDPOINT_AUTH_TYPE_ID");
-            b.Property(e => e.EndpointAuthTypeName).HasColumnName("ENDPOINT_AUTH_TYPE");
-            b.Property(e => e.EndpointAuthApiKey).HasColumnName("ENDPOINT_AUTH_API_KEY");
-            b.Property(e => e.EndpointAuthApiValue).HasColumnName("ENDPOINT_AUTH_API_VALUE");
-            b.Property(e => e.EndpointAuthApiKeyAddTo).HasColumnName("ENDPOINT_AUTH_API_KEY_ADD_TO_ID");
-            b.Property(e => e.EndpointAuthApiKeyAddToName).HasColumnName("ENDPOINT_AUTH_API_KEY_ADD_TO");
-            b.Property(e => e.EndpointAuthToken).HasColumnName("ENDPOINT_AUTH_TOKEN");
-            b.Property(e => e.EndpointAuthUsername).HasColumnName("ENDPOINT_AUTH_USERNAME");
-            b.Property(e => e.EndpointAuthPassword).HasColumnName("ENDPOINT_AUTH_PASSWORD");
-            b.Property(e => e.EndpointAuthDomain).HasColumnName("ENDPOINT_AUTH_DOMAIN");
-            b.Property(e => e.EndpointAuthWorkstation).HasColumnName("ENDPOINT_AUTH_WORKSTATION");
-            b.Property(e => e.EndpointParamsId).HasColumnName("ENDPOINT_PARAMS_ID");
-            b.Property(e => e.SqlConnectionId).HasColumnName("SQL_CONNECTION_ID");
-            b.Property(e => e.SqlConnectionServer).HasColumnName("SQL_CONNECTION_SERVER");
-            b.Property(e => e.SqlConnectionDb).HasColumnName("SQL_CONNECTION_DB");
-            b.Property(e => e.SqlConnectionUsername).HasColumnName("SQL_CONNECTION_USERNAME");
-            b.Property(e => e.SqlConnectionPassword).HasColumnName("SQL_CONNECTION_PASSWORD");
-            b.Property(e => e.RestType).HasColumnName("REST_TYPE_ID");
-            b.Property(e => e.RestTypeName).HasColumnName("REST_TYPE");
-            b.Property(e => e.PreprocessingQuery).HasColumnName("PREPROCESSING_QUERY");
-            b.Property(e => e.HeaderQuery).HasColumnName("HEADER_QUERY");
-            b.Property(e => e.BodyQuery).HasColumnName("BODY_QUERY");
-            b.Property(e => e.PostprocessingQuery).HasColumnName("POSTPROCESSING_QUERY");
-            b.Property(e => e.ErrorAction).HasColumnName("ERROR_ACTION_ID");
-            b.Property(e => e.ErrorActionName).HasColumnName("ERROR_ACTION");
 
             b.HasMany(e => e.Results)
                 .WithOne(r => r.Action)
@@ -73,46 +37,11 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
         modelBuilder.Entity<ProfileView>(b =>
         {
             b.ToView("VWREC_PROFILE", "dbo");
-            b.HasKey(e => e.Id);
-            b.Property(e => e.Id).HasColumnName("PROFILE_GUID");
-            b.Property(e => e.Active).HasColumnName("ACTIVE");
-            b.Property(e => e.TypeId).HasColumnName("TYPE_ID");
-            b.Property(e => e.Type).HasColumnName("TYPE");
-            b.Property(e => e.Mandantor).HasColumnName("MANDANTOR");
-            b.Property(e => e.ProfileName).HasColumnName("PROFILE_NAME");
-            b.Property(e => e.Description).HasColumnName("DESCRIPTION");
-            b.Property(e => e.LogLevelId).HasColumnName("LOG_LEVEL_ID");
-            b.Property(e => e.LogLevel).HasColumnName("LOG_LEVEL");
-            b.Property(e => e.LanguageId).HasColumnName("LANGUAGE_ID");
-            b.Property(e => e.Language).HasColumnName("LANGUAGE");
-            b.Property(e => e.AddedWho).HasColumnName("ADDED_WHO");
-            b.Property(e => e.AddedWhen).HasColumnName("ADDED_WHEN");
-            b.Property(e => e.ChangedWho).HasColumnName("CHANGED_WHO");
-            b.Property(e => e.ChangedWhen).HasColumnName("CHANGED_WHEN");
-            b.Property(e => e.FirstRun).HasColumnName("FIRST_RUN");
-            b.Property(e => e.LastRun).HasColumnName("LAST_RUN");
-            b.Property(e => e.LastResult).HasColumnName("LAST_RESULT");
         });
 
         modelBuilder.Entity<ResultView>(b =>
         {
             b.ToView("VWREC_RESULT", "dbo");
-            b.HasKey(e => e.Id);
-
-            b.Property(e => e.Id).HasColumnName("RESULT_GUID");
-            b.Property(e => e.ActionId).HasColumnName("ACTION_ID");
-            b.Property(e => e.ProfileId).HasColumnName("PROFILE_ID");
-            b.Property(e => e.ProfileName).HasColumnName("PROFILE_NAME");
-            b.Property(e => e.StatusCode).HasColumnName("STATUS_ID");
-            b.Property(e => e.StatusName).HasColumnName("STATUS");
-            b.Property(e => e.Header).HasColumnName("RESULT_HEADER");
-            b.Property(e => e.Body).HasColumnName("RESULT_BODY");
-            b.Property(e => e.Info).HasColumnName("RESULT_INFO");
-            b.Property(e => e.Error).HasColumnName("RESULT_ERROR");
-            b.Property(e => e.AddedWho).HasColumnName("ADDED_WHO");
-            b.Property(e => e.AddedWhen).HasColumnName("ADDED_WHEN");
-            b.Property(e => e.ChangedWho).HasColumnName("CHANGED_WHO");
-            b.Property(e => e.ChangedWhen).HasColumnName("CHANGED_WHEN");
 
             b.HasOne(r => r.Action)
                 .WithMany(a => a.Results)
@@ -126,19 +55,16 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
         modelBuilder.Entity<HeaderQueryResult>(b =>
         {
             b.HasNoKey();
-            b.Property(e => e.RawHeader).HasColumnName("REQUEST_HEADER");
         });
 
         modelBuilder.Entity<BodyQueryResult>(b =>
         {
             b.HasNoKey();
-            b.Property(e => e.RawBody).HasColumnName("REQUEST_BODY");
         });
 
         modelBuilder.Entity<InsertObjectResult>(b =>
         {
             b.HasNoKey();
-            b.Property(e => e.NewObjectId).HasColumnName("oGUID");
         });
     }
 }

tests/ReC.Tests/Application/Behaviors/InvokeActionTests.cs

@@ -0,0 +1,250 @@
+using System.ComponentModel.DataAnnotations.Schema;
+using ReC.Application.Common.Dto;
+
+namespace ReC.Tests.Application.Behaviors;
+
+#region Test Models
+
+public class Foo
+{
+    [Column("BAZ")]
+    public int Baz { get; set; }
+
+    [Column("FOO_NAME")]
+    public string FooName { get; set; } = string.Empty;
+}
+
+public class Bar
+{
+    [Column("QUX")]
+    public bool Qux { get; set; }
+
+    [Column("BAR_DATE")]
+    public DateTime BarDate { get; set; }
+}
+
+public class Fuz
+{
+    [Column("QUZ")]
+    public string Quz { get; set; } = string.Empty;
+
+    [Column("FUZ_OFFSET")]
+    public DateTimeOffset FuzOffset { get; set; }
+}
+
+public class NoColumnModel
+{
+    public int Id { get; set; }
+    public string Name { get; set; } = string.Empty;
+}
+
+#endregion
+
+[TestFixture]
+public class InvokeActionTests
+{
+    private Foo _foo = null!;
+    private Bar _bar = null!;
+    private Fuz _fuz = null!;
+
+    [SetUp]
+    public void Setup()
+    {
+        _foo = new Foo { Baz = 2, FooName = "TestFoo" };
+        _bar = new Bar { Qux = true, BarDate = new DateTime(2025, 6, 15, 14, 30, 0) };
+        _fuz = new Fuz { Quz = "QuZ", FuzOffset = new DateTimeOffset(2025, 6, 15, 14, 30, 0, TimeSpan.FromHours(3)) };
+    }
+
+    #region GetValueByColumnName Tests
+
+    [Test]
+    public void GetValueByColumnName_ExistingColumn_ReturnsValue()
+    {
+        var result = _foo.GetValueByColumnName("BAZ");
+        Assert.That(result, Is.EqualTo(2));
+    }
+
+    [Test]
+    public void GetValueByColumnName_NonExistingColumn_ReturnsNull()
+    {
+        var result = _foo.GetValueByColumnName("NON_EXISTING");
+        Assert.That(result, Is.Null);
+    }
+
+    [Test]
+    public void GetValueByColumnName_PropertyNameInsteadOfColumnName_ReturnsNull()
+    {
+        var result = _foo.GetValueByColumnName("Baz");
+        Assert.That(result, Is.Null);
+    }
+
+    [Test]
+    public void GetValueByColumnName_ModelWithoutColumnAttribute_ReturnsNull()
+    {
+        var model = new NoColumnModel { Id = 1, Name = "Test" };
+        var result = model.GetValueByColumnName("Id");
+        Assert.That(result, Is.Null);
+    }
+
+    #endregion
+
+    #region ReplacePlaceholders - Basic Type Tests
+
+    [TestCase("SELECT * FROM T WHERE BAZ = {#INT#BAZ}", "SELECT * FROM T WHERE BAZ = 2")]
+    [TestCase("... WHERE BAZ = {#INT#BAZ}", "... WHERE BAZ = 2")]
+    public void ReplacePlaceholders_IntValue_ReplacesCorrectly(string input, string expected)
+    {
+        var result = input.ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo(expected));
+    }
+
+    [TestCase("SELECT * FROM T WHERE QUX = {#BOOL#QUX}", "SELECT * FROM T WHERE QUX = TRUE")]
+    [TestCase("... WHERE QUX = {#INT#QUX}", "... WHERE QUX = TRUE")]
+    public void ReplacePlaceholders_BoolTrueValue_ReplacesWithTRUE(string input, string expected)
+    {
+        var result = input.ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo(expected));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_BoolFalseValue_ReplacesWithFALSE()
+    {
+        var bar = new Bar { Qux = false };
+        var result = "WHERE QUX = {#BOOL#QUX}".ReplacePlaceholders(bar);
+        Assert.That(result, Is.EqualTo("WHERE QUX = FALSE"));
+    }
+
+    [TestCase("... WHERE QUZ <> '{#STR#QUZ}'", "... WHERE QUZ <> 'QuZ'")]
+    [TestCase("SELECT * FROM T WHERE QUZ = '{#TEXT#QUZ}'", "SELECT * FROM T WHERE QUZ = 'QuZ'")]
+    public void ReplacePlaceholders_StringValue_ReplacesCorrectly(string input, string expected)
+    {
+        var result = input.ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo(expected));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_DateTimeValue_FormatsAsSqlDateTime()
+    {
+        var result = "WHERE D = '{#DATE#BAR_DATE}'".ReplacePlaceholders(_bar);
+        Assert.That(result, Is.EqualTo("WHERE D = '2025-06-15 14:30:00'"));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_DateTimeOffsetValue_FormatsWithOffset()
+    {
+        var result = "WHERE D = '{#DTO#FUZ_OFFSET}'".ReplacePlaceholders(_fuz);
+        Assert.That(result, Is.EqualTo("WHERE D = '2025-06-15 14:30:00 +03:00'"));
+    }
+
+    #endregion
+
+    #region ReplacePlaceholders - Multiple Placeholders
+
+    [Test]
+    public void ReplacePlaceholders_MultiplePlaceholdersInSameString_ReplacesAll()
+    {
+        var input = "WHERE BAZ = {#INT#BAZ} AND QUX = {#BOOL#QUX} AND QUZ = '{#STR#QUZ}'";
+        var expected = "WHERE BAZ = 2 AND QUX = TRUE AND QUZ = 'QuZ'";
+
+        var result = input.ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo(expected));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_SamePlaceholderTwice_ReplacesBoth()
+    {
+        var input = "WHERE BAZ = {#INT#BAZ} OR BAZ = {#INT#BAZ}";
+        var expected = "WHERE BAZ = 2 OR BAZ = 2";
+
+        var result = input.ReplacePlaceholders(_foo);
+        Assert.That(result, Is.EqualTo(expected));
+    }
+
+    #endregion
+
+    #region ReplacePlaceholders - Object Resolution Order
+
+    [Test]
+    public void ReplacePlaceholders_ValueFoundInSecondObject_ReturnsValueFromSecondObject()
+    {
+        var result = "WHERE QUX = {#BOOL#QUX}".ReplacePlaceholders(_foo, _bar);
+        Assert.That(result, Is.EqualTo("WHERE QUX = TRUE"));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_ValueFoundInThirdObject_ReturnsValueFromThirdObject()
+    {
+        var result = "WHERE QUZ = '{#STR#QUZ}'".ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo("WHERE QUZ = 'QuZ'"));
+    }
+
+    #endregion
+
+    #region ReplacePlaceholders - No Placeholder
+
+    [TestCase("SELECT * FROM T WHERE X = 1")]
+    [TestCase("")]
+    [TestCase("some random text")]
+    public void ReplacePlaceholders_NoPlaceholders_ReturnsOriginalString(string input)
+    {
+        var result = input.ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo(input));
+    }
+
+    #endregion
+
+    #region ReplacePlaceholders - Different Prefix Strings
+
+    [TestCase("WHERE BAZ = {#VAR#BAZ}", "WHERE BAZ = 2")]
+    [TestCase("WHERE BAZ = {#PARAM#BAZ}", "WHERE BAZ = 2")]
+    [TestCase("WHERE BAZ = {#X#BAZ}", "WHERE BAZ = 2")]
+    [TestCase("WHERE BAZ = {#SOME_LONG_PREFIX#BAZ}", "WHERE BAZ = 2")]
+    public void ReplacePlaceholders_DifferentPrefixes_AllResolveCorrectly(string input, string expected)
+    {
+        var result = input.ReplacePlaceholders(_foo);
+        Assert.That(result, Is.EqualTo(expected));
+    }
+
+    #endregion
+
+    #region ReplacePlaceholders - Exception Tests
+
+    [Test]
+    public void ReplacePlaceholders_UnresolvableColumn_ReturnsNull()
+    {
+        var input = "WHERE X = {#INT#NON_EXISTING}";
+
+        var result = input.ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo("WHERE X = NULL"));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_NoObjectsProvided_ReturnsNull()
+    {
+        var input = "WHERE X = {#INT#BAZ}";
+
+        var result = input.ReplacePlaceholders();
+        Assert.That(result, Is.EqualTo("WHERE X = NULL"));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_ObjectWithoutColumnAttributes_ReturnsNull()
+    {
+        var model = new NoColumnModel { Id = 1, Name = "Test" };
+        var input = "WHERE X = {#INT#Id}";
+
+        var result = input.ReplacePlaceholders(model);
+        Assert.That(result, Is.EqualTo("WHERE X = NULL"));
+    }
+
+    [Test]
+    public void ReplacePlaceholders_MixedResolvableAndUnresolvable_ReturnsNullForUnresolvable()
+    {
+        var input = "WHERE BAZ = {#INT#BAZ} AND X = {#INT#UNKNOWN}";
+
+        var result = input.ReplacePlaceholders(_foo, _bar, _fuz);
+        Assert.That(result, Is.EqualTo("WHERE BAZ = 2 AND X = NULL"));
+    }
+
+    #endregion
+}

tests/ReC.Tests/Application/RecActions/InvokeBatchDuplicateGuardTests.cs

@@ -0,0 +1,87 @@
+using System.Linq;
+using System.Threading.Tasks;
+using FluentValidation;
+using MediatR;
+using Microsoft.Extensions.DependencyInjection;
+using NUnit.Framework;
+using ReC.Application.RecActions.Commands;
+using ReC.Application.Results.Queries;
+
+namespace ReC.Tests.Application.RecActions;
+
+[TestFixture]
+public class InvokeBatchDuplicateGuardTests : RecApplicationTestBase
+{
+    private const long ProfileId = 3;
+
+    private (ISender Sender, IServiceScope Scope) CreateScopedSender()
+    {
+        var scope = ServiceProvider.CreateScope();
+        var sender = scope.ServiceProvider.GetRequiredService<ISender>();
+        return (sender, scope);
+    }
+
+    [Test]
+    public async Task Invoke_with_existing_batchId_throws_ValidationException()
+    {
+        var (sender, scope) = CreateScopedSender();
+        using var _ = scope;
+
+        // Arrange: read an existing result to get a real BatchId from the database
+        var results = await sender.Send(new ReadResultViewQuery
+        {
+            ProfileId = ProfileId,
+            IncludeAction = false,
+            LastBatch = true
+        });
+
+        var existingBatchId = results.FirstOrDefault()?.BatchId;
+        Assert.That(existingBatchId, Is.Not.Null.And.Not.Empty,
+            $"No results with a BatchId found for ProfileId {ProfileId}. Ensure test data exists in the database.");
+
+        // Act & Assert: invoking with the same BatchId should throw ValidationException
+        var ex = Assert.ThrowsAsync<ValidationException>(async () =>
+            await sender.Send(new InvokeBatchRecActionViewsCommand
+            {
+                ProfileId = ProfileId,
+                References = new InvokeReferences
+                {
+                    BatchId = existingBatchId!
+                }
+            }));
+
+        Assert.That(ex!.Errors.Any(e => e.PropertyName.Contains("BatchId")));
+    }
+
+    [Test]
+    public void Invoke_with_new_batchId_does_not_throw_duplicate_guard()
+    {
+        var (sender, scope) = CreateScopedSender();
+        using var _ = scope;
+
+        var uniqueBatchId = $"test-{System.Guid.NewGuid():N}";
+
+        // This should NOT throw ValidationException for duplicate BatchId.
+        // It may throw other exceptions (e.g., no actions found, endpoint errors),
+        // but the duplicate guard should pass.
+        try
+        {
+            sender.Send(new InvokeBatchRecActionViewsCommand
+            {
+                ProfileId = ProfileId,
+                References = new InvokeReferences
+                {
+                    BatchId = uniqueBatchId
+                }
+            }).GetAwaiter().GetResult();
+        }
+        catch (ValidationException valEx) when (valEx.Errors.Any(e => e.PropertyName.Contains("BatchId")))
+        {
+            Assert.Fail("Duplicate guard should not trigger for a unique BatchId.");
+        }
+        catch
+        {
+            // Other exceptions (endpoint errors, etc.) are acceptable
+        }
+    }
+}

tests/ReC.Tests/Application/Results/ResultProcedureTests.cs

@@ -1,3 +1,4 @@
+using System.Net;
 using System.Threading.Tasks;
 using MediatR;
 using Microsoft.Extensions.DependencyInjection;
@@ -5,7 +6,9 @@ using NUnit.Framework;
 using ReC.Application.Common.Procedures.DeleteProcedure;
 using ReC.Application.Common.Procedures.InsertProcedure;
 using ReC.Application.Common.Procedures.UpdateProcedure;
+using ReC.Application.RecActions.Commands;
 using ReC.Application.Results.Commands;
+using ReC.Domain.Constants;
 using ReC.Tests.Application;
 
 namespace ReC.Tests.Application.Results;
@@ -23,7 +26,7 @@ public class ResultProcedureTests : RecApplicationTestBase
     [Test]
     public async Task InsertResultProcedure_runs_via_mediator()
     {
-        var procedure = new InsertResultCommand { ActionId = 1, StatusId = 200, Header = "h", Body = "b" };
+        var procedure = new InsertResultCommand { ActionId = 1, Status = HttpStatusCode.OK.ToRecStatus(), Header = "h", Body = "b", Info = 200, Type = ResultType.Main, References = new () { BatchId = DateTime.Now.ToString() } };
 
         var (sender, scope) = CreateScopedSender();
         using var _ = scope;