Added functionality to the database for a WhoWas feature that can say when a user was last in chat

2026-04-30 03:22:04 -04:00 · 2025-04-13 13:09:46 -05:00
parent 291ca7954e
commit dd0f6cee6c
6 changed files with 471 additions and 0 deletions
--- a/KfChatDotNetBot/ApplicationDbContext.cs
+++ b/KfChatDotNetBot/ApplicationDbContext.cs
@@ -18,4 +18,5 @@ public class ApplicationDbContext : DbContext
    public DbSet<TwitchViewCountDbModel> TwitchViewCounts { get; set; }
    public DbSet<ChipsggBetDbModel> ChipsggBets { get; set; }
    public DbSet<ImageDbModel> Images { get; set; }
+    public DbSet<UserWhoWasDbModel> UsersWhoWere { get; set; }
 }
--- a/KfChatDotNetBot/ChatBot.cs
+++ b/KfChatDotNetBot/ChatBot.cs
@@ -10,6 +10,8 @@ using KfChatDotNetWsClient;
 using KfChatDotNetWsClient.Models;
 using KfChatDotNetWsClient.Models.Events;
 using KfChatDotNetWsClient.Models.Json;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.IO;
 using NLog;
 using Websocket.Client;

@@ -243,6 +245,7 @@ public class ChatBot
            {
                _seenMessages.Add(new SeenMessageMetadataModel {MessageId = message.MessageId, LastEdited = message.MessageEditDate});
            }
+            UpdateUserLastActivityAsync(message.Author.Id, WhoWasActivityType.Message).Wait(_cancellationToken);
        }
        
        if (InitialStartCooldown) InitialStartCooldown = false;
@@ -379,6 +382,9 @@ public class ChatBot
            {
                db.Users.Add(new UserDbModel { KfId = user.Id, KfUsername = user.Username });
                _logger.Debug("Adding user to DB");
+                // Immediately add to DB so we can populate activity
+                db.SaveChanges();
+                UpdateUserLastActivityAsync(user.Id, WhoWasActivityType.Join).Wait(_cancellationToken);
                continue;
            }
            // Detect a username change
@@ -387,6 +393,8 @@ public class ChatBot
                _logger.Debug("Username has updated, updating DB");
                userDb.KfUsername = user.Username;
            }
+
+            UpdateUserLastActivityAsync(user.Id, WhoWasActivityType.Join).Wait(_cancellationToken);
        }

        db.SaveChanges();
@@ -401,6 +409,39 @@ public class ChatBot
            _logger.Info("GambaSesh is no longer present");
            GambaSeshPresent = false;
        }
+
+        foreach (var user in userIds)
+        {
+            UpdateUserLastActivityAsync(user, WhoWasActivityType.Part).Wait(_cancellationToken);
+        }
+    }
+
+    private async Task UpdateUserLastActivityAsync(int kfId, WhoWasActivityType type)
+    {
+        await using var db = new ApplicationDbContext();
+        var user = await db.Users.FirstOrDefaultAsync(u => u.KfId == kfId, _cancellationToken);
+        if (user == null)
+        {
+            _logger.Error($"Failed to find user with KfId = {kfId} for the purposes of updating their last activity");
+            return;
+        }
+
+        var activity =
+            await db.UsersWhoWere.FirstOrDefaultAsync(u => u.User == user && u.ActivityType == type, _cancellationToken);
+        if (activity == null)
+        {
+            await db.UsersWhoWere.AddAsync(new UserWhoWasDbModel
+            {
+                User = user,
+                FirstOccurence = DateTimeOffset.UtcNow,
+                ActivityType = type,
+                LatestOccurence = DateTimeOffset.UtcNow
+            }, _cancellationToken);
+            await db.SaveChangesAsync(_cancellationToken);
+            return;
+        }
+        activity.LatestOccurence = DateTimeOffset.UtcNow;
+        await db.SaveChangesAsync(_cancellationToken);
    }

    private void OnKfWsDisconnected(object sender, DisconnectionInfo disconnectionInfo)
--- a/KfChatDotNetBot/Migrations/20250413180751_UserWhoWas.Designer.cs
+++ b/KfChatDotNetBot/Migrations/20250413180751_UserWhoWas.Designer.cs
@@ -0,0 +1,328 @@
+// <auto-generated />
+using System;
+using KfChatDotNetBot;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+
+#nullable disable
+
+namespace KfChatDotNetBot.Migrations
+{
+    [DbContext(typeof(ApplicationDbContext))]
+    [Migration("20250413180751_UserWhoWas")]
+    partial class UserWhoWas
+    {
+        /// <inheritdoc />
+        protected override void BuildTargetModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder.HasAnnotation("ProductVersion", "9.0.1");
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.ChipsggBetDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<double>("Amount")
+                        .HasColumnType("REAL");
+
+                    b.Property<string>("BetId")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<DateTimeOffset>("Created")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Currency")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<float>("CurrencyPrice")
+                        .HasColumnType("REAL");
+
+                    b.Property<string>("GameTitle")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<float>("Multiplier")
+                        .HasColumnType("REAL");
+
+                    b.Property<DateTimeOffset>("Updated")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("UserId")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Username")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<bool>("Win")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<double>("Winnings")
+                        .HasColumnType("REAL");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("ChipsggBets");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.HowlggBetsDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<long>("Bet")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<int>("BetId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<DateTimeOffset>("Date")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Game")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<long>("GameId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<long>("Profit")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<int>("UserId")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("HowlggBets");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.ImageDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Key")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<DateTimeOffset>("LastSeen")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Url")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Images");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.JuicerDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<float>("Amount")
+                        .HasColumnType("REAL");
+
+                    b.Property<DateTimeOffset>("JuicedAt")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("UserId")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("Juicers");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.RainbetBetsDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("BetId")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<DateTimeOffset>("BetSeenAt")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("GameName")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<float>("Multiplier")
+                        .HasColumnType("REAL");
+
+                    b.Property<float>("Payout")
+                        .HasColumnType("REAL");
+
+                    b.Property<string>("PublicId")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("RainbetUserId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<DateTimeOffset>("UpdatedAt")
+                        .HasColumnType("TEXT");
+
+                    b.Property<float>("Value")
+                        .HasColumnType("REAL");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("RainbetBets");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.SettingDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<double>("CacheDuration")
+                        .HasColumnType("REAL");
+
+                    b.Property<string>("Default")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Description")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<bool>("IsSecret")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("Key")
+                        .IsRequired()
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Regex")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Value")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("ValueType")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Settings");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.TwitchViewCountDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<double>("ServerTime")
+                        .HasColumnType("REAL");
+
+                    b.Property<DateTimeOffset>("Time")
+                        .HasColumnType("TEXT");
+
+                    b.Property<string>("Topic")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("Viewers")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("TwitchViewCounts");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.UserDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<bool>("Ignored")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<int>("KfId")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<string>("KfUsername")
+                        .IsRequired()
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("UserRight")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Users");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.UserWhoWasDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<int>("ActivityType")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<DateTimeOffset>("FirstOccurence")
+                        .HasColumnType("TEXT");
+
+                    b.Property<DateTimeOffset>("LatestOccurence")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("UserId")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("UsersWhoWere");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.JuicerDbModel", b =>
+                {
+                    b.HasOne("KfChatDotNetBot.Models.DbModels.UserDbModel", "User")
+                        .WithMany()
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("User");
+                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.UserWhoWasDbModel", b =>
+                {
+                    b.HasOne("KfChatDotNetBot.Models.DbModels.UserDbModel", "User")
+                        .WithMany()
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("User");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}
--- a/KfChatDotNetBot/Migrations/20250413180751_UserWhoWas.cs
+++ b/KfChatDotNetBot/Migrations/20250413180751_UserWhoWas.cs
@@ -0,0 +1,49 @@
+using System;
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace KfChatDotNetBot.Migrations
+{
+    /// <inheritdoc />
+    public partial class UserWhoWas : Migration
+    {
+        /// <inheritdoc />
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.CreateTable(
+                name: "UsersWhoWere",
+                columns: table => new
+                {
+                    Id = table.Column<int>(type: "INTEGER", nullable: false)
+                        .Annotation("Sqlite:Autoincrement", true),
+                    UserId = table.Column<int>(type: "INTEGER", nullable: false),
+                    FirstOccurence = table.Column<DateTimeOffset>(type: "TEXT", nullable: false),
+                    LatestOccurence = table.Column<DateTimeOffset>(type: "TEXT", nullable: false),
+                    ActivityType = table.Column<int>(type: "INTEGER", nullable: false)
+                },
+                constraints: table =>
+                {
+                    table.PrimaryKey("PK_UsersWhoWere", x => x.Id);
+                    table.ForeignKey(
+                        name: "FK_UsersWhoWere_Users_UserId",
+                        column: x => x.UserId,
+                        principalTable: "Users",
+                        principalColumn: "Id",
+                        onDelete: ReferentialAction.Cascade);
+                });
+
+            migrationBuilder.CreateIndex(
+                name: "IX_UsersWhoWere_UserId",
+                table: "UsersWhoWere",
+                column: "UserId");
+        }
+
+        /// <inheritdoc />
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropTable(
+                name: "UsersWhoWere");
+        }
+    }
+}
--- a/KfChatDotNetBot/Migrations/ApplicationDbContextModelSnapshot.cs
+++ b/KfChatDotNetBot/Migrations/ApplicationDbContextModelSnapshot.cs
@@ -273,6 +273,31 @@ namespace KfChatDotNetBot.Migrations
                    b.ToTable("Users");
                });

+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.UserWhoWasDbModel", b =>
+                {
+                    b.Property<int>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("INTEGER");
+
+                    b.Property<int>("ActivityType")
+                        .HasColumnType("INTEGER");
+
+                    b.Property<DateTimeOffset>("FirstOccurence")
+                        .HasColumnType("TEXT");
+
+                    b.Property<DateTimeOffset>("LatestOccurence")
+                        .HasColumnType("TEXT");
+
+                    b.Property<int>("UserId")
+                        .HasColumnType("INTEGER");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("UserId");
+
+                    b.ToTable("UsersWhoWere");
+                });
+
            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.JuicerDbModel", b =>
                {
                    b.HasOne("KfChatDotNetBot.Models.DbModels.UserDbModel", "User")
@@ -283,6 +308,17 @@ namespace KfChatDotNetBot.Migrations

                    b.Navigation("User");
                });
+
+            modelBuilder.Entity("KfChatDotNetBot.Models.DbModels.UserWhoWasDbModel", b =>
+                {
+                    b.HasOne("KfChatDotNetBot.Models.DbModels.UserDbModel", "User")
+                        .WithMany()
+                        .HasForeignKey("UserId")
+                        .OnDelete(DeleteBehavior.Cascade)
+                        .IsRequired();
+
+                    b.Navigation("User");
+                });
 #pragma warning restore 612, 618
        }
    }
--- a/KfChatDotNetBot/Models/DbModels/UserDbModel.cs
+++ b/KfChatDotNetBot/Models/DbModels/UserDbModel.cs
@@ -19,4 +19,20 @@ public enum UserRight
    [Description("Rat")]
    Guest = 10,
    Loser = 0
+}
+
+public enum WhoWasActivityType
+{
+    Join,
+    Part,
+    Message
+}
+
+public class UserWhoWasDbModel
+{
+    public int Id { get; set; }
+    public required UserDbModel User { get; set; }
+    public required DateTimeOffset FirstOccurence { get; set; }
+    public required DateTimeOffset LatestOccurence { get; set; }
+    public required WhoWasActivityType ActivityType { get; set; }
 }