Add project files.

2026-06-22 09:01:18 +03:00 · 2022-10-06 16:53:07 +03:00
parent 45fac5e086
commit 6f3acce7d4
38 changed files with 1051 additions and 0 deletions
@@ -0,0 +1,23 @@
+using Microsoft.EntityFrameworkCore;
+using PracticeCalendar.Domain.Entities;
+using System.Reflection;
+
+namespace PracticeCalendar.Infrastructure.Persistence
+{
+    public class ApplicationDbContext : DbContext
+    {
+        public ApplicationDbContext(DbContextOptions<ApplicationDbContext> options)
+      : base(options)
+        {
+        }
+
+        protected override void OnModelCreating(ModelBuilder modelBuilder)
+        {
+            base.OnModelCreating(modelBuilder);
+            modelBuilder.ApplyConfigurationsFromAssembly(Assembly.GetExecutingAssembly());
+        }
+
+        public DbSet<Attendee> Atendees => Set<Attendee>();
+        public DbSet<PracticeEvent> PracticeEvents => Set<PracticeEvent>();
+    }
+}
@@ -0,0 +1,65 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using PracticeCalendar.Domain.Entities;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace PracticeCalendar.Infrastructure.Persistence
+{
+    public class ApplicationDbContextInitialiser
+    {
+        private readonly ILogger<ApplicationDbContextInitialiser> logger;
+        private readonly ApplicationDbContext context;
+
+        public ApplicationDbContextInitialiser(ILogger<ApplicationDbContextInitialiser> logger, 
+            ApplicationDbContext context)
+        {
+            this.logger = logger;
+            this.context = context;
+        }
+
+        public async Task InitialiseAsync()
+        {
+            try
+            {
+                if (context.Database.IsSqlite())
+                {
+                    await context.Database.MigrateAsync();
+                }
+            }
+            catch (Exception ex)
+            {
+                logger.LogError(ex, "An error occurred while initialising the database.");
+                throw;
+            }
+        }
+
+        public async Task SeedAsync()
+        {
+            try
+            {
+                await TrySeedAsync();
+            }
+            catch (Exception ex)
+            {
+                logger.LogError(ex, "An error occurred while seeding the database.");
+                throw;
+            }
+        }
+
+        public async Task TrySeedAsync()
+        {
+            // Default data
+            // Seed, if necessary
+            if (!context.PracticeEvents.Any())
+            {
+                context.PracticeEvents.Add(new PracticeEvent("Event 1", "Event 1 desc"));
+
+                await context.SaveChangesAsync();
+            }
+        }
+    }
+}
@@ -0,0 +1,19 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using PracticeCalendar.Domain.Entities;
+
+namespace PracticeCalendar.Infrastructure.Persistence.Configuration
+{
+    public class AttendeeConfiguration : IEntityTypeConfiguration<Attendee>
+    {
+        public void Configure(EntityTypeBuilder<Attendee> builder)
+        {
+            builder.Property(x => x.Name)
+                .HasMaxLength(100)
+                .IsRequired();
+            builder.Property(x => x.EmailAddress)
+                .HasMaxLength(100)
+                .IsRequired();
+        }
+    }
+}
@@ -0,0 +1,19 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using PracticeCalendar.Domain.Entities;
+
+namespace PracticeCalendar.Infrastructure.Persistence.Configuration
+{
+    public class PracticeEventConfiguration : IEntityTypeConfiguration<PracticeEvent>
+    {
+        public void Configure(EntityTypeBuilder<PracticeEvent> builder)
+        {
+            builder.Property(x => x.Title)
+                .HasMaxLength(120)
+                .IsRequired();
+            builder.Property(x => x.Description)
+                .HasMaxLength(1000)
+                .IsRequired();
+        }
+    }
+}
@@ -0,0 +1,12 @@
+using Ardalis.Specification.EntityFrameworkCore;
+using PracticeCalendar.Domain.Common.Interfaces;
+
+namespace PracticeCalendar.Infrastructure.Persistence
+{
+    public class EfRepository<T> : RepositoryBase<T>, IRepository<T> where T : class, IAggregateRoot
+    {
+        public EfRepository(ApplicationDbContext dbContext) : base(dbContext)
+        {
+        }
+    }
+}