feat: upserting twitch user records

Author: ProgrammingByPermutation

src/Nullinside.Api.TwitchBot.Tests/ChatRules/BestCheapViewersTests.cs

@@ -41,6 +41,7 @@ public class BestCheapViewersTests : AChatRuleUnitTestBase<BestCheapViewers> {
   [TestCase("Chea̓p viewers on streamboo. com (remove the space)  @ND80DOGe")]
   [TestCase("Bestͮ vie͐wers ̷on cutt.ly/EeK6Anda")] 
   [TestCase("Bestͮ vie͐wers ̷on viewerszone.online")]
+  [TestCase("Best viěw\u0310e\u0329rs \u0333o\u032bno\u034en streamboo .com ( remove the space )  @WSZ7tPNI")]
   public async Task TestKnownStrings(string badString) {
     var rule = new BestCheapViewers();
     var botProxy = new Mock<ITwitchApiProxy>();

src/Nullinside.Api.TwitchBot.Tests/Nullinside.Api.TwitchBot.Tests.csproj

@@ -14,8 +14,8 @@
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>
-        <PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="8.0.11" />
-        <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.11" />
+        <PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="8.0.13" />
+        <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.13" />
         <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.11.1"/>
         <PackageReference Include="Moq" Version="4.20.72"/>
         <PackageReference Include="NUnit" Version="4.2.2"/>

src/Nullinside.Api.TwitchBot/Model/NullinsideContextExtensions.cs

@@ -161,30 +161,20 @@ private static async Task<int> UpdateOAuthInDatabase(this INullinsideContext db,
   /// <param name="stoppingToken">The stopping token.</param>
   public static async Task SaveTwitchBans(this INullinsideContext db, string channelId,
     IEnumerable<(string Id, string Username)> bannedUsers, string reason, CancellationToken stoppingToken = new()) {
-    List<string> banUserIds = bannedUsers.Select(b => b.Id).ToHashSet().ToList();
-    HashSet<string?> existingUsers = db.TwitchUser
-      .AsNoTracking()
-      .Where(u => null != u.TwitchId && banUserIds.Contains(u.TwitchId))
-      .Select(u => u.TwitchId)
-      .ToHashSet();
-
-    List<TwitchUser> nonExistantUsers = banUserIds
-      .Where(u => !existingUsers.Contains(u))
-      .Select(c => new TwitchUser {
-        TwitchId = c,
-        TwitchUsername = bannedUsers.FirstOrDefault(u => string.Equals(u.Id, c)).Username
-      })
-      .ToList();
-
-    db.TwitchUser.UpdateRange(nonExistantUsers);
-    db.TwitchBan
-      .AddRange(banUserIds
-        .Select(i => new TwitchBan {
-          ChannelId = channelId,
-          BannedUserTwitchId = i,
-          Reason = reason,
-          Timestamp = DateTime.UtcNow
-        }));
+    await db.TwitchUser.UpsertRange(
+        bannedUsers.Select(c => new TwitchUser { TwitchId = c.Id, TwitchUsername = c.Username })
+          .ToList()
+      )
+      .On(v => new { v.TwitchId })
+      .RunAsync(stoppingToken);
+
+    db.TwitchBan.AddRange(
+      bannedUsers.Select(i => new TwitchBan {
+        ChannelId = channelId,
+        BannedUserTwitchId = i.Id,
+        Reason = reason,
+        Timestamp = DateTime.UtcNow
+      }));
     await db.SaveChangesAsync(stoppingToken);
   }
 }

src/Nullinside.Api.TwitchBot/Nullinside.Api.TwitchBot.csproj

@@ -21,9 +21,10 @@
     </ItemGroup>
 
     <ItemGroup>
+        <PackageReference Include="FlexLabs.EntityFrameworkCore.Upsert" Version="8.1.2" />
         <PackageReference Include="log4net.Ext.Json" Version="2.0.10.1"/>
-        <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.11" />
-        <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="8.0.11">
+        <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.13" />
+        <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="8.0.13">
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>