Feature: HW3: setup EF Core, repositories, controllers and seeding

Homeworks/.gitattributes

@@ -0,0 +1 @@
+* text=auto eol=lf

Homeworks/03 Подключение базы данных через Entity Framework/src/PromoCodeFactory.Core/Abstractions/Repositories/IRepository.cs

@@ -8,23 +8,47 @@ public interface IRepository<T> where T : BaseEntity
 {
     Task<IReadOnlyCollection<T>> GetAll(bool withIncludes = false, CancellationToken ct = default);
 
+    /// <returns>The entity tracked by the current DbContext if found; otherwise, <see langword="null"/>.</returns>
     Task<T?> GetById(Guid id, bool withIncludes = false, CancellationToken ct = default);
 
-    Task<IReadOnlyCollection<T>> GetByRangeId(
-        IEnumerable<Guid> ids,
-        bool withIncludes = false,
+    /// <returns>
+    /// Collection of entities matching the specified ids. 
+    /// Entities are tracked by the current DbContext.
+    /// </returns>
+    Task<IReadOnlyCollection<T>> GetByRangeId(IEnumerable<Guid> ids, bool withIncludes = false,
         CancellationToken ct = default);
 
-    Task<IReadOnlyCollection<T>> GetWhere(
-        Expression<Func<T, bool>> predicate,
-        bool withIncludes = false,
+    /// <returns>
+    /// Collection of entities matching the specified predicate. 
+    /// Entities are tracked by the current DbContext.
+    /// </returns>
+    Task<IReadOnlyCollection<T>> GetWhere(Expression<Func<T, bool>> predicate, bool withIncludes = false,
         CancellationToken ct = default);
 
-    Task Add(T entity, CancellationToken ct);
+    /// <summary>
+    /// Adds a new entity to the current DbContext. Use IUnitOfWork to SaveChangesAsync
+    /// </summary>
+    /// <param name="entity">
+    /// A new entity with tracked references to existing related entities.
+    /// </param>
+    void Add(T entity);
 
-    /// <exception cref="EntityNotFoundException"/>
-    Task Update(T entity, CancellationToken ct);
+    /// <summary>
+    /// Updates a detached entity by applying its values to the existing entity in the DbContext and saving changes.
+    /// </summary>
+    /// <exception cref="EntityNotFoundException">Thrown if the entity with the given Id is not found in the database.</exception>
+    Task UpdateDetached(T entity, CancellationToken ct);
 
     /// <exception cref="EntityNotFoundException"/>
     Task Delete(Guid id, CancellationToken ct);
+
+    /// <summary>
+    /// Adds new entities to the current DbContext. Use IUnitOfWork to SaveChangesAsync.
+    /// </summary>
+    /// <param name="entities">
+    /// New entities with tracked references to existing related entities.
+    /// </param>
+    void AddRange(IEnumerable<T> entities);
+
+    Task<bool> IsNotEmptyAsync(CancellationToken ct);
 }

Homeworks/03 Подключение базы данных через Entity Framework/src/PromoCodeFactory.Core/Abstractions/Repositories/IUnitOfWork.cs

@@ -0,0 +1,9 @@
+namespace PromoCodeFactory.Core.Abstractions.Repositories;
+
+public interface IUnitOfWork
+{
+    /// <summary>
+    /// Persists changes for all modified entities currently tracked by the DbContext.
+    /// </summary>
+    Task SaveChangesAsync(CancellationToken ct);
+}

Homeworks/03 Подключение базы данных через Entity Framework/src/PromoCodeFactory.Core/Domain/BaseEntity.cs

@@ -2,5 +2,5 @@ namespace PromoCodeFactory.Core.Domain;
 
 public abstract class BaseEntity
 {
-    public Guid Id { get; set; }
+    public Guid Id { get; set; } = Guid.NewGuid();
 }

Homeworks/03 Подключение базы данных через Entity Framework/src/PromoCodeFactory.DataAccess/.editorconfig

@@ -0,0 +1,3 @@
+
+[*.cs]
+csharp_style_namespace_declarations = block_scoped:silent

Homeworks/03 Подключение базы данных через Entity Framework/src/PromoCodeFactory.DataAccess/DependencyInjection.cs

@@ -9,7 +9,7 @@ namespace PromoCodeFactory.DataAccess;
 
 public static class DependencyInjection
 {
-    public static void AddInMemoryDataAccess(this IServiceCollection services)
+/*    public static void AddInMemoryDataAccess(this IServiceCollection services)
     {
         services.AddSingleton<IRepository<Employee>>(_ =>
             new InMemoryRepository<Employee>(SeedData.Employees));
@@ -23,18 +23,28 @@ public static void AddInMemoryDataAccess(this IServiceCollection services)
             new InMemoryRepository<PromoCode>(SeedData.PromoCodes));
         services.AddSingleton<IRepository<CustomerPromoCode>>(_ =>
             new InMemoryRepository<CustomerPromoCode>(SeedData.CustomerPromoCodes));
-    }
+    }*/
 
-    public static void AddEfDataAccess(this IServiceCollection services)
+    public static void AddEfDataAccess(this IServiceCollection services, string contentRootPath)
     {
+        var dbPath = Path.Combine(contentRootPath, "PromoCodeFactory.sqlite");
+        Console.WriteLine($"dbPath[{dbPath}]");
+
         services.AddDbContext<PromoCodeFactoryDbContext>(builder =>
-                builder.UseSqlite("Filename=PromoCodeFactory.sqlite"));
+                builder.UseSqlite(
+                    $"Data Source={dbPath}",
+                    // EfRepository<T> auto Include => therefore EF warns about multiple collection include
+                    // SplitQuery => fixes execution strategy for that auto Include
+                    opt => opt.UseQuerySplittingBehavior(QuerySplittingBehavior.SplitQuery)
+                    )
+                );
 
+        services.AddScoped<IUnitOfWork, EfUnitOfWork>();
         services.AddScoped<IRepository<Employee>, EmployeeEfRepository>();
         services.AddScoped<IRepository<Role>, EfRepository<Role>>();
         services.AddScoped<IRepository<Customer>, CustomerEfRepository>();
         services.AddScoped<IRepository<PromoCode>, PromoCodeEfRepository>();
-        services.AddScoped<IRepository<Preference>, EfRepository<Preference>>();
+        services.AddScoped<IRepository<Preference>, PreferenceEfRepository>();
         services.AddScoped<IRepository<CustomerPromoCode>, EfRepository<CustomerPromoCode>>();
     }
 }

Homeworks/03 Подключение базы данных через Entity Framework/src/PromoCodeFactory.DataAccess/HostExtensions.cs

@@ -14,18 +14,18 @@ public static class HostExtensions
     public static async Task SeedDatabase(this IHost host, CancellationToken ct = default)
     {
         using var scope = host.Services.CreateScope();
-        var logger = scope.ServiceProvider
-            .GetRequiredService<ILoggerFactory>()
-            .CreateLogger("SeedDatabase");
+        IServiceProvider sp = scope.ServiceProvider;
 
+        var logger = sp.GetRequiredService<ILoggerFactory>().CreateLogger("SeedDatabase");
         logger.LogInformation("Starting database seed...");
+        var unitOfWork = sp.GetRequiredService<IUnitOfWork>();
 
-        await SeedEntity(scope.ServiceProvider, SeedData.Roles, ct);
-        await SeedEntity(scope.ServiceProvider, SeedData.Preferences, ct);
-        await SeedEntity(scope.ServiceProvider, SeedData.Employees, ct);
-        await SeedEntity(scope.ServiceProvider, SeedData.Customers, ct);
-        await SeedEntity(scope.ServiceProvider, SeedData.PromoCodes, ct);
-        await SeedEntity(scope.ServiceProvider, SeedData.CustomerPromoCodes, ct);
+        await SeedEntity(sp, SeedData.Roles, unitOfWork, ct);
+        await SeedEntity(sp, SeedData.Preferences, unitOfWork, ct);
+        await SeedEntity(sp, SeedData.Employees, unitOfWork, ct);
+        await SeedEntity(sp, SeedData.Customers, unitOfWork, ct);
+        await SeedEntity(sp, SeedData.PromoCodes, unitOfWork, ct);
+        await SeedEntity(sp, SeedData.CustomerPromoCodes, unitOfWork, ct);
 
         logger.LogInformation("Database seed completed.");
     }
@@ -52,18 +52,22 @@ private static IHost MigrateDatabase<TDbContext>(this IHost host) where TDbConte
         return host;
     }
 
-    public static async Task SeedEntity<T>(
-        IServiceProvider serviceProvider,
-        IReadOnlyCollection<T> entities,
-        CancellationToken ct)
-        where T : BaseEntity
+    public static async Task SeedEntity<T>(IServiceProvider serviceProvider, IReadOnlyCollection<T> entities,
+        IUnitOfWork unitOfWork, CancellationToken ct) where T : BaseEntity
     {
         var repository = serviceProvider.GetRequiredService<IRepository<T>>();
 
-        if ((await repository.GetAll()).Count > 0)
-            return;
+        var ids = entities.Select(x => x.Id);
+        var existing = await repository.GetByRangeId(ids, ct: ct);
+
+        var existingIds = existing.Select(x => x.Id).ToHashSet();
 
         foreach (var entity in entities)
-            await repository.Add(entity, ct);
+        {
+            if (!existingIds.Contains(entity.Id))
+                repository.Add(entity);
+        }
+
+        await unitOfWork.SaveChangesAsync(ct);
     }
 }