Bump to 1.2.1

- Implementiert für Resolver

WorkFlow.Domain/Entities/ProfControlsTf.cs

@@ -1,63 +0,0 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace WorkFlow.Domain.Entities
-{
-    [Table("TBMWF_PROF_CONTROLS_TF", Schema = "dbo")]
-    public class ProfControlsTf
-    {
-        [Key]
-        [Column("GUID")]
-        public int Id { get; init; }
-
-        [Required]
-        [Column("MWF_PROFILE_ID")]
-        public required int MwfProfileId { get; init; }
-
-        [Required]
-        [Column("USR_ID")]
-        public required int UsrId { get; init; }
-
-        [Required]
-        [Column("OBJ_ID")]
-        public required long ObjId { get; init; }
-
-        [Required]
-        [Column("OBJ_TYPE", TypeName = "varchar(10)")]
-        public required string ObjType { get; init; }
-
-        [Required]
-        [Column("ATTR_NAME", TypeName = "varchar(100)")]
-        public required string AttrName { get; init; }
-
-        [Required]
-        [Column("CTRL_TYPE", TypeName = "varchar(10)")]
-        public required string CtrlType { get; init; }
-
-        [Required]
-        [Column("CTRL_CAPTION", TypeName = "varchar(100)")]
-        public required string CtrlCaption { get; init; }
-
-        [Required]
-        [Column("MANDATORY")]
-        public required bool Mandatory { get; init; }
-
-        [Column("CHOICE_LIST", TypeName = "nvarchar(max)")]
-        public string? ChoiceList { get; init; }
-
-        [Required]
-        [Column("READ_ONLY")]
-        public required bool ReadOnly { get; init; }
-
-        [Required]
-        [Column("ADDED_WHO", TypeName = "varchar(100)")]
-        public required string AddedWho { get; init; }
-
-        [Required]
-        [Column("ADDED_WHEN", TypeName = "datetime")]
-        public required DateTime AddedWhen { get; init; }
-
-        [ForeignKey("MwfProfileId")]
-        public Profile? MwfProfile { get; init; } = default;
-    }
-}

WorkFlow.Domain/Entities/Profile.cs

@@ -1,43 +0,0 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace WorkFlow.Domain.Entities
-{
-    [Table("TBMWF_PROFILE", Schema = "dbo")]
-    public class Profile
-    {
-        [Key]
-        [Column("GUID")]
-        public int Id { get; init; }
-
-        [Required]
-        [Column("INTL_NAME", TypeName = "varchar(200)")]
-        public required string IntlName { get; init; }
-
-        [Required]
-        [Column("EXT_ID1")]
-        public required int ExtId1 { get; init; }
-
-        [Required]
-        [Column("ACTIVE")]
-        public required bool Active { get; init; }
-
-        [Required]
-        [Column("ADDED_WHO", TypeName = "varchar(30)")]
-        public required string AddedWho { get; init; }
-
-        [Required]
-        [Column("ADDED_WHEN", TypeName = "datetime")]
-        public required DateTime AddedWhen { get; init; }
-
-        [Column("CHANGED_WHO", TypeName = "varchar(30)")]
-        public string? ChangedWho { get; init; }
-
-        [Column("CHANGED_WHEN", TypeName = "datetime")]
-        public DateTime? ChangedWhen { get; init; }
-
-        [Required]
-        [Column("TYPE_ID")]
-        public required byte TypeId { get; init; }
-    }
-}

WorkFlow.Domain/Entities/ProfileObjState.cs

@@ -1,46 +0,0 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace WorkFlow.Domain.Entities
-{
-    [Table("TBMWF_PROFILE_OBJ_STATE", Schema = "dbo")]
-    public class ProfileObjState
-    {
-        [Key]
-        [Column("GUID")]
-        public int Id { get; init; }
-
-        [Required]
-        [Column("MWF_PROFILE_ID")]
-        public required int MwfProfileId { get; init; }
-
-        [Required]
-        [Column("USR_ID")]
-        public required int UsrId { get; init; }
-
-        [Required]
-        [Column("OBJ_ID")]
-        public required long ObjId { get; init; }
-
-        [Required]
-        [Column("STATE_ID")]
-        public required int StateId { get; init; }
-
-        [Column("STATE2", TypeName = "nvarchar(3000)")]
-        public string? State2 { get; init; }
-
-        [Column("STATE3", TypeName = "nvarchar(3000)")]
-        public string? State3 { get; init; }
-
-        [Column("STATE4", TypeName = "nvarchar(3000)")]
-        public string? State4 { get; init; }
-
-        [Required]
-        [Column("ADDED_WHO", TypeName = "varchar(30)")]
-        public required string AddedWho { get; init; }
-
-        [Required]
-        [Column("ADDED_WHEN", TypeName = "datetime")]
-        public required DateTime AddedWhen { get; init; }
-    }
-}

WorkFlow.Domain/Entities/WfState.cs

@@ -1,25 +0,0 @@
-using System.ComponentModel.DataAnnotations;
-using System.ComponentModel.DataAnnotations.Schema;
-
-namespace WorkFlow.Domain.Entities
-{
-    [Table("TBMWF_WF_STATE", Schema = "dbo")]
-    public class WfState
-    {
-        [Key]
-        [Column("GUID")]
-        public int Id { get; init; }
-
-        [Required]
-        [Column("INTL_STATE", TypeName = "varchar(100)")]
-        public required string IntlState { get; init; }
-
-        [Required]
-        [Column("ADDED_WHO", TypeName = "varchar(30)")]
-        public required string AddedWho { get; init; }
-
-        [Required]
-        [Column("ADDED_WHEN", TypeName = "datetime")]
-        public required DateTime AddedWhen { get; init; }
-    }
-}

WorkFlow.Infrastructure/WFDBContext.cs

@@ -1,18 +0,0 @@
-using Microsoft.EntityFrameworkCore;
-using WorkFlow.Domain.Entities;
-
-namespace WorkFlow.Infrastructure
-{
-    public class WFDBContext(DbContextOptions options) : DbContext(options)
-    {
-        public DbSet<Config> Configs { get; set; }
-
-        public DbSet<ProfControlsTf> ProfControlsTf { get; set; }
-
-        public DbSet<Profile> Profiles { get; set; }
-
-        public DbSet<ProfileObjState> ProfileObjStates { get; set; }
-
-        public DbSet<WfState> WfStates { get; set; }
-    }
-}

WorkFlow.Infrastructure/WorkFlow.Infrastructure.csproj

@@ -1,17 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="DigitalData.Core.Infrastructure" Version="2.0.0" />
-  </ItemGroup>
-
-  <ItemGroup>
-    <ProjectReference Include="..\WorkFlow.Domain\WorkFlow.Domain.csproj" />
-  </ItemGroup>
-
-</Project>

WorkFlow.sln

@@ -3,9 +3,21 @@ Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio Version 17
 VisualStudioVersion = 17.9.34622.214
 MinimumVisualStudioVersion = 10.0.40219.1
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "WorkFlow.Domain", "WorkFlow.Domain\WorkFlow.Domain.csproj", "{71E9264E-A2F0-4E5A-B010-8E4618C0C6AC}"
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{8EC462FD-D22E-90A8-E5CE-7E832BA40C5D}"
+	ProjectSection(SolutionItems) = preProject
+		scripts\GetProfile.sql = scripts\GetProfile.sql
+		README.md = README.md
+	EndProjectSection
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkFlow.Infrastructure", "WorkFlow.Infrastructure\WorkFlow.Infrastructure.csproj", "{62526D0D-3365-4113-854A-3656191D7C63}"
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{02EA681E-C7D8-13C7-8484-4AC65E1B71E8}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkFlow.API", "src\WorkFlow.API\WorkFlow.API.csproj", "{2B724243-4C79-F3A4-EE25-B9A53C81464C}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkFlow.Application", "src\WorkFlow.Application\WorkFlow.Application.csproj", "{F1B4AC83-5137-C20B-641C-1699B46007A0}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkFlow.Domain", "src\WorkFlow.Domain\WorkFlow.Domain.csproj", "{92A11048-6B9C-374E-87A0-BD6D8F864B77}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "WorkFlow.Infrastructure", "src\WorkFlow.Infrastructure\WorkFlow.Infrastructure.csproj", "{94F2D67D-649E-63D2-A3BF-0BEC98C2D7E6}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -13,18 +25,32 @@ Global
 		Release|Any CPU = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(ProjectConfigurationPlatforms) = postSolution
-		{71E9264E-A2F0-4E5A-B010-8E4618C0C6AC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{71E9264E-A2F0-4E5A-B010-8E4618C0C6AC}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{71E9264E-A2F0-4E5A-B010-8E4618C0C6AC}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{71E9264E-A2F0-4E5A-B010-8E4618C0C6AC}.Release|Any CPU.Build.0 = Release|Any CPU
-		{62526D0D-3365-4113-854A-3656191D7C63}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{62526D0D-3365-4113-854A-3656191D7C63}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{62526D0D-3365-4113-854A-3656191D7C63}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{62526D0D-3365-4113-854A-3656191D7C63}.Release|Any CPU.Build.0 = Release|Any CPU
+		{2B724243-4C79-F3A4-EE25-B9A53C81464C}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2B724243-4C79-F3A4-EE25-B9A53C81464C}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2B724243-4C79-F3A4-EE25-B9A53C81464C}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2B724243-4C79-F3A4-EE25-B9A53C81464C}.Release|Any CPU.Build.0 = Release|Any CPU
+		{F1B4AC83-5137-C20B-641C-1699B46007A0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{F1B4AC83-5137-C20B-641C-1699B46007A0}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{F1B4AC83-5137-C20B-641C-1699B46007A0}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{F1B4AC83-5137-C20B-641C-1699B46007A0}.Release|Any CPU.Build.0 = Release|Any CPU
+		{92A11048-6B9C-374E-87A0-BD6D8F864B77}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{92A11048-6B9C-374E-87A0-BD6D8F864B77}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{92A11048-6B9C-374E-87A0-BD6D8F864B77}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{92A11048-6B9C-374E-87A0-BD6D8F864B77}.Release|Any CPU.Build.0 = Release|Any CPU
+		{94F2D67D-649E-63D2-A3BF-0BEC98C2D7E6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{94F2D67D-649E-63D2-A3BF-0BEC98C2D7E6}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{94F2D67D-649E-63D2-A3BF-0BEC98C2D7E6}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{94F2D67D-649E-63D2-A3BF-0BEC98C2D7E6}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
 	EndGlobalSection
+	GlobalSection(NestedProjects) = preSolution
+		{2B724243-4C79-F3A4-EE25-B9A53C81464C} = {02EA681E-C7D8-13C7-8484-4AC65E1B71E8}
+		{F1B4AC83-5137-C20B-641C-1699B46007A0} = {02EA681E-C7D8-13C7-8484-4AC65E1B71E8}
+		{92A11048-6B9C-374E-87A0-BD6D8F864B77} = {02EA681E-C7D8-13C7-8484-4AC65E1B71E8}
+		{94F2D67D-649E-63D2-A3BF-0BEC98C2D7E6} = {02EA681E-C7D8-13C7-8484-4AC65E1B71E8}
+	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {1ECB3995-5040-40BC-BC70-906E64BB4E01}
 	EndGlobalSection

scripts/GetProfile.sql

@@ -0,0 +1,4 @@
+--PROFILES
+select * from FNMWF_GET_PROFILES (1) --USER_ID
+--PROFILE_OBJECTS
+SELECT * FROM [FNMWF_GET_PROFILE_OBJECTS] (1,1) --USERID, PROFILE_ID

src/WorkFlow.API/Attributes/APIKeyAuthAttribute.cs

@@ -0,0 +1,14 @@
+using Microsoft.AspNetCore.Mvc;
+using WorkFlow.API.Filters;
+
+namespace WorkFlow.API.Attributes
+{
+    //TODO: move APIKeyAuthAttribute to Core.API
+    public class APIKeyAuthAttribute : ServiceFilterAttribute
+    {
+        public APIKeyAuthAttribute()
+            : base(typeof(APIKeyAuthFilter))
+        {
+        }
+    }
+}

src/WorkFlow.API/Controllers/ControllerExtensions.cs

@@ -0,0 +1,74 @@
+using System.Security.Claims;
+using WorkFlow.API.Attributes;
+
+namespace WorkFlow.API.Controllers;
+
+[APIKeyAuth]
+public static class ControllerExtensions
+{
+    public static bool TryGetUserId(this ClaimsPrincipal user, out int id) => int.TryParse(user.FindFirstValue(ClaimTypes.NameIdentifier), out id);
+
+    public static bool TryGetUsername(this ClaimsPrincipal user, out string username)
+    {
+        var value = user.FindFirstValue(ClaimTypes.Name);
+
+        if (value is null)
+        {
+            username = string.Empty;
+            return false;
+        }
+        else
+        {
+            username = value;
+            return true;
+        }
+    }
+
+    public static bool TryGetName(this ClaimsPrincipal user, out string name)
+    {
+        var value = user.FindFirstValue(ClaimTypes.Surname);
+
+        if (value is null)
+        {
+            name = string.Empty;
+            return false;
+        }
+        else
+        {
+            name = value;
+            return true;
+        }
+    }
+
+    public static bool TryGetPrename(this ClaimsPrincipal user, out string prename)
+    {
+        var value = user.FindFirstValue(ClaimTypes.GivenName);
+
+        if (value is null)
+        {
+            prename = string.Empty;
+            return false;
+        }
+        else
+        {
+            prename = value;
+            return true;
+        }
+    }
+
+    public static bool TryGetEmail(this ClaimsPrincipal user, out string email)
+    {
+        var value = user.FindFirstValue(ClaimTypes.Email);
+
+        if (value is null)
+        {
+            email = string.Empty;
+            return false;
+        }
+        else
+        {
+            email = value;
+            return true;
+        }
+    }
+}

src/WorkFlow.API/Controllers/FileController.cs

@@ -0,0 +1,57 @@
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using System.Web;
+
+namespace WorkFlow.API.Controllers;
+
+[Route("api/[controller]")]
+[ApiController]
+[Authorize]
+public class FileController : ControllerBase
+{
+    [HttpGet("{path}")]
+    public IActionResult GetFile([FromRoute] string path, [FromQuery] bool icon = false)
+    {
+        string dPath = HttpUtility.UrlDecode(path);
+
+        byte[]? fileBytes = null;
+        string? contentType = null;      
+
+        if (dPath == "docs/doc1.pdf" && !icon)
+        {
+            fileBytes = Convert.FromBase64String(Base64File.Doc1Base64);
+            contentType = "application/pdf";
+        }
+        else if (dPath == "icons/icon1.png" && icon)
+        {
+            fileBytes = Convert.FromBase64String(Base64File.Icon1Base64);
+            contentType = "image/png";
+        }
+        else
+        {
+            string fullPath = Path.Combine(AppContext.BaseDirectory, "files", dPath);
+            if (!System.IO.File.Exists(fullPath))
+                return NotFound();
+
+            fileBytes = System.IO.File.ReadAllBytes(fullPath);
+            contentType = GetContentType(fullPath);
+        }
+
+        return File(fileBytes, contentType ?? "application/octet-stream");
+    }
+
+    private string GetContentType(string path)
+    {
+        var ext = Path.GetExtension(path).ToLowerInvariant();
+        return ext switch
+        {
+            ".pdf" => "application/pdf",
+            ".png" => "image/png",
+            ".jpg" => "image/jpeg",
+            ".jpeg" => "image/jpeg",
+            ".txt" => "text/plain",
+            ".docx" => "application/vnd.openxmlformats-officedocument.wordprocessingml.document",
+            _ => "application/octet-stream",
+        };
+    }
+}

src/WorkFlow.API/Controllers/PlaceholderAuthController.cs

@@ -0,0 +1,24 @@
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Authorization;
+using WorkFlow.API.Models;
+using WorkFlow.API.Attributes;
+
+namespace WorkFlow.API.Controllers;
+
+//TODO: implement up-to-date AuthController in UserManager
+[APIKeyAuth]
+[Route("api/Auth")]
+[ApiController]
+[Tags("Auth")]
+public class PlaceholderAuthController : ControllerBase
+{
+    [HttpPost]
+    public IActionResult CreateToken([FromBody] Login login)
+    {
+        throw new NotImplementedException();
+    }
+
+    [HttpGet("check")]
+    [Authorize]
+    public IActionResult Check() => Ok();
+}

src/WorkFlow.API/Controllers/ProfileController.cs

@@ -0,0 +1,37 @@
+using MediatR;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using WorkFlow.API.Attributes;
+using WorkFlow.Application.Profiles;
+
+namespace WorkFlow.API.Controllers;
+
+[APIKeyAuth]
+[Route("api/[controller]")]
+[ApiController]
+[Authorize]
+public class ProfileController : ControllerBase
+{
+    private readonly ILogger<ProfileController> _logger;
+
+    private readonly IMediator _mediator;
+
+    public ProfileController(ILogger<ProfileController> logger, IMediator mediator)
+    {
+        _logger = logger;
+        _mediator = mediator;
+    }
+
+    [HttpGet]
+    public async Task<IActionResult> GetAsync()
+    {
+        if (!User.TryGetUserId(out var userId))
+        {
+            _logger.LogError("Invalid user ID: Retrieved ID is null or not an integer.");
+            return Unauthorized("Failed to retrieve user identity.");
+        }
+
+        var profile = await _mediator.ReadProfileAsync(userId);
+        return Ok(profile);
+    }
+}

src/WorkFlow.API/Controllers/UserController.cs

@@ -0,0 +1,42 @@
+using DigitalData.Core.Abstraction.Application.DTO;
+using DigitalData.UserManager.Application.Contracts;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+using WorkFlow.API.Attributes;
+
+namespace WorkFlow.API.Controllers;
+
+[APIKeyAuth]
+[Route("api/[controller]")]
+[ApiController]
+[Authorize]
+[Obsolete("Use MediatR")]
+public class UserController : ControllerBase
+{
+    private readonly ILogger<UserController> logger;
+    private readonly IUserService userService;
+
+    public UserController(ILogger<UserController> logger, IUserService userService)
+    {
+        this.logger = logger;
+        this.userService = userService;
+    }
+
+    [HttpGet]
+    public async Task<IActionResult> GetAsync()
+    {
+        if (!User.TryGetUserId(out var id))
+        {
+            logger.LogError("Authorization failed: User ID claim not found.");
+            return Unauthorized("Failed to retrieve user identity.");
+        }
+
+        return await userService.ReadByIdAsync(id).ThenAsync(
+            Success: Ok,
+            Fail: IActionResult (msg, ntc) =>
+            {
+                logger.LogNotice(ntc);
+                return NotFound();
+            });
+    }
+}

src/WorkFlow.API/Extensions/DIExtensions.cs

@@ -0,0 +1,22 @@
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+using Microsoft.Extensions.Options;
+using WorkFlow.API.Filters;
+using WorkFlow.API.Models;
+
+namespace WorkFlow.API.Extensions
+{
+    public static class DIExtensions
+    {
+        public static IServiceCollection AddAPIKeyAuth(this IServiceCollection services, Func<string?, bool> isValidKey, string headerName = "X-API-Key")
+            => services.AddSingleton<APIKeyAuthFilter>(provider => new(isValidKey: isValidKey, headerName: headerName));
+
+        public static IServiceCollection AddAPIKeyAuth(this IServiceCollection services, APIKeyAuthOptions options, bool configureOptions = true)
+        {
+            if(configureOptions)
+                services.TryAddSingleton(Options.Create(options));
+
+            return services.AddAPIKeyAuth(isValidKey: key => options.Key is null || options.Key == key, headerName: options.HeaderName);
+        }
+    }
+}

src/WorkFlow.API/Filters/APIKeyAuthFilter.cs

@@ -0,0 +1,22 @@
+using Microsoft.AspNetCore.Mvc.Filters;
+using Microsoft.AspNetCore.Mvc;
+
+namespace WorkFlow.API.Filters;
+
+public class APIKeyAuthFilter : IAuthorizationFilter
+{
+    private readonly Func<string?, bool> isValidKey;
+    private readonly string headerName;
+
+    public APIKeyAuthFilter(Func<string?, bool> isValidKey, string headerName = "X-API-Key")
+    {
+        this.isValidKey = isValidKey;
+        this.headerName = headerName;
+    }
+
+    public void OnAuthorization(AuthorizationFilterContext context)
+    {
+        if (!isValidKey(context.HttpContext.Request.Headers[headerName]))
+            context.Result = new UnauthorizedResult();
+    }
+}

src/WorkFlow.API/Filters/APIKeyAuthHeaderOpFilter.cs

@@ -0,0 +1,42 @@
+using Microsoft.Extensions.Options;
+using Microsoft.OpenApi.Any;
+using Microsoft.OpenApi.Models;
+using Swashbuckle.AspNetCore.SwaggerGen;
+using WorkFlow.API.Models;
+
+namespace WorkFlow.API.Filters;
+
+public class APIKeyAuthHeaderOpFilter : IOperationFilter
+{
+    private readonly APIKeyAuthOptions apiKeyAuthOptions;
+    private readonly IWebHostEnvironment environment;
+
+    public APIKeyAuthHeaderOpFilter(IOptions<APIKeyAuthOptions> options, IWebHostEnvironment environment)
+    {
+        this.environment = environment;
+        apiKeyAuthOptions = options.Value;
+    }
+
+    public void Apply(OpenApiOperation operation, OperationFilterContext context)
+    {
+        var param = new OpenApiParameter
+        {
+            Name = apiKeyAuthOptions.HeaderName,
+            In = ParameterLocation.Header,
+            Required = true,
+            AllowEmptyValue = false,
+            Schema = new OpenApiSchema
+            {
+                Type = "string"
+            }
+        };
+
+        if(environment.IsDevelopment())
+            param.Schema.Default = new OpenApiString(apiKeyAuthOptions.Key);
+
+        if (apiKeyAuthOptions.SwaggerDescription is not null)
+            param.Description = apiKeyAuthOptions.SwaggerDescription;
+
+        operation.Parameters.Add(param);
+    }
+}

src/WorkFlow.API/Jenkinsfile

@@ -0,0 +1,10 @@
+pipeline {
+    agent any
+    stages {
+        stage('Build') {
+            steps {
+                sh 'dotnet build'
+            }
+        }
+    }
+}

src/WorkFlow.API/LazyServiceProvider.cs

@@ -0,0 +1,18 @@
+namespace WorkFlow.API;
+
+public class LazyServiceProvider : IServiceProvider
+{
+    private Lazy<IServiceProvider>? _serviceProvider;
+
+    public Func<IServiceProvider> Factory 
+    {
+        set => _serviceProvider = new(value);
+    }
+
+    public object? GetService(Type serviceType)
+    {
+        if (_serviceProvider is null)
+            throw new InvalidOperationException("GetService cannot be called before _serviceProvider is set.");
+        return _serviceProvider.Value.GetService(serviceType);
+    }
+}

src/WorkFlow.API/Middleware/ExceptionHandlingMiddleware.cs

@@ -0,0 +1,84 @@
+using DigitalData.Core.Exceptions;
+using System.Net;
+using System.Text.Json;
+
+namespace WorkFlow.API.Middleware;
+
+//TODO: Fix and use DigitalData.Core.Exceptions.Middleware
+/// <summary>
+/// Middleware for handling exceptions globally in the application.
+/// Captures exceptions thrown during the request pipeline execution,
+/// logs them, and returns an appropriate HTTP response with a JSON error message.
+/// </summary>
+[Obsolete("Use DigitalData.Core.Exceptions.Middleware")]
+public class ExceptionHandlingMiddleware
+{
+    private readonly RequestDelegate _next;
+    private readonly ILogger<ExceptionHandlingMiddleware> _logger;
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="ExceptionHandlingMiddleware"/> class.
+    /// </summary>
+    /// <param name="next">The next middleware in the request pipeline.</param>
+    /// <param name="logger">The logger instance for logging exceptions.</param>
+    public ExceptionHandlingMiddleware(RequestDelegate next, ILogger<ExceptionHandlingMiddleware> logger)
+    {
+        _next = next;
+        _logger = logger;
+    }
+
+    /// <summary>
+    /// Invokes the middleware to handle the HTTP request.
+    /// </summary>
+    /// <param name="context">The HTTP context of the current request.</param>
+    /// <returns>A task that represents the asynchronous operation.</returns>
+    public async Task InvokeAsync(HttpContext context)
+    {
+        try
+        {
+            await _next(context); // Continue down the pipeline
+        }
+        catch (Exception ex)
+        {
+            await HandleExceptionAsync(context, ex, _logger);
+        }
+    }
+
+    /// <summary>
+    /// Handles exceptions by logging them and writing an appropriate JSON response.
+    /// </summary>
+    /// <param name="context">The HTTP context of the current request.</param>
+    /// <param name="exception">The exception that occurred.</param>
+    /// <param name="logger">The logger instance for logging the exception.</param>
+    /// <returns>A task that represents the asynchronous operation.</returns>
+    private static async Task HandleExceptionAsync(HttpContext context, Exception exception, ILogger logger)
+    {
+        context.Response.ContentType = "application/json";
+
+        string message;
+
+        switch (exception)
+        {
+            case BadRequestException badRequestEx:
+                context.Response.StatusCode = (int)HttpStatusCode.BadRequest;
+                message = badRequestEx.Message;
+                break;
+
+            case NotFoundException notFoundEx:
+                context.Response.StatusCode = (int)HttpStatusCode.NotFound;
+                message = notFoundEx.Message;
+                break;
+
+            default:
+                logger.LogError(exception, "Unhandled exception occurred.");
+                context.Response.StatusCode = (int)HttpStatusCode.InternalServerError;
+                message = "An unexpected error occurred.";
+                break;
+        }
+
+        await context.Response.WriteAsync(JsonSerializer.Serialize(new
+        {
+            message
+        }));
+    }
+}

src/WorkFlow.API/Models/APIKeyAuthOptions.cs

@@ -0,0 +1,11 @@
+namespace WorkFlow.API.Models
+{
+    public class APIKeyAuthOptions
+    {
+        public string? Key { get; init; } = null;
+
+        public string HeaderName { get; init; } = "X-API-Key";
+
+        public string? SwaggerDescription { get; init; } = null;
+    }
+}

src/WorkFlow.API/Models/AuthTokenKeys.cs

@@ -0,0 +1,12 @@
+namespace WorkFlow.API.Models;
+
+public class AuthTokenKeys
+{
+    public string Cookie { get; init; } = "AuthToken";
+
+    public string QueryString { get; init; } = "AuthToken";
+
+    public string Issuer { get; init; } = "auth.digitaldata.works";
+
+    public string Audience { get; init; } = "work-flow.digitaldata.works";
+}

src/WorkFlow.API/Models/Login.cs

@@ -0,0 +1,4 @@
+namespace WorkFlow.API.Models
+{
+    public record Login(int? UserId, string? Username, string Password);
+}

src/WorkFlow.API/Models/ModelExtensions.cs

@@ -0,0 +1,19 @@
+using DigitalData.UserManager.Application.DTOs.User;
+using System.Security.Claims;
+
+namespace WorkFlow.API.Models
+{
+    public static class ModelExtensions
+    {
+        public static List<Claim> ToClaimList(this UserReadDto user) => new()
+        {
+            new (ClaimTypes.NameIdentifier, user.Id.ToString()),
+            new (ClaimTypes.Name, user.Username),
+            new (ClaimTypes.Surname, user.Name ?? ""),
+            new (ClaimTypes.GivenName, user.Prename ?? ""),
+            new (ClaimTypes.Email, user.Email ?? "")
+        };
+
+        public static Dictionary<string, object> ToClaimDictionary(this UserReadDto user) => user.ToClaimList().ToDictionary(claim => claim.Type, claim => (object) claim.Value);
+    }
+}

src/WorkFlow.API/Program.cs

@@ -0,0 +1,181 @@
+using DigitalData.Auth.Client;
+using DigitalData.Core.Abstractions.Security.Extensions;
+using DigitalData.Core.Application;
+using DigitalData.UserManager.Application.DTOs.User;
+using DigitalData.UserManager.DependencyInjection;
+using Microsoft.AspNetCore.Authentication.JwtBearer;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Options;
+using Microsoft.IdentityModel.Tokens;
+using Microsoft.OpenApi.Models;
+using NLog;
+using NLog.Web;
+using WorkFlow.API;
+using WorkFlow.API.Extensions;
+using WorkFlow.API.Filters;
+using WorkFlow.API.Middleware;
+using WorkFlow.API.Models;
+using WorkFlow.Application;
+using WorkFlow.Infrastructure;
+
+var logger = LogManager.Setup().LoadConfigurationFromAppSettings().GetCurrentClassLogger();
+logger.Info("Logging initialized.");
+
+try
+{
+    var builder = WebApplication.CreateBuilder(args);
+    var config = builder.Configuration;
+
+    Directory
+        .GetFiles(builder.Environment.ContentRootPath, "appsettings.*.json", SearchOption.TopDirectoryOnly)
+        .Where(file => Path.GetFileName(file) != $"appsettings.Development.json")
+        .ToList()
+        .ForEach(file => config.AddJsonFile(file, true, true));
+
+    // Add NLogger
+    builder.Logging.SetMinimumLevel(Microsoft.Extensions.Logging.LogLevel.Trace);
+    if (!builder.Environment.IsDevelopment())
+    {
+        builder.Logging.ClearProviders();
+        builder.Host.UseNLog();
+    }
+
+    // Add services to the container
+    var cnn_str = config.GetConnectionString("Default") ?? throw new("Default connection string not found.");
+    builder.Services.AddDbContext<WFDBContext>(options => options.UseSqlServer(cnn_str).EnableDetailedErrors());
+    var mediatRLicense = config["MediatRLicense"]
+        ?? throw new InvalidOperationException(
+            "The 'MediatRLicense' configuration value is missing or empty." +
+            "Please ensure it is properly set in the configuration source.");
+    builder.Services.AddWorkFlowServices(opt =>
+    {
+        opt.MediatRLicense = mediatRLicense;
+        opt.ConfigMapping(config.GetSection("MappingOptions"));
+    }).AddWorkFlowRepositories();
+        
+    builder.Services.AddUserManager<WFDBContext>();
+    
+    builder.Services.AddDirectorySearchService(config.GetSection("DirectorySearchOptions"));
+    builder.Services.AddJWTService<UserReadDto>(user => new SecurityTokenDescriptor()
+    {
+        Claims = user.ToClaimList().ToDictionary(claim => claim.Type, claim => claim.Value as object)
+    });
+
+    bool disableAPIKeyAuth = config.GetValue<bool>("DisableAPIKeyAuth");
+    if (disableAPIKeyAuth)
+        builder.Services.AddAPIKeyAuth(new APIKeyAuthOptions());
+    else
+        if (config.GetSection("APIKeyAuth").Get<APIKeyAuthOptions>() is APIKeyAuthOptions options)
+        builder.Services.AddAPIKeyAuth(options);
+    else
+        throw new("The API Key Authorization configuration is not available in the app settings, even though the app is not in development or DiP mode and API Key Authorization is not disabled.");
+
+    var lazyProvider = new LazyServiceProvider();
+
+    builder.Services.AddAuthHubClient(config.GetSection("AuthClientParams"));
+
+    builder.Services.AddControllers();
+
+    var authTokenKeys = config.GetSection(nameof(AuthTokenKeys)).Get<AuthTokenKeys>() ?? new();
+
+    builder.Services.AddAuthentication(options =>
+    {
+        options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
+        options.DefaultChallengeScheme = JwtBearerDefaults.AuthenticationScheme;
+    })
+            .AddJwtBearer(opt =>
+        {
+            opt.TokenValidationParameters = new TokenValidationParameters
+            {
+                ValidateIssuerSigningKey = true,
+                IssuerSigningKeyResolver = (token, securityToken, identifier, parameters) =>
+                {
+                    var clientParams = lazyProvider.GetRequiredService<IOptions<ClientParams>>()?.Value;
+                    var publicKey = clientParams!.PublicKeys.Get(authTokenKeys.Issuer, authTokenKeys.Audience);
+                    return new List<SecurityKey>() { publicKey.SecurityKey };
+                },
+                ValidateIssuer = true,
+                ValidIssuer = authTokenKeys.Issuer,
+                ValidateAudience = true,
+                ValidAudience = authTokenKeys.Audience,
+            };
+
+            opt.Events = new JwtBearerEvents
+            {
+                OnMessageReceived = context =>
+                {
+                    // if there is no token read related cookie or query string
+                    if (context.Token is null)   // if there is no token
+                    {
+                        if (context.Request.Cookies.TryGetValue(authTokenKeys.Cookie, out var cookieToken) && cookieToken is not null)
+                            context.Token = cookieToken;
+                        else if (context.Request.Query.TryGetValue(authTokenKeys.QueryString, out var queryStrToken))
+                            context.Token = queryStrToken;
+                    }
+                    return Task.CompletedTask;
+                }
+            };
+        });
+
+    builder.Services.AddEndpointsApiExplorer();
+    builder.Services.AddSwaggerGen(setupAct =>
+    {
+        setupAct.AddSecurityDefinition("Bearer", new OpenApiSecurityScheme
+        {
+            Description = "JWT Authorization header using the Bearer scheme. Example: \"Bearer {token}\"",
+            Name = "Authorization",
+            In = ParameterLocation.Header,
+            Type = SecuritySchemeType.Http,
+            Scheme = "Bearer"
+        });
+
+        setupAct.AddSecurityRequirement(new OpenApiSecurityRequirement
+        {
+            {
+                new OpenApiSecurityScheme
+                {
+                    Reference = new OpenApiReference
+                    {
+                        Type = ReferenceType.SecurityScheme,
+                        Id = "Bearer"
+                    }
+                },
+                Array.Empty<string>()
+            }
+        });
+
+        if (!disableAPIKeyAuth)
+            setupAct.OperationFilter<APIKeyAuthHeaderOpFilter>();
+
+        if (config.GetSection("OpenApiInfo").Get<OpenApiInfo>() is OpenApiInfo openApiInfo)
+            setupAct.SwaggerDoc(openApiInfo?.Version ?? "v1", openApiInfo);
+    });
+
+    var app = builder.Build();
+
+    lazyProvider.Factory = () => app.Services;
+
+    app.UseMiddleware<ExceptionHandlingMiddleware>();
+
+    // Configure the HTTP request pipeline.
+    if (app.Configuration.GetValue<bool>("EnableSwagger"))
+    {
+        app.UseSwagger();
+        app.UseSwaggerUI();
+    }
+
+    app.UseHttpsRedirection();
+
+    app.UseAuthentication();
+
+    app.UseAuthorization();
+
+    app.MapControllers();
+
+    app.Run();
+}
+catch (Exception ex)
+{
+    logger.Error(ex, "Stopped program because of exception.");
+    throw;
+}

src/WorkFlow.API/Properties/launchSettings.json

@@ -0,0 +1,41 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:56180",
+      "sslPort": 44397
+    }
+  },
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": false,
+      "launchUrl": "swagger",
+      "applicationUrl": "http://localhost:5130",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "applicationUrl": "https://localhost:7120;http://localhost:5130",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": false,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

src/WorkFlow.API/WFKey.cs

@@ -0,0 +1,8 @@
+namespace WorkFlow.API
+{
+    public static class WFKey
+    {
+        public static readonly string WrongPassword = nameof(WrongPassword);
+        public static readonly string UserNotFoundOrWrongPassword = nameof(UserNotFoundOrWrongPassword);
+    }
+}

src/WorkFlow.API/WorkFlow.API.csproj

@@ -0,0 +1,38 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFrameworks>net7.0;net8.0</TargetFrameworks>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <PackageId>WorkFlow.API</PackageId>
+    <Version>1.2.1</Version>
+    <Company>Digital Data GmbH</Company>
+    <Product>WorkFlow.API</Product>
+    <Title>WorkFlow.API</Title>
+    <AssemblyVersion>1.2.1</AssemblyVersion>
+    <FileVersion>1.2.1</FileVersion>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <_WebToolingArtifacts Remove="Properties\PublishProfiles\IISProfile - Copy.pubxml" />
+    <_WebToolingArtifacts Remove="Properties\PublishProfiles\IISProfileNet7.pubxml" />
+    <_WebToolingArtifacts Remove="Properties\PublishProfiles\IISProfileNet8.pubxml" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="DigitalData.Auth.Client" Version="1.3.7" />
+    <PackageReference Include="DigitalData.Core.Abstraction.Application" Version="1.0.0" />
+    <PackageReference Include="DigitalData.Core.Exceptions" Version="1.0.1" />
+    <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="7.0.20" />
+    <PackageReference Include="NLog" Version="5.3.4" />
+    <PackageReference Include="NLog.Web.AspNetCore" Version="5.3.14" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
+    <PackageReference Include="UserManager" Version="1.1.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\WorkFlow.Application\WorkFlow.Application.csproj" />
+    <ProjectReference Include="..\WorkFlow.Infrastructure\WorkFlow.Infrastructure.csproj" />
+  </ItemGroup>
+
+</Project>

src/WorkFlow.API/appsettings.Auth.json

@@ -0,0 +1,18 @@
+{
+  "DisableAPIKeyAuth": true,
+  "APIKeyAuth": {
+    "Key": "ULbcOUiAXAoCXPviyCGtObZUGnrCHNgDmtNbQNpq5MOhB0EFQn18dObdQ93INNy8xIcnOPMJfEHqOotllELVrJ2R5AjqOfQszT2j00w215GanD3UiJGwFhwmdoNFsmNj",
+    "HeaderName": "X-API-Key",
+    "SwaggerDescription": "Required header for API key authentication. Enter a valid API key."
+  },
+  "AuthClientParams": {
+    "Url": "http://172.24.12.39:9090/auth-hub",
+    "RetryDelay": "00:00:05",
+    "PublicKeys": [
+      {
+        "Issuer": "auth.digitaldata.works",
+        "Audience": "work-flow.digitaldata.works"
+      }
+    ]
+  }
+}

src/WorkFlow.API/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

src/WorkFlow.API/appsettings.LDAP.json

@@ -0,0 +1,11 @@
+{
+  "DirectorySearchOptions": {
+    "ServerName": "DD-VMP01-DC01",
+    "Root": "DC=dd-gan,DC=local,DC=digitaldata,DC=works",
+    "UserCacheExpirationDays": 1,
+    "CustomSearchFilters": {
+      "User": "(&(objectClass=user)(sAMAccountName=*))",
+      "Group": "(&(objectClass=group) (samAccountName=*))"
+    }
+  }
+}

src/WorkFlow.API/appsettings.Logging.json

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

src/WorkFlow.API/appsettings.Mapping.json

@@ -0,0 +1,17 @@
+{
+  "MappingOptions": {
+    "TfFileUri": {
+      "Scheme": "https",
+      "Host": "dd-gan.digitaldata.works",
+      "Port": 8443,
+      "Path": "api/file"
+    },
+    "TfFileIconUri": {
+      "Scheme": "https",
+      "Host": "dd-gan.digitaldata.works",
+      "Port": 8443,
+      "Path": "api/file",
+      "Query": "icon=true"
+    }
+  }
+}

src/WorkFlow.API/appsettings.json

@@ -0,0 +1,17 @@
+{
+  "DiPMode": true,
+  "EnableSwagger": true,
+  "AllowedHosts": "*",
+  "ConnectionStrings": {
+    "Default": "Server=SDD-VMP04-SQL17\\DD_DEVELOP01;Database=DD_ECM;User Id=sa;Password=dd;Encrypt=false;TrustServerCertificate=True;"
+  },
+  "OpenApiInfo": {
+    "Title": "WorkFlow API",
+    "Contact": {
+      "Email": "info-flow@digitaldata.works",
+      "Name": "Digital Data GmbH",
+      "Url": "https://digitaldata.works/"
+    }
+  },
+  "MediatRLicense": "eyJhbGciOiJSUzI1NiIsImtpZCI6Ikx1Y2t5UGVubnlTb2Z0d2FyZUxpY2Vuc2VLZXkvYmJiMTNhY2I1OTkwNGQ4OWI0Y2IxYzg1ZjA4OGNjZjkiLCJ0eXAiOiJKV1QifQ.eyJpc3MiOiJodHRwczovL2x1Y2t5cGVubnlzb2Z0d2FyZS5jb20iLCJhdWQiOiJMdWNreVBlbm55U29mdHdhcmUiLCJleHAiOiIxNzg0ODUxMjAwIiwiaWF0IjoiMTc1MzM2MjQ5MSIsImFjY291bnRfaWQiOiIwMTk4M2M1OWU0YjM3MjhlYmZkMzEwM2MyYTQ4NmU4NSIsImN1c3RvbWVyX2lkIjoiY3RtXzAxazB5NmV3MmQ4YTk4Mzg3aDJnbTRuOWswIiwic3ViX2lkIjoiLSIsImVkaXRpb24iOiIwIiwidHlwZSI6IjIifQ.ZqsFG7kv_-xGfxS6ACk3i0iuNiVUXX2AvPI8iAcZ6-z2170lGv__aO32tWpQccD9LCv5931lBNLWSblKS0MT3gOt-5he2TEftwiSQGFwoIBgtOHWsNRMinUrg2trceSp3IhyS3UaMwnxZDrCvx4-0O-kpOzVpizeHUAZNr5U7oSCWO34bpKdae6grtM5e3f93Z1vs7BW_iPgItd-aLvPwApbaG9VhmBTKlQ7b4Jh64y7UXJ9mKP7Qb_Oa97oEg0oY5DPHOWTZWeE1EzORgVr2qkK2DELSHuZ_EIUhODojkClPNAKtvEl_qEjpq0HZCIvGwfCCRlKlSkQqIeZdFkiXg"
+}

src/WorkFlow.Application/Buttons/ReadButton.cs

@@ -0,0 +1,20 @@
+namespace WorkFlow.Application.Buttons;
+
+public record ButtonDto
+{
+    public byte? DialogNo { get; init; }
+
+    public string? BtnType { get; init; }
+
+    public string? Icon { get; init; }
+
+    public string? ForeColor { get; init; }
+
+    public string? BackColor { get; init; }
+
+    public string? Command { get; init; }
+
+    public string? DialogCommand { get; init; }
+
+    public string? ConfirmationText { get; init; }
+}

src/WorkFlow.Application/Contracts/Repositories/IProfileObjRepository.cs

@@ -0,0 +1,23 @@
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Application.Contracts.Repositories;
+
+/// <summary>
+/// Repository for retrieving <see cref="PObject"/> entities from the database.
+/// </summary>
+public interface IProfileObjRepository
+{
+    /// <summary>
+    /// Retrieves the list of <see cref="PObject"/> associated with a given user ID and profile ID by calling a database function.
+    /// </summary>
+    /// <param name="userId">The unique identifier of the user whose profile is to be retrieved.</param>
+    /// <param name="profileId">The unique identifier of the profile whose object is to be retrieved.</param>
+    /// <param name="cancel">Propagates notification that operations should be canceled.</param>
+    /// <returns>
+    /// A task that represents the asynchronous operation. The task result contains the <see cref="PObject"/> object if found; otherwise, <c>null</c>.
+    /// </returns>
+    /// <remarks>
+    /// Logs an error if no profile is found, or if multiple profiles are returned, indicating potential data issues.
+    /// </remarks>
+    public Task<IEnumerable<PObject>> ReadAsync(int userId, int profileId, CancellationToken cancel = default);
+}

src/WorkFlow.Application/Contracts/Repositories/IProfileRepository.cs

@@ -0,0 +1,22 @@
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Application.Contracts.Repositories;
+
+/// <summary>
+/// Repository implementation for retrieving <see cref="Profile"/> entities from the database.
+/// </summary>
+public interface IProfileRepository
+{
+    /// <summary>
+    /// Retrieves the <see cref="Profile"/> associated with a given user ID by calling a database function.
+    /// </summary>
+    /// <param name="userId">The unique identifier of the user whose profile is to be retrieved.</param>
+    /// <param name="cancel">Propagates notification that operations should be canceled.</param>
+    /// <returns>
+    /// A task that represents the asynchronous operation. The task result contains the <see cref="Profile"/> object if found; otherwise, <c>null</c>.
+    /// </returns>
+    /// <remarks>
+    /// Logs an error if no profile is found, or if multiple profiles are returned, indicating potential data issues.
+    /// </remarks>
+    Task<Profile?> ReadAsync(int userId, CancellationToken cancel = default);
+}

src/WorkFlow.Application/DTO/BaseCreateDto.cs

@@ -0,0 +1,13 @@
+using System.Text.Json.Serialization;
+
+namespace WorkFlow.Application.Dto
+{
+    public record BaseCreateDto
+    {
+        [JsonIgnore]
+        public required string AddedWho { get; set; } = "UNKNOWN";
+
+        [JsonIgnore]
+        public required DateTime AddedWhen = DateTime.Now;
+    }
+}

src/WorkFlow.Application/DTO/BaseUpdateDto.cs

@@ -0,0 +1,15 @@
+using System.Text.Json.Serialization;
+
+namespace WorkFlow.Application.Dto
+{
+    public record BaseUpdateDto
+    {
+        public required int Id { get; init; }
+
+        [JsonIgnore]
+        public required string ChangedWho { get; set; } = "UNKNOWN";
+
+        [JsonIgnore]
+        public required DateTime ChangedWhen = DateTime.Now;
+    }
+}

src/WorkFlow.Application/DependencyInjection.cs

@@ -0,0 +1,52 @@
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using WorkFlow.Application.Mapping;
+
+namespace WorkFlow.Application;
+
+public static class DependencyInjection
+{
+    public static IServiceCollection AddWorkFlowServices(this IServiceCollection services, Action<WorkFlowServiceOptions>? options = null)
+    {
+        WorkFlowServiceOptions sOptions = new(services);
+        options?.Invoke(sOptions);
+
+        services.AddAutoMapper(typeof(MappingProfile).Assembly);
+        services.AddMediatR(cfg =>
+        {
+            cfg.RegisterServicesFromAssembly(typeof(DependencyInjection).Assembly);
+            cfg.LicenseKey = sOptions.MediatRLicense;
+        });
+
+        if(!sOptions.IsMappingConfigured)
+            services.Configure<MappingOptions>(_ => { });
+
+        services.AddTransient<TfFileUriResolver>();
+        services.AddTransient<TfFileIconUriResolver>();
+
+        return services;
+    }
+
+    public class WorkFlowServiceOptions
+    {
+        private readonly IServiceCollection _services;
+
+        internal bool IsMappingConfigured { get; private set; } = false;
+
+        public WorkFlowServiceOptions(IServiceCollection services) => _services = services;
+    
+        private void EnsureSingleMappingConfiguration(Action action)
+        {
+            if (IsMappingConfigured)
+                throw new InvalidOperationException("Mapping configuration has already been set.");
+            action();
+            IsMappingConfigured = true;
+        }
+
+        public void ConfigMapping(IConfiguration config) => EnsureSingleMappingConfiguration(() => _services.Configure<MappingOptions>(config));
+
+        public void ConfigMapping(Action<MappingOptions> options) => EnsureSingleMappingConfiguration(() => _services.Configure(options));
+
+        public string? MediatRLicense { get; set; }
+    }
+}

src/WorkFlow.Application/Dto/ConfigDto.cs

@@ -0,0 +1,10 @@
+namespace WorkFlow.Application.Dto
+{
+    public record ConfigDto(int Id,
+                            string Title,
+                            string String,
+                            string AddedWho,
+                            DateTime AddedWhen,
+                            string? ChangedWho = null,
+                            DateTime? ChangedWhen = null);
+}

src/WorkFlow.Application/Dto/ObjectDto.cs

@@ -0,0 +1,16 @@
+namespace WorkFlow.Application.Dto;
+
+public class ObjectDto
+{
+    public IEnumerable<string> Headlines { get; set; } = Array.Empty<string>();
+
+    public IEnumerable<string> Sublines { get; set; } = Array.Empty<string>();
+
+    public string? CmdCheckIn { get; set; }
+
+    public ObjectStateDto? State { get; set; }
+
+    public IEnumerable<ObjectStateHistDto> StateHistories { get; set; } = Array.Empty<ObjectStateHistDto>();
+
+    public IEnumerable<PControlsUpdateDto>? ControlsUpdates { get; set; } = Array.Empty<PControlsUpdateDto>();
+}

src/WorkFlow.Application/Dto/ObjectStateDto.cs

@@ -0,0 +1,15 @@
+namespace WorkFlow.Application.Dto;
+
+public record ObjectStateDto
+{
+    public virtual string? Intl { get; set; }
+
+    /// <summary>
+    /// Holds state 2, 3 and 4 as a list of strings.
+    /// </summary>
+    public IEnumerable<string> Others { get; set; } = Array.Empty<string>();
+
+    public virtual IEnumerable<PControlsTFDto>? TFControls { get; set; }
+
+    public virtual IEnumerable<TfFileDto>? TfFiles { get; set; }
+}

src/WorkFlow.Application/Dto/ObjectStateHistDto.cs

@@ -0,0 +1,15 @@
+namespace WorkFlow.Application.Dto;
+
+public record ObjectStateHistDto
+{
+    public virtual string? Intl { get; set; }
+
+    /// <summary>
+    /// Holds state 2, 3 and 4 as a list of strings.
+    /// </summary>
+    public IEnumerable<string> Others { get; set; } = Array.Empty<string>();
+
+    public string? ChangedWho { get; set; }
+
+    public DateTime? ChangedWhen { get; set; }
+}

src/WorkFlow.Application/Dto/PControlsTFDto.cs

@@ -0,0 +1,24 @@
+namespace WorkFlow.Application.Dto;
+
+public record PControlsTFDto
+{
+    public byte? DialogNo { get; set; }
+
+    public string? AttrName { get; set; }
+
+    public string? CtrlType { get; set; }
+
+    public string? Caption { get; set; }
+
+    public string? Text { get; set; }
+
+    public string? Icon { get; set; }
+
+    public bool? Mandatory { get; set; }
+
+    public string? ChoiceList { get; set; }
+
+    public bool? ReadOnly { get; set; }
+
+    public byte? Sequ { get; set; }
+}

src/WorkFlow.Application/Dto/PControlsUpdateDto.cs

@@ -0,0 +1,12 @@
+namespace WorkFlow.Application.Dto;
+
+public record PControlsUpdateDto
+{
+    public string? AttrName { get; set; }
+
+    public string? AttrValue { get; set; }
+
+    public string? AddedWho { get; set; }
+
+    public DateTime? AddedWhen { get; set; }
+}

src/WorkFlow.Application/Dto/ProfileDto.cs

@@ -0,0 +1,22 @@
+using WorkFlow.Application.Buttons;
+
+namespace WorkFlow.Application.Dto;
+
+public class ProfileDto
+{
+    public byte? TypeId { get; init; }
+
+    public string? Caption { get; init; }
+
+    public string? Subtitle { get; init; }
+
+    public int? CountObj { get; init; }
+
+    public string? ForeColor { get; init; }
+
+    public string? BackColor { get; init; }
+
+    public IEnumerable<ObjectDto> Objects { get; init; } = Array.Empty<ObjectDto>();
+
+    public IEnumerable<ButtonDto>? Buttons { get; set; } = Array.Empty<ButtonDto>();
+}

src/WorkFlow.Application/Dto/TfFileDto.cs

@@ -0,0 +1,14 @@
+namespace WorkFlow.Application.Dto;
+
+public class TfFileDto
+{
+    public string? Url { get; set; }
+
+    public string? Headline { get; set; }
+
+    public string? Subline { get; set; }
+
+    public string? Comment { get; set; }
+
+    public string? IconUrl { get; set; }
+}

src/WorkFlow.Application/Mapping/MappingOptions.cs

@@ -0,0 +1,52 @@
+namespace WorkFlow.Application.Mapping;
+
+public class MappingOptions
+{
+    public UriBuilderOptions TfFileUri { get; set; } = new();
+
+    public UriBuilderOptions TfFileIconUri { get; set; } = new();
+
+    public class UriBuilderOptions
+    {
+        public string? Scheme { get; set; }
+
+        public string? Host { get; set; }
+
+        public int? Port { get; set; }
+
+        private string _path = "/";
+
+        public string Path
+        { 
+            get => _path;
+            set => _path = value.Trim('/');
+        }
+
+        private string _query = string.Empty;
+
+        public string Query
+        {
+            get => _query;
+            set => _query = value.TrimStart('?');
+        }
+
+        public UriBuilder ToBuilder
+        {
+            get
+            {
+                var uriBuilder = new UriBuilder()
+                {
+                    Scheme = Scheme ?? "http",
+                    Host = Host ?? "localhost",
+                    Path = Path,
+                    Query = Query,
+                };
+
+                if (Port is int port)
+                    uriBuilder.Port = port;
+
+                return uriBuilder;
+            }
+        }
+    }
+}

src/WorkFlow.Application/Mapping/MappingProfile.cs

@@ -0,0 +1,37 @@
+using WorkFlow.Application.Buttons;
+using WorkFlow.Application.Dto;
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Application.Mapping;
+
+public class MappingProfile : AutoMapper.Profile
+{
+    public MappingProfile()
+    {
+        CreateMap<Config, ConfigDto>();
+
+        CreateMap<Profile, ProfileDto>();
+
+        CreateMap<PControlsTF, PControlsTFDto>();
+
+        CreateMap<Button, ButtonDto>();
+
+        CreateMap<PObject, ObjectDto>()
+            .ForMember(dest => dest.Headlines, opt => opt.MapFrom(src => new[] { src.Headline1, src.Headline2 }))
+            .ForMember(dest => dest.Sublines, opt => opt.MapFrom(src => new[] { src.Subline1, src.Subline2 }));
+
+        CreateMap<PObjectState, ObjectStateDto>()
+            .ForMember(dest => dest.Intl, opt => opt.MapFrom(src => src.State1 != null ? src.State1.IntlState : null))
+            .ForMember(dest => dest.Others, opt => opt.MapFrom(src => new string?[] { src.State2, src.State3, src.State4 }));
+
+        CreateMap<PObjectStateHist, ObjectStateHistDto>()
+            .ForMember(dest => dest.Intl, opt => opt.MapFrom(src => src.State1 != null ? src.State1.IntlState : null))
+            .ForMember(dest => dest.Others, opt => opt.MapFrom(src => new string?[] { src.State2, src.State3, src.State4 }));
+
+        CreateMap<TfFile, TfFileDto>()
+            .ForMember(dest => dest.Url, opt => opt.MapFrom<TfFileUriResolver>())
+            .ForMember(dest => dest.IconUrl, opt => opt.MapFrom<TfFileIconUriResolver>());
+
+        CreateMap<PControlsUpdate, PControlsUpdateDto>();
+    }
+}

src/WorkFlow.Application/Mapping/TfFileIconUriResolver.cs

@@ -0,0 +1,24 @@
+using AutoMapper;
+using Microsoft.Extensions.Options;
+using System.Web;
+using WorkFlow.Application.Dto;
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Application.Mapping;
+
+public class TfFileIconUriResolver : IValueResolver<TfFile, TfFileDto, string?>
+{
+    private readonly Func<UriBuilder> _uriBuilderFactory;
+
+    public TfFileIconUriResolver(IOptions<MappingOptions> options) => _uriBuilderFactory = () => options.Value.TfFileIconUri.ToBuilder;
+
+    public string? Resolve(TfFile source, TfFileDto destination, string? destMember, ResolutionContext context)
+    {
+       if(string.IsNullOrEmpty(source.Icon))
+            return null;
+        
+        var builder = _uriBuilderFactory();
+        builder.AppendPath(source.Icon);
+        return builder.ToString();
+    }
+}

src/WorkFlow.Application/Mapping/TfFileUriResolver.cs

@@ -0,0 +1,23 @@
+using AutoMapper;
+using Microsoft.Extensions.Options;
+using WorkFlow.Application.Dto;
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Application.Mapping;
+
+public class TfFileUriResolver : IValueResolver<TfFile, TfFileDto, string?>
+{
+    private readonly Func<UriBuilder> _uriBuilderFactory;
+
+    public TfFileUriResolver(IOptions<MappingOptions> options) => _uriBuilderFactory = () => options.Value.TfFileUri.ToBuilder;
+
+    public string? Resolve(TfFile source, TfFileDto destination, string? destMember, ResolutionContext context)
+    {
+        if (string.IsNullOrEmpty(source.Path))
+            return null;
+
+        var builder = _uriBuilderFactory();
+        builder.AppendPath(source.Path);
+        return builder.ToString();
+    }
+}

src/WorkFlow.Application/Mapping/UriBuilderExtensions.cs

@@ -0,0 +1,14 @@
+using System.Web;
+
+namespace WorkFlow.Application.Mapping;
+
+internal static class UriBuilderExtensions
+{
+    public static void AppendPath(this UriBuilder uriBuilder, string path, bool encode = true)
+    {
+        if(encode)
+            path = HttpUtility.UrlEncode(path);
+
+        uriBuilder.Path = $"{uriBuilder.Path.TrimEnd('/', '\\')}/{path.Trim('/', '\\')}";
+    }
+}

src/WorkFlow.Application/Profiles/ReadProfileQuery.cs

@@ -0,0 +1,71 @@
+using AutoMapper;
+using DigitalData.Core.Abstraction.Application.Repository;
+using DigitalData.Core.Exceptions;
+using MediatR;
+using WorkFlow.Application.Buttons;
+using WorkFlow.Application.Contracts.Repositories;
+using WorkFlow.Application.Dto;
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Application.Profiles;
+
+/// <summary>
+/// Represents a request to read a user profile by their user ID.
+/// </summary>
+/// <param name="UserId">The ID of the user whose profile is being requested.</param>
+public record ReadProfileQuery(int UserId, bool IncludeObject = true) : IRequest<ProfileDto>;
+
+/// <summary>
+/// Handles the <see cref="ReadProfileQuery"/> request by retrieving the user profile
+/// from the data store using the <see cref="IProfileRepository"/>.
+/// </summary>
+public class ReadProfileHandler : IRequestHandler<ReadProfileQuery, ProfileDto>
+{
+    private readonly IProfileRepository _profileRepository;
+
+    private readonly IProfileObjRepository _objRepository;
+
+    private readonly IRepository<Button> _bttnRepository;
+
+    private readonly IMapper _mapper;
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="ReadProfileHandler"/> class.
+    /// </summary>
+    /// <param name="profileRepository">The profile repository used to access profile data.</param>
+    /// <param name="objRepository">The profile object repository used to access object data.</param>
+    public ReadProfileHandler(IProfileRepository profileRepository, IProfileObjRepository objRepository, IRepository<Button> buttonRepository, IMapper mapper)
+    {
+        _profileRepository = profileRepository;
+        _objRepository = objRepository;
+        _bttnRepository = buttonRepository;
+        _mapper = mapper;
+    }
+
+    /// <summary>
+    /// Handles the <see cref="ReadProfileQuery"/> request by retrieving the profile
+    /// corresponding to the specified user ID.
+    /// </summary>
+    /// <param name="request">The request containing the user ID.</param>
+    /// <param name="cancel">A cancellation token for the operation.</param>
+    /// <returns>The user profile if found; otherwise, <c>null</c>.</returns>
+    public async Task<ProfileDto> Handle(ReadProfileQuery request, CancellationToken cancel = default)
+    {
+        var profile = await _profileRepository.ReadAsync(request.UserId, cancel)
+            ?? throw new NotFoundException();
+
+        if (request.IncludeObject && profile.Id is int profileId)
+            profile.Objects = await _objRepository.ReadAsync(request.UserId, profileId, cancel);
+
+        if (profile.Id is int pId)
+            profile.Buttons = await _bttnRepository.Read(b => b.ProfileId == pId).ToListAsync(cancel);
+
+        return _mapper.Map<ProfileDto>(profile);
+    }
+}
+
+public static class ReadProfileQueryExtensions
+{
+    public static Task<ProfileDto> ReadProfileAsync(this IMediator mediator, int userId, bool includeObject = true)
+        => mediator.Send(new ReadProfileQuery(UserId: userId, IncludeObject: includeObject));
+}

src/WorkFlow.Application/WorkFlow.Application.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFrameworks>net7.0;net8.0</TargetFrameworks>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="DigitalData.Core.Abstraction.Application" Version="1.0.0" />
+    <PackageReference Include="DigitalData.Core.Application" Version="3.3.4" />
+    <PackageReference Include="DigitalData.Core.Exceptions" Version="1.0.1" />
+    <PackageReference Include="MediatR" Version="13.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="7.0.20" />
+    <PackageReference Include="UserManager" Version="1.1.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\WorkFlow.Domain\WorkFlow.Domain.csproj" />
+  </ItemGroup>
+
+</Project>

src/WorkFlow.Domain/Entities/Button.cs

@@ -0,0 +1,115 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+[Table("TBMWF_PROF_BUTTONS")]
+public class Button
+{
+    [Key]
+    [Column("GUID", TypeName = "int")]
+    public int Id { get; set; }
+
+    [Required]
+    [Column("MWF_PROFILE_ID", TypeName = "int")]
+    public required int ProfileId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("DIALOG_NO", TypeName = "tinyint")]
+    public byte? DialogNo { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("BTN_TYPE", TypeName = "nvarchar(20)")]
+    public string? BtnType { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("TEXT", TypeName = "nvarchar(500)")]
+    public string? Text { get; set; }
+
+    [Column("ICON", TypeName = "nvarchar(100)")]
+    public string? Icon { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("FORE_COLOR", TypeName = "nvarchar(100)")]
+    public string? ForeColor { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("BACK_COLOR", TypeName = "nvarchar(100)")]
+    public string? BackColor { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("COMMAND", TypeName = "nvarchar(max)")]
+    public string? Command { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("DIALOG_COMMAND", TypeName = "nvarchar(max)")]
+    public string? DialogCommand { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("CONFIRMATION_TEXT", TypeName = "nvarchar(250)")]
+    public string? ConfirmationText { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHO", TypeName = "nvarchar(100)")]
+    public string? AddedWho { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHEN", TypeName = "datetime")]
+    public DateTime? AddedWhen { get; set; }
+
+    [Column("CHANGED_WHO", TypeName = "nvarchar(100)")]
+    public string? ChangedWho { get; set; }
+
+    [Column("CHANGED_WHEN", TypeName = "datetime")]
+    public DateTime? ChangedWhen { get; set; }
+}

src/WorkFlow.Domain/Entities/Config.cs

@@ -12,11 +12,11 @@ namespace WorkFlow.Domain.Entities
 
         [Required]
         [Column("CONF_TITLE", TypeName = "varchar(100)")]
-        public required string ConfTitle { get; init; }
+        public required string Title { get; init; }
 
         [Required]
         [Column("CONF_STRING", TypeName = "varchar(900)")]
-        public required string ConfString { get; init; }
+        public required string String { get; init; }
 
         [Required]
         [Column("ADDED_WHO", TypeName = "varchar(30)")]

src/WorkFlow.Domain/Entities/PControlsTF.cs

@@ -0,0 +1,94 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+[Table("TBMWF_PROF_CONTROLS_TF", Schema = "dbo")]
+public class PControlsTF
+{
+    [Key]
+    [Column("GUID", TypeName = "bigint")]
+    public long Id { get; set; }
+
+    [Required]
+    [Column("OBJ_STATE_ID", TypeName = "bigint")]
+    public long ObjStateId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("DIALOG_NO", TypeName = "tinyint")]
+    public byte? DialogNo { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ATTR_NAME", TypeName = "nvarchar(100)")]
+    public string? AttrName { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("CTRL_TYPE", TypeName = "nvarchar(10)")]
+    public string? CtrlType { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("CAPTION", TypeName = "nvarchar(100)")]
+    public string? Caption { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("TEXT", TypeName = "nvarchar(500)")]
+    public string? Text { get; set; }
+
+    [Column("ICON", TypeName = "nvarchar(100)")]
+    public string? Icon { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("MANDATORY", TypeName = "bit")]
+    public bool? Mandatory { get; set; }
+
+    [Column("CHOICE_LIST", TypeName = "nvarchar(max)")]
+    public string? ChoiceList { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("READ_ONLY", TypeName = "bit")]
+    public bool? ReadOnly { get; set; }
+
+    [Column("SEQU", TypeName = "tinyint")]
+    public byte? Sequ { get; set; }
+
+    [Column("ADDED_WHO", TypeName = "nvarchar(100)")]
+    public required string AddedWho { get; set; }
+
+    [Column("ADDED_WHEN", TypeName = "datetime")]
+    public DateTime AddedWhen { get; set; }
+}

src/WorkFlow.Domain/Entities/PControlsUpdate.cs

@@ -0,0 +1,69 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+[Table("TBMWF_PROFILE_CONTROLS_UPDATE")]
+public class PControlsUpdate
+{
+    [Column("GUID", TypeName = "bigint")]
+    public long Id { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("MWF_PROFILE_ID", TypeName = "int")]
+    public int ProfileId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("USR_ID", TypeName = "int")]
+    public int? UsrId { get; set; }
+
+    [Required]
+    [Column("OBJ_ID", TypeName = "bigint")]
+    public long ObjId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ATTR_NAME", TypeName = "nvarchar(100)")]
+    public string? AttrName { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ATTR_VALUE", TypeName = "nvarchar(3000)")]
+    public string? AttrValue { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHO", TypeName = "nvarchar(30)")]
+    public string? AddedWho { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHEN", TypeName = "datetime")]
+    public DateTime? AddedWhen { get; set; }
+}

src/WorkFlow.Domain/Entities/PObject.cs

@@ -0,0 +1,34 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+public class PObject
+{
+    [Column("ObjStateID")]
+    public long? ObjStateId { get; set; }
+
+    [Column("ObjectID")]
+    public long? Id { get; set; }
+
+    [Column("Headline1")]
+    public string? Headline1 { get; set; }
+
+    [Column("Headline2")]
+    public string? Headline2 { get; set; }
+
+    [Column("Subline1")]
+    public string? Subline1 { get; set; }
+
+    [Column("Subline2")]
+    public string? Subline2 { get; set; }
+
+    [Column("CMD_CheckIn")]
+    public string? CmdCheckIn { get; set; }
+
+    [ForeignKey("ObjStateId")]
+    public virtual PObjectState? State { get; set; }
+
+    public virtual IEnumerable<PObjectStateHist>? StateHistories { get; set; }
+
+    public virtual IEnumerable<PControlsUpdate>? ControlsUpdates { get; set; }
+}

src/WorkFlow.Domain/Entities/PObjectState.cs

@@ -0,0 +1,88 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+[Table("TBMWF_PROFILE_OBJ_STATE", Schema = "dbo")]
+public class PObjectState
+{
+    [Key]
+    [Column("GUID", TypeName = "bigint")]
+    public long Id { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("MWF_PROFILE_ID", TypeName = "int")]
+    public int? ProfileId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("USR_ID", TypeName = "int")]
+    public int? UserId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("OBJ_ID", TypeName = "bigint")]
+    public long? ObjectId { get; set; }
+
+    [Required]
+    [Column("STATE_ID", TypeName = "int")]
+    public int StateId { get; set; }
+
+    [Column("STATE2", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? State2 { get; set; }
+
+    [Column("STATE3", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? State3 { get; set; }
+
+    [Column("STATE4", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? State4 { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHO", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? AddedWho { get; set; } = "SYS";
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHEN", TypeName = "datetime")]
+    public DateTime? AddedWhen { get; set; } = DateTime.Now;
+
+    [Column("CHANGED_WHO", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? ChangedWho { get; set; }
+
+    [Column("CHANGED_WHEN", TypeName = "datetime")]
+    public DateTime? ChangedWhen { get; set; }
+
+    [ForeignKey("StateId")]
+    public virtual State? State1 { get; set; }
+
+    public virtual IEnumerable<PControlsTF>? TFControls { get; set; }
+
+    public virtual IEnumerable<TfFile>? TfFiles { get; set; }
+}

src/WorkFlow.Domain/Entities/PObjectStateHist.cs

@@ -0,0 +1,65 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+[Table("TBMWF_PROFILE_OBJ_STATE_HISTORY", Schema = "dbo")]
+public class PObjectStateHist
+{
+    [Key]
+    [Column("GUID", TypeName = "bigint")]
+    public long Id { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("MWF_PROFILE_ID", TypeName = "int")]
+    public int? ProfileId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("USR_ID", TypeName = "int")]
+    public int? UserId { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("OBJ_ID", TypeName = "bigint")]
+    public long? ObjectId { get; set; }
+
+    [Required]
+    [Column("STATE_ID", TypeName = "int")]
+    public int StateId { get; set; }
+
+    [Column("STATE2", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? State2 { get; set; }
+
+    [Column("STATE3", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? State3 { get; set; }
+
+    [Column("STATE4", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? State4 { get; set; }
+
+    [Column("CHANGED_WHO", TypeName = "nvarchar(100)")]
+    [StringLength(100)]
+    public string? ChangedWho { get; set; }
+
+    [Column("CHANGED_WHEN", TypeName = "datetime")]
+    public DateTime? ChangedWhen { get; set; }
+
+    [ForeignKey("StateId")]
+    public virtual State? State1 { get; set; }
+}

src/WorkFlow.Domain/Entities/Profile.cs

@@ -0,0 +1,33 @@
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+public class Profile
+{
+    [Column("PROFILE_ID")]
+    public int? Id { get; set; }
+
+    [Column("TYPE_ID")]
+    public byte? TypeId { get; set; }
+
+    [Column("CAPTION")]
+    public string? Caption { get; set; }
+
+    [Column("SUBTITLE")]
+    public string? Subtitle { get; set; }
+
+    [Column("COUNTOBJ")]
+    public int? CountObj { get; set; }
+
+    [Column("FORE_COLOR")]
+    public string? ForeColor { get; set; }
+
+    [Column("BACK_COLOR")]
+    public string? BackColor { get; set; }
+
+    [NotMapped]
+    public IEnumerable<PObject>? Objects { get; set; }
+
+    [NotMapped]
+    public IEnumerable<Button>? Buttons { get; set; }
+}

src/WorkFlow.Domain/Entities/State.cs

@@ -0,0 +1,24 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+[Table("TBMWF_WF_STATE", Schema = "dbo")]
+public class State
+{
+    [Key]
+    [Column("GUID")]
+    public int Id { get; init; }
+
+    [Required]
+    [Column("INTL_STATE", TypeName = "varchar(100)")]
+    public required string IntlState { get; init; }
+
+    [Required]
+    [Column("ADDED_WHO", TypeName = "varchar(30)")]
+    public required string AddedWho { get; init; }
+
+    [Required]
+    [Column("ADDED_WHEN", TypeName = "datetime")]
+    public required DateTime AddedWhen { get; init; }
+}

src/WorkFlow.Domain/Entities/TfFile.cs

@@ -0,0 +1,60 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace WorkFlow.Domain.Entities;
+
+[Table("TBMWF_TF_FILES")]
+public class TfFile
+{
+    [Key]
+    [Column("GUID", TypeName = "bigint")]
+    public long Id { get; set; }
+
+    [Required]
+    [Column("OBJ_STATE_ID", TypeName = "bigint")]
+    public long ObjStateId { get; set; }
+
+    [Required]
+    [StringLength(512)]
+    [Column("F_FAPTH", TypeName = "nvarchar(512)")]
+    public string Path { get; set; } = null!;
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("HEADLINE", TypeName = "nvarchar(100)")]
+    public string? Headline { get; set; }
+
+    [StringLength(100)]
+    [Column("SUBLINE", TypeName = "nvarchar(100)")]
+    public string? Subline { get; set; }
+
+    [StringLength(250)]
+    [Column("COMMENT", TypeName = "nvarchar(250)")]
+    public string? Comment { get; set; }
+
+    [StringLength(100)]
+    [Column("ICON", TypeName = "nvarchar(100)")]
+    public string? Icon { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHO", TypeName = "nvarchar(100)")]
+    public string? AddedWho { get; set; }
+
+    /// <summary>
+    /// Although this field is marked as <c>nullable</c> in the database schema to allow 
+    /// for greater flexibility during database-level operations or migrations, it is 
+    /// treated as <c>required</c> and <c>not null</c> within the application logic. 
+    /// Validation should be enforced at the application level to ensure a value is provided.
+    /// </summary>
+    [Column("ADDED_WHEN", TypeName = "datetime")]
+    public DateTime? AddedWhen { get; set; }
+}

src/WorkFlow.Domain/WorkFlow.Domain.csproj

@@ -1,9 +1,13 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFramework>net8.0</TargetFramework>
+    <TargetFrameworks>net7.0;net8.0</TargetFrameworks>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="UserManager" Version="1.1.2" />
+  </ItemGroup>
+
 </Project>

src/WorkFlow.Infrastructure/DependencyInjection.cs

@@ -0,0 +1,27 @@
+using DigitalData.Core.Infrastructure;
+using DigitalData.Core.Infrastructure.AutoMapper;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+using WorkFlow.Application.Contracts.Repositories;
+using WorkFlow.Domain.Entities;
+using WorkFlow.Infrastructure.Repositories;
+
+namespace WorkFlow.Infrastructure;
+
+public static class DependencyInjection
+{
+    public static IServiceCollection AddWorkFlowRepositories(this IServiceCollection services)
+    {
+        services.TryAddScoped<IProfileRepository, ProfileRepository>();
+        services.TryAddScoped<IProfileObjRepository, PObjectRepository>();
+
+        services.AddDbRepository<WFDBContext, Config>(c => c.Configs).UseAutoMapper();
+        services.AddDbRepository<WFDBContext, PControlsTF>(c => c.ProfileControlsTFs).UseAutoMapper();
+        services.AddDbRepository<WFDBContext, State>(c => c.States).UseAutoMapper();
+        services.AddDbRepository<WFDBContext, Button>(c => c.Buttons).UseAutoMapper();
+        services.AddDbRepository<WFDBContext, State>(c => c.States).UseAutoMapper();
+        services.AddDbRepository<WFDBContext, PObjectState>(c => c.ProfileObjStates).UseAutoMapper();
+
+        return services;
+    }
+}

src/WorkFlow.Infrastructure/Repositories/PObjectRepository.cs

@@ -0,0 +1,44 @@
+using Microsoft.EntityFrameworkCore;
+using WorkFlow.Application.Contracts.Repositories;
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Infrastructure.Repositories;
+
+/// <summary>
+/// Repository implementation for retrieving <see cref="PObject"/> entities from the database.
+/// </summary>
+public class PObjectRepository : IProfileObjRepository
+{
+    private readonly WFDBContext _context;
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="PObjectRepository"/> class.
+    /// </summary>
+    /// <param name="context">The database context used for accessing profile data.</param>
+    public PObjectRepository(WFDBContext context)
+    {
+        _context = context;
+    }
+
+    /// <summary>
+    /// Retrieves the list of <see cref="PObject"/> associated with a given user ID and profile ID by calling a database function.
+    /// </summary>
+    /// <param name="userId">The unique identifier of the user whose profile is to be retrieved.</param>
+    /// <param name="profileId">The unique identifier of the profile whose object is to be retrieved.</param>
+    /// <param name="cancel">Propagates notification that operations should be canceled.</param>
+    /// <returns>
+    /// A task that represents the asynchronous operation. The task result contains the <see cref="PObject"/> object if found; otherwise, <c>null</c>.
+    /// </returns>
+    /// <remarks>
+    /// Logs an error if no profile is found, or if multiple profiles are returned, indicating potential data issues.
+    /// </remarks>
+    public async Task<IEnumerable<PObject>> ReadAsync(int userId, int profileId, CancellationToken cancel = default)
+        => await _context.Objects
+            .FromSqlRaw("SELECT * FROM [FNMWF_GET_PROFILE_OBJECTS] ({0}, {1})", userId, profileId)
+            .Include(obj => obj.State).ThenInclude(objState => objState != null ? objState.State1 : null)
+            .Include(obj => obj.State).ThenInclude(objState => objState != null ? objState.TFControls : null)
+            .Include(obj => obj.State).ThenInclude(objState => objState != null ? objState.TfFiles : null)
+            .Include(obj => obj.StateHistories!).ThenInclude(hist => hist != null ? hist.State1 : null)
+            .Include(obj => obj.ControlsUpdates)
+            .ToListAsync(cancel);
+}

src/WorkFlow.Infrastructure/Repositories/ProfileRepository.cs

@@ -0,0 +1,55 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using WorkFlow.Application.Contracts.Repositories;
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Infrastructure.Repositories;
+
+/// <summary>
+/// Repository implementation for retrieving <see cref="Profile"/> entities from the database.
+/// </summary>
+public class ProfileRepository : IProfileRepository
+{
+    private readonly ILogger<ProfileRepository> _logger;
+    private readonly WFDBContext _context;
+
+    /// <summary>
+    /// Initializes a new instance of the <see cref="ProfileRepository"/> class.
+    /// </summary>
+    /// <param name="context">The database context used for accessing profile data.</param>
+    /// <param name="logger">The logger instance used for logging repository operations.</param>
+    public ProfileRepository(WFDBContext context, ILogger<ProfileRepository> logger)
+    {
+        _logger = logger;
+        _context = context;
+    }
+
+    /// <summary>
+    /// Retrieves the <see cref="Profile"/> associated with a given user ID by calling a database function.
+    /// </summary>
+    /// <param name="userId">The unique identifier of the user whose profile is to be retrieved.</param>
+    /// <param name="cancel">Propagates notification that operations should be canceled.</param>
+    /// <returns>
+    /// A task that represents the asynchronous operation. The task result contains the <see cref="Profile"/> object if found; otherwise, <c>null</c>.
+    /// </returns>
+    /// <remarks>
+    /// Logs an error if no profile is found, or if multiple profiles are returned, indicating potential data issues.
+    /// </remarks>
+    public async Task<Profile?> ReadAsync(int userId, CancellationToken cancel = default)
+    {
+        var profiles = await _context.Profiles
+            .FromSqlRaw("SELECT * FROM FNMWF_GET_PROFILES ({0})", userId)
+            .ToListAsync(cancel);
+
+        if (profiles == null || profiles.Count == 0)
+        {
+            _logger.LogError("No profile record was found associated with user ID {userId}.", userId);
+        }
+        else if (profiles.Count > 1)
+        {
+            _logger.LogError("Multiple profile records were found for user ID {userId}, which may indicate a data integrity issue.", userId);
+        }
+
+        return profiles?.FirstOrDefault();
+    }
+}

src/WorkFlow.Infrastructure/WFDBContext.cs

@@ -0,0 +1,72 @@
+using DigitalData.UserManager.Domain.Entities;
+using DigitalData.UserManager.Infrastructure;
+using DigitalData.UserManager.Infrastructure.Contracts;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.SqlServer.Query.Internal;
+using WorkFlow.Domain.Entities;
+
+namespace WorkFlow.Infrastructure;
+
+public class WFDBContext : DbContext, IUserManagerDbContext
+{
+    public DbSet<Config> Configs { get; set; }
+
+    public DbSet<PControlsTF> ProfileControlsTFs { get; set; }
+
+    public DbSet<Profile> Profiles { get; set; }
+    
+    public DbSet<PObject> Objects { get; set; }
+
+    public DbSet<PObjectState> ProfileObjStates { get; set; }
+
+    public DbSet<State> States { get; set; }
+
+    public DbSet<GroupOfUser> GroupOfUsers { get; set; }
+
+    public DbSet<Group> Groups { get; set; }
+
+    public DbSet<ModuleOfUser> ModuleOfUsers { get; set; }
+
+    public DbSet<Module> Modules { get; set; }
+
+    public DbSet<User> Users { get; set; }
+
+    public DbSet<UserRep> UserReps { get; set; }
+
+    public DbSet<ClientUser> ClientUsers { get; set; }
+
+    public DbSet<Button> Buttons { get; set; }
+
+    public WFDBContext(DbContextOptions options) : base(options)
+    {
+    }
+
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        modelBuilder.ConfigureUserManager();
+
+        modelBuilder.Entity<PObjectState>()
+            .HasMany(objState => objState.TFControls)
+            .WithOne()
+            .HasForeignKey(control => control.ObjStateId)
+            .OnDelete(DeleteBehavior.Cascade);
+
+        modelBuilder.Entity<PObjectState>()
+            .HasMany(objState => objState.TfFiles)
+            .WithOne()
+            .HasForeignKey(file => file.ObjStateId);
+
+        modelBuilder.Entity<PObject>()
+            .HasMany(p => p.StateHistories)
+            .WithOne()
+            .HasForeignKey(hist => hist.ObjectId);
+
+        modelBuilder.Entity<PObject>()
+            .HasMany(obj => obj.ControlsUpdates)
+            .WithOne()
+            .HasForeignKey(cu => cu.ObjId)
+            .OnDelete(DeleteBehavior.Cascade);
+
+        base.OnModelCreating(modelBuilder);
+    }
+}

src/WorkFlow.Infrastructure/WorkFlow.Infrastructure.csproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFrameworks>net7.0;net8.0</TargetFrameworks>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="DigitalData.Core.Abstraction.Application" Version="1.0.0" />
+    <PackageReference Include="DigitalData.Core.Infrastructure" Version="2.1.1" />
+    <PackageReference Include="DigitalData.Core.Infrastructure.AutoMapper" Version="1.0.3" />
+    <PackageReference Include="UserManager" Version="1.1.2" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\WorkFlow.Domain\WorkFlow.Domain.csproj" />
+	<ProjectReference Include="..\WorkFlow.Application\WorkFlow.Application.csproj" />
+  </ItemGroup>
+
+</Project>