Finished adding user support and ability to update specific novels or set your last read chapter

DBConnection/Repositories/BaseRepository.cs

@@ -84,8 +84,18 @@ public abstract class BaseRepository<TEntityType> : IRepository<TEntityType> whe
         return GetAllIncludedQueryable().FirstOrDefault(predicate);
     }
 
+    public virtual async Task<IEnumerable<TEntityType?>> GetWhereIncluded(IEnumerable<TEntityType> entities)
+    {
+        return await GetWhereIncluded(entities.Contains);
+    }
+    
     public virtual async Task<IEnumerable<TEntityType>> GetWhereIncluded(Func<TEntityType, bool> predicate)
     {
         return GetAllIncludedQueryable().AsEnumerable().Where(predicate);
     }
+
+    public virtual async Task PersistChanges()
+    {
+        await DbContext.SaveChangesAsync();
+    }
 }

DBConnection/Repositories/Interfaces/IRepository.cs

@@ -16,4 +16,6 @@ public interface IRepository<TEntityType> : IRepository where TEntityType : Base
     Task<IEnumerable<TEntityType>> GetWhereIncluded(Func<TEntityType, bool> predicate);
     Task<IEnumerable<TEntityType>> GetAllIncluded();
     Task<IEnumerable<TEntityType>> UpsertMany(IEnumerable<TEntityType> entities, bool saveAfter=true);
+    Task PersistChanges();
+    Task<IEnumerable<TEntityType?>> GetWhereIncluded(IEnumerable<TEntityType> entities);
 }

DBConnection/Repositories/Interfaces/IUserRepository.cs

@@ -0,0 +1,9 @@
+using Treestar.Shared.Models.DBDomain;
+
+namespace DBConnection.Repositories.Interfaces;
+
+public interface IUserRepository : IRepository<User>
+{
+    Task<User> AssignNovelsToUser(User user, List<Novel> novels);
+    Task<User> UpdateLastChapterRead(User user, Novel novel, int chapterRead);
+}

DBConnection/Repositories/UserRepository.cs

@@ -0,0 +1,49 @@
+using DBConnection.Contexts;
+using DBConnection.Repositories.Interfaces;
+using Microsoft.EntityFrameworkCore;
+using Treestar.Shared.Models.DBDomain;
+
+namespace DBConnection.Repositories;
+
+public class UserRepository : BaseRepository<User>, IUserRepository
+{
+    private readonly INovelRepository _novelRepository;
+    public UserRepository(AppDbContext dbContext, INovelRepository novelRepository) : base(dbContext)
+    {
+        _novelRepository = novelRepository;
+    }
+
+    protected override IQueryable<User> GetAllIncludedQueryable()
+    {
+        return DbContext.Users.Include(u => u.WatchedNovels);
+    }
+
+    public async Task<User> AssignNovelsToUser(User user, List<Novel> novels)
+    {
+        var dbUser = await GetIncluded(user);
+        if (dbUser == null)
+        {
+            return user;
+        }
+
+        var dbNovels = await _novelRepository.GetWhereIncluded(novels);
+        var newNovels = dbNovels.Except(dbUser.WatchedNovels.Select(un => un.Novel));
+        var newUserNovels = newNovels.Select(n => new UserNovel
+        {
+            Novel = n,
+            User = dbUser
+        });
+        dbUser.WatchedNovels.AddRange(newUserNovels);
+        await DbContext.SaveChangesAsync();
+        return dbUser;
+    }
+
+    public async Task<User> UpdateLastChapterRead(User user, Novel novel, int chapterRead)
+    {
+        var dbUser = await GetIncluded(user);
+        var userNovel = dbUser.WatchedNovels.FirstOrDefault(i => i.NovelUrl == novel.Url);
+        userNovel.LastChapterRead = chapterRead;
+        await DbContext.SaveChangesAsync();
+        return dbUser;
+    }
+}