Updaed event logic and event creation system

SpotiParty.Web/Services/DashboardAuthHandler.cs

@@ -1,5 +1,6 @@
 using HopFrame.Core.Services;
 using Microsoft.EntityFrameworkCore;
+using SpotiParty.Web.Models;
 
 namespace SpotiParty.Web.Services;
 
@@ -8,14 +9,10 @@ public class DashboardAuthHandler(ClientSideStorage storage, IDbContextFactory<D
     public const string AdminPolicy = "ADMIN";
     
     public async Task<bool> IsAuthenticatedAsync(string? policy) {
-        var token = storage.GetUserToken();
-        if (string.IsNullOrWhiteSpace(token))
+        var user = await GetCurrentUser();
+        if (user is null)
             return false;
 
-        await using var context = await contextFactory.CreateDbContextAsync();
-        var user = await context.Users.AsNoTracking().FirstOrDefaultAsync(u => u.RefreshToken == token);
-        if (user is null) return false;
-
         if (policy == AdminPolicy) {
             return user.IsAdmin;
         }
@@ -34,4 +31,14 @@ public class DashboardAuthHandler(ClientSideStorage storage, IDbContextFactory<D
 
         return user.DisplayName;
     }
+
+    public async Task<User?> GetCurrentUser() {
+        var token = storage.GetUserToken();
+        if (string.IsNullOrWhiteSpace(token))
+            return null;
+
+        await using var context = await contextFactory.CreateDbContextAsync();
+        return await context.Users.AsNoTracking().FirstOrDefaultAsync(u => u.RefreshToken == token);
+    }
+    
 }

SpotiParty.Web/Services/EventsDashboardRepo.cs

@@ -0,0 +1,49 @@
+using HopFrame.Core.Repositories;
+using Microsoft.EntityFrameworkCore;
+using SpotiParty.Web.Models;
+
+namespace SpotiParty.Web.Services;
+
+public class EventsDashboardRepo(DatabaseContext context, DashboardAuthHandler handler) : IHopFrameRepository<Event, Guid> {
+    public async Task<IEnumerable<Event>> LoadPage(int page, int perPage) {
+        var user = await handler.GetCurrentUser();
+        if (user is null) return [];
+
+        return await context.Events
+            .AsNoTracking()
+            .Include(e => e.Host)
+            .Where(e => e.Host.UserId == user.UserId)
+            .Skip(page * perPage)
+            .Take(perPage)
+            .ToListAsync();
+    }
+    
+    public async Task<SearchResult<Event>> Search(string searchTerm, int page, int perPage) {
+        var entries = await LoadPage(page, perPage);
+        return new(entries, await GetTotalPageCount(perPage));
+    }
+    
+    public async Task<int> GetTotalPageCount(int perPage) {
+        double count = await context.Events.CountAsync();
+        return Convert.ToInt32(Math.Ceiling(count / perPage));
+    }
+    
+    public async Task CreateItem(Event item) {
+        await context.Events.AddAsync(item);
+        await context.SaveChangesAsync();
+    }
+    
+    public async Task EditItem(Event item) {
+        context.Events.Update(item);
+        await context.SaveChangesAsync();
+    }
+    
+    public async Task DeleteItem(Event item) {
+        context.Events.Remove(item);
+        await context.SaveChangesAsync();
+    }
+    
+    public async Task<Event?> GetOne(Guid key) {
+        return await context.Events.FindAsync(key);
+    }
+}