ReC/src/ReC.Infrastructure/RecDbContext.cs

using Microsoft.EntityFrameworkCore;
using ReC.Application.Common.Interfaces;
using ReC.Domain.Entities;

namespace ReC.Infrastructure;

public class RecDbContext(DbContextOptions<RecDbContext> options) : DbContext(options), IRecDbContext
{
    public DbSet<EndpointParam> EndpointParams { get; set; }

    public DbSet<RecActionView> Actions { get; set; }

    public DbSet<OutRes> OutRes { get; set; }

    public DbSet<HeaderQueryResult> HeaderQueryResults { get; set; }

    public DbSet<BodyQueryResult> BodyQueryResults { get; set; }

    public DbSet<Connection> Connections { get; set; }

    public DbSet<Endpoint> Endpoints { get; set; }

    public DbSet<EndpointAuth> EndpointAuths { get; set; }

    public DbSet<Profile> Profiles { get; set; }

    public DbSet<RecAction> RecActions { get; set; }

    protected override void OnModelCreating(ModelBuilder modelBuilder)
    {
        base.OnModelCreating(modelBuilder);

        modelBuilder.Entity<Connection>(b =>
        {
            b.ToTable("TBDD_CONNECTION");

            b.HasKey(e => e.Id);

            b.Property(e => e.Id)
                .HasColumnName("GUID")
                .ValueGeneratedOnAdd();

            b.Property(e => e.Bezeichnung).HasColumnName("BEZEICHNUNG");
            b.Property(e => e.SqlProvider).HasColumnName("SQL_PROVIDER");
            b.Property(e => e.Server).HasColumnName("SERVER");
            b.Property(e => e.Datenbank).HasColumnName("DATENBANK");
            b.Property(e => e.Username).HasColumnName("USERNAME");
            b.Property(e => e.Password).HasColumnName("PASSWORD");
            b.Property(e => e.Bemerkung).HasColumnName("BEMERKUNG");
            b.Property(e => e.Aktiv).HasColumnName("AKTIV");
            b.Property(e => e.ErstelltWer).HasColumnName("ERSTELLTWER");
            b.Property(e => e.ErstelltWann).HasColumnName("ERSTELLTWANN");
            b.Property(e => e.GeandertWer).HasColumnName("GEANDERTWER");
            b.Property(e => e.GeaendertWann).HasColumnName("GEAENDERTWANN");
            b.Property(e => e.SysConnection).HasColumnName("SYS_CONNECTION");
        });

        modelBuilder.Entity<EndpointParam>(b =>
        {
            b.ToTable("TBREC_CFG_ENDPOINT_PARAMS", "dbo");

            b.HasKey(e => e.Id);

            b.Property(e => e.Id).HasColumnName("GUID");
            b.Property(e => e.Active).HasColumnName("ACTIVE");
            b.Property(e => e.Description).HasColumnName("DESCRIPTION");
            b.Property(e => e.GroupId).HasColumnName("GROUP_ID");
            b.Property(e => e.Sequence).HasColumnName("SEQUENCE");
            b.Property(e => e.Key).HasColumnName("KEY");
            b.Property(e => e.Value).HasColumnName("VALUE");
            b.Property(e => e.AddedWho).HasColumnName("ADDED_WHO");
            b.Property(e => e.AddedWhen).HasColumnName("ADDED_WHEN");
            b.Property(e => e.ChangedWho).HasColumnName("CHANGED_WHO");
            b.Property(e => e.ChangedWhen).HasColumnName("CHANGED_WHEN");
        });

        modelBuilder.Entity<OutRes>(b =>
        {
            b.ToTable("TBREC_OUT_RESULT", "dbo");

            b.HasKey(e => e.Id);

            b.Property(e => e.Id)
                .HasColumnName("GUID")
                .ValueGeneratedOnAdd();

            b.Property(e => e.ActionId).HasColumnName("ACTION_ID");
            b.Property(e => e.Header).HasColumnName("RESULT_HEADER");
            b.Property(e => e.Body).HasColumnName("RESULT_BODY");
            b.Property(e => e.AddedWho).HasColumnName("ADDED_WHO");
            b.Property(e => e.AddedWhen).HasColumnName("ADDED_WHEN");
            b.Property(e => e.ChangedWho).HasColumnName("CHANGED_WHO");
            b.Property(e => e.ChangedWhen).HasColumnName("CHANGED_WHEN");
        });

        modelBuilder.Entity<RecActionView>(b =>
        {
            b.ToTable("VWREC_ACTION", "dbo");
            b.HasNoKey();

            b.Property(e => e.Id).HasColumnName("ACTION_ID");
            b.Property(e => e.ProfileId).HasColumnName("PROFILE_ID");
            b.Property(e => e.ProfileName).HasColumnName("PROFILE_NAME");
            b.Property(e => e.ProfileType).HasColumnName("PROFILE_TYPE");
            b.Property(e => e.Sequence).HasColumnName("SEQUENCE");
            b.Property(e => e.EndpointId).HasColumnName("ENDPOINT_ID");
            b.Property(e => e.EndpointUri).HasColumnName("ENDPOINT_URI");
            b.Property(e => e.EndpointAuthId).HasColumnName("ENDPOINT_AUTH_ID");
            b.Property(e => e.EndpointAuthType).HasColumnName("ENDPOINT_AUTH_TYPE");
            b.Property(e => e.EndpointAuthApiKey).HasColumnName("ENDPOINT_AUTH_API_KEY");
            b.Property(e => e.EndpointAuthApiValue).HasColumnName("ENDPOINT_AUTH_API_VALUE");
            b.Property(e => e.EndpointAuthApiKeyAddTo).HasColumnName("ENDPOINT_AUTH_API_KEY_ADD_TO");
            b.Property(e => e.EndpointAuthToken).HasColumnName("ENDPOINT_AUTH_TOKEN");
            b.Property(e => e.EndpointAuthUsername).HasColumnName("ENDPOINT_AUTH_USERNAME");
            b.Property(e => e.EndpointAuthPassword).HasColumnName("ENDPOINT_AUTH_PASSWORD");
            b.Property(e => e.EndpointAuthDomain).HasColumnName("ENDPOINT_AUTH_DOMAIN");
            b.Property(e => e.EndpointAuthWorkstation).HasColumnName("ENDPOINT_AUTH_WORKSTATION");
            b.Property(e => e.EndpointParamsId).HasColumnName("ENDPOINT_PARAMS_ID");
            b.Property(e => e.SqlConnectionId).HasColumnName("SQL_CONNECTION_ID");
            b.Property(e => e.SqlConnectionServer).HasColumnName("SQL_CONNECTION_SERVER");
            b.Property(e => e.SqlConnectionDb).HasColumnName("SQL_CONNECTION_DB");
            b.Property(e => e.SqlConnectionUsername).HasColumnName("SQL_CONNECTION_USERNAME");
            b.Property(e => e.SqlConnectionPassword).HasColumnName("SQL_CONNECTION_PASSWORD");
            b.Property(e => e.RestType).HasColumnName("REST_TYPE");
            b.Property(e => e.PreprocessingQuery).HasColumnName("PREPROCESSING_QUERY");
            b.Property(e => e.HeaderQuery).HasColumnName("HEADER_QUERY");
            b.Property(e => e.BodyQuery).HasColumnName("BODY_QUERY");
            b.Property(e => e.PostprocessingQuery).HasColumnName("POSTPROCESSING_QUERY");
        });

        modelBuilder.Entity<HeaderQueryResult>(b =>
        {
            b.HasNoKey();
            b.Property(e => e.RawHeader).HasColumnName("REQUEST_HEADER");
        });

        modelBuilder.Entity<BodyQueryResult>(b =>
        {
            b.HasNoKey();
            b.Property(e => e.RawBody).HasColumnName("REQUEST_BODY");
        });

        modelBuilder.Entity<RecAction>()
            .HasOne(act => act.OutRes)
            .WithOne(res => res.Action)
            .HasForeignKey<OutRes>(res => res.ActionId)
            .OnDelete(DeleteBehavior.Cascade);
    }
}