Applying Soft Delete & integrate user identity

AskFm/AskFm.API/AskFm.API.csproj

@@ -8,6 +8,7 @@
 
     <ItemGroup>
         <PackageReference Include="DotNetEnv" Version="3.1.1" />
+        <PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version="9.0.0" />
         <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="9.0.0" />
         <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.0" />
         <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.0">

AskFm/AskFm.API/Program.cs

@@ -1,11 +1,14 @@
 using Microsoft.EntityFrameworkCore;
+using Microsoft.AspNetCore.Identity;
 using AskFm.DAL;
+using AskFm.DAL.Models;
 using AskFm.DAL.Interfaces;
 using AskFm.DAL.Repositories;
 using DotNetEnv;
 using Microsoft.EntityFrameworkCore.Proxies;
 namespace AskFm.API;
 
+
 public class Program
 {
     public static void Main(string[] args)
@@ -24,10 +27,16 @@ public static void Main(string[] args)
         {
             throw new Exception("Connection string is null");
         }
+
         builder.Services.AddDbContext<AppDbContext>(options =>
             options
                 .UseLazyLoadingProxies()
                 .UseSqlServer(ConnectionString));
+
+        builder.Services.AddIdentity<ApplicationUser, IdentityRole<int>>()
+            .AddEntityFrameworkStores<AppDbContext>()
+            .AddDefaultTokenProviders();
+
 
         builder.Services.AddScoped<IUnitOfWork, UnitOfWork>();
 

AskFm/AskFm.DAL/AppDbContext.cs

@@ -1,16 +1,19 @@
+using System.Data;
 using AskFm.DAL.Models;
+using Microsoft.AspNetCore.Identity;
+using Microsoft.AspNetCore.Identity.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore;
 using Thread = AskFm.DAL.Models.Thread;
 
 namespace AskFm.DAL;
 
-public class AppDbContext : DbContext
+public class AppDbContext : IdentityDbContext<ApplicationUser,IdentityRole<int>, int>
 {
     public AppDbContext(DbContextOptions<AppDbContext> options) : base(options)
     {
     }
 
-    public DbSet<User> Users { get; set; }
+    public DbSet<ApplicationUser> Users { get; set; }
     public DbSet<Thread> Threads { get; set; }
     public DbSet<Comment> Comments { get; set; }
     public DbSet<Follow> Follows { get; set; }
@@ -23,5 +26,59 @@
     {
         base.OnModelCreating(modelBuilder);
         modelBuilder.ApplyConfigurationsFromAssembly(typeof(AppDbContext).Assembly);
+
+        foreach (var entityType in modelBuilder.Model.GetEntityTypes()
+                     .Where(t => typeof(ITrackable).IsAssignableFrom(t.ClrType)))
+        {
+
+            modelBuilder.Entity(entityType.ClrType).Property<DateTime>("DeletedAt")
+                .HasColumnType("DATETIME");
+
+            modelBuilder.Entity(entityType.ClrType).Property<DateTime>("UpdatedAt")
+                .HasColumnType("DATETIME");
+
+            modelBuilder.Entity(entityType.ClrType).Property<DateTime>("CreatedAt")
+                .HasColumnType("DATETIME");
+
+            modelBuilder.Entity(entityType.ClrType).Property<bool>("IsDeleted")
+                .HasColumnType("BIT")
+                .HasDefaultValue(false);
+        }
+
+    }
+
+    public override Task<int> SaveChangesAsync(CancellationToken cancellationToken = new CancellationToken())
+    {
+        _fillTrackableInfromation();
+        return base.SaveChangesAsync(cancellationToken);
+
+    }
+    public override int SaveChanges()
+    {
+        _fillTrackableInfromation();
+        return base.SaveChanges();
+    }
+    private void _fillTrackableInfromation()
+    {
+        foreach (var entry in  ChangeTracker.Entries<ITrackable>())
+        {
+            switch (entry.State)
+            {
+                case EntityState.Added:
+                    entry.Entity.CreatedAt = DateTime.UtcNow;
+                    entry.Entity.DeletedAt = DateTime.UtcNow;;
+                    entry.Entity.UpdatedAt = DateTime.UtcNow;
+                    entry.Entity.IsDeleted = false;
+                    break;
+                case EntityState.Modified:
+                    entry.Entity.UpdatedAt = DateTime.UtcNow;
+                    break;
+                case EntityState.Deleted:
+                    entry.Entity.IsDeleted = true;
+                    entry.Entity.DeletedAt = DateTime.UtcNow;
+                    entry.State = EntityState.Modified;
+                    break;
+            }
+        }
     }
 }

AskFm/AskFm.DAL/AskFm.DAL.csproj

@@ -8,6 +8,7 @@
     </PropertyGroup>
 
     <ItemGroup>
+        <PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" Version="9.0.0" />
         <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.0" />
         <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="9.0.0">
             <PrivateAssets>all</PrivateAssets>

AskFm/AskFm.DAL/Interfaces/IUnitOfWork.cs

@@ -5,7 +5,7 @@ namespace AskFm.DAL.Interfaces;
 
 public interface IUnitOfWork : IDisposable
 {
-    IRepository<User> Users { get; }
+    IRepository<ApplicationUser> Users { get; }
     IRepository<Thread>  Threads { get; }
     IRepository<SavedThreads> SavedThreads { get; }
     IRepository<ThreadLike>  ThreadLikes { get; }

AskFm/AskFm.DAL/Interfaces/IUserRepository.cs

@@ -2,8 +2,8 @@
 
 namespace AskFm.DAL.Interfaces;
 
-public interface IUserRepository : IRepository<User>
+public interface IApplicationUserRepository : IRepository<ApplicationUser>
 {
-    Task<User?> GetByUsernameAsync(string username);
+    Task<ApplicationUser?> GetByUsernameAsync(string username);
 
 }