using Common.Configuration;
using Data.Models.Configuration.Arr;
using Data.Models.Configuration.DownloadCleaner;
using Data.Models.Configuration.General;
using Data.Models.Configuration.Notification;
using Data.Models.Configuration.QueueCleaner;
using Common.Helpers;
using Data.Converters;
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
namespace Data;
///
/// Database context for configuration data
///
public class DataContext : DbContext
{
public static SemaphoreSlim Lock { get; } = new(1, 1);
public DbSet GeneralConfigs { get; set; }
public DbSet DownloadClients { get; set; }
public DbSet QueueCleanerConfigs { get; set; }
public DbSet DownloadCleanerConfigs { get; set; }
public DbSet ArrConfigs { get; set; }
public DbSet ArrInstances { get; set; }
public DbSet AppriseConfigs { get; set; }
public DbSet NotifiarrConfigs { get; set; }
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
if (optionsBuilder.IsConfigured)
{
return;
}
var dbPath = Path.Combine(ConfigurationPathProvider.GetConfigPath(), "cleanuparr.db");
optionsBuilder
.UseSqlite($"Data Source={dbPath}")
.UseLowerCaseNamingConvention()
.UseSnakeCaseNamingConvention();
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity(entity =>
{
entity.ComplexProperty(e => e.FailedImport);
entity.ComplexProperty(e => e.Stalled);
entity.ComplexProperty(e => e.Slow);
entity.ComplexProperty(e => e.ContentBlocker);
});
// Configure ArrConfig -> ArrInstance relationship
modelBuilder.Entity(entity =>
{
entity.HasMany(a => a.Instances)
.WithOne(i => i.ArrConfig)
.HasForeignKey(i => i.ArrConfigId)
.OnDelete(DeleteBehavior.Cascade);
});
foreach (var entityType in modelBuilder.Model.GetEntityTypes())
{
var enumProperties = entityType.ClrType.GetProperties()
.Where(p => p.PropertyType.IsEnum ||
(p.PropertyType.IsGenericType &&
p.PropertyType.GetGenericTypeDefinition() == typeof(Nullable<>) &&
p.PropertyType.GetGenericArguments()[0].IsEnum));
foreach (var property in enumProperties)
{
var enumType = property.PropertyType.IsEnum
? property.PropertyType
: property.PropertyType.GetGenericArguments()[0];
var converterType = typeof(LowercaseEnumConverter<>).MakeGenericType(enumType);
var converter = Activator.CreateInstance(converterType);
modelBuilder.Entity(entityType.ClrType)
.Property(property.Name)
.HasConversion((ValueConverter)converter);
}
}
}
}