Merge branch 'master' of http://git.dd:3000/AppStd/ReC

Updated <Version>, <AssemblyVersion>, <FileVersion>, and <InformationalVersion> fields in the project file from 1.0.2-beta to 1.0.3-beta. No other changes were made.

src/ReC.API/Controllers/OutResController.cs

@@ -1,6 +1,7 @@
 using MediatR;
 using Microsoft.AspNetCore.Mvc;
 using ReC.API.Extensions;
+using ReC.Application.OutResults.Commands;
 using ReC.Application.OutResults.Queries;
 
 namespace ReC.API.Controllers;
@@ -55,6 +56,34 @@ public class OutResController(IMediator mediator, IConfiguration config) : Contr
             _ => Ok(res),
         };
     }
+    
+    /// <summary>
+    /// Deletes output results based on the provided criteria.
+    /// </summary>
+    /// <param name="command">The command containing the deletion criteria, such as ActionId or ProfileId.</param>
+    /// <param name="cancel">A token to cancel the operation.</param>
+    /// <returns>An empty response indicating success.</returns>
+    [HttpDelete]
+    [ProducesResponseType(StatusCodes.Status204NoContent)]
+    public async Task<IActionResult> Delete([FromQuery] DeleteOutResCommand command, CancellationToken cancel)
+    {
+        await mediator.Send(command, cancel);
+        return NoContent();
+    }
+
+    /// <summary>
+    /// Deletes all output results for a fake/test profile.
+    /// </summary>
+    /// <param name="cancel">A token to cancel the operation.</param>
+    /// <returns>An empty response indicating success.</returns>
+    [HttpDelete("fake")]
+    [ProducesResponseType(StatusCodes.Status204NoContent)]
+    [ProducesResponseType(StatusCodes.Status400BadRequest)]
+    public async Task<IActionResult> Delete(CancellationToken cancel)
+    {
+        await mediator.Send(new DeleteOutResCommand() { ProfileId = config.GetFakeProfileId() }, cancel);
+        return NoContent();
+    }
 }
 
 /// <summary>

src/ReC.API/Controllers/RecActionController.cs

@@ -18,7 +18,7 @@ public class RecActionController(IMediator mediator, IConfiguration config) : Co
     /// <param name="profileId">The ID of the profile.</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/{cmd}")]
+    [HttpPost("invoke/{profileId}")]
     [ProducesResponseType(StatusCodes.Status202Accepted)]
     public async Task<IActionResult> Invoke([FromRoute] int profileId, CancellationToken cancel)
     {
@@ -43,7 +43,7 @@ public class RecActionController(IMediator mediator, IConfiguration config) : Co
     /// <summary>
     /// Gets all RecActions for a given profile.
     /// </summary>
-    /// <param name="profileId">The ID of the profile.</param>
+    /// <param name="query"></param>
     /// <param name="cancel">A token to cancel the operation.</param>
     /// <returns>A list of RecActions for the specified profile.</returns>
     [HttpGet]

src/ReC.API/Program.cs

@@ -1,9 +1,11 @@
+using Microsoft.AspNetCore.Rewrite;
 using Microsoft.EntityFrameworkCore;
 using NLog;
 using NLog.Web;
 using ReC.API.Middleware;
 using ReC.Application;
 using ReC.Infrastructure;
+using System.Reflection;
 using LogLevel = Microsoft.Extensions.Logging.LogLevel;
 
 var logger = LogManager.Setup().LoadConfigurationFromAppSettings().GetCurrentClassLogger();
@@ -48,7 +50,12 @@ try
     builder.Services.AddControllers();
     // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
     builder.Services.AddEndpointsApiExplorer();
-    builder.Services.AddSwaggerGen();
+    builder.Services.AddSwaggerGen(c =>
+    {
+        var xmlFile = $"{Assembly.GetExecutingAssembly().GetName().Name}.xml";
+        var xmlPath = Path.Combine(AppContext.BaseDirectory, xmlFile);
+        c.IncludeXmlComments(xmlPath);
+    });
 
     var app = builder.Build();
 
@@ -57,10 +64,13 @@ try
 #pragma warning restore CS0618
 
     // Configure the HTTP request pipeline.
-    if (app.Environment.IsDevelopment())
+    if (app.Environment.IsDevelopment() || config.GetValue<bool>("UseSwagger"))
     {
         app.UseSwagger();
         app.UseSwaggerUI();
+
+        var rewriteOptions = new RewriteOptions().AddRedirect("^$", "swagger");
+        app.UseRewriter(rewriteOptions);
     }
 
     app.UseHttpsRedirection();

src/ReC.API/ReC.API.csproj

@@ -10,13 +10,15 @@
 	<Product>ReC.API</Product>
 	<PackageIcon>Assets\icon.ico</PackageIcon>
 	<PackageTags>digital data rest-caller rec api</PackageTags>
-	<Version>1.0.0-beta</Version>
-    <AssemblyVersion>1.0.0.0</AssemblyVersion>
-    <FileVersion>1.0.0.0</FileVersion>
-    <InformationalVersion>1.0.0-beta</InformationalVersion>
+	<Version>1.0.3-beta</Version>
+	<AssemblyVersion>1.0.3.0</AssemblyVersion>
+	<FileVersion>1.0.3.0</FileVersion>
+	<InformationalVersion>1.0.3-beta</InformationalVersion>
 	<Copyright>Copyright © 2025 Digital Data GmbH. All rights reserved.</Copyright>
+    <GenerateDocumentationFile>true</GenerateDocumentationFile>
+    <NoWarn>$(NoWarn);1591</NoWarn>
   </PropertyGroup>
-
+		
   <ItemGroup>
     <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="9.0.11" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />  

src/ReC.API/appsettings.json

@@ -5,6 +5,7 @@
       "Microsoft.AspNetCore": "Warning"
     }
   },
+  "UseSwagger": true,
   "ConnectionStrings": {
     "Default": "Server=SDD-VMP04-SQL19\\DD_DEVELOP01;Database=DD_ECM;User Id=sa;Password=dd;Encrypt=false;TrustServerCertificate=True;"
   },

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

@@ -62,6 +62,8 @@ public record RecActionDto
 
     public string? PostprocessingQuery { get; init; }
 
+    public string? ErrorAction { get; init; }
+
     public UriBuilder ToEndpointUriBuilder()
     {
         var builder = EndpointUri is null ? new UriBuilder() : new UriBuilder(EndpointUri);

src/ReC.Application/OutResults/Commands/CreateOutResCommand.cs

@@ -8,6 +8,10 @@ public class CreateOutResCommand : IRequest
 {
     public required long ActionId { get; set; }
 
+    public short? Status { get; set; }
+
+    public string? Message { get; set; }
+
     public string? Header { get; set; }
 
     public string? Body { get; set; }

src/ReC.Application/OutResults/Commands/DeleteOutResCommand.cs

@@ -0,0 +1,46 @@
+using DigitalData.Core.Abstraction.Application.Repository;
+using MediatR;
+using ReC.Domain.Entities;
+
+namespace ReC.Application.OutResults.Commands;
+
+/// <summary>
+/// Represents the command to delete output results based on specified criteria.
+/// </summary>
+/// <remarks>
+/// Deletion can be performed by providing either an <see cref="ActionId"/> or a <see cref="ProfileId"/>.
+/// At least one of these properties must be set for the operation to proceed.
+/// </remarks>
+public record DeleteOutResCommand : IRequest
+{
+    /// <summary>
+    /// Gets the unique identifier for the action whose output results should be deleted.
+    /// </summary>
+    public long? ActionId { get; init; }
+
+    /// <summary>
+    /// Gets the unique identifier for the profile whose associated action's output results should be deleted.
+    /// </summary>
+    public long? ProfileId { get; init; }
+}
+
+/// <summary>
+/// Handles the execution of the <see cref="DeleteOutResCommand"/>.
+/// </summary>
+public class DeleteOutResCommandHandler(IRepository<OutRes> repo) : IRequestHandler<DeleteOutResCommand>
+{
+    /// <summary>
+    /// Processes the delete command by removing matching <see cref="OutRes"/> entities from the repository.
+    /// </summary>
+    /// <param name="request">The command containing the deletion criteria.</param>
+    /// <param name="cancel">A cancellation token that can be used to cancel the work.</param>
+    /// <returns>A task that represents the asynchronous delete operation.</returns>
+    /// <remarks>
+    /// The handler deletes records where <c>OutRes.ActionId</c> matches <see cref="DeleteOutResCommand.ActionId"/>
+    /// or where the associated <c>Action.ProfileId</c> matches <see cref="DeleteOutResCommand.ProfileId"/>.
+    /// </remarks>
+    public Task Handle(DeleteOutResCommand request, CancellationToken cancel)
+    {
+        return repo.DeleteAsync(x => x.ActionId == request.ActionId || x.Action!.ProfileId == request.ProfileId, cancel);
+    }
+}

src/ReC.Application/OutResults/Commands/DeleteOutResCommandValidator.cs

@@ -0,0 +1,14 @@
+using FluentValidation;
+
+namespace ReC.Application.OutResults.Commands;
+
+public class DeleteOutResCommandValidator : AbstractValidator<DeleteOutResCommand>
+{
+    public DeleteOutResCommandValidator()
+    {
+        RuleFor(x => x)
+            .Must(x => x.ActionId.HasValue || x.ProfileId.HasValue)
+            .WithMessage("At least one of ActionId or ProfileId must be provided.")
+            .WithName("Identifier");
+    }
+}

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

@@ -1,6 +1,4 @@
 using MediatR;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Logging;
 using ReC.Application.RecActions.Queries;
 
 namespace ReC.Application.RecActions.Commands;
@@ -13,40 +11,23 @@ public static class InvokeBatchRecActionsCommandExtensions
         => sender.Send(new InvokeBatchRecActionsCommand { ProfileId = profileId }, cancel);
 }
 
-public class InvokeRecActionsCommandHandler(ISender sender, IServiceScopeFactory scopeFactory, IHttpClientFactory clientFactory, ILogger<InvokeRecActionsCommandHandler>? logger = null) : IRequestHandler<InvokeBatchRecActionsCommand>
+public class InvokeRecActionsCommandHandler(ISender sender) : IRequestHandler<InvokeBatchRecActionsCommand>
 {
     public async Task Handle(InvokeBatchRecActionsCommand request, CancellationToken cancel)
     {
         var actions = await sender.Send(request.ToReadQuery(q => q.Invoked = false), cancel);
 
-        var http = clientFactory.CreateClient();
-
-        using var semaphore = new SemaphoreSlim(5);
-
-        var tasks = actions.Select(async action =>
+        foreach (var action in actions)
         {
-            await semaphore.WaitAsync(cancel);
-            try
-            {
-                using var scope = scopeFactory.CreateScope();
-                var sender = scope.ServiceProvider.GetRequiredService<ISender>();
-                await sender.Send(action.ToInvokeCommand(), cancel);
-            }
-            catch(Exception ex)
-            {
-                logger?.LogError(
-                    ex,
-                    "Error invoking Rec action. ProfileId: {ProfileId}, Id: {Id}",
-                    action.ProfileId,
-                    action.Id
-                );
-            }
-            finally
-            {
-                semaphore.Release();
-            }
-        });
-
-        await Task.WhenAll(tasks);
+            var ok = await sender.Send(action.ToInvokeCommand(), cancel);
+            if (!ok)
+                switch (action.ErrorAction?.ToLowerInvariant())
+                {
+                    case "continue":
+                        break;
+                    default:
+                        return;
+                }
+        }
     }
 }

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

@@ -8,7 +8,7 @@ using System.Text.Json;
 
 namespace ReC.Application.RecActions.Commands;
 
-public record InvokeRecActionCommand : IRequest
+public record InvokeRecActionCommand : IRequest<bool>
 {
     public RecActionDto Action { get; set; } = null!;
 }
@@ -22,9 +22,9 @@ public class InvokeRecActionCommandHandler(
     ISender sender,
     IHttpClientFactory clientFactory,
     IConfiguration? config = null
-    ) : IRequestHandler<InvokeRecActionCommand>
+    ) : IRequestHandler<InvokeRecActionCommand, bool>
 {
-    public async Task Handle(InvokeRecActionCommand request, CancellationToken cancel)
+    public async Task<bool> Handle(InvokeRecActionCommand request, CancellationToken cancel)
     {
         var action = request.Action;
         using var http = clientFactory.CreateClient();
@@ -54,12 +54,17 @@ public class InvokeRecActionCommandHandler(
         var resBody = await response.Content.ReadAsStringAsync(cancel);
         var resHeaders = response.Headers.ToDictionary();
 
+        var statusCode = (short)response.StatusCode;
+
         await sender.Send(new CreateOutResCommand
         {
+            Status = statusCode,
             ActionId = action.Id,
             Header = JsonSerializer.Serialize(resHeaders, options: new() { WriteIndented = false }),
             Body = resBody,
             AddedWho = config?["AddedWho"]
         }, cancel);
+
+        return response.IsSuccessStatusCode;
     }
 }

src/ReC.Domain/Attributes/MustConfiguredAttribute.cs

@@ -0,0 +1,6 @@
+namespace ReC.Domain.Attributes;
+
+[AttributeUsage(AttributeTargets.Property)]
+public class MustConfiguredAttribute : Attribute
+{
+}

src/ReC.Domain/Entities/BodyQueryResult.cs.cs

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

src/ReC.Domain/Entities/Connection.cs

@@ -1,52 +1,32 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+namespace ReC.Domain.Entities;
 
-namespace ReC.Domain.Entities;
-
-[Table("TBDD_CONNECTION")]
 public class Connection
 {
-    [Key]
-    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
-    [Column("GUID")]
     public short? Id { get; set; }
 
-    [Column("BEZEICHNUNG")]
     public string? Bezeichnung { get; set; }
 
-    [Column("SQL_PROVIDER")]
     public string? SqlProvider { get; set; }
 
-    [Column("SERVER")]
     public string? Server { get; set; }
 
-    [Column("DATENBANK")]
     public string? Datenbank { get; set; }
 
-    [Column("USERNAME")]
     public string? Username { get; set; }
 
-    [Column("PASSWORD")]
     public string? Password { get; set; }
 
-    [Column("BEMERKUNG")]
     public string? Bemerkung { get; set; }
 
-    [Column("AKTIV")]
     public bool? Aktiv { get; set; }
 
-    [Column("ERSTELLTWER")]
     public string? ErstelltWer { get; set; }
 
-    [Column("ERSTELLTWANN")]
     public DateTime? ErstelltWann { get; set; }
 
-    [Column("GEANDERTWER")]
     public string? GeandertWer { get; set; }
 
-    [Column("GEAENDERTWANN")]
     public DateTime? GeaendertWann { get; set; }
 
-    [Column("SYS_CONNECTION")]
     public bool? SysConnection { get; set; }
 }

src/ReC.Domain/Entities/Endpoint.cs

@@ -1,34 +1,20 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+namespace ReC.Domain.Entities;
 
-namespace ReC.Domain.Entities;
-
-[Table("TBREC_CFG_ENDPOINT")]
 public class Endpoint
 {
-    [Key]
-    [Column("GUID")]
-    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
     public long Id { get; set; }
 
-    [Column("ACTIVE")]
     public bool? Active { get; set; }
 
-    [Column("DESCRIPTION")]
     public string? Description { get; set; }
 
-    [Column("URI")]
     public string? Uri { 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.Domain/Entities/EndpointAuth.cs

@@ -3,56 +3,37 @@ using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Entities;
 
-[Table("TBREC_CFG_ENDPOINT_AUTH")]
 public class EndpointAuth
 {
-    [Key]
-    [Column("GUID")]
-    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
     public long? Id { get; set; }
 
-    [Column("ACTIVE")]
     public bool? Active { get; set; }
 
-    [Column("DESCRIPTION")]
     public string? Description { get; set; }
 
-    [Column("TYPE")]
     public string? Type { get; set; }
 
-    [Column("API_KEY")]
     public string? ApiKey { get; set; }
 
-    [Column("API_VALUE")]
     public string? ApiValue { get; set; }
 
-    [Column("API_KEY_ADD_TO")]
     public string? ApiKeyAddTo { get; set; }
 
-    [Column("TOKEN")]
     public string? Token { get; set; }
 
-    [Column("USERNAME")]
     public string? Username { get; set; }
 
-    [Column("PASSWORD")]
     public string? Password { get; set; }
 
-    [Column("DOMAIN")]
     public string? Domain { get; set; }
 
-    [Column("WORKSTATION")]
     public string? Workstation { 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.Domain/Entities/EndpointParam.cs

@@ -1,47 +1,31 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace ReC.Domain.Entities;
+namespace ReC.Domain.Entities;
 
 /// <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>
-[Table("TBREC_CFG_ENDPOINT_PARAMS", Schema = "dbo")]
 public class EndpointParam
 {
-    [Key]
-    [Column("GUID")]
     public long? Id { get; set; }
 
-    [Column("ACTIVE")]
     public bool? Active { get; set; }
 
-    [Column("DESCRIPTION")]
     public string? Description { get; set; }
 
-    [Column("GROUP_ID")]
     public short? GroupId { get; set; }
 
-    [Column("SEQUENCE")]
     public byte? Sequence { get; set; }
 
-    [Column("KEY")]
     public string? Key { get; set; }
 
-    [Column("VALUE")]
     public string? Value { 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.Domain/Entities/HeaderQueryResult.cs

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

src/ReC.Domain/Entities/OutRes.cs

@@ -1,37 +1,26 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+namespace ReC.Domain.Entities;
 
-namespace ReC.Domain.Entities;
-
-[Table("TBREC_OUT_RESULT", Schema = "dbo")]
 public class OutRes
 {
-    [Key]
-    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
-    [Column("GUID")]
     public long? Id { get; set; }
     
-    [Column("ACTION_ID")]
     public long? ActionId { get; set; }
 
-    [ForeignKey("ActionId")]
     public RecAction? Action { get; set; }
 
-    [Column("RESULT_HEADER")]
+    public short? Status { get; set; }
+
+    public string? Message { get; set; }
+
     public string? Header { get; set; }
 
-    [Column("RESULT_BODY")]
     public string? Body { 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.Domain/Entities/Profile.cs

@@ -1,46 +1,28 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+namespace ReC.Domain.Entities;
 
-namespace ReC.Domain.Entities;
-
-[Table("TBREC_CFG_PROFILE", Schema = "dbo")]
 public class Profile
 {
-    [Key]
-    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
-    [Column("GUID")]
     public long Id { get; set; }
 
-    [Column("ACTIVE")]
     public bool? Active { get; set; }
 
-    [Column("TYPE")]
     public string? Type { get; set; }
 
-    [Column("MANDANTOR")]
     public string? Mandantor { get; set; }
 
-    [Column("PROFILE_NAME")]
     public string? Name { get; set; }
 
-    [Column("DESCRIPTION")]
     public string? Description { get; set; }
 
-    [Column("LOG_LEVEL")]
     public string? LogLevel { get; set; }
 
-    [Column("LANGUAGE")]
     public string? Language { 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.Domain/Entities/RecAction.cs

@@ -1,73 +1,49 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+namespace ReC.Domain.Entities;
 
-namespace ReC.Domain.Entities;
-
-[Table("TBREC_CFG_ACTION")]
 public class RecAction
 {
-    [Key]
-    [Column("GUID")]
     public long? Id { get; set; }
 
-    [Column("PROFILE_ID")]
     public long? ProfileId { get; set; }
 
-    [ForeignKey("ProfileId")]
     public Profile? Profile { get; set; }
 
-    [Column("ACTIVE")]
     public bool? Active { get; set; }
 
-    [Column("SEQUENCE")]
     public byte? Sequence { get; set; }
 
-    [Column("ENDPOINT_ID")]
     public long? EndpointId { get; set; }
 
-    [ForeignKey("EndpointId")]
     public Endpoint? Endpoint { get; set; }
 
-    [Column("ENDPOINT_AUTH_ID")]
     public long? EndpointAuthId { get; set; }
 
-    [ForeignKey("EndpointAuthId")]
     public EndpointAuth? EndpointAuth { get; set; }
 
-    [Column("ENDPOINT_PARAMS_ID")]
     public short? EndpointParamsId { get; set; }
 
-    [Column("SQL_CONNECTION_ID")]
     public short? SqlConnectionId { get; set; }
 
-    [ForeignKey("SqlConnectionId")]
     public Connection? SqlConnection { get; set; }
 
-    [Column("TYPE")]
     public string? Type { 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("ADDED_WHO")]
+    public string? ErrorAction { get; set; }
+
     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; }
 
     public OutRes? OutRes { get; set; }

src/ReC.Domain/Entities/RecActionView.cs

@@ -11,113 +11,65 @@ namespace ReC.Domain.Entities;
 /// runtime mapping errors and ensures the application can handle schema changes without
 /// requiring immediate code updates.
 /// </summary>
-[Table("VWREC_ACTION", Schema = "dbo")]
 public class RecActionView
 {
-    [Column("ACTION_ID")]
     public required long Id { get; set; }
 
-    [ForeignKey("Id")]
     public RecAction? Root { get; set; }
 
-    [Column("PROFILE_ID")]
     public long? ProfileId { get; set; }
 
-    [ForeignKey("ProfileId")]
     public Profile? Profile { get; set; }
 
-    [Column("PROFILE_NAME")]
-    [MaxLength(100)]
     public string? ProfileName { get; set; }
 
-    [Column("PROFILE_TYPE")]
-    [MaxLength(20)]
     public string? ProfileType { get; set; }
 
-    [Column("PROFILE_SEQUENCE")]
-    public byte? ProfileSequence { get; set; }
+    public byte? Sequence { get; set; }
 
-    [Column("ENDPOINT_ID")]
     public long? EndpointId { get; set; }
 
-    [Column("ENDPOINT_URI")]
-    [MaxLength(4000)]
     public string? EndpointUri { get; set; }
 
-    [Column("ENDPOINT_AUTH_ID")]
     public long? EndpointAuthId { get; set; }
 
-    [Column("ENDPOINT_AUTH_TYPE")]
-    [MaxLength(50)]
     public string? EndpointAuthType { get; set; }
 
-    [Column("ENDPOINT_AUTH_API_KEY")]
-    [MaxLength(300)]
     public string? EndpointAuthApiKey { get; set; }
 
-    [Column("ENDPOINT_AUTH_API_VALUE")]
-    [MaxLength(300)]
     public string? EndpointAuthApiValue { get; set; }
 
-    [Column("ENDPOINT_AUTH_API_KEY_ADD_TO")]
-    [MaxLength(20)]
     public string? EndpointAuthApiKeyAddTo { get; set; }
 
-    [Column("ENDPOINT_AUTH_TOKEN")]
-    [MaxLength(300)]
     public string? EndpointAuthToken { get; set; }
 
-    [Column("ENDPOINT_AUTH_USERNAME")]
-    [MaxLength(200)]
     public string? EndpointAuthUsername { get; set; }
 
-    [Column("ENDPOINT_AUTH_PASSWORD")]
-    [MaxLength(200)]
     public string? EndpointAuthPassword { get; set; }
 
-    [Column("ENDPOINT_AUTH_DOMAIN")]
-    [MaxLength(100)]
     public string? EndpointAuthDomain { get; set; }
 
-    [Column("ENDPOINT_AUTH_WORKSTATION")]
-    [MaxLength(100)]
     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")]
-    [MaxLength(150)]
     public string? SqlConnectionServer { get; set; }
 
-    [Column("SQL_CONNECTION_DB")]
-    [MaxLength(100)]
     public string? SqlConnectionDb { get; set; }
 
-    [Column("SQL_CONNECTION_USERNAME")]
-    [MaxLength(100)]
     public string? SqlConnectionUsername { get; set; }
 
-    [Column("SQL_CONNECTION_PASSWORD")]
-    [MaxLength(100)]
     public string? SqlConnectionPassword { get; set; }
 
-    [Column("REST_TYPE")]
-    [MaxLength(20)]
     public string? RestType { 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; }
 }

src/ReC.Infrastructure/Exceptions/DbModelConfigurationException.cs

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

src/ReC.Infrastructure/Options/DbModelOptions.cs

@@ -0,0 +1,23 @@
+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

@@ -0,0 +1,33 @@
+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

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

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

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

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

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

src/ReC.Infrastructure/RecDbContext.cs

@@ -30,15 +30,217 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
     {
         base.OnModelCreating(modelBuilder);
 
-        modelBuilder.Entity<RecActionView>().HasNoKey();
+        modelBuilder.Entity<Connection>(b =>
+        {
+            b.ToTable("TBDD_CONNECTION");
 
-        modelBuilder.Entity<HeaderQueryResult>().HasNoKey();
+            b.HasKey(e => e.Id);
 
-        modelBuilder.Entity<BodyQueryResult>().HasNoKey();
+            b.Property(e => e.Id)
+                .HasColumnName("GUID")
+                .ValueGeneratedOnAdd();
+
+            b.Property(e => e.Bezeichnung).HasColumnName("BEZEICHNUNG");
+            b.Property(e => e.SqlProvider).HasColumnName("SQL_PROVIDER");
+            b.Property(e => e.Server).HasColumnName("SERVER");
+            b.Property(e => e.Datenbank).HasColumnName("DATENBANK");
+            b.Property(e => e.Username).HasColumnName("USERNAME");
+            b.Property(e => e.Password).HasColumnName("PASSWORD");
+            b.Property(e => e.Bemerkung).HasColumnName("BEMERKUNG");
+            b.Property(e => e.Aktiv).HasColumnName("AKTIV");
+            b.Property(e => e.ErstelltWer).HasColumnName("ERSTELLTWER");
+            b.Property(e => e.ErstelltWann).HasColumnName("ERSTELLTWANN");
+            b.Property(e => e.GeandertWer).HasColumnName("GEANDERTWER");
+            b.Property(e => e.GeaendertWann).HasColumnName("GEAENDERTWANN");
+            b.Property(e => e.SysConnection).HasColumnName("SYS_CONNECTION");
+        });
+
+        modelBuilder.Entity<Endpoint>(b =>
+        {
+            b.ToTable("TBREC_CFG_ENDPOINT");
+
+            b.HasKey(e => e.Id);
+
+            b.Property(e => e.Id)
+                .HasColumnName("GUID")
+                .ValueGeneratedOnAdd();
+
+            b.Property(e => e.Active).HasColumnName("ACTIVE");
+            b.Property(e => e.Description).HasColumnName("DESCRIPTION");
+            b.Property(e => e.Uri).HasColumnName("URI");
+            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");
+        });
+
+        modelBuilder.Entity<EndpointAuth>(b =>
+        {
+            b.ToTable("TBREC_CFG_ENDPOINT_AUTH");
+
+            b.HasKey(e => e.Id);
+
+            b.Property(e => e.Id)
+                .HasColumnName("GUID")
+                .ValueGeneratedOnAdd();
+
+            b.Property(e => e.Active).HasColumnName("ACTIVE");
+            b.Property(e => e.Description).HasColumnName("DESCRIPTION");
+            b.Property(e => e.Type).HasColumnName("TYPE");
+            b.Property(e => e.ApiKey).HasColumnName("API_KEY");
+            b.Property(e => e.ApiValue).HasColumnName("API_VALUE");
+            b.Property(e => e.ApiKeyAddTo).HasColumnName("API_KEY_ADD_TO");
+            b.Property(e => e.Token).HasColumnName("TOKEN");
+            b.Property(e => e.Username).HasColumnName("USERNAME");
+            b.Property(e => e.Password).HasColumnName("PASSWORD");
+            b.Property(e => e.Domain).HasColumnName("DOMAIN");
+            b.Property(e => e.Workstation).HasColumnName("WORKSTATION");
+            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");
+        });
+
+        modelBuilder.Entity<EndpointParam>(b =>
+        {
+            b.ToTable("TBREC_CFG_ENDPOINT_PARAMS", "dbo");
+
+            b.HasKey(e => e.Id);
+
+            b.Property(e => e.Id).HasColumnName("GUID");
+            b.Property(e => e.Active).HasColumnName("ACTIVE");
+            b.Property(e => e.Description).HasColumnName("DESCRIPTION");
+            b.Property(e => e.GroupId).HasColumnName("GROUP_ID");
+            b.Property(e => e.Sequence).HasColumnName("SEQUENCE");
+            b.Property(e => e.Key).HasColumnName("KEY");
+            b.Property(e => e.Value).HasColumnName("VALUE");
+            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");
+        });
+
+        modelBuilder.Entity<OutRes>(b =>
+        {
+            b.ToTable("TBREC_OUT_RESULT", "dbo");
+
+            b.HasKey(e => e.Id);
+
+            b.Property(e => e.Id)
+                .HasColumnName("GUID")
+                .ValueGeneratedOnAdd();
+
+            b.Property(e => e.ActionId).HasColumnName("ACTION_ID");
+            b.Property(e => e.Status).HasColumnName("STATUS");
+            b.Property(e => e.Message).HasColumnName("MESSAGE");
+            b.Property(e => e.Header).HasColumnName("RESULT_HEADER");
+            b.Property(e => e.Body).HasColumnName("RESULT_BODY");
+            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");
+        });
+
+        modelBuilder.Entity<Profile>(b =>
+        {
+            b.ToTable("TBREC_CFG_PROFILE", "dbo");
+
+            b.HasKey(e => e.Id);
+
+            b.Property(e => e.Id)
+                .HasColumnName("GUID")
+                .ValueGeneratedOnAdd();
+
+            b.Property(e => e.Active).HasColumnName("ACTIVE");
+            b.Property(e => e.Type).HasColumnName("TYPE");
+            b.Property(e => e.Mandantor).HasColumnName("MANDANTOR");
+            b.Property(e => e.Name).HasColumnName("PROFILE_NAME");
+            b.Property(e => e.Description).HasColumnName("DESCRIPTION");
+            b.Property(e => e.LogLevel).HasColumnName("LOG_LEVEL");
+            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");
+        });
+
+        modelBuilder.Entity<RecAction>(b =>
+        {
+            b.ToTable("TBREC_CFG_ACTION");
+
+            b.HasKey(e => e.Id);
+
+            b.Property(e => e.Id).HasColumnName("GUID");
+            b.Property(e => e.ProfileId).HasColumnName("PROFILE_ID");
+            b.Property(e => e.Active).HasColumnName("ACTIVE");
+            b.Property(e => e.Sequence).HasColumnName("SEQUENCE");
+            b.Property(e => e.EndpointId).HasColumnName("ENDPOINT_ID");
+            b.Property(e => e.EndpointAuthId).HasColumnName("ENDPOINT_AUTH_ID");
+            b.Property(e => e.EndpointParamsId).HasColumnName("ENDPOINT_PARAMS_ID");
+            b.Property(e => e.SqlConnectionId).HasColumnName("SQL_CONNECTION_ID");
+            b.Property(e => e.Type).HasColumnName("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");
+            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(act => act.OutRes)
+                .WithOne(res => res.Action)
+                .HasForeignKey<OutRes>(res => res.ActionId)
+                .OnDelete(DeleteBehavior.Cascade);
+        });
+
+        modelBuilder.Entity<RecActionView>(b =>
+        {
+            b.ToTable("VWREC_ACTION", "dbo");
+            b.HasNoKey();
+
+            b.Property(e => e.Id).HasColumnName("ACTION_ID");
+            b.Property(e => e.ProfileId).HasColumnName("PROFILE_ID");
+            b.Property(e => e.ProfileName).HasColumnName("PROFILE_NAME");
+            b.Property(e => e.ProfileType).HasColumnName("PROFILE_TYPE");
+            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");
+            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");
+            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");
+            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");
+        });
+
+        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<RecAction>()
-            .HasOne(act => act.OutRes)
-            .WithOne(res => res.Action)
-            .HasForeignKey<OutRes>(res => res.ActionId);
     }
 }