Move assistant events to supabase db and rip out some create events stuff

Author: NixFey

Controllers/EventController.cs

@@ -106,6 +106,7 @@ await client.Child($"/seasons/{state.CurrentSeason}/events/{id}").PatchAsync(Jso
         }));
 
         var notifyTasks = new List<Task>();
+        // TODO: Listen to supabase to notify carts of changes
         if (oldCartId is not null && oldCartId != cartId)
             notifyTasks.Add(assistantService.SendEventsToCart(oldCartId.Value));
         if (cartId is not null) notifyTasks.Add(assistantService.SendEventsToCart(cartId.Value));

Data/FimDbContext.cs

@@ -19,7 +19,10 @@ public FimDbContext(DbContextOptions options) : base(options)
     public DbSet<AlertCart> AlertCarts { get; set; } = null!;
 
     public DbSet<EquipmentLog> EquipmentLogs { get; set; } = null!;
-    
+    public DbSet<Event> Events { get; set; } = null!;
+    public DbSet<Season> Seasons { get; set; } = null!;
+    public DbSet<Level> Levels { get; set; } = null!;
+
     protected override void ConfigureConventions(ModelConfigurationBuilder configurationBuilder)
     {
         configurationBuilder.Properties(typeof(Enum)).HaveConversion<string>();

Models/BaseEquipment.cs

@@ -19,7 +19,7 @@ public class BaseEquipment
     public required string Name { get; set; }
     [MaxLength(16)]
     public string? TeamviewerId { get; set; }
-
+    public int? TruckRouteId { get; set; }
 }
 
 public abstract class BaseEquipmentEntityTypeConfiguration<T> : IEntityTypeConfiguration<T> where T : BaseEquipment

Models/Event.cs

@@ -0,0 +1,48 @@
+// ReSharper disable InconsistentNaming Intentional to match casing of DB model
+
+using System.ComponentModel;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+
+namespace fim_queueing_admin.Models;
+
+[EntityTypeConfiguration(typeof(EventEntityTypeConfiguration))]
+public class Event
+{
+    public Guid Id { get; set; }
+    public required int SeasonId { get; set; }
+    public required string Key { get; set; }
+    public string? Code { get; set; }
+    public required string Name { get; set; }
+    public required bool IsOfficial { get; set; }
+    public int? TruckRouteId { get; set; }
+    public required DateTime StartTime { get; set; }
+    public required DateTime EndTime { get; set; }
+    public required string TimeZone { get; set; }
+    public DateTimeOffset? SyncAsOf { get; set; }
+    public required EventStatus Status { get; set; } = EventStatus.NotStarted;
+
+    // Relations
+    [Description("Note: This object may not be populated in some endpoints.")]
+    public Season? Season { get; set; }
+}
+
+public enum EventStatus
+{
+    NotStarted,
+    AwaitingQuals,
+    QualsInProgress,
+    AwaitingAlliances,
+    AwaitingPlayoffs,
+    PlayoffsInProgress,
+    WinnerDetermined,
+    Completed
+}
+
+public class EventEntityTypeConfiguration : IEntityTypeConfiguration<Event>
+{
+    public void Configure(EntityTypeBuilder<Event> builder)
+    {
+        
+    }
+}

Models/Level.cs

@@ -0,0 +1,12 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace fim_queueing_admin.Models;
+
+[Table("levels")]
+public class Level
+{
+    [Key]
+    public int Id { get; set; }
+    public required string Name { get; set; }
+}

Models/Season.cs

@@ -0,0 +1,16 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+
+namespace fim_queueing_admin.Models;
+
+[Table("seasons")]
+public class Season
+{
+    [Key]
+    public int Id { get; set; }
+    public required int LevelId { get; set; }
+    public Level? Level { get; set; }
+    public required string Name { get; set; }
+    public required DateTime StartTime { get; set; }
+    public required DateTime EndTime { get; set; }
+}

Services/AssistantService.cs

@@ -28,21 +28,16 @@ public async Task SendPendingAlertsToEveryone()
 
     public async Task SendEventsToCart(Guid cartId)
     {
-        var season = serviceProvider.GetRequiredService<GlobalState>().CurrentSeason;
-        var rtdb = serviceProvider.GetRequiredService<FirebaseClient>();
+        var dbContext = serviceProvider.GetRequiredService<FimDbContext>();
 
-        var events = await rtdb.Child($"/seasons/{season}/events").OrderBy("cartId").EqualTo(cartId.ToString())
-            .OnceAsync<DbEvent>();
+        var route = (await dbContext.Carts.FindAsync(cartId))?.TruckRouteId;
+        var events = route is not null
+            ? await dbContext.Events.Where(e =>
+                e.TruckRouteId == route && e.Season!.StartTime <= DateTime.UtcNow &&
+                e.Season!.EndTime >= DateTime.UtcNow).OrderBy(e => e.StartTime).ToListAsync()
+            : [];
 
-        await hubContext.Clients.User(cartId.ToString()).SendAsync("Events", events.Select(e => new
-        {
-            eventKey = e.Key,
-            e.Object.eventCode,
-            e.Object.name,
-            e.Object.start,
-            e.Object.end,
-            state = e.Object.state?.ToString()
-        }));
+        await hubContext.Clients.User(cartId.ToString()).SendAsync("Events", events);
     }
 
     public async Task StartStreamForCart(Guid cartId, int? streamNumber)