Add ResultViewController for output result retrieval

Introduce ResultViewController with endpoints to fetch output results by query, for fake/test profiles, and by action ID. Supports returning full, header, or body parts of results via a new ViewResultType enum. Utilizes MediatR and configuration injection for flexible and testable result access. Includes XML docs for improved API clarity.

src/ReC.API/Controllers/OutResController.cs

@@ -1,10 +1,12 @@
 using MediatR;
 using Microsoft.AspNetCore.Mvc;
 using ReC.API.Extensions;
+using ReC.Application.OutResults.Commands;
 using ReC.Application.OutResults.Queries;
 
 namespace ReC.API.Controllers;
 
+[Obsolete("This controller is deprecated and will be removed in future versions. Use the new ResultViewController instead.")]
 [Route("api/[controller]")]
 [ApiController]
 public class OutResController(IMediator mediator, IConfiguration config) : ControllerBase
@@ -55,6 +57,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

@@ -3,7 +3,8 @@ using Microsoft.AspNetCore.Mvc;
 using ReC.API.Extensions;
 using ReC.API.Models;
 using ReC.Application.RecActions.Commands;
-using ReC.Application.RecActions.Queries;
+using ReC.Application.RecActionViews.Commands;
+using ReC.Application.RecActionViews.Queries;
 using System.Text.Json;
 
 namespace ReC.API.Controllers;
@@ -18,11 +19,11 @@ 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)
     {
-        await mediator.InvokeBatchRecAction(profileId, cancel);
+        await mediator.InvokeBatchRecActionView(profileId, cancel);
         return Accepted();
     }
 
@@ -35,7 +36,7 @@ public class RecActionController(IMediator mediator, IConfiguration config) : Co
     [ProducesResponseType(StatusCodes.Status202Accepted)]
     public async Task<IActionResult> Invoke(CancellationToken cancel)
     {
-        await mediator.InvokeBatchRecAction(config.GetFakeProfileId(), cancel);
+        await mediator.InvokeBatchRecActionView(config.GetFakeProfileId(), cancel);
         return Accepted();
     }
 
@@ -43,12 +44,12 @@ 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]
     [ProducesResponseType(StatusCodes.Status200OK)]
-    public async Task<IActionResult> Get([FromQuery] ReadRecActionQuery query, CancellationToken cancel) => Ok(await mediator.Send(query, cancel));
+    public async Task<IActionResult> Get([FromQuery] ReadRecActionViewQuery query, CancellationToken cancel) => Ok(await mediator.Send(query, cancel));
 
     /// <summary>
     /// Gets all RecActions for a fake/test profile.
@@ -58,7 +59,7 @@ public class RecActionController(IMediator mediator, IConfiguration config) : Co
     /// <returns>A list of RecActions for the fake profile.</returns>
     [HttpGet("fake")]
     [ProducesResponseType(StatusCodes.Status200OK)]
-    public async Task<IActionResult> Get(CancellationToken cancel, [FromQuery] bool invoked = false) => Ok(await mediator.Send(new ReadRecActionQuery()
+    public async Task<IActionResult> Get(CancellationToken cancel, [FromQuery] bool invoked = false) => Ok(await mediator.Send(new ReadRecActionViewQuery()
     {
         ProfileId = config.GetFakeProfileId(),
         Invoked = invoked

src/ReC.API/Controllers/ResultViewController.cs

@@ -0,0 +1,40 @@
+using MediatR;
+using Microsoft.AspNetCore.Mvc;
+using ReC.API.Extensions;
+using ReC.Application.ResultViews.Queries;
+
+namespace ReC.API.Controllers;
+
+[Route("api/[controller]")]
+[ApiController]
+public class ResultViewController(IMediator mediator, IConfiguration config) : ControllerBase
+{
+    [HttpGet]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    public async Task<IActionResult> Get([FromQuery] ReadResultViewQuery query, CancellationToken cancel) => Ok(await mediator.Send(query, cancel));
+
+    [HttpGet("fake")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    public async Task<IActionResult> Get(CancellationToken cancel) => Ok(await mediator.Send(new ReadResultViewQuery()
+    {
+        ProfileId = config.GetFakeProfileId()
+    }, cancel));
+
+    [HttpGet("fake/{actionId}")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    public async Task<IActionResult> Get([FromRoute] long actionId, CancellationToken cancel, ResultType resultType = ResultType.Full)
+    {
+        var res = (await mediator.Send(new ReadResultViewQuery()
+        {
+            ProfileId = config.GetFakeProfileId(),
+            ActionId = actionId
+        }, cancel)).First();
+
+        return resultType switch
+        {
+            ResultType.Body => res.Body is null ? Ok(new object { }) : Ok(res.Body.JsonToDynamic()),
+            ResultType.Header => res.Header is null ? Ok(new object { }) : Ok(res.Header.JsonToDynamic()),
+            _ => Ok(res),
+        };
+    }
+}

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();
@@ -23,6 +25,13 @@ try
 
     var config = builder.Configuration;
 
+    Directory
+        .GetFiles(builder.Environment.ContentRootPath, "appsettings.*.json", SearchOption.TopDirectoryOnly)
+        .Where(file => Path.GetFileName(file) != $"appsettings.Development.json")
+        .Where(file => Path.GetFileName(file) != $"appsettings.migration.json")
+        .ToList()
+        .ForEach(file => config.AddJsonFile(file, true, true));
+
     // Add services to the container.
     builder.Services.AddRecServices(options =>
     {
@@ -48,7 +57,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 +71,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.Logging.json

@@ -0,0 +1,59 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "NLog": {
+    "throwConfigExceptions": true,
+    "variables": {
+      "logDirectory": "E:\\LogFiles\\Digital Data\\Rec.API",
+      "logFileNamePrefix": "${shortdate}.Rec.API"
+    },
+    "targets": {
+      "infoLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Info.log",
+        "maxArchiveDays": 30
+      },
+      "warningLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Warning.log",
+        "maxArchiveDays": 30
+      },
+      "errorLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Error.log",
+        "maxArchiveDays": 30
+      },
+      "criticalLogs": {
+        "type": "File",
+        "fileName": "${logDirectory}\\${logFileNamePrefix}-Critical.log",
+        "maxArchiveDays": 30
+      }
+    },
+    "rules": [
+      {
+        "logger": "*",
+        "level": "Info",
+        "writeTo": "infoLogs"
+      },
+      {
+        "logger": "*",
+        "level": "Warn",
+        "writeTo": "warningLogs"
+      },
+      {
+        "logger": "*",
+        "level": "Error",
+        "writeTo": "errorLogs"
+      },
+      {
+        "logger": "*",
+        "level": "Fatal",
+        "writeTo": "criticalLogs"
+      }
+    ]
+  }
+}

src/ReC.API/appsettings.json

@@ -1,10 +1,5 @@
 {
-  "Logging": {
-    "LogLevel": {
-      "Default": "Information",
-      "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;"
   },
@@ -14,56 +9,5 @@
     "MaxConcurrentInvocations": 5
   },
   "AddedWho": "ReC.API",
-  "FakeProfileId": 2,
-  "NLog": {
-    "throwConfigExceptions": true,
-    "variables": {
-      "logDirectory": "E:\\LogFiles\\Digital Data\\Rec.API",
-      "logFileNamePrefix": "${shortdate}.Rec.API"
-    },
-    "targets": {
-      "infoLogs": {
-        "type": "File",
-        "fileName": "${logDirectory}\\${logFileNamePrefix}-Info.log",
-        "maxArchiveDays": 30
-      },
-      "warningLogs": {
-        "type": "File",
-        "fileName": "${logDirectory}\\${logFileNamePrefix}-Warning.log",
-        "maxArchiveDays": 30
-      },
-      "errorLogs": {
-        "type": "File",
-        "fileName": "${logDirectory}\\${logFileNamePrefix}-Error.log",
-        "maxArchiveDays": 30
-      },
-      "criticalLogs": {
-        "type": "File",
-        "fileName": "${logDirectory}\\${logFileNamePrefix}-Critical.log",
-        "maxArchiveDays": 30
-      }
-    },
-    "rules": [
-      {
-        "logger": "*",
-        "level": "Info",
-        "writeTo": "infoLogs"
-      },
-      {
-        "logger": "*",
-        "level": "Warn",
-        "writeTo": "warningLogs"
-      },
-      {
-        "logger": "*",
-        "level": "Error",
-        "writeTo": "errorLogs"
-      },
-      {
-        "logger": "*",
-        "level": "Fatal",
-        "writeTo": "criticalLogs"
-      }
-    ]
-  }
+  "FakeProfileId": 2
 }

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

@@ -6,7 +6,7 @@ using Microsoft.EntityFrameworkCore;
 namespace ReC.Application.Common.Behaviors;
 
 public class BodyQueryBehavior<TRequest, TResponse>(IRecDbContext dbContext) : IPipelineBehavior<TRequest, TResponse>
-    where TRequest : RecActionDto
+    where TRequest : RecActionViewDto
     where TResponse : notnull
 {
     public async Task<TResponse> Handle(TRequest action, RequestHandlerDelegate<TResponse> next, CancellationToken cancel)

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

@@ -8,7 +8,7 @@ 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 : RecActionDto
+    where TRequest : RecActionViewDto
     where TResponse : notnull
 {
     public async Task<TResponse> Handle(TRequest action, RequestHandlerDelegate<TResponse> next, CancellationToken cancel)

src/ReC.Application/Common/Constants/Http.cs

@@ -0,0 +1,6 @@
+namespace ReC.Application.Common.Constants;
+
+public static class Http
+{
+    public static readonly string ClientName = "HttpClient-" + Guid.NewGuid().ToString();
+}

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

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

@@ -6,7 +6,18 @@ public class DtoMappingProfile : AutoMapper.Profile
 {
     public DtoMappingProfile()
     {
-        CreateMap<RecActionView, RecActionDto>();
+        CreateMap<RecActionView, RecActionViewDto>();
         CreateMap<OutRes, OutResDto>();
+
+
+        CreateMap<Connection, ConnectionDto>();
+        CreateMap<EndpointAuth, EndpointAuthDto>();
+        CreateMap<Endpoint, EndpointDto>();
+        CreateMap<EndpointParam, EndpointParamDto>();
+        CreateMap<Profile, ProfileDto>();
+        CreateMap<RecAction, RecActionDto>();
+
+        CreateMap<ResultView, ResultViewDto>();
+        CreateMap<ProfileView, ProfileViewDto>();
     }
 }

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

@@ -0,0 +1,40 @@
+using ReC.Domain.Constants;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace ReC.Application.Common.Dto;
+
+[Table("TBREC_CFG_ENDPOINT_AUTH")]
+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

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

@@ -0,0 +1,33 @@
+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/ProfileDto.cs

@@ -0,0 +1,31 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace ReC.Application.Common.Dto;
+
+[Table("TBREC_CFG_PROFILE", Schema = "dbo")]
+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/ProfileViewDto.cs

@@ -0,0 +1,42 @@
+namespace ReC.Application.Common.Dto;
+
+public class ProfileViewDto
+{
+    public long Id { get; init; }
+
+    public IEnumerable<RecActionViewDto>? RecActions { get; set; }
+
+    public bool Active { get; init; }
+
+    public byte TypeId { get; init; }
+
+    public string? Type { get; init; }
+
+    public string? Mandantor { get; init; }
+
+    public string? ProfileName { get; init; }
+
+    public string? Description { get; init; }
+
+    public byte LogLevelId { get; init; }
+
+    public string? LogLevel { get; init; }
+
+    public short LanguageId { get; init; }
+
+    public string? Language { get; init; }
+
+    public string? AddedWho { get; init; }
+
+    public DateTime AddedWhen { get; init; }
+
+    public string? ChangedWho { get; init; }
+
+    public DateTime? ChangedWhen { get; init; }
+
+    public DateTime? FirstRun { get; init; }
+
+    public DateTime? LastRun { get; init; }
+
+    public string? LastResult { get; init; }
+}

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

@@ -1,76 +1,54 @@
-namespace ReC.Application.Common.Dto;
+using ReC.Domain.Constants;
+using System.ComponentModel.DataAnnotations.Schema;
 
+namespace ReC.Application.Common.Dto;
+
+[Table("TBREC_CFG_ACTION")]
 public record RecActionDto
 {
-    public required long Id { get; init; }
+    public long? Id { get; set; }
 
-    public long? ProfileId { get; init; }
+    public long? ProfileId { get; set; }
 
-    public string? ProfileName { get; init; }
+    public ProfileDto? Profile { get; set; }
 
-    public string? ProfileType { get; init; }
+    public bool? Active { get; set; }
 
-    public byte? ProfileSequence { get; init; }
+    public byte? Sequence { get; set; }
 
-    public long? EndpointId { get; init; }
+    public long? EndpointId { get; set; }
 
-    public string? EndpointUri { get; init; }
+    public EndpointDto? Endpoint { get; set; }
 
-    public long? EndpointAuthId { get; init; }
+    public long? EndpointAuthId { get; set; }
 
-    public string? EndpointAuthType { get; init; }
+    public EndpointAuthDto? EndpointAuth { get; set; }
 
-    public string? EndpointAuthApiKey { get; init; }
+    public short? EndpointParamsId { get; set; }
 
-    public string? EndpointAuthApiValue { get; init; }
+    public short? SqlConnectionId { get; set; }
 
-    public string? EndpointAuthApiKeyAddTo { get; init; }
+    public ConnectionDto? SqlConnection { get; set; }
 
-    public string? EndpointAuthToken { get; init; }
+    public string? Type { get; set; }
 
-    public string? EndpointAuthUsername { get; init; }
+    public string? PreprocessingQuery { get; set; }
 
-    public string? EndpointAuthPassword { get; init; }
+    public string? HeaderQuery { get; set; }
 
-    public string? EndpointAuthDomain { get; init; }
+    public string? BodyQuery { get; set; }
 
-    public string? EndpointAuthWorkstation { get; init; }
+    public string? PostprocessingQuery { get; set; }
 
-    public short? EndpointParamsId { get; init; }
+    public ErrorAction? ErrorAction { get; set; }
 
-    public short? SqlConnectionId { get; init; }
+    public string? AddedWho { get; set; }
 
-    public string? SqlConnectionServer { get; init; }
+    public DateTime? AddedWhen { get; set; }
 
-    public string? SqlConnectionDb { get; init; }
+    public string? ChangedWho { get; set; }
 
-    public string? SqlConnectionUsername { get; init; }
+    public DateTime? ChangedWhen { get; set; }
 
-    public string? SqlConnectionPassword { get; init; }
-
-    public string? RestType { get; init; }
-
-    public string? PreprocessingQuery { get; init; }
-
-    public string? HeaderQuery { get; init; }
-
-    public Dictionary<string, string>? Headers { get; set; }
-
-    public string? BodyQuery { get; init; }
-
-    public string? Body { get; set; }
-
-    public string? PostprocessingQuery { get; init; }
-
-    public UriBuilder ToEndpointUriBuilder()
-    {
-        var builder = EndpointUri is null ? new UriBuilder() : new UriBuilder(EndpointUri);
-
-        builder.Port = -1;
-
-        if (ProfileType is not null)
-            builder.Scheme = ProfileType;
-
-        return builder;
-    }
+    public OutResDto? OutRes { get; set; }
 }

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

@@ -0,0 +1,88 @@
+using ReC.Domain.Constants;
+
+namespace ReC.Application.Common.Dto;
+
+public record RecActionViewDto
+{
+    public required long Id { get; init; }
+
+    public long? ProfileId { get; init; }
+
+    public string? ProfileName { get; init; }
+
+    public ProfileType? ProfileType { get; init; }
+
+    public byte? Sequence { get; init; }
+
+    public long? EndpointId { get; init; }
+
+    public string? EndpointUri { get; init; }
+
+    public long? EndpointAuthId { get; init; }
+
+    public EndpointAuthType? EndpointAuthType { get; init; }
+
+    public string? EndpointAuthTypeName { get; init; }
+
+    public string? EndpointAuthApiKey { get; init; }
+
+    public string? EndpointAuthApiValue { get; init; }
+
+    public ApiKeyLocation? EndpointAuthApiKeyAddTo { get; init; }
+
+    public string? EndpointAuthApiKeyAddToName { get; init; }
+
+    public string? EndpointAuthToken { get; init; }
+
+    public string? EndpointAuthUsername { get; init; }
+
+    public string? EndpointAuthPassword { get; init; }
+
+    public string? EndpointAuthDomain { get; init; }
+
+    public string? EndpointAuthWorkstation { get; init; }
+
+    public short? EndpointParamsId { get; init; }
+
+    public short? SqlConnectionId { get; init; }
+
+    public string? SqlConnectionServer { get; init; }
+
+    public string? SqlConnectionDb { get; init; }
+
+    public string? SqlConnectionUsername { get; init; }
+
+    public string? SqlConnectionPassword { get; init; }
+
+    public RestType? RestType { get; init; }
+
+    public string? RestTypeName { get; init; }
+
+    public string? PreprocessingQuery { get; init; }
+
+    public string? HeaderQuery { get; init; }
+
+    public Dictionary<string, string>? Headers { get; set; }
+
+    public string? BodyQuery { get; init; }
+
+    public string? Body { get; set; }
+
+    public string? PostprocessingQuery { get; init; }
+
+    public ErrorAction? ErrorAction { get; init; }
+
+    public string? ErrorActionName { get; init; }
+
+    public UriBuilder ToEndpointUriBuilder()
+    {
+        var builder = EndpointUri is null ? new UriBuilder() : new UriBuilder(EndpointUri);
+
+        builder.Port = -1;
+
+        if (ProfileType is ProfileType type)
+            builder.Scheme = type.ToUriBuilderScheme();
+
+        return builder;
+    }
+}

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

@@ -0,0 +1,34 @@
+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; }
+
+    public long? ProfileId { get; init; }
+
+    public ProfileViewDto? Profile { get; init; }
+
+    public string? ProfileName { get; init; }
+
+    public short? StatusCode { get; init; }
+
+    public string? StatusName { get; init; }
+
+    public string? Header { get; init; }
+
+    public string? Body { get; init; }
+
+    public string? AddedWho { get; init; }
+
+    public DateTime? AddedWhen { get; init; }
+
+    public string? ChangedWho { get; init; }
+
+    public DateTime? ChangedWhen { get; init; }
+}

src/ReC.Application/Common/HttpExtensions.cs

@@ -1,25 +1,28 @@
-using System.Diagnostics.CodeAnalysis;
+using ReC.Domain.Constants;
+using System.Diagnostics.CodeAnalysis;
 
 namespace ReC.Application.Common;
 
 public static class HttpExtensions
 {
-    private static readonly Dictionary<string, HttpMethod> _methods = new(StringComparer.OrdinalIgnoreCase)
+    private static readonly Dictionary<RestType, HttpMethod> _methods = new()
     {
-        ["GET"] = HttpMethod.Get,
-        ["POST"] = HttpMethod.Post,
-        ["PUT"] = HttpMethod.Put,
-        ["DELETE"] = HttpMethod.Delete,
-        ["PATCH"] = HttpMethod.Patch,
-        ["HEAD"] = HttpMethod.Head,
-        ["OPTIONS"] = HttpMethod.Options,
-        ["TRACE"] = HttpMethod.Trace,
-        ["CONNECT"] = HttpMethod.Connect
+        [RestType.Get] = HttpMethod.Get,
+        [RestType.Post] = HttpMethod.Post,
+        [RestType.Put] = HttpMethod.Put,
+        [RestType.Delete] = HttpMethod.Delete,
+        [RestType.Patch] = HttpMethod.Patch,
+        [RestType.Head] = HttpMethod.Head,
+        [RestType.Options] = HttpMethod.Options,
+        [RestType.Trace] = HttpMethod.Trace,
+        [RestType.Connect] = HttpMethod.Connect
     };
 
-    public static HttpMethod ToHttpMethod(this string method) => _methods.TryGetValue(method, out var httpMethod) 
-        ? httpMethod 
-        : new HttpMethod(method);
+    public static HttpMethod ToHttpMethod(this RestType method) => !method.IsValid()
+            ? throw new ArgumentOutOfRangeException(nameof(method), $"The RestType value '{method}' is not valid.")
+            : _methods.TryGetValue(method, out var httpMethod)
+                ? httpMethod
+                : new HttpMethod(method.ToHttpMethodName());
 
     public static HttpRequestMessage ToHttpRequestMessage(this HttpMethod method, [StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri)
         => new(method, requestUri);

src/ReC.Application/Common/Interfaces/IRecDbContext.cs

@@ -5,15 +5,25 @@ namespace ReC.Application.Common.Interfaces;
 
 public interface IRecDbContext
 {
-    public DbSet<EndpointParam> EndpointParams { get; }
+    public DbSet<EndpointParam> EndpointParams { get; set; }
 
-    public DbSet<RecActionView> Actions { get; }
+    public DbSet<RecActionView> RecActionViews { get; set; }
 
-    public DbSet<OutRes> OutRes { get; }
+    public DbSet<OutRes> OutRes { get; set; }
 
-    public DbSet<HeaderQueryResult> HeaderQueryResults { get; }
+    public DbSet<HeaderQueryResult> HeaderQueryResults { get; set; }
 
-    public DbSet<BodyQueryResult> BodyQueryResults { get; }
+    public DbSet<BodyQueryResult> BodyQueryResults { get; set; }
+
+    public DbSet<Connection> Connections { get; set; }
+
+    public DbSet<Endpoint> Endpoints { get; set; }
+
+    public DbSet<EndpointAuth> EndpointAuths { get; set; }
+
+    public DbSet<Profile> Profiles { get; set; }
+
+    public DbSet<RecAction> RecActions { get; set; }
 
     public Task<int> SaveChangesAsync(CancellationToken cancel = default);
 }

src/ReC.Application/DependencyInjection.cs

@@ -1,10 +1,11 @@
-using MediatR;
+using FluentValidation;
+using MediatR;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using ReC.Application.Common.Behaviors;
+using ReC.Application.Common.Constants;
 using ReC.Application.Common.Options;
 using System.Reflection;
-using FluentValidation;
 
 namespace ReC.Application;
 
@@ -35,7 +36,11 @@ public static class DependencyInjection
             cfg.LicenseKey = configOpt.LuckyPennySoftwareLicenseKey;
         });
 
-        services.AddHttpClient();
+        services.AddHttpClient(Http.ClientName)
+            .ConfigurePrimaryHttpMessageHandler(() => new HttpClientHandler
+            {
+                UseDefaultCredentials = false
+            });
 
         return services;
     }

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

@@ -1,25 +1,27 @@
-using DigitalData.Core.Abstraction.Application.Repository;
+using AutoMapper;
+using DigitalData.Core.Abstraction.Application.Repository;
 using MediatR;
 using Microsoft.EntityFrameworkCore;
+using ReC.Application.Common.Dto;
 using ReC.Domain.Entities;
 
 namespace ReC.Application.Endpoints.Commands;
 
-public class ObtainEndpointCommand : IRequest<Endpoint>
+public class ObtainEndpointCommand : IRequest<EndpointDto>
 {
     public string Uri { get; init; } = null!;
 }
 
-public class ObtainEndpointCommandHandler(IRepository<Endpoint> repo) : IRequestHandler<ObtainEndpointCommand, Endpoint>
+public class ObtainEndpointCommandHandler(IRepository<Endpoint> repo, IMapper mapper) : IRequestHandler<ObtainEndpointCommand, EndpointDto>
 {
-    public async Task<Endpoint> Handle(ObtainEndpointCommand request, CancellationToken cancel)
+    public async Task<EndpointDto> Handle(ObtainEndpointCommand request, CancellationToken cancel)
     {
         var endpoint = await repo.Where(e => e.Uri == request.Uri).FirstOrDefaultAsync(cancel);
 
         if (endpoint is not null)
-            return endpoint;
+            return mapper.Map<EndpointDto>(endpoint);
 
         endpoint = await repo.CreateAsync(request, cancel);
-        return endpoint;
+        return mapper.Map<EndpointDto>(endpoint);
     }
 }

src/ReC.Application/Endpoints/MappingProfile.cs

@@ -1,5 +1,5 @@
 using ReC.Application.Endpoints.Commands;
-using ReC.Domain.Entities;
+using ReC.Application.Common.Dto;
 
 namespace ReC.Application.Endpoints;
 
@@ -8,7 +8,7 @@ public class MappingProfile : AutoMapper.Profile
 {
     public MappingProfile()
     {
-        CreateMap<ObtainEndpointCommand, Endpoint>()
+        CreateMap<ObtainEndpointCommand, EndpointDto>()
             .ForMember(e => e.Active, exp => exp.MapFrom(cmd => true))
             .ForMember(e => e.AddedWhen, exp => exp.MapFrom(cmd => DateTime.UtcNow))
             .ForMember(e => e.AddedWho, exp => exp.MapFrom(cmd => "ReC.API"));

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/RecActionViews/Commands/InvokeBatchRecActionViewsCommand.cs

@@ -0,0 +1,37 @@
+using MediatR;
+using ReC.Application.RecActionViews.Queries;
+using ReC.Domain.Constants;
+
+namespace ReC.Application.RecActionViews.Commands;
+
+public record InvokeBatchRecActionViewsCommand : IRequest
+{
+    public long ProfileId { 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 async Task Handle(InvokeBatchRecActionViewsCommand request, CancellationToken cancel)
+    {
+        var actions = await sender.Send(new ReadRecActionViewQuery() { ProfileId = request.ProfileId, Invoked = false }, cancel);
+
+        foreach (var action in actions)
+        {
+            var ok = await sender.Send(action.ToInvokeCommand(), cancel);
+            if (!ok)
+                switch (action.ErrorAction)
+                {
+                    case ErrorAction.Continue:
+                        break;
+                    default:
+                        return;
+                }
+        }
+    }
+}

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

@@ -0,0 +1,147 @@
+using MediatR;
+using Microsoft.Extensions.Configuration;
+using ReC.Application.Common;
+using ReC.Application.Common.Constants;
+using ReC.Application.Common.Dto;
+using ReC.Application.Common.Exceptions;
+using ReC.Application.OutResults.Commands;
+using ReC.Domain.Constants;
+using System.Net;
+using System.Net.Http.Headers;
+using System.Text;
+using System.Text.Json;
+
+namespace ReC.Application.RecActionViews.Commands;
+
+public record InvokeRecActionViewCommand : IRequest<bool>
+{
+    public RecActionViewDto Action { get; set; } = null!;
+}
+
+public static class InvokeRecActionViewCommandExtensions
+{
+    public static InvokeRecActionViewCommand ToInvokeCommand(this RecActionViewDto dto) => new() { Action = dto };
+}
+
+public class InvokeRecActionViewCommandHandler(
+    ISender sender,
+    IHttpClientFactory clientFactory,
+    IConfiguration? config = null
+    ) : IRequestHandler<InvokeRecActionViewCommand, bool>
+{
+    public async Task<bool> Handle(InvokeRecActionViewCommand request, CancellationToken cancel)
+    {
+        var action = request.Action;
+
+        using var http = clientFactory.CreateClient(Http.ClientName);
+
+        if (action.RestType is not RestType restType)
+            throw new DataIntegrityException(
+                $"Rec action could not be invoked because the RestType value is null. " +
+                $"ProfileId: {action.ProfileId}, " +
+                $"Id: {action.Id}"
+            );
+
+        using var httpReq = restType
+            .ToHttpMethod()
+            .ToHttpRequestMessage(action.EndpointUri);
+
+        if (action.Body is not null)
+        {
+            using var reqBody = new StringContent(action.Body);
+            httpReq.Content = reqBody;
+        }
+
+        if (action.Headers is not null)
+            foreach (var header in action.Headers)
+                httpReq.Headers.Add(header.Key, header.Value);
+
+        switch (action.EndpointAuthType)
+        {
+            case EndpointAuthType.NoAuth:
+                break;
+
+            case EndpointAuthType.ApiKey:
+                if (action.EndpointAuthApiKey is string apiKey && action.EndpointAuthApiValue is string apiValue)
+                {
+                    switch (action.EndpointAuthApiKeyAddTo)
+                    {
+                        case ApiKeyLocation.Header:
+                            httpReq.Headers.Add(apiKey, apiValue);
+                            break;                        
+                        case ApiKeyLocation.Query:                        
+                            var uriBuilder = new UriBuilder(httpReq.RequestUri!);
+                            var query = System.Web.HttpUtility.ParseQueryString(uriBuilder.Query);
+                            query[apiKey] = apiValue;
+                            uriBuilder.Query = query.ToString();
+                            httpReq.RequestUri = uriBuilder.Uri;
+                            break;
+                        default:
+                            throw new DataIntegrityException(
+                                $"The API key location '{action.EndpointAuthApiKeyAddTo}' is not supported. " +
+                                $"ProfileId: {action.ProfileId}, " +
+                                $"Id: {action.Id}"
+                            );
+                    }
+                }
+                break;
+
+            case EndpointAuthType.BearerToken:
+            case EndpointAuthType.JwtBearer:
+            case EndpointAuthType.OAuth2:
+                if (action.EndpointAuthToken is string authToken)
+                    httpReq.Headers.Authorization = new AuthenticationHeaderValue("Bearer", authToken);
+                break;
+
+            case EndpointAuthType.BasicAuth:
+                if (action.EndpointAuthUsername is string authUsername && action.EndpointAuthPassword is string authPassword)
+                {
+                    var basicAuth = Convert.ToBase64String(Encoding.UTF8.GetBytes($"{authUsername}:{authPassword}"));
+                    httpReq.Headers.Authorization = new AuthenticationHeaderValue("Basic", basicAuth);
+                }
+                break;
+
+            case EndpointAuthType.NtlmAuth:
+                if (!string.IsNullOrWhiteSpace(action.EndpointAuthUsername))
+                {
+                    var credentials = new NetworkCredential(
+                        action.EndpointAuthUsername,
+                        action.EndpointAuthPassword,
+                        action.EndpointAuthDomain);
+                    var credentialCache = new CredentialCache { { httpReq.RequestUri!, "NTLM", credentials } };
+                    httpReq.Options.Set(new HttpRequestOptionsKey<CredentialCache>("Credentials"), credentialCache);
+                }
+                break;
+
+            case EndpointAuthType.DigestAuth:
+            case EndpointAuthType.OAuth1:
+            case EndpointAuthType.AwsSignature:
+            // These authentication methods require more complex implementations,
+            // often involving multi-step handshakes or specialized libraries.
+            // They are left as placeholders for future implementation.
+            default:
+                throw new NotImplementedException(
+                    $"The authentication type '{action.EndpointAuthType}' is not supported yet. " +
+                    $"ProfileId: {action.ProfileId}, " +
+                    $"Id: {action.Id}"
+                );
+        }
+
+        using var response = await http.SendAsync(httpReq, cancel);
+        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.Application/RecActionViews/MappingProfile.cs

@@ -1,14 +1,14 @@
-using ReC.Application.RecActions.Commands;
-using ReC.Domain.Entities;
+using ReC.Application.Common.Dto;
+using ReC.Application.RecActions.Commands;
 
-namespace ReC.Application.RecActions;
+namespace ReC.Application.RecActionViews;
 
 // TODO: update to inject AddedWho from the current host/user contex
 public class MappingProfile : AutoMapper.Profile
 {
     public MappingProfile()
     {
-        CreateMap<CreateRecActionCommand, RecAction>()
+        CreateMap<CreateRecActionCommand, RecActionDto>()
             .ForMember(e => e.Active, exp => exp.MapFrom(cmd => true))
             .ForMember(e => e.AddedWhen, exp => exp.MapFrom(cmd => DateTime.UtcNow))
             .ForMember(e => e.AddedWho, exp => exp.MapFrom(cmd => "ReC.API"));

src/ReC.Application/RecActionViews/Queries/ReadRecActionViewQuery.cs

@@ -0,0 +1,37 @@
+using MediatR;
+using DigitalData.Core.Abstraction.Application.Repository;
+using ReC.Domain.Entities;
+using AutoMapper;
+using Microsoft.EntityFrameworkCore;
+using DigitalData.Core.Exceptions;
+using ReC.Application.Common.Dto;
+
+namespace ReC.Application.RecActionViews.Queries;
+
+public record ReadRecActionViewQuery : IRequest<IEnumerable<RecActionViewDto>>
+{
+    public long? ProfileId { get; init; } = null;
+
+    public bool? Invoked { get; set; } = null;
+}
+
+public class ReadRecActionViewQueryHandler(IRepository<RecActionView> repo, IMapper mapper) : IRequestHandler<ReadRecActionViewQuery, IEnumerable<RecActionViewDto>>
+{
+    public async Task<IEnumerable<RecActionViewDto>> Handle(ReadRecActionViewQuery request, CancellationToken cancel)
+    {
+        var query = repo.Query;
+
+        if (request.ProfileId is long profileId)
+            query = repo.Where(act => act.ProfileId == profileId);
+
+        if (request.Invoked is bool invoked)
+            query = invoked ? query.Where(act => act.Root!.OutRes != null) : query.Where(act => act.Root!.OutRes == null);
+
+        var actions = await query.Include(act => act.EndpointAuth).ToListAsync(cancel);
+
+        if (actions.Count == 0)
+            throw new NotFoundException($"No actions found for the profile {request.ProfileId}.");
+
+        return mapper.Map<IEnumerable<RecActionViewDto>>(actions);
+    }
+}

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

@@ -1,8 +1,8 @@
 using DigitalData.Core.Abstraction.Application.Repository;
 using DigitalData.Core.Exceptions;
 using MediatR;
-using ReC.Application.Endpoints.Commands;
 using ReC.Domain.Entities;
+using ReC.Application.Endpoints.Commands;
 
 namespace ReC.Application.RecActions.Commands;
 

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

@@ -1,52 +0,0 @@
-using MediatR;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Logging;
-using ReC.Application.RecActions.Queries;
-
-namespace ReC.Application.RecActions.Commands;
-
-public record InvokeBatchRecActionsCommand : ReadRecActionQueryBase, IRequest;
-
-public static class InvokeBatchRecActionsCommandExtensions
-{
-    public static Task InvokeBatchRecAction(this ISender sender, long profileId, CancellationToken cancel = default)
-        => sender.Send(new InvokeBatchRecActionsCommand { ProfileId = profileId }, cancel);
-}
-
-public class InvokeRecActionsCommandHandler(ISender sender, IServiceScopeFactory scopeFactory, IHttpClientFactory clientFactory, ILogger<InvokeRecActionsCommandHandler>? logger = null) : 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 =>
-        {
-            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);
-    }
-}

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

@@ -1,65 +0,0 @@
-using MediatR;
-using Microsoft.Extensions.Configuration;
-using ReC.Application.Common;
-using ReC.Application.Common.Dto;
-using ReC.Application.Common.Exceptions;
-using ReC.Application.OutResults.Commands;
-using System.Text.Json;
-
-namespace ReC.Application.RecActions.Commands;
-
-public record InvokeRecActionCommand : IRequest
-{
-    public RecActionDto Action { get; set; } = null!;
-}
-
-public static class InvokeRecActionCommandExtensions
-{
-    public static InvokeRecActionCommand ToInvokeCommand(this RecActionDto dto) => new() { Action = dto };
-}
-
-public class InvokeRecActionCommandHandler(
-    ISender sender,
-    IHttpClientFactory clientFactory,
-    IConfiguration? config = null
-    ) : IRequestHandler<InvokeRecActionCommand>
-{
-    public async Task Handle(InvokeRecActionCommand request, CancellationToken cancel)
-    {
-        var action = request.Action;
-        using var http = clientFactory.CreateClient();
-
-        if (action.RestType is null)
-            throw new DataIntegrityException(
-                $"Rec action could not be invoked because the RestType value is null. " +
-                $"ProfileId: {action.ProfileId}, " +
-                $"Id: {action.Id}"
-            );
-
-        using var httpReq = action.RestType
-            .ToHttpMethod()
-            .ToHttpRequestMessage(action.EndpointUri);
-
-        if(action.Body is not null)
-        {
-            using var reqBody = new StringContent(action.Body);
-            httpReq.Content = reqBody;
-        }
-
-        if (action.Headers is not null)
-            foreach (var header in action.Headers)
-                httpReq.Headers.Add(header.Key, header.Value);
-
-        using var response = await http.SendAsync(httpReq, cancel);
-        var resBody = await response.Content.ReadAsStringAsync(cancel);
-        var resHeaders = response.Headers.ToDictionary();
-
-        await sender.Send(new CreateOutResCommand
-        {
-            ActionId = action.Id,
-            Header = JsonSerializer.Serialize(resHeaders, options: new() { WriteIndented = false }),
-            Body = resBody,
-            AddedWho = config?["AddedWho"]
-        }, cancel);
-    }
-}

src/ReC.Application/RecActions/Queries/ReadRecActionQuery.cs

@@ -1,48 +0,0 @@
-using MediatR;
-using DigitalData.Core.Abstraction.Application.Repository;
-using ReC.Domain.Entities;
-using AutoMapper;
-using Microsoft.EntityFrameworkCore;
-using DigitalData.Core.Exceptions;
-using ReC.Application.Common.Dto;
-
-namespace ReC.Application.RecActions.Queries;
-
-public record ReadRecActionQueryBase
-{
-    public long ProfileId { get; init; }
-
-    public ReadRecActionQuery ToReadQuery(Action<ReadRecActionQuery> modify)
-    {
-        ReadRecActionQuery query = new(this);
-        modify(query);
-        return query;
-    }
-}
-
-public record ReadRecActionQuery : ReadRecActionQueryBase, IRequest<IEnumerable<RecActionDto>>
-{
-    public ReadRecActionQuery(ReadRecActionQueryBase root) : base(root) { }
-
-    public bool? Invoked { get; set; } = null;
-
-    public ReadRecActionQuery() { }
-}
-
-public class ReadRecActionQueryHandler(IRepository<RecActionView> repo, IMapper mapper) : IRequestHandler<ReadRecActionQuery, IEnumerable<RecActionDto>>
-{
-    public async Task<IEnumerable<RecActionDto>> Handle(ReadRecActionQuery request, CancellationToken cancel)
-    {
-        var query = repo.Where(act => act.ProfileId == request.ProfileId);
-
-        if (request.Invoked is bool invoked)
-            query = invoked ? query.Where(act => act.Root!.OutRes != null) : query.Where(act => act.Root!.OutRes == null);
-
-        var actions = await query.ToListAsync(cancel);
-
-        if(actions.Count == 0)
-            throw new NotFoundException($"No actions found for the profile {request.ProfileId}.");
-
-        return mapper.Map<IEnumerable<RecActionDto>>(actions);
-    }
-}

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

@@ -0,0 +1,49 @@
+using AutoMapper;
+using DigitalData.Core.Abstraction.Application.Repository;
+using DigitalData.Core.Exceptions;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using ReC.Application.Common.Dto;
+using ReC.Domain.Entities;
+using System.Text.Json;
+
+namespace ReC.Application.ResultViews.Queries;
+
+public record ReadResultViewQuery : IRequest<IEnumerable<ResultViewDto>>
+{
+    public long? Id { get; init; } = null;
+
+    public long? ActionId { get; init; } = null;
+
+    public long? ProfileId { get; init; } = null;
+}
+
+public class ReadResultViewQueryHandler(IRepository<ResultView> repo, IMapper mapper) : IRequestHandler<ReadResultViewQuery, IEnumerable<ResultViewDto>>
+{
+    public async Task<IEnumerable<ResultViewDto>> Handle(ReadResultViewQuery 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);
+
+        var entities = await q.ToListAsync(cancel);
+
+        if (entities.Count == 0)
+            throw new NotFoundException($"No result views found for the given criteria. Criteria: {
+                JsonSerializer.Serialize(request, options: new()
+                {
+                    PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
+                    WriteIndented = true
+                })}"
+            );
+
+        return mapper.Map<IEnumerable<ResultViewDto>>(entities);
+    }
+}

src/ReC.Domain/Attributes/MustConfiguredAttribute.cs

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

src/ReC.Domain/Constants/ApiKeyLocation.cs

@@ -0,0 +1,7 @@
+namespace ReC.Domain.Constants;
+
+public enum ApiKeyLocation : byte
+{
+    Header = 0,
+    Query = 1
+}

src/ReC.Domain/Constants/EndpointAuthType.cs

@@ -0,0 +1,15 @@
+namespace ReC.Domain.Constants;
+
+public enum EndpointAuthType : byte
+{
+    NoAuth = 0,
+    ApiKey = 1,
+    BearerToken = 2,
+    JwtBearer = 3,
+    BasicAuth = 4,
+    DigestAuth = 5,
+    OAuth1 = 6,
+    OAuth2 = 7,
+    AwsSignature = 8,
+    NtlmAuth = 9
+}

src/ReC.Domain/Constants/ErrorAction.cs

@@ -0,0 +1,7 @@
+namespace ReC.Domain.Constants;
+
+public enum ErrorAction : byte
+{
+    Stop = 0,
+    Continue = 1,
+}

src/ReC.Domain/Constants/ProfileType.cs

@@ -0,0 +1,12 @@
+namespace ReC.Domain.Constants;
+
+public enum ProfileType : byte
+{
+    Http = 1,
+    Https = 2
+}
+
+public static class ProfileTypeExtensions
+{
+    public static string ToUriBuilderScheme(this ProfileType profileType) => profileType.ToString().ToLower();
+}

src/ReC.Domain/Constants/RestType.cs

@@ -0,0 +1,28 @@
+namespace ReC.Domain.Constants;
+
+public enum RestType : byte
+{
+    None = 0,
+    Get = 1,
+    Post = 2,
+    Put = 3,
+    Patch = 4,
+    Delete = 5,
+    Head = 6,
+    Options = 7,
+    Connect = 8,
+    Trace = 9,
+}
+
+public static class RestTypeExtensions
+{
+    public static string ToHttpMethodName(this RestType restType)
+    {
+        return restType.ToString().ToUpper();
+    }
+
+    public static bool IsValid(this RestType restType)
+    {
+        return restType != RestType.None;
+    }
+}

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,35 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations.Schema;
 
 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,23 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations.Schema;
 
 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

@@ -1,4 +1,4 @@
-using System.ComponentModel.DataAnnotations;
+using ReC.Domain.Constants;
 using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Entities;
@@ -6,53 +6,35 @@ 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; }
+    public EndpointAuthType? 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; }
+    public ApiKeyLocation? 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,5 +1,4 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Entities;
 
@@ -11,37 +10,25 @@ namespace ReC.Domain.Entities;
 [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,27 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations.Schema;
 
 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? 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,31 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
+using System.ComponentModel.DataAnnotations.Schema;
 
 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/ProfileView.cs

@@ -0,0 +1,42 @@
+using ReC.Domain.Constants;
+
+namespace ReC.Domain.Entities;
+
+public record ProfileView
+{
+    public long Id { get; init; }
+    
+    public bool Active { get; init; }
+    
+    public ProfileType TypeId { get; init; }
+    
+    public string? Type { get; init; }
+    
+    public string? Mandantor { get; init; }
+
+    public string? ProfileName { get; init; }
+
+    public string? Description { get; init; }
+
+    public byte LogLevelId { get; init; }
+
+    public string? LogLevel { get; init; }
+
+    public short LanguageId { get; init; }
+
+    public string? Language { get; init; }
+
+    public string? AddedWho { get; init; }
+
+    public DateTime AddedWhen { get; init; }
+
+    public string? ChangedWho { get; init; }
+
+    public DateTime? ChangedWhen { get; init; }
+
+    public DateTime? FirstRun { get; init; }
+
+    public DateTime? LastRun { get; init; }
+
+    public string? LastResult { get; init; }
+}

src/ReC.Domain/Entities/RecAction.cs

@@ -1,4 +1,4 @@
-using System.ComponentModel.DataAnnotations;
+using ReC.Domain.Constants;
 using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Entities;
@@ -6,68 +6,48 @@ 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 ErrorAction? 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

@@ -1,4 +1,4 @@
-using System.ComponentModel.DataAnnotations;
+using ReC.Domain.Constants;
 using System.ComponentModel.DataAnnotations.Schema;
 
 namespace ReC.Domain.Entities;
@@ -14,110 +14,84 @@ namespace ReC.Domain.Entities;
 [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; }
+    public ProfileView? Profile { get; set; }
 
-    [Column("PROFILE_NAME")]
-    [MaxLength(100)]
     public string? ProfileName { get; set; }
 
-    [Column("PROFILE_TYPE")]
-    [MaxLength(20)]
-    public string? ProfileType { get; set; }
+    public ProfileType? 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)]
+    [ForeignKey("EndpointId")]
+    public Endpoint? Endpoint { get; set; }
+
     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; }
+    [ForeignKey("EndpointAuthId")]
+    public EndpointAuth? EndpointAuth { get; set; }
+
+    public EndpointAuthType? EndpointAuthType { get; set; }
+
+    public string? EndpointAuthTypeName { 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; }
+    public ApiKeyLocation? EndpointAuthApiKeyAddTo { get; set; }
+
+    public string? EndpointAuthApiKeyAddToName { 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)]
+    [ForeignKey("SqlConnectionId")]
+    public Connection? SqlConnection { get; set; }
+
     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; }
+    public RestType? RestType { get; set; }
+
+    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; }
+
+    public ErrorAction? ErrorAction { get; set; }
+
+    public string? ErrorActionName { get; set; }
 }

src/ReC.Domain/Entities/ResultView.cs

@@ -0,0 +1,37 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace ReC.Domain.Entities;
+
+public class ResultView
+{
+    public long Id { get; set; }
+
+    [ForeignKey("Id")]
+    public OutRes? Root { get; set; }
+
+    public long? ActionId { get; set; }
+
+    public RecActionView? Action { get; set; }
+
+    public long? ProfileId { get; set; }
+
+    public ProfileView? Profile { get; set; }
+
+    public string? ProfileName { get; set; }
+
+    public short? StatusCode { get; set; }
+
+    public string? StatusName { get; set; }
+
+    public string? Header { get; set; }
+
+    public string? Body { get; set; }
+
+    public string? AddedWho { get; set; }
+
+    public DateTime? AddedWhen { get; set; }
+
+    public string? ChangedWho { get; set; }
+
+    public DateTime? ChangedWhen { 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

@@ -8,7 +8,11 @@ public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(op
 {
     public DbSet<EndpointParam> EndpointParams { get; set; }
 
-    public DbSet<RecActionView> Actions { get; set; }
+    public DbSet<RecActionView> RecActionViews { get; set; }
+
+    public DbSet<ProfileView> ProfileViews { get; set; }
+
+    public DbSet<ResultView> RecResultViews { get; set; }
 
     public DbSet<OutRes> OutRes { get; set; }
 
@@ -30,15 +34,265 @@ 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_ID");
+            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<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<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.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");
+        });
+
+        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.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<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);
     }
 }