Foxchat.NET/Foxchat.Chat/Database/ChatContext.cs

82 lines
2.8 KiB
C#
Raw Permalink Normal View History

using Foxchat.Chat.Database.Models;
2024-05-14 22:24:53 +02:00
using Foxchat.Core;
using Foxchat.Core.Database;
using Foxchat.Core.Extensions;
2024-05-14 22:24:53 +02:00
using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.Design;
2024-05-19 17:20:45 +02:00
using Npgsql;
2024-05-14 22:24:53 +02:00
namespace Foxchat.Chat.Database;
public class ChatContext : IDatabaseContext
{
2024-05-19 17:20:45 +02:00
private readonly NpgsqlDataSource _dataSource;
private readonly ILoggerFactory? _loggerFactory;
2024-05-14 22:24:53 +02:00
public override DbSet<Instance> Instance { get; set; }
public DbSet<IdentityInstance> IdentityInstances { get; set; }
public DbSet<User> Users { get; set; }
public DbSet<Guild> Guilds { get; set; }
public DbSet<Channel> Channels { get; set; }
public DbSet<Message> Messages { get; set; }
2024-05-14 22:24:53 +02:00
public ChatContext(InstanceConfig config, ILoggerFactory? loggerFactory)
2024-05-14 22:24:53 +02:00
{
2024-05-19 17:20:45 +02:00
var connString = new NpgsqlConnectionStringBuilder(config.Database.Url)
2024-05-14 22:24:53 +02:00
{
Timeout = config.Database.Timeout ?? 5,
MaxPoolSize = config.Database.MaxPoolSize ?? 50,
}.ConnectionString;
2024-05-19 17:20:45 +02:00
var dataSourceBuilder = new NpgsqlDataSourceBuilder(connString);
dataSourceBuilder.UseNodaTime();
_dataSource = dataSourceBuilder.Build();
_loggerFactory = loggerFactory;
2024-05-14 22:24:53 +02:00
}
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
=> optionsBuilder
.UseNpgsql(_dataSource, o => o.UseNodaTime())
.UseSnakeCaseNamingConvention()
.UseLoggerFactory(_loggerFactory);
2024-05-14 22:24:53 +02:00
protected override void ConfigureConventions(ModelConfigurationBuilder configurationBuilder)
{
// ULIDs are stored as UUIDs in the database
configurationBuilder.Properties<Ulid>().HaveConversion<UlidConverter>();
}
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
modelBuilder.Entity<IdentityInstance>().HasIndex(i => i.Domain).IsUnique();
modelBuilder.Entity<User>().HasIndex(u => new { u.RemoteUserId, u.InstanceId }).IsUnique();
modelBuilder.Entity<User>().HasIndex(u => new { u.Username, u.InstanceId }).IsUnique();
modelBuilder.Entity<Guild>()
.HasOne(e => e.Owner)
.WithMany(e => e.OwnedGuilds)
.HasForeignKey(e => e.OwnerId)
.IsRequired();
modelBuilder.Entity<User>()
.HasMany(e => e.Guilds)
.WithMany(e => e.Users);
2024-05-14 22:24:53 +02:00
}
}
// ReSharper disable once UnusedType.Global
2024-05-14 22:24:53 +02:00
public class DesignTimeIdentityContextFactory : IDesignTimeDbContextFactory<ChatContext>
{
public ChatContext CreateDbContext(string[] args)
{
// Read the configuration file
var config = new ConfigurationBuilder()
.AddConfiguration("chat.ini")
2024-05-14 22:24:53 +02:00
.Build()
// Get the configuration as our config class
.Get<InstanceConfig>() ?? new();
return new ChatContext(config, null);
2024-05-14 22:24:53 +02:00
}
}